socklife.c File Reference

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

Include dependency graph for socklife.c:

Go to the source code of this file.

Macros
#define	NDEBUG

Functions
SOCKET WSAAPI	accept (IN SOCKET s, OUT LPSOCKADDR addr, OUT INT FAR *addrlen)
INT WSAAPI	bind (IN SOCKET s, IN CONST struct sockaddr *name, IN INT namelen)
INT WSAAPI	closesocket (IN SOCKET s)
SOCKET WSAAPI	socket (IN INT af, IN INT type, IN INT protocol)
INT WSPAPI	WPUCloseSocketHandle (IN SOCKET s, OUT LPINT lpErrno)
SOCKET WSPAPI	WPUCreateSocketHandle (IN DWORD dwCatalogEntryId, IN DWORD_PTR dwContext, OUT LPINT lpErrno)
SOCKET WSPAPI	WPUModifyIFSHandle (IN DWORD dwCatalogEntryId, IN SOCKET ProposedHandle, OUT LPINT lpErrno)
INT WSPAPI	WPUQuerySocketHandleContext (IN SOCKET s, OUT PDWORD_PTR lpContext, OUT LPINT lpErrno)
SOCKET WSAAPI	WSAAccept (IN SOCKET s, OUT LPSOCKADDR addr, IN OUT LPINT addrlen, IN LPCONDITIONPROC lpfnCondition, IN DWORD_PTR dwCallbackData)
SOCKET WSAAPI	WSAJoinLeaf (IN SOCKET s, IN CONST struct sockaddr *name, IN INT namelen, IN LPWSABUF lpCallerData, OUT LPWSABUF lpCalleeData, IN LPQOS lpSQOS, IN LPQOS lpGQOS, IN DWORD dwFlags)
SOCKET WSAAPI	WSASocketA (IN INT af, IN INT type, IN INT protocol, IN LPWSAPROTOCOL_INFOA lpProtocolInfo, IN GROUP g, IN DWORD dwFlags)
SOCKET WSAAPI	WSASocketW (IN INT af, IN INT type, IN INT protocol, IN LPWSAPROTOCOL_INFOW lpProtocolInfo, IN GROUP g, IN DWORD dwFlags)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 13 of file socklife.c.

Function Documentation

accept()

SOCKET WSAAPI accept	(	IN SOCKET	s,
		OUT LPSOCKADDR	addr,
		OUT INT FAR *	addrlen
	)

Definition at line 23 of file socklife.c.

{
    /* Let WSA do it */
    return WSAAccept(s, addr, addrlen, NULL, 0);
}

Referenced by AcceptConnections(), AcceptDataConnection(), AcceptKillThread(), AcceptProc(), consistsof(), dataconn(), FTP_GetDataSocket(), InputProcessorProfiles_ChangeCurrentLanguage(), INTERNET_InternetOpenUrlW(), main(), memrpbrkW(), CServerSocket::MessageLoop(), oob_server(), open_tcp_connect(), rdp2vnc_connect(), rendezvous_request(), rpcrt4_conn_tcp_handoff(), SAcceptA(), SAcceptS(), select_server(), server_thread(), simple_server(), SocketTest(), START_TEST(), strpbrkW(), strspnW(), tcp_socketpair(), tcp_socketpair_ovl(), test_accept(), test_AcceptEx(), test_async_HttpSendRequestEx(), test_ConnectEx(), test_DisconnectEx(), test_events(), test_select(), test_set_getsockopt(), test_so_reuseaddr(), test_TransmitFile(), test_WSAPoll(), test_WSARecv(), WaitForConnect(), wcspbrk(), and wcsspn().

bind()

INT WSAAPI bind	(	IN SOCKET	s,
		IN CONST struct sockaddr *	name,
		IN INT	namelen
	)

Definition at line 36 of file socklife.c.

