summaryrefslogtreecommitdiff
path: root/deps/uv/src/unix/stream.c
diff options
context:
space:
mode:
authorBert Belder <bertbelder@gmail.com>2013-05-14 17:13:42 -0700
committerBert Belder <bertbelder@gmail.com>2013-05-14 17:13:42 -0700
commit79348256216ba0b3d6b9e0145ca27270152a6449 (patch)
treece4f172ebe5c9a5b7321a244fc0bf5ffa8abcd0b /deps/uv/src/unix/stream.c
parent8886c6bf624e6627f68a10c5f4c6399bb5257cdf (diff)
downloadandroid-node-v8-79348256216ba0b3d6b9e0145ca27270152a6449.tar.gz
android-node-v8-79348256216ba0b3d6b9e0145ca27270152a6449.tar.bz2
android-node-v8-79348256216ba0b3d6b9e0145ca27270152a6449.zip
uv: upgrade to v0.11.3
Diffstat (limited to 'deps/uv/src/unix/stream.c')
-rw-r--r--deps/uv/src/unix/stream.c48
1 files changed, 16 insertions, 32 deletions
diff --git a/deps/uv/src/unix/stream.c b/deps/uv/src/unix/stream.c
index 0c38231d68..1e97625eb2 100644
--- a/deps/uv/src/unix/stream.c
+++ b/deps/uv/src/unix/stream.c
@@ -536,42 +536,30 @@ void uv__server_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) {
int uv_accept(uv_stream_t* server, uv_stream_t* client) {
- uv_stream_t* streamServer;
- uv_stream_t* streamClient;
- int saved_errno;
- int status;
-
/* TODO document this */
assert(server->loop == client->loop);
- saved_errno = errno;
- status = -1;
-
- streamServer = (uv_stream_t*)server;
- streamClient = (uv_stream_t*)client;
-
- if (streamServer->accepted_fd < 0) {
- uv__set_sys_error(server->loop, EAGAIN);
- goto out;
- }
+ if (server->accepted_fd == -1)
+ return uv__set_sys_error(server->loop, EAGAIN);
- switch (streamClient->type) {
+ switch (client->type) {
case UV_NAMED_PIPE:
case UV_TCP:
- if (uv__stream_open(streamClient, streamServer->accepted_fd,
- UV_STREAM_READABLE | UV_STREAM_WRITABLE)) {
+ if (uv__stream_open(client,
+ server->accepted_fd,
+ UV_STREAM_READABLE | UV_STREAM_WRITABLE)) {
/* TODO handle error */
- close(streamServer->accepted_fd);
- streamServer->accepted_fd = -1;
- goto out;
+ close(server->accepted_fd);
+ server->accepted_fd = -1;
+ return -1;
}
break;
case UV_UDP:
- if (uv_udp_open((uv_udp_t*) client, streamServer->accepted_fd)) {
- close(streamServer->accepted_fd);
- streamServer->accepted_fd = -1;
- goto out;
+ if (uv_udp_open((uv_udp_t*) client, server->accepted_fd)) {
+ close(server->accepted_fd);
+ server->accepted_fd = -1;
+ return -1;
}
break;
@@ -579,13 +567,9 @@ int uv_accept(uv_stream_t* server, uv_stream_t* client) {
assert(0);
}
- uv__io_start(streamServer->loop, &streamServer->io_watcher, UV__POLLIN);
- streamServer->accepted_fd = -1;
- status = 0;
-
-out:
- errno = saved_errno;
- return status;
+ uv__io_start(server->loop, &server->io_watcher, UV__POLLIN);
+ server->accepted_fd = -1;
+ return 0;
}