Function json_stfu_channels

lightningd/channel_control.c:2545–2612

}

static struct command_result *json_stfu_channels(struct command *cmd,
						 const char *buffer,
						 const jsmntok_t *obj UNNEEDED,
						 const jsmntok_t *params)
{
	struct channel *channel, **channels;
	const jsmntok_t *channel_ids_tok, *channel_id_tok;
	struct command_result *result;
	struct splice_command *cc;
	struct stfu_req_info *req;
	size_t i;

	if (!param_check(cmd, buffer, params,
			 p_opt("channel_ids", param_array, &channel_ids_tok),
			 NULL))
		return command_param_failed();

	channels = tal_arr(cmd, struct channel*, 0);
	json_for_each_arr(i, channel_id_tok, channel_ids_tok) {
		result = param_channel_for_splice(cmd, NULL, buffer, channel_id_tok,
						  &channel);
		if (result)
			return result;
		if (splice_command_for_chan(cmd->ld, channel))
			return command_fail(cmd,
					    SPLICE_BUSY_ERROR,
					    "Currently waiting on previous"
					    " splice command to finish.");

		tal_arr_expand(&channels, channel);
	}

	if (!tal_count(channels))
		return command_fail_badparam(cmd, "channel_ids", buffer,
					     channel_ids_tok,
					     "Must specify a channel");

	if (command_check_only(cmd))
		return command_check_done(cmd);

	req = tal(cmd, struct stfu_req_info);

	/* Next we split into multiple `stfu` commands. The final command to
	 * return finish the cmd response */
	req->results = tal_arr(cmd, struct stfu_result*, 0);
	req->channel_ids = tal_arr(cmd, struct channel_id*,
				   tal_count(channels));

	for (i = 0; i < tal_count(channels); i++) {
		channel = channels[i];

		req->channel_ids[i] = tal(req->channel_ids, struct channel_id);
		*req->channel_ids[i] = channel->cid;

		cc = tal(cmd, struct splice_command);

		list_add_tail(&cmd->ld->splice_commands, &cc->list);
		tal_add_destructor(cc, destroy_splice_command);