Home
last modified time | relevance | path

Searched refs:what (Results 1 – 25 of 42) sorted by relevance

12

/libevent-2.1.12/
H A Dbufferevent_async.c357 if (what & EV_READ) in be_async_enable()
359 if (what & EV_WRITE) in be_async_enable()
365 if (what & EV_READ) in be_async_enable()
367 if (what & EV_WRITE) in be_async_enable()
380 if (what & EV_READ) { in be_async_disable()
384 if (what & EV_WRITE) { in be_async_disable()
466 short what = BEV_EVENT_READING; in read_complete() local
486 what |= BEV_EVENT_ERROR; in read_complete()
490 what |= BEV_EVENT_EOF; in read_complete()
529 what |= BEV_EVENT_ERROR; in write_complete()
[all …]
H A Ddevpoll.c204 int what = events[i].revents; in devpoll_dispatch() local
206 if (what & POLLHUP) in devpoll_dispatch()
207 what |= POLLIN | POLLOUT; in devpoll_dispatch()
208 else if (what & POLLERR) in devpoll_dispatch()
209 what |= POLLIN | POLLOUT; in devpoll_dispatch()
211 if (what & POLLIN) in devpoll_dispatch()
213 if (what & POLLOUT) in devpoll_dispatch()
H A Dpoll.c202 int what; in poll_dispatch() local
205 what = event_set[i].revents; in poll_dispatch()
206 if (!what) in poll_dispatch()
212 if (what & (POLLHUP|POLLERR|POLLNVAL)) in poll_dispatch()
213 what |= POLLIN|POLLOUT; in poll_dispatch()
214 if (what & POLLIN) in poll_dispatch()
216 if (what & POLLOUT) in poll_dispatch()
218 if (what & POLLRDHUP) in poll_dispatch()
H A Dbufferevent.c73 bufev_private->read_suspended |= what; in bufferevent_suspend_read_()
82 bufev_private->read_suspended &= ~what; in bufferevent_unsuspend_read_()
95 bufev_private->write_suspended |= what; in bufferevent_suspend_write_()
104 bufev_private->write_suspended &= ~what; in bufferevent_unsuspend_write_()
175 short what = bufev_private->eventcb_pending; in bufferevent_run_deferred_callbacks_locked() local
180 bufev->errorcb(bufev, what, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
220 short what = bufev_private->eventcb_pending; in bufferevent_run_deferred_callbacks_unlocked() local
225 UNLOCKED(errorcb(bufev,what,cbarg)); in bufferevent_run_deferred_callbacks_unlocked()
292 p->eventcb_pending |= what; in bufferevent_run_eventcb_()
296 bufev->errorcb(bufev, what, bufev->cbarg); in bufferevent_run_eventcb_()
[all …]
H A Dbufferevent_sock.c155 short what = BEV_EVENT_READING; in bufferevent_readcb() local
164 what |= BEV_EVENT_TIMEOUT; in bufferevent_readcb()
202 what |= BEV_EVENT_ERROR; in bufferevent_readcb()
205 what |= BEV_EVENT_EOF; in bufferevent_readcb()
223 bufferevent_run_eventcb_(bufev, what, 0); in bufferevent_readcb()
235 short what = BEV_EVENT_WRITING; in bufferevent_writecb() local
245 what |= BEV_EVENT_TIMEOUT; in bufferevent_writecb()
301 what |= BEV_EVENT_ERROR; in bufferevent_writecb()
307 what |= BEV_EVENT_EOF; in bufferevent_writecb()
337 bufferevent_run_eventcb_(bufev, what, 0); in bufferevent_writecb()
H A Dbufferevent-internal.h330 void bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what);
334 void bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what);
338 void bufferevent_suspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what);
341 void bufferevent_unsuspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what);
396 void bufferevent_run_eventcb_(struct bufferevent *bufev, short what, int options);
H A Depoll.c482 int what = events[i].events; in epoll_dispatch() local
489 if (what & EPOLLERR) { in epoll_dispatch()
491 } else if ((what & EPOLLHUP) && !(what & EPOLLRDHUP)) { in epoll_dispatch()
494 if (what & EPOLLIN) in epoll_dispatch()
496 if (what & EPOLLOUT) in epoll_dispatch()
498 if (what & EPOLLRDHUP) in epoll_dispatch()
H A Dbufferevent_openssl.c923 if (what & BEV_EVENT_EOF) { in be_openssl_eventcb()
928 } else if (what & BEV_EVENT_TIMEOUT) { in be_openssl_eventcb()
930 event = what; in be_openssl_eventcb()
931 } else if (what & BEV_EVENT_ERROR) { in be_openssl_eventcb()
933 event = what; in be_openssl_eventcb()
934 } else if (what & BEV_EVENT_CONNECTED) { in be_openssl_eventcb()
943 be_openssl_readeventcb(evutil_socket_t fd, short what, void *ptr) in be_openssl_readeventcb() argument
947 if (what == EV_TIMEOUT) { in be_openssl_readeventcb()
957 be_openssl_writeeventcb(evutil_socket_t fd, short what, void *ptr) in be_openssl_writeeventcb() argument
961 if (what == EV_TIMEOUT) { in be_openssl_writeeventcb()
[all …]
H A Dbufferevent_pair.c328 short what = BEV_EVENT_EOF; in be_pair_flush() local
330 what |= BEV_EVENT_WRITING; in be_pair_flush()
332 what |= BEV_EVENT_READING; in be_pair_flush()
333 bufferevent_run_eventcb_(partner, what, 0); in be_pair_flush()
H A Dhttp.c1489 if (what & BEV_EVENT_TIMEOUT) { in evhttp_error_cb()
1544 if (what & BEV_EVENT_TIMEOUT) { in evhttp_error_cb()
1547 if (what & BEV_EVENT_WRITING && in evhttp_error_cb()
1553 if (what & BEV_EVENT_READING && in evhttp_error_cb()
1581 if (!(what & BEV_EVENT_CONNECTED)) { in evhttp_connection_cb()
1590 evhttp_error_cb(bufev, what, arg); in evhttp_connection_cb()
3351 if (!strcmp(cb->what, translated)) { in evhttp_dispatch_callback()
3755 mm_free(http_cb->what); in evhttp_free()
3929 http_cb->what = mm_strdup(uri); in evhttp_set_cb()
3930 if (http_cb->what == NULL) { in evhttp_set_cb()
[all …]
H A Dhttp-internal.h111 char *what; member
H A Dbufferevent_filter.c551 be_filter_eventcb(struct bufferevent *underlying, short what, void *me_) in be_filter_eventcb() argument
566 bufferevent_run_eventcb_(bev, what, 0); in be_filter_eventcb()
/libevent-2.1.12/test/
H A Dregress_bufferevent.c629 TT_FAIL(("Got sender error %d",(int)what)); in sender_errorcb()
685 if (what & BEV_EVENT_ERROR) { in reader_eventcb()
687 TT_FAIL(("got connector error %d", (int)what)); in reader_eventcb()
690 if (what & BEV_EVENT_CONNECTED) { in reader_eventcb()
694 if (what & BEV_EVENT_EOF) { in reader_eventcb()
874 if (what & BEV_EVENT_ERROR) { in want_fail_eventcb()
881 TT_FAIL(("didn't fail? what %hd", what)); in want_fail_eventcb()
963 if ((what & (BEV_EVENT_READING|BEV_EVENT_TIMEOUT)) in bev_timeout_event_cb()
1086 if (what == ~0) { in trigger_eventcb()
1091 reader_eventcb(bev, what, ctx); in trigger_eventcb()
[all …]
H A Dregress_finalize.c42 timer_callback(evutil_socket_t fd, short what, void *arg) in timer_callback() argument
47 (void)what; in timer_callback()
244 timer_callback_2(evutil_socket_t fd, short what, void *arg) in timer_callback_2() argument
251 (void)what; in timer_callback_2()
342 timer_callback_3(evutil_socket_t *fd, short what, void *arg)
345 (void)what;
H A Dbench_httpclient.c70 static void errorcb(struct bufferevent *b, short what, void *arg);
84 errorcb(struct bufferevent *b, short what, void *arg) in errorcb() argument
88 if (what & BEV_EVENT_EOF) { in errorcb()
H A Dregress_http.c258 const char *what = BASIC_REQUEST_BODY; in http_readcb() local
307 if (what & BEV_EVENT_CONNECTED) in http_errorcb()
640 const char *what = "Hello, 127.0.0.1"; in http_badreq_readcb() local
1615 const char *what = arg; in http_request_done() local
1884 const char *what = "DISPATCHER_TEST"; in http_dispatcher_test_done() local
2062 const char *what = BASIC_REQUEST_BODY; in http_postrequest_done() local
2180 const char *what = "That ain't funny"; in http_putrequest_done() local
2217 const char *what = "400 Bad Request"; in http_failure_readcb() local
3077 if (what & BEV_EVENT_CONNECTED) in http_incomplete_errorcb()
3181 if (what & BEV_EVENT_CONNECTED) in http_chunked_errorcb()
[all …]
H A Dregress_ssl.c364 eventcb(struct bufferevent *bev, short what, void *ctx) in eventcb() argument
371 TT_BLATHER(("Got event %d", (int)what)); in eventcb()
372 if (what & BEV_EVENT_CONNECTED) { in eventcb()
390 } else if (what & BEV_EVENT_EOF) { in eventcb()
400 } else if (what & BEV_EVENT_ERROR) { in eventcb()
410 } else if (what & BEV_EVENT_TIMEOUT) { in eventcb()
845 wm_eventcb(struct bufferevent *bev, short what, void *arg) in wm_eventcb() argument
849 ctx->server ? "server" : "client", bev, what)); in wm_eventcb()
850 if (what & BEV_EVENT_CONNECTED) { in wm_eventcb()
H A Dregress_thread.c75 wake_all_timeout(evutil_socket_t fd, short what, void *arg) in wake_all_timeout() argument
85 wake_one_timeout(evutil_socket_t fd, short what, void *arg) in wake_one_timeout() argument
436 timer_callback(evutil_socket_t fd, short what, void *arg) in timer_callback() argument
442 start_threads_callback(evutil_socket_t fd, short what, void *arg) in start_threads_callback() argument
502 note_time_cb(evutil_socket_t fd, short what, void *arg) in note_time_cb() argument
H A Dregress.c380 record_event_cb(evutil_socket_t s, short what, void *ptr) in record_event_cb() argument
385 *whatp = what; in record_event_cb()
1911 (void) fd; (void) what; in incr_arg_cb()
1917 (void) fd; (void) what; in remove_timers_cb()
1924 (void) fd; (void) what; in send_a_byte_cb()
1939 (void) fd; (void) what; in read_not_timeout_cb()
1942 rntp->events |= what; in read_not_timeout_cb()
3161 short what; in test_get_assignment() local
3170 tt_int_op(what, ==, EV_READ); in test_get_assignment()
3347 tabf_cb(evutil_socket_t fd, short what, void *arg) in tabf_cb() argument
[all …]
H A Dregress_dns.c1211 int what; member
1217 be_connect_hostname_event_cb(struct bufferevent *bev, short what, void *ctx) in be_connect_hostname_event_cb() argument
1221 if (got->what) { in be_connect_hostname_event_cb()
1223 got->what, (int)what)); in be_connect_hostname_event_cb()
1226 TT_BLATHER(("Got a bufferevent event %d", what)); in be_connect_hostname_event_cb()
1227 got->what = what; in be_connect_hostname_event_cb()
1229 if ((what & BEV_EVENT_CONNECTED) || (what & BEV_EVENT_ERROR)) { in be_connect_hostname_event_cb()
1359 tt_int_op(be_outcome[0].what, ==, BEV_EVENT_ERROR); in test_bufferevent_connect_hostname()
1372 tt_int_op(be_outcome[4].what, ==, BEV_EVENT_ERROR); in test_bufferevent_connect_hostname()
1419 cancel_gai_cb(evutil_socket_t fd, short what, void *ptr) in cancel_gai_cb() argument
[all …]
H A Dtest-ratelim.c152 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx) in write_on_connectedcb() argument
154 if (what & BEV_EVENT_CONNECTED) { in write_on_connectedcb()
181 echo_eventcb(struct bufferevent *bev, short what, void *ctx) in echo_eventcb() argument
183 if (what & (BEV_EVENT_EOF|BEV_EVENT_ERROR)) { in echo_eventcb()
/libevent-2.1.12/sample/
H A Dle-proxy.c50 static void eventcb(struct bufferevent *bev, short what, void *ctx);
103 eventcb(struct bufferevent *bev, short what, void *ctx) in eventcb() argument
107 if (what & (BEV_EVENT_EOF|BEV_EVENT_ERROR)) { in eventcb()
108 if (what & BEV_EVENT_ERROR) { in eventcb()
/libevent-2.1.12/include/event2/
H A Dbuffer_compat.h108 unsigned char *evbuffer_find(struct evbuffer *buffer, const unsigned char *what, size_t len);
H A Dbufferevent.h154 typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short what, void *ctx);
662 void bufferevent_trigger_event(struct bufferevent *bufev, short what,
H A Dbuffer.h749 struct evbuffer_ptr evbuffer_search(struct evbuffer *buffer, const char *what, size_t len, const st…
766 struct evbuffer_ptr evbuffer_search_range(struct evbuffer *buffer, const char *what, size_t len, co…

12