mirror of https://github.com/lukechilds/node.git
Browse Source
PR-URL: https://github.com/nodejs/node/pull/2310 Reviewed-By: bnoordhuis - Ben Noordhuis <info@bnoordhuis.nl> Reviewed-By: cjihrig - Colin Ihrig <cjihrig@gmail.com>v4.0.0-rc
Saúl Ibarra Corretgé
10 years ago
committed by
Rod Vagg
Rod Vagg
78 changed files with 2772 additions and 651 deletions
@ -0,0 +1,36 @@ |
|||||
|
|
||||
|
# Project Maintainers |
||||
|
|
||||
|
libuv is currently managed by the following individuals: |
||||
|
|
||||
|
* **Ben Noordhuis** ([@bnoordhuis](https://github.com/bnoordhuis)) |
||||
|
- GPG key: D77B 1E34 243F BAF0 5F8E 9CC3 4F55 C8C8 46AB 89B9 (pubkey-bnoordhuis) |
||||
|
* **Bert Belder** ([@piscisaureus](https://github.com/piscisaureus)) |
||||
|
* **Fedor Indutny** ([@indutny](https://github.com/indutny)) |
||||
|
- GPG key: AF2E EA41 EC34 47BF DD86 FED9 D706 3CCE 19B7 E890 (pubkey-indutny) |
||||
|
* **Saúl Ibarra Corretgé** ([@saghul](https://github.com/saghul)) |
||||
|
- GPG key: FDF5 1936 4458 319F A823 3DC9 410E 5553 AE9B C059 (pubkey-saghul) |
||||
|
|
||||
|
## Storing a maintainer key in Git |
||||
|
|
||||
|
It's quite handy to store a maintainer's signature as a git blob, and have |
||||
|
that object tagged and signed with such key. |
||||
|
|
||||
|
Export your public key: |
||||
|
|
||||
|
$ gpg --armor --export saghul@gmail.com > saghul.asc |
||||
|
|
||||
|
Store it as a blob on the repo: |
||||
|
|
||||
|
$ git hash-object -w saghul.asc |
||||
|
|
||||
|
The previous command returns a hash, copy it. For the sake of this explanation, |
||||
|
we'll assume it's 'abcd1234'. Storing the blob in git is not enough, it could |
||||
|
be garbage collected since nothing references it, so we'll create a tag for it: |
||||
|
|
||||
|
$ git tag -s pubkey-saghul abcd1234 |
||||
|
|
||||
|
Commit the changes and push: |
||||
|
|
||||
|
$ git push origin pubkey-saghul |
||||
|
|
||||
@ -0,0 +1,36 @@ |
|||||
|
version: v1.7.3.build{build} |
||||
|
|
||||
|
install: |
||||
|
- cinst -y nsis |
||||
|
|
||||
|
matrix: |
||||
|
fast_finish: true |
||||
|
allow_failures: |
||||
|
- platform: x86 |
||||
|
configuration: Release |
||||
|
- platform: x64 |
||||
|
configuration: Release |
||||
|
|
||||
|
platform: |
||||
|
- x86 |
||||
|
- x64 |
||||
|
|
||||
|
configuration: |
||||
|
- Release |
||||
|
|
||||
|
build_script: |
||||
|
# Fixed tag version number if using a tag. |
||||
|
- cmd: if "%APPVEYOR_REPO_TAG%" == "true" set APPVEYOR_BUILD_VERSION=%APPVEYOR_REPO_TAG_NAME% |
||||
|
# vcbuild overwrites the platform variable. |
||||
|
- cmd: set ARCH=%platform% |
||||
|
- cmd: vcbuild.bat release %ARCH% shared |
||||
|
|
||||
|
after_build: |
||||
|
- '"%PROGRAMFILES(x86)%\NSIS\makensis" /DVERSION=%APPVEYOR_BUILD_VERSION% /DARCH=%ARCH% libuv.nsi' |
||||
|
|
||||
|
artifacts: |
||||
|
- name: Installer |
||||
|
path: 'libuv-*.exe' |
||||
|
|
||||
|
cache: |
||||
|
- C:\projects\libuv\build\gyp |
||||
@ -0,0 +1,60 @@ |
|||||
|
|
||||
|
.. _version: |
||||
|
|
||||
|
Version-checking macros and functions |
||||
|
===================================== |
||||
|
|
||||
|
Starting with version 1.0.0 libuv follows the `semantic versioning`_ |
||||
|
scheme. This means that new APIs can be introduced throughout the lifetime of |
||||
|
a major release. In this section you'll find all macros and functions that |
||||
|
will allow you to write or compile code conditionally, in order to work with |
||||
|
multiple libuv versions. |
||||
|
|
||||
|
.. _semantic versioning: http://semver.org |
||||
|
|
||||
|
|
||||
|
Macros |
||||
|
------ |
||||
|
|
||||
|
.. c:macro:: UV_VERSION_MAJOR |
||||
|
|
||||
|
libuv version's major number. |
||||
|
|
||||
|
.. c:macro:: UV_VERSION_MINOR |
||||
|
|
||||
|
libuv version's minor number. |
||||
|
|
||||
|
.. c:macro:: UV_VERSION_PATCH |
||||
|
|
||||
|
libuv version's patch number. |
||||
|
|
||||
|
.. c:macro:: UV_VERSION_IS_RELEASE |
||||
|
|
||||
|
Set to 1 to indicate a release version of libuv, 0 for a development |
||||
|
snapshot. |
||||
|
|
||||
|
.. c:macro:: UV_VERSION_SUFFIX |
||||
|
|
||||
|
libuv version suffix. Certain development releases such as Release Candidates |
||||
|
might have a suffix such as "rc". |
||||
|
|
||||
|
.. c:macro:: UV_VERSION_HEX |
||||
|
|
||||
|
Returns the libuv version packed into a single integer. 8 bits are used for |
||||
|
each component, with the patch number stored in the 8 least significant |
||||
|
bits. E.g. for libuv 1.2.3 this would be 0x010203. |
||||
|
|
||||
|
.. versionadded:: 1.7.0 |
||||
|
|
||||
|
|
||||
|
Functions |
||||
|
--------- |
||||
|
|
||||
|
.. c:function:: unsigned int uv_version(void) |
||||
|
|
||||
|
Returns :c:macro:`UV_VERSION_HEX`. |
||||
|
|
||||
|
.. c:function:: const char* uv_version_string(void) |
||||
|
|
||||
|
Returns the libuv version number as a string. For non-release versions the |
||||
|
version suffix is included. |
||||
@ -0,0 +1,86 @@ |
|||||
|
; NSIS installer script for libuv |
||||
|
|
||||
|
!include "MUI2.nsh" |
||||
|
|
||||
|
Name "libuv" |
||||
|
OutFile "libuv-${ARCH}-${VERSION}.exe" |
||||
|
|
||||
|
!include "x64.nsh" |
||||
|
# Default install location, for 32-bit files |
||||
|
InstallDir "$PROGRAMFILES\libuv" |
||||
|
|
||||
|
# Override install and registry locations if this is a 64-bit install. |
||||
|
function .onInit |
||||
|
${If} ${ARCH} == "x64" |
||||
|
SetRegView 64 |
||||
|
StrCpy $INSTDIR "$PROGRAMFILES64\libuv" |
||||
|
${EndIf} |
||||
|
functionEnd |
||||
|
|
||||
|
;-------------------------------- |
||||
|
; Installer pages |
||||
|
!insertmacro MUI_PAGE_WELCOME |
||||
|
!insertmacro MUI_PAGE_DIRECTORY |
||||
|
!insertmacro MUI_PAGE_INSTFILES |
||||
|
!insertmacro MUI_PAGE_FINISH |
||||
|
|
||||
|
|
||||
|
;-------------------------------- |
||||
|
; Uninstaller pages |
||||
|
!insertmacro MUI_UNPAGE_WELCOME |
||||
|
!insertmacro MUI_UNPAGE_CONFIRM |
||||
|
!insertmacro MUI_UNPAGE_INSTFILES |
||||
|
!insertmacro MUI_UNPAGE_FINISH |
||||
|
|
||||
|
;-------------------------------- |
||||
|
; Languages |
||||
|
!insertmacro MUI_LANGUAGE "English" |
||||
|
|
||||
|
;-------------------------------- |
||||
|
; Installer sections |
||||
|
|
||||
|
Section "Files" SecInstall |
||||
|
SectionIn RO |
||||
|
SetOutPath "$INSTDIR" |
||||
|
File "Release\*.dll" |
||||
|
File "Release\*.lib" |
||||
|
File "LICENSE" |
||||
|
File "README.md" |
||||
|
|
||||
|
SetOutPath "$INSTDIR\include" |
||||
|
File "include\uv.h" |
||||
|
File "include\uv-errno.h" |
||||
|
File "include\uv-threadpool.h" |
||||
|
File "include\uv-version.h" |
||||
|
File "include\uv-win.h" |
||||
|
File "include\tree.h" |
||||
|
|
||||
|
WriteUninstaller "$INSTDIR\Uninstall.exe" |
||||
|
WriteRegStr HKLM "Software\Microsoft\Windows\CurrentVersion\Uninstall\libuv-${ARCH}-${VERSION}" "DisplayName" "libuv-${ARCH}-${VERSION}" |
||||
|
WriteRegStr HKLM "Software\Microsoft\Windows\CurrentVersion\Uninstall\libuv-${ARCH}-${VERSION}" "UninstallString" "$\"$INSTDIR\Uninstall.exe$\"" |
||||
|
WriteRegStr HKLM "Software\Microsoft\Windows\CurrentVersion\Uninstall\libuv-${ARCH}-${VERSION}" "QuietUninstallString" "$\"$INSTDIR\Uninstall.exe$\" /S" |
||||
|
WriteRegStr HKLM "Software\Microsoft\Windows\CurrentVersion\Uninstall\libuv-${ARCH}-${VERSION}" "HelpLink" "http://libuv.org/" |
||||
|
WriteRegStr HKLM "Software\Microsoft\Windows\CurrentVersion\Uninstall\libuv-${ARCH}-${VERSION}" "URLInfoAbout" "http://libuv.org/" |
||||
|
WriteRegStr HKLM "Software\Microsoft\Windows\CurrentVersion\Uninstall\libuv-${ARCH}-${VERSION}" "DisplayVersion" "${VERSION}" |
||||
|
WriteRegDWORD HKLM "Software\Microsoft\Windows\CurrentVersion\Uninstall\libuv-${ARCH}-${VERSION}" "NoModify" "1" |
||||
|
WriteRegDWORD HKLM "Software\Microsoft\Windows\CurrentVersion\Uninstall\libuv-${ARCH}-${VERSION}" "NoRepair" "1" |
||||
|
SectionEnd |
||||
|
|
||||
|
Section "Uninstall" |
||||
|
Delete "$INSTDIR\libuv.dll" |
||||
|
Delete "$INSTDIR\libuv.lib" |
||||
|
Delete "$INSTDIR\LICENSE" |
||||
|
Delete "$INSTDIR\README.md" |
||||
|
|
||||
|
Delete "$INSTDIR\include\uv.h" |
||||
|
Delete "$INSTDIR\include\uv-errno.h" |
||||
|
Delete "$INSTDIR\include\uv-threadpool.h" |
||||
|
Delete "$INSTDIR\include\uv-version.h" |
||||
|
Delete "$INSTDIR\include\uv-win.h" |
||||
|
Delete "$INSTDIR\include\tree.h" |
||||
|
|
||||
|
Delete "$INSTDIR\Uninstall.exe" |
||||
|
RMDir "$INSTDIR" |
||||
|
DeleteRegKey HKLM "Software\Microsoft\Windows\CurrentVersion\Uninstall\libuv-${ARCH}-${VERSION}" |
||||
|
SectionEnd |
||||
|
|
||||
File diff suppressed because it is too large
@ -0,0 +1,104 @@ |
|||||
|
/* Copyright (c) 2015 Saúl Ibarra Corretgé <saghul@gmail.com>.
|
||||
|
* 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" |
||||
|
#include <stdio.h> |
||||
|
#include <stdlib.h> |
||||
|
|
||||
|
|
||||
|
static int connection_cb_called = 0; |
||||
|
static int connect_cb_called = 0; |
||||
|
|
||||
|
#define NUM_CLIENTS 4 |
||||
|
|
||||
|
typedef struct { |
||||
|
uv_pipe_t pipe_handle; |
||||
|
uv_connect_t conn_req; |
||||
|
} client_t; |
||||
|
|
||||
|
static uv_pipe_t server_handle; |
||||
|
static client_t clients[NUM_CLIENTS]; |
||||
|
static uv_pipe_t connections[NUM_CLIENTS]; |
||||
|
|
||||
|
|
||||
|
static void connection_cb(uv_stream_t* server, int status) { |
||||
|
int r; |
||||
|
uv_pipe_t* conn; |
||||
|
ASSERT(status == 0); |
||||
|
|
||||
|
conn = &connections[connection_cb_called]; |
||||
|
r = uv_pipe_init(server->loop, conn, 0); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_accept(server, (uv_stream_t*)conn); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
if (++connection_cb_called == NUM_CLIENTS && |
||||
|
connect_cb_called == NUM_CLIENTS) { |
||||
|
uv_stop(server->loop); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
|
||||
|
static void connect_cb(uv_connect_t* connect_req, int status) { |
||||
|
ASSERT(status == 0); |
||||
|
if (++connect_cb_called == NUM_CLIENTS && |
||||
|
connection_cb_called == NUM_CLIENTS) { |
||||
|
uv_stop(connect_req->handle->loop); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(pipe_connect_multiple) { |
||||
|
int i; |
||||
|
int r; |
||||
|
uv_loop_t* loop; |
||||
|
|
||||
|
loop = uv_default_loop(); |
||||
|
|
||||
|
r = uv_pipe_init(loop, &server_handle, 0); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_pipe_bind(&server_handle, TEST_PIPENAME); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_listen((uv_stream_t*)&server_handle, 128, connection_cb); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
for (i = 0; i < NUM_CLIENTS; i++) { |
||||
|
r = uv_pipe_init(loop, &clients[i].pipe_handle, 0); |
||||
|
ASSERT(r == 0); |
||||
|
uv_pipe_connect(&clients[i].conn_req, |
||||
|
&clients[i].pipe_handle, |
||||
|
TEST_PIPENAME, |
||||
|
connect_cb); |
||||
|
} |
||||
|
|
||||
|
uv_run(loop, UV_RUN_DEFAULT); |
||||
|
|
||||
|
ASSERT(connection_cb_called == NUM_CLIENTS); |
||||
|
ASSERT(connect_cb_called == NUM_CLIENTS); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
@ -0,0 +1,59 @@ |
|||||
|
/* Copyright (c) 2015 Saúl Ibarra Corretgé <saghul@gmail.com>.
|
||||
|
* 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" |
||||
|
|
||||
|
|
||||
|
static void connection_cb(uv_stream_t* server, int status) { |
||||
|
ASSERT(0 && "this will never be called"); |
||||
|
} |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(pipe_pending_instances) { |
||||
|
int r; |
||||
|
uv_pipe_t pipe_handle; |
||||
|
uv_loop_t* loop; |
||||
|
|
||||
|
loop = uv_default_loop(); |
||||
|
|
||||
|
r = uv_pipe_init(loop, &pipe_handle, 0); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
uv_pipe_pending_instances(&pipe_handle, 8); |
||||
|
|
||||
|
r = uv_pipe_bind(&pipe_handle, TEST_PIPENAME); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
uv_pipe_pending_instances(&pipe_handle, 16); |
||||
|
|
||||
|
r = uv_listen((uv_stream_t*)&pipe_handle, 128, connection_cb); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
uv_close((uv_handle_t*)&pipe_handle, NULL); |
||||
|
|
||||
|
r = uv_run(loop, UV_RUN_DEFAULT); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
@ -0,0 +1,206 @@ |
|||||
|
/* Copyright (c) 2015 Saúl Ibarra Corretgé <saghul@gmail.com>.
|
||||
|
* 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" |
||||
|
#include <string.h> |
||||
|
|
||||
|
#ifdef _WIN32 |
||||
|
# define INVALID_FD (INVALID_HANDLE_VALUE) |
||||
|
#else |
||||
|
# define INVALID_FD (-1) |
||||
|
#endif |
||||
|
|
||||
|
|
||||
|
static void on_connect(uv_connect_t* req, int status) { |
||||
|
ASSERT(status == 0); |
||||
|
uv_close((uv_handle_t*) req->handle, NULL); |
||||
|
} |
||||
|
|
||||
|
|
||||
|
static void on_connection(uv_stream_t* server, int status) { |
||||
|
uv_tcp_t* handle; |
||||
|
int r; |
||||
|
|
||||
|
ASSERT(status == 0); |
||||
|
|
||||
|
handle = malloc(sizeof(*handle)); |
||||
|
ASSERT(handle != NULL); |
||||
|
|
||||
|
r = uv_tcp_init_ex(server->loop, handle, AF_INET); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_accept(server, (uv_stream_t*)handle); |
||||
|
ASSERT(r == UV_EBUSY); |
||||
|
|
||||
|
uv_close((uv_handle_t*) server, NULL); |
||||
|
uv_close((uv_handle_t*) handle, (uv_close_cb)free); |
||||
|
} |
||||
|
|
||||
|
|
||||
|
static void tcp_listener(uv_loop_t* loop, uv_tcp_t* server) { |
||||
|
struct sockaddr_in addr; |
||||
|
int r; |
||||
|
|
||||
|
ASSERT(0 == uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); |
||||
|
|
||||
|
r = uv_tcp_init(loop, server); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_tcp_bind(server, (const struct sockaddr*) &addr, 0); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_listen((uv_stream_t*) server, 128, on_connection); |
||||
|
ASSERT(r == 0); |
||||
|
} |
||||
|
|
||||
|
|
||||
|
static void tcp_connector(uv_loop_t* loop, uv_tcp_t* client, uv_connect_t* req) { |
||||
|
struct sockaddr_in server_addr; |
||||
|
int r; |
||||
|
|
||||
|
ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &server_addr)); |
||||
|
|
||||
|
r = uv_tcp_init(loop, client); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_tcp_connect(req, |
||||
|
client, |
||||
|
(const struct sockaddr*) &server_addr, |
||||
|
on_connect); |
||||
|
ASSERT(r == 0); |
||||
|
} |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(tcp_create_early) { |
||||
|
struct sockaddr_in addr; |
||||
|
struct sockaddr_in sockname; |
||||
|
uv_tcp_t client; |
||||
|
uv_os_fd_t fd; |
||||
|
int r, namelen; |
||||
|
|
||||
|
ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); |
||||
|
|
||||
|
r = uv_tcp_init_ex(uv_default_loop(), &client, AF_INET); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_fileno((const uv_handle_t*) &client, &fd); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(fd != INVALID_FD); |
||||
|
|
||||
|
/* Windows returns WSAEINVAL if the socket is not bound */ |
||||
|
#ifndef _WIN32 |
||||
|
namelen = sizeof sockname; |
||||
|
r = uv_tcp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(sockname.sin_family == AF_INET); |
||||
|
#endif |
||||
|
|
||||
|
r = uv_tcp_bind(&client, (const struct sockaddr*) &addr, 0); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
namelen = sizeof sockname; |
||||
|
r = uv_tcp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(memcmp(&addr.sin_addr, |
||||
|
&sockname.sin_addr, |
||||
|
sizeof(addr.sin_addr)) == 0); |
||||
|
|
||||
|
uv_close((uv_handle_t*) &client, NULL); |
||||
|
uv_run(uv_default_loop(), UV_RUN_DEFAULT); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(tcp_create_early_bad_bind) { |
||||
|
struct sockaddr_in addr; |
||||
|
uv_tcp_t client; |
||||
|
uv_os_fd_t fd; |
||||
|
int r; |
||||
|
|
||||
|
ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); |
||||
|
|
||||
|
r = uv_tcp_init_ex(uv_default_loop(), &client, AF_INET6); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_fileno((const uv_handle_t*) &client, &fd); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(fd != INVALID_FD); |
||||
|
|
||||
|
/* Windows returns WSAEINVAL if the socket is not bound */ |
||||
|
#ifndef _WIN32 |
||||
|
{ |
||||
|
int namelen; |
||||
|
struct sockaddr_in6 sockname; |
||||
|
namelen = sizeof sockname; |
||||
|
r = uv_tcp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(sockname.sin6_family == AF_INET6); |
||||
|
} |
||||
|
#endif |
||||
|
|
||||
|
r = uv_tcp_bind(&client, (const struct sockaddr*) &addr, 0); |
||||
|
#ifndef _WIN32 |
||||
|
ASSERT(r == UV_EINVAL); |
||||
|
#else |
||||
|
ASSERT(r == UV_EFAULT); |
||||
|
#endif |
||||
|
|
||||
|
uv_close((uv_handle_t*) &client, NULL); |
||||
|
uv_run(uv_default_loop(), UV_RUN_DEFAULT); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(tcp_create_early_bad_domain) { |
||||
|
uv_tcp_t client; |
||||
|
int r; |
||||
|
|
||||
|
r = uv_tcp_init_ex(uv_default_loop(), &client, 47); |
||||
|
ASSERT(r == UV_EINVAL); |
||||
|
|
||||
|
r = uv_tcp_init_ex(uv_default_loop(), &client, 1024); |
||||
|
ASSERT(r == UV_EINVAL); |
||||
|
|
||||
|
uv_run(uv_default_loop(), UV_RUN_DEFAULT); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(tcp_create_early_accept) { |
||||
|
uv_tcp_t client, server; |
||||
|
uv_connect_t connect_req; |
||||
|
|
||||
|
tcp_listener(uv_default_loop(), &server); |
||||
|
tcp_connector(uv_default_loop(), &client, &connect_req); |
||||
|
|
||||
|
uv_run(uv_default_loop(), UV_RUN_DEFAULT); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
@ -0,0 +1,119 @@ |
|||||
|
/* Copyright (c) 2015, Santiago Gimeno <santiago.gimeno@gmail.com>
|
||||
|
* |
||||
|
* 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" |
||||
|
#include <stdio.h> |
||||
|
#include <stdlib.h> |
||||
|
|
||||
|
|
||||
|
static uv_tcp_t tcp_server; |
||||
|
static uv_tcp_t tcp_client; |
||||
|
static uv_tcp_t tcp_server_client; |
||||
|
static uv_connect_t connect_req; |
||||
|
static uv_write_t write_req; |
||||
|
|
||||
|
static void alloc_cb(uv_handle_t* handle, |
||||
|
size_t size, |
||||
|
uv_buf_t* buf) { |
||||
|
buf->base = malloc(size); |
||||
|
buf->len = size; |
||||
|
} |
||||
|
|
||||
|
static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { |
||||
|
free(buf->base); |
||||
|
ASSERT(nread == UV_EOF); |
||||
|
} |
||||
|
|
||||
|
static void on_connect(uv_connect_t* req, int status) { |
||||
|
int r; |
||||
|
uv_buf_t outbuf; |
||||
|
|
||||
|
ASSERT(req != NULL); |
||||
|
ASSERT(status == 0); |
||||
|
|
||||
|
outbuf = uv_buf_init("ping", 4); |
||||
|
r = uv_write(&write_req, (uv_stream_t*) req->handle, &outbuf, 1, NULL); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_read_start((uv_stream_t*) req->handle, alloc_cb, read_cb); |
||||
|
ASSERT(r == 0); |
||||
|
} |
||||
|
|
||||
|
static void on_connection(uv_stream_t* server, int status) { |
||||
|
int r; |
||||
|
|
||||
|
ASSERT(status == 0); |
||||
|
|
||||
|
r = uv_tcp_init(uv_default_loop(), &tcp_server_client); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_accept(server, (uv_stream_t*) &tcp_server_client); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
uv_close((uv_handle_t*) &tcp_server_client, NULL); |
||||
|
uv_close((uv_handle_t*) &tcp_server, NULL); |
||||
|
} |
||||
|
|
||||
|
static void start_server(void) { |
||||
|
struct sockaddr_in addr; |
||||
|
int r; |
||||
|
|
||||
|
ASSERT(0 == uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); |
||||
|
|
||||
|
r = uv_tcp_init(uv_default_loop(), &tcp_server); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_tcp_bind(&tcp_server, (const struct sockaddr*) &addr, 0); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_listen((uv_stream_t*) &tcp_server, SOMAXCONN, on_connection); |
||||
|
ASSERT(r == 0); |
||||
|
} |
||||
|
|
||||
|
static void start_client(void) { |
||||
|
struct sockaddr_in addr; |
||||
|
int r; |
||||
|
|
||||
|
ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); |
||||
|
|
||||
|
r = uv_tcp_init(uv_default_loop(), &tcp_client); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_tcp_connect(&connect_req, |
||||
|
&tcp_client, |
||||
|
(const struct sockaddr*) &addr, |
||||
|
on_connect); |
||||
|
ASSERT(r == 0); |
||||
|
} |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(tcp_squelch_connreset) { |
||||
|
|
||||
|
start_server(); |
||||
|
|
||||
|
start_client(); |
||||
|
|
||||
|
uv_run(uv_default_loop(), UV_RUN_DEFAULT); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
@ -0,0 +1,132 @@ |
|||||
|
/* Copyright (c) 2015 Saúl Ibarra Corretgé <saghul@gmail.com>.
|
||||
|
* 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" |
||||
|
#include <string.h> |
||||
|
|
||||
|
#ifdef _WIN32 |
||||
|
# define INVALID_FD (INVALID_HANDLE_VALUE) |
||||
|
#else |
||||
|
# define INVALID_FD (-1) |
||||
|
#endif |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(udp_create_early) { |
||||
|
struct sockaddr_in addr; |
||||
|
struct sockaddr_in sockname; |
||||
|
uv_udp_t client; |
||||
|
uv_os_fd_t fd; |
||||
|
int r, namelen; |
||||
|
|
||||
|
ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); |
||||
|
|
||||
|
r = uv_udp_init_ex(uv_default_loop(), &client, AF_INET); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_fileno((const uv_handle_t*) &client, &fd); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(fd != INVALID_FD); |
||||
|
|
||||
|
/* Windows returns WSAEINVAL if the socket is not bound */ |
||||
|
#ifndef _WIN32 |
||||
|
namelen = sizeof sockname; |
||||
|
r = uv_udp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(sockname.sin_family == AF_INET); |
||||
|
#endif |
||||
|
|
||||
|
r = uv_udp_bind(&client, (const struct sockaddr*) &addr, 0); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
namelen = sizeof sockname; |
||||
|
r = uv_udp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(memcmp(&addr.sin_addr, |
||||
|
&sockname.sin_addr, |
||||
|
sizeof(addr.sin_addr)) == 0); |
||||
|
|
||||
|
uv_close((uv_handle_t*) &client, NULL); |
||||
|
uv_run(uv_default_loop(), UV_RUN_DEFAULT); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(udp_create_early_bad_bind) { |
||||
|
struct sockaddr_in addr; |
||||
|
uv_udp_t client; |
||||
|
uv_os_fd_t fd; |
||||
|
int r; |
||||
|
|
||||
|
ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); |
||||
|
|
||||
|
r = uv_udp_init_ex(uv_default_loop(), &client, AF_INET6); |
||||
|
ASSERT(r == 0); |
||||
|
|
||||
|
r = uv_fileno((const uv_handle_t*) &client, &fd); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(fd != INVALID_FD); |
||||
|
|
||||
|
/* Windows returns WSAEINVAL if the socket is not bound */ |
||||
|
#ifndef _WIN32 |
||||
|
{ |
||||
|
int namelen; |
||||
|
struct sockaddr_in6 sockname; |
||||
|
namelen = sizeof sockname; |
||||
|
r = uv_udp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); |
||||
|
ASSERT(r == 0); |
||||
|
ASSERT(sockname.sin6_family == AF_INET6); |
||||
|
} |
||||
|
#endif |
||||
|
|
||||
|
r = uv_udp_bind(&client, (const struct sockaddr*) &addr, 0); |
||||
|
#ifndef _WIN32 |
||||
|
ASSERT(r == UV_EINVAL); |
||||
|
#else |
||||
|
ASSERT(r == UV_EFAULT); |
||||
|
#endif |
||||
|
|
||||
|
uv_close((uv_handle_t*) &client, NULL); |
||||
|
uv_run(uv_default_loop(), UV_RUN_DEFAULT); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
|
|
||||
|
|
||||
|
TEST_IMPL(udp_create_early_bad_domain) { |
||||
|
uv_udp_t client; |
||||
|
int r; |
||||
|
|
||||
|
r = uv_udp_init_ex(uv_default_loop(), &client, 47); |
||||
|
ASSERT(r == UV_EINVAL); |
||||
|
|
||||
|
r = uv_udp_init_ex(uv_default_loop(), &client, 1024); |
||||
|
ASSERT(r == UV_EINVAL); |
||||
|
|
||||
|
uv_run(uv_default_loop(), UV_RUN_DEFAULT); |
||||
|
|
||||
|
MAKE_VALGRIND_HAPPY(); |
||||
|
return 0; |
||||
|
} |
||||
Loading…
Reference in new issue