Function msg_out_dev_disconnect

connectd/multiplex.c:435–467

--dev-disconnect can do magic things: if this returns non-NULL, free msg and do that */

/* --dev-disconnect can do magic things: if this returns non-NULL,
     free msg and do that */
static struct io_plan *msg_out_dev_disconnect(struct peer *peer, const u8 *msg)
{
	int type = fromwire_peektype(msg);

	switch (dev_disconnect_out(&peer->id, type)) {
	case DEV_DISCONNECT_OUT_BEFORE:
		return io_close(peer->to_peer);
	case DEV_DISCONNECT_OUT_AFTER:
		/* Disallow reads from now on */
		peer->dev_read_enabled = false;
		free_all_subds(peer);
		drain_peer(peer);
		return NULL;
	case DEV_DISCONNECT_OUT_BLACKHOLE:
		/* Disable both reads and writes from now on */
		peer->dev_read_enabled = false;
		peer->dev_writes_enabled = talz(peer, u32);
		return NULL;
	case DEV_DISCONNECT_OUT_NORMAL:
		return NULL;
	case DEV_DISCONNECT_OUT_DROP:
		/* Tell them to read again. */
		io_wake(&peer->subds);
		return msg_queue_wait(peer->to_peer, peer->peer_outq,
				      write_to_peer, peer);
	case DEV_DISCONNECT_OUT_DISABLE_AFTER:
		peer->dev_read_enabled = false;
		peer->dev_writes_enabled = tal(peer, u32);
		*peer->dev_writes_enabled = 1;
		return NULL;
	}
	abort();
}

/* Do we have enough bytes without padding? */
static bool have_full_encrypted_queue(const struct peer *peer)