coffee/wepoll
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test: make test-connect-success-events more robust

Browse Source
This commit is contained in:
Bert Belder 2018-11-17 02:02:49 -08:00
parent 6cf7a01f4a
commit 653545fd35
No known key found for this signature in database
GPG Key ID: 7A77887B2E2ED461
1 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
test/test-connect-success-events.c
View File

@ -76,23 +76,29 @@ int main(void) {
/* Wait for client end to become writable. */ /* Wait for client end to become writable. */
r = epoll_wait(ephnd, evs, array_count(evs), -1); r = epoll_wait(ephnd, evs, array_count(evs), -1);
check(r == 1);
check(evs[0].data.sock == client_sock);
check(evs[0].events == EPOLLOUT);
/* Try to send data until the kernel buffer is full. */ /* Try to send data until the kernel buffer is full. */
memset(buf, round, sizeof buf); memset(buf, round, sizeof buf);
bytes_sent = 0; bytes_sent = 0;
do { do {
/* We shouldn't get here unless epoll_wait() reported that the client
* socket is writable. */
check(r == 1);
check(evs[0].data.sock == client_sock);
check(evs[0].events == EPOLLOUT);
/* The actual send() call should never fail, because epoll_wait() just
* reported the socket as writable. */
r = send(client_sock, buf, sizeof buf, 0); r = send(client_sock, buf, sizeof buf, 0);
if (r >= 0) check(r > 0);
bytes_sent += r; bytes_sent += r;
else
check(WSAGetLastError() == WSAEWOULDBLOCK); /* Call epoll_wait() without blocking to see if there's more space in the
* kernel write buffer. */
r = epoll_wait(ephnd, evs, array_count(evs), 0);
} while (r > 0); } while (r > 0);
/* The client end should not be writable now. */ /* Verify that epoll_wait() reported no events, but did not fail. */
r = epoll_wait(ephnd, evs, array_count(evs), 0);
check(r == 0); check(r == 0);
/* Read all data incoming on the server end of the connection. */ /* Read all data incoming on the server end of the connection. */