---

/Go4TaskHandler/TGo4Master.cxx

Go to the documentation of this file.

//---------------------------------------------------------------
//        Go4 Release Package v2.10-5 (build 21005) 
//                      03-Nov-2005
//---------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//       Experiment Data Processing at DVEE department, GSI
//---------------------------------------------------------------
//
//Copyright (C) 2000- Gesellschaft f. Schwerionenforschung, GSI
//                    Planckstr. 1, 64291 Darmstadt, Germany
//Contact:            http://go4.gsi.de
//----------------------------------------------------------------
//This software can be used under the license agreements as stated
//in Go4License.txt file which is part of the distribution.
//----------------------------------------------------------------
/* Generated by Together */

#include "TGo4Master.h"

#include "Go4Log/TGo4Log.h"
#include "TGo4Task.h"
#include "TGo4ServerTask.h"
#include "TGo4ClientTask.h"
#include "Go4CommandsBase/TGo4CommandInvoker.h"
#include "Go4CommandsTaskHandler/TGo4TaskHandlerCommandList.h"
#include "TGo4LocalCommandRunnable.h"
#include "Go4Queue/TGo4ObjectQueue.h"
#include <Rtypes.h>

TGo4Master::TGo4Master(const char* name, Bool_t isserver, const char* serverhost, UInt_t negotport) 
: TGo4TaskOwner(isserver)
{ 
   TGo4CommandInvoker::Instance(); // make sure a command invoker exists
   TGo4CommandInvoker::Register("MasterTask", this);
   TGo4Task* task=0;
   if(IsServer())
      {
         task=new TGo4ServerTask(name, negotport, 
               kFALSE, //blockingmode
               kFALSE, //standalone 
               kTRUE,  //autostart
               kTRUE,  //autocreate 
               kTRUE   //ismaster 
               );  
      }     
   else
      {
         task=new TGo4ClientTask(name, serverhost, negotport,
                     kFALSE, //blockingmode
                     kFALSE, //standalone
                     kFALSE, //autostart
                     kTRUE,  //autocreate
                     kTRUE, //ismaster
                     kFALSE); // autoconnect
      } 
   SetTask(task);
}



TGo4Master::TGo4Master() 
{ 
   
}

TGo4Master::~TGo4Master() 
{ 
  
}

TGo4TaskHandlerCommandList* TGo4Master::CreateCommandList()
{
   return (new TGo4TaskHandlerCommandList("Go4ServerTaskDefaultCommandList") );
}

Bool_t TGo4Master::SubmitCommand(const char* name)
{
   return (GetTask()->SubmitCommand(name));
}

Bool_t TGo4Master::SubmitEmergencyCommand(Go4EmergencyCommand_t val)
{
   return (GetTask()->SubmitEmergencyCommand(val));
}
Bool_t TGo4Master::SubmitCommand(TGo4Command* com)
{
   return (GetTask()->SubmitCommand(com));
}

void TGo4Master::SetSlave(const char* node, const char* shell, const char* command)
{
fxSlaveNode=node;
fxSlaveShell=shell;
fxSlaveExec=command;      
}

const char * TGo4Master::GetSlaveNode()
{
   return fxSlaveNode.Data();
}

const char * TGo4Master::GetSlaveShell()
{
   return fxSlaveShell.Data();   
}

const char * TGo4Master::GetSlaveExec()
{
   return fxSlaveExec.Data();   
}
void TGo4Master::StartSlaveWindow(const char*)
{
   
}
Bool_t TGo4Master::ConnectSlave(const char* name, 
                                const char* remotehost,
                                UInt_t negport, 
                                const char* remotedir, 
                                const char* remotecommand, 
                                Int_t mode,
                                Bool_t startserver, 
                                Go4CommandMode_t role,
                                const char* passwd
                                )
{
Bool_t rev=kTRUE;
if(IsServer())
   {
      TGo4ServerTask* server=dynamic_cast<TGo4ServerTask*> (GetTask());
      if(server) 
         {
            if(server->LaunchClient(name, 
                                    remotehost, 
                                    remotedir,
                                    remotecommand, 
                                    mode
                                    ) !=0) 
               rev=kFALSE;  
            else
               rev=kTRUE;
         }
   }
else
   {
      if(startserver)
         {
            //cout <<"MMMMMMM Master ConnectSlave sees startserver flag..." << endl;
            LaunchSlaveServer(name, 
                                    remotehost, 
                                    remotedir,
                                    remotecommand, 
                                    mode
                                    );
            rev=kFALSE; // not yet connected
         }
      else
         {
            TGo4ClientTask* client=dynamic_cast<TGo4ClientTask*> (GetTask());
            if(client) 
               rev=client->ConnectServer(remotehost,negport, role, passwd);
            else
               rev=kFALSE;
         }
   }
return rev;
}


