Allow bidirectional communication over TCP connection

diff --git a/src/proto_inet.c b/src/proto_inet.c
index 538cb711bd0d20fe502c6f78f21e3304f231b15c..c7874c3e2ecfc0786ce7e5f4cd141908422a547e 100644 (file)
--- a/src/proto_inet.c
+++ b/src/proto_inet.c
@@ -173,6 +173,18 @@ inet_connect(forb_peer_t *peer)
                goto err_close;
        }
 
+       struct epoll_event ev;
+       struct inet_port *p = peer->port->desc.proto_priv;
+       memset(&ev, 0, sizeof(ev));
+       ev.events = EPOLLIN | EPOLLET;
+       ev.data.fd = ipeer->socket;
+       ret = epoll_ctl(p->epoll_fd, EPOLL_CTL_ADD, ipeer->socket, &ev);
+       if (ret) {
+               ul_logerr("epoll_ctl on connect failed: %s\n", strerror(errno));
+               goto err_close;
+       }
+
+
        return ipeer;
 err_close:
        close(ipeer->socket);