Function handshake_success

devtools/gossipwith.c:166–248

}

static struct io_plan *handshake_success(struct io_conn *conn,
					 const struct pubkey *them,
					 const struct wireaddr_internal *addr,
					 struct crypto_state *cs,
					 struct oneshot *timer,
					 char **args)
{
	int peer_fd = io_conn_fd(conn);
	struct pollfd pollfd[2];

	if (initial_sync)
		set_feature_bit(&features,
				OPTIONAL_FEATURE(OPT_INITIAL_ROUTING_SYNC));

	if (!no_init) {
		u8 *msg;
		struct tlv_init_tlvs *tlvs = NULL;
		if (explicit_network) {
			tlvs = tlv_init_tlvs_new(NULL);
			tlvs->networks = tal_arr(tlvs, struct bitcoin_blkid, 1);
			tlvs->networks[0] = chainparams->genesis_blockhash;
		}
		msg = towire_init(NULL, NULL, features, tlvs);

		sync_crypto_write(peer_fd, cs, take(msg));
		/* Ignore their init message. */
		tal_free(sync_crypto_read(NULL, peer_fd, cs));
		tal_free(tlvs);
	}

	if (stream_stdin)
		pollfd[0].fd = STDIN_FILENO;
	else
		pollfd[0].fd = -1;
	pollfd[0].events = POLLIN;
	pollfd[1].fd = peer_fd;
	pollfd[1].events = POLLIN;

	while (*args) {
		u8 *m = tal_hexdata(NULL, *args, strlen(*args));
		if (!m)
			errx(1, "Invalid hexdata '%s'", *args);
		sync_crypto_write(peer_fd, cs, take(m));
		args++;
	}

	while (max_messages != 0 || pollfd[0].fd != -1) {
		beint16_t belen;
		u8 *msg;

		if (poll(pollfd, ARRAY_SIZE(pollfd),
			 timeout_after < 0 ? -1 : timeout_after * 1000) == 0)
			return 0;

		/* We always to stdin first if we can */
		if (pollfd[0].revents & POLLIN) {
			if (!read_all(STDIN_FILENO, &belen, sizeof(belen)))
				pollfd[0].fd = -1;