Lines Matching defs:sink
5977 bool upb_bufsrc_putbuf(const char *buf, size_t len, upb_bytessink sink) {
5982 ret = upb_bytessink_start(sink, len, &subc);
5984 ret = (upb_bytessink_putbuf(sink, subc, buf, len, &handle) >= len);
5987 ret = upb_bytessink_end(sink);
7521 upb_sink_putunknown(d->top->sink, d->checkpoint, d->ptr - d->checkpoint);
7615 upb_sink_put ## name(d->top->sink, arg, (convfunc)(val)); \
7667 CHECK_SUSPEND(upb_sink_startmsg(d->top->sink));
7670 CHECK_SUSPEND(upb_sink_endmsg(d->top->sink, d->status));
7674 CHECK_SUSPEND(upb_sink_startseq(outer->sink, arg, &d->top->sink));
7677 CHECK_SUSPEND(upb_sink_endseq(d->top->sink, arg));
7681 CHECK_SUSPEND(upb_sink_startsubmsg(outer->sink, arg, &d->top->sink));
7684 upb_sink subsink = (d->top + 1)->sink;
7685 CHECK_SUSPEND(upb_sink_endsubmsg(d->top->sink, subsink, arg));
7690 CHECK_SUSPEND(upb_sink_startstr(outer->sink, arg, len, &d->top->sink));
7697 size_t n = upb_sink_putstring(d->top->sink, arg, d->ptr, len, handle);
7718 CHECK_SUSPEND(upb_sink_endstr(d->top->sink, arg));
7900 upb_sink sink, upb_status *status) {
7925 if (sink.handlers != d->method_->dest_handlers_)
7928 d->top->sink = sink;
8980 ** - handling of push-back (non-success returns from sink functions).
9065 upb_bytessink sink;
9072 upb_stringsink *sink = _sink;
9073 sink->len = 0;
9076 return sink;
9081 upb_stringsink *sink = _sink;
9082 size_t new_size = sink->size;
9087 while (sink->len + len > new_size) {
9091 if (new_size != sink->size) {
9092 sink->ptr = realloc(sink->ptr, new_size);
9093 sink->size = new_size;
9096 memcpy(sink->ptr + sink->len, ptr, len);
9097 sink->len += len;
9102 void upb_stringsink_init(upb_stringsink *sink) {
9103 upb_byteshandler_init(&sink->handler);
9104 upb_byteshandler_setstartstr(&sink->handler, stringsink_start, NULL);
9105 upb_byteshandler_setstring(&sink->handler, stringsink_string, NULL);
9107 upb_bytessink_reset(&sink->sink, &sink->handler, sink);
9109 sink->size = 32;
9110 sink->ptr = malloc(sink->size);
9111 sink->len = 0;
9114 void upb_stringsink_uninit(upb_stringsink *sink) { free(sink->ptr); }
9123 upb_sink sink;
9135 upb_sink sink;
9290 encoder = upb_pb_encoder_create(p->arena, h, frame->stringsink.sink);
9294 upb_sink_reset(&frame->sink, h, encoder);
9296 upb_json_parser_create(p->arena, parser_method, p->symtab, frame->sink,
9476 upb_sink_putstring(p->top->sink, sel, output, 3, NULL);
9501 upb_sink_putstring(p->top->sink, sel, &output, 1, NULL);
9518 upb_sink_putstring(p->top->sink, sel, output, 2, NULL);
9684 upb_sink_putstring(p->top->sink, p->string_selector, buf, len, handle);
9930 upb_sink_putint32(p->top->sink, parser_getsel(p), (int32_t)val);
9941 upb_sink_putuint32(p->top->sink, parser_getsel(p), (uint32_t)val);
9952 upb_sink_putint64(p->top->sink, parser_getsel(p), val);
9963 upb_sink_putuint64(p->top->sink, parser_getsel(p), val);
9994 upb_sink_put ## smalltype(p->top->sink, parser_getsel(p), \
10008 upb_sink_putdouble(p->top->sink, parser_getsel(p), val);
10014 upb_sink_putfloat(p->top->sink, parser_getsel(p), val);
10058 ok = upb_sink_putbool(p->top->sink, parser_getsel(p), val);
10209 upb_sink_startstr(p->top->sink, sel, 0, &inner->sink);
10252 upb_sink_startstr(p->top->sink, sel, 0, &inner->sink);
10254 upb_sink_putstring(inner->sink, sel, buf, len, NULL);
10256 upb_sink_endstr(inner->sink, sel);
10311 upb_sink_endstr(p->top->sink, sel);
10328 upb_sink_putint32(p->top->sink, sel, int_val);
10478 upb_sink_putint64(p->top->sink, parser_getsel(p), seconds);
10486 upb_sink_putint32(p->top->sink, parser_getsel(p), nanos);
10636 upb_sink_putint32(p->top->sink, parser_getsel(p), nanos);
10722 upb_sink_putint64(p->top->sink, parser_getsel(p), seconds);
10749 upb_sink_startstr(p->top->sink, sel, 0, &inner->sink);
10765 upb_sink_putstring(p->top->sink, sel, "_", 1, NULL);
10766 upb_sink_putstring(p->top->sink, sel, &lower, 1, NULL);
10768 upb_sink_putstring(p->top->sink, sel, ptr, 1, NULL);
10785 upb_sink_endstr(p->top->sink, sel);
10845 upb_sink_startstr(p->top->sink, sel, len, &subsink);
10875 /* Map entry: p->top->sink is the seq frame, so we need to start a frame
10887 upb_sink_startsubmsg(p->top->sink, sel, &inner->sink);
10892 * the key field value to the sink, and these handlers will pop the frame
10899 upb_sink_startmsg(p->top->sink);
10975 upb_sink_endmsg(p->top->sink, p->status);
10982 upb_sink_endsubmsg(p->top->sink, (p->top + 1)->sink, sel);
11017 upb_sink_startseq(p->top->sink, sel, &inner->sink);
11034 upb_sink_startsubmsg(p->top->sink, sel, &inner->sink);
11089 upb_sink_endseq(p->top->sink, sel);
11096 upb_sink_endsubmsg(p->top->sink, (p->top + 1)->sink, sel);
11166 upb_sink_startseq(p->top->sink, sel, &inner->sink);
11187 upb_sink_endseq(p->top->sink, sel);
11206 upb_sink_startmsg(p->top->sink);
11212 upb_sink_endmsg(p->top->sink, p->status);
11318 upb_sink_startstr(p->top->sink, sel, 0, &inner->sink);
11320 upb_sink_putstring(inner->sink, sel, p->top->any_frame->stringsink.ptr,
11323 upb_sink_endstr(inner->sink, sel);
12312 p->top->sink = output;
12482 /* TODO: Will need to change if we support pushback from the sink. */