| /dports/www/uwsgi/uwsgi-2.0.20/core/ |
| H A D | master_events.c | 5 int uwsgi_master_manage_events(int interesting_fd) { in uwsgi_master_manage_events() argument
26 return uwsgi_notify_socket_manage(interesting_fd); in uwsgi_master_manage_events()
31 if (interesting_fd == uwsgi.stats_fd) { in uwsgi_master_manage_events()
39 if (interesting_fd == uwsgi.zerg_server_fd) { in uwsgi_master_manage_events()
52 if (interesting_fd == uwsgi.emperor_fd) { in uwsgi_master_manage_events()
64 if (uwsgi_fsmon_event(interesting_fd)) { in uwsgi_master_manage_events()
75 if (interesting_fd == (int) usl->custom) { in uwsgi_master_manage_events()
143 if (interesting_fd == uwsgi_sock->fd) { in uwsgi_master_manage_events()
220 close(interesting_fd); in uwsgi_master_manage_events()
238 close(interesting_fd); in uwsgi_master_manage_events()
[all …]
|
| H A D | async.c | 415 int interesting_fd, i; in async_loop() local
481 interesting_fd = event_queue_interesting_fd(events, i); in async_loop()
484 …if (uwsgi.signal_socket > -1 && (interesting_fd == uwsgi.signal_socket || interesting_fd == uwsgi.… in async_loop()
495 if (interesting_fd == uwsgi_sock->fd) { in async_loop()
534 uwsgi.wsgi_req = find_wsgi_req_proto_by_fd(interesting_fd); in async_loop()
542 uwsgi.async_proto_fd_table[interesting_fd] = NULL; in async_loop()
550 uwsgi.async_proto_fd_table[interesting_fd] = NULL; in async_loop()
551 close(interesting_fd); in async_loop()
562 uwsgi.wsgi_req = find_wsgi_req_by_fd(interesting_fd); in async_loop()
565 close(interesting_fd); in async_loop()
[all …]
|
| H A D | mule.c | 173 int interesting_fd; in uwsgi_mule_handler() local
188 rlen = event_queue_wait(mule_queue, -1, &interesting_fd); in uwsgi_mule_handler()
193 …if (interesting_fd == uwsgi.signal_socket || interesting_fd == uwsgi.my_signal_socket || farm_has_… in uwsgi_mule_handler()
194 len = read(interesting_fd, &uwsgi_signal, 1); in uwsgi_mule_handler()
207 …f (interesting_fd == uwsgi.mules[uwsgi.muleid - 1].queue_pipe[1] || interesting_fd == uwsgi.shared… in uwsgi_mule_handler()
208 len = read(interesting_fd, message, 65536); in uwsgi_mule_handler()
349 int interesting_fd = -1; in uwsgi_mule_get_msg() local
351 interesting_fd = mulepoll[2].fd; in uwsgi_mule_get_msg()
354 interesting_fd = mulepoll[3].fd; in uwsgi_mule_get_msg()
357 if (interesting_fd > -1) { in uwsgi_mule_get_msg()
[all …]
|
| H A D | fsmon.c | 135 static struct uwsgi_fsmon *uwsgi_fsmon_ack(int interesting_fd) { in uwsgi_fsmon_ack() argument
139 if (fs->fd == interesting_fd) { in uwsgi_fsmon_ack()
152 if (ioctl(interesting_fd, FIONREAD, &isize) < 0) { in uwsgi_fsmon_ack()
160 ssize_t len = read(interesting_fd, ie, isize); in uwsgi_fsmon_ack()
168 if (fs->fd == interesting_fd && fs->id == ie->wd) { in uwsgi_fsmon_ack()
180 int uwsgi_fsmon_event(int interesting_fd) { in uwsgi_fsmon_event() argument
182 struct uwsgi_fsmon *fs = uwsgi_fsmon_ack(interesting_fd); in uwsgi_fsmon_event()
|
| H A D | event.c | 64 int event_queue_wait(int eq, int timeout, int *interesting_fd) { in event_queue_wait() argument
73 *interesting_fd = upe->poll[i].fd; in event_queue_wait()
444 int event_queue_wait(int eq, int timeout, int *interesting_fd) { argument
480 *interesting_fd = (long) pe.portev_user;
483 *interesting_fd = (int) pe.portev_object;
714 int event_queue_wait(int eq, int timeout, int *interesting_fd) { argument
730 *interesting_fd = ee.data.fd;
948 int event_queue_wait(int eq, int timeout, int *interesting_fd) { argument
969 *interesting_fd = ev.ident;
|
| H A D | alarm.c | 223 int interesting_fd = -1; in uwsgi_alarm_thread_loop() local
224 int ret = event_queue_wait(ut->queue, -1, &interesting_fd); in uwsgi_alarm_thread_loop()
226 if (interesting_fd == ut->pipe[1]) { in uwsgi_alarm_thread_loop()
244 if (interesting_fd == uafd->fd) { in uwsgi_alarm_thread_loop()
|
| H A D | offload.c | 281 int interesting_fd = event_queue_interesting_fd(events, i); in uwsgi_offload_loop() local
282 if (interesting_fd == ut->pipe[1]) { in uwsgi_offload_loop()
300 struct uwsgi_offload_request *uor = uwsgi_offload_get_by_fd(ut, interesting_fd); in uwsgi_offload_loop()
304 if (uor->engine->event_func(ut, uor, interesting_fd)) { in uwsgi_offload_loop()
|
| H A D | spooler.c | 424 int interesting_fd = -1; local
457 if (event_queue_wait(spooler_event_queue, timeout, &interesting_fd) > 0) {
459 if (interesting_fd == uwsgi.shared->spooler_signal_pipe[1]) {
460 uwsgi_receive_signal(interesting_fd, "spooler", (int) getpid());
|
| H A D | emperor.c | 1668 int interesting_fd; in emperor_loop() local
1790 interesting_fd = event_queue_interesting_fd(events, i); in emperor_loop()
1792 …if (uwsgi.emperor_stats && uwsgi.emperor_stats_fd > -1 && interesting_fd == uwsgi.emperor_stats_fd… in emperor_loop()
1798 if (uwsgi_emperor_scanner_event(interesting_fd)) { in emperor_loop()
1802 ui_current = emperor_get_by_fd(interesting_fd); in emperor_loop()
1805 ssize_t rlen = read(interesting_fd, &byte, 1); in emperor_loop()
1810 event_queue_del_fd(uwsgi.emperor_queue, interesting_fd, event_queue_read()); in emperor_loop()
1862 ui_current = emperor_get_by_socket_fd(interesting_fd); in emperor_loop()
1870 uwsgi_log("[emperor] unrecognized vassal event on fd %d\n", interesting_fd); in emperor_loop()
1871 close(interesting_fd); in emperor_loop()
|
| H A D | exceptions.c | 442 int interesting_fd = -1; in uwsgi_exception_handler_thread_loop() local
443 int ret = event_queue_wait(ut->queue, -1, &interesting_fd); in uwsgi_exception_handler_thread_loop()
|
| H A D | master.c | 716 int interesting_fd = -1; local
733 rlen = event_queue_wait(uwsgi.master_queue, check_interval, &interesting_fd);
757 if (uwsgi_master_manage_events(interesting_fd)) {
|
| H A D | stats.c | 449 int interesting_fd = event_queue_interesting_fd(events, 0); in uwsgi_stats_pusher_loop() local
451 ssize_t len = read(interesting_fd, buf, 4096); in uwsgi_stats_pusher_loop()
|
| H A D | legion.c | 507 int interesting_fd = -1; in legion_loop() local
509 int rlen = event_queue_wait(uwsgi.legion_queue, timeout, &interesting_fd); in legion_loop()
531 struct uwsgi_legion *ul = uwsgi_legion_get_by_socket(interesting_fd); in legion_loop()
|
| H A D | utils.c | 1489 int interesting_fd = -1; in wsgi_req_accept() local
1533 ret = event_queue_wait(queue, timeout, &interesting_fd); in wsgi_req_accept()
1553 …if (uwsgi.signal_socket > -1 && (interesting_fd == uwsgi.signal_socket || interesting_fd == uwsgi.… in wsgi_req_accept()
1557 uwsgi_receive_signal(interesting_fd, "worker", uwsgi.mywid); in wsgi_req_accept()
1566 …if (interesting_fd == uwsgi_sock->fd || (uwsgi_sock->retry && uwsgi_sock->retry[wsgi_req->async_id… in wsgi_req_accept()
1568 wsgi_req->fd = wsgi_req->socket->proto_accept(wsgi_req, interesting_fd); in wsgi_req_accept()
|
| H A D | cache.c | 1056 int interesting_fd = -1; in cache_udp_server_loop() local
1057 int rlen = event_queue_wait(queue, -1, &interesting_fd); in cache_udp_server_loop()
1059 if (interesting_fd < 0) continue; in cache_udp_server_loop()
1060 ssize_t len = read(interesting_fd, buf, UMAX16); in cache_udp_server_loop()
|
| /dports/www/uwsgi/uwsgi-2.0.20/plugins/pty/ |
| H A D | pty.c | 133 int interesting_fd = -1; in uwsgi_pty_loop() local
134 int ret = event_queue_wait(upty.queue, -1, &interesting_fd); in uwsgi_pty_loop()
138 if (upty.input && interesting_fd == upty.original_input) { in uwsgi_pty_loop()
147 if (interesting_fd == upty.master_fd) { in uwsgi_pty_loop()
172 if (interesting_fd == upty.server_fd) { in uwsgi_pty_loop()
189 if (interesting_fd == upc->fd) { in uwsgi_pty_loop()
321 int interesting_fd = -1; in uwsgi_pty_client() local
322 int ret = event_queue_wait(upty.queue, -1, &interesting_fd); in uwsgi_pty_client()
328 if (interesting_fd == 0) { in uwsgi_pty_client()
342 if (interesting_fd == upty.server_fd) { in uwsgi_pty_client()
|
| /dports/www/uwsgi/uwsgi-2.0.20/plugins/tuntap/ |
| H A D | tuntap.c | 104 int interesting_fd = -1; in uwsgi_tuntap_loop() local
105 int ret = event_queue_wait(uttr->queue, -1, &interesting_fd); in uwsgi_tuntap_loop()
110 if (interesting_fd == uttr->fd) { in uwsgi_tuntap_loop()
143 if (interesting_fd == uttr->server_fd) { in uwsgi_tuntap_loop()
250 int interesting_fd = event_queue_interesting_fd(events, i); in uwsgi_tuntap_router_loop() local
251 if (interesting_fd == uttr->fd) { in uwsgi_tuntap_router_loop()
294 if (interesting_fd == uttr->server_fd) { in uwsgi_tuntap_router_loop()
313 if (uttr->stats_server_fd > -1 && interesting_fd == uttr->stats_server_fd) { in uwsgi_tuntap_router_loop()
318 if (uttr->gateway_fd > -1 && interesting_fd == uttr->gateway_fd) { in uwsgi_tuntap_router_loop()
353 if (interesting_fd == uttp->fd) { in uwsgi_tuntap_router_loop()
|
| /dports/www/uwsgi/uwsgi-2.0.20/plugins/alarm_xmpp/ |
| H A D | gloox.cc | 98 int interesting_fd; in uwsgi_alarm_xmpp_loop() local
146 int ret = event_queue_wait(ut->queue, timeout, &interesting_fd); in uwsgi_alarm_xmpp_loop()
149 if (ret > 0 && interesting_fd == ut->pipe[1]) { in uwsgi_alarm_xmpp_loop()
156 else if (ret == 0 || (ret > 0 && j.fd > -1 && interesting_fd == j.fd)) { in uwsgi_alarm_xmpp_loop()
|
| /dports/www/uwsgi/uwsgi-2.0.20/plugins/zergpool/ |
| H A D | zergpool.c | 50 int interesting_fd = event_queue_interesting_fd(events, i); in zergpool_loop() local
54 if (zps->fd == interesting_fd) { in zergpool_loop()
|
| /dports/www/uwsgi/uwsgi-2.0.20/plugins/corerouter/ |
| H A D | corerouter.c | 815 ucr->interesting_fd = event_queue_interesting_fd(events, i); in uwsgi_corerouter_loop()
817 if (ucr->interesting_fd < 0) continue; in uwsgi_corerouter_loop()
823 if (ugs->gateway == &ushared->gateways[id] && ucr->interesting_fd == ugs->fd) { in uwsgi_corerouter_loop()
826 …new_connection = accept4(ucr->interesting_fd, (struct sockaddr *) &cr_addr, &cr_addr_len, SOCK_NON… in uwsgi_corerouter_loop()
832 new_connection = accept(ucr->interesting_fd, (struct sockaddr *) &cr_addr, &cr_addr_len); in uwsgi_corerouter_loop()
863 if (ucr->interesting_fd == ushared->gateways[id].internal_subscription_pipe[1]) { in uwsgi_corerouter_loop()
864 uwsgi_corerouter_manage_internal_subscription(ucr, ucr->interesting_fd); in uwsgi_corerouter_loop()
867 else if (ucr->interesting_fd == ucr->cr_stats_server) { in uwsgi_corerouter_loop()
871 struct corerouter_peer *peer = ucr->cr_table[ucr->interesting_fd]; in uwsgi_corerouter_loop()
|
| H A D | cr.h | 269 int interesting_fd; member
|
| /dports/www/uwsgi/uwsgi-2.0.20/plugins/alarm_curl/ |
| H A D | alarm_curl_plugin.c | 235 int interesting_fd; in uwsgi_alarm_curl_loop() local
240 int ret = event_queue_wait(ut->queue, -1, &interesting_fd); in uwsgi_alarm_curl_loop()
243 if (interesting_fd != ut->pipe[1]) continue; in uwsgi_alarm_curl_loop()
|
| /dports/www/uwsgi/uwsgi-2.0.20/plugins/airbrake/ |
| H A D | airbrake_plugin.c | 218 int interesting_fd; local
246 int ret = event_queue_wait(ut->queue, -1, &interesting_fd);
249 if (interesting_fd != ut->pipe[1]) continue;
|