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

debugging

Browse Source
This commit is contained in:
Dhanya Maliakal 2016-11-08 09:22:18 +01:00
parent a5c4434ae8
commit 01db6b988b
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
slsReceiverSoftware/include/genericSocket.h
View File

@ -611,7 +611,7 @@ cprintf(RED,"packet_soze:%d\n",packet_size);
break; break;
case UDP: case UDP:
if (socketDescriptor<0) return -1; if (socketDescriptor<0) return -1;
cprintf(RED,"length:%d packetsize:%d\n",length,packet_size);
//if length given, listens to length, else listens for packetsize till length is reached //if length given, listens to length, else listens for packetsize till length is reached
if(length){ if(length){

6
slsReceiverSoftware/src/UDPStandardImplementation.cpp
View File

@ -2133,7 +2133,7 @@ int UDPStandardImplementation::prepareAndListenBuffer(int ithread, int cSize, ch
int currentfnum=-1; int currentfnum=-1;
//read first packet //read first packet
receivedSize = udpSocket[ithread]->ReceiveDataOnly(buffer[ithread] + offset, onePacketSize); receivedSize = udpSocket[ithread]->ReceiveDataOnly(buffer[ithread] + offset);
if(!receivedSize) return 0; if(!receivedSize) return 0;
header = (jfrau_packet_header_t*)(buffer[ithread] + offset); header = (jfrau_packet_header_t*)(buffer[ithread] + offset);
currentpnum = (*( (uint8_t*) header->packetNumber)); currentpnum = (*( (uint8_t*) header->packetNumber));
@ -2159,7 +2159,7 @@ int UDPStandardImplementation::prepareAndListenBuffer(int ithread, int cSize, ch
break; break;
pnum --; pnum --;
receivedSize = udpSocket[ithread]->ReceiveDataOnly(buffer[ithread] + offset, onePacketSize); receivedSize = udpSocket[ithread]->ReceiveDataOnly(buffer[ithread] + offset);
if(!receivedSize){ if(!receivedSize){
totalIgnoredPacketCount[ithread] += (packetsPerFrame - pnum); totalIgnoredPacketCount[ithread] += (packetsPerFrame - pnum);
return 0; return 0;
@ -2180,7 +2180,7 @@ int UDPStandardImplementation::prepareAndListenBuffer(int ithread, int cSize, ch
//find the start of next image //find the start of next image
while(currentpnum != pnum){ while(currentpnum != pnum){
totalIgnoredPacketCount[ithread]++; totalIgnoredPacketCount[ithread]++;
receivedSize = udpSocket[ithread]->ReceiveDataOnly(buffer[ithread] + offset, onePacketSize); receivedSize = udpSocket[ithread]->ReceiveDataOnly(buffer[ithread] + offset);
if(!receivedSize) return 0; if(!receivedSize) return 0;
header = (jfrau_packet_header_t*)(buffer[ithread] + offset); header = (jfrau_packet_header_t*)(buffer[ithread] + offset);
currentpnum = (*( (uint8_t*) header->packetNumber)); currentpnum = (*( (uint8_t*) header->packetNumber));