{
    PWSSOCKET Socket;
    INT Status;
    INT ErrorCode;
    DPRINT("bind: %lx, %p, %lx\n", s, name, namelen);

    /* Check for WSAStartup */
    if ((ErrorCode = WsQuickProlog()) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            if (name && (namelen >= sizeof(*name)))
            {
                /* Make the call */
                Status = Socket->Provider->Service.lpWSPBind(s,
                                                             name,
                                                             namelen,
                                                             &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
            {
                /* Deference the Socket Context */
                WsSockDereference(Socket);

                /* name or namelen not valid */
                ErrorCode = WSAEFAULT;
            }
        }
        else
        {
            /* No Socket Context Found */
            ErrorCode = WSAENOTSOCK;
        }
    }

    /* Return with an Error */
    SetLastError(ErrorCode);
    return SOCKET_ERROR;
}

Referenced by AcceptProc(), AdapterDiscoveryThread(), bindresvport_sa(), BindToEphemeralPortNumber(), ClassMoniker_IsEqual(), CreateSocket(), DEVENUM_IMediaCatMoniker_IsEqual(), do_bind(), epm_register(), FileMonikerImpl_ComposeWith(), FileMonikerImpl_IsEqual(), FileMonikerImpl_RelativePathTo(), FTP_InitListenSocket(), get_epm_handle_client(), I_RpcAsyncSetHandle(), I_RpcBindingSetAsync(), I_RpcFreeBuffer(), I_RpcGetBuffer(), I_RpcNegotiateTransferSyntax(), I_RpcReceive(), I_RpcSend(), init(), initconn(), is_epm_destination_local(), ItemMonikerImpl_IsEqual(), main(), make_listening_socket(), CServerSocket::Open(), open_tcp_connect(), openlog(), processRequest(), RPC_CreateClientChannel(), RpcBindingFromStringBindingA(), RpcBindingFromStringBindingW(), RpcBindingInqAuthClientExW(), RpcBindingInqAuthInfoExW(), RpcBindingInqObject(), RpcBindingReset(), RpcBindingServerFromClient(), RpcBindingSetAuthInfoExA(), RpcBindingSetAuthInfoExW(), RpcBindingSetObject(), RpcBindingToStringBindingA(), RpcEpResolveBinding(), RpcEpUnregister(), RpcImpersonateClient(), RpcRevertToSelfEx(), rpcrt4_protseq_ncacn_ip_tcp_open_endpoint(), SBind(), SendRequest(), server_thread(), setup_iocp_src(), setup_server_socket(), SetUpListener(), SocketTest(), START_TEST(), svc_tli_create(), switch_proc(), tcp_socketpair(), tcp_socketpair_ovl(), test_AcceptEx(), test_BindToObject(), test_BindToStorage(), Test_CloseWhileSelectDuplicatedSocket(), Test_CloseWhileSelectSameSocket(), test_ConnectEx(), test_DisconnectEx(), test_events(), test_extendedSocketOptions(), test_getsockname(), test_ioctlsocket(), test_ip_pktinfo(), test_ipv6only(), test_listen(), test_Load(), test_set_getsockopt(), test_sioAddressListChange(), test_so_reuseaddr(), test_tcp(), test_TransmitFile(), test_udp(), test_WSADuplicateSocket(), test_WSAEnumNetworkEvents(), test_WSARecv(), test_WSASendMsg(), TestBind(), and URLMoniker_IsEqual().

closesocket()

INT WSAAPI closesocket

(

IN SOCKET

s

)

Definition at line 93 of file socklife.c.

{
    PWSSOCKET Socket;
    INT Status;
    INT ErrorCode;
    DPRINT("closesocket: %lx\n", s);

    /* Check for WSAStartup */
    if ((ErrorCode = WsQuickProlog()) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Make the call */
            Status = Socket->Provider->Service.lpWSPCloseSocket(s, &ErrorCode);

            /* Check if this is a provider socket */
            if ((Status == ERROR_SUCCESS) && (Socket->IsProvider))
            {
                /* Disassociate the handle */
                if (WsSockDisassociateHandle(Socket) == ERROR_SUCCESS)
                {
                    /* Deference the Socket Context */
                    WsSockDereference(Socket);
                }

                /* Remove the last reference */
                WsSockDereference(Socket);

                /* Return success if everything is OK */
                if (ErrorCode == ERROR_SUCCESS) return ErrorCode;
            }
        }
        else
        {
            /* No Socket Context Found */
            ErrorCode = WSAENOTSOCK;
        }
    }

    /* Return with an Error */
    SetLastError(ErrorCode);
    return SOCKET_ERROR;
}

