From: Michal Sojka Date: Tue, 26 May 2009 15:00:28 +0000 (+0200) Subject: Allow bidirectional communication over TCP connection X-Git-Url: https://rtime.felk.cvut.cz/gitweb/frescor/forb.git/commitdiff_plain/35ccb6692c69a5aef0f9b7ebe1668a8407c18214 Allow bidirectional communication over TCP connection --- diff --git a/src/proto_inet.c b/src/proto_inet.c index 538cb71..c7874c3 100644 --- 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);