1#include "toys.h"
2
3int xsocket(int domain, int type, int protocol)
4{
5  int fd = socket(domain, type, protocol);
6
7  if (fd < 0) perror_exit("socket %x %x", type, protocol);
8  fcntl(fd, F_SETFD, FD_CLOEXEC);
9
10  return fd;
11}
12
13void xsetsockopt(int fd, int level, int opt, void *val, socklen_t len)
14{
15  if (-1 == setsockopt(fd, level, opt, val, len)) perror_exit("setsockopt");
16}
17
18int xconnect(char *host, char *port, int family, int socktype, int protocol,
19             int flags)
20{
21  struct addrinfo info, *ai, *ai2;
22  int fd;
23
24  memset(&info, 0, sizeof(struct addrinfo));
25  info.ai_family = family;
26  info.ai_socktype = socktype;
27  info.ai_protocol = protocol;
28  info.ai_flags = flags;
29
30  fd = getaddrinfo(host, port, &info, &ai);
31  if (fd || !ai)
32    error_exit("Connect '%s%s%s': %s", host, port ? ":" : "", port ? port : "",
33      fd ? gai_strerror(fd) : "not found");
34
35  // Try all the returned addresses. Report errors if last entry can't connect.
36  for (ai2 = ai; ai; ai = ai->ai_next) {
37    fd = (ai->ai_next ? socket : xsocket)(ai->ai_family, ai->ai_socktype,
38      ai->ai_protocol);
39    if (!connect(fd, ai->ai_addr, ai->ai_addrlen)) break;
40    else if (!ai->ai_next) perror_exit("connect");
41    close(fd);
42  }
43  freeaddrinfo(ai2);
44
45  return fd;
46}
47
48int xpoll(struct pollfd *fds, int nfds, int timeout)
49{
50  int i;
51
52  for (;;) {
53    if (0>(i = poll(fds, nfds, timeout))) {
54      if (toys.signal) return i;
55      if (errno != EINTR && errno != ENOMEM) perror_exit("xpoll");
56      else if (timeout>0) timeout--;
57    } else return i;
58  }
59}
60
61// Loop forwarding data from in1 to out1 and in2 to out2, handling
62// half-connection shutdown. timeouts return if no data for X miliseconds.
63// Returns 0: both closed, 1 shutdown_timeout, 2 timeout
64int pollinate(int in1, int in2, int out1, int out2, int timeout, int shutdown_timeout)
65{
66  struct pollfd pollfds[2];
67  int i, pollcount = 2;
68
69  memset(pollfds, 0, 2*sizeof(struct pollfd));
70  pollfds[0].events = pollfds[1].events = POLLIN;
71  pollfds[0].fd = in1;
72  pollfds[1].fd = in2;
73
74  // Poll loop copying data from each fd to the other one.
75  for (;;) {
76    if (!xpoll(pollfds, pollcount, timeout)) return pollcount;
77
78    for (i=0; i<pollcount; i++) {
79      if (pollfds[i].revents & POLLIN) {
80        int len = read(pollfds[i].fd, libbuf, sizeof(libbuf));
81        if (len<1) pollfds[i].revents = POLLHUP;
82        else xwrite(i ? out2 : out1, libbuf, len);
83      }
84      if (pollfds[i].revents & POLLHUP) {
85        // Close half-connection.  This is needed for things like
86        // "echo GET / | netcat landley.net 80"
87        // Note that in1 closing triggers timeout, in2 returns now.
88        if (i) {
89          shutdown(pollfds[0].fd, SHUT_WR);
90          pollcount--;
91          timeout = shutdown_timeout;
92        } else return 0;
93      }
94    }
95  }
96}
97