diff --git a/src/win/internal.h b/src/win/internal.h index d6c5d8b2..f5d0d172 100644 --- a/src/win/internal.h +++ b/src/win/internal.h @@ -88,12 +88,8 @@ /* - * Streams + * Streams: see stream-inl.h */ -void uv_stream_init(uv_loop_t* loop, uv_stream_t* handle); -void uv_connection_init(uv_stream_t* handle); - -size_t uv_count_bufs(uv_buf_t bufs[], int count); /* diff --git a/src/win/pipe.c b/src/win/pipe.c index 59511734..05510471 100644 --- a/src/win/pipe.c +++ b/src/win/pipe.c @@ -27,6 +27,7 @@ #include "uv.h" #include "internal.h" #include "handle-inl.h" +#include "stream-inl.h" #include "req-inl.h" diff --git a/src/win/stream-inl.h b/src/win/stream-inl.h new file mode 100644 index 00000000..91313566 --- /dev/null +++ b/src/win/stream-inl.h @@ -0,0 +1,67 @@ +/* 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. + */ + +#ifndef UV_WIN_STREAM_INL_H_ +#define UV_WIN_STREAM_INL_H_ + +#include + +#include "uv.h" +#include "internal.h" +#include "handle-inl.h" +#include "req-inl.h" + + +INLINE static void uv_stream_init(uv_loop_t* loop, uv_stream_t* handle) { + uv_handle_init(loop, (uv_handle_t*) handle); + handle->write_queue_size = 0; + handle->activecnt = 0; + + loop->counters.stream_init++; +} + + +INLINE static void uv_connection_init(uv_stream_t* handle) { + handle->flags |= UV_HANDLE_CONNECTION; + handle->write_reqs_pending = 0; + + uv_req_init(handle->loop, (uv_req_t*) &(handle->read_req)); + handle->read_req.event_handle = NULL; + handle->read_req.wait_handle = INVALID_HANDLE_VALUE; + handle->read_req.type = UV_READ; + handle->read_req.data = handle; + + handle->shutdown_req = NULL; +} + + +INLINE static size_t uv_count_bufs(uv_buf_t bufs[], int count) { + size_t bytes = 0; + int i; + + for (i = 0; i < count; i++) { + bytes += (size_t)bufs[i].len; + } + + return bytes; +} + +#endif /* UV_WIN_STREAM_INL_H_ */ diff --git a/src/win/stream.c b/src/win/stream.c index 08c62eda..195e0b80 100644 --- a/src/win/stream.c +++ b/src/win/stream.c @@ -27,29 +27,6 @@ #include "req-inl.h" -void uv_stream_init(uv_loop_t* loop, uv_stream_t* handle) { - uv_handle_init(loop, (uv_handle_t*) handle); - handle->write_queue_size = 0; - handle->activecnt = 0; - - loop->counters.stream_init++; -} - - -void uv_connection_init(uv_stream_t* handle) { - handle->flags |= UV_HANDLE_CONNECTION; - handle->write_reqs_pending = 0; - - uv_req_init(handle->loop, (uv_req_t*) &(handle->read_req)); - handle->read_req.event_handle = NULL; - handle->read_req.wait_handle = INVALID_HANDLE_VALUE; - handle->read_req.type = UV_READ; - handle->read_req.data = handle; - - handle->shutdown_req = NULL; -} - - int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) { switch (stream->type) { case UV_TCP: @@ -180,18 +157,6 @@ int uv_shutdown(uv_shutdown_t* req, uv_stream_t* handle, uv_shutdown_cb cb) { } -size_t uv_count_bufs(uv_buf_t bufs[], int count) { - size_t bytes = 0; - int i; - - for (i = 0; i < count; i++) { - bytes += (size_t)bufs[i].len; - } - - return bytes; -} - - int uv_is_readable(const uv_stream_t* handle) { return !(handle->flags & UV_HANDLE_EOF); } diff --git a/src/win/tcp.c b/src/win/tcp.c index 82e2d8d8..6ea39a2b 100644 --- a/src/win/tcp.c +++ b/src/win/tcp.c @@ -24,6 +24,7 @@ #include "uv.h" #include "internal.h" #include "handle-inl.h" +#include "stream-inl.h" #include "req-inl.h" diff --git a/src/win/tty.c b/src/win/tty.c index f1c02474..047cad26 100644 --- a/src/win/tty.c +++ b/src/win/tty.c @@ -27,6 +27,7 @@ #include "uv.h" #include "internal.h" #include "handle-inl.h" +#include "stream-inl.h" #include "req-inl.h" diff --git a/src/win/udp.c b/src/win/udp.c index cdd1c153..10cca00a 100644 --- a/src/win/udp.c +++ b/src/win/udp.c @@ -24,6 +24,7 @@ #include "uv.h" #include "internal.h" #include "handle-inl.h" +#include "stream-inl.h" #include "req-inl.h" diff --git a/uv.gyp b/uv.gyp index 2171fd8e..d67ccc62 100644 --- a/uv.gyp +++ b/uv.gyp @@ -152,6 +152,7 @@ 'src/win/req.c', 'src/win/req-inl.h', 'src/win/stream.c', + 'src/win/stream-inl.h', 'src/win/tcp.c', 'src/win/tty.c', 'src/win/threadpool.c',