/dports/www/httest/httest-2.4.24/src/ |
H A D | worker.h | 78 typedef struct worker_s worker_t; typedef 80 typedef apr_status_t(*interpret_f)(worker_t *worker, worker_t *parent, 92 worker_t *block; 202 worker_t *worker; 203 worker_t *cur_worker; 298 (worker_t *worker)) 300 (worker_t *worker)) 322 (worker_t *worker, worker_t *clone)) 416 void worker_clone(worker_t ** self, worker_t * orig); 425 void worker_test_reset(worker_t * worker); [all …]
|
H A D | body.h | 28 apr_status_t worker_body(worker_t **body, worker_t *worker); 29 void worker_body_end(worker_t *body, worker_t *worker); 30 apr_status_t command_IF(command_t * self, worker_t * worker, char *data, apr_pool_t *ptmp); 31 apr_status_t command_LOOP(command_t *self, worker_t *worker, char *data, apr_pool_t *ptmp); 32 apr_status_t command_FOR(command_t *self, worker_t *worker, char *data, apr_pool_t *ptmp); 33 apr_status_t command_BPS(command_t *self, worker_t *worker, char *data, apr_pool_t *ptmp); 34 apr_status_t command_RPS(command_t *self, worker_t *worker, char *data, apr_pool_t *ptmp); 35 apr_status_t command_SOCKET(command_t *self, worker_t *worker, char *data, apr_pool_t *ptmp); 36 apr_status_t command_ERROR(command_t *self, worker_t *worker, char *data, apr_pool_t *ptmp); 37 apr_status_t command_MILESTONE(command_t *self, worker_t *worker, char *data, apr_pool_t *ptmp);
|
H A D | sys_module.c | 82 static apr_status_t block_THREAD_GET_NUMBER(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_THREAD_GET_NUMBER() 103 static apr_status_t block_PROC_LOCK(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_PROC_LOCK() 128 static apr_status_t block_PROC_UNLOCK(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_PROC_UNLOCK() 153 static apr_status_t block_PROC_GET_PID(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_PROC_GET_PID() 171 static apr_status_t block_PROC_DETACH(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_PROC_DETACH() 185 static apr_status_t block_SYS_SLEEP(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_SYS_SLEEP()
|
H A D | ssl_module.c | 70 worker_t *msg_worker; 246 worker_t *worker = arg; in ssl_tlsext_trace() 327 worker_t *worker = arg; in ssl_message_trace() 1089 static apr_status_t block_SSL_CONNECT(worker_t * worker, worker_t *parent, apr_pool_t *ptmp) { in block_SSL_CONNECT() 1177 static apr_status_t block_SSL_ACCEPT(worker_t * worker, worker_t *parent, apr_pool_t *ptmp) { in block_SSL_ACCEPT() 1249 static apr_status_t block_SSL_CLOSE(worker_t * worker, worker_t *parent, apr_pool_t *ptmp) { in block_SSL_CLOSE() 1554 static apr_status_t block_SSL_CIPHER_SUITE(worker_t * worker, worker_t *parent, in block_SSL_CIPHER_SUITE() 1620 static apr_status_t block_SSL_LOAD_KEY(worker_t * worker, worker_t *parent, apr_pool_t *ptmp) { in block_SSL_LOAD_KEY() 1692 static apr_status_t block_SSL_SET_CA(worker_t * worker, worker_t *parent, apr_pool_t *ptmp) { in block_SSL_SET_CA() 1735 static apr_status_t block_SSL_TRACE(worker_t * worker, worker_t *parent, in block_SSL_TRACE() [all …]
|
H A D | body.c | 116 apr_status_t worker_body(worker_t **body, worker_t *worker) { in worker_body() 130 memcpy(*body, worker, sizeof(worker_t)); in worker_body() 170 void worker_body_end(worker_t *body, worker_t *worker) { in worker_body_end() 247 worker_t *body; in command_IF() 418 worker_t *body; in command_LOOP() 508 worker_t *body; in command_FOR() 562 worker_t *body; in command_BPS() 637 worker_t *body; in command_RPS() 713 worker_t *body; in command_ERROR() 779 worker_t *body; in command_SOCKET() [all …]
|
H A D | date_module.c | 51 static date_wconf_t *date_get_worker_config(worker_t *worker) { in date_get_worker_config() 70 apr_status_t block_DATE_GET_TIME(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_DATE_GET_TIME() 91 apr_status_t block_DATE_FORMAT(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_DATE_FORMAT() 153 apr_status_t block_DATE_SYNC(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_DATE_SYNC() 181 apr_status_t block_DATE_TIMER(worker_t *worker, worker_t *parent, in block_DATE_TIMER()
|
H A D | h2_module.c | 190 static apr_status_t h2_worker_body(worker_t **body, worker_t *worker, in h2_worker_body() 992 apr_status_t block_H2_UPGRADE(worker_t *worker, worker_t *parent, in block_H2_UPGRADE() 997 apr_status_t block_H2_SESSION(worker_t *worker, worker_t *parent, in block_H2_SESSION() 1223 apr_status_t block_H2_SLEEP(worker_t *worker, worker_t *parent, in block_H2_SLEEP() 1232 apr_status_t block_H2_FLUSH(worker_t *worker, worker_t *parent, in block_H2_FLUSH() 1239 apr_status_t block_H2_DEFER(worker_t *worker, worker_t *parent, in block_H2_DEFER() 1252 apr_status_t block_H2_REQ(worker_t *worker, worker_t *parent, in block_H2_REQ() 1263 worker_t *body; in block_H2_REQ() 1392 apr_status_t block_H2_EXPECT(worker_t *worker, worker_t *parent, in block_H2_EXPECT() 1480 apr_status_t block_H2_WAIT(worker_t *worker, worker_t *parent, in block_H2_WAIT() [all …]
|
H A D | coder_module.c | 61 apr_status_t block_CODER_URLENC(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_CODER_URLENC() 118 apr_status_t block_CODER_URLDEC(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_CODER_URLDEC() 177 apr_status_t block_CODER_HTMLDEC(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_CODER_HTMLDEC() 227 apr_status_t block_CODER_B64ENC(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_CODER_B64ENC() 263 apr_status_t block_CODER_REGEXENC(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_CODER_REGEXENC() 331 apr_status_t block_CODER_B64DEC(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_CODER_B64DEC()
|
H A D | worker.c | 89 worker_t *worker; 607 apr_status_t worker_sockstate(worker_t * worker) { in worker_sockstate() 971 void worker_test_reset(worker_t * worker) { in worker_test_reset() 1087 void worker_conn_close_all(worker_t *self) { in worker_conn_close_all() 1152 static void worker_set_cookie(worker_t *worker) { in worker_set_cookie() 1236 worker_t *block, *call; in command_CALL() 3871 (*self) = apr_pcalloc(p, sizeof(worker_t)); in worker_new() 3935 void worker_clone(worker_t ** self, worker_t * orig) { in worker_clone() 3963 void worker_destroy(worker_t * worker) { in worker_destroy() 4443 apr_status_t worker_to_file(worker_t * worker) { in worker_to_file() [all …]
|
H A D | tcp_module.c | 132 static apr_status_t tcp_hook_connect(worker_t *worker) { in tcp_hook_connect() 155 static apr_status_t tcp_hook_accept(worker_t *worker, char *data) { in tcp_hook_accept() 182 apr_status_t tcp_listen(worker_t *worker, int backlog) { in tcp_listen() 230 apr_status_t tcp_connect(worker_t *worker, char *hostname, char *portname) { in tcp_connect() 303 apr_status_t tcp_accept(worker_t *worker) { in tcp_accept() 336 apr_status_t tcp_close(worker_t *worker) { in tcp_close() 363 static apr_status_t block_TCP_LISTEN(worker_t * worker, worker_t *parent, apr_pool_t *ptmp) { in block_TCP_LISTEN() 395 static apr_status_t block_TCP_CONNECT(worker_t * worker, worker_t *parent, apr_pool_t *ptmp) { in block_TCP_CONNECT() 436 static apr_status_t block_TCP_ACCEPT(worker_t * worker, worker_t *parent, apr_pool_t *ptmp) { in block_TCP_ACCEPT() 472 static apr_status_t block_TCP_CLOSE(worker_t * worker, worker_t *parent, apr_pool_t *ptmp) { in block_TCP_CLOSE()
|
H A D | udp_module.c | 52 static udp_socket_config_t *udp_get_socket_config(worker_t *worker) { in udp_get_socket_config() 75 worker_t *worker = data; in udp_transport_os_desc_get() 90 worker_t *worker = data; in udp_transport_set_timeout() 105 worker_t *worker = data; in udp_transport_get_timeout() 122 worker_t *worker = data; in udp_transport_read() 150 worker_t *worker = data; in udp_transport_write() 186 static apr_status_t block_UDP_CONNECT(worker_t *worker, worker_t *parent, in block_UDP_CONNECT() 259 static apr_status_t block_UDP_BIND(worker_t *worker, worker_t *parent, in block_UDP_BIND()
|
H A D | tcp_module.h | 28 apr_status_t tcp_listen(worker_t *worker, int backlog); 29 apr_status_t tcp_connect(worker_t *worker, char *hostname, char *portname); 30 apr_status_t tcp_accept(worker_t *worker); 31 apr_status_t tcp_close(worker_t *worker);
|
H A D | math_module.c | 60 static apr_status_t block_MATH_EVAL(worker_t *worker, worker_t *parent, in block_MATH_EVAL() 95 static apr_status_t block_MATH_OP(worker_t *worker, worker_t *parent, in block_MATH_OP() 164 static apr_status_t block_MATH_RAND(worker_t *worker, worker_t *parent, in block_MATH_RAND()
|
H A D | xml_module.c | 56 static xml_wconf_t *xml_get_worker_config(worker_t *worker) { in xml_get_worker_config() 73 static char *xml_node2str(worker_t *worker, xmlXPathObjectPtr obj, in xml_node2str() 126 static apr_status_t block_XML_PARSE(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_XML_PARSE() 156 static apr_status_t block_XML_XPATH(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_XML_XPATH()
|
H A D | annotation_module.c | 46 static apr_status_t block_ANNOTATION_SKIP(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_ANNOTATION_SKIP() 65 static apr_status_t block_ANNOTATION_ONLY(worker_t *worker, worker_t *parent, apr_pool_t *ptmp) { in block_ANNOTATION_ONLY()
|
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/include/uhdlib/experts/ |
H A D | expert_factory.hpp | 212 template <typename worker_t> 215 container->add_worker(new worker_t()); in add_worker_node() 233 template <typename worker_t, typename arg1_t> 237 container->add_worker(new worker_t(arg1)); in add_worker_node() 244 container->add_worker(new worker_t(arg1, arg2)); in add_worker_node() 253 container->add_worker(new worker_t(arg1, arg2, arg3)); in add_worker_node() 256 template <typename worker_t, 270 template <typename worker_t, 286 template <typename worker_t, 304 template <typename worker_t, [all …]
|
/dports/net/aprsc/aprsc-2.1.10.gd72a17c/src/ |
H A D | worker.h | 163 struct worker_t; /* used in client_t, but introduced later */ 363 int (*write) (struct worker_t *self, struct client_t *c, char *p, int len); 365 int (*handler_client_readable) (struct worker_t *self, struct client_t *c); 421 extern int pass_client_to_worker(struct worker_t *wc, struct client_t *c); 427 struct worker_t { struct 428 struct worker_t *next; argument 429 struct worker_t **prevp; argument 488 extern void pbuf_free(struct worker_t *self, struct pbuf_t *p); argument 501 extern struct worker_t *worker_threads; 502 extern struct worker_t *worker_alloc(void); [all …]
|
/dports/net/arataga/so5extra-v.1.4.1/dev/sample/so_5_extra/mboxes/broadcast/simple/ |
H A D | main.cpp | 14 class worker_t final : public so_5::agent_t class 20 worker_t( context_t ctx, std::string name ) in worker_t() function in worker_t 29 .event( &worker_t::on_start ) in so_define_agent() 30 .event( &worker_t::on_stop ); in so_define_agent() 68 so_5::send< worker_t::start >( m_worker ); in so_evt_start() 77 so_5::send< worker_t::stop >( m_worker ); in on_stop() 90 coop.make_agent< worker_t >( "First" )->so_direct_mbox(), in main() 91 coop.make_agent< worker_t >( "Second" )->so_direct_mbox(), in main() 92 coop.make_agent< worker_t >( "Third" )->so_direct_mbox() in main()
|
/dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/testing/v1/inline_ns/ |
H A D | main.cpp | 10 class worker_t final : public so_5::agent_t class 19 worker_t( context_t ctx, const so_5::mbox_t & control_mbox ) in worker_t() function in worker_t 47 so_5::send< worker_t::acquire >( m_control_mbox ); in __anonbbeb3d260302() 52 so_5::send< worker_t::release >( m_control_mbox ); in __anonbbeb3d260402() 85 coop.make_agent< worker_t >( control_mbox ), in UT_UNIT_TEST() 86 coop.make_agent< worker_t >( control_mbox ) ); in UT_UNIT_TEST() 94 & tests::reacts_to< worker_t::acquire >( control_mbox ) in UT_UNIT_TEST() 97 & tests::reacts_to< worker_t::acquire >( control_mbox ) in UT_UNIT_TEST() 106 & tests::reacts_to< worker_t::release >( control_mbox ) in UT_UNIT_TEST() 109 & tests::reacts_to< worker_t::release >( control_mbox ) in UT_UNIT_TEST()
|
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | ppqueue.go | 25 type worker_t struct { struct 32 func s_worker_new(identity string) worker_t { 33 return worker_t{ 42 func s_worker_ready(self worker_t, workers []worker_t) []worker_t { argument 61 func s_workers_purge(workers []worker_t) []worker_t { argument 83 workers := make([]worker_t, 0)
|
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | ppqueue.go | 25 type worker_t struct { struct 32 func s_worker_new(identity string) worker_t { 33 return worker_t{ 42 func s_worker_ready(self worker_t, workers []worker_t) []worker_t { argument 61 func s_workers_purge(workers []worker_t) []worker_t { argument 83 workers := make([]worker_t, 0)
|
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | ppqueue.go | 25 type worker_t struct { struct 32 func s_worker_new(identity string) worker_t { 33 return worker_t{ 42 func s_worker_ready(self worker_t, workers []worker_t) []worker_t { argument 61 func s_workers_purge(workers []worker_t) []worker_t { argument 83 workers := make([]worker_t, 0)
|
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | ppqueue.go | 25 type worker_t struct { 32 func s_worker_new(identity string) worker_t { 33 return worker_t{ 42 func s_worker_ready(self worker_t, workers []worker_t) []worker_t { 61 func s_workers_purge(workers []worker_t) []worker_t { 83 workers := make([]worker_t, 0)
|
/dports/audio/icecast-kh/icecast-kh-icecast-2.4.0-kh15/src/ |
H A D | client.h | 22 typedef struct _worker_t worker_t; typedef 51 extern worker_t *workers; 114 worker_t *worker; 148 int client_change_worker (client_t *client, worker_t *dest_worker); 151 worker_t *worker_selected (void); 154 void worker_wakeup (worker_t *worker); 157 int is_worker_incoming (worker_t *w);
|
H A D | client.c | 305 worker_t *worker = client->worker; in client_send_404() 461 int is_worker_incoming (worker_t *w) in is_worker_incoming() 477 worker_t *min = workers; in find_least_busy_handler() 482 worker_t *handler = workers; in find_least_busy_handler() 504 worker_t *worker_selected (void) in worker_selected() 538 worker_t *handler; in client_add_worker() 553 worker_t *handler; in client_add_incoming() 710 worker_t *worker = arg; in worker() 831 worker_t *handler = calloc (1, sizeof(worker_t)); in worker_start() 862 worker_t *handler; in worker_stop() [all …]
|