| /libevent-2.1.12/test/ |
| H A D | tinytest_macros.h | 91 if (!(b)) { \ 109 #define tt_want(b) tt_want_msg( (b), "want("#b")") argument 111 #define tt_assert(b) tt_assert_msg((b), "assert("#b")") argument 158 tt_assert_test_type(a,b,#a" "#op" "#b,long,(val1_ op val2_), \ 170 tt_assert_test_type(a,b,#a" "#op" "#b,unsigned long, \ 174 tt_assert_test_type(a,b,#a" "#op" "#b,const void*, \ 179 tt_assert_test_type_opt(a,b,#a" "#op" "#b,const char *, \ 184 tt_assert_test_type_opt(a,b,#a" "#op" "#b,const char *, \ 202 tt_assert_test_type(a,b,#a" "#op" "#b,unsigned long, \ 206 tt_assert_test_type(a,b,#a" "#op" "#b,const void*, \ [all …]
|
| H A D | bench_httpclient.c | 69 static void readcb(struct bufferevent *b, void *arg); 73 readcb(struct bufferevent *b, void *arg) in readcb() argument 76 struct evbuffer *input = bufferevent_get_input(b); in readcb() 84 errorcb(struct bufferevent *b, short what, void *arg) in errorcb() argument 107 bufferevent_setcb(b, NULL, NULL, NULL, NULL); in errorcb() 109 bufferevent_disable(b, EV_READ|EV_WRITE); in errorcb() 110 bufferevent_free(b); in errorcb() 135 struct bufferevent *b; in launch_request() local 167 bufferevent_setcb(b, readcb, NULL, errorcb, ri); in launch_request() 168 bufferevent_enable(b, EV_READ|EV_WRITE); in launch_request() [all …]
|
| H A D | regress_ssl.c | 356 if (evbuffer_get_length(b)) in done_writing_cb() 622 bio_rwcount_new(BIO *b) in bio_rwcount_new() argument 624 BIO_set_init(b, 0); in bio_rwcount_new() 625 BIO_set_data(b, NULL); in bio_rwcount_new() 629 bio_rwcount_free(BIO *b) in bio_rwcount_free() argument 632 if (!b) in bio_rwcount_free() 634 if (BIO_get_shutdown(b)) { in bio_rwcount_free() 635 BIO_set_init(b, 0); in bio_rwcount_free() 636 BIO_set_data(b, NULL); in bio_rwcount_free() 647 BIO_set_retry_read(b); in bio_rwcount_read() [all …]
|
| H A D | include.am | 61 $(top_srcdir)/test/test.sh -b EPOLL 63 $(top_srcdir)/test/test.sh -b SELECT 65 $(top_srcdir)/test/test.sh -b KQUEUE 67 $(top_srcdir)/test/test.sh -b EVPORT 69 $(top_srcdir)/test/test.sh -b DEVPOLL 71 $(top_srcdir)/test/test.sh -b POLL 73 $(top_srcdir)/test/test.sh -b WIN32 75 $(top_srcdir)/test/test.sh -b "" -t 77 $(top_srcdir)/test/test.sh -b "" -c 79 $(top_srcdir)/test/test.sh -b "" -T
|
| H A D | tinytest.c | 268 char b[1]; in testcase_run_forked_() 272 b[0] = "NYS"[test_r]; in testcase_run_forked_() 273 write_r = (int)write(outcome_pipe[1], b, 1); in testcase_run_forked_() 283 char b[1]; in testcase_run_forked_() 287 r = (int)read(outcome_pipe[0], b, 1); in testcase_run_forked_() 304 return b[0]=='Y' ? OK : (b[0]=='S' ? SKIP : FAIL); in testcase_run_forked_()
|
| H A D | regress.c | 2657 char b[256]; in setenv() local 2658 evutil_snprintf(b, sizeof(b), "%s=%s",k,v); in setenv() 2659 putenv(b); in setenv() 2669 char b[256]; in unsetenv() local 2670 evutil_snprintf(b, sizeof(b), "%s=",k); in unsetenv() 2671 putenv(b); in unsetenv() 3066 tt_assert(b); in test_mm_functions() 3071 if (b) in test_mm_functions() 3072 event_base_free(b); in test_mm_functions() 3159 struct event_base *b; in test_get_assignment() local [all …]
|
| H A D | test-ratelim.c | 54 #define MIN(a,b) (((a)<(b))?(a):(b)) argument
|
| H A D | regress_util.c | 727 const char *b; member 737 es1.b = "Hello"; in test_evutil_upcast() 740 tt_int_op(evutil_offsetof(struct example_struct, b), ==, sizeof(char*)); in test_evutil_upcast() 742 cp = &es1.b; in test_evutil_upcast() 743 tt_ptr_op(EVUTIL_UPCAST(cp, struct example_struct, b), ==, &es1); in test_evutil_upcast()
|
| H A D | regress_buffer.c | 1066 struct evbuffer *b = arg; in addfile_test_writecb() local 1068 evbuffer_validate(b); in addfile_test_writecb() 1069 while (evbuffer_get_length(b)) { in addfile_test_writecb() 1070 r = evbuffer_write(b, fd); in addfile_test_writecb() 1081 evbuffer_validate(b); in addfile_test_writecb() 1092 struct evbuffer *b = arg; in addfile_test_readcb() local 1095 r = evbuffer_read(b, fd, 1024); in addfile_test_readcb()
|
| H A D | regress_dns.c | 118 const char *b = evutil_inet_ntop(AF_INET6, &in6_addrs[i], buf,sizeof(buf)); in dns_gethostbyname_cb() local 119 if (b) in dns_gethostbyname_cb() 120 TT_BLATHER(("%s ", b)); in dns_gethostbyname_cb() 336 const char *b = evutil_inet_ntop(AF_INET6, &in6_addrs[0],buf,sizeof(buf)); in dns_server_gethostbyname_cb() local 337 printf("Bad IPv6 response \"%s\" %d. ", b, ttl); in dns_server_gethostbyname_cb()
|
| /libevent-2.1.12/ |
| H A D | openssl-compat.h | 21 #define BIO_meth_set_write(b, f) (b)->bwrite = (f) argument 22 #define BIO_meth_set_read(b, f) (b)->bread = (f) argument 23 #define BIO_meth_set_puts(b, f) (b)->bputs = (f) argument 24 #define BIO_meth_set_ctrl(b, f) (b)->ctrl = (f) argument 25 #define BIO_meth_set_create(b, f) (b)->create = (f) argument 28 #define BIO_set_init(b, val) (b)->init = (val) argument 29 #define BIO_set_data(b, val) (b)->ptr = (val) argument 31 #define BIO_get_init(b) (b)->init argument 32 #define BIO_get_data(b) (b)->ptr argument 33 #define BIO_get_shutdown(b) (b)->shutdown argument [all …]
|
| H A D | ht-internal.h | 253 unsigned b = 0; \ 254 while (b < head->hth_table_length) { \ 255 if (head->hth_table[b]) \ 256 return &head->hth_table[b]; \ 257 ++b; \ 273 while (b < head->hth_table_length) { \ 274 if (head->hth_table[b]) \ 275 return &head->hth_table[b]; \ 276 ++b; \ 335 for (b = 0; b < head->hth_table_length; ++b) { \ [all …]
|
| H A D | evutil_rand.c | 78 unsigned char *b = buf; in ev_arc4random_buf() 98 if (n >= 4 && ((ev_uintptr_t)b) & 3) { in ev_arc4random_buf() 100 int n_bytes = 4 - (((ev_uintptr_t)b) & 3); in ev_arc4random_buf() 101 memcpy(b, &u, n_bytes); in ev_arc4random_buf() 102 b += n_bytes; in ev_arc4random_buf() 106 *(ev_uint32_t*)b = arc4random(); in ev_arc4random_buf() 107 b += 4; in ev_arc4random_buf() 112 memcpy(b, &u, n); in ev_arc4random_buf()
|
| H A D | bufferevent-internal.h | 343 #define bufferevent_wm_suspend_read(b) \ argument 344 bufferevent_suspend_read_((b), BEV_SUSPEND_WM) 345 #define bufferevent_wm_unsuspend_read(b) \ argument 346 bufferevent_unsuspend_read_((b), BEV_SUSPEND_WM) 478 #define BEV_UPCAST(b) EVUTIL_UPCAST((b), struct bufferevent_private, bev) argument 481 #define BEV_LOCK(b) EVUTIL_NIL_STMT_ argument 482 #define BEV_UNLOCK(b) EVUTIL_NIL_STMT_ argument 485 #define BEV_LOCK(b) do { \ argument 486 struct bufferevent_private *locking = BEV_UPCAST(b); \ 491 #define BEV_UNLOCK(b) do { \ argument [all …]
|
| H A D | ratelim-internal.h | 91 #define ev_token_bucket_decrement_read(b,n) \ argument 93 (b)->read_limit -= (n); \ 96 #define ev_token_bucket_decrement_write(b,n) \ argument 98 (b)->write_limit -= (n); \
|
| H A D | bufferevent_openssl.c | 110 bio_bufferevent_new(BIO *b) in bio_bufferevent_new() argument 112 BIO_set_init(b, 0); in bio_bufferevent_new() 121 if (!b) in bio_bufferevent_free() 124 if (BIO_get_init(b) && BIO_get_data(b)) in bio_bufferevent_free() 126 BIO_free(b); in bio_bufferevent_free() 138 BIO_clear_retry_flags(b); in bio_bufferevent_read() 142 if (!BIO_get_data(b)) in bio_bufferevent_read() 148 BIO_set_retry_read(b); in bio_bufferevent_read() 165 BIO_clear_retry_flags(b); in bio_bufferevent_write() 167 if (!BIO_get_data(b)) in bio_bufferevent_write() [all …]
|
| H A D | log-internal.h | 37 #define EV_CHECK_FMT(a,b) __attribute__((format(printf, a, b))) argument 40 #define EV_CHECK_FMT(a,b)
|
| H A D | bufferevent_pair.c | 69 incref_and_lock(struct bufferevent *b) in incref_and_lock() argument 72 bufferevent_incref_and_lock_(b); in incref_and_lock() 73 bevp = upcast(b); in incref_and_lock() 79 decref_and_unlock(struct bufferevent *b) in decref_and_unlock() argument 81 struct bufferevent_pair *bevp = upcast(b); in decref_and_unlock() 84 bufferevent_decref_and_unlock_(b); in decref_and_unlock()
|
| H A D | buffer_iocp.c | 206 WSABUF *b = &buf_o->buffers[i]; in evbuffer_launch_write_() local 207 b->buf = (char*)( chain->buffer + chain->misalign ); in evbuffer_launch_write_() 215 b->len = (unsigned long)chain->off; in evbuffer_launch_write_() 218 b->len = (unsigned long)at_most; in evbuffer_launch_write_()
|
| H A D | make-event-config.sed | 21 /#\( *\)undef STDC_HEADERS\>/b 22 /#\( *\)define STDC_HEADERS\>/b
|
| H A D | evutil.c | 1727 const struct cached_sock_errs_entry *b) in eq_cached_sock_errs() argument 1729 return a->code == b->code; in eq_cached_sock_errs() 2033 unsigned a,b,c,d; in evutil_inet_pton() 2036 if (sscanf(src, "%u.%u.%u.%u%c", &a,&b,&c,&d,&more) != 4) in evutil_inet_pton() 2039 if (b > 255) return 0; in evutil_inet_pton() 2042 addr->s_addr = htonl((a<<24) | (b<<16) | (c<<8) | d); in evutil_inet_pton() 2248 char b[128]; in evutil_format_sockaddr_port_() local 2253 res = evutil_inet_ntop(AF_INET, &sin->sin_addr,b,sizeof(b)); in evutil_format_sockaddr_port_() 2256 evutil_snprintf(out, outlen, "%s:%d", b, port); in evutil_format_sockaddr_port_() 2261 res = evutil_inet_ntop(AF_INET6, &sin6->sin6_addr,b,sizeof(b)); in evutil_format_sockaddr_port_() [all …]
|
| H A D | minheap-internal.h | 61 #define min_heap_elem_greater(a, b) \ argument 62 (evutil_timercmp(&(a)->ev_timeout, &(b)->ev_timeout, >))
|
| H A D | event.c | 200 const struct event_debug_entry *b) in eq_debug_entry() argument 202 return a->ptr == b->ptr; in eq_debug_entry() 964 nil_backend_del(struct event_base *b, evutil_socket_t fd, short old, in nil_backend_del() argument 3207 #define MAX(a,b) (((a)>(b))?(a):(b)) argument
|
| /libevent-2.1.12/include/event2/ |
| H A D | event.h | 964 #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
|
| /libevent-2.1.12/sample/ |
| H A D | le-proxy.c | 95 struct evbuffer *b = bufferevent_get_output(bev); in close_on_finished_writecb() local 97 if (evbuffer_get_length(b) == 0) { in close_on_finished_writecb()
|