| /dports/net-mgmt/xymon-server/xymon-4.3.30/xymond/rrd/ |
| H A D | do_mailq.c | 19 char *inqueue, *outqueue; in do_mailq_rrd() local
30 outqueue = strstr(msg, "\nMail queue out:"); in do_mailq_rrd()
32 if (inqueue && outqueue) { in do_mailq_rrd()
36 outqueue = strchr(outqueue+1, '\n'); in do_mailq_rrd()
38 if ((outqueue == NULL) || (inqueue == NULL)) return 0; in do_mailq_rrd()
39 outqueue++; inqueue++; in do_mailq_rrd()
42 p = strchr(outqueue, '\n'); if (p) *p = '\0'; in do_mailq_rrd()
46 p = outqueue + strcspn(outqueue, "0123456789"); outq = atoi(p); in do_mailq_rrd()
|
| /dports/net-mgmt/xymon-client/xymon-4.3.30/xymond/rrd/ |
| H A D | do_mailq.c | 19 char *inqueue, *outqueue; in do_mailq_rrd() local
30 outqueue = strstr(msg, "\nMail queue out:"); in do_mailq_rrd()
32 if (inqueue && outqueue) { in do_mailq_rrd()
36 outqueue = strchr(outqueue+1, '\n'); in do_mailq_rrd()
38 if ((outqueue == NULL) || (inqueue == NULL)) return 0; in do_mailq_rrd()
39 outqueue++; inqueue++; in do_mailq_rrd()
42 p = strchr(outqueue, '\n'); if (p) *p = '\0'; in do_mailq_rrd()
46 p = outqueue + strcspn(outqueue, "0123456789"); outq = atoi(p); in do_mailq_rrd()
|
| /dports/games/openage/openage-0.3.0-1262-ga554ab49/openage/convert/ |
| H A D | slp_converter_pool.py | 59 outqueue = multiprocessing.Queue()
63 args=(inqueue, outqueue)
73 self.idle.put((inqueue, outqueue))
105 inqueue, outqueue = self.idle.get()
111 result = outqueue.get()
114 self.idle.put((inqueue, outqueue))
130 def converter_process(inqueue, outqueue): argument
158 outqueue.put(texture)
163 outqueue.put(exc)
|
| /dports/net/unix2tcp/unix2tcp-0.8.2/ |
| H A D | server.c | 72 t_list *outqueue; member
313 if (out->outqueue == NULL && (out->outqueue = list_init()) == NULL) { in server_read()
332 if (list_append_data(out->outqueue, packet) < 0) { in server_read()
355 if (con->outqueue == NULL) { in server_write()
360 elem = LIST_FIRST(con->outqueue); in server_write()
453 c->in.outqueue = NULL; in conn_new()
456 c->out.outqueue = NULL; in conn_new()
534 if (c->in.outqueue) { in conn_destroy()
541 list_free(c->in.outqueue); in conn_destroy()
543 if (c->out.outqueue) { in conn_destroy()
[all …]
|
| /dports/devel/py-tables/tables-3.6.1/examples/ |
| H A D | simple_threading.py | 43 def run(filename, path, inqueue, outqueue): argument
51 outqueue.put(e)
53 outqueue.put(psum)
65 outqueue = queue.Queue()
70 args=(FILENAME, H5PATH, inqueue, outqueue))
83 out = outqueue.get()
|
| H A D | threading_monkeypatch.py | 81 def run(filename, path, inqueue, outqueue): argument
89 outqueue.put(e)
91 outqueue.put(psum)
101 outqueue = queue.Queue()
106 args=(FILENAME, H5PATH, inqueue, outqueue))
119 out = outqueue.get()
|
| /dports/www/libdatachannel/libdatachannel-0.16.1/deps/usrsctp/usrsctplib/netinet/ |
| H A D | sctp_ss_functions.c | 206 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
233 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
282 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
368 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
529 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_prio_select()
678 … (net == NULL || (TAILQ_FIRST(&strqt->outqueue) && TAILQ_FIRST(&strqt->outqueue)->net == NULL) || in sctp_ss_fb_select()
679 … (net != NULL && TAILQ_FIRST(&strqt->outqueue) && TAILQ_FIRST(&strqt->outqueue)->net != NULL && in sctp_ss_fb_select()
706 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
721 if (TAILQ_FIRST(&strq->outqueue)) { in sctp_ss_fb_scheduled()
873 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_fcfs_select()
[all …]
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/netwerk/sctp/src/netinet/ |
| H A D | sctp_ss_functions.c | 112 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
143 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
200 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
261 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
327 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
395 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_add()
427 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
485 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_prio_select()
593 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
634 … (net != NULL && TAILQ_FIRST(&strqt->outqueue) && TAILQ_FIRST(&strqt->outqueue)->net != NULL && in sctp_ss_fb_select()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/netwerk/sctp/src/netinet/ |
| H A D | sctp_ss_functions.c | 132 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
163 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
223 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
248 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
297 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
318 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
384 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
494 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
673 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
743 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/usrsctp/usrsctplib/usrsctplib/netinet/ |
| H A D | sctp_ss_functions.c | 132 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
163 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
223 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
248 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
297 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
318 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
384 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
494 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
670 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
737 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
[all …]
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/third_party/usrsctp/usrsctplib/usrsctplib/netinet/ |
| H A D | sctp_ss_functions.c | 132 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
163 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
223 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
248 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
297 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
318 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
384 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
494 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
670 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
737 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/usrsctp/usrsctplib/usrsctplib/netinet/ |
| H A D | sctp_ss_functions.c | 132 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
163 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
222 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
247 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
296 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
317 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
383 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
491 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
670 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
740 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
[all …]
|
| /dports/www/firefox/firefox-99.0/netwerk/sctp/src/netinet/ |
| H A D | sctp_ss_functions.c | 132 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
163 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
223 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
248 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
297 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
318 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
384 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
494 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
673 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
743 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/netwerk/sctp/src/netinet/ |
| H A D | sctp_ss_functions.c | 124 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
155 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
215 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
240 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
289 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
310 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
376 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
484 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
658 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
725 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
[all …]
|
| /dports/net/libusrsctp/usrsctp-0.9.5.0/usrsctplib/netinet/ |
| H A D | sctp_ss_functions.c | 132 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
163 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
222 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
247 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
296 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
317 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
383 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
491 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
670 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
740 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/netwerk/sctp/src/netinet/ |
| H A D | sctp_ss_functions.c | 132 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
163 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
223 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
248 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
297 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
318 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
384 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
494 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
673 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
743 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/netwerk/sctp/src/netinet/ |
| H A D | sctp_ss_functions.c | 124 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add()
155 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove()
215 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
240 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
289 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
310 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add()
376 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
484 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_remove()
658 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_fb_remove()
725 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_fb_scheduled()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/net/sctp/ |
| H A D | stream_sched.c | 133 struct sctp_sched_ops *old = asoc->outqueue.sched; in sctp_sched_set_sched()
160 asoc->outqueue.sched = n; in sctp_sched_set_sched()
172 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_set_sched()
176 n->enqueue(&asoc->outqueue, msg); in sctp_sched_set_sched()
183 asoc->outqueue.sched = &sctp_sched_fcfs; /* Always safe */ in sctp_sched_set_sched()
193 if (asoc->outqueue.sched == sctp_sched_ops[i]) in sctp_sched_get_sched()
213 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
225 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value()
272 return asoc->outqueue.sched; in sctp_sched_ops_from_stream()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/sctp/ |
| H A D | stream_sched.c | 133 struct sctp_sched_ops *old = asoc->outqueue.sched; in sctp_sched_set_sched()
160 asoc->outqueue.sched = n; in sctp_sched_set_sched()
172 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_set_sched()
176 n->enqueue(&asoc->outqueue, msg); in sctp_sched_set_sched()
183 asoc->outqueue.sched = &sctp_sched_fcfs; /* Always safe */ in sctp_sched_set_sched()
193 if (asoc->outqueue.sched == sctp_sched_ops[i]) in sctp_sched_get_sched()
213 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
225 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value()
272 return asoc->outqueue.sched; in sctp_sched_ops_from_stream()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/net/sctp/ |
| H A D | stream_sched.c | 133 struct sctp_sched_ops *old = asoc->outqueue.sched; in sctp_sched_set_sched()
160 asoc->outqueue.sched = n; in sctp_sched_set_sched()
172 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_set_sched()
176 n->enqueue(&asoc->outqueue, msg); in sctp_sched_set_sched()
183 asoc->outqueue.sched = &sctp_sched_fcfs; /* Always safe */ in sctp_sched_set_sched()
193 if (asoc->outqueue.sched == sctp_sched_ops[i]) in sctp_sched_get_sched()
213 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
225 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value()
272 return asoc->outqueue.sched; in sctp_sched_ops_from_stream()
|
| /dports/net/vncreflector/vnc_reflector/ |
| H A D | async_io.c | 466 if (cur_slot->outqueue == NULL) { in aio_write_nocopy()
468 cur_slot->outqueue = block; in aio_write_nocopy()
585 if (bytes > 0 || slot->outqueue->data_size == 0) { in aio_process_output()
589 if (slot->outqueue->func != NULL) { in aio_process_output()
591 (*slot->outqueue->func)(); in aio_process_output()
593 next = slot->outqueue->next; in aio_process_output()
596 free(slot->outqueue); in aio_process_output()
597 slot->outqueue = next; in aio_process_output()
601 free(slot->outqueue); in aio_process_output()
602 slot->outqueue = NULL; in aio_process_output()
[all …]
|
| /dports/net-mgmt/py-pdagent/pdagent-1.7.2/build-linux/deb/ |
| H A D | postinst | 58 chmod 2750 /var/lib/pdagent/outqueue/err /var/lib/pdagent/outqueue/suc
59 chmod 2753 /var/lib/pdagent/outqueue/tmp /var/lib/pdagent/outqueue/pdq
|
| /dports/net-mgmt/py-pdagent/pdagent-1.7.2/build-linux/rpm/ |
| H A D | postinst | 55 chmod 2750 /var/lib/pdagent/outqueue/err /var/lib/pdagent/outqueue/suc
56 chmod 2753 /var/lib/pdagent/outqueue/tmp /var/lib/pdagent/outqueue/pdq
|
| /dports/net/libnfs/libnfs-libnfs-4.0.0/lib/ |
| H A D | init.c | 98 rpc_reset_queue(&rpc->outqueue); in rpc_init_context()
124 rpc_reset_queue(&rpc->outqueue); in rpc_init_server_context()
269 struct rpc_queue outqueue; in rpc_purge_all_pdus() local
282 outqueue = rpc->outqueue; in rpc_purge_all_pdus()
284 rpc_reset_queue(&rpc->outqueue); in rpc_purge_all_pdus()
285 while ((pdu = outqueue.head) != NULL) { in rpc_purge_all_pdus()
286 outqueue.head = pdu->next; in rpc_purge_all_pdus()
304 assert(!rpc->outqueue.head); in rpc_purge_all_pdus()
|
| /dports/net/libiscsi/libiscsi-1.19.0/lib/ |
| H A D | socket.c | 90 struct iscsi_pdu *current = iscsi->outqueue; in iscsi_add_to_outqueue()
99 if (iscsi->outqueue == NULL) { in iscsi_add_to_outqueue()
100 iscsi->outqueue = pdu; in iscsi_add_to_outqueue()
122 iscsi->outqueue=pdu; in iscsi_add_to_outqueue()
457 (iscsi->outqueue != NULL && !iscsi->is_corked && in iscsi_tcp_which_events()
459 iscsi->outqueue->outdata.data[0] & ISCSI_PDU_IMMEDIATE) in iscsi_tcp_which_events()
479 for (pdu = iscsi->outqueue; pdu; pdu = pdu->next) { in iscsi_queue_length()
498 for (pdu = iscsi->outqueue; pdu; pdu = pdu->next) { in iscsi_out_queue_length()
759 iscsi->outqueue->cmdsn, iscsi->maxcmdsn); in iscsi_write_to_socket()
767 … iscsi->outqueue->cmdsn, iscsi->expcmdsn, iscsi->outqueue->outdata.data[0] & 0x3f); in iscsi_write_to_socket()
[all …]
|