Function rpc_conn_read_response

plugins/libplugin.c:1378–1410

static struct io_plan *rpc_conn_read_response(struct io_conn *conn,
					      struct plugin *plugin)
{
	const tal_t *working_ctx = tal(NULL, char);

	/* Gather an parse any new bytes */
	for (;;) {
		const jsmntok_t *toks;
		const char *buf;
		const char *err;

		err = jsonrpc_io_parse(tmpctx,
				       plugin->jsonrpc_in,
				       &toks, &buf);
		if (err)
			plugin_err(plugin, "%s", err);

		if (!toks)
			break;

		handle_rpc_reply(working_ctx, plugin, buf, toks);
		jsonrpc_io_parse_done(plugin->jsonrpc_in);
	}

	/* Explicitly free any expired requests now; xpay uses this to
	 * fire more commands! */
	tal_free(working_ctx);

	/* Read more */
	return jsonrpc_io_read(conn, plugin->jsonrpc_in,
			       rpc_conn_read_response,
			       plugin);
}

static struct io_plan *rpc_conn_write_request(struct io_conn *conn,
					      struct plugin *plugin);