One Level Up Top Level

src/os/win32/ngx_socket.h - nginx source code

Data types defined

Macros defined

Source code


  2. /*
  3. * Copyright (C) Igor Sysoev
  4. * Copyright (C) Nginx, Inc.
  5. */


  8. #ifndef _NGX_SOCKET_H_INCLUDED_
  9. ‌#define _NGX_SOCKET_H_INCLUDED_


  12. #include <ngx_config.h>
  13. #include <ngx_core.h>


  16. ‌#define NGX_WRITE_SHUTDOWN SD_SEND
  17. ‌#define NGX_READ_SHUTDOWN  SD_RECEIVE
  18. ‌#define NGX_RDWR_SHUTDOWN  SD_BOTH


  21. ‌typedef SOCKET  ngx_socket_t;
  22. ‌typedef int     socklen_t;


  25. ‌#define ngx_socket(af, type, proto)                                          \
  26.     WSASocketW(af, type, proto, NULL, 0, WSA_FLAG_OVERLAPPED)

  28. ‌#define ngx_socket_n        "WSASocketW()"

  30. int ngx_nonblocking(ngx_socket_t s);
  31. int ngx_blocking(ngx_socket_t s);

  33. ‌#define ngx_nonblocking_n   "ioctlsocket(FIONBIO)"
  34. ‌#define ngx_blocking_n      "ioctlsocket(!FIONBIO)"

  36. int ngx_socket_nread(ngx_socket_t s, int *n);
  37. ‌#define ngx_socket_nread_n  "ioctlsocket(FIONREAD)"

  39. ‌#define ngx_shutdown_socket    shutdown
  40. ‌#define ngx_shutdown_socket_n  "shutdown()"

  42. ‌#define ngx_close_socket    closesocket
  43. ‌#define ngx_close_socket_n  "closesocket()"


  46. #ifndef WSAID_ACCEPTEX

  48. ‌typedef BOOL (PASCAL FAR * LPFN_ACCEPTEX)(
  49.     IN SOCKET sListenSocket,
  50.     IN SOCKET sAcceptSocket,
  51.     IN PVOID lpOutputBuffer,
  52.     IN DWORD dwReceiveDataLength,
  53.     IN DWORD dwLocalAddressLength,
  54.     IN DWORD dwRemoteAddressLength,
  55.     OUT LPDWORD lpdwBytesReceived,
  56.     IN LPOVERLAPPED lpOverlapped
  57.     );

  59. ‌#define WSAID_ACCEPTEX                                                       \
  60.     {0xb5367df1,0xcbac,0x11cf,{0x95,0xca,0x00,0x80,0x5f,0x48,0xa1,0x92}}

  62. #endif


  65. #ifndef WSAID_GETACCEPTEXSOCKADDRS

  67. ‌typedef VOID (PASCAL FAR * LPFN_GETACCEPTEXSOCKADDRS)(
  68.     IN PVOID lpOutputBuffer,
  69.     IN DWORD dwReceiveDataLength,
  70.     IN DWORD dwLocalAddressLength,
  71.     IN DWORD dwRemoteAddressLength,
  72.     OUT struct sockaddr **LocalSockaddr,
  73.     OUT LPINT LocalSockaddrLength,
  74.     OUT struct sockaddr **RemoteSockaddr,
  75.     OUT LPINT RemoteSockaddrLength
  76.     );

  78. ‌#define WSAID_GETACCEPTEXSOCKADDRS                                           \
  79.         {0xb5367df2,0xcbac,0x11cf,{0x95,0xca,0x00,0x80,0x5f,0x48,0xa1,0x92}}

  81. #endif


  84. #ifndef WSAID_TRANSMITFILE

  86. #ifndef TF_DISCONNECT

  88. ‌#define TF_DISCONNECT           1
  89. ‌#define TF_REUSE_SOCKET         2
  90. ‌#define TF_WRITE_BEHIND         4
  91. ‌#define TF_USE_DEFAULT_WORKER   0
  92. ‌#define TF_USE_SYSTEM_THREAD    16
  93. ‌#define TF_USE_KERNEL_APC       32

  95. ‌typedef struct _TRANSMIT_FILE_BUFFERS {
  96.     LPVOID Head;
  97.     DWORD HeadLength;
  98.     LPVOID Tail;
  99.     DWORD TailLength;
  100. ‌‌‌} TRANSMIT_FILE_BUFFERS, *PTRANSMIT_FILE_BUFFERS, FAR *LPTRANSMIT_FILE_BUFFERS;

  102. #endif

  104. ‌typedef BOOL (PASCAL FAR * LPFN_TRANSMITFILE)(
  105.     IN SOCKET hSocket,
  106.     IN HANDLE hFile,
  107.     IN DWORD nNumberOfBytesToWrite,
  108.     IN DWORD nNumberOfBytesPerSend,
  109.     IN LPOVERLAPPED lpOverlapped,
  110.     IN LPTRANSMIT_FILE_BUFFERS lpTransmitBuffers,
  111.     IN DWORD dwReserved
  112.     );

  114. ‌#define WSAID_TRANSMITFILE                                                   \
  115.     {0xb5367df0,0xcbac,0x11cf,{0x95,0xca,0x00,0x80,0x5f,0x48,0xa1,0x92}}

  117. #endif


  120. #ifndef WSAID_TRANSMITPACKETS

  122. /* OpenWatcom has a swapped TP_ELEMENT_FILE and TP_ELEMENT_MEMORY definition */

  124. #ifndef TP_ELEMENT_FILE

  126. #ifdef _MSC_VER
  127. #pragma warning(disable:4201) /* Nonstandard extension, nameless struct/union */
  128. #endif

  130. ‌typedef struct _TRANSMIT_PACKETS_ELEMENT {
  131.     ULONG dwElFlags;
  132. ‌#define TP_ELEMENT_MEMORY   1
  133. ‌#define TP_ELEMENT_FILE     2
  134. ‌#define TP_ELEMENT_EOP      4
  135.     ULONG cLength;
  136. ‌    union {
  137. ‌        struct {
  138.             LARGE_INTEGER nFileOffset;
  139.             HANDLE        hFile;
  140.         };
  141.         PVOID             pBuffer;
  142.     };
  143. ‌‌} TRANSMIT_PACKETS_ELEMENT, *PTRANSMIT_PACKETS_ELEMENT,
  144. ‌    FAR *LPTRANSMIT_PACKETS_ELEMENT;

  146. #ifdef _MSC_VER
  147. #pragma warning(default:4201)
  148. #endif

  150. #endif

  152. ‌typedef BOOL (PASCAL FAR * LPFN_TRANSMITPACKETS) (
  153.     SOCKET hSocket,
  154.     TRANSMIT_PACKETS_ELEMENT *lpPacketArray,
  155.     DWORD nElementCount,
  156.     DWORD nSendSize,
  157.     LPOVERLAPPED lpOverlapped,
  158.     DWORD dwFlags
  159.     );

  161. ‌#define WSAID_TRANSMITPACKETS                                                \
  162.     {0xd9689da0,0x1f90,0x11d3,{0x99,0x71,0x00,0xc0,0x4f,0x68,0xc8,0x76}}

  164. #endif


  167. #ifndef WSAID_CONNECTEX

  169. ‌typedef BOOL (PASCAL FAR * LPFN_CONNECTEX) (
  170.     IN SOCKET s,
  171.     IN const struct sockaddr FAR *name,
  172.     IN int namelen,
  173.     IN PVOID lpSendBuffer OPTIONAL,
  174.     IN DWORD dwSendDataLength,
  175.     OUT LPDWORD lpdwBytesSent,
  176.     IN LPOVERLAPPED lpOverlapped
  177.     );

  179. ‌#define WSAID_CONNECTEX \
  180.     {0x25a207b9,0xddf3,0x4660,{0x8e,0xe9,0x76,0xe5,0x8c,0x74,0x06,0x3e}}

  182. #endif


  185. #ifndef WSAID_DISCONNECTEX

  187. ‌typedef BOOL (PASCAL FAR * LPFN_DISCONNECTEX) (
  188.     IN SOCKET s,
  189.     IN LPOVERLAPPED lpOverlapped,
  190.     IN DWORD  dwFlags,
  191.     IN DWORD  dwReserved
  192.     );

  194. ‌#define WSAID_DISCONNECTEX                                                   \
  195.     {0x7fda2e11,0x8630,0x436f,{0xa0,0x31,0xf5,0x36,0xa6,0xee,0xc1,0x57}}

  197. #endif


  200. extern LPFN_ACCEPTEX              ngx_acceptex;
  201. extern LPFN_GETACCEPTEXSOCKADDRS  ngx_getacceptexsockaddrs;
  202. extern LPFN_TRANSMITFILE          ngx_transmitfile;
  203. extern LPFN_TRANSMITPACKETS       ngx_transmitpackets;
  204. extern LPFN_CONNECTEX             ngx_connectex;
  205. extern LPFN_DISCONNECTEX          ngx_disconnectex;


  208. #if (NGX_HAVE_POLL && !defined POLLIN)

  210. /*
  211. * WSAPoll() is only available if _WIN32_WINNT >= 0x0600.
  212. * If it is not available during compilation, we try to
  213. * load it dynamically at runtime.
  214. */

  216. ‌#define NGX_LOAD_WSAPOLL 1

  218. ‌#define POLLRDNORM  0x0100
  219. ‌#define POLLRDBAND  0x0200
  220. ‌#define POLLIN      (POLLRDNORM | POLLRDBAND)
  221. ‌#define POLLPRI     0x0400

  223. ‌#define POLLWRNORM  0x0010
  224. ‌#define POLLOUT     (POLLWRNORM)
  225. ‌#define POLLWRBAND  0x0020

  227. ‌#define POLLERR     0x0001
  228. ‌#define POLLHUP     0x0002
  229. ‌#define POLLNVAL    0x0004

  231. ‌typedef struct pollfd {

  233.     SOCKET  fd;
  234.     SHORT   events;
  235.     SHORT   revents;

  237. ‌‌‌} WSAPOLLFD, *PWSAPOLLFD, FAR *LPWSAPOLLFD;

  239. ‌typedef int (WSAAPI *ngx_wsapoll_pt)(
  240.     LPWSAPOLLFD fdArray,
  241.     ULONG fds,
  242.     INT timeout
  243.     );

  245. extern ngx_wsapoll_pt             WSAPoll;
  246. extern ngx_uint_t                 ngx_have_wsapoll;

  248. #endif


  251. int ngx_tcp_push(ngx_socket_t s);
  252. ‌#define ngx_tcp_push_n            "tcp_push()"


  255. #endif /* _NGX_SOCKET_H_INCLUDED_ */

One Level Up Top Level