socket()

SOCKET WSAAPI socket	(	IN INT	af,
		IN INT	type,
		IN INT	protocol
	)

Definition at line 143 of file socklife.c.

{
    PWSPROCESS Process;
    PWSTHREAD Thread;
    DWORD Flags = 0;
    INT ErrorCode;
    DPRINT("socket: %lx, %lx, %lx\n", af, type, protocol);

    /* Enter prolog */
    if ((ErrorCode = WsApiProlog(&Process, &Thread)) != ERROR_SUCCESS)
    {
        /* Fail here */
        SetLastError(ErrorCode);
        return INVALID_SOCKET;
    }

    /* Check the current open type and use overlapped if it's default */
    if (!Thread->OpenType) Flags = WSA_FLAG_OVERLAPPED;

    /* Make the protocol negative if this is NETBIOS */
    if ((af == AF_NETBIOS) && (protocol > 0)) protocol *= -1;

    /* Now let WSA handle it */
    return WSASocketW(af, type, protocol, NULL, 0, Flags);
}

Referenced by __rpc_get_time_offset(), __rpc_nconf2fd(), __rpcbind_is_up(), AcceptProc(), AdapterDiscoveryThread(), adns__tcp_tryconnect(), Telnet::Connect(), create_netconn_socket(), CreateSocket(), FTP_Connect(), FTP_DoPassive(), FTP_InitListenSocket(), hookup(), init(), init_finish(), initconn(), InitConnection(), InternetCheckConnectionW(), InternetTransport_Connect(), local_rpcb(), main(), make_listening_socket(), netconn_create(), netfinger(), CServerSocket::Open(), open_http(), open_tcp_connect(), OpenControlConnection(), OpenDataConnection(), openlog(), processRequest(), rpc_broadcast_exp(), rpcrt4_ncacn_ip_tcp_open(), rpcrt4_protseq_ncacn_ip_tcp_open_endpoint(), rtime(), SendRequest(), server_thread(), CSocket::SetSocket(), setup_connector_socket(), setup_iocp_src(), setup_server_socket(), SetUpListener(), SNewDatagramClient(), SNewDatagramServer(), SNewStreamClient(), SNewStreamServer(), SocketInit(), SocketTest(), START_TEST(), tcp_connect(), tcp_socketpair(), test_AcceptEx(), test_address_list_query(), Test_CloseDuplicatedSocket(), Test_CloseWhileSelectDuplicatedSocket(), Test_CloseWhileSelectSameSocket(), test_communication(), test_completion_port(), test_ConnectEx(), test_DisconnectEx(), test_errors(), test_events(), test_extendedSocketOptions(), test_getpeername(), test_getsockname(), test_ioctlsocket(), test_ip_pktinfo(), test_ipv6only(), test_listen(), test_select(), test_send(), test_sendto(), test_set_getsockopt(), test_sioAddressListChange(), test_sioRoutingInterfaceQuery(), test_so_reuseaddr(), test_synchronous_WSAIoctl(), test_tcp(), test_TransmitFile(), test_udp(), test_UDP(), test_WSAAddressToStringA(), test_WSAAddressToStringW(), test_WSAEnumNetworkEvents(), test_WSASendMsg(), test_WSASendTo(), TestBind(), and write_packet().

WPUCloseSocketHandle()

INT WSPAPI WPUCloseSocketHandle	(	IN SOCKET	s,
		OUT LPINT	lpErrno
	)

Definition at line 176 of file socklife.c.

{
    UNIMPLEMENTED;
    return 0;
}

Referenced by WsTpInitialize().

WPUCreateSocketHandle()

SOCKET WSPAPI WPUCreateSocketHandle	(	IN DWORD	dwCatalogEntryId,
		IN DWORD_PTR	dwContext,
		OUT LPINT	lpErrno
	)

Definition at line 188 of file socklife.c.

