#include "dabc/logging.h"
#include "dabc/timing.h"
#include "dabc/ModuleSync.h"
#include "dabc/Port.h"
#include "dabc/Timer.h"
#include "dabc/Command.h"
#include "dabc/Manager.h"
#include "dabc/MemoryPool.h"
#include "dabc/PoolHandle.h"
#include "dabc/threads.h"
#include "dabc/Application.h"
#include "dabc/SocketDevice.h"
#include "dabc/statistic.h"
#include "dabc/Factory.h"
#include "dabc/Configuration.h"
#include "mbs/MbsTypeDefs.h"
#include "mbs/Iterator.h"
#include <string>
#include <vector>
#include <map>
Go to the source code of this file.
typedef std::map<uint32_t,int> SubeventsMap |
Definition at line 112 of file oct12-sorter.cxx.
enum ERocMbsTypes |
Definition at line 25 of file oct12-sorter.cxx.
dabc::FactoryPlugin cernoct12 | ( | new | CernOct12Factory"cern-oct12" | ) |
int GetEventNumber | ( | uint32_t | id, | |
void * | dataptr, | |||
int | datalen | |||
) |
Definition at line 66 of file oct12-sorter.cxx.
References last_master(), last_mastertm(), last_slave(), proc_CERN_Oct12, proc_EPICS, proc_FASP, proc_RocEvent, proc_SlaveMbs, proc_TRBEvent, proc_TRD_Spadic, and proc_Triglog.
std::string GetHeaderInfo | ( | uint32_t | id | ) |
Definition at line 44 of file oct12-sorter.cxx.
References proc_CERN_Oct11, proc_CERN_Oct12, proc_EPICS, proc_ErrEvent, proc_FASP, proc_MergedEvent, proc_RawData, proc_RocEvent, proc_SlaveMbs, proc_TRBEvent, proc_TRD_MADC, proc_TRD_Spadic, and proc_Triglog.
int last_master | ( | 0 | ) |
int last_mastertm | ( | 0 | ) |
Referenced by GetEventNumber().
int last_slave | ( | 0 | ) |
int mbseventid | ( | 0 | ) |
Referenced by CernOct12SorterModule::NormalLoop().
void RunSorter | ( | ) |
Definition at line 576 of file oct12-sorter.cxx.
const int FaspBlockSize = 44 |
Definition at line 571 of file oct12-sorter.cxx.
Referenced by fasp::Transport::CloseCurrentEvent(), fasp::FileInput::Read_Complete(), fasp::FileInput::Read_Init(), and fasp::Transport::ReadFromSocket().
const int FaspSyncPos = 34 |
Definition at line 572 of file oct12-sorter.cxx.
Referenced by main(), fasp::FileInput::Read_Complete(), and fasp::Transport::ReadFromSocket().