Function connect_activate_subd

lightningd/peer_control.c:1431–1540

Talk to connectd about an active channel */

/* Talk to connectd about an active channel */
static void connect_activate_subd(struct lightningd *ld, struct channel *channel)
{
	const u8 *error;
	struct peer_fd *pfd;
	int other_fd;

	/* If we have a canned error for this channel, send it now */
	if (channel->error) {
		error = channel->error;
		goto send_error;
	}

	switch (channel->state) {
	case ONCHAIN:
	case FUNDING_SPEND_SEEN:
	case CLOSINGD_COMPLETE:
	case CLOSED:
	case DUALOPEND_OPEN_INIT:
		/* Channel is active */
		abort();
	case AWAITING_UNILATERAL:
		/* channel->error is not saved in db, so this can
		 * happen if we restart. */
		error = towire_errorfmt(tmpctx, &channel->cid,
					"Awaiting unilateral close");
		goto send_error;

	case DUALOPEND_OPEN_COMMIT_READY:
	case DUALOPEND_OPEN_COMMITTED:
	case DUALOPEND_AWAITING_LOCKIN:
		assert(!channel->owner);
		pfd = sockpair(tmpctx, channel, &other_fd, &error);
		if (!pfd)
			goto send_error;

		if (peer_restart_dualopend(channel->peer,
					   pfd,
					   channel, false))
			goto tell_connectd;
		close(other_fd);
		return;

	case CHANNELD_AWAITING_LOCKIN:
	case CHANNELD_NORMAL:
	case CHANNELD_AWAITING_SPLICE:
	case CHANNELD_SHUTTING_DOWN:
	case CLOSINGD_SIGEXCHANGE:
		assert(!channel->owner);
		pfd = sockpair(tmpctx, channel, &other_fd, &error);
		if (!pfd)
			goto send_error;

		if (peer_start_channeld(channel,
					pfd,
					NULL, true)) {
			goto tell_connectd;
		}
		close(other_fd);