Home
last modified time | relevance | path

Searched refs:worker_t (Results 1 – 25 of 191) sorted by relevance

12345678

/dports/www/httest/httest-2.4.24/src/
H A Dworker.h78 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 Dbody.h28 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 Dsys_module.c82 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 Dssl_module.c70 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 Dbody.c116 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 Ddate_module.c51 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 Dh2_module.c190 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 Dcoder_module.c61 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 Dworker.c89 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 Dtcp_module.c132 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 Dudp_module.c52 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 Dtcp_module.h28 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 Dmath_module.c60 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 Dxml_module.c56 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 Dannotation_module.c46 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 Dexpert_factory.hpp212 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 Dworker.h163 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 Dmain.cpp14 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 Dmain.cpp10 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 Dppqueue.go25 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 Dppqueue.go25 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 Dppqueue.go25 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 Dppqueue.go25 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 Dclient.h22 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 Dclient.c305 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 …]

12345678