Home
last modified time | relevance | path

Searched refs:evbuf (Results 1 – 14 of 14) sorted by relevance

/netbsd-src/external/bsd/libevent/dist/
H A Devent_tagging.c101 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
103 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
105 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag);
107 int evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf);
161 evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number) in evtag_encode_int() argument
165 evbuffer_add(evbuf, data, len); in evtag_encode_int()
169 evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number) in evtag_encode_int64() argument
173 evbuffer_add(evbuf, data, len); in evtag_encode_int64()
182 evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag) in evtag_encode_tag() argument
198 if (evbuf != NULL) in evtag_encode_tag()
[all …]
H A Dbuffer_iocp.c101 evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_read_() argument
103 struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf); in evbuffer_commit_read_()
108 EVBUFFER_LOCK(evbuf); in evbuffer_commit_read_()
112 evbuffer_unfreeze(evbuf, 0); in evbuffer_commit_read_()
114 chainp = evbuf->last_with_datap; in evbuffer_commit_read_()
124 evbuf->last_with_datap = chainp; in evbuffer_commit_read_()
133 evbuf->total_len += nBytes; in evbuffer_commit_read_()
134 evbuf->n_add_for_cb += nBytes; in evbuffer_commit_read_()
136 evbuffer_invoke_callbacks_(evbuf); in evbuffer_commit_read_()
138 evbuffer_decref_and_unlock_(evbuf); in evbuffer_commit_read_()
[all …]
H A Devrpc.c193 struct evhttp_request *req, struct evbuffer *evbuf) in evrpc_process_hooks() argument
197 int res = hook->process(ctx, req, evbuf, hook->process_arg); in evrpc_process_hooks()
/netbsd-src/external/bsd/ntp/dist/sntp/libevent/include/event2/
H A Dtag.h74 int evtag_unmarshal_header(struct evbuffer *evbuf, ev_uint32_t *ptag);
77 void evtag_marshal(struct evbuffer *evbuf, ev_uint32_t tag, const void *data,
80 void evtag_marshal_buffer(struct evbuffer *evbuf, ev_uint32_t tag,
94 void evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number);
96 void evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number);
99 void evtag_marshal_int(struct evbuffer *evbuf, ev_uint32_t tag,
102 void evtag_marshal_int64(struct evbuffer *evbuf, ev_uint32_t tag,
110 void evtag_marshal_timeval(struct evbuffer *evbuf, ev_uint32_t tag,
117 int evtag_peek(struct evbuffer *evbuf, ev_uint32_t *ptag);
119 int evtag_peek_length(struct evbuffer *evbuf, ev_uint32_t *plength);
[all …]
H A Dtag_compat.h47 #define encode_int(evbuf, number) evtag_encode_int((evbuf), (number)) argument
48 #define encode_int64(evbuf, number) evtag_encode_int64((evbuf), (number)) argument
/netbsd-src/external/bsd/libevent/dist/include/event2/
H A Dtag.h73 int evtag_unmarshal_header(struct evbuffer *evbuf, ev_uint32_t *ptag);
76 void evtag_marshal(struct evbuffer *evbuf, ev_uint32_t tag, const void *data,
79 void evtag_marshal_buffer(struct evbuffer *evbuf, ev_uint32_t tag,
93 void evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number);
95 void evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number);
98 void evtag_marshal_int(struct evbuffer *evbuf, ev_uint32_t tag,
101 void evtag_marshal_int64(struct evbuffer *evbuf, ev_uint32_t tag,
109 void evtag_marshal_timeval(struct evbuffer *evbuf, ev_uint32_t tag,
116 int evtag_peek(struct evbuffer *evbuf, ev_uint32_t *ptag);
118 int evtag_peek_length(struct evbuffer *evbuf, ev_uint32_t *plength);
[all …]
H A Dtag_compat.h46 #define encode_int(evbuf, number) evtag_encode_int((evbuf), (number)) argument
47 #define encode_int64(evbuf, number) evtag_encode_int64((evbuf), (number)) argument
/netbsd-src/external/bsd/libevent/dist/test/
H A Dregress.gen.c307 msg_marshal(struct evbuffer *evbuf, const struct msg *tmp) { in msg_marshal() argument
308 evtag_marshal_string(evbuf, MSG_FROM_NAME, tmp->from_name_data); in msg_marshal()
309 evtag_marshal_string(evbuf, MSG_TO_NAME, tmp->to_name_data); in msg_marshal()
311 evtag_marshal_kill(evbuf, MSG_ATTACK, tmp->attack_data); in msg_marshal()
317 evtag_marshal_run(evbuf, MSG_RUN, tmp->run_data[i]); in msg_marshal()
324 msg_unmarshal(struct msg *tmp, struct evbuffer *evbuf) in msg_unmarshal() argument
327 while (evbuffer_get_length(evbuf) > 0) { in msg_unmarshal()
328 if (evtag_peek(evbuf, &tag) == -1) in msg_unmarshal()
335 if (evtag_unmarshal_string(evbuf, MSG_FROM_NAME, &tmp->from_name_data) == -1) { in msg_unmarshal()
344 if (evtag_unmarshal_string(evbuf, MSG_TO_NAME, &tmp->to_name_data) == -1) { in msg_unmarshal()
[all …]
H A Dregress_zlib.c249 struct evbuffer *evbuf = evbuffer_new(); in readcb() local
250 assert(evbuf != NULL); in readcb()
253 bufferevent_read_buffer(bev, evbuf); in readcb()
257 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
261 evbuffer_free(evbuf); in readcb()
H A Dregress_bufferevent.c112 struct evbuffer *evbuf = evbuffer_new(); in readcb() local
113 assert(evbuf != NULL); in readcb()
116 bufferevent_read_buffer(bev, evbuf); in readcb()
120 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
124 evbuffer_free(evbuf); in readcb()
373 struct evbuffer *evbuf = evbuffer_new(); in wm_readcb() local
379 assert(evbuf != NULL); in wm_readcb()
382 bufferevent_read_buffer(bev, evbuf); in wm_readcb()
390 evbuffer_free(evbuf); in wm_readcb()
H A Dregress_rpc.c401 struct evbuffer *evbuf, void *arg) in rpc_hook_add_header() argument
416 struct evbuffer *evbuf, void *arg) in rpc_hook_add_meta() argument
427 struct evbuffer *evbuf, void *arg) in rpc_hook_remove_header() argument
619 rpc_hook_pause(void *ctx, struct evhttp_request *req, struct evbuffer *evbuf, in rpc_hook_pause() argument
H A Dregress.c2375 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
2376 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
2377 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t number);
2378 int evtag_decode_tag(ev_uint32_t *pnumber, struct evbuffer *evbuf);
/netbsd-src/external/bsd/libevent/dist/sample/
H A Dhttp-connect.c64 struct evbuffer *evbuf; in get_cb() local
68 evbuf = evhttp_request_get_input_buffer(req); in get_cb()
69 len = evbuffer_get_length(evbuf); in get_cb()
70 fwrite(evbuffer_pullup(evbuf, len), len, 1, stdout); in get_cb()
71 evbuffer_drain(evbuf, len); in get_cb()
/netbsd-src/sys/dev/audio/
H A Daudio.c3422 char evbuf[64]; in audio_poll() local
3423 snprintb(evbuf, sizeof(evbuf), POLLEV_BITMAP, events); in audio_poll()
3425 (int)curproc->p_pid, (int)l->l_lid, evbuf); in audio_poll()
3464 snprintb(evbuf, sizeof(evbuf), POLLEV_BITMAP, revents); in audio_poll()
3465 TRACEF(2, file, "revents=%s", evbuf); in audio_poll()