select.c File Reference

#include <ws2_32.h>
#include <debug.h>

Include dependency graph for select.c:

Go to the source code of this file.

Macros
#define	NDEBUG

Functions
INT WSPAPI	__WSAFDIsSet (SOCKET s, LPFD_SET set)
INT WSAAPI	select (IN INT s, IN OUT LPFD_SET readfds, IN OUT LPFD_SET writefds, IN OUT LPFD_SET exceptfds, IN CONST struct timeval *timeout)
INT WSPAPI	WPUFDIsSet (IN SOCKET s, IN LPFD_SET set)
INT WSAAPI	WSAAsyncSelect (IN SOCKET s, IN HWND hWnd, IN UINT wMsg, IN LONG lEvent)
INT WSAAPI	WSAEventSelect (IN SOCKET s, IN WSAEVENT hEventObject, IN LONG lNetworkEvents)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 13 of file select.c.

Function Documentation

__WSAFDIsSet()

INT WSPAPI __WSAFDIsSet	(	SOCKET	s,
		LPFD_SET	set
	)

Definition at line 23 of file select.c.

{
    INT i = set->fd_count;
    INT Return = FALSE;
 
    /* Loop until a match is found */
    while (i--) if (set->fd_array[i] == s) Return = TRUE;
 
    /* Return */
    return Return;
}

select()

INT WSAAPI select	(	IN INT	s,
		IN OUT LPFD_SET	readfds,
		IN OUT LPFD_SET	writefds,
		IN OUT LPFD_SET	exceptfds,
		IN CONST struct timeval *	timeout
	)

Definition at line 41 of file select.c.

{
    PWSSOCKET Socket;
    INT Status;
    INT ErrorCode;
    SOCKET Handle;
    LPWSPSELECT WSPSelect;
 
    DPRINT("select: %lx %p %p %p %p\n", s, readfds, writefds, exceptfds, timeout);
 
    /* Check for WSAStartup */
    ErrorCode = WsQuickProlog();
 
    if (ErrorCode != ERROR_SUCCESS)
    {
        SetLastError(ErrorCode);
        return SOCKET_ERROR;
    }
 
    /* Use the first Socket from the first valid set */
    if (readfds && readfds->fd_count)
    {
        Handle = readfds->fd_array[0];
    }
    else if (writefds && writefds->fd_count)
    {
        Handle = writefds->fd_array[0];
    }
    else if (exceptfds && exceptfds->fd_count)
    {
        Handle = exceptfds->fd_array[0];
    }
    else
    {
        /* Invalid handles */
        SetLastError(WSAEINVAL);
        return SOCKET_ERROR;
    }
 
    /* Get the Socket Context */
    Socket = WsSockGetSocket(Handle);
 
    if (!Socket)
    {
        /* No Socket Context Found */
        SetLastError(WSAENOTSOCK);
        return SOCKET_ERROR;
    }
 
    /* Get the select procedure */
    WSPSelect = Socket->Provider->Service.lpWSPSelect;
 
    /* Make the call */
    Status = WSPSelect(s, readfds, writefds, exceptfds, (struct timeval *)timeout,
                       &ErrorCode);
 
    /* Deference the Socket Context */
    WsSockDereference(Socket);
 
    /* Return Provider Value */
    if (Status != SOCKET_ERROR)
        return Status;
 
    /* If everything seemed fine, then the WSP call failed itself */
    if (ErrorCode == NO_ERROR)
        ErrorCode = WSASYSCALLFAILURE;
 
    /* Return with an error */
    SetLastError(ErrorCode);
    return SOCKET_ERROR;
}

