sPhenix code displayed by LXR master/​online_distribution/​eventlibraries/​changeid.cc	Source navigation Diff markup Identifier search General search
	Version: master Revert   Change

File indexing completed on 2025-08-03 08:20:32

 #include "A_Event.h"
 #include "packet.h"
 #include "Cframe.h"
 #include "framePackets.h"
 #include "dataBlock.h"
 
 #include "frameRoutines.h"
 #include "frameHdr.h"
 
 #include "fileEventiterator.h"
 #include "testEventiterator.h"
 #include "phenixTypes.h"
 #include "ophBuffer.h"
 #include "oEvent.h"
 
 
 #include <sys/types.h>
 #include <sys/stat.h>
 #include <fcntl.h>
 
 
 
 #include <stdlib.h>
 #include <signal.h>
 #include <unistd.h>
 
 #include <stdio.h>
 
 #ifdef HAVE_GETOPT_H
 #include <getopt.h>
 #endif
 
 #define DDEVENTITERATOR 1
 #define FILEEVENTITERATOR 2
 #define TESTEVENTITERATOR 3
 #define DDPOOL 4
 #define DFILE 5
 #define DNULL 6
 
 
 
 
 class X_Event : public A_Event 
 {
 
 public:
   // constructors and destructors
   X_Event( PHDWORD *);
   X_Event( int *);
   ~X_Event();
 
    // info & debug utils
    
    int change_id(const int oldid, const int newid);
 
 
 };
 
 X_Event::X_Event (PHDWORD *data)
   : A_Event(data)
 { }
 
 X_Event::X_Event (int *data)
   : A_Event(data)
 { }
 
 X_Event::~X_Event ()
 { }
 
 int X_Event::change_id (const int oldid, const int newid)
 {
   
   int i = 0;
   PHDWORD *fp;
   PHDWORD *pp;
   UINT ids = oldid;
   
   while ( (fp = framelist[i++]) )
     {
       if ( ( pp = findFramePacketId (fp, ids) ) !=  ptrFailure) 
     {
       setPacketId (pp, newid);
     }
     }
   return 0;
 
 }
 
 
 
 
 #if defined(SunOS) || defined(Linux) || defined(OSF1)
 void sig_handler(int);
 #else
 void sig_handler(...);
 #endif
 
 
 void exitmsg()
 {
   COUT << "** usage: changeid infile outfile id1 id2 " << std::endl;
   exit(0);
 }
 
 void exithelp()
 {
   COUT <<  std::endl;
 
 }
 
 // The global pointer to the Eventiterator (we must be able to 
 // get at it in the signal handler) 
 Eventiterator *it;
 
 
 
 int 
 main(int argc, char *argv[])
 {
   int c;
   int status = 0;
 
   int eventnr = 0;
 
   extern int optind;
 
   PHDWORD  *buffer;
   oBuffer *ob;
   int fd;
   int buffer_size = 2000000;
 
   if (argc < 2) exitmsg();
 
   while ((c = getopt(argc, argv, "s:d:n:w:vhi")) != EOF)
     {
       switch (c) 
     {
       // the -s (source type) switch
     case 'h':
       exithelp();
       break;
 
     default:
       break;
     }
     }
 
 
 
   // install some handlers for the most common signals
   signal(SIGKILL, sig_handler);
   signal(SIGTERM, sig_handler);
   signal(SIGINT,  sig_handler);
 
   // see if we can open the file
 
 
   it = new fileEventiterator(argv[optind], status);
        
 
   if (status)
     {
       delete it;
       COUT << "Could not open input stream" << std::endl;
       exit(1);
     }
 
   unlink ( argv[optind+1] );
   fd = open(argv[optind+1], O_WRONLY | O_CREAT | O_EXCL | O_LARGEFILE , 
           S_IRWXU | S_IROTH | S_IRGRP );
   if ( fd < 0) 
     {
       COUT << "Could not open file: " <<  argv[optind+1] << std::endl;
       exit (1);
     }
 
   buffer = new PHDWORD [buffer_size];
   
   ob = new ophBuffer (fd, buffer, buffer_size);
 
 
   int paircount = 0;
   int idold[1000];
   int idnew[1000];
 
   int argind = 0;
   while ( optind +2 + argind +1 < argc) 
     {
       sscanf(argv[optind +2 + argind]    , "%d", &idold[paircount]); 
       sscanf(argv[optind +2 + argind + 1], "%d", &idnew[paircount]); 
       COUT << "changing  " << idold[paircount] << " -> " << idnew[paircount] << std::endl;
       argind+=2;
       paircount++;
     }
 
     
 
   // ok. now go through the events
 
   Event *evt;
   X_Event *nevt;
 
   int *eb;
   int nw;
   int j;
   while (  ( evt = it->getNextEvent())  )
     {
 
 
       eb = new int [evt->getEvtLength() +100];
       evt->Copy (eb, evt->getEvtLength() +100, &nw);
       nevt = new X_Event(eb);
       for (j=0; j<paircount; j++)
     nevt->change_id(idold[j] , idnew[j]);
 
       ob->addEvent(nevt);
 
 
       eventnr++;
 
       delete evt;
       delete nevt;
       delete [] eb;
 
     }
   delete it;
 
 
   delete ob;
   close(fd);
       
   return 0;
 }
     
 
 #if defined(SunOS) || defined(Linux) || defined(OSF1)
 void sig_handler(int i)
 #else
   void sig_handler(...)
 #endif
 {
   COUT << "sig_handler: signal seen " << std::endl;
   if (it) delete it;
   exit(0);
 }
 
 
   

This page was automatically generated by the 2.3.7 LXR engine. The LXR team