| /external/libevent/ |
| D | event_tagging.c | 96 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() argument
157 evbuffer_add(evbuf, data, len); in evtag_encode_int()
161 evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number) in evtag_encode_int64() argument
165 evbuffer_add(evbuf, data, len); in evtag_encode_int64()
174 evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag) in evtag_encode_tag() argument
190 if (evbuf != NULL) in evtag_encode_tag()
[all …]
|
| D | buffer_iocp.c | 97 evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_read_() argument
99 struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf); in evbuffer_commit_read_()
104 EVBUFFER_LOCK(evbuf); in evbuffer_commit_read_()
108 evbuffer_unfreeze(evbuf, 0); in evbuffer_commit_read_()
110 chainp = evbuf->last_with_datap; in evbuffer_commit_read_()
120 evbuf->last_with_datap = chainp; in evbuffer_commit_read_()
129 evbuf->total_len += nBytes; in evbuffer_commit_read_()
130 evbuf->n_add_for_cb += nBytes; in evbuffer_commit_read_()
132 evbuffer_invoke_callbacks_(evbuf); in evbuffer_commit_read_()
134 evbuffer_decref_and_unlock_(evbuf); in evbuffer_commit_read_()
[all …]
|
| D | evrpc.c | 189 struct evhttp_request *req, struct evbuffer *evbuf) in evrpc_process_hooks() argument
193 int res = hook->process(ctx, req, evbuf, hook->process_arg); in evrpc_process_hooks()
|
| /external/libevent/include/event2/ |
| D | tag.h | 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,
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,
108 void evtag_marshal_timeval(struct evbuffer *evbuf, ev_uint32_t tag,
115 int evtag_peek(struct evbuffer *evbuf, ev_uint32_t *ptag);
117 int evtag_peek_length(struct evbuffer *evbuf, ev_uint32_t *plength);
[all …]
|
| D | tag_compat.h | 45 #define encode_int(evbuf, number) evtag_encode_int((evbuf), (number)) argument
46 #define encode_int64(evbuf, number) evtag_encode_int64((evbuf), (number)) argument
|
| /external/libevent/test/ |
| D | regress.gen.c | 298 msg_marshal(struct evbuffer *evbuf, const struct msg *tmp){ in msg_marshal() argument
299 evtag_marshal_string(evbuf, MSG_FROM_NAME, tmp->from_name_data); in msg_marshal()
300 evtag_marshal_string(evbuf, MSG_TO_NAME, tmp->to_name_data); in msg_marshal()
302 evtag_marshal_kill(evbuf, MSG_ATTACK, tmp->attack_data); in msg_marshal()
308 evtag_marshal_run(evbuf, MSG_RUN, tmp->run_data[i]); in msg_marshal()
315 msg_unmarshal(struct msg *tmp, struct evbuffer *evbuf) in msg_unmarshal() argument
318 while (evbuffer_get_length(evbuf) > 0) { in msg_unmarshal()
319 if (evtag_peek(evbuf, &tag) == -1) in msg_unmarshal()
327 if (evtag_unmarshal_string(evbuf, MSG_FROM_NAME, &tmp->from_name_data) == -1) { in msg_unmarshal()
338 if (evtag_unmarshal_string(evbuf, MSG_TO_NAME, &tmp->to_name_data) == -1) { in msg_unmarshal()
[all …]
|
| D | regress_zlib.c | 246 struct evbuffer *evbuf = evbuffer_new(); in readcb() local
247 assert(evbuf != NULL); in readcb()
250 bufferevent_read_buffer(bev, evbuf); in readcb()
254 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
258 evbuffer_free(evbuf); in readcb()
|
| D | regress_bufferevent.c | 95 struct evbuffer *evbuf = evbuffer_new(); in readcb() local
96 assert(evbuf != NULL); in readcb()
99 bufferevent_read_buffer(bev, evbuf); in readcb()
103 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
107 evbuffer_free(evbuf); in readcb()
356 struct evbuffer *evbuf = evbuffer_new(); in wm_readcb() local
362 assert(evbuf != NULL); in wm_readcb()
365 bufferevent_read_buffer(bev, evbuf); in wm_readcb()
373 evbuffer_free(evbuf); in wm_readcb()
|
| D | regress_rpc.c | 398 struct evbuffer *evbuf, void *arg) in rpc_hook_add_header() argument
413 struct evbuffer *evbuf, void *arg) in rpc_hook_add_meta() argument
424 struct evbuffer *evbuf, void *arg) in rpc_hook_remove_header() argument
616 rpc_hook_pause(void *ctx, struct evhttp_request *req, struct evbuffer *evbuf, in rpc_hook_pause() argument
|
| D | regress.c | 2300 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
2301 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
2302 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t number);
2303 int evtag_decode_tag(ev_uint32_t *pnumber, struct evbuffer *evbuf);
|
| /external/libevent/sample/ |
| D | http-connect.c | 28 struct evbuffer *evbuf; in get_cb() local
32 evbuf = evhttp_request_get_input_buffer(req); in get_cb()
33 len = evbuffer_get_length(evbuf); in get_cb()
34 fwrite(evbuffer_pullup(evbuf, len), len, 1, stdout); in get_cb()
35 evbuffer_drain(evbuf, len); in get_cb()
|
| /external/strace/ |
| D | strace.c | 1981 char evbuf[sizeof(",EVENT_VFORK_DONE (%u)") + sizeof(int)*3 /*paranoia:*/ + 16]; in print_debug_info() local
1997 evbuf[0] = '\0'; in print_debug_info()
2013 xsprintf(evbuf, ",EVENT_%s (%u)", e, event); in print_debug_info()
2015 error_msg("[wait(0x%06x) = %u] %s%s", status, pid, buf, evbuf); in print_debug_info()
|