Home
last modified time | relevance | path

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

12

/external/libevent/include/event2/
Dbuffer.h95 struct evbuffer struct
143 struct evbuffer *evbuffer_new(void);
149 void evbuffer_free(struct evbuffer *buf);
163 int evbuffer_enable_locking(struct evbuffer *buf, void *lock);
169 void evbuffer_lock(struct evbuffer *buf);
175 void evbuffer_unlock(struct evbuffer *buf);
202 int evbuffer_set_flags(struct evbuffer *buf, ev_uint64_t flags);
210 int evbuffer_clear_flags(struct evbuffer *buf, ev_uint64_t flags);
218 size_t evbuffer_get_length(const struct evbuffer *buf);
232 size_t evbuffer_get_contiguous_space(const struct evbuffer *buf);
[all …]
Dtag.h51 struct evbuffer;
68 int evtag_unmarshal_header(struct evbuffer *evbuf, ev_uint32_t *ptag);
70 void evtag_marshal(struct evbuffer *evbuf, ev_uint32_t tag, const void *data,
72 void evtag_marshal_buffer(struct evbuffer *evbuf, ev_uint32_t tag,
73 struct evbuffer *data);
85 void evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number);
86 void evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number);
88 void evtag_marshal_int(struct evbuffer *evbuf, ev_uint32_t tag,
90 void evtag_marshal_int64(struct evbuffer *evbuf, ev_uint32_t tag,
93 void evtag_marshal_string(struct evbuffer *buf, ev_uint32_t tag,
[all …]
Drpc.h145 struct evbuffer;
179 struct evbuffer* rpc_data; \
193 void (*req_marshal)(struct evbuffer*, void *),
195 int (*rpl_unmarshal)(void *, struct evbuffer *),
217 (void (*)(struct evbuffer *, void *))reqstruct##_marshal, \
219 (int (*)(void *, struct evbuffer *))rplystruct##_unmarshal, \
243 (void (*)(struct evbuffer *, void *))reqstruct##_marshal, \
245 (int (*)(void *, struct evbuffer *))rplystruct##_unmarshal); \
324 (int (*)(void *, struct evbuffer *))request##_unmarshal, \
328 (void (*)(struct evbuffer *, void *))reply##_marshal)
[all …]
Dbuffer_compat.h48 char *evbuffer_readline(struct evbuffer *buffer);
70 typedef void (*evbuffer_cb)(struct evbuffer *buffer, size_t old_len, size_t new_len, void *arg);
91 void evbuffer_setcb(struct evbuffer *buffer, evbuffer_cb cb, void *cbarg);
102 unsigned char *evbuffer_find(struct evbuffer *buffer, const unsigned char *what, size_t len);
Dbufferevent.h117 struct evbuffer;
350 int bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf);
373 int bufferevent_read_buffer(struct bufferevent *bufev, struct evbuffer *buf);
384 struct evbuffer *bufferevent_get_input(struct bufferevent *bufev);
398 struct evbuffer *bufferevent_get_output(struct bufferevent *bufev);
556 struct evbuffer *src, struct evbuffer *dst, ev_ssize_t dst_limit,
Dhttp.h38 struct evbuffer;
325 const char *reason, struct evbuffer *databuf);
358 struct evbuffer *databuf);
544 struct evbuffer *evhttp_request_get_input_buffer(struct evhttp_request *req);
546 struct evbuffer *evhttp_request_get_output_buffer(struct evhttp_request *req);
Drpc_struct.h73 int (*request_unmarshal)(void *, struct evbuffer *);
86 void (*reply_marshal)(struct evbuffer*, void *);
Dbufferevent_struct.h88 struct evbuffer *input;
92 struct evbuffer *output;
Dhttp_struct.h106 struct evbuffer *input_buffer; /* read data */
111 struct evbuffer *output_buffer; /* outgoing post or data */
/external/libevent/
Devent_tagging.c94 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
95 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
96 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag);
97 int evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf);
151 evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number) in evtag_encode_int()
159 evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number) in evtag_encode_int64()
172 evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag) in evtag_encode_tag()
195 decode_tag_internal(ev_uint32_t *ptag, struct evbuffer *evbuf, int dodrain) in decode_tag_internal()
236 evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf) in evtag_decode_tag()
248 evtag_marshal(struct evbuffer *evbuf, ev_uint32_t tag, in evtag_marshal()
[all …]
Diocp-internal.h36 struct evbuffer;
115 struct evbuffer *evbuffer_overlapped_new(evutil_socket_t fd);
118 evutil_socket_t _evbuffer_overlapped_get_fd(struct evbuffer *buf);
120 void _evbuffer_overlapped_set_fd(struct evbuffer *buf, evutil_socket_t fd);
134 int evbuffer_launch_read(struct evbuffer *buf, size_t n, struct event_overlapped *ol);
148 int evbuffer_launch_write(struct evbuffer *buf, ev_ssize_t n, struct event_overlapped *ol);
151 void evbuffer_commit_read(struct evbuffer *, ev_ssize_t);
152 void evbuffer_commit_write(struct evbuffer *, ev_ssize_t);
Devbuffer-internal.h78 struct evbuffer { struct
250 void _evbuffer_incref(struct evbuffer *buf);
252 void _evbuffer_incref_and_lock(struct evbuffer *buf);
260 void _evbuffer_decref_and_unlock(struct evbuffer *buffer);
264 int _evbuffer_expand_fast(struct evbuffer *, size_t, int);
272 int _evbuffer_read_setup_vecs(struct evbuffer *buf, ev_ssize_t howmuch,
285 void evbuffer_set_parent(struct evbuffer *buf, struct bufferevent *bev);
287 void evbuffer_invoke_callbacks(struct evbuffer *buf);
Dbuffer.c143 static int evbuffer_ptr_memcmp(const struct evbuffer *buf,
145 static struct evbuffer_chain *evbuffer_expand_singlechain(struct evbuffer *buf,
149 static int evbuffer_readfile(struct evbuffer *buf, evutil_socket_t fd,
274 evbuffer_free_trailing_empty_chains(struct evbuffer *buf) in evbuffer_free_trailing_empty_chains()
292 evbuffer_chain_insert(struct evbuffer *buf, in evbuffer_chain_insert()
323 evbuffer_chain_insert_new(struct evbuffer *buf, size_t datlen) in evbuffer_chain_insert_new()
348 struct evbuffer *
351 struct evbuffer *buffer; in evbuffer_new()
353 buffer = mm_calloc(1, sizeof(struct evbuffer)); in evbuffer_new()
365 evbuffer_set_flags(struct evbuffer *buf, ev_uint64_t flags) in evbuffer_set_flags()
[all …]
Dbuffer_iocp.c53 struct evbuffer buffer;
73 upcast_evbuffer(struct evbuffer *buf) in upcast_evbuffer()
96 evbuffer_commit_read(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_read()
137 evbuffer_commit_write(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_write()
150 struct evbuffer *
170 evbuffer_launch_write(struct evbuffer *buf, ev_ssize_t at_most, in evbuffer_launch_write()
244 evbuffer_launch_read(struct evbuffer *buf, size_t at_most, in evbuffer_launch_read()
310 _evbuffer_overlapped_get_fd(struct evbuffer *buf) in _evbuffer_overlapped_get_fd()
317 _evbuffer_overlapped_set_fd(struct evbuffer *buf, evutil_socket_t fd) in _evbuffer_overlapped_set_fd()
Devrpc-internal.h44 struct evbuffer *, void *);
159 struct evbuffer* rpc_data;
195 void (*request_marshal)(struct evbuffer *, void *);
201 int (*reply_unmarshal)(void *, struct evbuffer*);
Dhttp-internal.h40 struct evbuffer;
186 enum message_read_status evhttp_parse_firstline(struct evhttp_request *, struct evbuffer*);
187 enum message_read_status evhttp_parse_headers(struct evhttp_request *, struct evbuffer*);
193 void evhttp_send_page(struct evhttp_request *, struct evbuffer *);
Dwhatsnew-2.0.txt67 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
331 Libevent has long had an "evbuffer" implementation to wrap access to an
338 Previously, each evbuffer was a huge chunk of memory. When we ran out of
339 space in an evbuffer, we used realloc() to grow the chunk of memory. When
356 The evbuffer struct is no longer exposed in a header. The code here is
357 too volatile to expose an official evbuffer structure, and there was never
358 any means provided to create an evbuffer except via evbuffer_new which
375 in an evbuffer without ever extracting the line.
379 You can now add chunks of a file into a evbuffer, and Libevent will have
[all …]
Devrpc.c121 int (*cb)(void *, struct evhttp_request *, struct evbuffer *, void *), in evrpc_add_hook() argument
188 struct evhttp_request *req, struct evbuffer *evbuf) in evrpc_process_hooks()
828 void (*req_marshal)(struct evbuffer*, void *), in evrpc_make_request_ctx() argument
830 int (*rpl_unmarshal)(void *, struct evbuffer *), in evrpc_make_request_ctx() argument
1087 void (*req_marshal)(struct evbuffer *, void *), in evrpc_send_request_generic() argument
1089 int (*rpl_unmarshal)(void *, struct evbuffer *)) in evrpc_send_request_generic()
1109 int (*req_unmarshal)(void *, struct evbuffer *), in evrpc_register_object() argument
1112 void (*rpl_marshal)(struct evbuffer *, void *)) in evrpc_register_object() argument
1138 int (*req_unmarshal)(void *, struct evbuffer *), in evrpc_register_generic() argument
1141 void (*rpl_marshal)(struct evbuffer *, void *)) in evrpc_register_generic() argument
Dbufferevent_filter.c71 static void bufferevent_filtered_outbuf_cb(struct evbuffer *buf,
150 be_null_filter(struct evbuffer *src, struct evbuffer *dst, ev_ssize_t lim, in be_null_filter()
396 bufferevent_filtered_outbuf_cb(struct evbuffer *buf, in bufferevent_filtered_outbuf_cb()
Dbufferevent_openssl.c134 struct evbuffer *input; in bio_bufferevent_read()
160 struct evbuffer *output; in bio_bufferevent_write()
569 struct evbuffer *input = bev->input; in do_read()
639 struct evbuffer *output = bev->output; in do_write()
722 struct evbuffer *input = bev->bev.bev.input; in bytes_to_read()
822 struct evbuffer *input = bev->input; in consider_reading()
842 struct evbuffer *output = bev_ssl->bev.bev.output; in consider_writing()
843 struct evbuffer *target = NULL; in consider_writing()
850 struct evbuffer *input = bev->input; in consider_writing()
1108 be_openssl_outbuf_cb(struct evbuffer *buf, in be_openssl_outbuf_cb()
Dhttp.c596 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_make_header()
842 evhttp_handle_chunked_read(struct evhttp_request *req, struct evbuffer *buf) in evhttp_handle_chunked_read()
935 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_read_trailer()
957 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_read_body()
1075 struct evbuffer *input; in evhttp_read_cb()
1222 struct evbuffer *tmp; in evhttp_connection_reset()
1722 evhttp_parse_firstline(struct evhttp_request *req, struct evbuffer *buffer) in evhttp_parse_firstline()
1787 evhttp_parse_headers(struct evhttp_request *req, struct evbuffer* buffer) in evhttp_parse_headers()
2384 struct evbuffer *buf = evbuffer_new(); in evhttp_send_error()
2407 evhttp_send(struct evhttp_request *req, struct evbuffer *databuf) in evhttp_send()
[all …]
Dbufferevent.c117 bufferevent_inbuf_wm_cb(struct evbuffer *buf, in bufferevent_inbuf_wm_cb()
358 struct evbuffer *
364 struct evbuffer *
386 bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf) in bufferevent_write_buffer()
401 bufferevent_read_buffer(struct bufferevent *bufev, struct evbuffer *buf) in bufferevent_read_buffer()
Dbufferevent_pair.c87 static void be_pair_outbuf_cb(struct evbuffer *,
210 be_pair_outbuf_cb(struct evbuffer *outbuf, in be_pair_outbuf_cb()
Dbufferevent_sock.c102 bufferevent_socket_outbuf_cb(struct evbuffer *buf, in bufferevent_socket_outbuf_cb()
128 struct evbuffer *input; in bufferevent_readcb()
Dbufferevent_async.c283 be_async_outbuf_callback(struct evbuffer *buf, in be_async_outbuf_callback()
302 be_async_inbuf_callback(struct evbuffer *buf, in be_async_inbuf_callback()

12