recv.c File Reference

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

Include dependency graph for recv.c:

Go to the source code of this file.

Macros
#define	NDEBUG

Functions
INT WSAAPI	recv (IN SOCKET s, OUT CHAR FAR *buf, IN INT len, IN INT flags)
INT WSAAPI	recvfrom (IN SOCKET s, OUT CHAR FAR *buf, IN INT len, IN INT flags, OUT LPSOCKADDR from, IN OUT INT FAR *fromlen)
INT WSAAPI	WSARecv (IN SOCKET s, IN OUT LPWSABUF lpBuffers, IN DWORD dwBufferCount, OUT LPDWORD lpNumberOfBytesRecvd, IN OUT LPDWORD lpFlags, IN LPWSAOVERLAPPED lpOverlapped, IN LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine)
INT WSAAPI	WSARecvDisconnect (IN SOCKET s, OUT LPWSABUF lpInboundDisconnectData)
INT WSAAPI	WSARecvFrom (IN SOCKET s, IN OUT LPWSABUF lpBuffers, IN DWORD dwBufferCount, OUT LPDWORD lpNumberOfBytesRecvd, IN OUT LPDWORD lpFlags, OUT LPSOCKADDR lpFrom, IN OUT LPINT lpFromlen, IN LPWSAOVERLAPPED lpOverlapped, IN LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 13 of file recv.c.

Function Documentation

recv()

INT WSAAPI recv	(	IN SOCKET	s,
		OUT CHAR FAR *	buf,
		IN INT	len,
		IN INT	flags
	)

Definition at line 23 of file recv.c.

{
    PWSSOCKET Socket;
    INT Status;
    INT ErrorCode;
    LPWSATHREADID ThreadId;
    WSABUF Buffers;
    DWORD BytesReceived;
    DPRINT("recv: %lx, %lx, %lx, %p\n", s, flags, len, buf);
 
    /* Check for WSAStartup */
    if ((ErrorCode = WsQuickPrologTid(&ThreadId)) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Setup the buffers */
            Buffers.buf = buf;
            Buffers.len = len;
 
            /* Make the call */
            Status = Socket->Provider->Service.lpWSPRecv(s,
                                                         &Buffers,
                                                         1,
                                                         &BytesReceived,
                                                         (LPDWORD)&flags,
                                                         NULL,
                                                         NULL,
                                                         ThreadId,
                                                         &ErrorCode);
            /* Deference the Socket Context */
            WsSockDereference(Socket);
 
            /* Return Provider Value */
            if (Status == ERROR_SUCCESS)
            {
                /* Handle OOB */
                if (!(flags & MSG_PARTIAL)) return BytesReceived;
                ErrorCode = WSAEMSGSIZE;
            }
 
            /* 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 __rpc_get_time_offset(), _server_read_data(), close_connection(), compare_file2(), do_synchronous_recv(), DoTelnetHandshake(), drain_socket_thread(), EchoIncomingPackets(), event_client(), fgetcSocket(), fgetsSocket(), InternetTransport_WndProc(), main(), netfinger(), processRequest(), read_line(), read_vc(), read_zero_bytes(), TNetwork::ReadString(), CServerClientSocket::Receive(), receive_data(), ReceiveIncomingPackets(), ReceiveLine(), recvrequest(), RecvSubvolGUIW(), rpcrt4_conn_tcp_read(), rtime(), WriterThread::Run(), select_server(), send_file(), server_read_data(), server_thread(), ShutdownConnection(), sock_recv(), SRead(), SRecv(), START_TEST(), tcp_recv(), test_events(), Test_ioctlsocket(), Test_Overread(), Test_recv(), and test_select().

recvfrom()

INT WSAAPI recvfrom	(	IN SOCKET	s,
		OUT CHAR FAR *	buf,
		IN INT	len,
		IN INT	flags,
		OUT LPSOCKADDR	from,
		IN OUT INT FAR *	fromlen
	)

Definition at line 87 of file recv.c.

{
    PWSSOCKET Socket;
    INT Status;
    INT ErrorCode;
    LPWSATHREADID ThreadId;
    WSABUF Buffers;
    DWORD BytesReceived;
    DPRINT("recvfrom: %lx, %lx, %lx, %p\n", s, flags, len, buf);
 
    /* Check for WSAStartup */
    if ((ErrorCode = WsQuickPrologTid(&ThreadId)) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Setup the buffers */
            Buffers.buf = buf;
            Buffers.len = len;
 
            /* Make the call */
            Status = Socket->Provider->Service.lpWSPRecvFrom(s,
                                                             &Buffers,
                                                             1,
                                                             &BytesReceived,
                                                             (LPDWORD)&flags,
                                                             from,
                                                             fromlen,
                                                             NULL,
                                                             NULL,
                                                             ThreadId,
                                                             &ErrorCode);
            /* Deference the Socket Context */
            WsSockDereference(Socket);
 
            /* Return Provider Value */
            if (Status == ERROR_SUCCESS)
            {
                /* Handle OOB */
                if (!(flags & MSG_PARTIAL)) return BytesReceived;
                ErrorCode = WSAEMSGSIZE;
            }
 
            /* 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 __rpc_get_time_offset(), adns_processreadable(), do_synchronous_recvfrom(), main(), processRequest(), receive_packet(), ReceiveData(), rpc_broadcast_exp(), rtime(), SendRequest(), server_thread(), SRecvfrom(), and svc_dg_recv().

WSARecv()

INT WSAAPI WSARecv	(	IN SOCKET	s,
		IN OUT LPWSABUF	lpBuffers,
		IN DWORD	dwBufferCount,
		OUT LPDWORD	lpNumberOfBytesRecvd,
		IN OUT LPDWORD	lpFlags,
		IN LPWSAOVERLAPPED	lpOverlapped,
		IN LPWSAOVERLAPPED_COMPLETION_ROUTINE	lpCompletionRoutine
	)

Definition at line 155 of file recv.c.

{
    PWSSOCKET Socket;
    INT Status;
    INT ErrorCode;
    LPWSATHREADID ThreadId;
    DPRINT("WSARecv: %lx, %lx, %lx, %p\n", s, lpFlags, dwBufferCount, lpBuffers);
 
    /* Check for WSAStartup */
    if ((ErrorCode = WsQuickPrologTid(&ThreadId)) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Make the call */
            Status = Socket->Provider->Service.lpWSPRecv(s,
                                                         lpBuffers,
                                                         dwBufferCount,
                                                         lpNumberOfBytesRecvd,
                                                         lpFlags,
                                                         lpOverlapped,
                                                         lpCompletionRoutine,
                                                         ThreadId,
                                                         &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 NetBTRecv(), NetBTSessionReq(), test_events(), Test_Overread(), and Test_WSARecv().

WSARecvDisconnect()

INT WSAAPI WSARecvDisconnect	(	IN SOCKET	s,
		OUT LPWSABUF	lpInboundDisconnectData
	)

Definition at line 211 of file recv.c.

{
    PWSPROCESS Process;
    PWSTHREAD Thread;
    PWSSOCKET Socket;
    INT ErrorCode;
    INT Status;
    DPRINT("WSARecvDisconnect: %lx %p\n", s, lpInboundDisconnectData);
 
    /* Enter prolog */
    if ((ErrorCode = WsApiProlog(&Process, &Thread)) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Make the call */
            Status = Socket->Provider->Service.lpWSPRecvDisconnect(s,
                                                                   lpInboundDisconnectData,
                                                                   &ErrorCode);
            /* Deference the Socket Context */
            WsSockDereference(Socket);
 
            /* Return Provider Value */
            if (Status == ERROR_SUCCESS) return ERROR_SUCCESS;
        }
        else
        {
            /* No Socket Context Found */
            ErrorCode = WSAENOTSOCK;
        }
    }
 
    /* Return with an Error */
    SetLastError(ErrorCode);
    return SOCKET_ERROR;
}

WSARecvFrom()

INT WSAAPI WSARecvFrom	(	IN SOCKET	s,
		IN OUT LPWSABUF	lpBuffers,
		IN DWORD	dwBufferCount,
		OUT LPDWORD	lpNumberOfBytesRecvd,
		IN OUT LPDWORD	lpFlags,
		OUT LPSOCKADDR	lpFrom,
		IN OUT LPINT	lpFromlen,
		IN LPWSAOVERLAPPED	lpOverlapped,
		IN LPWSAOVERLAPPED_COMPLETION_ROUTINE	lpCompletionRoutine
	)

Definition at line 254 of file recv.c.

{
    PWSSOCKET Socket;
    INT Status;
    INT ErrorCode;
    LPWSATHREADID ThreadId;
    DPRINT("WSARecvFrom: %lx, %lx, %lx, %p\n", s, lpFlags, dwBufferCount, lpBuffers);
 
    /* Check for WSAStartup */
    if ((ErrorCode = WsQuickPrologTid(&ThreadId)) == ERROR_SUCCESS)
    {
        /* Get the Socket Context */
        if ((Socket = WsSockGetSocket(s)))
        {
            /* Make the call */
            Status = Socket->Provider->Service.lpWSPRecvFrom(s,
                                                             lpBuffers,
                                                             dwBufferCount,
                                                             lpNumberOfBytesRecvd,
                                                             lpFlags,
                                                             lpFrom,
                                                             lpFromlen,
                                                             lpOverlapped,
                                                             lpCompletionRoutine,
                                                             ThreadId,
                                                             &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 NetBTWaitForNameResponse().