Lines Matching defs:nsock
2015 isc_socket_t *nsock;
2044 nsock = adev->newsocket;
2061 nsock->address = adev->address;
2062 nsock->pf = adev->address.type.sa.sa_family;
2064 socket_log(__LINE__, nsock, &nsock->address, TRACE,
2071 INSIST(setsockopt(nsock->fd, SOL_SOCKET, SO_UPDATE_ACCEPT_CONTEXT,
2077 nsock->bound = 1;
2078 nsock->connected = 1;
2079 _set_state(nsock, SOCK_OPEN);
2081 LOCK(&nsock->manager->lock);
2082 ISC_LIST_APPEND(nsock->manager->socklist, nsock, link);
2083 InterlockedIncrement(&nsock->manager->totalSockets);
2084 UNLOCK(&nsock->manager->lock);
2086 socket_log(__LINE__, sock, &nsock->address, CREATION,
2089 nsock, nsock->fd);
2379 isc_socket_t *nsock = lpo->adev->newsocket;
2389 if (nsock->fd == INVALID_SOCKET) {
2392 closesocket(nsock->fd);
2393 nsock->fd = new_fd;
2398 nsock->fd, /* Accepted Socket */
2407 InterlockedDecrement(&nsock->manager->iocp_total);
2408 iocompletionport_update(nsock);
3308 isc_socket_t *nsock;
3344 result = allocate_socket(manager, sock->type, &nsock);
3354 nsock->fd = socket(sock->pf, SOCK_STREAM, IPPROTO_TCP);
3355 if (nsock->fd == INVALID_SOCKET) {
3356 free_socket(&nsock, __LINE__);
3367 free_socket(&nsock, __LINE__);
3373 nsock->references++;
3376 adev->newsocket = nsock;
3377 _set_state(nsock, SOCK_ACCEPT);
3394 nsock->fd, /* Accepted Socket */
3402 iocompletionport_update(nsock);
3406 "accepting for nsock %p fd %d", nsock, nsock->fd);