Lines Matching refs:evbuf
94 int evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf);
95 int evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf);
96 int evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag);
97 int evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf);
151 evtag_encode_int(struct evbuffer *evbuf, ev_uint32_t number)
155 evbuffer_add(evbuf, data, len);
159 evtag_encode_int64(struct evbuffer *evbuf, ev_uint64_t number)
163 evbuffer_add(evbuf, data, len);
172 evtag_encode_tag(struct evbuffer *evbuf, ev_uint32_t tag)
188 if (evbuf != NULL)
189 evbuffer_add(evbuf, data, bytes);
195 decode_tag_internal(ev_uint32_t *ptag, struct evbuffer *evbuf, int dodrain)
198 size_t len = evbuffer_get_length(evbuf);
208 evbuf, len < sizeof(number) + 1 ? len : sizeof(number) + 1);
225 evbuffer_drain(evbuf, count);
234 evtag_decode_tag(ev_uint32_t *ptag, struct evbuffer *evbuf)
236 return (decode_tag_internal(ptag, evbuf, 1 /* dodrain */));
246 evtag_marshal(struct evbuffer *evbuf, ev_uint32_t tag,
249 evtag_encode_tag(evbuf, tag);
250 evtag_encode_int(evbuf, len);
251 evbuffer_add(evbuf, (void *)data, len);
255 evtag_marshal_buffer(struct evbuffer *evbuf, ev_uint32_t tag,
258 evtag_encode_tag(evbuf, tag);
260 evtag_encode_int(evbuf, (ev_uint32_t)evbuffer_get_length(data));
261 evbuffer_add_buffer(evbuf, data);
266 evtag_marshal_int(struct evbuffer *evbuf, ev_uint32_t tag, ev_uint32_t integer)
271 evtag_encode_tag(evbuf, tag);
272 evtag_encode_int(evbuf, len);
273 evbuffer_add(evbuf, data, len);
277 evtag_marshal_int64(struct evbuffer *evbuf, ev_uint32_t tag,
283 evtag_encode_tag(evbuf, tag);
284 evtag_encode_int(evbuf, len);
285 evbuffer_add(evbuf, data, len);
296 evtag_marshal_timeval(struct evbuffer *evbuf, ev_uint32_t tag, struct timeval *tv)
301 evtag_marshal(evbuf, tag, data, len);
304 #define DECODE_INT_INTERNAL(number, maxnibbles, pnumber, evbuf, offset) \
307 ev_ssize_t len = evbuffer_get_length(evbuf) - offset; \
314 data = evbuffer_pullup(evbuf, offset + 1) + offset; \
321 data = evbuffer_pullup(evbuf, offset + len) + offset; \
340 * @param evbuf the buffer to read from
347 decode_int_internal(ev_uint32_t *pnumber, struct evbuffer *evbuf, int offset)
350 DECODE_INT_INTERNAL(number, 8, pnumber, evbuf, offset);
354 decode_int64_internal(ev_uint64_t *pnumber, struct evbuffer *evbuf, int offset)
357 DECODE_INT_INTERNAL(number, 16, pnumber, evbuf, offset);
361 evtag_decode_int(ev_uint32_t *pnumber, struct evbuffer *evbuf)
363 int res = decode_int_internal(pnumber, evbuf, 0);
365 evbuffer_drain(evbuf, res);
371 evtag_decode_int64(ev_uint64_t *pnumber, struct evbuffer *evbuf)
373 int res = decode_int64_internal(pnumber, evbuf, 0);
375 evbuffer_drain(evbuf, res);
381 evtag_peek(struct evbuffer *evbuf, ev_uint32_t *ptag)
383 return (decode_tag_internal(ptag, evbuf, 0 /* dodrain */));
387 evtag_peek_length(struct evbuffer *evbuf, ev_uint32_t *plength)
391 len = decode_tag_internal(NULL, evbuf, 0 /* dodrain */);
395 res = decode_int_internal(plength, evbuf, len);
405 evtag_payload_length(struct evbuffer *evbuf, ev_uint32_t *plength)
409 len = decode_tag_internal(NULL, evbuf, 0 /* dodrain */);
413 res = decode_int_internal(plength, evbuf, len);
423 evtag_unmarshal_header(struct evbuffer *evbuf, ev_uint32_t *ptag)
427 if (decode_tag_internal(ptag, evbuf, 1 /* dodrain */) == -1)
429 if (evtag_decode_int(&len, evbuf) == -1)
432 if (evbuffer_get_length(evbuf) < len)
439 evtag_consume(struct evbuffer *evbuf)
442 if ((len = evtag_unmarshal_header(evbuf, NULL)) == -1)
444 evbuffer_drain(evbuf, len);
470 evtag_unmarshal_int(struct evbuffer *evbuf, ev_uint32_t need_tag,
477 if (decode_tag_internal(&tag, evbuf, 1 /* dodrain */) == -1)
481 if (evtag_decode_int(&len, evbuf) == -1)
484 if (evbuffer_get_length(evbuf) < len)
487 result = decode_int_internal(pinteger, evbuf, 0);
488 evbuffer_drain(evbuf, len);
496 evtag_unmarshal_int64(struct evbuffer *evbuf, ev_uint32_t need_tag,
503 if (decode_tag_internal(&tag, evbuf, 1 /* dodrain */) == -1)
507 if (evtag_decode_int(&len, evbuf) == -1)
510 if (evbuffer_get_length(evbuf) < len)
513 result = decode_int64_internal(pinteger, evbuf, 0);
514 evbuffer_drain(evbuf, len);
543 evtag_unmarshal_string(struct evbuffer *evbuf, ev_uint32_t need_tag,
549 if ((tag_len = evtag_unmarshal_header(evbuf, &tag)) == -1 ||
558 evbuffer_remove(evbuf, *pstring, tag_len);
565 evtag_unmarshal_timeval(struct evbuffer *evbuf, ev_uint32_t need_tag,
573 if ((len = evtag_unmarshal_header(evbuf, &tag)) == -1)
577 if ((offset = decode_int_internal(&integer, evbuf, 0)) == -1)
580 if ((offset2 = decode_int_internal(&integer, evbuf, offset)) == -1)
588 evbuffer_drain(evbuf, len);