/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()
|