kotovalexarian-likes-github/ruby--ruby
1
0
Fork 0
mirror of https://github.com/ruby/ruby.git synced 2022-11-09 12:17:21 -05:00
Code Releases Activity

* win32/win32.c (finish_overlapped_socket): refactoring.

Browse source 
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@29715 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
usa 2010-11-08 02:48:07 +00:00
parent 877e90f17a
commit 7dd7ce0ff7
2 changed files with 47 additions and 94 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
ChangeLog
View file

@ -1,3 +1,7 @@
Mon Nov 8 11:47:39 2010 NAKAMURA Usaku <usa@ruby-lang.org>
* win32/win32.c (finish_overlapped_socket): refactoring.
Mon Nov 8 11:02:21 2010 NAKAMURA Usaku <usa@ruby-lang.org>
* win32/win32.c (get_proc_address): refactoring.

137
win32/win32.c
View file

@ -2858,6 +2858,44 @@ rb_w32_listen(int s, int backlog)
#undef send
#undef sendto
static int
finish_overlapped_socket(SOCKET s, WSAOVERLAPPED *wol, int result, DWORD *len, DWORD size)
{
DWORD flg;
int err;
if (result != SOCKET_ERROR)
*len = size;
else if ((err = WSAGetLastError()) == WSA_IO_PENDING) {
switch (rb_w32_wait_events_blocking(&wol->hEvent, 1, INFINITE)) {
case WAIT_OBJECT_0:
RUBY_CRITICAL(
result = WSAGetOverlappedResult(s, wol, &size, TRUE, &flg)
);
if (result) {
*len = size;
break;
}
/* thru */
default:
errno = map_errno(WSAGetLastError());
/* thru */
case WAIT_OBJECT_0 + 1:
/* interrupted */
*len = -1;
cancel_io((HANDLE)s);
break;
}
}
else {
errno = map_errno(err);
*len = -1;
}
CloseHandle(wol->hEvent);
return result;
}
static int
overlapped_socket_io(BOOL input, int fd, char *buf, int len, int flags,
struct sockaddr *addr, int *addrlen)
@ -2869,7 +2907,6 @@ overlapped_socket_io(BOOL input, int fd, char *buf, int len, int flags,
DWORD flg;
WSAOVERLAPPED wol;
WSABUF wbuf;
int err;
SOCKET s;
if (!NtSocketsInitialized)
@ -2920,35 +2957,7 @@ overlapped_socket_io(BOOL input, int fd, char *buf, int len, int flags,
}
});
if (ret != SOCKET_ERROR) {
r = size;
}
else if ((err = WSAGetLastError()) == WSA_IO_PENDING) {
switch (rb_w32_wait_events_blocking(&wol.hEvent, 1, INFINITE)) {
case WAIT_OBJECT_0:
RUBY_CRITICAL(
ret = WSAGetOverlappedResult(s, &wol, &size, TRUE, &flg)
);
if (ret) {
r = size;
break;
}
/* thru */
default:
errno = map_errno(WSAGetLastError());
/* thru */
case WAIT_OBJECT_0 + 1:
/* interrupted */
r = -1;
cancel_io((HANDLE)s);
break;
}
}
else {
errno = map_errno(err);
r = -1;
}
CloseHandle(wol.hEvent);
finish_overlapped_socket(s, &wol, ret, &r, size);
}
return r;
@ -3053,44 +3062,14 @@ recvmsg(int fd, struct msghdr *msg, int flags)
}
else {
DWORD size;
int err;
WSAOVERLAPPED wol;
memset(&wol, 0, sizeof(wol));
RUBY_CRITICAL({
wol.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
ret = pWSARecvMsg(s, &wsamsg, &len, &wol, NULL);
ret = pWSARecvMsg(s, &wsamsg, &size, &wol, NULL);
});
if (ret != SOCKET_ERROR) {
/* nothing to do */
}
else if ((err = WSAGetLastError()) == WSA_IO_PENDING) {
DWORD flg;
switch (rb_w32_wait_events_blocking(&wol.hEvent, 1, INFINITE)) {
case WAIT_OBJECT_0:
RUBY_CRITICAL(
ret = WSAGetOverlappedResult(s, &wol, &size, TRUE, &flg)
);
if (ret) {
len = size;
break;
}
/* thru */
default:
errno = map_errno(WSAGetLastError());
/* thru */
case WAIT_OBJECT_0 + 1:
/* interrupted */
len = -1;
cancel_io((HANDLE)s);
break;
}
}
else {
errno = map_errno(err);
len = -1;
}
CloseHandle(wol.hEvent);
ret = finish_overlapped_socket(s, &wol, ret, &len, size);
}
if (ret == SOCKET_ERROR)
return -1;
@ -3141,44 +3120,14 @@ sendmsg(int fd, const struct msghdr *msg, int flags)
}
else {
DWORD size;
int err;
WSAOVERLAPPED wol;
memset(&wol, 0, sizeof(wol));
RUBY_CRITICAL({
wol.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
ret = pWSASendMsg(s, &wsamsg, flags, &len, &wol, NULL);
ret = pWSASendMsg(s, &wsamsg, flags, &size, &wol, NULL);
});
if (ret != SOCKET_ERROR) {
/* nothing to do */
}
else if ((err = WSAGetLastError()) == WSA_IO_PENDING) {
DWORD flg;
switch (rb_w32_wait_events_blocking(&wol.hEvent, 1, INFINITE)) {
case WAIT_OBJECT_0:
RUBY_CRITICAL(
ret = WSAGetOverlappedResult(s, &wol, &size, TRUE, &flg)
);
if (ret) {
len = size;
break;
}
/* thru */
default:
errno = map_errno(WSAGetLastError());
/* thru */
case WAIT_OBJECT_0 + 1:
/* interrupted */
len = -1;
cancel_io((HANDLE)s);
break;
}
}
else {
errno = map_errno(err);
len = -1;
}
CloseHandle(wol.hEvent);
finish_overlapped_socket(s, &wol, ret, &len, size);
}
return len;