{

uint32_t data_len_encoded = htonl(src.data.size());

uint32_t tag_encoded = htonl((uint32_t)src.tag);

send(conn, (char*)&tag_encoded, sizeof(uint32_t), NULL); // Send tag encoded

send(conn, (char*)&data_len_encoded, sizeof(uint32_t), NULL); // Send data length encoded

send(conn, src.data.c_str(), src.data.length(), NULL); // Send data

{

SocketData sd;

sd.tag = tag;

sd.data = data;

_send(conn, sd);

{

uint32_t data_len, tag;

recv(conn, (char*)&tag, sizeof(uint32_t), NULL); // Recive tag

recv(conn, (char*)&data_len, sizeof(uint32_t), NULL); // Recive data len

tag = (SocketTag)ntohl(tag); // Decode tag

data_len = ntohl(data_len); // Decode data len

vector<char> data_buffer(data_len);

recv(conn, &(data_buffer[0]), data_len, NULL); // Recive data

dest.data.assign(&(data_buffer[0]), data_buffer.size()); // Assign data buffer to the destination SocketData

dest.tag = (SocketTag)tag; // Assign tag to the destination SocketData

{

uint32_t data_len, tag;

int recvReturn = 0;

while (recvReturn == 0) {

Sleep(100);

recvReturn = recv(conn, (char*)&tag, sizeof(uint32_t), NULL); // Recive tag

if (recvReturn == SOCKET_ERROR)

return SOCKET_ERROR;

} recvReturn = 0;

while (recvReturn == 0) {

Sleep(100);

recvReturn = recv(conn, (char*)&data_len, sizeof(uint32_t), NULL); // Recive data len

if (recvReturn == SOCKET_ERROR)

return SOCKET_ERROR;

} recvReturn = 0;

tag = (SocketTag)ntohl(tag); // Decode tag

data_len = ntohl(data_len); // Decode data len

if (data_len > 0) {

vector<char> data_buffer(data_len);

while (recvReturn == 0) {

Sleep(100);

recvReturn = recv(conn, &(data_buffer[0]), data_len, NULL); // Recive data

if (recvReturn == SOCKET_ERROR)

return SOCKET_ERROR;

} recvReturn = 0;

dest.data.assign(&(data_buffer[0]), data_buffer.size()); // Assign data buffer to the destination SocketData

}

dest.tag = (SocketTag)tag; // Assign tag to the destination SocketData

return 0;

}