jobiomgr.h

Go to the documentation of this file.

#pragma once

/*+
________________________________________________________________________

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

-*/

#include "mmprocmod.h"

#include "bufstring.h"
#include "callback.h"
#include "oscommand.h"

class CommandString;
class HostData;
class JobInfo;
class JobIOHandler;
class od_ostream;
namespace File { class Path; }
template <class T> class ObjQueue;

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,float priority=-1.f,
                                 od_ostream* logstrm=0);
    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 File::Path&,
                                  const JobInfo&,const char*);

    void                setPriority( float p );
    void                reqModeForJob(const JobInfo&,Mode);
    void                removeJob(const char*,int);
    bool                isReady() const;

    ObjQueue<StatusInfo>& statusQueue();

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

    JobIOHandler&       iohdlr_;
    BufferString        msg_;
    OS::CommandExecPars execpars_;
    od_ostream*         logstrm_;

    void                mkCommand(OS::MachineCommand&,const HostData&,
                                  const char* progname,const File::Path& basefp,
                                  const File::Path& iopfp,const JobInfo&,
                                  const char* rshcomm);

};


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


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 File::Path&);

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

private:

    void                add(const char*);

    BufferString        cmd_;
    const HostData&     hstdata_;

};