libs/newlib-cygwin
libs/newlib-cygwin
4
0
Fork 0
mirror of git://sourceware.org/git/newlib-cygwin.git synced 2025-02-06 14:30:38 +08:00
Code Issues Projects Releases Wiki Activity

* fhandler_socket.cc: Include cygthread.h.

Browse Source 
(class sock_event): Remove.
	(thread_connect): New function.
	(thread_accept): Ditto.
	(fhandler_socket::connect): Use cygthread instead of socket event
	handling for blocking sockets.
	(fhandler_socket::accept): Ditto.
This commit is contained in:
Corinna Vinschen 2003-06-02 17:52:16 +00:00
parent 418c623614
commit 8e13bd144d
2 changed files with 72 additions and 111 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
winsup/cygwin/ChangeLog
View File

@ -1,3 +1,13 @@
2003-06-02 Corinna Vinschen <corinna@vinschen.de>
* fhandler_socket.cc: Include cygthread.h.
(class sock_event): Remove.
(thread_connect): New function.
(thread_accept): Ditto.
(fhandler_socket::connect): Use cygthread instead of socket event
handling for blocking sockets.
(fhandler_socket::accept): Ditto.
2003-06-02 Christopher Faylor <cgf@redhat.com> 2003-06-02 Christopher Faylor <cgf@redhat.com>
* fhandler.cc (fhandler_base::write): Correct minor printf formatting * fhandler.cc (fhandler_base::write): Correct minor printf formatting
@ -5,8 +15,8 @@
2003-06-01 Pierre Humblet <pierre.humblet@ieee.org> 2003-06-01 Pierre Humblet <pierre.humblet@ieee.org>
* fhandler_disk_file.cc (fhandler_disk_file::fstat_by_name): Assume * fhandler_disk_file.cc (fhandler_disk_file::fstat_by_name): Assume
an existing directory is a root if FindFirstFile fails. an existing directory is a root if FindFirstFile fails.
2003-05-30 Christopher Faylor <cgf@redhat.com> 2003-05-30 Christopher Faylor <cgf@redhat.com>

169
winsup/cygwin/fhandler_socket.cc
View File

