Home
last modified time | relevance | path

Searched refs:evbuffer (Results 1 – 25 of 49) 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.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.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);
95 void evbuffer_setcb(struct evbuffer *buffer, evbuffer_cb cb, void *cbarg);
107 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);
701 struct evbuffer *src, struct evbuffer *dst, ev_ssize_t dst_limit,
Dhttp.h39 struct evbuffer;
418 const char *reason, struct evbuffer *databuf);
453 struct evbuffer *databuf);
469 void evhttp_send_reply_chunk_with_cb(struct evhttp_request *, struct evbuffer *,
837 struct evbuffer *evhttp_request_get_input_buffer(struct evhttp_request *req);
840 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.c96 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
97 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
98 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag);
99 int evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf);
153 evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number) in evtag_encode_int()
161 evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number) in evtag_encode_int64()
174 evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag) in evtag_encode_tag()
197 decode_tag_internal(ev_uint32_t *ptag, struct evbuffer *evbuf, int dodrain) in decode_tag_internal()
245 evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf) in evtag_decode_tag()
257 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;
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);
Dbuffer.c146 static int evbuffer_ptr_memcmp(const struct evbuffer *buf,
148 static struct evbuffer_chain *evbuffer_expand_singlechain(struct evbuffer *buf,
150 static int evbuffer_ptr_subtract(struct evbuffer *buf, struct evbuffer_ptr *pos,
290 evbuffer_free_trailing_empty_chains(struct evbuffer *buf) in evbuffer_free_trailing_empty_chains()
308 evbuffer_chain_insert(struct evbuffer *buf, in evbuffer_chain_insert()
329 evbuffer_chain_insert_new(struct evbuffer *buf, size_t datlen) in evbuffer_chain_insert_new()
360 struct evbuffer *
363 struct evbuffer *buffer; in evbuffer_new()
365 buffer = mm_calloc(1, sizeof(struct evbuffer)); in evbuffer_new()
377 evbuffer_set_flags(struct evbuffer *buf, ev_uint64_t flags) in evbuffer_set_flags()
[all …]
Dbuffer_iocp.c54 struct evbuffer buffer;
74 upcast_evbuffer(struct evbuffer *buf) in upcast_evbuffer()
97 evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_read_()
138 evbuffer_commit_write_(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_write_()
151 struct evbuffer *
171 evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t at_most, in evbuffer_launch_write_()
245 evbuffer_launch_read_(struct evbuffer *buf, size_t at_most, in evbuffer_launch_read_()
311 evbuffer_overlapped_get_fd_(struct evbuffer *buf) in evbuffer_overlapped_get_fd_()
318 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.h32 struct evbuffer;
192 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()
825 void (*req_marshal)(struct evbuffer*, void *), in evrpc_make_request_ctx() argument
827 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.h57 void msg_marshal(struct evbuffer *, const struct msg *);
58 int msg_unmarshal(struct msg *, struct evbuffer *);
60 void evtag_marshal_msg(struct evbuffer *, ev_uint32_t,
62 int evtag_unmarshal_msg(struct evbuffer *, ev_uint32_t,
112 void kill_marshal(struct evbuffer *, const struct kill *);
113 int kill_unmarshal(struct kill *, struct evbuffer *);
115 void evtag_marshal_kill(struct evbuffer *, ev_uint32_t,
117 int evtag_unmarshal_kill(struct evbuffer *, ev_uint32_t,
184 void run_marshal(struct evbuffer *, const struct run *);
185 int run_unmarshal(struct run *, struct evbuffer *);
[all …]
Dregress_buffer.c69 evbuffer_validate_(struct evbuffer *buf) in evbuffer_validate_()
124 evbuffer_get_waste(struct evbuffer *buf, size_t *allocatedp, size_t *wastedp, size_t *usedp) in evbuffer_get_waste()
174 struct evbuffer *evb = evbuffer_new(); in test_evbuffer()
175 struct evbuffer *evb_two = evbuffer_new(); in test_evbuffer()
297 struct evbuffer *src = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty()
298 struct evbuffer *dst = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty()
329 struct evbuffer *src = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty2()
330 struct evbuffer *dst = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty2()
331 struct evbuffer *buf = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty2()
370 struct evbuffer *src = evbuffer_new(); in test_evbuffer_remove_buffer_with_empty3()
[all …]
Dregress.gen.c136 struct evbuffer *tmp = NULL; in msg_attack_assign()
178 struct evbuffer *tmp = NULL; in msg_run_assign()
298 msg_marshal(struct evbuffer *evbuf, const struct msg *tmp){ in msg_marshal()
315 msg_unmarshal(struct msg *tmp, struct evbuffer *evbuf) in msg_unmarshal()
407 evtag_unmarshal_msg(struct evbuffer *evbuf, ev_uint32_t need_tag, struct msg *msg) in evtag_unmarshal_msg()
412 struct evbuffer *tmp = evbuffer_new(); in evtag_unmarshal_msg()
428 evtag_marshal_msg(struct evbuffer *evbuf, ev_uint32_t tag, const struct msg *msg) in evtag_marshal_msg()
430 struct evbuffer *buf_ = evbuffer_new(); in evtag_marshal_msg()
618 kill_marshal(struct evbuffer *evbuf, const struct kill *tmp){ in kill_marshal()
632 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()
Dtest-ratelim.c115 struct evbuffer *output = bufferevent_get_output(bev); in loud_writecb()
129 struct evbuffer *input = bufferevent_get_input(bev); in discard_readcb()
148 struct evbuffer *input = bufferevent_get_input(bev); in echo_readcb()
149 struct evbuffer *output = bufferevent_get_output(bev); in echo_readcb()
159 struct evbuffer *output = bufferevent_get_output(bev); in echo_writecb()
Dbench_http.c59 struct evbuffer *evb = evbuffer_new(); in http_basic_cb()
73 struct evbuffer *evb = evbuffer_new(); in http_ref_cb()

12