43 	int sock;  member
194 static int eloop_sock_queue(int sock, eloop_event_type type)  in eloop_sock_queue()  argument
215 	ev.data.fd = sock;  in eloop_sock_queue()
216 	if (epoll_ctl(eloop.epollfd, EPOLL_CTL_ADD, sock, &ev) < 0) {  in eloop_sock_queue()
218 			   __func__, sock, strerror(errno));  in eloop_sock_queue()
227 static int eloop_sock_queue(int sock, eloop_event_type type)  in eloop_sock_queue()  argument
242 	EV_SET(&ke, sock, filter, EV_ADD, 0, 0, 0);  in eloop_sock_queue()
245 			   __func__, sock, strerror(errno));  in eloop_sock_queue()
254                                      int sock, eloop_sock_handler handler,  in eloop_sock_table_add_sock()  argument
270 	if (sock > eloop.max_sock)  in eloop_sock_table_add_sock()
271 		new_max_sock = sock;  in eloop_sock_table_add_sock()
356 	tmp[table->count].sock = sock;  in eloop_sock_table_add_sock()
369 	if (eloop_sock_queue(sock, table->type) < 0)  in eloop_sock_table_add_sock()
371 	os_memcpy(&eloop.fd_table[sock], &table->table[table->count - 1],  in eloop_sock_table_add_sock()
379                                          int sock)  in eloop_sock_table_remove_sock()  argument
390 		if (table->table[i].sock == sock)  in eloop_sock_table_remove_sock()
406 	if (epoll_ctl(eloop.epollfd, EPOLL_CTL_DEL, sock, NULL) < 0) {  in eloop_sock_table_remove_sock()
408 			   __func__, sock, strerror(errno));  in eloop_sock_table_remove_sock()
411 	os_memset(&eloop.fd_table[sock], 0, sizeof(struct eloop_sock));  in eloop_sock_table_remove_sock()
414 	EV_SET(&ke, sock, 0, EV_DELETE, 0, 0, 0);  in eloop_sock_table_remove_sock()
417 			   __func__, sock, strerror(errno));  in eloop_sock_table_remove_sock()
420 	os_memset(&eloop.fd_table[sock], 0, sizeof(struct eloop_sock));  in eloop_sock_table_remove_sock()
452 			fd = readers->table[i].sock;  in eloop_sock_table_set_fds()
468 			fd = writers->table[i].sock;  in eloop_sock_table_set_fds()
494 			fd = exceptions->table[i].sock;  in eloop_sock_table_set_fds()
525 		pfd = find_pollfd(pollfds_map, table->table[i].sock,  in eloop_sock_table_dispatch_table()
533 		table->table[i].handler(table->table[i].sock,  in eloop_sock_table_dispatch_table()
578 		assert(table->table[i].sock >= 0);  in eloop_sock_table_set_fds()
579 		FD_SET(table->table[i].sock, fds);  in eloop_sock_table_set_fds()
594 		if (FD_ISSET(table->table[i].sock, fds)) {  in eloop_sock_table_dispatch()
595 			table->table[i].handler(table->table[i].sock,  in eloop_sock_table_dispatch()
617 		table->handler(table->sock, table->eloop_data,  in eloop_sock_table_dispatch()
639 		table->handler(table->sock, table->eloop_data,  in eloop_sock_table_dispatch()
655 		if (eloop_sock_queue(table->table[i].sock, table->type) == -1)  in eloop_sock_table_requeue()
697 				   table->table[i].sock,  in eloop_sock_table_destroy()
711 int eloop_register_read_sock(int sock, eloop_sock_handler handler,  in eloop_register_read_sock()  argument
714 	return eloop_register_sock(sock, EVENT_TYPE_READ, handler,  in eloop_register_read_sock()
719 void eloop_unregister_read_sock(int sock)  in eloop_unregister_read_sock()  argument
721 	eloop_unregister_sock(sock, EVENT_TYPE_READ);  in eloop_unregister_read_sock()
740 int eloop_register_sock(int sock, eloop_event_type type,  in eloop_register_sock()  argument
746 	assert(sock >= 0);  in eloop_register_sock()
748 	return eloop_sock_table_add_sock(table, sock, handler,  in eloop_register_sock()
753 void eloop_unregister_sock(int sock, eloop_event_type type)  in eloop_unregister_sock()  argument
758 	eloop_sock_table_remove_sock(table, sock);  in eloop_unregister_sock()
1300 void eloop_wait_for_read_sock(int sock)  in eloop_wait_for_read_sock()  argument
1305 	if (sock < 0)  in eloop_wait_for_read_sock()
1309 	pfd.fd = sock;  in eloop_wait_for_read_sock()
1322 	if (sock < 0)  in eloop_wait_for_read_sock()
1326 	FD_SET(sock, &rfds);  in eloop_wait_for_read_sock()
1327 	select(sock + 1, &rfds, NULL, NULL, NULL);  in eloop_wait_for_read_sock()
1336 	EV_SET(&ke1, sock, EVFILT_READ, EV_ADD | EV_ONESHOT, 0, 0, 0);  in eloop_wait_for_read_sock()