d/freebsd-nq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Be more descriptive about poll error / timeout when transmitting.

Browse Source
This commit is contained in:
Ed Maste 2012-08-08 19:15:01 +00:00
parent 94dff77179
commit e5ecae38fc
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tools/tools/netmap/pkt-gen.c
View File

@ -468,13 +468,14 @@ static void *
sender_body(void *data) sender_body(void *data)
{ {
struct targ *targ = (struct targ *) data; struct targ *targ = (struct targ *) data;
struct pollfd fds[1]; struct pollfd fds[1];
struct netmap_if *nifp = targ->nifp; struct netmap_if *nifp = targ->nifp;
struct netmap_ring *txring; struct netmap_ring *txring;
int i, pkts_per_td = targ->g->npackets / targ->g->nthreads, sent = 0; int i, pkts_per_td = targ->g->npackets / targ->g->nthreads, sent = 0;
int continuous = 0; int continuous = 0;
int options = targ->g->options | OPT_COPY; int options = targ->g->options | OPT_COPY;
int retval;
D("start"); D("start");
if (pkts_per_td == 0) { if (pkts_per_td == 0) {
continuous = 1; continuous = 1;
@ -508,10 +509,14 @@ D("start");
/* /*
* wait for available room in the send queue(s) * wait for available room in the send queue(s)
*/ */
if (poll(fds, 1, 2000) <= 0) { if ((retval = poll(fds, 1, 2000)) <= 0) {
if (targ->cancel) if (targ->cancel)
break; break;
D("poll error/timeout on queue %d\n", targ->me); if (retval == 0)
D("poll timeout on queue %d\n", targ->me);
else
D("poll error on queue %d: %s\n", targ->me,
strerror(errno));
goto quit; goto quit;
} }
/* /*