|
Packit |
b5b901 |
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
Packit |
b5b901 |
* of this software and associated documentation files (the "Software"), to
|
|
Packit |
b5b901 |
* deal in the Software without restriction, including without limitation the
|
|
Packit |
b5b901 |
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
|
|
Packit |
b5b901 |
* sell copies of the Software, and to permit persons to whom the Software is
|
|
Packit |
b5b901 |
* furnished to do so, subject to the following conditions:
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* The above copyright notice and this permission notice shall be included in
|
|
Packit |
b5b901 |
* all copies or substantial portions of the Software.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
Packit |
b5b901 |
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
Packit |
b5b901 |
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
Packit |
b5b901 |
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
Packit |
b5b901 |
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
Packit |
b5b901 |
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
|
|
Packit |
b5b901 |
* IN THE SOFTWARE.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifndef UV_WIN_HANDLE_INL_H_
|
|
Packit |
b5b901 |
#define UV_WIN_HANDLE_INL_H_
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include <assert.h>
|
|
Packit |
b5b901 |
#include <io.h>
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include "uv.h"
|
|
Packit |
b5b901 |
#include "internal.h"
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define DECREASE_ACTIVE_COUNT(loop, handle) \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
if (--(handle)->activecnt == 0 && \
|
|
Packit |
b5b901 |
!((handle)->flags & UV_HANDLE_CLOSING)) { \
|
|
Packit |
b5b901 |
uv__handle_stop((handle)); \
|
|
Packit |
b5b901 |
} \
|
|
Packit |
b5b901 |
assert((handle)->activecnt >= 0); \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define INCREASE_ACTIVE_COUNT(loop, handle) \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
if ((handle)->activecnt++ == 0) { \
|
|
Packit |
b5b901 |
uv__handle_start((handle)); \
|
|
Packit |
b5b901 |
} \
|
|
Packit |
b5b901 |
assert((handle)->activecnt > 0); \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define DECREASE_PENDING_REQ_COUNT(handle) \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
assert(handle->reqs_pending > 0); \
|
|
Packit |
b5b901 |
handle->reqs_pending--; \
|
|
Packit |
b5b901 |
\
|
|
Packit |
b5b901 |
if (handle->flags & UV_HANDLE_CLOSING && \
|
|
Packit |
b5b901 |
handle->reqs_pending == 0) { \
|
|
Packit |
b5b901 |
uv_want_endgame(loop, (uv_handle_t*)handle); \
|
|
Packit |
b5b901 |
} \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define uv__handle_closing(handle) \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
assert(!((handle)->flags & UV_HANDLE_CLOSING)); \
|
|
Packit |
b5b901 |
\
|
|
Packit |
b5b901 |
if (!(((handle)->flags & UV_HANDLE_ACTIVE) && \
|
|
Packit |
b5b901 |
((handle)->flags & UV_HANDLE_REF))) \
|
|
Packit |
b5b901 |
uv__active_handle_add((uv_handle_t*) (handle)); \
|
|
Packit |
b5b901 |
\
|
|
Packit |
b5b901 |
(handle)->flags |= UV_HANDLE_CLOSING; \
|
|
Packit |
b5b901 |
(handle)->flags &= ~UV_HANDLE_ACTIVE; \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define uv__handle_close(handle) \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
QUEUE_REMOVE(&(handle)->handle_queue); \
|
|
Packit |
b5b901 |
uv__active_handle_rm((uv_handle_t*) (handle)); \
|
|
Packit |
b5b901 |
\
|
|
Packit |
b5b901 |
(handle)->flags |= UV_HANDLE_CLOSED; \
|
|
Packit |
b5b901 |
\
|
|
Packit |
b5b901 |
if ((handle)->close_cb) \
|
|
Packit |
b5b901 |
(handle)->close_cb((uv_handle_t*) (handle)); \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
INLINE static void uv_want_endgame(uv_loop_t* loop, uv_handle_t* handle) {
|
|
Packit |
b5b901 |
if (!(handle->flags & UV_HANDLE_ENDGAME_QUEUED)) {
|
|
Packit |
b5b901 |
handle->flags |= UV_HANDLE_ENDGAME_QUEUED;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
handle->endgame_next = loop->endgame_handles;
|
|
Packit |
b5b901 |
loop->endgame_handles = handle;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
INLINE static void uv_process_endgames(uv_loop_t* loop) {
|
|
Packit |
b5b901 |
uv_handle_t* handle;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
while (loop->endgame_handles) {
|
|
Packit |
b5b901 |
handle = loop->endgame_handles;
|
|
Packit |
b5b901 |
loop->endgame_handles = handle->endgame_next;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
handle->flags &= ~UV_HANDLE_ENDGAME_QUEUED;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
switch (handle->type) {
|
|
Packit |
b5b901 |
case UV_TCP:
|
|
Packit |
b5b901 |
uv_tcp_endgame(loop, (uv_tcp_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_NAMED_PIPE:
|
|
Packit |
b5b901 |
uv_pipe_endgame(loop, (uv_pipe_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_TTY:
|
|
Packit |
b5b901 |
uv_tty_endgame(loop, (uv_tty_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_UDP:
|
|
Packit |
b5b901 |
uv_udp_endgame(loop, (uv_udp_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_POLL:
|
|
Packit |
b5b901 |
uv_poll_endgame(loop, (uv_poll_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_TIMER:
|
|
Packit |
b5b901 |
uv__timer_close((uv_timer_t*) handle);
|
|
Packit |
b5b901 |
uv__handle_close(handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_PREPARE:
|
|
Packit |
b5b901 |
case UV_CHECK:
|
|
Packit |
b5b901 |
case UV_IDLE:
|
|
Packit |
b5b901 |
uv_loop_watcher_endgame(loop, handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_ASYNC:
|
|
Packit |
b5b901 |
uv_async_endgame(loop, (uv_async_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_SIGNAL:
|
|
Packit |
b5b901 |
uv_signal_endgame(loop, (uv_signal_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_PROCESS:
|
|
Packit |
b5b901 |
uv_process_endgame(loop, (uv_process_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_FS_EVENT:
|
|
Packit |
b5b901 |
uv_fs_event_endgame(loop, (uv_fs_event_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
case UV_FS_POLL:
|
|
Packit |
b5b901 |
uv__fs_poll_endgame(loop, (uv_fs_poll_t*) handle);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
default:
|
|
Packit |
b5b901 |
assert(0);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
INLINE static HANDLE uv__get_osfhandle(int fd)
|
|
Packit |
b5b901 |
{
|
|
Packit |
b5b901 |
/* _get_osfhandle() raises an assert in debug builds if the FD is invalid.
|
|
Packit |
b5b901 |
* But it also correctly checks the FD and returns INVALID_HANDLE_VALUE for
|
|
Packit |
b5b901 |
* invalid FDs in release builds (or if you let the assert continue). So this
|
|
Packit |
b5b901 |
* wrapper function disables asserts when calling _get_osfhandle. */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
HANDLE handle;
|
|
Packit |
b5b901 |
UV_BEGIN_DISABLE_CRT_ASSERT();
|
|
Packit |
b5b901 |
handle = (HANDLE) _get_osfhandle(fd);
|
|
Packit |
b5b901 |
UV_END_DISABLE_CRT_ASSERT();
|
|
Packit |
b5b901 |
return handle;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#endif /* UV_WIN_HANDLE_INL_H_ */
|