Home
last modified time | relevance | path

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

123

/libevent-2.1.12/
H A Devent_tagging.c127 data[off/2] = (data[off/2] & 0xf0) | (number & 0x0f); \
129 data[off/2] = (data[off/2] & 0x0f) | \
139 data[0] = (data[0] & 0x0f) | ((nibbles & 0x0f) << 4); \
159 ev_uint8_t data[5]; in evtag_encode_int() local
167 ev_uint8_t data[9]; in evtag_encode_int64() local
181 ev_uint8_t data[5]; in evtag_encode_tag() local
183 memset(data, 0, sizeof(data)); in evtag_encode_tag()
205 ev_uint8_t *data; in decode_tag_internal() local
215 if (!data) in decode_tag_internal()
330 if (!data) \
[all …]
H A Devdns.c215 } data; member
1821 if (!(item->data = mm_strdup(data))) { in evdns_server_request_add_reply()
1834 memcpy(item->data, data, datalen); in evdns_server_request_add_reply()
4423 add_cname_to_reply(data, data->pending_result); in evdns_getaddrinfo_timeout_cb()
4424 data->user_cb(0, data->pending_result, data->user_data); in evdns_getaddrinfo_timeout_cb()
4430 data->user_cb(e, NULL, data->user_data); in evdns_getaddrinfo_timeout_cb()
4547 add_cname_to_reply(data, data->pending_result); in evdns_getaddrinfo_gotresolve()
4548 data->user_cb(0, data->pending_result, data->user_data); in evdns_getaddrinfo_gotresolve()
4554 data->user_cb(err, NULL, data->user_data); in evdns_getaddrinfo_gotresolve()
4635 data->user_cb(0, res, data->user_data); in evdns_getaddrinfo_gotresolve()
[all …]
H A Devport.c167 grow(struct evport_data *data, int min_events) in grow() argument
172 if (data->ed_maxevents) { in grow()
173 newsize = data->ed_maxevents; in grow()
181 new_pending = mm_realloc(data->ed_pending, sizeof(int)*newsize); in grow()
184 data->ed_pending = new_pending; in grow()
185 new_pevtlist = mm_realloc(data->ed_pevtlist, sizeof(port_event_t)*newsize); in grow()
188 data->ed_pevtlist = new_pevtlist; in grow()
190 data->ed_maxevents = newsize; in grow()
H A Dbufferevent_async.c666 union bufferevent_ctrl_data *data) in be_async_ctrl() argument
670 data->fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_ctrl()
676 if (data->fd == evbuffer_overlapped_get_fd_(bev->input)) in be_async_ctrl()
680 if (event_iocp_port_associate_(iocp, data->fd, 1) < 0) { in be_async_ctrl()
684 evbuffer_overlapped_set_fd_(bev->input, data->fd); in be_async_ctrl()
685 evbuffer_overlapped_set_fd_(bev->output, data->fd); in be_async_ctrl()
686 bev_a->ok = data->fd >= 0; in be_async_ctrl()
H A Devrpc.c992 mm_free(entry->data); in evrpc_meta_data_free()
1030 const void *data, size_t data_size) in evrpc_hook_add_meta() argument
1044 meta->data = mm_malloc(data_size); in evrpc_hook_add_meta()
1045 EVUTIL_ASSERT(meta->data != NULL); in evrpc_hook_add_meta()
1046 memcpy(meta->data, data, data_size); in evrpc_hook_add_meta()
1052 evrpc_hook_find_meta(void *ctx, const char *key, void **data, size_t *data_size) in evrpc_hook_find_meta() argument
1062 *data = meta->data; in evrpc_hook_find_meta()
H A Devent_rpcgen.py1573 def ProcessStruct(factory, data): argument
1574 tokens = data.split(" ")
1620 data = ""
1659 data += line
1665 data += " " + line
1672 data += " %s}" % tokens[0]
1676 data = re.sub(r"/\*.*\*/", "", data)
1678 return data
1690 data = GetNextStruct(filep)
1692 if not data:
[all …]
H A Depoll.c198 epev.data.fd = epollop->timerfd; in epoll_init()
288 epev.data.fd = ch->fd; in epoll_apply_one_change()
485 if (events[i].data.fd == epollop->timerfd) in epoll_dispatch()
505 evmap_io_active_(base, events[i].data.fd, ev | EV_ET); in epoll_dispatch()
H A Dbuffer.c1195 char *data = data_out; in evbuffer_copyout_from() local
1231 memcpy(data, in evbuffer_copyout_from()
1234 data += copylen; in evbuffer_copyout_from()
1771 data, datlen); in evbuffer_add()
1804 data, remain); in evbuffer_add()
1810 data += remain; in evbuffer_add()
1813 memcpy(tmp->buffer, data, datlen); in evbuffer_add()
1868 data, datlen); in evbuffer_prepend()
3244 LPVOID data; in evbuffer_add_file_segment() local
3252 data = MapViewOfFile( in evbuffer_add_file_segment()
[all …]
/libevent-2.1.12/test/
H A Dregress_main.c312 data = calloc(1, sizeof(*data)); in basic_test_setup()
313 if (!data) in basic_test_setup()
315 data->base = base; in basic_test_setup()
319 return data; in basic_test_setup()
342 if (data->base) { in basic_test_cleanup()
351 free(data); in basic_test_cleanup()
369 if (data == (void*)TT_SKIP || data == NULL) in legacy_test_setup()
370 return data; in legacy_test_setup()
372 pair[0] = data->pair[0]; in legacy_test_setup()
373 pair[1] = data->pair[1]; in legacy_test_setup()
[all …]
H A Dregress_http.c518 exit_base = data->base; in http_basic_test_impl()
695 exit_base = data->base; in http_bad_request_test()
816 exit_base = data->base; in http_delete_test()
900 exit_base = data->base; in http_on_complete_test()
961 exit_base = data->base; in http_allowed_methods_test()
1087 data->base, -1, ssl, in http_connection_test_()
1103 exit_base = data->base; in http_connection_test_()
1198 exit_base = data->base; in http_connection_async_test()
1491 exit_base = data->base; in http_cancel_test()
1507 data->base, dns_base, in http_cancel_test()
[all …]
H A Dregress_listener.c73 struct basic_test_data *data = arg; in regress_pick_a_port() local
74 struct event_base *base = data->base; in regress_pick_a_port()
87 if (data->setup_data && strstr((char*)data->setup_data, "ts")) { in regress_pick_a_port()
150 int *data = data_; in errorcb() local
151 *data = 1000; in errorcb()
158 struct basic_test_data *data = arg; in regress_listener_error() local
164 if (data->setup_data && strstr((char*)data->setup_data, "ts")) { in regress_listener_error()
174 data->pair[0]); in regress_listener_error()
204 struct basic_test_data *data = arg; in regress_listener_close_accepted_fd() local
237 struct basic_test_data *data = arg; in regress_listener_immediate_close() local
[all …]
H A Dregress_bufferevent.c341 data->base = NULL; in free_lock_unlock_profiler()
356 free_lock_unlock_profiler(data); in test_bufferevent_pair_release_lock()
763 lev = evconnlistener_new_bind(data->base, listen_cb, data->base, in test_bufferevent_connect()
788 event_base_dispatch(data->base); in test_bufferevent_connect()
854 event_base_dispatch(data->base); in test_bufferevent_connect_fail_eventcb()
920 event_base_dispatch(data->base); in test_bufferevent_connect_fail()
999 bev1 = bufferevent_socket_new(data->base, data->pair[0], 0); in test_bufferevent_timeouts()
1000 bev2 = bufferevent_socket_new(data->base, data->pair[1], 0); in test_bufferevent_timeouts()
1044 event_base_dispatch(data->base); in test_bufferevent_timeouts()
1171 lev = evconnlistener_new_bind(data->base, listen_cb, data->base, in test_bufferevent_trigger()
[all …]
H A Dregress.c864 data->base = NULL; in test_common_timeout()
1865 ev2 = event_new(data->base, data->pair[1], EV_WRITE|EV_PERSIST, write_a_byte_cb, NULL); in test_active_later()
1903 event_base_free(data->base); in test_active_later()
1904 data->base = NULL; in test_active_later()
2805 r = event_base_once(data->base, data->pair[0], EV_READ, in test_event_once()
2869 r = event_new(data->base, data->pair[0], EV_READ, simple_read_cb, in test_event_pending()
2871 w = event_new(data->base, data->pair[1], EV_WRITE, simple_write_cb, in test_event_pending()
2913 *(int*)data = (int)e; in dfd_cb()
2929 e = event_new(data->base, data->pair[0], EV_READ, dfd_cb, &i); in test_event_closed_fd_poll()
2936 close(data->pair[0]); in test_event_closed_fd_poll()
[all …]
H A Dregress_ssl.c492 fd_pair = data->pair; in regress_bufferevent_openssl()
494 bev_ll[0] = bufferevent_socket_new(data->base, data->pair[0], in regress_bufferevent_openssl()
496 bev_ll[1] = bufferevent_socket_new(data->base, data->pair[1], in regress_bufferevent_openssl()
512 exit_base = data->base; in regress_bufferevent_openssl()
762 data->base, -1, ssl, in regress_bufferevent_openssl_connect()
803 struct evbuffer *data; member
916 client.data = evbuffer_new(); in regress_bufferevent_openssl_wm()
917 server.data = evbuffer_new(); in regress_bufferevent_openssl_wm()
953 data->base, -1, ssl, in regress_bufferevent_openssl_wm()
980 evbuffer_free(client.data); in regress_bufferevent_openssl_wm()
[all …]
H A Dregress_iocp.c239 struct basic_test_data *data = ptr; in test_iocp_evbuffer() local
253 rbuf = evbuffer_overlapped_new_(data->pair[0]); in test_iocp_evbuffer()
254 wbuf = evbuffer_overlapped_new_(data->pair[1]); in test_iocp_evbuffer()
263 tt_assert(!event_iocp_port_associate_(port, data->pair[0], 100)); in test_iocp_evbuffer()
264 tt_assert(!event_iocp_port_associate_(port, data->pair[1], 100)); in test_iocp_evbuffer()
307 struct basic_test_data *data = ptr; in test_iocp_bufferevent_async() local
313 event_base_start_iocp_(data->base, 0); in test_iocp_bufferevent_async()
314 port = event_base_get_iocp_(data->base); in test_iocp_bufferevent_async()
317 bea1 = bufferevent_async_new_(data->base, data->pair[0], in test_iocp_bufferevent_async()
319 bea2 = bufferevent_async_new_(data->base, data->pair[1], in test_iocp_bufferevent_async()
[all …]
H A Dregress_et.c81 struct basic_test_data *data = data_; in test_edgetriggered() local
82 struct event_base *base = data->base; in test_edgetriggered()
83 evutil_socket_t *pair = data->pair; in test_edgetriggered()
138 struct basic_test_data *data = data_; in test_edgetriggered_mix_error() local
153 ev_et = event_new(base, data->pair[0], EV_READ|EV_ET, read_cb, ev_et); in test_edgetriggered_mix_error()
155 ev_lt = event_new(base, data->pair[0], EV_READ, read_cb, ev_lt); in test_edgetriggered_mix_error()
207 struct basic_test_data *data = data_; in test_edge_triggered_multiple_events() local
211 struct event_base *base = data->base; in test_edge_triggered_multiple_events()
212 evutil_socket_t *pair = data->pair; in test_edge_triggered_multiple_events()
H A Dregress_thread.c173 struct basic_test_data *data = arg; in thread_basic() local
174 struct event_base *base = data->base; in thread_basic()
188 if (data->setup_data && !strcmp(data->setup_data, "forking")) { in thread_basic()
300 struct basic_test_data *data = arg; in thread_conditions_simple() local
301 struct event_base *base = data->base; in thread_conditions_simple()
422 struct deferred_test_data *data = arg; in load_deferred_queue() local
428 event_deferred_cb_schedule_(data->queue, &data->cbs[i]); in load_deferred_queue()
532 struct basic_test_data *data = arg; in thread_no_events() local
535 exit_base = data->base; in thread_no_events()
539 event_assign(&time_events[i], data->base, in thread_no_events()
[all …]
H A Dregress_dns.c542 struct basic_test_data *data = arg; in dns_search_test_impl() local
605 struct basic_test_data *data = arg; in dns_search_empty_test() local
654 struct basic_test_data *data = arg; in dns_search_cancel_test() local
696 int *count = data; in fail_server_cb()
729 struct basic_test_data *data = arg; in dns_retry_test_impl() local
828 struct basic_test_data *data = arg; in dns_reissue_test_impl() local
904 struct basic_test_data *data = arg; in dns_inflight_test_impl() local
1072 int *n_got_p=data; in be_getaddrinfo_server_cb()
1267 int emfile = data->setup_data && !strcmp(data->setup_data, "emfile"); in test_bufferevent_connect_hostname()
1703 event_base_dispatch(data->base); in test_getaddrinfo_async()
[all …]
H A Dregress_finalize.c75 struct basic_test_data *data = arg; in test_fin_cb_invoked() local
76 struct event_base *base = data->base; in test_fin_cb_invoked()
257 struct basic_test_data *data = arg; in test_fin_within_cb() local
258 struct event_base *base = data->base; in test_fin_within_cb()
313 struct basic_test_data *data = arg; in test_fin_debug_use_after_free() local
314 struct event_base *base = data->base; in test_fin_debug_use_after_free()
351 struct basic_test_data *data = arg;
352 struct event_base *base = data->base;
H A Dregress_buffer.c830 char data[4096]; in test_evbuffer_expand() local
835 memset(data, 'X', sizeof(data)); in test_evbuffer_expand()
887 evbuffer_add(buf, data, sizeof(data)); in test_evbuffer_expand()
888 evbuffer_add(buf, data, sizeof(data)); in test_evbuffer_expand()
889 evbuffer_add(buf, data, sizeof(data)); in test_evbuffer_expand()
952 memset(data, 'P', sizeof(data)); in test_evbuffer_add2()
994 tt_assert(evbuffer_add_reference(src, data, strlen(data), in test_evbuffer_reference()
1020 data, strlen(data))); in test_evbuffer_reference()
1037 memset(data, 'P', sizeof(data)); in test_evbuffer_reference2()
1291 if (data) in test_evbuffer_add_file()
[all …]
H A Dtinytest_demo.c50 test_strcmp(void *data) in test_strcmp() argument
52 (void)data; /* This testcase takes no data. */ in test_strcmp()
H A Dregress_testutils.c150 regress_dns_server_cb(struct evdns_server_request *req, void *data) in regress_dns_server_cb() argument
152 struct regress_dns_server_table *tab = data; in regress_dns_server_cb()
H A Dregress_testutils.h52 struct evdns_server_request *req, void *data);
/libevent-2.1.12/include/event2/
H A Dtag.h75 void evtag_marshal(struct evbuffer *evbuf, ev_uint32_t tag, const void *data,
79 struct evbuffer *data);
132 void *data, size_t len);
H A Dbuffer.h336 int evbuffer_add(struct evbuffer *buf, const void *data, size_t datlen);
351 int evbuffer_remove(struct evbuffer *buf, void *data, size_t datlen);
479 typedef void (*evbuffer_ref_cleanup_cb)(const void *data,
499 const void *data, size_t datlen,
1006 int evbuffer_prepend(struct evbuffer *buf, const void *data, size_t size);

123