jobiomgr.h

Go to the documentation of this file.

#ifndef jobiomgr_h
#define jobiomgr_h

/*+
________________________________________________________________________

 (C) dGB Beheer B.V.; (LICENSE) http://opendtect.org/OpendTect_license.txt
 Author:        A.H.Lammertink
 Date:          Oct 2004
 RCS:           $Id$
________________________________________________________________________

-*/

#include "mmprocmod.h"
#include "callback.h"
#include "bufstring.h"

class CommandString;
class FilePath;
class HostData;
class JobInfo;
class JobIOHandler;
template <class T> class ObjQueue;
namespace OS { class MachineCommand; }

mExpClass(MMProc) StatusInfo
{
public:
                        StatusInfo( char tg, int desc, int stat, int pid,
                                    const char* mg, const char* hostname,
                                    int time )
                            : tag(tg), descnr(desc), status(stat), msg(mg)
                            , hostnm(hostname), timestamp(time), procid(pid) {}

    char                tag;
    int                 descnr;
    int                 status;
    int                 timestamp;
    int                 procid;
    BufferString        hostnm;
    BufferString        msg;
};


mExpClass(MMProc) JobIOMgr : public CallBacker
{
public:
    enum                Mode { Work, Pause, Stop };

                        JobIOMgr(int firstport=19345,int niceval=19);
    virtual             ~JobIOMgr();

    const char*         peekMsg()  { if ( msg_.size() ) return msg_; return 0; }
    void                fetchMsg( BufferString& bs )    { bs = msg_; msg_ = "";}

    bool                startProg(const char*,IOPar&,const FilePath&,
                                  const JobInfo&,const char*);

    void                setNiceNess( int n )            { niceval_ = n; }
    void                reqModeForJob(const JobInfo&,Mode);
    void                removeJob(const char*,int);
    bool                isReady() const;

    ObjQueue<StatusInfo>& statusQueue();

    static bool         mkIOParFile(const FilePath& basefnm,
                                    const HostData&,const IOPar&,
                                    FilePath&,BufferString& msg);
    static BufferString mkRexecCmd(const char* prognm,
                                   const HostData& machine,
                                   const HostData& localhost);
protected:

    JobIOHandler&       iohdlr_;
    BufferString        msg_;
    int                 niceval_;

    bool                mkIOParFile(FilePath&,const FilePath& basefnm,
                                    const HostData&,const IOPar&);
    void                mkCommand(CommandString&,const HostData&,
                                  const char* progname,const FilePath& basefp,
                                  const FilePath& iopfp,const JobInfo&,
                                  const char* rshcomm);
    void                mkCommand(OS::MachineCommand&,const HostData&,
                                  const char* progname,const FilePath& basefp,
                                  const FilePath& iopfp,const JobInfo&,
                                  const char* rshcomm);

};


mGlobal(MMProc) const OD::String& getTempBaseNm();
mGlobal(MMProc) int mkTmpFileNr();
mGlobal(MMProc) int& MMJob_getTempFileNr();


mClass(MMProc) CommandString
{
public:
                        CommandString(const HostData& targetmachine,
                                      const char* init=0);

    CommandString&      operator=(const char*);

    void                addFlag(const char* flag,const char* value);
    void                addFlag(const char* flag,int value);
    void                addFilePath(const FilePath&);

    const OD::String&   string()                { return cmd_; }

private:

    void                add(const char*);

    BufferString        cmd_;
    const HostData&     hstdata_;

};

#endif