| /freebsd/contrib/ntp/sntp/libevent/ |
| H A D | event_tagging.c | 97 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
99 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
101 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag);
103 int evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf);
157 evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number) in evtag_encode_int() argument
161 evbuffer_add(evbuf, data, len); in evtag_encode_int()
165 evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number) in evtag_encode_int64() argument
169 evbuffer_add(evbuf, data, len); in evtag_encode_int64()
178 evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag) in evtag_encode_tag() argument
194 if (evbuf != NULL) in evtag_encode_tag()
[all …]
|
| H A D | buffer_iocp.c | 98 evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_read_() argument
100 struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf); in evbuffer_commit_read_()
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_()
[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 | 97 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
99 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
101 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag);
103 int evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf);
157 evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number) in evtag_encode_int() argument
161 evbuffer_add(evbuf, data, len); in evtag_encode_int()
165 evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number) in evtag_encode_int64() argument
169 evbuffer_add(evbuf, data, len); in evtag_encode_int64()
178 evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag) in evtag_encode_tag() argument
194 if (evbuf != NULL) in evtag_encode_tag()
[all …]
|
| H A D | buffer_iocp.c | 98 evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes) in evbuffer_commit_read_() argument
100 struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf); in evbuffer_commit_read_()
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_()
[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);
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 …]
|
| 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);
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 …]
|
| 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 | 306 msg_marshal(struct evbuffer *evbuf, const struct msg *tmp) { in msg_marshal() argument
307 evtag_marshal_string(evbuf, MSG_FROM_NAME, tmp->from_name_data); in msg_marshal()
308 evtag_marshal_string(evbuf, MSG_TO_NAME, tmp->to_name_data); in msg_marshal()
310 evtag_marshal_kill(evbuf, MSG_ATTACK, tmp->attack_data); in msg_marshal()
316 evtag_marshal_run(evbuf, MSG_RUN, tmp->run_data[i]); in msg_marshal()
323 msg_unmarshal(struct msg *tmp, struct evbuffer *evbuf) in msg_unmarshal() argument
326 while (evbuffer_get_length(evbuf) > 0) { in msg_unmarshal()
327 if (evtag_peek(evbuf, &tag) == -1) in msg_unmarshal()
334 if (evtag_unmarshal_string(evbuf, MSG_FROM_NAME, &tmp->from_name_data) == -1) { in msg_unmarshal()
343 if (evtag_unmarshal_string(evbuf, MSG_TO_NAME, &tmp->to_name_data) == -1) { in msg_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 | 306 msg_marshal(struct evbuffer *evbuf, const struct msg *tmp) { in msg_marshal() argument
307 evtag_marshal_string(evbuf, MSG_FROM_NAME, tmp->from_name_data); in msg_marshal()
308 evtag_marshal_string(evbuf, MSG_TO_NAME, tmp->to_name_data); in msg_marshal()
310 evtag_marshal_kill(evbuf, MSG_ATTACK, tmp->attack_data); in msg_marshal()
316 evtag_marshal_run(evbuf, MSG_RUN, tmp->run_data[i]); in msg_marshal()
323 msg_unmarshal(struct msg *tmp, struct evbuffer *evbuf) in msg_unmarshal() argument
326 while (evbuffer_get_length(evbuf) > 0) { in msg_unmarshal()
327 if (evtag_peek(evbuf, &tag) == -1) in msg_unmarshal()
334 if (evtag_unmarshal_string(evbuf, MSG_FROM_NAME, &tmp->from_name_data) == -1) { in msg_unmarshal()
343 if (evtag_unmarshal_string(evbuf, MSG_TO_NAME, &tmp->to_name_data) == -1) { in msg_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()
|