00001
00002
00003
00004 #include "sls_receiver_defs.h"
00005 #include "slsReceiverUsers.h"
00006
00007 #include <iostream>
00008 #include <string.h>
00009 #include <signal.h>
00010 #include <cstdlib>
00011
00012
00013
00014
00015 #include <sys/types.h>
00016 #include <sys/wait.h>
00017
00018 #include <string>
00019 using namespace std;
00020
00021 #define NUM_RECEIVERS 2
00022 #define START_TCP_PORT 1954
00023 #define PRINT_IN_COLOR(c,f, ...) printf ("\033[%dm" f RESET, 30 + c+1, ##__VA_ARGS__)
00024
00025
00026 pid_t childPid[NUM_RECEIVERS];
00027 bool keeprunning;
00028 int numrunning;
00029
00030
00031
00032 void sigChildExitedHandler(int sig) {
00033 pid_t pid = wait(NULL);
00034 bprintf(GRAY, "\nChild Process Pid %d exited.\n", pid);
00035 numrunning--;
00036 }
00037
00038
00039 void sigInterruptHandler(int p){
00040 keeprunning = false;
00041 }
00042
00043 int StartAcq(char* filepath, char* filename, uint64_t fileindex, uint32_t datasize, void*p){
00044 bprintf(BLUE, "#### StartAcq: filepath:%s filename:%s fileindex:%llu datasize:%u ####\n",
00045 filepath, filename, fileindex, datasize);
00046
00047 bprintf(BLUE, "--StartAcq: returning 0\n");
00048 return 0;
00049 }
00050
00051
00052 void AcquisitionFinished(uint64_t frames, void*p){
00053 bprintf(BLUE, "#### AcquisitionFinished: frames:%llu ####\n",frames);
00054 }
00055
00056
00057 void GetData(uint64_t frameNumber, uint32_t expLength, uint32_t packetNumber, uint64_t bunchId, uint64_t timestamp,
00058 uint16_t modId, uint16_t xCoord, uint16_t yCoord, uint16_t zCoord, uint32_t debug, uint16_t roundRNumber, uint8_t detType, uint8_t version,
00059 char* datapointer, uint32_t datasize, void* p){
00060
00061 PRINT_IN_COLOR (xCoord,
00062 "#### %d GetData: ####\n"
00063 "frameNumber: %llu\t\texpLength: %u\t\tpacketNumber: %u\t\tbunchId: %llu\t\ttimestamp: %llu\t\tmodId: %u\t\t"
00064 "xCoord: %u\t\tyCoord: %u\t\tzCoord: %u\t\tdebug: %u\t\troundRNumber: %u\t\tdetType: %u\t\t"
00065 "version: %u\t\tfirstbytedata: 0x%x\t\tdatsize: %u\n\n",
00066 xCoord, frameNumber, expLength, packetNumber, bunchId, timestamp, modId,
00067 xCoord, yCoord, zCoord, debug, roundRNumber, detType, version,
00068 ((uint8_t)(*((uint8_t*)(datapointer)))), datasize);
00069
00070 }
00071
00072
00073
00074 int main(int argc, char *argv[]) {
00075
00076
00077 for (int i = 0; i < NUM_RECEIVERS; ++i)
00078 childPid[i] = -1;
00079
00080 keeprunning = true;
00081 numrunning = 0;
00082
00083
00084 struct sigaction sa;
00085 sa.sa_flags=0;
00086 sa.sa_handler=sigInterruptHandler;
00087 sigemptyset(&sa.sa_mask);
00088 if (sigaction(SIGINT, &sa, NULL) == -1) {
00089 bprintf(RED, "Could not set handler function for SIGINT\n");
00090 }
00091
00092
00093 struct sigaction asa;
00094 asa.sa_flags=0;
00095 asa.sa_handler=sigChildExitedHandler;
00096 sigemptyset(&asa.sa_mask);
00097 if (sigaction(SIGCHLD, &asa, NULL) == -1) {
00098 bprintf(RED, "Could not set handler function for SICHILD\n");
00099 }
00100
00101
00102 int narg= 3;
00103
00104 for (int i = 0; i < NUM_RECEIVERS; ++i) {
00105
00106 childPid[i] = fork();
00107
00108
00109 if (childPid[i] < 0) {
00110 bprintf(RED,"fork() failed. Killing all the receiver objects\n");
00111 raise(SIGINT);
00112 }
00113
00114
00115 else if (childPid[i] == 0) {
00116 bprintf(BLUE,"Starting Receiver %d with pid %ld\n", i, (long)getpid());
00117
00118 char temp[10];
00119 sprintf(temp,"%d",START_TCP_PORT + i);
00120 char* args[] = {(char*)"ignored", (char*)"--rx_tcpport", temp};
00121 int ret = slsReceiverDefs::OK;
00122 slsReceiverUsers *receiver = new slsReceiverUsers(narg, args, ret);
00123 if(ret==slsReceiverDefs::FAIL){
00124 delete receiver;
00125 exit(EXIT_FAILURE);
00126 }
00127
00128
00129
00130
00131
00144 bprintf(BLUE, "Registering StartAcq()\n");
00145 receiver->registerCallBackStartAcquisition(StartAcq, NULL);
00146
00152 bprintf(BLUE, "Registering AcquisitionFinished()\n");
00153 receiver->registerCallBackAcquisitionFinished(AcquisitionFinished, NULL);
00154
00174 bprintf(BLUE, "Registering GetData() \n");
00175 receiver->registerCallBackRawDataReady(GetData,NULL);
00176
00177
00178
00179 if (receiver->start() == slsReceiverDefs::FAIL){
00180 delete receiver;
00181 exit(EXIT_FAILURE);
00182 }
00183
00184 while(keeprunning)
00185 usleep(1 * 1000 * 1000);
00186 delete receiver;
00187 exit(EXIT_SUCCESS);
00188 }
00189
00190
00191 else
00192 numrunning++;
00193
00194 }
00195
00196 cout << "Ready ... " << endl;
00197 bprintf(GRAY, "\n[ Press \'Ctrl+c\' to exit ]\n");
00198
00199
00200 while(numrunning)
00201 usleep(1 * 1000 * 1000);
00202 cout << "Goodbye!" << endl;
00203 return 0;
00204 }
00205