{
    UNIMPLEMENTED;
    return (SOCKET)0;
}

Referenced by WsTpInitialize().

WPUModifyIFSHandle()

SOCKET WSPAPI WPUModifyIFSHandle	(	IN DWORD	dwCatalogEntryId,
		IN SOCKET	ProposedHandle,
		OUT LPINT	lpErrno
	)

Definition at line 201 of file socklife.c.

{
    SOCKET Handle = INVALID_SOCKET;
    DWORD ErrorCode = ERROR_SUCCESS;
    PWSPROCESS Process;
    PTCATALOG Catalog;
    PTCATALOG_ENTRY Entry;
    PWSSOCKET Socket;
    DPRINT("WPUModifyIFSHandle: %lx, %lx\n", dwCatalogEntryId, ProposedHandle);

    /* Get the current process */
    if ((Process = WsGetProcess()))
    {
        /* Get the Transport Catalog */
        if ((Catalog = WsProcGetTCatalog(Process)))
        {
            /* Get the entry for this ID */
            ErrorCode = WsTcGetEntryFromCatalogEntryId(Catalog,
                                                       dwCatalogEntryId,
                                                       &Entry);
            /* Check for success */
            if (ErrorCode == ERROR_SUCCESS)
            {
                /* Create a socket object */
                if ((Socket = WsSockAllocate()))
                {
                    /* Initialize it */
                    WsSockInitialize(Socket, Entry);

                    /* Associate it */
                    ErrorCode = WsSockAssociateHandle(Socket,
                                                      ProposedHandle,
                                                      TRUE);
                    /* Check for success */
                    if (ErrorCode == ERROR_SUCCESS)
                    {
                        /* Return */
                        Handle = ProposedHandle;
                        *lpErrno = ERROR_SUCCESS;
                    }
                    else
                    {
                        /* Fail */
                        WsSockDereference(Socket);
                        *lpErrno = ErrorCode;
                    }

                    /* Dereference the extra count */
                    WsSockDereference(Socket);
                }
                else
                {
                    /* No memory to allocate a socket */
                    *lpErrno = WSAENOBUFS;
                }

                /* Dereference the catalog entry */
                WsTcEntryDereference(Entry);
            }
            else
            {
                /* Entry not found */
                *lpErrno = ErrorCode;
            }
        }
        else
        {
            /* Catalog not found */
            *lpErrno = WSANOTINITIALISED;
        }
    }
    else
    {
        /* Process not ready */
        *lpErrno = WSANOTINITIALISED;
    }

    /* Return */
    return Handle;
}

Referenced by WsTcFindIfsProviderForSocket(), and WsTpInitialize().

WPUQuerySocketHandleContext()

INT WSPAPI WPUQuerySocketHandleContext	(	IN SOCKET	s,
		OUT PDWORD_PTR	lpContext,
		OUT LPINT	lpErrno
	)

Definition at line 289 of file socklife.c.

{
    UNIMPLEMENTED;
    return 0;
}

Referenced by WsTpInitialize().

WSAAccept()

SOCKET WSAAPI WSAAccept	(	IN SOCKET	s,
		OUT LPSOCKADDR	addr,
		IN OUT LPINT	addrlen,
		IN LPCONDITIONPROC	lpfnCondition,
		IN DWORD_PTR	dwCallbackData
	)

Definition at line 302 of file socklife.c.

{
    PWSPROCESS Process;
    PWSTHREAD Thread;
    PWSSOCKET Socket;
    DWORD OpenType;
    INT ErrorCode;
    SOCKET Status;
    DPRINT("WSAAccept: %lx, %lx, %lx, %p\n", s, addr, addrlen, lpfnCondition);

    /* Enter prolog */
    if ((ErrorCode = WsApiProlog(&Process, &Thread)) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Get the old open type and set new one */
            OpenType = Thread->OpenType;
            Thread->OpenType = Socket->Overlapped ? 0 : SO_SYNCHRONOUS_NONALERT;

            /* Make the call */
            Status = Socket->Provider->Service.lpWSPAccept(s,
                                                           addr,
                                                           addrlen,
                                                           lpfnCondition,
                                                           dwCallbackData,
                                                           &ErrorCode);
            /* Restore open type */
            Thread->OpenType = OpenType;

            /* Deference the Socket Context */
            WsSockDereference(Socket);

            /* Check if we got a valid socket */
            if (Status != INVALID_SOCKET)
            {
                /* Check if we got a new socket */
                if (Status != s)
                {
                    /* Add a new reference */
                    WsSockAddApiReference(Status);
                }

                /* Return */
                return Status;
            }
        }
        else
        {
            /* No Socket Context Found */
            ErrorCode = WSAENOTSOCK;
        }
    }

    /* Return with an Error */
    SetLastError(ErrorCode);
    return INVALID_SOCKET;
}

