Lines Matching defs:db
641 struct decode_baton *db = (struct decode_baton *) baton;
646 if (db->header_bytes < SVNDIFF_HEADER_SIZE)
648 apr_size_t nheader = SVNDIFF_HEADER_SIZE - db->header_bytes;
651 if (memcmp(buffer, SVNDIFF_V0 + db->header_bytes, nheader) == 0)
652 db->version = 0;
653 else if (memcmp(buffer, SVNDIFF_V1 + db->header_bytes, nheader) == 0)
654 db->version = 1;
655 else if (memcmp(buffer, SVNDIFF_V2 + db->header_bytes, nheader) == 0)
656 db->version = 2;
662 db->header_bytes += nheader;
666 svn_stringbuf_appendbytes(db->buffer, buffer, buflen);
685 p = (const unsigned char *) db->buffer->data;
686 end = (const unsigned char *) db->buffer->data + db->buffer->len;
688 if (db->window_header_len == 0)
733 && (sview_offset < db->last_sview_offset
735 < db->last_sview_offset + db->last_sview_len)))
741 db->window_header_len = p - hdr_start;
742 db->sview_offset = sview_offset;
743 db->sview_len = sview_len;
744 db->tview_len = tview_len;
745 db->inslen = inslen;
746 db->newlen = newlen;
751 p += db->window_header_len;
756 if ((apr_size_t) (end - p) < db->inslen + db->newlen)
760 SVN_ERR(decode_window(&window, db->sview_offset, db->sview_len,
761 db->tview_len, db->inslen, db->newlen, p,
762 db->subpool, db->version));
763 SVN_ERR(db->consumer_func(&window, db->consumer_baton));
765 p += db->inslen + db->newlen;
768 svn_stringbuf_remove(db->buffer, 0, db->buffer->len - (end - p));
771 db->window_header_len = 0;
774 db->last_sview_offset = db->sview_offset;
775 db->last_sview_len = db->sview_len;
778 svn_pool_clear(db->subpool);
785 if (db->buffer->len > 5 * SVN__MAX_ENCODED_UINT_LEN)
804 struct decode_baton *db = (struct decode_baton *) baton;
809 if ((db->error_on_early_close)
810 && (db->header_bytes < 4 || db->buffer->len != 0))
815 err = db->consumer_func(NULL, db->consumer_baton);
816 svn_pool_destroy(db->pool);
832 struct decode_baton *db = apr_palloc(pool, sizeof(*db));
834 db->consumer_func = handler;
835 db->consumer_baton = handler_baton;
836 db->pool = subpool;
837 db->subpool = svn_pool_create(subpool);
838 db->buffer = svn_stringbuf_create_empty(db->pool);
839 db->last_sview_offset = 0;
840 db->last_sview_len = 0;
841 db->header_bytes = 0;
842 db->error_on_early_close = error_on_early_close;
843 db->window_header_len = 0;
844 stream = svn_stream_create(db, pool);