mirror of
https://github.com/aljazceru/lightning.git
synced 2025-12-19 23:24:27 +01:00
8678c5efb3
Now we have separate peer draining logic, we can simply use it when connectd tells us to release the peer, without waiting. (We could simply free the peer, but that's a bit rude, as messages can get lost). This removes various complex flags and logic we had before. Signed-off-by: Rusty Russell <rusty@rustcorp.com.au> Changelog-Fixed: `connectd`: various crashes and issues fixed by simplification and rewrite.
38 lines
1.2 KiB
C
38 lines
1.2 KiB
C
#ifndef LIGHTNING_CONNECTD_MULTIPLEX_H
|
|
#define LIGHTNING_CONNECTD_MULTIPLEX_H
|
|
#include "config.h"
|
|
#include <ccan/short_types/short_types.h>
|
|
#include <common/crypto_state.h>
|
|
#include <common/msg_queue.h>
|
|
#include <common/node_id.h>
|
|
|
|
struct peer;
|
|
struct io_conn;
|
|
struct feature_set;
|
|
|
|
/* Take over peer_conn as peer->to_peer */
|
|
struct io_plan *multiplex_peer_setup(struct io_conn *peer_conn,
|
|
struct peer *peer);
|
|
|
|
/* Send this message to peer and disconnect. */
|
|
void multiplex_final_msg(struct peer *peer,
|
|
const u8 *final_msg TAKES);
|
|
|
|
/* Inject a message into the output stream. Unlike a raw msg_enqueue,
|
|
* this does io logging. */
|
|
void inject_peer_msg(struct peer *peer, const u8 *msg TAKES);
|
|
|
|
void setup_peer_gossip_store(struct peer *peer,
|
|
const struct feature_set *our_features,
|
|
const u8 *their_features);
|
|
|
|
/* When lightningd says to send a ping */
|
|
void send_manual_ping(struct daemon *daemon, const u8 *msg);
|
|
|
|
/* When lightningd says to send a custom message (from a plugin) */
|
|
void send_custommsg(struct daemon *daemon, const u8 *msg);
|
|
|
|
/* Lightningd wants to talk to you. */
|
|
void peer_make_active(struct daemon *daemon, const u8 *msg);
|
|
#endif /* LIGHTNING_CONNECTD_MULTIPLEX_H */
|