mirror of
https://github.com/ElementsProject/lightning.git
synced 2024-11-19 18:11:28 +01:00
ee9e300da0
1. The code to skip over padding didn't take into account max. 2. It also didn't use symbolic names. 3. We are not supposed to fail on unknown addresses, just stop parsing. 4. We don't use the read_ip/write_ip code, so get rid of it. Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
134 lines
3.9 KiB
C
134 lines
3.9 KiB
C
#ifndef LIGHTNING_LIGHTNINGD_GOSSIP_ROUTING_H
|
|
#define LIGHTNING_LIGHTNINGD_GOSSIP_ROUTING_H
|
|
#include "config.h"
|
|
#include <bitcoin/pubkey.h>
|
|
#include <ccan/htable/htable_type.h>
|
|
#include <gossipd/broadcast.h>
|
|
#include <wire/wire.h>
|
|
|
|
#define ROUTING_MAX_HOPS 20
|
|
#define ROUTING_FLAGS_DISABLED 2
|
|
|
|
struct node_connection {
|
|
struct node *src, *dst;
|
|
/* millisatoshi. */
|
|
u32 base_fee;
|
|
/* millionths */
|
|
s32 proportional_fee;
|
|
|
|
/* Delay for HTLC in blocks.*/
|
|
u32 delay;
|
|
|
|
/* Is this connection active? */
|
|
bool active;
|
|
|
|
s64 last_timestamp;
|
|
|
|
/* Minimum number of msatoshi in an HTLC */
|
|
u32 htlc_minimum_msat;
|
|
|
|
/* The channel ID, as determined by the anchor transaction */
|
|
struct short_channel_id short_channel_id;
|
|
|
|
/* Flags as specified by the `channel_update`s, among other
|
|
* things indicated direction wrt the `channel_id` */
|
|
u16 flags;
|
|
|
|
/* Cached `channel_announcement` and `channel_update` we might forward to new peers*/
|
|
u8 *channel_announcement;
|
|
u8 *channel_update;
|
|
};
|
|
|
|
struct node {
|
|
struct pubkey id;
|
|
|
|
/* -1 means never; other fields undefined */
|
|
s64 last_timestamp;
|
|
|
|
/* IP/Hostname and port of this node (may be NULL) */
|
|
struct ipaddr *addresses;
|
|
|
|
/* Routes connecting to us, from us. */
|
|
struct node_connection **in, **out;
|
|
|
|
/* Temporary data for routefinding. */
|
|
struct {
|
|
/* Total to get to here from target. */
|
|
s64 total;
|
|
/* Total risk premium of this route. */
|
|
u64 risk;
|
|
/* Where that came from. */
|
|
struct node_connection *prev;
|
|
} bfg[ROUTING_MAX_HOPS+1];
|
|
|
|
/* UTF-8 encoded alias as tal_arr, not zero terminated */
|
|
u8 *alias;
|
|
|
|
/* Color to be used when displaying the name */
|
|
u8 rgb_color[3];
|
|
|
|
/* Cached `node_announcement` we might forward to new peers. */
|
|
u8 *node_announcement;
|
|
};
|
|
|
|
const secp256k1_pubkey *node_map_keyof_node(const struct node *n);
|
|
size_t node_map_hash_key(const secp256k1_pubkey *key);
|
|
bool node_map_node_eq(const struct node *n, const secp256k1_pubkey *key);
|
|
HTABLE_DEFINE_TYPE(struct node, node_map_keyof_node, node_map_hash_key, node_map_node_eq, node_map);
|
|
|
|
struct routing_state {
|
|
/* All known nodes. */
|
|
struct node_map *nodes;
|
|
|
|
struct broadcast_state *broadcasts;
|
|
|
|
struct sha256_double chain_hash;
|
|
};
|
|
|
|
struct route_hop {
|
|
struct short_channel_id channel_id;
|
|
struct pubkey nodeid;
|
|
u32 amount;
|
|
u32 delay;
|
|
};
|
|
|
|
struct routing_state *new_routing_state(const tal_t *ctx,
|
|
const struct sha256_double *chain_hash);
|
|
|
|
/* msatoshi must be possible (< 21 million BTC), ie < 2^60.
|
|
* If it returns more than msatoshi, it overflowed. */
|
|
s64 connection_fee(const struct node_connection *c, u64 msatoshi);
|
|
|
|
/* Add a connection to the routing table, but do not mark it as usable
|
|
* yet. Used by channel_announcements before the channel_update comes
|
|
* in. */
|
|
|
|
struct node_connection *half_add_connection(struct routing_state *rstate,
|
|
const struct pubkey *from,
|
|
const struct pubkey *to,
|
|
const struct short_channel_id *schanid,
|
|
const u16 flags);
|
|
|
|
/* Given a short_channel_id, retrieve the matching connection, or NULL if it is
|
|
* unknown. */
|
|
struct node_connection *get_connection_by_scid(const struct routing_state *rstate,
|
|
const struct short_channel_id *schanid,
|
|
const u8 direction);
|
|
|
|
/* Handlers for incoming messages */
|
|
void handle_channel_announcement(struct routing_state *rstate, const u8 *announce, size_t len);
|
|
void handle_channel_update(struct routing_state *rstate, const u8 *update, size_t len);
|
|
void handle_node_announcement(struct routing_state *rstate, const u8 *node, size_t len);
|
|
|
|
/* Compute a route to a destination, for a given amount and riskfactor. */
|
|
struct route_hop *get_route(tal_t *ctx, struct routing_state *rstate,
|
|
const struct pubkey *source,
|
|
const struct pubkey *destination,
|
|
const u32 msatoshi, double riskfactor);
|
|
|
|
/* Utility function that, given a source and a destination, gives us
|
|
* the direction bit the matching channel should get */
|
|
#define get_channel_direction(from, to) (pubkey_cmp(from, to) > 0)
|
|
|
|
#endif /* LIGHTNING_LIGHTNINGD_GOSSIP_ROUTING_H */
|