Bool_t TGo4Master::DisconnectSlave(const char* name, Bool_t waitforslave)
{
Bool_t rev=kTRUE;
if(IsServer())
   {
      TGo4ServerTask* server=dynamic_cast<TGo4ServerTask*> (GetTask());
      if(server)
         rev=server->RemoveClient(name, waitforslave); //waitforclient
      else
         rev=kFALSE;
   }
else
   {
      TGo4ClientTask* client=dynamic_cast<TGo4ClientTask*> (GetTask());
      if(client)
         rev=client->DisconnectServer();
      else
         rev=kFALSE;
   }   
return rev;   
}

Int_t TGo4Master::LaunchSlaveServer(const char* name, 
                                const char* remotehost, 
                                const char* remotedir, 
                                const char* remotecommand,  
                                Int_t mode)
{
   Int_t rev = 0;
   UInt_t negport=1234; //dummy
   Text_t commandstring[5*TGo4ThreadManager::fguTEXTLENGTH];
   Text_t formatstring[2*TGo4ThreadManager::fguTEXTLENGTH];
   Text_t filename[2*TGo4ThreadManager::fguTEXTLENGTH];
   Text_t shcom[TGo4ThreadManager::fguTEXTLENGTH];
  Text_t serverdisplay[TGo4ThreadManager::fguTEXTLENGTH];
   if(mode & TGo4ServerTask::kSecureShell)
      sprintf(shcom,"ssh ");
   else
      sprintf(shcom,"rsh -n");
   const Text_t* serverhost=gSystem->HostName();
   const Text_t* sdisplay=gSystem->Getenv("DISPLAY");
   const Text_t* go4system=gSystem->Getenv("GO4SYS");
   const Text_t* rootsystem=gSystem->Getenv("ROOTSYS");
   const Text_t* path=gSystem->Getenv("PATH");
   const Text_t* ldpath=gSystem->Getenv("LD_LIBRARY_PATH");
   snprintf(serverdisplay, 2*TGo4ThreadManager::fguTEXTLENGTH,"-display %s",sdisplay);
   if(remotehost==0)
      {
         remotehost="localhost";
      }
   else
      { }
   SetSlave(remotehost,shcom,remotecommand);

   snprintf(filename, 2*TGo4ThreadManager::fguTEXTLENGTH,
           "%s/%s",go4system, TGo4ServerTask::fgcLAUNCHPREFSFILE);
   ifstream launchprefs(filename);
   if(!launchprefs)
      {
         TGo4Log::Debug(" Master -- ERROR: Preferences file %s not existing, could not launch client ",
                  filename);
         return -1;
      }
   TGo4Log::Debug(" Master -- Launching new slave server process %s on host %s",
         name, remotehost);
  launchprefs.getline(formatstring, 2*TGo4ThreadManager::fguTEXTLENGTH, '\n' ); // skip first line (for client) 
  launchprefs.getline(formatstring, 2*TGo4ThreadManager::fguTEXTLENGTH, '\n' ); // skip second line (for client)

  launchprefs.getline(formatstring, 2*TGo4ThreadManager::fguTEXTLENGTH, '\n' ); // read third line ((for server) 
  if((mode & TGo4ServerTask::kGuiEmbed))
    {
    //   cout << "mode & kGuiEmbed  is true" << endl;
     // run without external xterm, but within the same shell window as the gui:
     // use formatstring of first line here
         snprintf(commandstring,
              5*TGo4ThreadManager::fguTEXTLENGTH-1,
              formatstring,
              shcom, remotehost, go4system, rootsystem,
                 path, ldpath, remotedir, remotecommand, name, serverhost, negport);

        StartSlaveWindow(commandstring);
    }
    else
    {
            if (mode & TGo4ServerTask::kSecureShell) {
               // start xterm window and display it on the local desktop (display of the gui)
                //cout << "kSecureShell " << kSecureShell << endl;
               launchprefs.getline(formatstring, 2*TGo4ThreadManager::fguTEXTLENGTH, '\n'); // use fourth line
               snprintf(commandstring,
                 5*TGo4ThreadManager::fguTEXTLENGTH-1,
                 formatstring,
                 shcom, remotehost, "", name, remotehost, go4system, rootsystem,
                    path, ldpath, remotedir, remotecommand, name, serverhost, negport);
            }else {
            //cout << " ELSE " << kSecureShell  << endl;
           launchprefs.getline(formatstring, 2*TGo4ThreadManager::fguTEXTLENGTH, '\n'); // use fourth  line
               snprintf(commandstring,
                 5*TGo4ThreadManager::fguTEXTLENGTH-1,
                 formatstring,
                 shcom, remotehost, serverdisplay, name, remotehost, go4system, rootsystem,
                    path, ldpath, remotedir, remotecommand, name, serverhost, negport);
            }

             rev=gSystem->Exec(commandstring);
    }
  // cout << commandstring << remotehost << "display" << serverdisplay << endl;
//
//   cout << "######## returned from gSystem->Exec() with value "<<rev<<endl;
   return rev;
}

//----------------------------END OF GO4 SOURCE FILE ---------------------

---