X-Git-Url: http://git.meshlink.io/?p=utcp;a=blobdiff_plain;f=test.c;h=1df172efa56556443bfa5c6ec913f9e9014b0035;hp=0f7f33368dc1def41192c494b4a29ea918298eac;hb=7cfc0ef57625f1dcc443c811c0eff3b99f915f8f;hpb=c1752fb36936ac8d08e5802afd66086f51c3e8cd diff --git a/test.c b/test.c index 0f7f333..1df172e 100644 --- a/test.c +++ b/test.c @@ -132,15 +132,17 @@ int main(int argc, char *argv[]) { struct timeval timeout = utcp_timeout(u); while(!connected || utcp_is_active(u)) { - debug("\n"); size_t max = c ? utcp_get_sndbuf_free(c) : 0; if(max > sizeof buf) max = sizeof buf; + int timeout_ms = timeout.tv_sec * 1000 + timeout.tv_usec / 1000 + 1; + + debug("polling, dir = %d, timeout = %d\n", dir, timeout_ms); if((dir & DIR_READ) && max) - poll(fds, 2, timeout.tv_sec * 1000 + timeout.tv_usec / 1000); + poll(fds, 2, timeout_ms); else - poll(fds + 1, 1, timeout.tv_sec * 1000 + timeout.tv_usec / 1000); + poll(fds + 1, 1, timeout_ms); if(fds[0].revents) { fds[0].revents = 0; @@ -165,7 +167,7 @@ int main(int argc, char *argv[]) { if(fds[1].revents) { fds[1].revents = 0; - debug("netout\n"); + debug("netin\n"); struct sockaddr_storage ss; socklen_t sl = sizeof ss; int len = recvfrom(s, buf, sizeof buf, MSG_DONTWAIT, (struct sockaddr *)&ss, &sl);