aboutsummaryrefslogtreecommitdiff
path: root/deps/uv/test/echo-server.c
diff options
context:
space:
mode:
authorRyan Dahl <ry@tinyclouds.org>2011-07-15 11:15:02 -0700
committerRyan Dahl <ry@tinyclouds.org>2011-07-15 13:41:44 -0700
commit130be31cfff34a2c6ccb477dbcfead97b3e09646 (patch)
tree901c4a3fdb4ec70d09759b66dbbb24b6bcd989f8 /deps/uv/test/echo-server.c
parentf5a7de1ea7c747d986321c467c0acb41d13971d6 (diff)
downloadandroid-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.c20
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");
}
}