diff options
author | usa <usa@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-06-06 04:29:38 +0000 |
---|---|---|
committer | usa <usa@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-06-06 04:29:38 +0000 |
commit | f047b1f0dcaab60f22619046d419b36f2cc3f6b0 (patch) | |
tree | c395e4deba419177c467ee7ca510e255fb01eb33 /win32 | |
parent | 4c3e402cda1347ebfd94d6070c28ec159f2767d9 (diff) | |
download | ruby-f047b1f0dcaab60f22619046d419b36f2cc3f6b0.tar.gz |
* win32/win32.c, include/ruby/win32.h (rb_w32_wrap_io_handle): new API.
this API wraps an I/O handle (HANDLE or SOCKET) and returns fd.
the second parameter should be combination of O_*, for example,
O_RDWR | O_BINARY | O_NOINHERT.
* win32/win32.c, include/ruby/win32.h (rb_w32_unwrap_io_handle): new
API. this API unwraps an I/O handle and close the fd (not closes
the handle itself).
[Feature #4960] [ruby-core:37227]
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@35937 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'win32')
-rw-r--r-- | win32/win32.c | 38 |
1 files changed, 38 insertions, 0 deletions
diff --git a/win32/win32.c b/win32/win32.c index 8633c8600e..414f7e458f 100644 --- a/win32/win32.c +++ b/win32/win32.c @@ -6747,3 +6747,41 @@ localtime_r(const time_t *tp, struct tm *rp) #endif return rp; } + +/* License: Ruby's */ +int +rb_w32_wrap_io_handle(HANDLE h, int flags) +{ + BOOL tmp; + int len = sizeof(tmp); + int r = getsockopt((SOCKET)h, SOL_SOCKET, SO_DEBUG, (char *)&tmp, &len); + if (r != SOCKET_ERROR || WSAGetLastError() != WSAENOTSOCK) { + int f = 0; + if (flags & O_NONBLOCK) { + flags &= ~O_NONBLOCK; + f = O_NONBLOCK; + } + socklist_insert((SOCKET)h, f); + } + else if (flags & O_NONBLOCK) { + errno = EINVAL; + return -1; + } + return rb_w32_open_osfhandle((intptr_t)h, flags); +} + +/* License: Ruby's */ +int +rb_w32_unwrap_io_handle(int fd) +{ + SOCKET sock = TO_SOCKET(fd); + _set_osfhnd(fd, (SOCKET)INVALID_HANDLE_VALUE); + if (!is_socket(sock)) { + UnlockFile((HANDLE)sock, 0, 0, LK_LEN, LK_LEN); + constat_delete((HANDLE)sock); + } + else { + socklist_delete(&sock, NULL); + } + return _close(fd); +} |