Skip to content
This repository has been archived by the owner on Apr 22, 2023. It is now read-only.

Commit

Permalink
Browse files Browse the repository at this point in the history
Upgrade libuv to 2ef8f35
  • Loading branch information
ry committed Sep 20, 2011
1 parent b20c98e commit 6b98a63
Show file tree
Hide file tree
Showing 13 changed files with 86 additions and 12 deletions.
1 change: 1 addition & 0 deletions deps/uv/.mailmap
Expand Up @@ -5,3 +5,4 @@
<bertbelder@gmail.com> <info@2bs.nl>
<alan@prettyrobots.com> <alan@blogometer.com>
San-Tai Hsu <vanilla@fatpipi.com>
Isaac Z. Schlueter <i@izs.me>
3 changes: 3 additions & 0 deletions deps/uv/AUTHORS
Expand Up @@ -21,3 +21,6 @@ Clifford Heath <clifford.heath@gmail.com>
Jorge Chamorro Bieling <jorge@jorgechamorro.com>
Luis Lavena <luislavena@gmail.com>
Matthew Sporleder <msporleder@gmail.com>
Erick Tryzelaar <erick.tryzelaar@gmail.com>
Isaac Z. Schlueter <i@izs.me>
Pieter Noordhuis <pcnoordhuis@gmail.com>
2 changes: 1 addition & 1 deletion deps/uv/common.gypi
Expand Up @@ -113,7 +113,7 @@
'cflags_cc': [ '-fno-rtti', '-fno-exceptions' ],
'ldflags': [ '-pthread', ],
'conditions': [
[ 'target_arch=="ia32"', {
[ 'host_arch != target_arch and target_arch=="ia32"', {
'cflags': [ '-m32' ],
'ldflags': [ '-m32' ],
}],
Expand Down
5 changes: 5 additions & 0 deletions deps/uv/include/uv.h
Expand Up @@ -600,6 +600,11 @@ struct uv_tty_s {
UV_TTY_PRIVATE_FIELDS
};

/*
* Returns 1 if file is associated with a Console/TTY 0 otherwise.
*/
int uv_is_tty(uv_file file);

int uv_tty_init(uv_loop_t*, uv_tty_t*, uv_file fd);

/*
Expand Down
12 changes: 9 additions & 3 deletions deps/uv/src/unix/core.c
Expand Up @@ -79,6 +79,7 @@ void uv_close(uv_handle_t* handle, uv_close_cb close_cb) {
uv_pipe_cleanup((uv_pipe_t*)handle);
/* Fall through. */

case UV_TTY:
case UV_TCP:
stream = (uv_stream_t*)handle;

Expand Down Expand Up @@ -231,6 +232,7 @@ void uv__finish_close(uv_handle_t* handle) {

case UV_NAMED_PIPE:
case UV_TCP:
case UV_TTY:
assert(!ev_is_active(&((uv_stream_t*)handle)->read_watcher));
assert(!ev_is_active(&((uv_stream_t*)handle)->write_watcher));
assert(((uv_stream_t*)handle)->fd == -1);
Expand Down Expand Up @@ -575,6 +577,8 @@ int64_t uv_timer_get_repeat(uv_timer_t* timer) {

static int uv_getaddrinfo_done(eio_req* req) {
uv_getaddrinfo_t* handle = req->data;
struct addrinfo *res = handle->res;
handle->res = NULL;

uv_unref(handle->loop);

Expand All @@ -587,10 +591,9 @@ static int uv_getaddrinfo_done(eio_req* req) {
uv_err_new(handle->loop, handle->retcode);
}

handle->cb(handle, handle->retcode, handle->res);
handle->cb(handle, handle->retcode, res);

freeaddrinfo(handle->res);
handle->res = NULL;
freeaddrinfo(res);

return 0;
}
Expand Down Expand Up @@ -633,6 +636,9 @@ int uv_getaddrinfo(uv_loop_t* loop,
handle->hints = malloc(sizeof(struct addrinfo));
memcpy(&handle->hints, hints, sizeof(struct addrinfo));
}
else {
handle->hints = NULL;
}

/* TODO security! check lengths, check return values. */

Expand Down
5 changes: 3 additions & 2 deletions deps/uv/src/unix/stream.c
Expand Up @@ -679,8 +679,9 @@ int uv_write(uv_write_t* req, uv_stream_t* stream, uv_buf_t bufs[], int bufcnt,
uv_write_cb cb) {
int empty_queue;

assert((stream->type == UV_TCP || stream->type == UV_NAMED_PIPE)
&& "uv_write (unix) does not yet support other types of streams");
assert((stream->type == UV_TCP || stream->type == UV_NAMED_PIPE ||
stream->type == UV_TTY) &&
"uv_write (unix) does not yet support other types of streams");

if (stream->fd < 0) {
uv_err_new(stream->loop, EBADF);
Expand Down
4 changes: 4 additions & 0 deletions deps/uv/src/unix/tty.c
Expand Up @@ -67,3 +67,7 @@ int uv_tty_set_mode(uv_tty_t* tty, int mode) {
return -1;
}


int uv_is_tty(uv_file file) {
return isatty(file);
}
9 changes: 7 additions & 2 deletions deps/uv/src/win/process.c
Expand Up @@ -845,14 +845,19 @@ static int duplicate_std_handle(uv_loop_t* loop, DWORD id, HANDLE* dup) {
int uv_spawn(uv_loop_t* loop, uv_process_t* process,
uv_process_options_t options) {
int err = 0, keep_child_stdio_open = 0;
wchar_t* path;
wchar_t* path = NULL;
int size;
BOOL result;
wchar_t* application_path, *application, *arguments, *env, *cwd;
wchar_t* application_path = NULL, *application = NULL, *arguments = NULL, *env = NULL, *cwd = NULL;
HANDLE* child_stdio = process->child_stdio;
STARTUPINFOW startup;
PROCESS_INFORMATION info;

if (!options.file) {
uv_set_error(loop, UV_EINVAL, 0);
return -1;
}

uv_process_init(loop, process);

process->exit_cb = options.exit_cb;
Expand Down
7 changes: 7 additions & 0 deletions deps/uv/src/win/tty.c
Expand Up @@ -35,3 +35,10 @@ int uv_tty_set_mode(uv_tty_t* tty, int mode) {
assert(0 && "implement me");
return -1;
}


int uv_is_tty(uv_file file) {
DWORD result;
int r = GetConsoleMode((HANDLE)_get_osfhandle(file), &result);
return r ? 1 : 0;
}
8 changes: 5 additions & 3 deletions deps/uv/test/test-getaddrinfo.c
Expand Up @@ -31,19 +31,20 @@

static const char* name = "localhost";

static uv_getaddrinfo_t getaddrinfo_handle;
static int getaddrinfo_cbs = 0;

/* data used for running multiple calls concurrently */
static uv_getaddrinfo_t* getaddrinfo_handle;
static uv_getaddrinfo_t getaddrinfo_handles[CONCURRENT_COUNT];
static int callback_counts[CONCURRENT_COUNT];


static void getaddrinfo_basic_cb(uv_getaddrinfo_t* handle,
int status,
struct addrinfo* res) {
ASSERT(handle == &getaddrinfo_handle);
ASSERT(handle == getaddrinfo_handle);
getaddrinfo_cbs++;
free(handle);
}


Expand Down Expand Up @@ -71,9 +72,10 @@ static void getaddrinfo_cuncurrent_cb(uv_getaddrinfo_t* handle,

TEST_IMPL(getaddrinfo_basic) {
int r;
getaddrinfo_handle = (uv_getaddrinfo_t*)malloc(sizeof(uv_getaddrinfo_t));

r = uv_getaddrinfo(uv_default_loop(),
&getaddrinfo_handle,
getaddrinfo_handle,
&getaddrinfo_basic_cb,
name,
NULL,
Expand Down
3 changes: 3 additions & 0 deletions deps/uv/test/test-list.h
Expand Up @@ -19,6 +19,7 @@
* IN THE SOFTWARE.
*/

TEST_DECLARE (tty)
TEST_DECLARE (tcp_ping_pong)
TEST_DECLARE (tcp_ping_pong_v6)
TEST_DECLARE (pipe_ping_pong)
Expand Down Expand Up @@ -98,6 +99,8 @@ HELPER_DECLARE (pipe_echo_server)


TASK_LIST_START
TEST_ENTRY (tty)

TEST_ENTRY (tcp_ping_pong)
TEST_HELPER (tcp_ping_pong, tcp4_echo_server)

Expand Down
33 changes: 33 additions & 0 deletions deps/uv/test/test-tty.c
@@ -0,0 +1,33 @@
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to
* deal in the Software without restriction, including without limitation the
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
* sell copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in
* all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
* IN THE SOFTWARE.
*/

#include "uv.h"
#include "task.h"

TEST_IMPL(tty) {
uv_loop_t* loop = uv_default_loop();

ASSERT(uv_is_tty(0) == 1);

uv_run(loop);

return 0;
}
6 changes: 5 additions & 1 deletion deps/uv/uv.gyp
Expand Up @@ -194,7 +194,10 @@
'include_dirs': [ 'src/ares/config_darwin' ],
'sources': [ 'src/unix/darwin.c' ],
'direct_dependent_settings': {
'libraries': [ '-framework CoreServices' ],
'libraries': [
'$(SDKROOT)/System/Library/Frameworks/Carbon.framework',
'$(SDKROOT)/System/Library/Frameworks/CoreServices.framework',
],
},
'defines': [
'EV_CONFIG_H="config_darwin.h"',
Expand Down Expand Up @@ -261,6 +264,7 @@
'test/test-tcp-bind-error.c',
'test/test-tcp-bind6-error.c',
'test/test-tcp-close.c',
'test/test-tcp-write-error.c',
'test/test-tcp-writealot.c',
'test/test-threadpool.c',
'test/test-timer-again.c',
Expand Down

0 comments on commit 6b98a63

Please sign in to comment.