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

bug fixed, rapidjson parse error

Browse Source
This commit is contained in:
Dhanya Maliakal
2016-09-19 12:34:31 +02:00
parent f517eb7a41
commit 38d477a1ad
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
slsDetectorSoftware/multiSlsDetector/multiSlsDetector.cpp
View File

@ -5022,20 +5022,25 @@ void multiSlsDetector::startReceivingData(){
cprintf(RED, "%d message null\n",ithread); cprintf(RED, "%d message null\n",ithread);
continue; continue;
} }
rapidjson::Document d; rapidjson::Document d;
d.Parse((char*)zmq_msg_data(&message)); // d.Parse((char*)zmq_msg_data(&message));
d.Parse( (char*)zmq_msg_data(&message), zmq_msg_size(&message));
// htype is an array of strings // htype is an array of strings
rapidjson::Value::Array htype = d["htype"].GetArray(); rapidjson::Value::Array htype = d["htype"].GetArray();
for(int i=0; i< htype.Size(); i++) for(int i=0; i< htype.Size(); i++)
cout << ithread << "htype: " << htype[i].GetString() << endl;/*print*/ std::cout << ithread << "htype: " << htype[i].GetString() << std::endl;
// shape is an array of ints // shape is an array of ints
rapidjson::Value::Array shape = d["shape"].GetArray(); rapidjson::Value::Array shape = d["shape"].GetArray();
cout << ithread << "shape: "; /*print*/ cout << ithread << "shape: ";
for(int i=0; i< shape.Size(); i++) for(int i=0; i< shape.Size(); i++)
cout << ithread << shape[i].GetInt() << " ";/*print*/ cout << ithread << shape[i].GetInt() << " ";
cout << endl; cout << endl;
cout << ithread << "type: " << d["type"].GetString() << endl;/*print*/ cout << ithread << "type: " << d["type"].GetString() << endl;
// close the message // close the message
zmq_msg_close(&message); zmq_msg_close(&message);
@ -5046,7 +5051,7 @@ void multiSlsDetector::startReceivingData(){
//last one //last one
if(len<1024*256){ if(len<1024*256){
cprintf(RED,"got less than planned for socket %d\n",ithread); cprintf(RED,"got less than planned for socket %d, length:%d\n",ithread,len);
//end of socket //end of socket
//if (len <= 3 ) { //if (len <= 3 ) {
if(!len) cprintf(RED,"Received no data in socket for %d\n", ithread); if(!len) cprintf(RED,"Received no data in socket for %d\n", ithread);