Pourquoi RIOSend est-il plus lent que le socket winapi classique?

Question

Je suis en train de tester deux applications avec des sockets TCP. La première application utilise de nouveaux appels de socket RIO, la deuxième application utilise des appels de socket Winsock classiques. Les deux applications envoient une seule chaîne à un serveur. Je leur ai fait utiliser des sockets non-bloquants et désactivé l'algorithme de Nagle. Quand je mesure le temps qu'il faut pour exécuter les envois, contrairement à mes attentes, le socket classique est plus rapide. Quelle est la raison pour ça?

Voici mon code:

/* 
    Classic socket 
*/ 
SOCKET ConnectSocket = INVALID_SOCKET; 

// ... socket initialization 

// Make socket non-blocking and disable Nagle's algorithm 
unsigned long mode = 1; 
ioctlsocket(ConnectSocket, FIONBIO, &mode); 
int isOn = 1; 
setsockopt(ConnectSocket, IPPROTO_TCP, TCP_NODELAY, (char *) &isOn, sizeof(int)); 

// Measure exec time 
t1 = __rdtscp(&dum); 
iResult = send(ConnectSocket, sendbuf, (int)strlen(sendbuf), 0); 
t2 = __rdtscp(&dum); 
cout << (t2 - t1)/3000.0f << " 10^-6 sec" << endl; 

/* 
    RIO socket 
*/ 
SOCKET s = WSASocket(
     AF_INET, 
     SOCK_STREAM, 
     IPPROTO_TCP, 
     NULL, 
     0, 
     WSA_FLAG_REGISTERED_IO); 

// ... socket initialization 

// Make socket non-blocking and disable Nagel's algorithm 
unsigned long mode = 1; 
ioctlsocket(s, FIONBIO, &mode); 
int isOn = 1; 
setsockopt(s, IPPROTO_TCP, TCP_NODELAY, (char *)&isOn, sizeof(int)); 

// RIO socket is event-based 
hEvent = WSACreateEvent(); 
RIO_NOTIFICATION_COMPLETION type; 
type.Type = RIO_EVENT_COMPLETION; 
type.Event.EventHandle = hEvent; 
type.Event.NotifyReset = TRUE; 
RIO_CQ complQueue = rioFuncTable.RIOCreateCompletionQueue(1000, &type); 

RIO_RQ requestQueue = rioFuncTable.RIOCreateRequestQueue(
     s, 
     10, 
     1, 
     10, 
     1, 
     complQueue, 
     complQueue, 
     NULL); 

// Init rio buffers 
char *pSndBuffer = new char[sndBufferSize + 1](); 
std::copy(message, message + sndBufferSize, pSndBuffer); // put message to a server here 

RIO_BUFFERID sndBufID = rioFuncTable.RIORegisterBuffer(pSndBuffer, sndBufferSize); 
RIO_BUF sndBuffer; 
sndBuffer.BufferId = sndBufID; 
sndBuffer.Offset = 0; 
sndBuffer.Length = sndBufferSize; 

// Measure exec time 
t1 = __rdtscp(&dum); 
rioFuncTable.RIOSend(requestQueue, &sndBuffer, 1, 0, NULL); 
t2 = __rdtscp(&dum); 
cout << (t2 - t1)/3000.0f << " 10^-6 sec" << endl; 

Answer 1

RioSend() envoie pour de vrai. send() enregistre le tampon dans le tampon tx du socket.