pemensik / rpms / cjdns

Forked from rpms/cjdns 2 years ago
Clone
Blob Blame History Raw
diff --git a/util/events/libuv/Pipe.c b/util/events/libuv/Pipe.c
index f702b8d..fdefe0d 100644
--- a/util/events/libuv/Pipe.c
+++ b/util/events/libuv/Pipe.c
@@ -234,11 +234,6 @@ static void incoming(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf)
     }
 }
 
-static void incoming2(uv_pipe_t* stream, ssize_t nread, const uv_buf_t* buf, uv_handle_type _)
-{
-    incoming((uv_stream_t*)stream, nread, buf);
-}
-
 static void allocate(uv_handle_t* handle, size_t size, uv_buf_t* buf)
 {
     struct Pipe_pvt* pipe = Identity_check((struct Pipe_pvt*) handle->data);
@@ -257,11 +252,7 @@ static void allocate(uv_handle_t* handle, size_t size, uv_buf_t* buf)
 
 static int startPipe(struct Pipe_pvt* pipe)
 {
-    if (pipe->ipc) {
-        return uv_read2_start((uv_stream_t*)&pipe->peer, allocate, incoming2);
-    } else {
-        return uv_read_start((uv_stream_t*)&pipe->peer, allocate, incoming);
-    }
+    return uv_read_start((uv_stream_t*)&pipe->peer, allocate, incoming);
 }
 
 static void connected(uv_connect_t* req, int status)
@@ -438,4 +429,4 @@ Er_DEFUN(bool Pipe_exists(const char* path, struct Allocator* errAlloc))
         #endif
         Er_ret(((int)(st.st_mode & S_IFMT)) == flag);
     }
-}
\ No newline at end of file
+}