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

trying different machine zmq

Browse Source
This commit is contained in:
Dhanya Maliakal 2016-11-03 17:06:02 +01:00
parent aee60c3dbc
commit 8c53ce9f87
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
slsReceiverSoftware/src/UDPStandardImplementation.cpp
View File

@ -1801,12 +1801,10 @@ void UDPStandardImplementation::startDataCallback(){
//send header //send header
//update frame details //update frame details
frameIndex = (*((uint32_t*)(latestData[ithread]))) - startFrameIndex; frameIndex = (*((uint32_t*)(latestData[ithread]))) - startFrameIndex;
cout<<"frameindex:"<<frameIndex<<endl;
acquisitionIndex = frameIndex - startAcquisitionIndex; acquisitionIndex = frameIndex - startAcquisitionIndex;
subframeIndex = -1; subframeIndex = -1;
int len = sprintf(buf,jsonFmt,type,shape, acquisitionIndex, frameIndex, subframeIndex,completeFileName[ithread]); int len = sprintf(buf,jsonFmt,type,shape, acquisitionIndex, frameIndex, subframeIndex,completeFileName[ithread]);
cout<<"buf:"<<buf<<endl; zmq_send(zmqsocket, buf,len, ZMQ_SNDMORE);
cout<<"zmqsend return val:"<<zmq_send(zmqsocket, buf,len, ZMQ_SNDMORE)<<endl;
cout<<"sent header"<<endl; cout<<"sent header"<<endl;
//send data //send data
zmq_send(zmqsocket, latestData[ithread]+JFRAU_FILE_FRAME_HEADER_LENGTH, oneframesize, 0); zmq_send(zmqsocket, latestData[ithread]+JFRAU_FILE_FRAME_HEADER_LENGTH, oneframesize, 0);