| /freebsd/contrib/ntp/sntp/libevent/ |
| H A D | event_tagging.c | 194 if (evbuf != NULL) in evtag_encode_tag()
264 evtag_encode_tag(evbuf, tag); in evtag_marshal()
265 evtag_encode_int(evbuf, len); in evtag_marshal()
273 evtag_encode_tag(evbuf, tag); in evtag_marshal_buffer()
286 evtag_encode_tag(evbuf, tag); in evtag_marshal_int()
384 evbuffer_drain(evbuf, res); in evtag_decode_int()
394 evbuffer_drain(evbuf, res); in evtag_decode_int64()
463 evbuffer_drain(evbuf, len); in evtag_consume()
507 evbuffer_drain(evbuf, len); in evtag_unmarshal_int()
533 evbuffer_drain(evbuf, len); in evtag_unmarshal_int64()
[all …]
|
| H A D | buffer_iocp.c | 105 EVBUFFER_LOCK(evbuf); in evbuffer_commit_read_()
109 evbuffer_unfreeze(evbuf, 0); in evbuffer_commit_read_()
111 chainp = evbuf->last_with_datap; in evbuffer_commit_read_()
121 evbuf->last_with_datap = chainp; in evbuffer_commit_read_()
130 evbuf->total_len += nBytes; in evbuffer_commit_read_()
131 evbuf->n_add_for_cb += nBytes; in evbuffer_commit_read_()
133 evbuffer_invoke_callbacks_(evbuf); in evbuffer_commit_read_()
135 evbuffer_decref_and_unlock_(evbuf); in evbuffer_commit_read_()
143 EVBUFFER_LOCK(evbuf); in evbuffer_commit_write_()
145 evbuffer_unfreeze(evbuf, 1); in evbuffer_commit_write_()
[all …]
|
| H A 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()
|
| /freebsd/contrib/libevent/ |
| H A D | event_tagging.c | 194 if (evbuf != NULL) in evtag_encode_tag()
264 evtag_encode_tag(evbuf, tag); in evtag_marshal()
265 evtag_encode_int(evbuf, len); in evtag_marshal()
273 evtag_encode_tag(evbuf, tag); in evtag_marshal_buffer()
286 evtag_encode_tag(evbuf, tag); in evtag_marshal_int()
384 evbuffer_drain(evbuf, res); in evtag_decode_int()
394 evbuffer_drain(evbuf, res); in evtag_decode_int64()
463 evbuffer_drain(evbuf, len); in evtag_consume()
507 evbuffer_drain(evbuf, len); in evtag_unmarshal_int()
533 evbuffer_drain(evbuf, len); in evtag_unmarshal_int64()
[all …]
|
| H A D | buffer_iocp.c | 105 EVBUFFER_LOCK(evbuf); in evbuffer_commit_read_()
109 evbuffer_unfreeze(evbuf, 0); in evbuffer_commit_read_()
111 chainp = evbuf->last_with_datap; in evbuffer_commit_read_()
121 evbuf->last_with_datap = chainp; in evbuffer_commit_read_()
130 evbuf->total_len += nBytes; in evbuffer_commit_read_()
131 evbuf->n_add_for_cb += nBytes; in evbuffer_commit_read_()
133 evbuffer_invoke_callbacks_(evbuf); in evbuffer_commit_read_()
135 evbuffer_decref_and_unlock_(evbuf); in evbuffer_commit_read_()
143 EVBUFFER_LOCK(evbuf); in evbuffer_commit_write_()
145 evbuffer_unfreeze(evbuf, 1); in evbuffer_commit_write_()
[all …]
|
| H A 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()
|
| /freebsd/contrib/ntp/sntp/libevent/include/event2/ |
| H A D | tag.h | 72 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 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
|
| /freebsd/contrib/libevent/include/event2/ |
| H A D | tag.h | 72 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 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
|
| /freebsd/contrib/ntp/sntp/libevent/test/ |
| H A D | regress.gen.c | 326 while (evbuffer_get_length(evbuf) > 0) { in msg_unmarshal()
327 if (evtag_peek(evbuf, &tag) == -1) in msg_unmarshal()
355 if (evtag_unmarshal_kill(evbuf, MSG_ATTACK, in msg_unmarshal()
371 if (evtag_unmarshal_run(evbuf, MSG_RUN, in msg_unmarshal()
437 evtag_marshal_buffer(evbuf, tag, buf_); in evtag_marshal_msg()
640 while (evbuffer_get_length(evbuf) > 0) { in kill_unmarshal()
641 if (evtag_peek(evbuf, &tag) == -1) in kill_unmarshal()
725 evtag_marshal_buffer(evbuf, tag, buf_); in evtag_marshal_kill()
1093 while (evbuffer_get_length(evbuf) > 0) { in run_unmarshal()
1094 if (evtag_peek(evbuf, &tag) == -1) in run_unmarshal()
[all …]
|
| H A 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()
|
| H A D | regress_bufferevent.c | 108 struct evbuffer *evbuf = evbuffer_new(); in readcb() local
109 assert(evbuf != NULL); in readcb()
112 bufferevent_read_buffer(bev, evbuf); in readcb()
116 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
120 evbuffer_free(evbuf); in readcb()
369 struct evbuffer *evbuf = evbuffer_new(); in wm_readcb() local
375 assert(evbuf != NULL); in wm_readcb()
378 bufferevent_read_buffer(bev, evbuf); in wm_readcb()
386 evbuffer_free(evbuf); in wm_readcb()
|
| H A D | regress_rpc.c | 397 struct evbuffer *evbuf, void *arg) in rpc_hook_add_header() argument
412 struct evbuffer *evbuf, void *arg) in rpc_hook_add_meta() argument
423 struct evbuffer *evbuf, void *arg) in rpc_hook_remove_header() argument
615 rpc_hook_pause(void *ctx, struct evhttp_request *req, struct evbuffer *evbuf, in rpc_hook_pause() argument
|
| H A D | regress.c | 2371 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
2372 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
2373 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t number);
2374 int evtag_decode_tag(ev_uint32_t *pnumber, struct evbuffer *evbuf);
|
| /freebsd/contrib/libevent/test/ |
| H A D | regress.gen.c | 326 while (evbuffer_get_length(evbuf) > 0) { in msg_unmarshal()
327 if (evtag_peek(evbuf, &tag) == -1) in msg_unmarshal()
355 if (evtag_unmarshal_kill(evbuf, MSG_ATTACK, in msg_unmarshal()
371 if (evtag_unmarshal_run(evbuf, MSG_RUN, in msg_unmarshal()
437 evtag_marshal_buffer(evbuf, tag, buf_); in evtag_marshal_msg()
640 while (evbuffer_get_length(evbuf) > 0) { in kill_unmarshal()
641 if (evtag_peek(evbuf, &tag) == -1) in kill_unmarshal()
725 evtag_marshal_buffer(evbuf, tag, buf_); in evtag_marshal_kill()
1093 while (evbuffer_get_length(evbuf) > 0) { in run_unmarshal()
1094 if (evtag_peek(evbuf, &tag) == -1) in run_unmarshal()
[all …]
|
| H A 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()
|
| H A D | regress_bufferevent.c | 108 struct evbuffer *evbuf = evbuffer_new(); in readcb() local
109 assert(evbuf != NULL); in readcb()
112 bufferevent_read_buffer(bev, evbuf); in readcb()
116 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
120 evbuffer_free(evbuf); in readcb()
369 struct evbuffer *evbuf = evbuffer_new(); in wm_readcb() local
375 assert(evbuf != NULL); in wm_readcb()
378 bufferevent_read_buffer(bev, evbuf); in wm_readcb()
386 evbuffer_free(evbuf); in wm_readcb()
|
| H A D | regress_rpc.c | 397 struct evbuffer *evbuf, void *arg) in rpc_hook_add_header() argument
412 struct evbuffer *evbuf, void *arg) in rpc_hook_add_meta() argument
423 struct evbuffer *evbuf, void *arg) in rpc_hook_remove_header() argument
615 rpc_hook_pause(void *ctx, struct evhttp_request *req, struct evbuffer *evbuf, in rpc_hook_pause() argument
|
| H A D | regress.c | 2371 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
2372 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
2373 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t number);
2374 int evtag_decode_tag(ev_uint32_t *pnumber, struct evbuffer *evbuf);
|
| /freebsd/contrib/pf/libevent/ |
| H A D | event.h | 301 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/contrib/ntp/sntp/libevent/sample/ |
| H A D | http-connect.c | 61 struct evbuffer *evbuf; in get_cb() local
65 evbuf = evhttp_request_get_input_buffer(req); in get_cb()
66 len = evbuffer_get_length(evbuf); in get_cb()
67 fwrite(evbuffer_pullup(evbuf, len), len, 1, stdout); in get_cb()
68 evbuffer_drain(evbuf, len); in get_cb()
|
| /freebsd/contrib/libevent/sample/ |
| H A D | http-connect.c | 61 struct evbuffer *evbuf; in get_cb() local
65 evbuf = evhttp_request_get_input_buffer(req); in get_cb()
66 len = evbuffer_get_length(evbuf); in get_cb()
67 fwrite(evbuffer_pullup(evbuf, len), len, 1, stdout); in get_cb()
68 evbuffer_drain(evbuf, len); in get_cb()
|