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

works, need to do json header and send dataready

Browse Source
This commit is contained in:
Dhanya Maliakal 2016-09-15 17:16:00 +02:00
parent 7d86e62045
commit 58713a90aa
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
slsReceiverSoftware/src/UDPStandardImplementation.cpp
View File

@ -1664,7 +1664,7 @@ void UDPStandardImplementation::startDataCallback(){cprintf(MAGENTA,"start data
void *context = zmq_ctx_new();
// create a publisher
void *zmqsocket = zmq_socket(context, ZMQ_PUB);
void *zmqsocket = zmq_socket(context, ZMQ_PUSH);
// bind
zmq_bind(zmqsocket,hostName);
@ -1685,8 +1685,11 @@ void UDPStandardImplementation::startDataCallback(){cprintf(MAGENTA,"start data
/**suing this in clientzmq_msg_more,
* in serve use zmq_msg_send (&message, sender, ZMQ_SNDMORE); and 0 for last packet, but better to check lengt*/
/*if (checkJoinThread()){for different scans
break;
}*/
zmq_send (zmqsocket, "end", 3, 0);
cprintf(BLUE,"sent done\n");
//cprintf(BLUE,"sent done\n");
pthread_mutex_lock(&statusMutex);
dataCallbackThreadsMask^=(1<<ithread);