Home
last modified time | relevance | path

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

/freebsd-13.1/contrib/ntp/sntp/libevent/
H A Devent_tagging.c189 if (evbuf != NULL) in evtag_encode_tag()
259 evtag_encode_tag(evbuf, tag); in evtag_marshal()
260 evtag_encode_int(evbuf, len); in evtag_marshal()
268 evtag_encode_tag(evbuf, tag); in evtag_marshal_buffer()
281 evtag_encode_tag(evbuf, tag); in evtag_marshal_int()
379 evbuffer_drain(evbuf, res); in evtag_decode_int()
389 evbuffer_drain(evbuf, res); in evtag_decode_int64()
458 evbuffer_drain(evbuf, len); in evtag_consume()
502 evbuffer_drain(evbuf, len); in evtag_unmarshal_int()
528 evbuffer_drain(evbuf, len); in evtag_unmarshal_int64()
[all …]
H A Dbuffer_iocp.c104 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_()
142 EVBUFFER_LOCK(evbuf); in evbuffer_commit_write_()
144 evbuffer_unfreeze(evbuf, 1); in evbuffer_commit_write_()
[all …]
H A Devrpc.c189 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()
/freebsd-13.1/contrib/libevent/
H A Devent_tagging.c190 if (evbuf != NULL) in evtag_encode_tag()
260 evtag_encode_tag(evbuf, tag); in evtag_marshal()
261 evtag_encode_int(evbuf, len); in evtag_marshal()
269 evtag_encode_tag(evbuf, tag); in evtag_marshal_buffer()
282 evtag_encode_tag(evbuf, tag); in evtag_marshal_int()
380 evbuffer_drain(evbuf, res); in evtag_decode_int()
390 evbuffer_drain(evbuf, res); in evtag_decode_int64()
459 evbuffer_drain(evbuf, len); in evtag_consume()
503 evbuffer_drain(evbuf, len); in evtag_unmarshal_int()
529 evbuffer_drain(evbuf, len); in evtag_unmarshal_int64()
[all …]
H A Dbuffer_iocp.c104 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_()
142 EVBUFFER_LOCK(evbuf); in evbuffer_commit_write_()
144 evbuffer_unfreeze(evbuf, 1); in evbuffer_commit_write_()
[all …]
H A Devrpc.c189 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()
/freebsd-13.1/contrib/ntp/sntp/libevent/include/event2/
H A Dtag.h72 int evtag_unmarshal_header(struct evbuffer *evbuf, ev_uint32_t *ptag);
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);
121 int evtag_consume(struct evbuffer *evbuf);
[all …]
H A Dtag_compat.h45 #define encode_int(evbuf, number) evtag_encode_int((evbuf), (number)) argument
46 #define encode_int64(evbuf, number) evtag_encode_int64((evbuf), (number)) argument
/freebsd-13.1/contrib/libevent/include/event2/
H A Dtag.h72 int evtag_unmarshal_header(struct evbuffer *evbuf, ev_uint32_t *ptag);
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);
121 int evtag_consume(struct evbuffer *evbuf);
[all …]
H A Dtag_compat.h45 #define encode_int(evbuf, number) evtag_encode_int((evbuf), (number)) argument
46 #define encode_int64(evbuf, number) evtag_encode_int64((evbuf), (number)) argument
/freebsd-13.1/contrib/libevent/test/
H A Dregress.gen.c308 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()
433 evtag_marshal_buffer(evbuf, tag, buf_); in evtag_marshal_msg()
635 while (evbuffer_get_length(evbuf) > 0) { in kill_unmarshal()
636 if (evtag_peek(evbuf, &tag) == -1) in kill_unmarshal()
724 evtag_marshal_buffer(evbuf, tag, buf_); in evtag_marshal_kill()
1090 while (evbuffer_get_length(evbuf) > 0) { in run_unmarshal()
1091 if (evtag_peek(evbuf, &tag) == -1) in run_unmarshal()
[all …]
H A Dregress_zlib.c246 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()
H A Dregress_bufferevent.c95 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()
H A Dregress_rpc.c398 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
H A Dregress.c2300 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);
/freebsd-13.1/contrib/ntp/sntp/libevent/test/
H A Dregress.gen.c308 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()
433 evtag_marshal_buffer(evbuf, tag, buf_); in evtag_marshal_msg()
635 while (evbuffer_get_length(evbuf) > 0) { in kill_unmarshal()
636 if (evtag_peek(evbuf, &tag) == -1) in kill_unmarshal()
724 evtag_marshal_buffer(evbuf, tag, buf_); in evtag_marshal_kill()
1090 while (evbuffer_get_length(evbuf) > 0) { in run_unmarshal()
1091 if (evtag_peek(evbuf, &tag) == -1) in run_unmarshal()
[all …]
H A Dregress_zlib.c246 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()
H A Dregress_bufferevent.c95 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()
343 struct evbuffer *evbuf = evbuffer_new(); in wm_readcb() local
349 assert(evbuf != NULL); in wm_readcb()
352 bufferevent_read_buffer(bev, evbuf); in wm_readcb()
360 evbuffer_free(evbuf); in wm_readcb()
H A Dregress_rpc.c398 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
H A Dregress.c2197 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
2198 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
2199 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t number);
2200 int evtag_decode_tag(ev_uint32_t *pnumber, struct evbuffer *evbuf);
/freebsd-13.1/contrib/pf/libevent/
H A Devent.h301 void evtag_marshal(struct evbuffer *evbuf, u_int8_t tag, const void *data,
304 void encode_int(struct evbuffer *evbuf, u_int32_t number);
306 void evtag_marshal_int(struct evbuffer *evbuf, u_int8_t tag,
312 void evtag_marshal_timeval(struct evbuffer *evbuf, u_int8_t tag,
319 int evtag_peek(struct evbuffer *evbuf, u_int8_t *ptag);
320 int evtag_peek_length(struct evbuffer *evbuf, u_int32_t *plength);
321 int evtag_payload_length(struct evbuffer *evbuf, u_int32_t *plength);
322 int evtag_consume(struct evbuffer *evbuf);
324 int evtag_unmarshal_int(struct evbuffer *evbuf, u_int8_t need_tag,
330 int evtag_unmarshal_string(struct evbuffer *evbuf, u_int8_t need_tag,
[all …]
/freebsd-13.1/contrib/libevent/sample/
H A Dhttp-connect.c28 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()