Lines Matching refs:threadid

345 	int threadid;  member
395 int threadid; member
627 thread->threadid, msgbuf); in thread_log()
941 select_poke(isc_socketmgr_t *mgr, int threadid, int fd, int msg) { in select_poke() argument
950 cc = write(mgr->threads[threadid].pipe_fds[1], buf, in select_poke()
1824 select_poke(thread->manager, thread->threadid, fd, in socketclose()
1887 thread = &manager->threads[sock->threadid]; in destroy()
1889 sock->threadid = -1; in destroy()
1924 sock->threadid = -1; in allocate_socket()
2528 sock->threadid = gen_threadid(sock); in socket_create()
2530 thread = &manager->threads[sock->threadid]; in socket_create()
2602 REQUIRE(sock->threadid == -1); in isc_socket_open()
2612 sock->threadid = gen_threadid(sock); in isc_socket_open()
2613 thread = &sock->manager->threads[sock->threadid]; in isc_socket_open()
2692 thread = &manager->threads[sock->threadid]; in isc_socket_close()
2695 sock->threadid = -1; in isc_socket_close()
2755 sock->threadid); in send_recvdone_event()
2757 isc_task_sendto(task, (isc_event_t **)dev, sock->threadid); in send_recvdone_event()
2781 sock->threadid); in send_senddone_event()
2783 isc_task_sendto(task, (isc_event_t **)dev, sock->threadid); in send_senddone_event()
2805 isc_task_sendtoanddetach(&task, (isc_event_t **)dev, sock->threadid); in send_connectdone_event()
2838 thread = &manager->threads[sock->threadid]; in internal_accept()
2992 NEWCONNSOCK(dev)->threadid = gen_threadid(NEWCONNSOCK(dev)); in internal_accept()
2995 nthread = &manager->threads[NEWCONNSOCK(dev)->threadid]; in internal_accept()
3001 bool same_bucket = (sock->threadid == in internal_accept()
3002 NEWCONNSOCK(dev)->threadid) && in internal_accept()
3069 isc_task_sendtoanddetach(&task, ISC_EVENT_PTR(&dev), sock->threadid); in internal_accept()
3128 unwatch_fd(&sock->manager->threads[sock->threadid], sock->fd, in internal_recv()
3167 unwatch_fd(&sock->manager->threads[sock->threadid], sock->fd, in internal_send()
3194 select_poke(sock->manager, sock->threadid, sock->fd, in internal_fdwatch_write()
3220 select_poke(sock->manager, sock->threadid, sock->fd, in internal_fdwatch_read()
3658 REQUIRE(thread->threadid >= 0 && in setup_thread()
3659 thread->threadid < thread->manager->nthreads); in setup_thread()
3916 manager->threads[i].threadid = i; in isc_socketmgr_create2()
4053 select_poke(sock->manager, sock->threadid, sock->fd, in socket_recv()
4202 select_poke(sock->manager, sock->threadid, in socket_send()
4760 select_poke(manager, sock->threadid, sock->fd, in isc_socket_accept()
4805 isc_task_sendto(task, ISC_EVENT_PTR(&dev), sock->threadid); in isc_socket_connect()
4874 isc_task_sendto(task, ISC_EVENT_PTR(&dev), sock->threadid); in isc_socket_connect()
4890 isc_task_sendto(task, ISC_EVENT_PTR(&dev), sock->threadid); in isc_socket_connect()
4918 select_poke(manager, sock->threadid, sock->fd, in isc_socket_connect()
5026 unwatch_fd(&sock->manager->threads[sock->threadid], sock->fd, in internal_connect()
5178 sock->threadid); in isc_socket_cancel()
5669 sock->threadid = gen_threadid(sock); in isc_socket_fdwatchcreate()
5671 thread = &manager->threads[sock->threadid]; in isc_socket_fdwatchcreate()
5703 select_poke(sock->manager, sock->threadid, sock->fd, in isc_socket_fdwatchcreate()
5706 select_poke(sock->manager, sock->threadid, sock->fd, in isc_socket_fdwatchcreate()
5734 select_poke(sock->manager, sock->threadid, sock->fd, in isc_socket_fdwatchpoke()
5737 select_poke(sock->manager, sock->threadid, sock->fd, in isc_socket_fdwatchpoke()