Home
last modified time | relevance | path

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

12

/external/libevent/include/event2/
Dbuffer.h97 struct evbuffer struct
152 struct evbuffer *evbuffer_new(void);
159 void evbuffer_free(struct evbuffer *buf);
174 int evbuffer_enable_locking(struct evbuffer *buf, void *lock);
181 void evbuffer_lock(struct evbuffer *buf);
188 void evbuffer_unlock(struct evbuffer *buf);
216 int evbuffer_set_flags(struct evbuffer *buf, ev_uint64_t flags);
225 int evbuffer_clear_flags(struct evbuffer *buf, ev_uint64_t flags);
234 size_t evbuffer_get_length(const struct evbuffer *buf);
249 size_t evbuffer_get_contiguous_space(const struct evbuffer *buf);
[all …]
Dtag.h53 struct evbuffer;
72 int evtag_unmarshal_header(struct evbuffer *evbuf, ev_uint32_t *ptag);
75 void evtag_marshal(struct evbuffer *evbuf, ev_uint32_t tag, const void *data,
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);
94 void evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_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,
[all …]
Drpc.h149 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, \
225 (int (*)(void *, struct evbuffer *))rplystruct##_unmarshal, \
249 (void (*)(struct evbuffer *, void *))reqstruct##_marshal, \
251 (int (*)(void *, struct evbuffer *))rplystruct##_unmarshal); \
335 (int (*)(void *, struct evbuffer *))request##_unmarshal, \
339 (void (*)(struct evbuffer *, void *))reply##_marshal)
[all …]
Dbuffer_compat.h51 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);
Dbufferevent.h119 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,
Dbufferevent_struct.h88 struct evbuffer *input;
92 struct evbuffer *output;
Drpc_struct.h83 int (*request_unmarshal)(void *, struct evbuffer *);
96 void (*reply_marshal)(struct evbuffer*, void *);
Dhttp.h39 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);
Dhttp_struct.h106 struct evbuffer *input_buffer; /* read data */
111 struct evbuffer *output_buffer; /* outgoing post or data */
/external/libevent/
Devent_tagging.c97 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
99 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
101 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag);
103 int evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf);
157 evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number) in evtag_encode_int()
165 evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number) in evtag_encode_int64()
178 evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag) in evtag_encode_tag()
201 decode_tag_internal(ev_uint32_t *ptag, struct evbuffer *evbuf, int dodrain) in decode_tag_internal()
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()
[all …]
Devbuffer-internal.h80 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,
Diocp-internal.h36 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);
Dbuffer.c147 static int evbuffer_ptr_memcmp(const struct evbuffer *buf,
149 static struct evbuffer_chain *evbuffer_expand_singlechain(struct evbuffer *buf,
151 static int evbuffer_ptr_subtract(struct evbuffer *buf, struct evbuffer_ptr *pos,
291 evbuffer_free_trailing_empty_chains(struct evbuffer *buf) in evbuffer_free_trailing_empty_chains()
309 evbuffer_chain_insert(struct evbuffer *buf, in evbuffer_chain_insert()
330 evbuffer_chain_insert_new(struct evbuffer *buf, size_t datlen) in evbuffer_chain_insert_new()
361 struct evbuffer *
364 struct evbuffer *buffer; in evbuffer_new()
366 buffer = mm_calloc(1, sizeof(struct evbuffer)); in evbuffer_new()
378 evbuffer_set_flags(struct evbuffer *buf, ev_uint64_t flags) in evbuffer_set_flags()
[all …]
Dbuffer_iocp.c55 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_()
Devrpc-internal.h45 struct evbuffer *, void *);
160 struct evbuffer* rpc_data;
196 void (*request_marshal)(struct evbuffer *, void *);
202 int (*reply_unmarshal)(void *, struct evbuffer*);
Dhttp-internal.h29 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 *);
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 …]
Dbufferevent_filter.c74 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()
Devrpc.c122 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
/external/libevent/test/
Dregress.gen.h58 void msg_marshal(struct evbuffer *, const struct msg *);
59 int msg_unmarshal(struct msg *, struct evbuffer *);
61 void evtag_marshal_msg(struct evbuffer *, ev_uint32_t,
63 int evtag_unmarshal_msg(struct evbuffer *, ev_uint32_t,
113 void kill_marshal(struct evbuffer *, const struct kill *);
114 int kill_unmarshal(struct kill *, struct evbuffer *);
116 void evtag_marshal_kill(struct evbuffer *, ev_uint32_t,
118 int evtag_unmarshal_kill(struct evbuffer *, ev_uint32_t,
185 void run_marshal(struct evbuffer *, const struct run *);
186 int run_unmarshal(struct run *, struct evbuffer *);
[all …]
Dregress_buffer.c71 evbuffer_validate_(struct evbuffer *buf) in evbuffer_validate_()
126 evbuffer_get_waste(struct evbuffer *buf, size_t *allocatedp, size_t *wastedp, size_t *usedp) in evbuffer_get_waste()
176 struct evbuffer *evb = evbuffer_new(); in test_evbuffer()
177 struct evbuffer *evb_two = evbuffer_new(); in test_evbuffer()
299 struct evbuffer *src = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty()
300 struct evbuffer *dst = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty()
337 struct evbuffer *src = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty2()
338 struct evbuffer *dst = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty2()
339 struct evbuffer *buf = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty2()
384 struct evbuffer *src = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty3()
[all …]
Dregress.gen.c143 struct evbuffer *tmp = NULL; in msg_attack_assign()
185 struct evbuffer *tmp = NULL; in msg_run_assign()
306 msg_marshal(struct evbuffer *evbuf, const struct msg *tmp) { in msg_marshal()
323 msg_unmarshal(struct msg *tmp, struct evbuffer *evbuf) in msg_unmarshal()
409 evtag_unmarshal_msg(struct evbuffer *evbuf, ev_uint32_t need_tag, in evtag_unmarshal_msg()
415 struct evbuffer *tmp = evbuffer_new(); in evtag_unmarshal_msg()
431 evtag_marshal_msg(struct evbuffer *evbuf, ev_uint32_t tag, in evtag_marshal_msg()
434 struct evbuffer *buf_ = evbuffer_new(); in evtag_marshal_msg()
623 kill_marshal(struct evbuffer *evbuf, const struct kill *tmp) { in kill_marshal()
637 kill_unmarshal(struct kill *tmp, struct evbuffer *evbuf) in kill_unmarshal()
[all …]
Dregress_zlib.c131 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()
Dbench_http.c59 struct evbuffer *evb = evbuffer_new(); in http_basic_cb()
73 struct evbuffer *evb = evbuffer_new(); in http_ref_cb()
Dtest-ratelim.c131 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()

12