|
@@ -595,11 +595,11 @@ static UA_StatusCode ClientNetworkLayerTCP_awaitResponse(ClientNetworkLayerTCP *
|
|
|
UA_SecureConversationMessageHeader msgHeader;
|
|
|
|
|
|
do{
|
|
|
+ if(already_received>0 || ret <= -1)Sleep(100); //0.1 s
|
|
|
|
|
|
ret = recv(handle->sockfd, (char*)(response->data+already_received), response->length-already_received, 0);
|
|
|
|
|
|
if(ret <= -1){
|
|
|
- Sleep(100); //0.1 s
|
|
|
continue;
|
|
|
}
|
|
|
if(ret == 0)
|
|
@@ -615,7 +615,7 @@ static UA_StatusCode ClientNetworkLayerTCP_awaitResponse(ClientNetworkLayerTCP *
|
|
|
size_t offset = 0;
|
|
|
//let us try to decode the length of the real message
|
|
|
UA_SecureConversationMessageHeader_decodeBinary(response, &offset, &msgHeader);
|
|
|
- printf("ret %d, length %d, already recv %d\n", ret, msgHeader.messageHeader.messageSize, already_received);
|
|
|
+ //printf("ret %d, length %d, already recv %d\n", ret, msgHeader.messageHeader.messageSize, already_received);
|
|
|
}while(msgHeader.messageHeader.messageSize == 0 || msgHeader.messageHeader.messageSize < already_received);
|
|
|
|
|
|
response->length = already_received;
|