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

switched

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

8
slsReceiverSoftware/src/UDPStandardImplementation.cpp
View File

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