Referenced by accept(), test_accept(), and test_AcceptEx().

WSAJoinLeaf()

SOCKET WSAAPI WSAJoinLeaf	(	IN SOCKET	s,
		IN CONST struct sockaddr *	name,
		IN INT	namelen,
		IN LPWSABUF	lpCallerData,
		OUT LPWSABUF	lpCalleeData,
		IN LPQOS	lpSQOS,
		IN LPQOS	lpGQOS,
		IN DWORD	dwFlags
	)

Definition at line 370 of file socklife.c.

{
    PWSPROCESS Process;
    PWSTHREAD Thread;
    PWSSOCKET Socket;
    DWORD OpenType;
    INT ErrorCode;
    SOCKET Status;
    DPRINT("WSAJoinLeaf: %lx, %lx, %lx\n", s, name, namelen);

    /* Enter prolog */
    if ((ErrorCode = WsApiProlog(&Process, &Thread)) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Get the old open type and set new one */
            OpenType = Thread->OpenType;
            Thread->OpenType = Socket->Overlapped ? 0 : SO_SYNCHRONOUS_NONALERT;

            /* Make the call */
            Status = Socket->Provider->Service.lpWSPJoinLeaf(s,
                                                             name,
                                                             namelen,
                                                             lpCallerData,
                                                             lpCalleeData,
                                                             lpSQOS,
                                                             lpGQOS,
                                                             dwFlags,
                                                             &ErrorCode);
            /* Restore open type */
            Thread->OpenType = OpenType;

            /* Deference the Socket Context */
            WsSockDereference(Socket);

            /* Check if we got a valid socket */
            if (Status != INVALID_SOCKET)
            {
                /* Check if we got a new socket */
                if (Status != s)
                {
                    /* Add a new reference */
                    WsSockAddApiReference(Status);
                }

                /* Return */
                return Status;
            }
        }
        else
        {
            /* No Socket Context Found */
            ErrorCode = WSAENOTSOCK;
        }
    }

    /* Return with an Error */
    SetLastError(ErrorCode);
    return INVALID_SOCKET;
}

WSASocketA()

SOCKET WSAAPI WSASocketA	(	IN INT	af,
		IN INT	type,
		IN INT	protocol,
		IN LPWSAPROTOCOL_INFOA	lpProtocolInfo,
		IN GROUP	g,
		IN DWORD	dwFlags
	)

Definition at line 444 of file socklife.c.

{
    WSAPROTOCOL_INFOW ProtocolInfoW;
    LPWSAPROTOCOL_INFOW p = &ProtocolInfoW;

    /* Convert Protocol Info to Wide */
    if (lpProtocolInfo)
    {
        /* Copy the Data */
        memcpy(&ProtocolInfoW,
               lpProtocolInfo,
               sizeof(WSAPROTOCOL_INFOA) - sizeof(CHAR) * (WSAPROTOCOL_LEN + 1));

        /* Convert the String */
        MultiByteToWideChar(CP_ACP,
                            0,
                            lpProtocolInfo->szProtocol,
                            -1,
                            ProtocolInfoW.szProtocol,
                            sizeof(ProtocolInfoW.szProtocol) / sizeof(WCHAR));
    }
    else
    {
        /* No Protocol Info Specified */
        p = NULL;
    }

    /* Call the Unicode Function */
    return WSASocketW(af,
                      type,
                      protocol,
                      p,
                      g,
                      dwFlags);
}

