| /libevent-2.1.12/include/event2/ |
| H A D | buffer.h | 97 struct evbuffer struct
152 struct evbuffer *evbuffer_new(void);
159 void evbuffer_free(struct evbuffer *buf);
181 void evbuffer_lock(struct evbuffer *buf);
188 void evbuffer_unlock(struct evbuffer *buf);
324 int evbuffer_commit_space(struct evbuffer *buf,
396 int evbuffer_remove_buffer(struct evbuffer *src, struct evbuffer *dst,
454 int evbuffer_add_buffer(struct evbuffer *outbuf, struct evbuffer *inbuf);
471 struct evbuffer *inbuf);
498 int evbuffer_add_reference(struct evbuffer *outbuf,
[all …]
|
| H A D | tag.h | 53 struct evbuffer;
78 void evtag_marshal_buffer(struct evbuffer *evbuf, ev_uint32_t tag,
79 struct evbuffer *data);
92 void evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number);
97 void evtag_marshal_int(struct evbuffer *evbuf, ev_uint32_t tag,
100 void evtag_marshal_int64(struct evbuffer *evbuf, ev_uint32_t tag,
104 void evtag_marshal_string(struct evbuffer *buf, ev_uint32_t tag,
112 int evtag_unmarshal(struct evbuffer *src, ev_uint32_t *ptag,
113 struct evbuffer *dst);
115 int evtag_peek(struct evbuffer *evbuf, ev_uint32_t *ptag);
[all …]
|
| H A D | rpc.h | 149 struct evbuffer;
183 struct evbuffer* rpc_data; \
199 void (*req_marshal)(struct evbuffer*, void *),
201 int (*rpl_unmarshal)(void *, struct evbuffer *),
223 (void (*)(struct evbuffer *, void *))reqstruct##_marshal, \
335 (int (*)(void *, struct evbuffer *))request##_unmarshal, \
339 (void (*)(struct evbuffer *, void *))reply##_marshal)
591 void (*req_marshal)(struct evbuffer *, void *),
593 int (*rpl_unmarshal)(void *, struct evbuffer *));
606 int (*req_unmarshal)(void *, struct evbuffer *),
[all …]
|
| H A D | buffer_compat.h | 51 char *evbuffer_readline(struct evbuffer *buffer);
73 typedef void (*evbuffer_cb)(struct evbuffer *buffer, size_t old_len, size_t new_len, void *arg);
96 int evbuffer_setcb(struct evbuffer *buffer, evbuffer_cb cb, void *cbarg);
108 unsigned char *evbuffer_find(struct evbuffer *buffer, const unsigned char *what, size_t len);
|
| H A D | bufferevent.h | 119 struct evbuffer;
400 int bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf);
425 int bufferevent_read_buffer(struct bufferevent *bufev, struct evbuffer *buf);
437 struct evbuffer *bufferevent_get_input(struct bufferevent *bufev);
452 struct evbuffer *bufferevent_get_output(struct bufferevent *bufev);
704 struct evbuffer *src, struct evbuffer *dst, ev_ssize_t dst_limit,
|
| H A D | bufferevent_struct.h | 88 struct evbuffer *input;
92 struct evbuffer *output;
|
| H A D | rpc_struct.h | 83 int (*request_unmarshal)(void *, struct evbuffer *);
96 void (*reply_marshal)(struct evbuffer*, void *);
|
| H A D | http.h | 39 struct evbuffer;
419 const char *reason, struct evbuffer *databuf);
454 struct evbuffer *databuf);
470 void evhttp_send_reply_chunk_with_cb(struct evhttp_request *, struct evbuffer *,
840 struct evbuffer *evhttp_request_get_input_buffer(struct evhttp_request *req);
843 struct evbuffer *evhttp_request_get_output_buffer(struct evhttp_request *req);
|
| H A D | http_struct.h | 106 struct evbuffer *input_buffer; /* read data */
111 struct evbuffer *output_buffer; /* outgoing post or data */
|
| /libevent-2.1.12/ |
| H A D | event_tagging.c | 101 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag);
157 evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number) in evtag_encode_int()
178 evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag) in evtag_encode_tag()
249 evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf) in evtag_decode_tag()
261 evtag_marshal(struct evbuffer *evbuf, ev_uint32_t tag, in evtag_marshal()
270 evtag_marshal_buffer(struct evbuffer *evbuf, ev_uint32_t tag, in evtag_marshal_buffer()
271 struct evbuffer *data) in evtag_marshal_buffer()
292 evtag_marshal_int64(struct evbuffer *evbuf, ev_uint32_t tag, in evtag_marshal_int64()
400 evtag_peek(struct evbuffer *evbuf, ev_uint32_t *ptag) in evtag_peek()
458 evtag_consume(struct evbuffer *evbuf) in evtag_consume()
[all …]
|
| H A D | evbuffer-internal.h | 80 struct evbuffer { struct
272 struct evbuffer *source;
303 void evbuffer_incref_(struct evbuffer *buf);
305 void evbuffer_incref_and_lock_(struct evbuffer *buf);
313 void evbuffer_decref_and_unlock_(struct evbuffer *buffer);
317 int evbuffer_expand_fast_(struct evbuffer *, size_t, int);
325 int evbuffer_read_setup_vecs_(struct evbuffer *buf, ev_ssize_t howmuch,
338 void evbuffer_set_parent_(struct evbuffer *buf, struct bufferevent *bev);
340 void evbuffer_invoke_callbacks_(struct evbuffer *buf);
343 int evbuffer_get_callbacks_(struct evbuffer *buffer,
|
| H A D | iocp-internal.h | 36 struct evbuffer;
118 struct evbuffer *evbuffer_overlapped_new_(evutil_socket_t fd);
121 evutil_socket_t evbuffer_overlapped_get_fd_(struct evbuffer *buf);
123 void evbuffer_overlapped_set_fd_(struct evbuffer *buf, evutil_socket_t fd);
138 int evbuffer_launch_read_(struct evbuffer *buf, size_t n, struct event_overlapped *ol);
153 int evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t n, struct event_overlapped *ol);
157 void evbuffer_commit_read_(struct evbuffer *, ev_ssize_t);
159 void evbuffer_commit_write_(struct evbuffer *, ev_ssize_t);
|
| H A D | buffer.c | 361 struct evbuffer *
364 struct evbuffer *buffer; in evbuffer_new()
537 struct evbuffer *buffer = arg; in evbuffer_deferred_callback()
875 COPY_CHAIN(struct evbuffer *dst, struct evbuffer *src) in COPY_CHAIN()
889 APPEND_CHAIN(struct evbuffer *dst, struct evbuffer *src) in APPEND_CHAIN()
908 APPEND_CHAIN_MULTICAST(struct evbuffer *dst, struct evbuffer *src) in APPEND_CHAIN_MULTICAST()
948 PREPEND_CHAIN(struct evbuffer *dst, struct evbuffer *src) in PREPEND_CHAIN()
966 evbuffer_add_buffer(struct evbuffer *outbuf, struct evbuffer *inbuf) in evbuffer_add_buffer()
1012 evbuffer_add_buffer_reference(struct evbuffer *outbuf, struct evbuffer *inbuf) in evbuffer_add_buffer_reference()
1055 evbuffer_prepend_buffer(struct evbuffer *outbuf, struct evbuffer *inbuf) in evbuffer_prepend_buffer()
[all …]
|
| H A D | buffer_iocp.c | 55 struct evbuffer buffer;
75 upcast_evbuffer(struct evbuffer *buf) in upcast_evbuffer()
98 evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_read_()
139 evbuffer_commit_write_(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_write_()
152 struct evbuffer *
172 evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t at_most, in evbuffer_launch_write_()
246 evbuffer_launch_read_(struct evbuffer *buf, size_t at_most, in evbuffer_launch_read_()
312 evbuffer_overlapped_get_fd_(struct evbuffer *buf) in evbuffer_overlapped_get_fd_()
319 evbuffer_overlapped_set_fd_(struct evbuffer *buf, evutil_socket_t fd) in evbuffer_overlapped_set_fd_()
|
| H A D | evrpc-internal.h | 45 struct evbuffer *, void *);
160 struct evbuffer* rpc_data;
196 void (*request_marshal)(struct evbuffer *, void *);
202 int (*reply_unmarshal)(void *, struct evbuffer*);
|
| H A D | http-internal.h | 29 struct evbuffer;
191 enum message_read_status evhttp_parse_firstline_(struct evhttp_request *, struct evbuffer*);
193 enum message_read_status evhttp_parse_headers_(struct evhttp_request *, struct evbuffer*);
200 void evhttp_send_page_(struct evhttp_request *, struct evbuffer *);
|
| H A D | whatsnew-2.0.txt | 67 The core event logic is now in event2/event.h. The "evbuffer" functions
241 To make an evbuffer or a bufferevent object threadsafe, call its
375 in an evbuffer without ever extracting the line.
389 You can add a piece of memory to an evbuffer without copying it.
396 4.5. Multiple callbacks per evbuffer
400 evbuffer callback to notice when an internal evbuffer was reading or
401 writing data, you couldn't have your own callback on that evbuffer.
421 4.7. Misc new evbuffer features
427 a pattern inside an evbuffer.
430 to a given evbuffer. This is useful for code that exposes an evbuffer as
[all …]
|
| H A D | bufferevent_filter.c | 74 static void bufferevent_filtered_inbuf_cb(struct evbuffer *buf,
77 static void bufferevent_filtered_outbuf_cb(struct evbuffer *buf,
159 be_null_filter(struct evbuffer *src, struct evbuffer *dst, ev_ssize_t lim, in be_null_filter()
421 bufferevent_filtered_outbuf_cb(struct evbuffer *buf, in bufferevent_filtered_outbuf_cb()
483 bufferevent_filtered_inbuf_cb(struct evbuffer *buf, in bufferevent_filtered_inbuf_cb()
|
| H A D | evrpc.c | 122 int (*cb)(void *, struct evhttp_request *, struct evbuffer *, void *), in evrpc_add_hook() argument
189 struct evhttp_request *req, struct evbuffer *evbuf) in evrpc_process_hooks()
826 void (*req_marshal)(struct evbuffer*, void *), in evrpc_make_request_ctx() argument
828 int (*rpl_unmarshal)(void *, struct evbuffer *), in evrpc_make_request_ctx() argument
1084 void (*req_marshal)(struct evbuffer *, void *), in evrpc_send_request_generic() argument
1086 int (*rpl_unmarshal)(void *, struct evbuffer *)) in evrpc_send_request_generic()
1106 int (*req_unmarshal)(void *, struct evbuffer *), in evrpc_register_object() argument
1109 void (*rpl_marshal)(struct evbuffer *, void *)) in evrpc_register_object() argument
1135 int (*req_unmarshal)(void *, struct evbuffer *), in evrpc_register_generic() argument
1138 void (*rpl_marshal)(struct evbuffer *, void *)) in evrpc_register_generic() argument
|
| H A D | http.c | 999 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_read_trailer()
1163 struct evbuffer *input; in evhttp_read_cb()
1332 struct evbuffer *tmp; in evhttp_connection_reset_()
1458 struct evbuffer *buf; in evhttp_connection_read_on_write_error()
2810 struct evbuffer *buf = evbuffer_new(); in evhttp_send_error()
2859 struct evbuffer *databuf) in evhttp_send_reply()
2898 struct evbuffer *output; in evhttp_send_reply_chunk_with_cb()
2929 struct evbuffer *output; in evhttp_send_reply_end()
3112 struct evbuffer *buf = evbuffer_new(); in evhttp_uriencode()
3513 struct evbuffer *buf; in evhttp_handle_request()
[all …]
|
| /libevent-2.1.12/test/ |
| H A D | regress_buffer.c | 431 struct evbuffer *buf = NULL; in test_evbuffer_pullup_with_empty()
773 struct evbuffer *buf; in test_evbuffer_reserve_with_empty()
831 struct evbuffer *buf; in test_evbuffer_expand()
904 struct evbuffer *buf; in test_evbuffer_expand_overflow()
921 struct evbuffer *buf; in test_evbuffer_add1()
946 struct evbuffer *buf; in test_evbuffer_add2()
1031 struct evbuffer *buf; in test_evbuffer_reference2()
1066 struct evbuffer *b = arg; in addfile_test_writecb()
1092 struct evbuffer *b = arg; in addfile_test_readcb()
1936 self_draining_callback(struct evbuffer *evbuffer, size_t old_len, in self_draining_callback() argument
[all …]
|
| H A D | regress_zlib.c | 131 zlib_input_filter(struct evbuffer *src, struct evbuffer *dst, in zlib_input_filter()
185 zlib_output_filter(struct evbuffer *src, struct evbuffer *dst, in zlib_output_filter()
246 struct evbuffer *evbuf = evbuffer_new(); in readcb()
|
| H A D | bench_http.c | 59 struct evbuffer *evb = evbuffer_new(); in http_basic_cb()
73 struct evbuffer *evb = evbuffer_new(); in http_ref_cb()
|
| H A D | test-ratelim.c | 131 struct evbuffer *output = bufferevent_get_output(bev); in loud_writecb()
145 struct evbuffer *input = bufferevent_get_input(bev); in discard_readcb()
164 struct evbuffer *input = bufferevent_get_input(bev); in echo_readcb()
165 struct evbuffer *output = bufferevent_get_output(bev); in echo_readcb()
175 struct evbuffer *output = bufferevent_get_output(bev); in echo_writecb()
|
| H A D | regress_bufferevent.c | 108 struct evbuffer *evbuf = evbuffer_new(); in readcb()
369 struct evbuffer *evbuf = evbuffer_new(); in wm_readcb()
495 bufferevent_input_filter(struct evbuffer *src, struct evbuffer *dst, in bufferevent_input_filter()
517 bufferevent_output_filter(struct evbuffer *src, struct evbuffer *dst, in bufferevent_output_filter()
1266 struct evbuffer *input = bufferevent_get_input(bev); in bufferevent_filter_data_stuck_readcb()
1277 struct evbuffer *src, struct evbuffer *dst, ev_ssize_t dst_limit, in bufferevent_filter_data_stuck_inputcb()
|