@ -32,6 +32,7 @@
#include "cygheap.h" #include "cygheap.h"
#include "sigproc.h" #include "sigproc.h"
#include "wsock_event.h" #include "wsock_event.h"
#include "cygthread.h"
#include <unistd.h> #include <unistd.h>
#define ENTROPY_SOURCE_DEV_UNIT 9 #define ENTROPY_SOURCE_DEV_UNIT 9
@ -119,86 +120,30 @@ get_inet_addr (const struct sockaddr *in, int inlen,
} }
} }
class sock_event struct sock_thread_data
{ {
WSAEVENT ev[2]; int socket;
SOCKET evt_sock; sockaddr *peer;
int evt_type_bit; int *len;
int ret;
public:
sock_event ()
{
ev[0] = WSA_INVALID_EVENT;
ev[1] = signal_arrived;
}
~sock_event ()
{
if (ev[0] != WSA_INVALID_EVENT)
WSACloseEvent (ev[0]);
}
void load (SOCKET sock, int type_bit)
{
if (!winsock2_active)
/* Can not wait for signal if winsock2 is not active */
return;
if (ev[0] == WSA_INVALID_EVENT)
if ((ev[0] = WSACreateEvent ()) == WSA_INVALID_EVENT)
return;
evt_sock = sock;
evt_type_bit = type_bit;
if (WSAEventSelect (evt_sock, ev[0], 1 << evt_type_bit))
{
WSACloseEvent (ev[0]);
ev[0] = WSA_INVALID_EVENT;
}
}
int wait ()
{
WSANETWORKEVENTS sock_event;
int wait_result;
if (ev[0] == WSA_INVALID_EVENT)
return 0;
wait_result = WSAWaitForMultipleEvents (2, ev, FALSE, WSA_INFINITE,
FALSE);
if (wait_result == WSA_WAIT_EVENT_0)
WSAEnumNetworkEvents (evt_sock, ev[0], &sock_event);
/* Cleanup, Revert to blocking. */
WSAEventSelect (evt_sock, ev[0], 0);
unsigned long nonblocking = 0;
ioctlsocket (evt_sock, FIONBIO, &nonblocking);
switch (wait_result)
{
case WSA_WAIT_EVENT_0:
if ((sock_event.lNetworkEvents & (1 << evt_type_bit))
&& sock_event.iErrorCode[evt_type_bit])
{
WSASetLastError (sock_event.iErrorCode[evt_type_bit]);
set_winsock_errno ();
return -1;
}
break;
case WSA_WAIT_EVENT_0 + 1:
debug_printf ("signal received");
set_errno (EINTR);
return 1;
case WSA_WAIT_FAILED:
default:
WSASetLastError (WSAEFAULT);
set_winsock_errno ();
return -1;
}
return 0;
}
}; };
static DWORD WINAPI
connect_thread (void *arg)
{
sock_thread_data *std = (sock_thread_data *) arg;
std->ret = ::connect (std->socket, std->peer, *std->len);
return 0;
}
static DWORD WINAPI
accept_thread (void *arg)
{
sock_thread_data *std = (sock_thread_data *) arg;
std->ret = ::accept (std->socket, std->peer, std->len);
return 0;
}
/**********************************************************************/ /**********************************************************************/
/* fhandler_socket */ /* fhandler_socket */
@ -575,7 +520,6 @@ out:
int int
fhandler_socket::connect (const struct sockaddr *name, int namelen) fhandler_socket::connect (const struct sockaddr *name, int namelen)
{ {
sock_event evt;
BOOL interrupted = FALSE; BOOL interrupted = FALSE;
int res = -1; int res = -1;
BOOL secret_check_failed = FALSE; BOOL secret_check_failed = FALSE;
@ -586,26 +530,28 @@ fhandler_socket::connect (const struct sockaddr *name, int namelen)
if (!get_inet_addr (name, namelen, &sin, &namelen, secret)) if (!get_inet_addr (name, namelen, &sin, &namelen, secret))
return -1; return -1;
if (!is_nonblocking () && !is_connect_pending ()) if (!is_nonblocking ())
evt.load (get_socket (), FD_CONNECT_BIT); {
sock_thread_data cd = { get_socket (), (sockaddr *) &sin, &namelen, -1 };
res = ::connect (get_socket (), (sockaddr *) &sin, namelen); cygthread *thread = new cygthread (connect_thread, &cd, "connect");
HANDLE wait_events[2] = { *thread, signal_arrived };
if (res && !is_nonblocking () && !is_connect_pending () if (WaitForMultipleObjects(2, wait_events, FALSE, INFINITE)
&& WSAGetLastError () == WSAEWOULDBLOCK) != WAIT_OBJECT_0)
switch (evt.wait ()) {
{ /* Signal arrived */
case 1: /* Signal */ thread->terminate_thread ();
WSASetLastError (WSAEINPROGRESS);
interrupted = TRUE; interrupted = TRUE;
break; }
case 0: else
res = 0; {
break; /* connect returned normally */
default: res = cd.ret;
res = -1; thread->detach ();
break; }
} delete thread;
}
else
res = ::connect (get_socket (), (sockaddr *) &sin, namelen);
if (res) if (res)
{ {
@ -704,20 +650,25 @@ fhandler_socket::accept (struct sockaddr *peer, int *len)
if (!is_nonblocking ()) if (!is_nonblocking ())
{ {
sock_event evt; sock_thread_data ad = { get_socket (), peer, len, -1 };
evt.load (get_socket (), FD_ACCEPT_BIT); cygthread *thread = new cygthread (accept_thread, &ad, "accept");
switch (evt.wait ()) HANDLE wait_events[2] = { *thread, signal_arrived };
{ if (WaitForMultipleObjects(2, wait_events, FALSE, INFINITE)
case 1: /* Signal */ != WAIT_OBJECT_0)
return -1; {
case 0: /* Signal arrived */
break; thread->terminate_thread ();
case -1: delete thread;
return -1; set_errno (EINTR);
return -1;
} }
/* accept returned normally */
res = ad.ret;
thread->detach ();
delete thread;
} }
else
res = ::accept (get_socket (), peer, len); res = ::accept (get_socket (), peer, len);
if ((SOCKET) res == INVALID_SOCKET && WSAGetLastError () == WSAEWOULDBLOCK) if ((SOCKET) res == INVALID_SOCKET && WSAGetLastError () == WSAEWOULDBLOCK)
in_progress = TRUE; in_progress = TRUE;