midasServer.cxx File Reference

#include <stdio.h>
#include <stdint.h>
#include <assert.h>
#include "midasServer.h"
#include <TROOT.h>
#include <TSemaphore.h>
#include <TFolder.h>
#include <TSocket.h>
#include <TServerSocket.h>
#include <TThread.h>
#include <TMessage.h>
#include <TObjString.h>
#include <TObjArray.h>
#include <TH1.h>
#include <TCutG.h>
#include "RootLock.h"
#include <map>
#include <string>

Include dependency graph for midasServer.cxx:

Go to the source code of this file.

Defines
#define	XPOINTER_T   uint32_t
Functions
void	VerboseMidasServer (bool verbose)
TFolder *	ReadFolderPointer (TSocket *fSocket)
void	root_server_thread (void *arg)
void	root_socket_server (void *arg)
void	StartMidasServer (int port)
Variables
static bool	gVerbose = false
static std::map< XPOINTER_T, std::string >	gPointers
static std::map< std::string, XPOINTER_T >	gRevPointers
static XPOINTER_T	gLastPointer = 0
TFolder *	gManaHistosFolder = NULL

---

Define Documentation

#define XPOINTER_T   uint32_t

Definition at line 49 of file midasServer.cxx.

Referenced by ReadFolderPointer(), and root_server_thread().

---

Function Documentation

TFolder* ReadFolderPointer

(

TSocket *

fSocket

)

Definition at line 55 of file midasServer.cxx.

References gManaHistosFolder, gPointers, gVerbose, and XPOINTER_T.

Referenced by root_server_thread().

{
   //read pointer to current folder
   TMessage *m = 0;
   fSocket->Recv(m);
   XPOINTER_T p;
   *m >> p;

   const char* name = gPointers[p].c_str();

   if (gVerbose)
     printf("converted %d to \'%s\'\n", p, name);

   TObject* obj = gROOT->FindObjectAny(name);

   if (!obj)
     obj = gManaHistosFolder;

   return (TFolder*) obj;
}

Here is the caller graph for this function:

void root_server_thread

(

void *

arg

)

Definition at line 78 of file midasServer.cxx.

References gLastPointer, gManaHistosFolder, gPointers, gRevPointers, gVerbose, ReadFolderPointer(), LockRootGuard::Unlock(), and XPOINTER_T.

Referenced by root_socket_server(), and socket_listener().

