Home
last modified time | relevance | path

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

/libevent-2.1.12/
H A Dminheap-internal.h66 void min_heap_elem_init_(struct event* e) { e->ev_timeout_pos.min_heap_idx = -1; } in min_heap_elem_init_() argument
75 min_heap_shift_up_(s, s->n++, e); in min_heap_push_()
83 struct event* e = *s->p; in min_heap_pop_() local
85 e->ev_timeout_pos.min_heap_idx = -1; in min_heap_pop_()
86 return e; in min_heap_pop_()
98 if (-1 != e->ev_timeout_pos.min_heap_idx) in min_heap_erase_()
111 e->ev_timeout_pos.min_heap_idx = -1; in min_heap_erase_()
120 return min_heap_push_(s, e); in min_heap_adjust_()
125 if (e->ev_timeout_pos.min_heap_idx > 0 && min_heap_elem_greater(s->p[parent], e)) in min_heap_adjust_()
126 min_heap_shift_up_unconditional_(s, e->ev_timeout_pos.min_heap_idx, e); in min_heap_adjust_()
[all …]
H A Dutil-internal.h112 ((e) == EAGAIN)
115 ((e) == EAGAIN || (e) == EWOULDBLOCK)
120 ((e) == EINTR || EVUTIL_ERR_IS_EAGAIN(e))
123 ((e) == EINTR || (e) == EINPROGRESS)
126 ((e) == EINTR || EVUTIL_ERR_IS_EAGAIN(e) || (e) == ECONNABORTED)
130 ((e) == ECONNREFUSED)
136 ((e) == WSAEWOULDBLOCK || (e) == EAGAIN)
140 (e) == WSAEINTR)
146 (e) == WSAEINVAL)
149 EVUTIL_ERR_RW_RETRIABLE(e)
[all …]
H A Dht-internal.h357 struct type *e, **pE; \
358 for (pE = &new_table[b], e = *pE; e != NULL; e = *pE) { \
359 b2 = HT_ELT_HASH_(e, field, hashfn) % new_len; \
361 pE = &e->field.hte_next; \
363 *pE = e->field.hte_next; \
364 e->field.hte_next = new_table[b2]; \
365 new_table[b2] = e; \
H A Devent.c3334 struct event *e; in insert_common_timeout_inorder() local
3342 TAILQ_FOREACH_REVERSE(e, &ctl->events, in insert_common_timeout_inorder()
3752 (void*)e, gloss, EV_SOCK_ARG(e->ev_fd), in dump_inserted_event_fn()
3753 (e->ev_events&EV_READ)?" Read":"", in dump_inserted_event_fn()
3758 (e->ev_events&EV_ET)?" ET":"", in dump_inserted_event_fn()
3760 if (e->ev_flags & EVLIST_TIMEOUT) { in dump_inserted_event_fn()
3762 tv.tv_sec = e->ev_timeout.tv_sec; in dump_inserted_event_fn()
3786 (void*)e, gloss, EV_SOCK_ARG(e->ev_fd), e->ev_pri, in dump_active_event_fn()
3787 (e->ev_res&EV_READ)?" Read":"", in dump_active_event_fn()
3788 (e->ev_res&EV_WRITE)?" Write":"", in dump_active_event_fn()
[all …]
H A Devutil.c223 #define ERR(e) WSA##e in evutil_ersatz_socketpair_() argument
225 #define ERR(e) e in evutil_ersatz_socketpair_()
557 int e = evutil_socket_geterror(*fd_ptr); in evutil_socket_connect_() local
558 if (EVUTIL_ERR_CONNECT_RETRIABLE(e)) in evutil_socket_connect_()
560 if (EVUTIL_ERR_CONNECT_REFUSED(e)) in evutil_socket_connect_()
582 int e; in evutil_socket_finished_connecting_() local
583 ev_socklen_t elen = sizeof(e); in evutil_socket_finished_connecting_()
588 if (e) { in evutil_socket_finished_connecting_()
589 if (EVUTIL_ERR_CONNECT_RETRIABLE(e)) in evutil_socket_finished_connecting_()
591 EVUTIL_SET_SOCKET_ERROR(e); in evutil_socket_finished_connecting_()
[all …]
H A Devent_rpcgen.py1912 except RpcGenError as e:
1913 sys.stderr.write(e)
1914 except EnvironmentError as e:
1915 if e.filename and e.strerror:
1916 sys.stderr.write("%s: %s" % (e.filename, e.strerror))
1917 elif e.strerror:
1918 sys.stderr.write(e.strerror)
H A Devdns.c4427 int e = data->pending_error; in evdns_getaddrinfo_timeout_cb() local
4428 if (!e) in evdns_getaddrinfo_timeout_cb()
4429 e = EVUTIL_EAI_AGAIN; in evdns_getaddrinfo_timeout_cb()
4646 struct hosts_entry *e; in find_hosts_entry() local
4651 e = TAILQ_FIRST(&base->hostsdb); in find_hosts_entry()
4653 for (; e; e = TAILQ_NEXT(e, next)) { in find_hosts_entry()
4655 return e; in find_hosts_entry()
4666 struct hosts_entry *e; in evdns_getaddrinfo_fromhosts() local
4671 for (e = find_hosts_entry(base, nodename, NULL); e; in evdns_getaddrinfo_fromhosts()
4672 e = find_hosts_entry(base, nodename, e)) { in evdns_getaddrinfo_fromhosts()
[all …]
H A Dbuffer.c3107 int e; in evbuffer_file_segment_materialize() local
3126 e = errno; in evbuffer_file_segment_materialize()
3130 errno = e; in evbuffer_file_segment_materialize()
3336 struct evbuffer_cb_entry *e; in evbuffer_add_cb() local
3337 if (! (e = mm_calloc(1, sizeof(struct evbuffer_cb_entry)))) in evbuffer_add_cb()
3340 e->cb.cb_func = cb; in evbuffer_add_cb()
3341 e->cbarg = cbarg; in evbuffer_add_cb()
3342 e->flags = EVBUFFER_CB_ENABLED; in evbuffer_add_cb()
3343 LIST_INSERT_HEAD(&buffer->callbacks, e, next); in evbuffer_add_cb()
3345 return e; in evbuffer_add_cb()
H A Dbufferevent.c730 struct event *e = &bufev_private->rate_limiting->refill_bucket_event; in bufferevent_decref_and_unlock_() local
731 if (event_initialized(e)) in bufferevent_decref_and_unlock_()
732 cbs[n_cbs++] = &e->ev_evcallback; in bufferevent_decref_and_unlock_()
H A Devmap.c92 hashsocket(struct event_map_entry *e) in hashsocket() argument
97 unsigned h = (unsigned) e->fd; in hashsocket()
H A DChangeLog421 o http: read server response even after server closed the connection (680742e Azat Khuzhin)
1089 o Fix a couple of compilation warnings in regress_http.c (860767e)
1291 Puls, 232055e, ffe1643)
1356 o Avoid test -e; older shs don't have one. (f1bd938)
1639 o Solaris sendfile: correctly detect amount of data sent (643922e Michael Herf)
1707 o Use OPENSSL_LIBS in Makefile.am (292092e Sebastian Hahn)
1747 o Handle calloc failure in evdns. (Found by Dave Hart) (364291e)
1902 o Remove the eventqueue list and the ev_next pointers. (604569b 066775e)
1956 time (212533e Abel Mathew)
2110 kqueue (148458e Zack Weinberg)
[all …]
H A DVagrantfile231 ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)"
H A DCMakeLists.txt160 # (i.e. libevent is used via add_subdirectory())
H A DChangeLog-2.0210 o Solaris sendfile: correctly detect amount of data sent (643922e Michael Herf)
278 o Use OPENSSL_LIBS in Makefile.am (292092e Sebastian Hahn)
318 o Handle calloc failure in evdns. (Found by Dave Hart) (364291e)
H A Dwhatsnew-2.1.txt599 (e.g., SOCK_CLOEXEC, SOCK_NONBLOCK, accept4, pipe2) that allow us to
/libevent-2.1.12/test/
H A Dregress_minheap.c59 struct event *e, *last_e; in test_heap_randomized() local
82 e = min_heap_pop_(&heap); in test_heap_randomized()
83 if (!e) in test_heap_randomized()
86 &e->ev_timeout, <=)); in test_heap_randomized()
H A Dtest-changelist.c93 ev_int64_t s, e, diff; in filetime_diff() local
96 e = filetime_to_100nsec(ftEnd); in filetime_diff()
97 diff = e - s; in filetime_diff()
H A Dbench_httpclient.c154 int e = evutil_socket_geterror(sock); in launch_request() local
155 if (! EVUTIL_ERR_CONNECT_RETRIABLE(e)) { in launch_request()
H A Dregress.c2911 dfd_cb(evutil_socket_t fd, short e, void *data) in dfd_cb() argument
2913 *(int*)data = (int)e; in dfd_cb()
2920 struct event *e; in test_event_closed_fd_poll() local
2929 e = event_new(data->base, data->pair[0], EV_READ, dfd_cb, &i); in test_event_closed_fd_poll()
2930 tt_assert(e); in test_event_closed_fd_poll()
2934 event_add(e, &tv); in test_event_closed_fd_poll()
2935 tt_assert(event_pending(e, EV_READ, NULL)); in test_event_closed_fd_poll()
2942 if (e) { in test_event_closed_fd_poll()
2943 event_del(e); in test_event_closed_fd_poll()
2944 event_free(e); in test_event_closed_fd_poll()
H A Dregress_bufferevent.c169 bufferevent_event_cb e; in test_bufferevent_impl() local
171 bufferevent_getcb(bev1, &r, &w, &e, &a); in test_bufferevent_impl()
174 tt_ptr_op(e, ==, errorcb); in test_bufferevent_impl()
H A Dregress_buffer.c1075 int e = evutil_socket_geterror(fd); in addfile_test_writecb() local
1076 if (EVUTIL_ERR_RW_RETRIABLE(e)) in addfile_test_writecb()
1093 int e, r = 0; in addfile_test_readcb() local
1102 e = evutil_socket_geterror(fd); in addfile_test_readcb()
1103 if (! EVUTIL_ERR_RW_RETRIABLE(e)) { in addfile_test_readcb()
/libevent-2.1.12/cmake/
H A DCodeCoverage.cmake95 # Pass them in list form, e.g.: "-j;2" for -j 2
137 # Pass them in list form, e.g.: "-j;2" for -j 2
154 …COMMAND ${GCOVR_PATH} -x -r ${CMAKE_SOURCE_DIR} -e '${CMAKE_SOURCE_DIR}/tests/' -o ${_outputname}…
/libevent-2.1.12/m4/
H A Dacx_pthread.m421 # flags, but also link it with them as well. e.g. you should link
34 # that name (e.g. PTHREAD_CREATE_UNDETACHED on AIX).
93 # requires special compiler flags (e.g. on True64 or Sequent).
117 # (e.g. DEC) have both -lpthread and -lpthreads, where one of the
H A Dax_prog_doxygen.m439 # ensure that contradictory flags are not given (e.g.,
/libevent-2.1.12/extra/abi-check/
H A DREADME.md31 …docker run --rm -it -v $PWD:/src:ro -w /src -v tmp/le-abi-check-root:/abi-root -e ABI_CHECK_ROOT=/…