diff options
author | Ryan Dahl <ry@tinyclouds.org> | 2011-07-15 11:15:02 -0700 |
---|---|---|
committer | Ryan Dahl <ry@tinyclouds.org> | 2011-07-15 13:41:44 -0700 |
commit | 130be31cfff34a2c6ccb477dbcfead97b3e09646 (patch) | |
tree | 901c4a3fdb4ec70d09759b66dbbb24b6bcd989f8 /deps/uv/test/echo-server.c | |
parent | f5a7de1ea7c747d986321c467c0acb41d13971d6 (diff) | |
download | android-node-v8-130be31cfff34a2c6ccb477dbcfead97b3e09646.tar.gz android-node-v8-130be31cfff34a2c6ccb477dbcfead97b3e09646.tar.bz2 android-node-v8-130be31cfff34a2c6ccb477dbcfead97b3e09646.zip |
Upgrade libuv to 1be48f12a0
and bindings for new req interface
Diffstat (limited to 'deps/uv/test/echo-server.c')
-rw-r--r-- | deps/uv/test/echo-server.c | 20 |
1 files changed, 9 insertions, 11 deletions
diff --git a/deps/uv/test/echo-server.c b/deps/uv/test/echo-server.c index 4dc0e20c60..e107dc5b95 100644 --- a/deps/uv/test/echo-server.c +++ b/deps/uv/test/echo-server.c @@ -25,7 +25,7 @@ #include <stdlib.h> typedef struct { - uv_req_t req; + uv_write_t req; uv_buf_t buf; } write_req_t; @@ -35,14 +35,14 @@ static uv_tcp_t tcpServer; static uv_pipe_t pipeServer; static uv_handle_t* server; -static void after_write(uv_req_t* req, int status); +static void after_write(uv_write_t* req, int status); static void after_read(uv_stream_t*, ssize_t nread, uv_buf_t buf); static void on_close(uv_handle_t* peer); static void on_server_close(uv_handle_t* handle); static void on_connection(uv_handle_t*, int status); -static void after_write(uv_req_t* req, int status) { +static void after_write(uv_write_t* req, int status) { write_req_t* wr; if (status) { @@ -59,8 +59,8 @@ static void after_write(uv_req_t* req, int status) { } -static void after_shutdown(uv_req_t* req, int status) { - uv_close(req->handle, on_close); +static void after_shutdown(uv_shutdown_t* req, int status) { + uv_close((uv_handle_t*)req->handle, on_close); free(req); } @@ -68,7 +68,7 @@ static void after_shutdown(uv_req_t* req, int status) { static void after_read(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { int i; write_req_t *wr; - uv_req_t* req; + uv_shutdown_t* req; if (nread < 0) { /* Error or EOF */ @@ -78,9 +78,8 @@ static void after_read(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { free(buf.base); } - req = (uv_req_t*) malloc(sizeof *req); - uv_req_init(req, (uv_handle_t*)handle, (void *(*)(void *))after_shutdown); - uv_shutdown(req); + req = (uv_shutdown_t*) malloc(sizeof *req); + uv_shutdown(req, handle, after_shutdown); return; } @@ -103,10 +102,9 @@ static void after_read(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { wr = (write_req_t*) malloc(sizeof *wr); - uv_req_init(&wr->req, (uv_handle_t*)handle, (void *(*)(void *))after_write); wr->buf.base = buf.base; wr->buf.len = nread; - if (uv_write(&wr->req, &wr->buf, 1)) { + if (uv_write(&wr->req, handle, &wr->buf, 1, after_write)) { FATAL("uv_write failed"); } } |