Home
last modified time | relevance | path

Searched refs:arg (Results 1 – 25 of 64) sorted by relevance

123

/libevent-2.1.12/test/
H A Dregress_http.c449 state->base = arg; in http_chunked_cb()
807 http_delete_test(void *arg) in http_delete_test() argument
934 char **output = arg; in http_allowed_methods_eventcb()
1451 http_cancel_test(void *arg) in http_cancel_test() argument
1615 const char *what = arg; in http_request_done()
1656 EVUTIL_ASSERT(arg); in http_request_expect_error()
1859 EVUTIL_ASSERT(arg); in http_request_empty_done()
1966 http_post_test(void *arg) in http_post_test() argument
2105 http_put_test(void *arg) in http_put_test() argument
2229 http_failure_test(void *arg) in http_failure_test() argument
[all …]
H A Dregress_finalize.c44 int *int_arg = arg; in timer_callback()
52 int *int_arg = arg; in simple_callback()
59 int *int_arg = arg; in event_finalize_callback_1()
66 int *int_arg = arg; in callback_finalize_callback_1()
73 test_fin_cb_invoked(void *arg) in test_fin_cb_invoked() argument
75 struct basic_test_data *data = arg; in test_fin_cb_invoked()
189 test_fin_free_finalize(void *arg) in test_fin_free_finalize() argument
199 (void)arg; in test_fin_free_finalize()
255 test_fin_within_cb(void *arg) in test_fin_within_cb() argument
296 struct event_base *base = arg; in event_finalize_callback_free()
[all …]
H A Dregress_thread.c77 struct cond_wait *cw = arg; in wake_all_timeout()
87 struct cond_wait *cw = arg; in wake_one_timeout()
99 basic_thread(void *arg) in basic_thread() argument
102 struct event_base *base = arg; in basic_thread()
150 struct event_base *base = arg; in sigchld_cb()
167 thread_basic(void *arg) in thread_basic() argument
268 wait_for_condition(void *arg) in wait_for_condition() argument
420 load_deferred_queue(void *arg) in load_deferred_queue() argument
504 evutil_gettimeofday(arg, NULL); in note_time_cb()
505 if (arg == &times[4]) { in note_time_cb()
[all …]
H A Dregress_listener.c61 int *ptr = arg; in acceptcb()
71 regress_pick_a_port(void *arg) in regress_pick_a_port() argument
73 struct basic_test_data *data = arg; in regress_pick_a_port()
156 regress_listener_error(void *arg) in regress_listener_error() argument
158 struct basic_test_data *data = arg; in regress_listener_error()
193 int *ptr = arg; in acceptcb_free()
204 struct basic_test_data *data = arg; in regress_listener_close_accepted_fd()
235 regress_listener_immediate_close(void *arg) in regress_listener_immediate_close() argument
237 struct basic_test_data *data = arg; in regress_listener_immediate_close()
274 regress_listener_error_unlock(void *arg) in regress_listener_error_unlock() argument
[all …]
H A Dregress.c155 event_del(arg->ev); in basic_read_cb()
179 struct event *ev = arg; in multiple_write_cb()
212 struct event *ev = arg; in multiple_read_cb()
245 struct both *both = arg; in combined_read_cb()
263 struct both *both = arg; in combined_write_cb()
638 int *count = arg; in periodic_timeout_cb()
875 event_del(arg); in fork_signal_cb()
1910 int *intptr = arg; in incr_arg_cb()
2955 test_dup_fd(void *arg) in test_dup_fd() argument
3079 int *calledp = arg; in many_event_cb()
[all …]
H A Dregress_dns.c151 if (arg == NULL) in dns_gethostbyname_cb()
346 if (arg != (void*)6) { in dns_server_gethostbyname_cb()
485 void *arg) in generic_dns_callback() argument
622 static void dns_search_test(void *arg) { dns_search_test_impl(arg, 0); } in dns_search_test() argument
623 static void dns_search_lower_test(void *arg) { dns_search_test_impl(arg, 1); } in dns_search_lower_test() argument
800 dns_retry_test(void *arg) in dns_retry_test() argument
879 dns_reissue_test(void *arg) in dns_reissue_test() argument
1200 int *p = arg; in nil_accept_cb()
2221 race_base_run(void *arg) in race_base_run() argument
2273 (void)arg; in getaddrinfo_race_gotresolve_test()
[all …]
H A Dregress_bufferevent.c346 struct basic_test_data *data = arg; in test_bufferevent_pair_release_lock()
644 struct event_base *base = arg; in listen_cb()
726 test_bufferevent_connect(void *arg) in test_bufferevent_connect() argument
728 struct basic_test_data *data = arg; in test_bufferevent_connect()
806 evutil_socket_t *fdp = arg; in close_socket_cb()
816 struct basic_test_data *data = arg; in test_bufferevent_connect_fail_eventcb()
976 test_bufferevent_timeouts(void *arg) in test_bufferevent_timeouts() argument
980 struct basic_test_data *data = arg; in test_bufferevent_timeouts()
1142 test_bufferevent_trigger(void *arg) in test_bufferevent_trigger() argument
1144 struct basic_test_data *data = arg; in test_bufferevent_trigger()
[all …]
H A Dregress_thread.h35 #define THREAD_START(threadvar, fn, arg) do { \ argument
36 uintptr_t threadhandle = _beginthreadex(NULL,0,fn,(arg),0,NULL); \
47 #define THREAD_START(threadvar, fn, arg) do { \ argument
48 if (!pthread_create(&(threadvar), NULL, fn, arg)) \
H A Dregress_rpc.c107 MessageCb(EVRPC_STRUCT(Message)* rpc, void *arg) in MessageCb() argument
326 struct msg *msg, struct kill *kill, void *arg) in GotKillCb() argument
397 struct evbuffer *evbuf, void *arg) in rpc_hook_add_header() argument
399 const char *hook_type = arg; in rpc_hook_add_header()
412 struct evbuffer *evbuf, void *arg) in rpc_hook_add_meta() argument
423 struct evbuffer *evbuf, void *arg) in rpc_hook_remove_header() argument
430 assert(strcmp(header, arg) == 0); in rpc_hook_remove_header()
608 struct rpc_hook_ctx_ *ctx = arg; in rpc_hook_pause_cb()
611 free(arg); in rpc_hook_pause_cb()
616 void *arg) in rpc_hook_pause() argument
[all …]
H A Dtest-changelist.c138 write_cb(evutil_socket_t fd, short event, void *arg) in write_cb() argument
143 event_del(*(struct event**)arg); in write_cb()
146 event_add(*(struct event**)arg,NULL); in write_cb()
149 event_del(*(struct event**)arg); in write_cb()
154 timeout_cb(evutil_socket_t fd, short event, void *arg) in timeout_cb() argument
157 event_del(*(struct event**)arg); in timeout_cb()
H A Dbench_httpclient.c69 static void readcb(struct bufferevent *b, void *arg);
70 static void errorcb(struct bufferevent *b, short what, void *arg);
73 readcb(struct bufferevent *b, void *arg) in readcb() argument
75 struct request_info *ri = arg; in readcb()
84 errorcb(struct bufferevent *b, short what, void *arg) in errorcb() argument
86 struct request_info *ri = arg; in errorcb()
H A Dregress_ssl.c458 regress_bufferevent_openssl(void *arg) in regress_bufferevent_openssl() argument
460 struct basic_test_data *data = arg; in regress_bufferevent_openssl()
574 struct bufferevent *bev = arg; in acceptcb_deferred()
581 struct basic_test_data *data = arg; in acceptcb()
727 regress_bufferevent_openssl_connect(void *arg) in regress_bufferevent_openssl_connect() argument
729 struct basic_test_data *data = arg; in regress_bufferevent_openssl_connect()
814 struct wm_context *ctx = arg; in wm_transfer()
847 struct wm_context *ctx = arg; in wm_eventcb()
859 struct wm_context *ctx = arg; in wm_acceptcb()
882 regress_bufferevent_openssl_wm(void *arg) in regress_bufferevent_openssl_wm() argument
[all …]
H A Dregress_zlib.c243 readcb(struct bufferevent *bev, void *arg) in readcb() argument
263 writecb(struct bufferevent *bev, void *arg) in writecb() argument
271 errorcb(struct bufferevent *bev, short what, void *arg) in errorcb() argument
277 test_bufferevent_zlib(void *arg) in test_bufferevent_zlib() argument
284 (void)arg; in test_bufferevent_zlib()
H A Dregress_util.c706 test_evutil_strlcpy(void *arg) in test_evutil_strlcpy() argument
732 test_evutil_upcast(void *arg) in test_evutil_upcast() argument
929 test_evutil_rand(void *arg) in test_evutil_rand() argument
988 test_EVUTIL_IS_(void *arg) in test_EVUTIL_IS_() argument
1246 test_event_malloc(void *arg) in test_event_malloc() argument
1249 (void)arg; in test_event_malloc()
1272 test_event_calloc(void *arg) in test_event_calloc() argument
1275 (void)arg; in test_event_calloc()
1318 test_event_strdup(void *arg) in test_event_strdup() argument
1321 (void)arg; in test_event_strdup()
[all …]
H A Dtinytest.c99 timeout_thread_proc_(LPVOID arg) in timeout_thread_proc_() argument
101 struct timeout_thread_args *args = arg; in timeout_thread_proc_()
364 tinytest_set_flag_(struct testgroup_t *groups, const char *arg, int set, unsigned long flag) argument
370 if (strstr(arg, ".."))
371 length = strstr(arg,"..")-arg;
386 if (!strncmp(fullname, arg, length)) {
H A Dregress_et.c63 read_cb(evutil_socket_t fd, short event, void *arg) in read_cb() argument
75 event_del(arg); in read_cb()
183 read_notification_cb(evutil_socket_t fd, short event, void *arg) in read_notification_cb() argument
192 write_notification_cb(evutil_socket_t fd, short event, void *arg) in write_notification_cb() argument
H A Dbench_http.c51 static void http_basic_cb(struct evhttp_request *req, void *arg);
57 http_basic_cb(struct evhttp_request *req, void *arg) in http_basic_cb() argument
71 http_ref_cb(struct evhttp_request *req, void *arg) in http_ref_cb() argument
/libevent-2.1.12/include/event2/
H A Devent_compat.h186 #define evtimer_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument
187 #define evsignal_set(ev, x, cb, arg) \ argument
188 event_set((ev), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg))
199 #define timeout_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument
213 #define signal_set(ev, x, cb, arg) \ argument
214 event_set((ev), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg))
H A Devent.h964 #define evtimer_assign(ev, b, cb, arg) \ argument
965 event_assign((ev), (b), -1, 0, (cb), (arg))
966 #define evtimer_new(b, cb, arg) event_new((b), -1, 0, (cb), (arg)) argument
980 #define evsignal_assign(ev, b, x, cb, arg) \ argument
981 event_assign((ev), (b), (x), EV_SIGNAL|EV_PERSIST, cb, (arg))
982 #define evsignal_new(b, x, cb, arg) \ argument
983 event_new((b), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg))
996 #define evuser_new(b, cb, arg) event_new((b), -1, 0, (cb), (arg)) argument
1618 int event_base_foreach_event(struct event_base *base, event_base_foreach_event_cb fn, void *arg);
/libevent-2.1.12/
H A Devmap.c548 void *arg) argument
564 if ((r = fn(base, fd, ctx, arg)))
587 void *arg) argument
597 if ((r = fn(base, signum, ctx, arg)))
608 struct evmap_io *ctx, void *arg) argument
612 int *result = arg;
643 int *result = arg;
1015 void *arg; member
1028 if ((r = h->fn(base, ev, h->arg)))
1044 if ((r = h->fn(base, ev, h->arg)))
[all …]
H A Devrpc.c285 evrpc_request_cb(struct evhttp_request *req, void *arg) in evrpc_request_cb() argument
287 struct evrpc *rpc = arg; in evrpc_request_cb()
339 evrpc_request_cb_closure(void *arg, enum EVRPC_HOOK_RESULT hook_res) in evrpc_request_cb_closure() argument
341 struct evrpc_req_generic *rpc_state = arg; in evrpc_request_cb_closure()
476 struct evrpc_req_generic *rpc_state = arg; in evrpc_request_done_closure()
720 struct evrpc_request_wrapper *ctx = arg; in evrpc_schedule_request_closure()
860 evrpc_reply_done(struct evhttp_request *req, void *arg) in evrpc_reply_done() argument
862 struct evrpc_request_wrapper *ctx = arg; in evrpc_reply_done()
915 struct evrpc_request_wrapper *ctx = arg; in evrpc_reply_done_closure()
970 evrpc_request_timeout(evutil_socket_t fd, short what, void *arg) in evrpc_request_timeout() argument
[all …]
H A Devent.c1832 struct event_base *base = arg; in event_loopexit_cb()
2071 eonce->arg = arg; in event_base_once()
2118 arg = ev; in event_assign()
2127 ev->ev_arg = arg; in event_assign()
3103 cb->evcb_arg = arg; in event_deferred_cb_init_()
3587 struct event_base *base = arg; in evthread_notify_drain_eventfd()
3603 struct event_base *base = arg; in evthread_notify_drain_default()
3699 if ((r = fn(base, ev, arg))) in event_base_foreach_event_nolock_()
3714 if ((r = fn(base, ev, arg))) in event_base_foreach_event_nolock_()
3744 FILE *output = arg; in dump_inserted_event_fn()
[all …]
H A Dbufferevent_sock.c131 void *arg) in bufferevent_socket_outbuf_cb() argument
133 struct bufferevent *bufev = arg; in bufferevent_socket_outbuf_cb()
149 bufferevent_readcb(evutil_socket_t fd, short event, void *arg) in bufferevent_readcb() argument
151 struct bufferevent *bufev = arg; in bufferevent_readcb()
230 bufferevent_writecb(evutil_socket_t fd, short event, void *arg) in bufferevent_writecb() argument
232 struct bufferevent *bufev = arg; in bufferevent_writecb()
458 void *arg) in bufferevent_connect_getaddrinfo_cb() argument
460 struct bufferevent *bev = arg; in bufferevent_connect_getaddrinfo_cb()
/libevent-2.1.12/sample/
H A Devent-read-fifo.c34 fifo_read(evutil_socket_t fd, short event, void *arg) in fifo_read() argument
38 struct event *ev = arg; in fifo_read()
44 (int)fd, event, arg); in fifo_read()
77 signal_cb(evutil_socket_t fd, short event, void *arg) in signal_cb() argument
79 struct event_base *base = arg; in signal_cb()
H A Dhttp-server.c134 dump_request_cb(struct evhttp_request *req, void *arg) in dump_request_cb() argument
182 send_document_cb(struct evhttp_request *req, void *arg) in send_document_cb() argument
185 struct options *o = arg; in send_document_cb()
196 dump_request_cb(req, arg); in send_document_cb()
387 do_term(int sig, short events, void *arg) in do_term() argument
389 struct event_base *base = arg; in do_term()

123