| /dports/net/pjsip/pjproject-2.11.1/pjlib/src/pj/ |
| H A D | ioqueue_select.c | 174 ioqueue->nfds = max; in rescan_fdset()
193 pj_ioqueue_t *ioqueue; in pj_ioqueue_create() local
209 ioqueue_init(ioqueue); in pj_ioqueue_create()
212 ioqueue->count = 0; in pj_ioqueue_create()
220 rescan_fdset(ioqueue); in pj_ioqueue_create()
273 *p_ioqueue = ioqueue; in pj_ioqueue_create()
356 if (ioqueue->count >= ioqueue->max) {
403 ++ioqueue->count;
406 rescan_fdset(ioqueue);
479 ioqueue = key->ioqueue;
[all …]
|
| H A D | ioqueue_epoll.c | 163 pj_ioqueue_t *ioqueue; in pj_ioqueue_create() local
178 ioqueue_init(ioqueue); in pj_ioqueue_create()
180 ioqueue->max = max_fd; in pj_ioqueue_create()
181 ioqueue->count = 0; in pj_ioqueue_create()
234 ioqueue_destroy(ioqueue); in pj_ioqueue_create()
246 *p_ioqueue = ioqueue; in pj_ioqueue_create()
264 ioqueue->epfd = 0; in pj_ioqueue_destroy()
315 if (ioqueue->count >= ioqueue->max) { in pj_ioqueue_register_sock2()
385 ++ioqueue->count; in pj_ioqueue_register_sock2()
459 ioqueue = key->ioqueue; in pj_ioqueue_unregister()
[all …]
|
| H A D | ioqueue_winnt.c | 239 ioqueue->event_pool[ioqueue->event_count++] = hEvent; in erase_connecting_socket()
330 pj_ioqueue_t *ioqueue; in pj_ioqueue_create() local
344 ioqueue = pj_pool_zalloc(pool, sizeof(*ioqueue)); in pj_ioqueue_create()
404 *p_ioqueue = ioqueue; in pj_ioqueue_create()
488 ioqueue->lock = lock; in pj_ioqueue_set_lock()
541 rec->ioqueue = ioqueue; in pj_ioqueue_register_sock()
778 ioqueue = key->ioqueue; in pj_ioqueue_unregister()
1327 ioqueue = key->ioqueue; in pj_ioqueue_connect()
1339 hEvent = ioqueue->event_pool[ioqueue->event_count - 1]; in pj_ioqueue_connect()
1363 ioqueue->connecting_keys[ ioqueue->connecting_count ] = key; in pj_ioqueue_connect()
[all …]
|
| H A D | ioqueue_uwp.cpp | 59 PJ_UNUSED_ARG(ioqueue); in ioqueue_remove_from_set()
99 PJ_UNUSED_ARG(ioqueue); in ioqueue_add_to_set()
126 pj_ioqueue_t *ioq = key->ioqueue; in on_read()
220 pj_ioqueue_t *ioqueue, in pj_ioqueue_register_sock() argument
231 pj_ioqueue_t *ioqueue, in pj_ioqueue_register_sock2() argument
243 pj_lock_acquire(ioqueue->lock); in pj_ioqueue_register_sock2()
270 pj_lock_release(ioqueue->lock); in pj_ioqueue_register_sock2()
281 pj_ioqueue_t *ioqueue; in pj_ioqueue_unregister() local
285 ioqueue = key->ioqueue; in pj_ioqueue_unregister()
294 pj_lock_acquire(ioqueue->lock); in pj_ioqueue_unregister()
[all …]
|
| H A D | ioqueue_common_abs.c | 35 ioqueue->lock = NULL; in ioqueue_init()
36 ioqueue->auto_delete_lock = 0; in ioqueue_init()
42 if (ioqueue->auto_delete_lock && ioqueue->lock ) { in ioqueue_destroy()
43 pj_lock_release(ioqueue->lock); in ioqueue_destroy()
44 return pj_lock_destroy(ioqueue->lock); in ioqueue_destroy()
59 if (ioqueue->auto_delete_lock && ioqueue->lock) { in pj_ioqueue_set_lock()
60 pj_lock_destroy(ioqueue->lock); in pj_ioqueue_set_lock()
63 ioqueue->lock = lock; in pj_ioqueue_set_lock()
64 ioqueue->auto_delete_lock = auto_delete; in pj_ioqueue_set_lock()
82 key->ioqueue = ioqueue; in ioqueue_init_key()
[all …]
|
| H A D | ioqueue_common_abs.h | 103 pj_ioqueue_t *ioqueue; \
134 static void ioqueue_add_to_set( pj_ioqueue_t *ioqueue,
137 static void ioqueue_remove_from_set( pj_ioqueue_t *ioqueue,
|
| /dports/games/wolfpack/empire-4.4.1/include/ |
| H A D | ioqueue.h | 38 struct ioqueue;
40 extern struct ioqueue *ioq_create(int size);
41 extern void ioq_destroy(struct ioqueue *ioq);
42 extern void ioq_drain(struct ioqueue *ioq);
43 extern int ioq_makeiov(struct ioqueue *ioq, struct iovec *iov, int cc);
44 extern int ioq_peek(struct ioqueue *ioq, char *buf, int cc);
45 extern void ioq_dequeue(struct ioqueue *ioq, int cc);
46 extern void ioq_append(struct ioqueue *ioq, char *buf, int cc);
47 extern int ioq_qsize(struct ioqueue *ioq);
48 extern int ioq_gets(struct ioqueue *ioq, char *buf, int cc);
[all …]
|
| /dports/games/wolfpack/empire-4.4.1/src/lib/gen/ |
| H A D | ioqueue.c | 56 struct ioqueue { struct
66 static int removecc(struct ioqueue *ioq, int cc);
68 struct ioqueue *
71 struct ioqueue *ioq; in ioq_create()
73 ioq = malloc(sizeof(struct ioqueue)); in ioq_create()
85 ioq_destroy(struct ioqueue *ioq) in ioq_destroy()
92 ioq_drain(struct ioqueue *ioq) in ioq_drain()
132 ioq_dequeue(struct ioqueue *ioq, int cc) in ioq_dequeue()
145 ioq_qsize(struct ioqueue *ioq) in ioq_qsize()
177 ioq_puts(struct ioqueue *ioq, char *buf) in ioq_puts()
[all …]
|
| /dports/security/erlang-fast_tls/fast_tls-1.1.13/c_src/ |
| H A D | ioqueue.h | 23 typedef struct ioqueue { struct
27 } ioqueue; argument
29 ioqueue *ioqueue_create();
30 void ioqueue_free(ioqueue *queue);
31 void ioqueue_consume(ioqueue *queue, size_t bytes);
32 int ioqueue_append(ioqueue *queue, const char *buf, size_t bytes);
|
| H A D | ioqueue.c | 22 ioqueue *ioqueue_create() { in ioqueue_create()
23 ioqueue *q = malloc(sizeof(ioqueue)); in ioqueue_create()
32 void ioqueue_free(ioqueue *queue) { in ioqueue_free()
39 void ioqueue_consume(ioqueue *queue, size_t bytes) { in ioqueue_consume()
50 int ioqueue_append(ioqueue *queue, const char *buf, size_t bytes) { in ioqueue_append()
|
| /dports/net/pjsip/pjproject-2.11.1/pjlib/src/pjlib-test/ |
| H A D | ioq_unreg.c | 125 pj_ioqueue_t *ioqueue = (pj_ioqueue_t*) arg; in worker_thread() local
129 pj_ioqueue_poll(ioqueue, &timeout); in worker_thread()
142 static int perform_unreg_test(pj_ioqueue_t *ioqueue, in perform_unreg_test() argument
194 ioqueue, 0, 0, &thread[i]); in perform_unreg_test()
263 n = pj_ioqueue_poll(ioqueue, &timeout); in perform_unreg_test()
298 pj_ioqueue_t *ioqueue; in udp_ioqueue_unreg_test_imp() local
307 rc = pj_ioqueue_create(test_pool, 16, &ioqueue); in udp_ioqueue_unreg_test_imp()
323 rc = perform_unreg_test(ioqueue, test_pool, title, 0); in udp_ioqueue_unreg_test_imp()
333 rc = perform_unreg_test(ioqueue, test_pool, title, 1); in udp_ioqueue_unreg_test_imp()
344 rc = perform_unreg_test(ioqueue, test_pool, title, 0); in udp_ioqueue_unreg_test_imp()
[all …]
|
| H A D | activesock.c | 97 pj_ioqueue_t *ioqueue, in udp_echo_srv_create() argument
150 pj_ioqueue_t *ioqueue = NULL; in udp_ping_pong_test() local
217 pj_ioqueue_poll(ioqueue, &delay); in udp_ping_pong_test()
244 if (ioqueue) in udp_ping_pong_test()
245 pj_ioqueue_destroy(ioqueue); in udp_ping_pong_test()
341 pj_ioqueue_t *ioqueue = NULL; in tcp_perf_test() local
412 pj_ioqueue_poll(ioqueue, NULL); in tcp_perf_test()
442 if (pj_ioqueue_poll(ioqueue, &timeout) < 1) in tcp_perf_test()
456 while (pj_ioqueue_poll(ioqueue, &delay) > 0) in tcp_perf_test()
487 if (ioqueue) in tcp_perf_test()
[all …]
|
| H A D | ssl_sock.c | 463 param.ioqueue = ioqueue; in https_client_test()
510 if (ioqueue) in https_client_test()
576 param.ioqueue = ioqueue; in echo_test()
777 if (ioqueue) in echo_test()
969 param.ioqueue = ioqueue; in client_non_ssl()
1065 if (ioqueue) in client_non_ssl()
1109 state_serv.ioqueue = ioqueue; in server_non_ssl()
1157 param.ioqueue = ioqueue; in server_non_ssl()
1217 if (ioqueue) in server_non_ssl()
1301 param.ioqueue = ioqueue; in perf_test()
[all …]
|
| H A D | ioq_perf.c | 56 pj_ioqueue_t *ioqueue; member
185 pj_ioqueue_t *ioqueue; member
199 rc = pj_ioqueue_poll(arg->ioqueue, &timeout); in worker_thread()
235 pj_ioqueue_t *ioqueue; in perform_test() local
259 rc = pj_ioqueue_create(pool, sockpair_cnt*2, &ioqueue); in perform_test()
265 rc = pj_ioqueue_set_default_concurrency(ioqueue, allow_concur); in perform_test()
275 items[i].ioqueue = ioqueue; in perform_test()
299 rc = pj_ioqueue_register_sock(pool, ioqueue, in perform_test()
310 rc = pj_ioqueue_register_sock(pool, ioqueue, in perform_test()
349 arg->ioqueue = ioqueue; in perform_test()
[all …]
|
| H A D | udp_echo_srv_ioqueue.c | 122 pj_ioqueue_t *ioqueue = (pj_ioqueue_t*) arg; in worker_thread() local
152 rc = pj_ioqueue_poll(ioqueue, &timeout); in worker_thread()
161 pj_ioqueue_t *ioqueue; in udp_echo_srv_ioqueue() local
175 rc = pj_ioqueue_create(pool, 2, &ioqueue); in udp_echo_srv_ioqueue()
188 rc = pj_ioqueue_register_sock(pool, ioqueue, sock, NULL, in udp_echo_srv_ioqueue()
202 rc = pj_thread_create(pool, NULL, &worker_thread, ioqueue, in udp_echo_srv_ioqueue()
|
| H A D | ioq_udp.c | 371 pj_ioqueue_t *ioqueue; in unregister_test() local
391 status = pj_ioqueue_create(pool, 16, &ioqueue); in unregister_test()
471 pj_ioqueue_poll(ioqueue, &timeout); in unregister_test()
510 pj_ioqueue_poll(ioqueue, &timeout); in unregister_test()
522 pj_ioqueue_destroy(ioqueue); in unregister_test()
539 pj_ioqueue_t *ioqueue; in many_handles_test() local
556 rc = pj_ioqueue_create(pool, MAX, &ioqueue); in many_handles_test()
557 if (rc != PJ_SUCCESS || ioqueue == NULL) { in many_handles_test()
563 rc = pj_ioqueue_set_default_concurrency(ioqueue, allow_concur); in many_handles_test()
578 rc = pj_ioqueue_register_sock(pool, ioqueue, sock[count], in many_handles_test()
[all …]
|
| /dports/net/pjsip/pjproject-2.11.1/pjnath/include/pjnath/ |
| H A D | stun_config.h | 58 pj_ioqueue_t *ioqueue; member
101 pj_ioqueue_t *ioqueue, in pj_stun_config_init() argument
108 cfg->ioqueue = ioqueue; in pj_stun_config_init()
121 PJ_ASSERT_RETURN(cfg->ioqueue && cfg->pf && cfg->timer_heap && in pj_stun_config_check_valid()
|
| /dports/net/pjsip/pjproject-2.11.1/pjnath/src/pjnath-test/ |
| H A D | test.c | 52 pj_ioqueue_t *ioqueue; in create_stun_config() local
57 status = pj_ioqueue_create(pool, 64, &ioqueue); in create_stun_config()
66 pj_ioqueue_destroy(ioqueue); in create_stun_config()
73 pj_stun_config_init(stun_cfg, mem, 0, ioqueue, timer_heap); in create_stun_config()
84 if (stun_cfg->ioqueue) { in destroy_stun_config()
85 pj_ioqueue_destroy(stun_cfg->ioqueue); in destroy_stun_config()
86 stun_cfg->ioqueue = NULL; in destroy_stun_config()
110 c = pj_ioqueue_poll( stun_cfg->ioqueue, &timeout); in poll_events()
|
| H A D | stun_sock_test.c | 139 pj_ioqueue_t *ioqueue, in create_server() argument
159 status = pj_activesock_create_udp(pool, &srv->addr, NULL, ioqueue, in create_server()
296 pj_ioqueue_poll(cfg->ioqueue, &delay); in handle_events()
319 status = create_server(client->pool, cfg->ioqueue, 0, use_ipv6, &srv); in timeout_test()
403 status = create_server(client->pool, cfg->ioqueue, RESPOND_STUN, use_ipv6, in missing_attr_test()
478 status = create_server(client->pool, cfg->ioqueue, RESPOND_STUN|WITH_XOR_MAPPED, in keep_alive_test()
847 pj_ioqueue_t *ioqueue = NULL; in stun_sock_test() local
855 status = pj_ioqueue_create(pool, 12, &ioqueue); in stun_sock_test()
869 pj_stun_config_init(&stun_cfg, mem, 0, ioqueue, timer_heap); in stun_sock_test()
881 if (ioqueue) pj_ioqueue_destroy(ioqueue); in stun_sock_test()
|
| /dports/net/pjsip/pjproject-2.11.1/pjlib-util/src/pjlib-util-test/ |
| H A D | http_client.c | 54 static pj_ioqueue_t *ioqueue; variable
456 pj_ioqueue_poll(ioqueue, &delay); in http_client_test1()
465 pj_ioqueue_poll(ioqueue, &delay); in http_client_test1()
476 pj_ioqueue_destroy(ioqueue); in http_client_test1()
586 pj_ioqueue_poll(ioqueue, &delay); in http_client_test2()
601 pj_ioqueue_poll(ioqueue, &delay); in http_client_test2()
612 pj_ioqueue_destroy(ioqueue); in http_client_test2()
704 pj_ioqueue_poll(ioqueue, &delay); in http_client_test_put1()
715 pj_ioqueue_destroy(ioqueue); in http_client_test_put1()
816 pj_ioqueue_destroy(ioqueue); in http_client_test_put2()
[all …]
|
| /dports/net/pjsip/pjproject-2.11.1/pjsip-apps/src/samples/ |
| H A D | httpdemo.c | 37 static pj_ioqueue_t *ioqueue; variable
122 if (pj_ioqueue_create(pool, 16, &ioqueue)) in getURL()
127 if ((status = pj_http_req_create(pool, &url, timer_heap, ioqueue, in getURL()
136 pj_ioqueue_poll(ioqueue, &delay); in getURL()
141 pj_ioqueue_destroy(ioqueue); in getURL()
|
| /dports/devel/pcl/libpcl-1.6/test/ |
| H A D | cothread.c | 69 struct ioqueue { struct
79 struct ioqueue *active; // requests processed by the last poll argument
80 struct ioqueue *wait; // requests for the next poll
81 struct ioqueue queues[2]; // data area of the queues.
147 static int check(struct ioqueue *q, struct ioreq *r, struct timeval *ctime) { in check()
163 static void enqueue(struct ioqueue *q, struct ioreq *r) { in enqueue()
203 struct ioqueue *q; in cothread_schedule()
|
| /dports/devel/libpcl/pcl-1.12/test/ |
| H A D | cothread.c | 70 struct ioqueue { struct
80 struct ioqueue *active; // requests processed by the last poll argument
81 struct ioqueue *wait; // requests for the next poll
82 struct ioqueue queues[2]; // data area of the queues.
143 static int check(struct ioqueue *q, struct ioreq *r, struct timeval *ctime) in check()
159 static void enqueue(struct ioqueue *q, struct ioreq *r) in enqueue()
200 struct ioqueue *q; in cothread_schedule()
|
| /dports/net/pjsip/pjproject-2.11.1/pjmedia/include/pjmedia/ |
| H A D | endpoint.h | 86 pj_ioqueue_t *ioqueue,
106 pj_ioqueue_t *ioqueue, in pjmedia_endpt_create() argument
122 status = pjmedia_endpt_create2(pf, ioqueue, worker_cnt, p_endpt); in pjmedia_endpt_create()
|
| /dports/sysutils/plasma5-ksysguard/ksysguard-5.22.0/ksysguardd/Linux/ |
| H A D | diskstats.c | 73 unsigned int ioqueue; /* - Field 9 - # of I/Os currently in progress */ member
154 ioqueue, iotim, iotimw; in process26DiskIO() local
200 &ioqueue, &iotim, &iotimw)) in process26DiskIO()
248 ptr->ioqueue = ioqueue; in process26DiskIO()
279 ptr->ioqueue = ioqueue; in process26DiskIO()
488 output( "%u\n", ptr->ioqueue ); in print26DiskIO()
|