Lines Matching defs:lpo

667 internal_sendmsg(isc_socket_t *sock, IoCompletionInfo *lpo,
679 messagehdr->to_addr_len, (LPWSAOVERLAPPED)lpo,
706 if (lpo != NULL)
720 IoCompletionInfo *lpo = NULL;
730 if (lpo != NULL)
731 HeapFree(hHeapHandle, 0, lpo);
739 if (lpo != NULL)
740 HeapFree(hHeapHandle, 0, lpo);
750 if (lpo == NULL) {
751 lpo = (IoCompletionInfo *)HeapAlloc(hHeapHandle,
754 RUNTIME_CHECK(lpo != NULL);
756 ZeroMemory(lpo, sizeof(IoCompletionInfo));
757 lpo->request_type = SOCKET_RECV;
766 (LPWSAOVERLAPPED)lpo, NULL);
796 HeapFree(hHeapHandle, 0, lpo);
797 lpo = NULL;
942 IoCompletionInfo *lpo)
977 ISC_LIST_ENQUEUE(lpo->bufferlist, cpbuffer, link);
1375 IoCompletionInfo *lpo;
1379 lpo = (IoCompletionInfo *)HeapAlloc(hHeapHandle,
1382 RUNTIME_CHECK(lpo != NULL);
1383 lpo->request_type = SOCKET_SEND;
1384 lpo->dev = dev;
1385 msghdr = &lpo->messagehdr;
1387 ISC_LIST_INIT(lpo->bufferlist);
1389 build_msghdr_send(sock, dev, msghdr, cmsg, sock->iov, lpo);
1391 *nbytes = internal_sendmsg(sock, lpo, msghdr, 0, send_errno);
1971 internal_accept(isc_socket_t *sock, IoCompletionInfo *lpo, int accept_errno) {
1995 adev = lpo->adev;
2014 ISCGetAcceptExSockaddrs(lpo->acceptbuffer, 0,
2062 HeapFree(hHeapHandle, 0, lpo->acceptbuffer);
2063 lpo->acceptbuffer = NULL;
2071 internal_connect(isc_socket_t *sock, IoCompletionInfo *lpo, int connect_errno) {
2087 cdev = lpo->cdev;
2230 struct msghdr *messagehdr, int nbytes, int send_errno, IoCompletionInfo *lpo)
2246 buffer = ISC_LIST_HEAD(lpo->bufferlist);
2248 ISC_LIST_DEQUEUE(lpo->bufferlist, buffer, link);
2256 buffer = ISC_LIST_HEAD(lpo->bufferlist);
2336 // Additionally, the lpo argument is re-used here, and must not be freed
2340 restart_accept(isc_socket_t *parent, IoCompletionInfo *lpo)
2342 isc_socket_t *nsock = lpo->adev->newsocket;
2358 memset(&lpo->overlapped, 0, sizeof(lpo->overlapped));
2362 lpo->acceptbuffer, /* Buffer for initial Recv */
2366 (LPDWORD)&lpo->received_bytes, /* Bytes Recved */
2367 (LPOVERLAPPED)lpo /* Overlapped structure */
2386 IoCompletionInfo *lpo = NULL;
2419 (LPWSAOVERLAPPED *)&lpo,
2421 if (lpo == NULL) /* Received request to exit */
2426 request = lpo->request_type;
2467 if (senddone_is_active(sock, lpo->dev)) {
2468 lpo->dev->result = isc_result;
2471 send_senddone_event(sock, &lpo->dev);
2482 if (acceptdone_is_active(sock, lpo->adev)) {
2483 if (restart_accept(sock, lpo) == ISC_R_SUCCESS) {
2497 if (acceptdone_is_active(sock, lpo->adev)) {
2498 closesocket(lpo->adev->newsocket->fd);
2499 lpo->adev->newsocket->fd = INVALID_SOCKET;
2500 lpo->adev->newsocket->references--;
2501 free_socket(&lpo->adev->newsocket, __LINE__);
2502 lpo->adev->result = isc_result;
2505 send_acceptdone_event(sock, &lpo->adev);
2514 if (connectdone_is_active(sock, lpo->cdev)) {
2515 lpo->cdev->result = isc_result;
2518 send_connectdone_event(sock, &lpo->cdev);
2524 if (lpo != NULL)
2525 HeapFree(hHeapHandle, 0, lpo);
2529 messagehdr = &lpo->messagehdr;
2536 internal_send(sock, lpo->dev, messagehdr, nbytes, errstatus, lpo);
2539 internal_accept(sock, lpo, errstatus);
2542 internal_connect(sock, lpo, errstatus);
2546 if (lpo != NULL)
2547 HeapFree(hHeapHandle, 0, lpo);
3278 IoCompletionInfo *lpo;
3350 lpo = (IoCompletionInfo *)HeapAlloc(hHeapHandle,
3353 RUNTIME_CHECK(lpo != NULL);
3354 lpo->acceptbuffer = (void *)HeapAlloc(hHeapHandle, HEAP_ZERO_MEMORY,
3356 RUNTIME_CHECK(lpo->acceptbuffer != NULL);
3358 lpo->adev = adev;
3359 lpo->request_type = SOCKET_ACCEPT;
3363 lpo->acceptbuffer, /* Buffer for initial Recv */
3367 (LPDWORD)&lpo->received_bytes, /* Bytes Recved */
3368 (LPOVERLAPPED)lpo /* Overlapped structure */
3395 IoCompletionInfo *lpo;
3467 lpo = (IoCompletionInfo *)HeapAlloc(hHeapHandle,
3470 lpo->cdev = cdev;
3471 lpo->request_type = SOCKET_CONNECT;
3475 NULL, 0, NULL, (LPOVERLAPPED)lpo);