Lines Matching defs:to
5 * Permission to use, copy, modify, and/or distribute this software for any
24 * features to pass on information through the completion port for
83 * no library exports this function. Instead, we need to
84 * issue a runtime call to get the address.
101 * Define this macro to control the behavior of connection
141 #define DOIO_NEEDMORE 5 /* IO was processed, but we need more due to minimum */
171 SOCK_OPEN, /* Socket opened but nothing yet to do */
174 SOCK_ACCEPT, /* TCP socket is waiting to accept */
184 * to collect the destination address and interface so the client can
194 * We really don't want to try and use these control messages. Win32
214 * The size to raise the receive buffer to.
231 /* Pointers to scatter/gather buffers */
244 * buffer that allows us to decouple the system recv() from the
246 * can be removed without having to cancel pending system recv()
247 * calls. It also allows us to read-ahead in some cases.
253 char *consume_position; // where to start copying data from next
268 bound : 1; /* bound to local addr */
309 * to handle the load on the Completion Port. The actual number
369 * This is used to dump the contents of the sock structure
429 /* This function will add an entry to the I/O completion port
430 * that will signal the I/O thread to exit (gracefully)
447 "Can't request service thread to exit: %s"),
494 * Create a private heap to handle the socket overlapped structure
535 * Associate a socket with an IO Completion Port. This allows us to queue events for it
556 "iocompletionport_update: failed to open"
560 /* XXXMLG temporary hack to make failures detected.
561 * This function should return errors to the caller, not
577 * Routine to cleanup and then close the socket.
580 * may fail due to the fact that the Wait should not
627 * actual functions is beyond me. So, ask winsock for the pointers to the
881 /* Set the socket to non-blocking */
898 * to not work correctly, returning a WSACONNRESET error when a WSASendTo
931 * Construct an iov array and attach it to the msghdr passed in. This is
937 * on the buffer linked list for this function to be meaningful.
1071 ev->result = ISC_R_IOERROR; // XXXMLG temporary change to detect failure to set
1276 * Copy out as much data from the internal buffer to done events.
1296 * to handle this. If we do, copy out the data.
1340 * that we expect to be fatal under TCP are merely
1362 * Exactly what we wanted to write. We're done with this
1465 * Set up list of readers and writers to be initially empty.
1565 * check is to be made; if some bit of code believes that IT is done with
1572 * When this function returns, *socketp will be NULL. No tricks to try
1573 * to hold on to this pointer are allowed.
1635 * will be posted to 'task' and when dispatched 'action' will be
1790 * Note we don't have to lock the socket like we normally would because
1791 * there are no external references to it yet.
1813 * Attach to a socket. Caller must explicitly detach when it is done.
1829 * Dereference a socket. If this is the last reference to it, clean things
1872 * in the done event to the one provided, and send it to the task it was
1875 * If the event to be sent is on a list, remove it before sending. If
1876 * asked to, send and detach from the task as well.
1878 * Caller must have the socket locked if the event is attached to the socket.
1963 * On entry to this function, the event delivered is the internal
1965 * the done event we want to send. If the list is empty, this is a no-op,
2174 * our data) then arrange for another system recv() call to fill our buffers.
2190 * event from our notification list (or never placed it on it due to immediate completion.)
2201 * have received enough data on a TCP stream to satisfy the minimum requirements. If
2223 * Unlock and/or destroy if we are the last thing this socket has left to do.
2320 // The Windows network stack seems to have two very distinct paths depending
2330 // not return this to the caller. However, with this product installed,
2378 * waiting for I/O to complete and then forwards them for further
2421 if (lpo == NULL) /* Received request to exit */
2652 * Wait for all sockets to be destroyed.
2665 * Here, we need to had some wait code for the completion port
2672 * Wait for threads to exit.
2722 * Check the pending receive queue, and if we have data pending, give it to this
2740 * Queue our event on the list of things to do. Call our function to
2741 * attempt to fill buffers as much as possible, and return done events.
2742 * We are going to lie about our handling of the ISC_SOCKFLAG_IMMEDIATE
2815 * Move each buffer from the passed in list to our internal one.
2931 "pktinfo structure provided, ifindex %u (set to 0)",
2937 * Set the pktinfo index to 0 here, to let the kernel decide
2945 case DOIO_PENDING: /* I/O started. Nothing more to do */
3090 * Move each buffer from the passed in list to our internal one.
3215 * Set up to listen on a given socket. We do this by creating an internal
3217 * watcher will send the internal event to the task when there is a new
3221 * is a new connection we'll have to allocate a new one anyway, so we might
3222 * as well keep things simple rather than having to track them.
3267 * This should try to do aggressive accept() XXXMLG
3300 * this event to. Just before the actual event is delivered the
3301 * actual ev_sender will be touched up to be the socket.
3331 * Attach to socket and to task.
3478 * Attach to task.
3585 * Quick exit if there is nothing to do. Don't even bother locking
3605 * o If the internal event is marked as "posted" try to