Referenced by __rpc_get_time_offset(), _get_select_iface(), _test_select_get_disabled(), _test_select_length(), _test_select_multiple(), _test_select_name(), _test_select_put_length(), _test_select_put_selidx(), _test_select_selidx(), _test_select_set_disabled(), _test_select_set_multiple(), _test_select_set_name(), _test_select_set_size(), _test_select_set_value(), _test_select_size(), _test_select_type(), _test_select_value(), AcceptConnections(), add_store_certs(), adns_wait(), check_sck(), checkRecv(), create_netconn_socket(), DATETIME_SetSelectedField(), DoTelnetHandshake(), drain_socket_thread(), empty(), FTP_GetNextLine(), GetRequestAndWait(), LISTVIEW_HitTest(), main(), mark_patched_components(), NetBTWaitForNameResponse(), netconn_create(), processRequest(), rdp2vnc_connect(), read_vc(), ReceiveData(), ReceiveLine(), rtime(), runProg(), SAcceptS(), SClose(), SConnect(), select_server(), SelectR(), SelectW(), CHttpClient::SendFile(), ServiceMain(), SRead(), SRecv(), SRecvfrom(), SSend(), SSendto(), SSendtoByName(), START_TEST(), svc_run(), SWaitUntilReadyForReading(), SWaitUntilReadyForWriting(), SWrite(), test_elems(), test_select(), test_select_elem(), test_select_form(), test_select_form_notfound(), test_select_remove(), test_TVS_SINGLEEXPAND(), Test_WSARecv(), thread_proc(), ui_select(), WaitForRemoteInput(), WaitForRemoteOutput(), and WaitResponse().

WPUFDIsSet()

INT WSPAPI WPUFDIsSet	(	IN SOCKET	s,
		IN LPFD_SET	set
	)

Definition at line 122 of file select.c.

{
    UNIMPLEMENTED;
    return (SOCKET)0;
}

Referenced by WsTpInitialize().

WSAAsyncSelect()

INT WSAAPI WSAAsyncSelect	(	IN SOCKET	s,
		IN HWND	hWnd,
		IN UINT	wMsg,
		IN LONG	lEvent
	)

Definition at line 134 of file select.c.

{
    PWSSOCKET Socket;
    INT Status;
    INT ErrorCode;
    DPRINT("WSAAsyncSelect: %lx, %lx, %lx, %lx\n", s, hWnd, wMsg, lEvent);
 
    /* Check for WSAStartup */
    if ((ErrorCode = WsQuickProlog()) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Make the call */
            Status = Socket->Provider->Service.lpWSPAsyncSelect(s,
                                                                hWnd,
                                                                wMsg,
                                                                lEvent,
                                                                &ErrorCode);
            /* Deference the Socket Context */
            WsSockDereference(Socket);
 
            /* Return Provider Value */
            if (Status == ERROR_SUCCESS) return Status;
 
            /* If everything seemed fine, then the WSP call failed itself */
            if (ErrorCode == NO_ERROR) ErrorCode = WSASYSCALLFAILURE;
        }
        else
        {
            /* No Socket Context Found */
            ErrorCode = WSAENOTSOCK;
        }
    }
 
    /* Return with an Error */
    SetLastError(ErrorCode);
    return SOCKET_ERROR;
}

Referenced by InternetTransport_ReadLine(), InternetTransport_WndProc(), mi_create_window(), and test_events().

WSAEventSelect()

INT WSAAPI WSAEventSelect	(	IN SOCKET	s,
		IN WSAEVENT	hEventObject,
		IN LONG	lNetworkEvents
	)

Definition at line 182 of file select.c.

{
    PWSSOCKET Socket;
    INT Status;
    INT ErrorCode;
 
    /* Check for WSAStartup */
    if ((ErrorCode = WsQuickProlog()) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Make the call */
            Status = Socket->Provider->Service.lpWSPEventSelect(s,
                                                        hEventObject,
                                                        lNetworkEvents,
                                                        &ErrorCode);
            /* Deference the Socket Context */
            WsSockDereference(Socket);
 
            /* Return Provider Value */
            if (Status == ERROR_SUCCESS) return Status;
        }
        else
        {
            /* No Socket Context Found */
            ErrorCode = WSAENOTSOCK;
        }
    }
 
    /* Return with an Error */
    SetLastError(ErrorCode);
    return SOCKET_ERROR;
}

Referenced by CServerSocket::Close(), dispatch(), event_client(), rpcrt4_protseq_sock_get_wait_array(), rpcrt4_sock_wait_for_recv(), rpcrt4_sock_wait_for_send(), CSocket::SetEvents(), START_TEST(), and test_events().