diff options
author | Jef Poskanzer <jef@mail.acme.com> | 2012-12-11 22:29:26 -0800 |
---|---|---|
committer | Jef Poskanzer <jef@mail.acme.com> | 2012-12-11 22:29:26 -0800 |
commit | ec2d0670b8e068c6d6713e078a29ba7460435629 (patch) | |
tree | 4b23df1b7dda26dcbf38feb7abdccc29091db24e /src/net.c | |
parent | 9673370f9817f5e0bf0bde9ac476baee1c9bd4ca (diff) | |
download | iperf3-ec2d0670b8e068c6d6713e078a29ba7460435629.tar.gz |
Switched to using a new timer package, adapted from thttpd and http_load.
Diffstat (limited to 'src/net.c')
-rw-r--r-- | src/net.c | 32 |
1 files changed, 16 insertions, 16 deletions
@@ -37,7 +37,7 @@ netdial(int domain, int proto, char *local, char *server, int port) s = socket(domain, proto, 0); if (s < 0) { - return (-1); + return -1; } if (local) { @@ -47,10 +47,10 @@ netdial(int domain, int proto, char *local, char *server, int port) // XXX: Check getaddrinfo for errors! if (getaddrinfo(local, NULL, &hints, &res) != 0) - return (-1); + return -1; if (bind(s, (struct sockaddr *) res->ai_addr, res->ai_addrlen) < 0) - return (-1); + return -1; freeaddrinfo(res); } @@ -61,17 +61,17 @@ netdial(int domain, int proto, char *local, char *server, int port) // XXX: Check getaddrinfo for errors! if (getaddrinfo(server, NULL, &hints, &res) != 0) - return (-1); + return -1; ((struct sockaddr_in *) res->ai_addr)->sin_port = htons(port); if (connect(s, (struct sockaddr *) res->ai_addr, res->ai_addrlen) < 0 && errno != EINPROGRESS) { - return (-1); + return -1; } freeaddrinfo(res); - return (s); + return s; } /***************************************************************/ @@ -85,7 +85,7 @@ netannounce(int domain, int proto, char *local, int port) s = socket(domain, proto, 0); if (s < 0) { - return (-1); + return -1; } opt = 1; setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char *) &opt, sizeof(opt)); @@ -97,22 +97,22 @@ netannounce(int domain, int proto, char *local, int port) hints.ai_flags = AI_PASSIVE; // XXX: Check getaddrinfo for errors! if (getaddrinfo(local, portstr, &hints, &res) != 0) - return (-1); + return -1; if (bind(s, (struct sockaddr *) res->ai_addr, res->ai_addrlen) < 0) { close(s); - return (-1); + return -1; } freeaddrinfo(res); if (proto == SOCK_STREAM) { if (listen(s, 5) < 0) { - return (-1); + return -1; } } - return (s); + return s; } @@ -131,14 +131,14 @@ Nread(int fd, void *buf, int count, int prot) if (errno == EINTR) n = 0; else - return (-1); + return -1; } else if (n == 0) break; nleft -= n; buf += n; } - return (count - nleft); + return count - nleft; } @@ -166,7 +166,7 @@ Nwrite(int fd, void *buf, int count, int prot) delay(18000); // XXX: Fixme! n = 0; } else { - return (-1); + return -1; } } nleft -= n; @@ -178,13 +178,13 @@ Nwrite(int fd, void *buf, int count, int prot) if (errno == EINTR) n = 0; else - return (-1); + return -1; } nleft -= n; buf += n; } } - return (count); + return count; } /*************************************************************************/ |