Function sync_req

plugins/libplugin.c:773–806

Send request, return response, set resp/len to reponse */

/* Send request, return response, set resp/len to reponse */
static const jsmntok_t *sync_req(const tal_t *ctx,
				 struct plugin *plugin,
				 const char *method,
				 const struct json_out *params TAKES,
				 const char **resp)
{
	struct json_out *jout = json_out_new(tmpctx);
	const char *id = json_id(tmpctx, plugin, "init/", method);

	json_out_start(jout, NULL, '{');
	json_out_addstr(jout, "jsonrpc", "2.0");
	/* Copy in id *literally* */
	memcpy(json_out_member_direct(jout, "id", strlen(id)), id, strlen(id));
	json_out_addstr(jout, "method", method);
	if (params)
		json_out_add_splice(jout, "params", params);
	else {
		json_out_start(jout, "params", '{');
		json_out_end(jout, '}');
	}
	tal_free_if_taken(params);

	/* If we're past init, we may need a new fd (the old one
	 * is being used for async comms). */
	if (plugin->sync_fd == -1) {
		plugin->sync_fd = rpc_open(plugin);
		if (!plugin->sync_io)
			plugin->sync_io = jsonrpc_io_new(plugin);
	}

	finish_and_send_json(plugin->sync_fd, jout);

	return read_sync_rpc_reply(ctx, plugin, method, resp);
}

const jsmntok_t *jsonrpc_request_sync(const tal_t *ctx,
				      struct command *cmd,