Remove dead code in process.cpp. Review: https://reviews.apache.org/r/27959
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/149164bb Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/149164bb Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/149164bb Branch: refs/heads/master Commit: 149164bb477ac5e8065e12f00124f6154a1180fe Parents: 4d616f8 Author: Joris Van Remoortere <[email protected]> Authored: Sat Nov 15 16:46:15 2014 -0800 Committer: Benjamin Hindman <[email protected]> Committed: Sat Nov 15 17:38:21 2014 -0800 ---------------------------------------------------------------------- 3rdparty/libprocess/src/process.cpp | 40 -------------------------------- 1 file changed, 40 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mesos/blob/149164bb/3rdparty/libprocess/src/process.cpp ---------------------------------------------------------------------- diff --git a/3rdparty/libprocess/src/process.cpp b/3rdparty/libprocess/src/process.cpp index 6916cbb..73d41c9 100644 --- a/3rdparty/libprocess/src/process.cpp +++ b/3rdparty/libprocess/src/process.cpp @@ -800,46 +800,6 @@ void send_file(Encoder* e) } -void sending_connect(Encoder* encoder) -{ - int s = encoder->socket(); - - // Now check that a successful connection was made. - int opt; - socklen_t optlen = sizeof(opt); - - if (getsockopt(s, SOL_SOCKET, SO_ERROR, &opt, &optlen) < 0 || opt != 0) { - // Connect failure. - VLOG(1) << "Socket error while connecting"; - socket_manager->close(s); - delete encoder; - } else { - // We're connected! Now let's do some sending. - io::poll(s, io::WRITE) - .onAny(lambda::bind(&send_data, encoder)); - } -} - - -void receiving_connect(Socket* socket, int s) -{ - // Now check that a successful connection was made. - int opt; - socklen_t optlen = sizeof(opt); - - if (getsockopt(s, SOL_SOCKET, SO_ERROR, &opt, &optlen) < 0 || opt != 0) { - // Connect failure. - VLOG(1) << "Socket error while connecting"; - socket_manager->close(s); - delete socket; - } else { - // We're connected! Now let's do some receiving. - io::poll(s, io::READ) - .onAny(lambda::bind(&ignore_data, socket, s)); - } -} - - void accept(struct ev_loop* loop, ev_io* watcher, int revents) { CHECK_EQ(__s__, watcher->fd);
