detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-05-06 21:00:02 +02:00
Code Issues Actions Packages Releases Activity

back

Browse Source
This commit is contained in:
Dhanya Maliakal 2016-10-18 14:05:05 +02:00
parent cdaeff76d5
commit 82884370b5
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
slsReceiverSoftware/src/UDPStandardImplementation.cpp
View File

@ -1673,8 +1673,7 @@ void UDPStandardImplementation::startDataCallback(){
//socket details //socket details
void *context = zmq_ctx_new(); void *context = zmq_ctx_new();
void *zmqsocket = zmq_socket(context, ZMQ_PUSH); // create a publisher void *zmqsocket = zmq_socket(context, ZMQ_PUSH); // create a publisher
/*int val = -1;*/ int val = -1;
int val = 4;
zmq_setsockopt(zmqsocket, ZMQ_LINGER, &val,sizeof(val)); // wait for the unsent packets before closing socket zmq_setsockopt(zmqsocket, ZMQ_LINGER, &val,sizeof(val)); // wait for the unsent packets before closing socket
//val = 10; //val = 10;
//zmq_setsockopt(zmqsocket,ZMQ_SNDHWM,&val,sizeof(val)); //set SEND HIGH WATER MARK (8-9ms slower) //zmq_setsockopt(zmqsocket,ZMQ_SNDHWM,&val,sizeof(val)); //set SEND HIGH WATER MARK (8-9ms slower)
@ -1754,7 +1753,7 @@ void UDPStandardImplementation::startDataCallback(){
} }
/*
//send final header //send final header
//update frame details //update frame details
#ifdef DEBUG #ifdef DEBUG
@ -1767,7 +1766,7 @@ void UDPStandardImplementation::startDataCallback(){
zmq_send(zmqsocket, buf,len, ZMQ_SNDMORE); zmq_send(zmqsocket, buf,len, ZMQ_SNDMORE);
//send final data //send final data
zmq_send (zmqsocket, "end", 3, 0); zmq_send (zmqsocket, "end", 3, 0);
*/
pthread_mutex_lock(&statusMutex); pthread_mutex_lock(&statusMutex);
dataCallbackThreadsMask^=(1<<ithread); dataCallbackThreadsMask^=(1<<ithread);