52 typedef void (*CallbackFunc)(int sock, void *ctx);
71     int sock;  member
97 dispatcher_add(Dispatcher *dispr, int sock, void *ctx, CallbackFunc cb)  in dispatcher_add()  argument
99     if (sock >= FD_SETSIZE) {  in dispatcher_add()
102                 sock, FD_SETSIZE);  in dispatcher_add()
106     dispr->events[sock].ctx = ctx;  in dispatcher_add()
107     dispr->events[sock].callback = cb;  in dispatcher_add()
109     FD_SET(sock, &dispr->fdset);  in dispatcher_add()
110     if (sock > dispr->max_sock) {  in dispatcher_add()
111         dispr->max_sock = sock;  in dispatcher_add()
114            sock, dispr->max_sock);  in dispatcher_add()
119 dispatcher_remove(Dispatcher *dispr, int sock)  in dispatcher_remove()  argument
121     if (sock >= FD_SETSIZE) {  in dispatcher_remove()
124                 sock, FD_SETSIZE);  in dispatcher_remove()
128     FD_CLR(sock, &dispr->fdset);  in dispatcher_remove()
129     DPRINT("Sock %d removed from dispatcher watch.\n", sock);  in dispatcher_remove()
157     int sock;  in dispatcher_wait()  local
158     for (sock = 0; sock < dispr->max_sock + 1; sock++) {  in dispatcher_wait()
163         if (FD_ISSET(sock, &fdset) && FD_ISSET(sock, &dispr->fdset)) {  in dispatcher_wait()
164             Event *e = &dispr->events[sock];  in dispatcher_wait()
165             e->callback(sock, e->ctx);  in dispatcher_wait()
271 vubr_backend_recv_cb(int sock, void *ctx)  in vubr_backend_recv_cb()  argument
373 vubr_receive_cb(int sock, void *ctx)  in vubr_receive_cb()  argument
389 watch_cb(int sock, void *ctx)  in watch_cb()  argument
485     dispatcher_remove(&vubr->dispatcher, dev->sock);  in vubr_panic()
504 vubr_accept_cb(int sock, void *ctx)  in vubr_accept_cb()  argument
511     conn_fd = accept(sock, (struct sockaddr *) &un, &len);  in vubr_accept_cb()
530     dispatcher_remove(&dev->dispatcher, sock);  in vubr_accept_cb()
547     dev->sock = socket(AF_UNIX, SOCK_STREAM, 0);  in vubr_new()
548     if (dev->sock == -1) {  in vubr_new()
561         if (bind(dev->sock, (struct sockaddr *) &un, len) == -1) {  in vubr_new()
565         if (listen(dev->sock, 1) == -1) {  in vubr_new()
572         if (connect(dev->sock, (struct sockaddr *)&un, len) == -1) {  in vubr_new()
578                      dev->sock,  in vubr_new()
593     dispatcher_add(&dev->dispatcher, dev->sock, (void *)dev, cb);  in vubr_new()
690     int sock;  in vubr_backend_udp_setup()  local
721     sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);  in vubr_backend_udp_setup()
722     if (sock == -1) {  in vubr_backend_udp_setup()
726     if (bind(sock, (struct sockaddr *)&si_local, sizeof(si_local)) == -1) {  in vubr_backend_udp_setup()
730     dev->backend_udp_sock = sock;  in vubr_backend_udp_setup()
731     dispatcher_add(&dev->dispatcher, sock, dev, vubr_backend_recv_cb);  in vubr_backend_udp_setup()