mirror of
https://github.com/ElementsProject/lightning.git
synced 2025-01-18 05:12:45 +01:00
f5a218f9d1
Instead of reading the store ourselves, we can just send them an offset. This saves gossipd a lot of work, putting it where it belongs (in the daemon responsible for the specific peer). MCP bench results: store_load_msec:28509-31001(29206.6+/-9.4e+02) vsz_kb:580004-580016(580006+/-4.8) store_rewrite_sec:11.640000-12.730000(11.908+/-0.41) listnodes_sec:1.790000-1.880000(1.83+/-0.032) listchannels_sec:21.180000-21.950000(21.476+/-0.27) routing_sec:2.210000-11.160000(7.126+/-3.1) peer_write_all_sec:36.270000-41.200000(38.168+/-1.9) Signficant savings in streaming gossip: -peer_write_all_sec:48.160000-51.480000(49.608+/-1.1) +peer_write_all_sec:35.780000-37.980000(36.43+/-0.81) Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
79 lines
2.5 KiB
C
79 lines
2.5 KiB
C
#ifndef LIGHTNING_GOSSIPD_BROADCAST_H
|
|
#define LIGHTNING_GOSSIPD_BROADCAST_H
|
|
#include "config.h"
|
|
|
|
#include <ccan/intmap/intmap.h>
|
|
#include <ccan/list/list.h>
|
|
#include <ccan/short_types/short_types.h>
|
|
#include <ccan/tal/tal.h>
|
|
|
|
/* Common functionality to implement staggered broadcasts with replacement. */
|
|
|
|
struct routing_state;
|
|
|
|
/* This is nested inside a node, chan or half_chan; rewriting the store can
|
|
* cause it to change! */
|
|
struct broadcastable {
|
|
/* This is also the offset within the gossip_store; even with 1M
|
|
* channels we still have a factor of 8 before this wraps. */
|
|
u32 index;
|
|
u32 timestamp;
|
|
};
|
|
|
|
struct broadcast_state {
|
|
UINTMAP(struct broadcastable *) broadcasts;
|
|
size_t count;
|
|
struct gossip_store *gs;
|
|
struct list_head *peers;
|
|
};
|
|
|
|
static inline void broadcastable_init(struct broadcastable *bcast)
|
|
{
|
|
bcast->index = 0;
|
|
}
|
|
|
|
struct broadcast_state *new_broadcast_state(struct routing_state *rstate,
|
|
struct gossip_store *gs,
|
|
struct list_head *peers);
|
|
|
|
/* Append a queued message for broadcast. Must be explicitly deleted.
|
|
* Also adds it to the gossip store.
|
|
*
|
|
* If it's a channel_announcement, channel_announce_sat must be set.
|
|
*/
|
|
void insert_broadcast(struct broadcast_state **bstate,
|
|
const u8 *msg,
|
|
const struct amount_sat *channel_announce_sat,
|
|
struct broadcastable *bcast);
|
|
|
|
/* Add to broadcast, but not store: for gossip store compaction. */
|
|
void insert_broadcast_nostore(struct broadcast_state *bstate,
|
|
struct broadcastable *bcast);
|
|
|
|
/* Delete a broadcast: not usually needed, since destructor does it */
|
|
void broadcast_del(struct broadcast_state *bstate,
|
|
struct broadcastable *bcast);
|
|
|
|
/* Return the next broadcastable entry; doesn't load it. */
|
|
struct broadcastable *next_broadcast_raw(struct broadcast_state *bstate,
|
|
u32 *last_index);
|
|
|
|
/* Return the broadcast with index >= *last_index, timestamp >= min and <= max
|
|
* and update *last_index.
|
|
* There's no broadcast with index 0. */
|
|
struct broadcastable *next_broadcast(struct broadcast_state *bstate,
|
|
u32 timestamp_min, u32 timestamp_max,
|
|
u32 *last_index);
|
|
|
|
/* index of last entry. */
|
|
u64 broadcast_final_index(const struct broadcast_state *bstate);
|
|
|
|
/* Returns b if all OK, otherwise aborts if abortstr non-NULL, otherwise returns
|
|
* NULL. */
|
|
struct broadcast_state *broadcast_state_check(struct broadcast_state *b,
|
|
const char *abortstr);
|
|
|
|
/* Callback for after we compacted the store */
|
|
void update_peers_broadcast_index(struct list_head *peers, u32 offset);
|
|
#endif /* LIGHTNING_GOSSIPD_BROADCAST_H */
|