Lines Matching refs:nsock
2039 isc_socket_t *nsock;
2068 nsock = adev->newsocket;
2085 nsock->address = adev->address;
2086 nsock->pf = adev->address.type.sa.sa_family;
2088 socket_log(__LINE__, nsock, &nsock->address, TRACE,
2100 INSIST(setsockopt(nsock->fd, SOL_SOCKET, SO_UPDATE_ACCEPT_CONTEXT,
2106 nsock->bound = 1;
2107 nsock->connected = 1;
2108 _set_state(nsock, SOCK_OPEN);
2110 LOCK(&nsock->manager->lock);
2111 ISC_LIST_APPEND(nsock->manager->socklist, nsock, link);
2112 InterlockedIncrement(&nsock->manager->totalSockets);
2113 UNLOCK(&nsock->manager->lock);
2115 socket_log(__LINE__, sock, &nsock->address, CREATION,
2118 nsock, nsock->fd);
2432 isc_socket_t *nsock = lpo->adev->newsocket;
2442 if (nsock->fd == INVALID_SOCKET) {
2445 closesocket(nsock->fd);
2446 nsock->fd = new_fd;
2451 nsock->fd, /* Accepted Socket */
2460 InterlockedDecrement(&nsock->manager->iocp_total);
2461 iocompletionport_update(nsock);
3389 isc_socket_t *nsock;
3425 result = allocate_socket(manager, sock->type, &nsock);
3435 nsock->fd = socket(sock->pf, SOCK_STREAM, IPPROTO_TCP);
3436 if (nsock->fd == INVALID_SOCKET) {
3437 free_socket(&nsock, __LINE__);
3448 free_socket(&nsock, __LINE__);
3454 nsock->references++;
3457 adev->newsocket = nsock;
3458 _set_state(nsock, SOCK_ACCEPT);
3475 nsock->fd, /* Accepted Socket */
3483 iocompletionport_update(nsock);
3487 "accepting for nsock %p fd %d", nsock, nsock->fd);