Referenced by client_start(), NetBTAstatRemote(), NetBTCall(), NetBTInternalFindName(), run_open_osfhandle(), server_start(), START_TEST(), test_completion_port(), test_WithoutWSAStartup(), test_WithWSAStartup(), test_WSADuplicateSocket(), and test_WSASocket().

WSASocketW()

SOCKET WSAAPI WSASocketW	(	IN INT	af,
		IN INT	type,
		IN INT	protocol,
		IN LPWSAPROTOCOL_INFOW	lpProtocolInfo,
		IN GROUP	g,
		IN DWORD	dwFlags
	)

Definition at line 490 of file socklife.c.

{
    PWSPROCESS Process;
    PWSTHREAD Thread;
    INT ErrorCode;
    PTCATALOG Catalog;
    DWORD CatalogId;
    PTCATALOG_ENTRY CatalogEntry;
    LPWSAPROTOCOL_INFOW ProtocolInfo;
    DWORD OpenType;
    SOCKET Status = INVALID_SOCKET;
    DPRINT("WSASocketW: %lx, %lx, %lx, %p\n", af, type, protocol, lpProtocolInfo);

    /* Enter prolog */
    if ((ErrorCode = WsApiProlog(&Process, &Thread)) != ERROR_SUCCESS)
    {
        /* Fail now */
        SetLastError(ErrorCode);
        return INVALID_SOCKET;
    }

    /* Get the catalog */
    Catalog = WsProcGetTCatalog(Process);

    /* Find a Provider for the Catalog ID */
    if (lpProtocolInfo)
    {
        /* Get the catalog ID */
        CatalogId = lpProtocolInfo->dwCatalogEntryId;

        /* Get the Catalog Entry */
        ErrorCode = WsTcGetEntryFromCatalogEntryId(Catalog,
                                                   CatalogId,
                                                   &CatalogEntry);
    }
    else
    {
        /* No ID */
        CatalogId = 0;

DoLookup:
        /* Get the Catalog Data from the Socket Info */
        ErrorCode = WsTcGetEntryFromTriplet(Catalog,
                                            af,
                                            type,
                                            protocol,
                                            CatalogId,
                                            &CatalogEntry);
    }

    /* Check for Success */
    if (ErrorCode == ERROR_SUCCESS)
    {
        /* Use the default Protocol Info if none given */
        ProtocolInfo = lpProtocolInfo ? lpProtocolInfo : &CatalogEntry->ProtocolInfo;

        /* Save the open type and set new one */
        OpenType = Thread->OpenType;
        Thread->OpenType = (dwFlags & WSA_FLAG_OVERLAPPED) ?
                            0 : SO_SYNCHRONOUS_NONALERT;

        /* Call the Provider to create the Socket */
        Status = CatalogEntry->Provider->Service.lpWSPSocket(af,
                                                             type,
                                                             protocol,
                                                             ProtocolInfo,
                                                             g,
                                                             dwFlags,
                                                             &ErrorCode);
        /* Restore open type */
        Thread->OpenType = OpenType;

        /* Get the catalog ID now, and dereference */
        CatalogId = ProtocolInfo->dwCatalogEntryId;
        WsTcEntryDereference(CatalogEntry);

        /* Did we fail with WSAEINPROGRESS and had no specific provider? */
        if ((Status == INVALID_SOCKET) &&
            (ErrorCode == WSAEINPROGRESS) &&
            !(lpProtocolInfo))
        {
            /* In that case, restart the lookup from this ID */
            goto DoLookup;
        }

        /* Check if we got a valid socket */
        if (Status != INVALID_SOCKET)
        {
            /* Add an API reference and return */
            WsSockAddApiReference(Status);
            return Status;
        }
    }

    /* Return with an Error */
    SetLastError(ErrorCode);
    return INVALID_SOCKET;
}

Referenced by socket(), tcp_socketpair_ovl(), Test_CloseDuplicatedSocket(), Test_CloseWhileSelectDuplicatedSocket(), test_sioAddressListChange(), test_synchronous_WSAIoctl(), Test_WSARecv(), test_WSARecv(), and WSASocketA().