version 1.6, 2008/06/26 07:05:56 |
version 1.7, 2008/08/14 22:29:43 |
|
|
err(1, "poll"); |
err(1, "poll"); |
} |
} |
for (i = 0; i < nconn; i++) { |
for (i = 0; i < nconn; i++) { |
if (pfd[i].revents & POLLOUT) |
if (pfd[i].revents & POLLOUT) { |
if ((n = write(pfd[i].fd, buf, Bflag)) == -1) { |
if ((n = write(pfd[i].fd, buf, Bflag)) == -1) { |
if (errno == EINTR || errno == EAGAIN) |
if (errno == EINTR || errno == EAGAIN) |
continue; |
continue; |
err(1, "write"); |
err(1, "write"); |
} |
} |
if (n == 0) { |
if (n == 0) { |
warnx("Remote end closed connection"); |
warnx("Remote end closed connection"); |
done = -1; |
done = -1; |
break; |
break; |
|
} |
|
if (vflag >= 3) |
|
fprintf(stderr, "write: %zd bytes\n", |
|
n); |
|
stats_update(&sc, n); |
} |
} |
if (vflag >= 3) |
|
fprintf(stderr, "write: %zd bytes\n", n); |
|
stats_update(&sc, n); |
|
} |
} |
} |
} |
stats_finish(&sc); |
stats_finish(&sc); |
|
|
errstr, optarg); |
errstr, optarg); |
break; |
break; |
case 'v': |
case 'v': |
if (vflag < 2) |
vflag++; |
vflag++; |
|
break; |
break; |
case 'n': |
case 'n': |
nconn = strtonum(optarg, 0, 65535, &errstr); |
nconn = strtonum(optarg, 0, 65535, &errstr); |