{
   char request[256];

   TSocket *sock = (TSocket *) arg;
   TMessage message(kMESS_OBJECT);

   do {

      /* close connection if client has disconnected */
      int rd = sock->Recv(request, sizeof(request));
      if (rd <= 0) {
         // printf("Closed connection to %s\n", sock->GetInetAddress().GetHostName());
         sock->Close();
         delete sock;
         return;
      }

      if (gVerbose)
        printf("Request %s\n", request);

      if (strcmp(request, "GetListOfFolders") == 0) {

        LockRootGuard lock;
        
        TFolder *folder = ReadFolderPointer(sock);
        if (folder == NULL) {
          message.Reset(kMESS_OBJECT);
          message.WriteObject(NULL);
          lock.Unlock();
          sock->Send(message);
          continue;
        }
        //get folder names
        TObject *obj;
        TObjArray *names = new TObjArray(100);
        
        TCollection *folders = folder->GetListOfFolders();
        TIterator *iterFolders = folders->MakeIterator();
        while ((obj = iterFolders->Next()) != NULL)
          names->Add(new TObjString(obj->GetName()));
        
        //write folder names
        message.Reset(kMESS_OBJECT);
        message.WriteObject(names);
        sock->Send(message);
        
        for (int i = 0; i < names->GetLast() + 1; i++)
          delete(TObjString *) names->At(i);
        
        delete names;
        
      } else if (strncmp(request, "FindObject", 10) == 0) {
        
        LockRootGuard lock;

        TFolder *folder = ReadFolderPointer(sock);
        
        //get object
        TObject *obj;
        if (strncmp(request + 10, "Any", 3) == 0)
          obj = folder->FindObjectAny(request + 14);
        else
          obj = folder->FindObject(request + 11);
        
        //write object
        if (!obj)
          sock->Send("Error");
        else {
          message.Reset(kMESS_OBJECT);
          message.WriteObject(obj);

          lock.Unlock();
          sock->Send(message);
        }
        
      } else if (strncmp(request, "FindFullPathName", 16) == 0) {
        
        LockRootGuard lock;

        TFolder *folder = ReadFolderPointer(sock);
        
        //find path
        const char *path = folder->FindFullPathName(request + 17);
        
        //write path
        if (!path) {
          sock->Send("Error");
        } else {
          TObjString *obj = new TObjString(path);
          message.Reset(kMESS_OBJECT);
          message.WriteObject(obj);
          lock.Unlock();
          sock->Send(message);
          delete obj;
        }
        
      } else if (strncmp(request, "GetPointer", 10) == 0) {

        //find object
        XPOINTER_T p = 0;
        TObject *obj = gROOT->FindObjectAny(request + 11);
        
        //write pointer
        message.Reset(kMESS_ANY);

        if (obj)
          {
            const char* name = obj->GetName();
            p = gRevPointers[name];
            if (p==0)
              {
                p = ++gLastPointer;
                gPointers[p] = name;
                gRevPointers[name] = p;
              }

            if (gVerbose)
              printf("give %d for \'%s\'\n", p, name);
          }

        message << p;
        sock->Send(message);
        
      } else if (strncmp(request, "Command", 7) == 0) {
        char objName[100], method[100];
        sock->Recv(objName, sizeof(objName));
        sock->Recv(method, sizeof(method));

        LockRootGuard lock;

        TObject *object = gROOT->FindObjectAny(objName);
        if (object && object->InheritsFrom(TH1::Class())
            && strcmp(method, "Reset") == 0)
          static_cast < TH1 * >(object)->Reset();
        
      } else if (strncmp(request, "SetCut", 6) == 0) {
        
        //read new settings for a cut
        char name[256];
        sock->Recv(name, sizeof(name));

        LockRootGuard lock;

        TCutG *cut = (TCutG *) gManaHistosFolder->FindObjectAny(name);
        
        TMessage *m = 0;
        sock->Recv(m);
        TCutG *newc = ((TCutG *) m->ReadObject(m->GetClass()));
        
        if (cut) {
          fprintf(stderr, "root server thread: changing cut %s\n", newc->GetName());
          newc->TAttMarker::Copy(*cut);
          newc->TAttFill::Copy(*cut);
          newc->TAttLine::Copy(*cut);
          newc->TNamed::Copy(*cut);
          cut->Set(newc->GetN());
          for (int i = 0; i < cut->GetN(); ++i) {
            cut->SetPoint(i, newc->GetX()[i], newc->GetY()[i]);
          }
        } else {
          fprintf(stderr, "root server thread: ignoring receipt of unknown cut \'%s\'\n",
                  newc->GetName());
        }
        delete newc;
        
      } else {
        fprintf(stderr, "midasServer: Received unknown request \"%s\"\n", request);
      }

   } while (1);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void root_socket_server

(

void *

arg

)

Definition at line 256 of file midasServer.cxx.

References root_server_thread().

Referenced by StartMidasServer(), and StartNetDirectoryServer().

{
// Server loop listening for incoming network connections on specified port.
// Starts a searver_thread for each connection.
   int port;

   port = *(int *) arg;

   printf("MIDAS ROOT server listening on port %d...\n", port);
   TServerSocket *lsock = new TServerSocket(port, kTRUE);

   do {
      TSocket *sock = lsock->Accept();

      if (sock==NULL) {
        fprintf(stderr, "MIDAS ROOT server accept() error\n");
        break;
      }

      // printf("Established connection to %s\n", sock->GetInetAddress().GetHostName());

      TThread *thread = new TThread("Server", root_server_thread, (void*)sock);
      thread->Run();
#if 0
      LPDWORD lpThreadId = 0;
      CloseHandle(CreateThread(NULL, 1024, &root_server_thread, sock, 0, lpThreadId));
#endif
   } while (1);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void StartMidasServer

(

int

port

)

Definition at line 290 of file midasServer.cxx.

References gManaHistosFolder, root_socket_server(), and StartLockRootTimer().

Referenced by main().

{
  /* create the folder for analyzer histograms */
  gManaHistosFolder = gROOT->GetRootFolder()->AddFolder("histos", "MIDAS Analyzer Histograms");
  gROOT->GetListOfBrowsables()->Add(gManaHistosFolder, "histos");

  StartLockRootTimer();
  
  static int pport = port;

  TThread *thread = new TThread("server_loop", root_socket_server, (void*)&pport);
  thread->Run();

#if 0
  LPDWORD lpThreadId = 0;
  CloseHandle(CreateThread(NULL, 1024, &root_socket_server, &pport, 0, lpThreadId));
#endif
}

Here is the call graph for this function:

Here is the caller graph for this function:

void VerboseMidasServer

(

bool

verbose

)

Definition at line 37 of file midasServer.cxx.

References gVerbose.

{
  fprintf(stderr, "VerboseMidasServer: change verbose level from %d to %d\n", gVerbose, verbose);
  gVerbose = verbose;
}

---

Variable Documentation

XPOINTER_T gLastPointer = 0 [static]

Definition at line 53 of file midasServer.cxx.

Referenced by root_server_thread().

TFolder* gManaHistosFolder = NULL

Definition at line 288 of file midasServer.cxx.

Referenced by endRun(), HandleSample(), main(), ReadFolderPointer(), root_server_thread(), and StartMidasServer().

std::map<XPOINTER_T,std::string> gPointers [static]

Definition at line 51 of file midasServer.cxx.

Referenced by ReadFolderPointer(), and root_server_thread().

std::map<std::string,XPOINTER_T> gRevPointers [static]

Definition at line 52 of file midasServer.cxx.

Referenced by root_server_thread().

bool gVerbose = false [static]

Definition at line 35 of file midasServer.cxx.

Referenced by ReadFolderPointer(), root_server_thread(), and VerboseMidasServer().