Lines Matching refs:wbuf
46 IWXSTR *wbuf; member
112 IWXSTR *wbuf = rctx->wbuf; in _jbr_flush_chunk() local
114 assert(wbuf); in _jbr_flush_chunk()
125 if (!finish && (iwxstr_size(wbuf) < JBR_HTTP_CHUNK_SIZE)) { in _jbr_flush_chunk()
129 if (iwxstr_size(wbuf) > 0) { in _jbr_flush_chunk()
130 int sz = snprintf(nbuf, JBNUMBUF_SIZE, "%zX\r\n", iwxstr_size(wbuf)); in _jbr_flush_chunk()
135 if (fio_write(uuid, iwxstr_ptr(wbuf), iwxstr_size(wbuf)) < 0) { in _jbr_flush_chunk()
143 iwxstr_clear(wbuf); in _jbr_flush_chunk()
158 IWXSTR *wbuf = rctx->wbuf; in _jbr_query_visitor() local
159 if (!wbuf) { in _jbr_query_visitor()
160 wbuf = iwxstr_new2(512); in _jbr_query_visitor()
161 if (!wbuf) { in _jbr_query_visitor()
164 rctx->wbuf = wbuf; in _jbr_query_visitor()
167 rc = iwxstr_cat(wbuf, iwxstr_ptr(ux->log), iwxstr_size(ux->log)); in _jbr_query_visitor()
169 rc = iwxstr_cat(wbuf, "--------------------", 20); in _jbr_query_visitor()
174 rc = iwxstr_printf(wbuf, "\r\n%lld\t", doc->id); in _jbr_query_visitor()
177 rc = jbn_as_json(doc->node, jbl_xstr_json_printer, wbuf, 0); in _jbr_query_visitor()
179 rc = jbl_as_json(doc->raw, jbl_xstr_json_printer, wbuf, 0); in _jbr_query_visitor()
227 if (!rc && rctx->wbuf) { in _jbr_on_query()
228 rc = iwxstr_cat(rctx->wbuf, "\r\n", 2); in _jbr_on_query()
280 if (rctx->wbuf) { in _jbr_on_query()
281 iwxstr_destroy(rctx->wbuf); in _jbr_on_query()
282 rctx->wbuf = 0; in _jbr_on_query()
888 IWXSTR *wbuf; member
896 IWXSTR *wbuf = qctx->wbuf; in _jbr_ws_query_visitor() local
897 if (!wbuf) { in _jbr_ws_query_visitor()
898 wbuf = iwxstr_new2(512); in _jbr_ws_query_visitor()
899 if (!wbuf) { in _jbr_ws_query_visitor()
902 qctx->wbuf = wbuf; in _jbr_ws_query_visitor()
904 iwxstr_clear(wbuf); in _jbr_ws_query_visitor()
907 rc = iwxstr_printf(wbuf, "%s\texplain\t%s", qctx->key, iwxstr_ptr(ux->log)); in _jbr_ws_query_visitor()
911 _jbr_ws_write_text(qctx->wctx->ws, iwxstr_ptr(wbuf), iwxstr_size(wbuf)); in _jbr_ws_query_visitor()
912 iwxstr_clear(wbuf); in _jbr_ws_query_visitor()
915 rc = iwxstr_printf(wbuf, "%s\t%lld\t", qctx->key, doc->id); in _jbr_ws_query_visitor()
919 rc = jbn_as_json(doc->node, jbl_xstr_json_printer, wbuf, 0); in _jbr_ws_query_visitor()
921 rc = jbl_as_json(doc->raw, jbl_xstr_json_printer, wbuf, 0); in _jbr_ws_query_visitor()
924 if (!_jbr_ws_write_text(qctx->wctx->ws, iwxstr_ptr(wbuf), iwxstr_size(wbuf))) { in _jbr_ws_query_visitor()
961 IWXSTR *wbuf = iwxstr_new(); in _jbr_ws_query() local
962 if (!wbuf) { in _jbr_ws_query()
966 if (!iwxstr_printf(wbuf, "%s\texplain\t%s", qctx.key, iwxstr_ptr(ux.log))) { in _jbr_ws_query()
967 _jbr_ws_write_text(wctx->ws, iwxstr_ptr(wbuf), iwxstr_size(wbuf)); in _jbr_ws_query()
969 iwxstr_destroy(wbuf); in _jbr_ws_query()
999 if (qctx.wbuf) { in _jbr_ws_query()
1000 iwxstr_destroy(qctx.wbuf); in _jbr_ws_query()