mirror of
https://github.com/slsdetectorgroup/slsDetectorPackage.git
synced 2025-04-26 00:00:02 +02:00
removed users folder, redundant as user documentation in manual-api
This commit is contained in:
Dhanya Maliakal
parent
35dcdd62c9
commit
7099bc3286
@ -1,25 +0,0 @@
|
||||
WD = $(shell pwd)
|
||||
LIBDIR = $(WD)/../bin
|
||||
LIBRARYRXRDIR = $(WD)/../slsReceiverSoftware
|
||||
LIBRARYDETDIR = $(WD)/../slsDetectorSoftware
|
||||
LDFLAGRXR = -L$(LIBDIR) -lSlsReceiver -L/usr/lib64/ -pthread
|
||||
LDFLAGDET = -L$(LIBDIR) -lSlsDetector -L/usr/lib64/ -pthread
|
||||
INCLUDESRXR = -I $(LIBRARYRXRDIR)/include
|
||||
INCLUDESDET = -I $(LIBRARYRXRDIR)/include -I $(LIBRARYDETDIR)/slsDetector -I $(LIBRARYDETDIR)/slsDetectorAnalysis
|
||||
|
||||
|
||||
|
||||
all: receivers users
|
||||
|
||||
receivers:
|
||||
@echo $(WD)
|
||||
g++ mainReceiver.cpp $(INCLUDESRXR) $(LDFLAGRXR) -o userReceiver
|
||||
|
||||
users:
|
||||
@echo $(WD)
|
||||
g++ mainClient.cpp $(INCLUDESDET) $(LDFLAGDET) -o userClient
|
||||
|
||||
|
||||
clean:
|
||||
rm userReceiver userClient
|
||||
|
||||
@ -1,24 +0,0 @@
|
||||
WD = $(shell pwd)
|
||||
LIBDIR = $(WD)/../bin
|
||||
LIBRARYRXRDIR = $(WD)/../slsReceiverSoftware
|
||||
LIBRARYDETDIR = $(WD)/../slsDetectorSoftware
|
||||
LDFLAGRXR = -L$(LIBDIR) -lSlsReceiver -L/usr/lib64/ -pthread
|
||||
LDFLAGDET = -L$(LIBDIR) -lSlsDetector -L/usr/lib64/ -pthread
|
||||
INCLUDESRXR = -I $(LIBRARYRXRDIR)/include
|
||||
INCLUDESDET = -I $(LIBRARYDETDIR)/slsDetector -I $(LIBRARYDETDIR)/slsDetectorAnalysis
|
||||
|
||||
|
||||
|
||||
all: receivers users
|
||||
|
||||
receivers:
|
||||
@echo $(WD)
|
||||
g++ mainReceiver.cpp $(INCLUDESRXR) $(LDFLAGRXR) -o userReceiver
|
||||
|
||||
users:
|
||||
@echo $(WD)
|
||||
g++ mainClient.cpp $(INCLUDESDET) $(LDFLAGDET) -o userClient
|
||||
|
||||
|
||||
clean:
|
||||
rm userReceiver userClient
|
||||
@ -1,78 +0,0 @@
|
||||
/**
|
||||
\file mainClient.cpp
|
||||
|
||||
This file is an example of how to implement the slsDetectorUsers class
|
||||
You can compile it linking it to the slsDetector library
|
||||
|
||||
gcc mainClient.cpp -L lib -l SlsDetector -lm -pthread
|
||||
|
||||
where lib is the location of libSlsDetector.so
|
||||
gcc mainClient.cpp -L . -l SlsDetector -lm -pthread -o users
|
||||
|
||||
*/
|
||||
|
||||
#include <iostream>
|
||||
#include "slsDetectorUsers.h"
|
||||
#include "detectorData.h"
|
||||
#include <cstdlib>
|
||||
|
||||
/** Definition of the data callback which simply prints out the number of points received and teh frame number */
|
||||
int dataCallback(detectorData *pData, int iframe, int isubframe, void *pArg)
|
||||
{
|
||||
std::cout << "dataCallback: " << pData->npoints << " " << pData->npy << "Frame number: " << iframe << std::endl;
|
||||
}
|
||||
|
||||
|
||||
/**example of a main program using the slsDetectorUsers class */
|
||||
int main(int argc, char **argv) {
|
||||
int id=0;
|
||||
/** if specified, argv[3] is used as detector ID (default is 0)*/
|
||||
if (argc>=4)
|
||||
id=atoi(argv[3]);
|
||||
|
||||
|
||||
|
||||
/** slsDetectorUsers is instantiated */
|
||||
slsDetectorUsers *pDetector = new slsDetectorUsers (id);
|
||||
|
||||
|
||||
/** if specified, argv[1] is used as detector config file (necessary at least the first time it is called to properly configure advanced settings in the shared memory)*/
|
||||
if (argc>=2){
|
||||
pDetector->readConfigurationFile(argv[1]);
|
||||
cout<<"Detector configured" << endl;
|
||||
}
|
||||
/** registering data callback */
|
||||
//pDetector->registerDataCallback(&dataCallback, NULL);
|
||||
//pDetector->enableDataStreamingFromReceiver(1);
|
||||
|
||||
/** checking detector status and exiting if not idle */
|
||||
int status = pDetector->getDetectorStatus();
|
||||
if (status != 0){
|
||||
std::cout << "Detector not ready: " << slsDetectorUsers::runStatusType(status) << std::endl;
|
||||
return 1;
|
||||
}
|
||||
|
||||
/** load detector settings */
|
||||
if (argc>=3){
|
||||
pDetector->retrieveDetectorSetup(argv[2]);
|
||||
cout<<"Detector measurement set-up done" << endl;
|
||||
}
|
||||
/** start measurement */
|
||||
pDetector->startMeasurement();
|
||||
cout<<"started measurement"<<endl;
|
||||
|
||||
/* while (1) {
|
||||
usleep(100000);
|
||||
status = pDetector->getDetectorStatus();
|
||||
if (status == 0 || status == 1|| status == 3)
|
||||
break;
|
||||
}*/
|
||||
cout<<"measurement finished"<<endl;
|
||||
/** returning when acquisition is finished or data are avilable */
|
||||
|
||||
|
||||
delete pDetector;
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
@ -1,205 +0,0 @@
|
||||
/* A simple server in the internet domain using TCP
|
||||
The port number is passed as an argument */
|
||||
|
||||
#include "sls_receiver_defs.h"
|
||||
#include "slsReceiverUsers.h"
|
||||
|
||||
#include <iostream>
|
||||
#include <string.h>
|
||||
#include <signal.h> //SIGINT
|
||||
#include <cstdlib> //system
|
||||
|
||||
#include "utilities.h"
|
||||
#include "logger.h"
|
||||
|
||||
#include <sys/types.h> //wait
|
||||
#include <sys/wait.h> //wait
|
||||
|
||||
#include <string>
|
||||
using namespace std;
|
||||
|
||||
#define NUM_RECEIVERS 2
|
||||
#define START_TCP_PORT 1954
|
||||
#define PRINT_IN_COLOR(c,f, ...) printf ("\033[%dm" f RESET, 30 + c+1, ##__VA_ARGS__)
|
||||
|
||||
|
||||
pid_t childPid[NUM_RECEIVERS];
|
||||
bool keeprunning;
|
||||
int numrunning;
|
||||
|
||||
|
||||
|
||||
void sigChildExitedHandler(int sig) {
|
||||
pid_t pid = wait(NULL);
|
||||
bprintf(GRAY, "\nChild Process Pid %d exited.\n", pid);
|
||||
numrunning--;
|
||||
}
|
||||
|
||||
|
||||
void sigInterruptHandler(int p){
|
||||
keeprunning = false;
|
||||
}
|
||||
|
||||
int StartAcq(char* filepath, char* filename, uint64_t fileindex, uint32_t datasize, void*p){
|
||||
bprintf(BLUE, "#### StartAcq: filepath:%s filename:%s fileindex:%llu datasize:%u ####\n",
|
||||
filepath, filename, fileindex, datasize);
|
||||
|
||||
bprintf(BLUE, "--StartAcq: returning 0\n");
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
void AcquisitionFinished(uint64_t frames, void*p){
|
||||
bprintf(BLUE, "#### AcquisitionFinished: frames:%llu ####\n",frames);
|
||||
}
|
||||
|
||||
|
||||
void GetData(uint64_t frameNumber, uint32_t expLength, uint32_t packetNumber, uint64_t bunchId, uint64_t timestamp,
|
||||
uint16_t modId, uint16_t xCoord, uint16_t yCoord, uint16_t zCoord, uint32_t debug, uint16_t roundRNumber, uint8_t detType, uint8_t version,
|
||||
char* datapointer, uint32_t datasize, void* p){
|
||||
|
||||
PRINT_IN_COLOR (xCoord,
|
||||
"#### %d GetData: ####\n"
|
||||
"frameNumber: %llu\t\texpLength: %u\t\tpacketNumber: %u\t\tbunchId: %llu\t\ttimestamp: %llu\t\tmodId: %u\t\t"
|
||||
"xCoord: %u\t\tyCoord: %u\t\tzCoord: %u\t\tdebug: %u\t\troundRNumber: %u\t\tdetType: %u\t\t"
|
||||
"version: %u\t\tfirstbytedata: 0x%x\t\tdatsize: %u\n\n",
|
||||
xCoord, frameNumber, expLength, packetNumber, bunchId, timestamp, modId,
|
||||
xCoord, yCoord, zCoord, debug, roundRNumber, detType, version,
|
||||
((uint8_t)(*((uint8_t*)(datapointer)))), datasize);
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
int main(int argc, char *argv[]) {
|
||||
|
||||
// set default child process pid values
|
||||
for (int i = 0; i < NUM_RECEIVERS; ++i)
|
||||
childPid[i] = -1;
|
||||
|
||||
keeprunning = true;
|
||||
numrunning = 0;
|
||||
|
||||
// Catch signal SIGINT to close files and call destructors properly
|
||||
struct sigaction sa;
|
||||
sa.sa_flags=0; // no flags
|
||||
sa.sa_handler=sigInterruptHandler; // handler function
|
||||
sigemptyset(&sa.sa_mask); // dont block additional signals during invocation of handler
|
||||
if (sigaction(SIGINT, &sa, NULL) == -1) {
|
||||
bprintf(RED, "Could not set handler function for SIGINT\n");
|
||||
}
|
||||
|
||||
// wait for all the SIGCHILD signals
|
||||
struct sigaction asa;
|
||||
asa.sa_flags=0; // no flags
|
||||
asa.sa_handler=sigChildExitedHandler; // handler function
|
||||
sigemptyset(&asa.sa_mask); // dont block additional signals during invocation of handler
|
||||
if (sigaction(SIGCHLD, &asa, NULL) == -1) {
|
||||
bprintf(RED, "Could not set handler function for SICHILD\n");
|
||||
}
|
||||
|
||||
|
||||
int narg= 3;
|
||||
|
||||
for (int i = 0; i < NUM_RECEIVERS; ++i) {
|
||||
|
||||
childPid[i] = fork();
|
||||
|
||||
// fork failed
|
||||
if (childPid[i] < 0) {
|
||||
bprintf(RED,"fork() failed. Killing all the receiver objects\n");
|
||||
raise(SIGINT);
|
||||
}
|
||||
|
||||
// child process
|
||||
else if (childPid[i] == 0) {
|
||||
bprintf(BLUE,"Starting Receiver %d with pid %ld\n", i, (long)getpid());
|
||||
|
||||
char temp[10];
|
||||
sprintf(temp,"%d",START_TCP_PORT + i);
|
||||
char* args[] = {(char*)"ignored", (char*)"--rx_tcpport", temp};
|
||||
int ret = slsReceiverDefs::OK;
|
||||
slsReceiverUsers *receiver = new slsReceiverUsers(narg, args, ret);
|
||||
if(ret==slsReceiverDefs::FAIL){
|
||||
delete receiver;
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
//register callbacks
|
||||
//remember to set file write enable to 0 (using the client) if we should not write files and
|
||||
//you will write data using the callbacks
|
||||
|
||||
/**
|
||||
* Call back for start acquisition
|
||||
* callback arguments are
|
||||
* filepath
|
||||
* filename
|
||||
* fileindex
|
||||
* datasize
|
||||
*
|
||||
* return value is insignificant at the moment
|
||||
* we write depending on file write enable
|
||||
* users get data to write depending on call backs registered
|
||||
*/
|
||||
bprintf(BLUE, "Registering StartAcq()\n");
|
||||
receiver->registerCallBackStartAcquisition(StartAcq, NULL);
|
||||
|
||||
/**
|
||||
* Call back for acquisition finished
|
||||
* callback argument is
|
||||
* total frames caught
|
||||
*/
|
||||
bprintf(BLUE, "Registering AcquisitionFinished()\n");
|
||||
receiver->registerCallBackAcquisitionFinished(AcquisitionFinished, NULL);
|
||||
|
||||
/**
|
||||
* Call back for raw data
|
||||
* args to raw data ready callback are
|
||||
* frameNumber is the frame number
|
||||
* expLength is the subframe number (32 bit eiger) or real time exposure time in 100ns (others)
|
||||
* packetNumber is the packet number
|
||||
* bunchId is the bunch id from beamline
|
||||
* timestamp is the time stamp with 10 MHz clock
|
||||
* modId is the unique module id (unique even for left, right, top, bottom)
|
||||
* xCoord is the x coordinate in the complete detector system
|
||||
* yCoord is the y coordinate in the complete detector system
|
||||
* zCoord is the z coordinate in the complete detector system
|
||||
* debug is for debugging purposes
|
||||
* roundRNumber is the round robin set number
|
||||
* detType is the detector type see :: detectorType
|
||||
* version is the version number of this structure format
|
||||
* dataPointer is the pointer to the data
|
||||
* dataSize in bytes is the size of the data in bytes
|
||||
*/
|
||||
bprintf(BLUE, "Registering GetData() \n");
|
||||
receiver->registerCallBackRawDataReady(GetData,NULL);
|
||||
|
||||
|
||||
//start tcp server thread
|
||||
if (receiver->start() == slsReceiverDefs::FAIL){
|
||||
delete receiver;
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
while(keeprunning)
|
||||
usleep(1 * 1000 * 1000);
|
||||
delete receiver;
|
||||
exit(EXIT_SUCCESS);
|
||||
}
|
||||
|
||||
// parent process
|
||||
else
|
||||
numrunning++;
|
||||
|
||||
}
|
||||
|
||||
FILE_LOG(logINFO) << "Ready ... ";
|
||||
bprintf(GRAY, "\n[ Press \'Ctrl+c\' to exit ]\n");
|
||||
|
||||
// wait for all child processes to exit
|
||||
while(numrunning)
|
||||
usleep(1 * 1000 * 1000);
|
||||
FILE_LOG(logINFO) << "Goodbye!";
|
||||
return 0;
|
||||
}
|
||||
|
||||
BIN
users/userClient
BIN
users/userClient
Binary file not shown.
Binary file not shown.
Loading…
x
Reference in New Issue
Block a user