Home
last modified time | relevance | path

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

12

/libevent-2.1.12/
H A Ddevpoll.c173 int i, res, timeout = -1; in devpoll_dispatch() local
191 if (res == -1) { in devpoll_dispatch()
202 for (i = 0; i < res; i++) { in devpoll_dispatch()
231 int res; in devpoll_add() local
241 res = 0; in devpoll_add()
243 res |= POLLIN; in devpoll_add()
245 res |= POLLOUT; in devpoll_add()
257 int res; in devpoll_del() local
260 res = 0; in devpoll_del()
262 res |= POLLIN; in devpoll_del()
[all …]
H A Devent_tagging.c383 if (res != -1) in evtag_decode_int()
384 evbuffer_drain(evbuf, res); in evtag_decode_int()
386 return (res == -1 ? -1 : 0); in evtag_decode_int()
393 if (res != -1) in evtag_decode_int64()
394 evbuffer_drain(evbuf, res); in evtag_decode_int64()
396 return (res == -1 ? -1 : 0); in evtag_decode_int64()
408 int res, len; in evtag_peek_length() local
415 if (res == -1) in evtag_peek_length()
418 *plength += res + len; in evtag_peek_length()
426 int res, len; in evtag_payload_length() local
[all …]
H A Dpoll.c138 int res, i, j, nfds; in poll_dispatch() local
182 res = poll(event_set, nfds, msec); in poll_dispatch()
186 if (res == -1) { in poll_dispatch()
195 event_debug(("%s: poll reports %d", __func__, res)); in poll_dispatch()
197 if (res == 0 || nfds == 0) in poll_dispatch()
209 res = 0; in poll_dispatch()
215 res |= EV_READ; in poll_dispatch()
217 res |= EV_WRITE; in poll_dispatch()
219 res |= EV_CLOSED; in poll_dispatch()
220 if (res == 0) in poll_dispatch()
[all …]
H A Dbufferevent_sock.c154 int res = 0; in bufferevent_readcb() local
193 if (res == -1) { in bufferevent_readcb()
203 } else if (res == 0) { in bufferevent_readcb()
208 if (res <= 0) in bufferevent_readcb()
234 int res = 0; in bufferevent_writecb() local
297 if (res == -1) { in bufferevent_writecb()
302 } else if (res == 0) { in bufferevent_writecb()
309 if (res <= 0) in bufferevent_writecb()
673 int res = -1; in bufferevent_base_set() local
682 if (res == -1) in bufferevent_base_set()
[all …]
H A Dselect.c142 int res=0, i, j, nfds; in select_dispatch() local
172 res = select(nfds, sop->event_readset_out, in select_dispatch()
179 if (res == -1) { in select_dispatch()
188 event_debug(("%s: select reports %d", __func__, res)); in select_dispatch()
195 res = 0; in select_dispatch()
197 res |= EV_READ; in select_dispatch()
199 res |= EV_WRITE; in select_dispatch()
201 if (res == 0) in select_dispatch()
204 evmap_io_active_(base, i, res); in select_dispatch()
H A Devutil.c703 ULONG size, res; in evutil_check_ifaddrs()
859 if (!res) in evutil_new_addrinfo_()
870 return res; in evutil_new_addrinfo_()
1079 if (!*res) in evutil_getaddrinfo_common_()
1095 if (!*res) in evutil_getaddrinfo_common_()
1216 res = evutil_addrinfo_append_(res, ai); in addrinfo_from_hostent()
1227 return res; in addrinfo_from_hostent()
1473 *res = NULL; in evutil_getaddrinfo()
1567 if (! *res) in evutil_getaddrinfo()
2255 if (res) { in evutil_format_sockaddr_port_()
[all …]
H A Dbufferevent_filter.c306 enum bufferevent_filter_result res; in be_filter_process_input() local
326 if (res == BEV_OK) in be_filter_process_input()
328 } while (res == BEV_OK && in be_filter_process_input()
336 return res; in be_filter_process_input()
346 enum bufferevent_filter_result res = BEV_OK; in be_filter_process_output() local
384 if (res == BEV_OK) in be_filter_process_output()
387 res == BEV_OK && in be_filter_process_output()
400 if (res == BEV_OK && in be_filter_process_output()
416 return res; in be_filter_process_output()
441 enum bufferevent_filter_result res; in be_filter_read_nolock_() local
[all …]
H A Devport.c258 int i, res; in evport_dispatch() local
306 res = port_getn(epdp->ed_port, pevtlist, epdp->ed_maxevents, in evport_dispatch()
311 if (res == -1) { in evport_dispatch()
340 res = 0; in evport_dispatch()
342 res = EV_READ | EV_WRITE; in evport_dispatch()
345 res |= EV_READ; in evport_dispatch()
347 res |= EV_WRITE; in evport_dispatch()
354 res |= EV_READ|EV_WRITE; in evport_dispatch()
356 evmap_io_active_(base, fd, res); in evport_dispatch()
H A Devent.c1056 res = -1; in event_reinit()
1068 res = -1; in event_reinit()
1897 int res; in event_base_got_break() local
1901 return res; in event_base_got_break()
1907 int res; in event_base_got_exit() local
2486 int res; in event_add() local
2576 int res; in event_remove_timer() local
2658 res = 0; in event_add_nolock_()
2771 int res; in event_del_() local
2868 res = 0; in event_del_nolock_()
[all …]
H A Devthread.c253 int res = 0; in debug_lock_lock() local
259 res = original_lock_fns_.lock(mode, lock->lock); in debug_lock_lock()
260 if (!res) { in debug_lock_lock()
263 return res; in debug_lock_lock()
289 int res = 0; in debug_lock_unlock() local
292 res = original_lock_fns_.unlock(mode, lock->lock); in debug_lock_unlock()
293 return res; in debug_lock_unlock()
H A Dlistener.c499 struct accepting_socket *res; in new_accepting_socket() local
511 res = mm_calloc(1,sizeof(struct accepting_socket)-1+buflen); in new_accepting_socket()
512 if (!res) in new_accepting_socket()
516 res->s = EVUTIL_INVALID_SOCKET; in new_accepting_socket()
517 res->lev = lev; in new_accepting_socket()
518 res->buflen = buflen; in new_accepting_socket()
519 res->family = family; in new_accepting_socket()
521 event_deferred_cb_init_(&res->deferred, in new_accepting_socket()
523 accepted_socket_invoke_user_cb, res); in new_accepting_socket()
525 InitializeCriticalSectionAndSpinCount(&res->lock, 1000); in new_accepting_socket()
[all …]
H A Depoll.c421 int i, res; in epoll_dispatch() local
465 res = epoll_wait(epollop->epfd, events, epollop->nevents, timeout); in epoll_dispatch()
469 if (res == -1) { in epoll_dispatch()
478 event_debug(("%s: epoll_wait reports %d", __func__, res)); in epoll_dispatch()
479 EVUTIL_ASSERT(res <= epollop->nevents); in epoll_dispatch()
481 for (i = 0; i < res; i++) { in epoll_dispatch()
508 if (res == epollop->nevents && epollop->nevents < MAX_NEVENT) { in epoll_dispatch()
H A Devmap.c279 short res = 0, old = 0; in evmap_io_add_() local
309 res |= EV_READ; in evmap_io_add_()
313 res |= EV_WRITE; in evmap_io_add_()
317 res |= EV_CLOSED; in evmap_io_add_()
332 if (res) { in evmap_io_add_()
338 old, (ev->ev_events & EV_ET) | res, extra) == -1) in evmap_io_add_()
360 short res = 0, old = 0; in evmap_io_del_() local
387 res |= EV_READ; in evmap_io_del_()
392 res |= EV_WRITE; in evmap_io_del_()
397 res |= EV_CLOSED; in evmap_io_del_()
[all …]
H A Dkqueue.c273 int i, n_changes, res; in kq_dispatch() local
315 res = kevent(kqop->kq, changes, n_changes, in kq_dispatch()
323 if (res == -1) { in kq_dispatch()
332 event_debug(("%s: kevent reports %d", __func__, res)); in kq_dispatch()
334 for (i = 0; i < res; i++) { in kq_dispatch()
422 if (res == kqop->events_size) { in kq_dispatch()
H A Devthread_win32.c253 DWORD res; in evthread_win32_cond_wait() local
254 res = WaitForSingleObject(cond->event, ms); in evthread_win32_cond_wait()
263 } else if (res != WAIT_OBJECT_0) { in evthread_win32_cond_wait()
264 result = (res==WAIT_TIMEOUT) ? 1 : -1; in evthread_win32_cond_wait()
H A Devrpc.c193 int res = hook->process(ctx, req, evbuf, hook->process_arg); in evrpc_process_hooks() local
194 if (res != EVRPC_CONTINUE) in evrpc_process_hooks()
195 return (res); in evrpc_process_hooks()
726 int res = 0; in evrpc_schedule_request_closure() local
746 res = evhttp_make_request(connection, req, EVHTTP_REQ_POST, uri); in evrpc_schedule_request_closure()
749 if (res == -1) in evrpc_schedule_request_closure()
793 (*pause->cb)(pause->ctx, res); in evrpc_resume_request()
919 int res = -1; in evrpc_reply_done_closure() local
930 res = ctx->reply_unmarshal(ctx->reply, req->input_buffer); in evrpc_reply_done_closure()
931 if (res == -1) in evrpc_reply_done_closure()
[all …]
H A Dbufferevent.c868 int res = -1; in bufferevent_setfd() local
872 res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d); in bufferevent_setfd()
873 if (res) in bufferevent_setfd()
876 return res; in bufferevent_setfd()
883 int res = -1; in bufferevent_getfd() local
887 res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d); in bufferevent_getfd()
888 if (res) in bufferevent_getfd()
891 return (res<0) ? -1 : d.fd; in bufferevent_getfd()
932 int res = -1; in bufferevent_get_underlying() local
936 res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_UNDERLYING, &d); in bufferevent_get_underlying()
[all …]
H A Dwin32select.c283 int res = 0; in win32_dispatch() local
319 res = select(fd_count, in win32_dispatch()
326 event_debug(("%s: select returned %d", __func__, res)); in win32_dispatch()
328 if (res <= 0) { in win32_dispatch()
331 return res; in win32_dispatch()
H A Devdns.c2605 int res; in evdns_base_nameserver_add() local
2613 return res; in evdns_base_nameserver_add()
2651 int res; in evdns_base_nameserver_ip_add() local
2665 return res; in evdns_base_nameserver_ip_add()
2679 int res; in evdns_base_nameserver_sockaddr_add() local
3461 int res; in evdns_base_set_option() local
3630 int res; in evdns_base_resolv_conf_parse() local
4288 int res; in evdns_base_load_hosts() local
4604 if (res) in evdns_getaddrinfo_gotresolve()
4611 res = evutil_addrinfo_append_(res, ai); in evdns_getaddrinfo_gotresolve()
[all …]
H A Devent-internal.h427 void event_active_nolock_(struct event *ev, int res, short count);
441 void event_active_later_(struct event *ev, int res);
442 void event_active_later_nolock_(struct event *ev, int res);
/libevent-2.1.12/test/
H A Dregress_zlib.c137 int res, n; in zlib_input_filter() local
157 res = inflate(p, getstate(state)); in zlib_input_filter()
167 if (res==Z_BUF_ERROR) { in zlib_input_filter()
174 assert(res == Z_OK || res == Z_STREAM_END); in zlib_input_filter()
191 int res, n; in zlib_output_filter() local
211 res = deflate(p, getstate(state)); in zlib_output_filter()
221 if (res==Z_BUF_ERROR) { in zlib_output_filter()
228 assert(res == Z_OK || res == Z_STREAM_END); in zlib_output_filter()
H A Dregress_dns.c489 res->result = result; in generic_dns_callback()
490 res->type = type; in generic_dns_callback()
491 res->count = count; in generic_dns_callback()
492 res->ttl = ttl; in generic_dns_callback()
501 res->addrs_len = len = 0; in generic_dns_callback()
502 res->addrs = NULL; in generic_dns_callback()
505 res->addrs_len = len; in generic_dns_callback()
509 res->addrs = res->addrs_buf; in generic_dns_callback()
1410 go->ai = res; in gai_cb()
1857 if (res) in gaic_getaddrinfo_cb()
[all …]
H A Dregress_bufferevent.c948 struct timeout_cb_result *res = arg; in bev_timeout_read_cb() local
949 evutil_gettimeofday(&res->last_read_at, NULL); in bev_timeout_read_cb()
954 struct timeout_cb_result *res = arg; in bev_timeout_write_cb() local
955 evutil_gettimeofday(&res->last_wrote_at, NULL); in bev_timeout_write_cb()
960 struct timeout_cb_result *res = arg; in bev_timeout_event_cb() local
961 ++res->total_calls; in bev_timeout_event_cb()
965 evutil_gettimeofday(&res->read_timeout_at, NULL); in bev_timeout_event_cb()
966 ++res->n_read_timeouts; in bev_timeout_event_cb()
970 evutil_gettimeofday(&res->write_timeout_at, NULL); in bev_timeout_event_cb()
971 ++res->n_write_timeouts; in bev_timeout_event_cb()
/libevent-2.1.12/sample/
H A Ddns-example.c216 int res; in main() local
219 res = evdns_base_config_windows_nameservers(evdns_base); in main()
223 res = evdns_base_nameserver_ip_add(evdns_base, o.ns); in main()
225 res = evdns_base_resolv_conf_parse(evdns_base, in main()
228 if (res) { in main()
H A Dhttps-client.c127 HostnameValidationResult res = Error; in cert_verify_callback() local
145 res = validate_hostname(host, server_cert); in cert_verify_callback()
147 switch (res) { in cert_verify_callback()
172 if (res == MatchFound) { in cert_verify_callback()

12