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

something

Browse Source
This commit is contained in:
Dhanya Maliakal 2016-11-01 12:04:08 +01:00
parent d6e78c19ad
commit 0c257dbcdd
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
slsReceiverSoftware/include/genericSocket.h
View File

@ -404,10 +404,12 @@ enum communicationProtocol{
cerr << "Can not create socket "<<endl; cerr << "Can not create socket "<<endl;
file_des = socketDescriptor; file_des = socketDescriptor;
} else { } else {
cprintf(BLUE,"going to connect\n");
if(connect(socketDescriptor,(struct sockaddr *) &serverAddress,sizeof(serverAddress))<0){ if(connect(socketDescriptor,(struct sockaddr *) &serverAddress,sizeof(serverAddress))<0){
cerr << "Can not connect to socket "<<endl; cerr << "Can not connect to socket "<<endl;
file_des = -1; file_des = -1;
} else{ } else{
cprintf(GREEN,"connected\n");
file_des = socketDescriptor; file_des = socketDescriptor;
} }
} }
@ -473,7 +475,7 @@ enum communicationProtocol{
//cout << "socketdescriptor "<< socketDescriptor << endl; //cout << "socketdescriptor "<< socketDescriptor << endl;
struct timeval tout; struct timeval tout;
tout.tv_sec = 0; tout.tv_sec = 0;
tout.tv_usec = 500;//0; tout.tv_usec = 0;
if(::setsockopt(socketDescriptor, SOL_SOCKET, SO_RCVTIMEO, &tout, sizeof(struct timeval)) <0) if(::setsockopt(socketDescriptor, SOL_SOCKET, SO_RCVTIMEO, &tout, sizeof(struct timeval)) <0)
{ {
cerr << "Error in setsockopt SO_RCVTIMEO "<< 0 << endl; cerr << "Error in setsockopt SO_RCVTIMEO "<< 0 << endl;
@ -593,7 +595,9 @@ enum communicationProtocol{
if (file_des<0) return -1; if (file_des<0) return -1;
while(length>0){ while(length>0){
nsending = (length>packet_size) ? packet_size:length; nsending = (length>packet_size) ? packet_size:length;
cout<<"going to read from " << serverAddress.sin_port << endl;
nsent = read(file_des,(char*)buf+total_sent,nsending); nsent = read(file_des,(char*)buf+total_sent,nsending);
cout <<"read**" <<endl;
if(!nsent) break; if(!nsent) break;
length-=nsent; length-=nsent;
total_sent+=nsent; total_sent+=nsent;
@ -667,7 +671,9 @@ enum communicationProtocol{
if (file_des<0) return -1; if (file_des<0) return -1;
while(length>0){ while(length>0){
nsending = (length>packet_size) ? packet_size:length; nsending = (length>packet_size) ? packet_size:length;
cout<<"going to send to " << serverAddress.sin_port << endl;
nsent = write(file_des,(char*)buf+total_sent,nsending); nsent = write(file_des,(char*)buf+total_sent,nsending);
cout<<"sent**" <<endl;
if(!nsent) break; if(!nsent) break;
length-=nsent; length-=nsent;
total_sent+=nsent; total_sent+=nsent;