#include <iostream>
#include <TThread.h>
+#include <TFile.h>
using namespace std;
/* parameters:
-
-0 - connect directly to reconstruction socket
-1 - connect to Storage Manager and ask for last event
-2 - connect to alieventserver, receive in thread and use in main thread
-
-*/
+
+ 0 - connect directly to reconstruction socket
+ 1 - connect to Storage Manager and ask for last event
+ 2 - connect to alieventserver, receive in thread and use in main thread
+
+ */
// global variables:
AliESDEvent *currentEvent[2];
int main(int argc, char **argv)
{
- if(argc<2)
- {
- cout<<"Usage: alifakedisplay <mode>"<<endl;
- cout<<"mode:"<<endl;
- cout<<"0 - connect directly to reconstruction socket"<<endl;
- cout<<"1 - connect to Storage Manager and ask for last event"<<endl;
- return 0;
- }
+ if(argc<2)
+ {
+ cout<<"Usage: alifakedisplay <mode>"<<endl;
+ cout<<"mode:"<<endl;
+ cout<<"0 - connect directly to reconstruction socket"<<endl;
+ cout<<"1 - connect to Storage Manager and ask for last event"<<endl;
+ cout<<"3 - connect to Storage Manager, download list of perm events and ask for them in loop"<<endl;
+ return 0;
+ }
+
+ storageSockets socket;
+ AliStorageEventManager *manager = AliStorageEventManager::GetEventManagerInstance();
+ AliESDEvent *event;
+ struct recPointsStruct *files;
+
+ if(atoi(argv[1])==0)
+ {
+ manager->CreateSocket(EVENTS_SERVER_SUB);
+ manager->CreateSocket(ITS_POINTS_SUB);
+ cout<<"Socket created"<<endl;
+ while(1)
+ {
+ cout<<"waiting for event..."<<flush;
+ event = manager->GetEvent(EVENTS_SERVER_SUB);
+
+ if(event)
+ {
+ cout<<"Received event. Run:"<<event->GetRunNumber()<<"\t event:"<<event->GetEventNumberInFile()<<endl;
+
+ cout<<event->GetPeriodNumber()<<endl;
+ cout<<event->GetOrbitNumber()<<endl;
+ cout<<event->GetBunchCrossNumber()<<endl;
+ for(int i=0;i<100;i++)
+ {
+ if(strcmp(event->GetESDRun()->GetTriggerClass(i),"")){
+ cout<<event->GetESDRun()->GetTriggerClass(i)<<endl;}
+ }
+ delete event;event=0;
+ }
+ else
+ {
+ cout<<"NO EVENT"<<endl;
+ }
+
+ // Receiving RecPoints:
+ /*
- storageSockets socket;
- AliStorageEventManager *manager = AliStorageEventManager::GetEventManagerInstance();
- AliESDEvent *event;
-
- if(atoi(argv[1])==0)
- {
- socket = EVENTS_SERVER_SUB;
- manager->CreateSocket(socket);
- while(1)
- {
- event = manager->GetEvent(socket);
- if(event)
- {
- cout<<"Received event. Run:"<<event->GetRunNumber()<<"\t event:"<<event->GetEventNumberInFile()<<endl;
+ files = manager->GetFiles(ITS_POINTS_SUB);
- cout<<event->GetPeriodNumber()<<endl;
- cout<<event->GetOrbitNumber()<<endl;
- cout<<event->GetBunchCrossNumber()<<endl;
- for(int i=0;i<100;i++)
- {
- if(strcmp(event->GetESDRun()->GetTriggerClass(i),"")){
- cout<<event->GetESDRun()->GetTriggerClass(i)<<endl;}
- }
- delete event;
- }
- else
- {
- cout<<"NO EVENT"<<endl;
- }
- }
- }
- else if(atoi(argv[1])==1)
- {
- socket = SERVER_COMMUNICATION_REQ;
- manager->CreateSocket(socket);
- while(1)
- {
- struct serverRequestStruct *requestMessage = new struct serverRequestStruct;
- requestMessage->messageType = REQUEST_GET_LAST_EVENT;
+
+ cout<<"Received file."<<endl;
- manager->Send(requestMessage,socket);
- event = manager->GetEvent(socket);
- if(event)
- {
- cout<<"Last event - Run:"<<event->GetRunNumber()<<"\t event:"<<event->GetEventNumberInFile()<<endl;
-
- delete event;
- }
- else
- {
- cout<<"NO EVENT"<<endl;
- }
- sleep(1);
- }
- }
- else if(atoi(argv[1])==2)
- {
- TThread *getEventThread = new TThread("getEventThread",GetNextEvent,nullptr);
- getEventThread->Run();
+ //file->Write("ITS.RecPoints.root",kOverwrite);
+ if(files->files[0]){files->files[0]->SaveAs("ITS.RecPoints.root","recreate");}
+ if(files->files[1]){files->files[1]->SaveAs("TOF.RecPoints.root","recreate");}
+ if(files->files[2]){files->files[2]->SaveAs("galice.root","recreate");}
- int counter=0;
-
- while(1)
- {
+ for(int i=0;i<10;i++)
+ {
+ if(files->files[i])
+ {
+ files->files[i]->Close();
+ delete files->files[i];files->files[i]=0;
+ }
+ }
+ sleep(2);
+ */
+ }
+ }
+ else if(atoi(argv[1])==1)
+ {
+ socket = SERVER_COMMUNICATION_REQ;
+ manager->CreateSocket(socket);
+ while(1)
+ {
+ struct serverRequestStruct *requestMessage = new struct serverRequestStruct;
+ requestMessage->messageType = REQUEST_GET_LAST_EVENT;
+
+ manager->Send(requestMessage,socket);
+ event = manager->GetEvent(socket);
+ if(event)
+ {
+ cout<<"Last event - Run:"<<event->GetRunNumber()<<"\t event:"<<event->GetEventNumberInFile()<<endl;
+
+ delete event;
+ }
+ else
+ {
+ cout<<"NO EVENT"<<endl;
+ }
+ sleep(1);
+ }
+ }
+ else if(atoi(argv[1])==2)
+ {
+ TThread *getEventThread = new TThread("getEventThread",GetNextEvent,nullptr);
+ getEventThread->Run();
+
+ int counter=0;
+
+ while(1)
+ {
counter++;
if(isNewEventAvaliable)
{
- cout<<"new event"<<endl;
- myMutex.Lock();
- if(writingToEventIndex == 0) eventInUse = 0;
- else if(writingToEventIndex == 1) eventInUse = 1;
- cout<<"Using:"<<eventInUse<<endl;
-
- if(currentEvent[eventInUse])
- {
- if(currentEvent[eventInUse]->GetRunNumber() >= 0)
+ cout<<"new event"<<endl;
+ myMutex.Lock();
+ if(writingToEventIndex == 0) eventInUse = 0;
+ else if(writingToEventIndex == 1) eventInUse = 1;
+ cout<<"Using:"<<eventInUse<<endl;
+
+ if(currentEvent[eventInUse])
{
- cout<<"CURRENT EVENT:"<<currentEvent[eventInUse]->GetEventNumberInFile()<<endl;
+ if(currentEvent[eventInUse]->GetRunNumber() >= 0)
+ {
+ cout<<"CURRENT EVENT:"<<currentEvent[eventInUse]->GetEventNumberInFile()<<endl;
+ }
}
- }
- isNewEventAvaliable = false;
- myMutex.UnLock();
+ isNewEventAvaliable = false;
+ myMutex.UnLock();
}
else{cout<<"No new event is avaliable."<<endl;}
-
+
sleep(2);
- }
- }
+ }
+ }
+ else if(atoi(argv[1])==3)
+ {
+ socket = SERVER_COMMUNICATION_REQ;
+ manager->CreateSocket(socket);
+
+
+ struct listRequestStruct list;
+ list.runNumber[0]=0;
+ list.runNumber[1]=999999;
+ list.eventNumber[0]=0;
+ list.eventNumber[1]=999999;
+ list.marked[0]=1;
+ list.marked[1]=1;
+ list.multiplicity[0]=1;
+ list.multiplicity[1]=999999;
+ strcpy(list.system[0],"p-p");
+ strcpy(list.system[1],"A-A");
+ struct serverRequestStruct *requestMessage = new struct serverRequestStruct;
+ requestMessage->messageType = REQUEST_LIST_EVENTS;
+ requestMessage->list = list;
+
+ manager->Send(requestMessage,socket);
+ vector<serverListStruct> receivedList = manager->GetServerListVector(socket,3000);
+
+ cout<<"FAKE DISPLAY -- received list of marked events"<<endl;
+
+ for(int i=0;i<receivedList.size();i++){
+ cout<<"ev:"<<receivedList[i].eventNumber<<endl;
+ }
- return 0;
+ int iter=0;
+ while(1)
+ {
+ if(iter<receivedList.size())
+ {
+ struct eventStruct mark;
+ mark.runNumber = receivedList[iter].runNumber;
+ mark.eventNumber = receivedList[iter].eventNumber;
+
+ requestMessage->messageType = REQUEST_GET_EVENT;
+ requestMessage->event = mark;
+
+ manager->Send(requestMessage,socket);
+ event = manager->GetEvent(socket);
+
+ if(event)
+ {
+ cout<<"i:"<<iter<<"\tevent:"<<event->GetEventNumberInFile()<<endl;
+ }
+ else
+ {
+ cout<<"Received NO event"<<endl;
+ }
+ iter++;
+ sleep(1);
+ }
+ else{iter=0;}
+ }
+ }
+
+ return 0;
}
void* GetNextEvent(void*)
{
- AliStorageEventManager *eventManager = AliStorageEventManager::GetEventManagerInstance();
- eventManager->CreateSocket(EVENTS_SERVER_SUB);
-
- currentEvent[0]=0;
- currentEvent[1]=0;
- currentTree[0]=0;
- currentTree[1]=0;
- AliESDEvent *tmpEvent;
-
- while(1)
- {
- //if(tmpEvent){delete tmpEvent;tmpEvent=0;}
- tmpEvent = eventManager->GetEvent(EVENTS_SERVER_SUB);
-
- if(tmpEvent)
+ AliStorageEventManager *eventManager = AliStorageEventManager::GetEventManagerInstance();
+ eventManager->CreateSocket(EVENTS_SERVER_SUB);
+
+ currentEvent[0]=0;
+ currentEvent[1]=0;
+ currentTree[0]=0;
+ currentTree[1]=0;
+ AliESDEvent *tmpEvent;
+
+ while(1)
{
- if(tmpEvent->GetRunNumber()>=0)
- {
- myMutex.Lock();
- if(eventInUse == 0){writingToEventIndex = 1;}
- else if(eventInUse == 1){writingToEventIndex = 0;}
-
- if(currentEvent[writingToEventIndex])
+ //if(tmpEvent){delete tmpEvent;tmpEvent=0;}
+ tmpEvent = eventManager->GetEvent(EVENTS_SERVER_SUB);
+
+ if(tmpEvent)
{
- delete currentEvent[writingToEventIndex];
- currentEvent[writingToEventIndex]=0;
- }
- currentEvent[writingToEventIndex] = tmpEvent;
- isNewEventAvaliable = true;
- myMutex.UnLock();
- }
- }
- }
+ if(tmpEvent->GetRunNumber()>=0)
+ {
+ myMutex.Lock();
+ if(eventInUse == 0){writingToEventIndex = 1;}
+ else if(eventInUse == 1){writingToEventIndex = 0;}
+
+ if(currentEvent[writingToEventIndex])
+ {
+ delete currentEvent[writingToEventIndex];
+ currentEvent[writingToEventIndex]=0;
+ }
+ currentEvent[writingToEventIndex] = tmpEvent;
+ isNewEventAvaliable = true;
+ myMutex.UnLock();
+ }
+ }
+ }
}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff