- n = byteq_tailroom(&rpc->input);
- used = json_parser_feed(rpc->parser,
- (char *) byteq_tail(&rpc->input), n);
- byteq_advance_tail(&rpc->input, used);
- if (json_parser_is_done(rpc->parser)) {
- jsonrpc_received(rpc);
- if (rpc->status) {
- const struct byteq *q = &rpc->input;
- if (q->head <= q->size) {
- stream_report_content(q->buffer, q->head,
- STREAM_JSONRPC,
- THIS_MODULE, rpc->name);
- }
- return rpc->status;
+
+ if (rpc->status) {
+ const struct byteq *q = &rpc->input;
+ if (q->head <= q->size) {
+ stream_report_content(q->buffer, q->head, STREAM_JSONRPC,
+ THIS_MODULE, rpc->name);