lightning/gossipd/broadcast.h

#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 broadcast_state {
	u64 next_index;
	UINTMAP(struct queued_message *) broadcasts;
};

struct broadcast_state *new_broadcast_state(tal_t *ctx);

/* Replace a queued message with @index, if it matches the type and
 * tag for the new message. The new message will be queued with the
 * next highest index. @index is updated to hold the index of the
 * newly queued message*/
bool replace_broadcast(const tal_t *ctx,
		       struct broadcast_state *bstate,
		       u64 *index,
		       const u8 *payload TAKES);


const u8 *next_broadcast(struct broadcast_state *bstate, u64 *last_index);

const u8 *get_broadcast(struct broadcast_state *bstate, u64 msgidx);
#endif /* LIGHTNING_GOSSIPD_BROADCAST_H */
Use expected LIGHTNING_DIR_FILE_H define 7 years ago			`#ifndef LIGHTNING_GOSSIPD_BROADCAST_H`
			`#define LIGHTNING_GOSSIPD_BROADCAST_H`
gossip: Moving to intmap-based broadcast for the legacy daemon Moved the broadcast functionality to broadcast.[ch]. So far this includes only the enqueuing side of broadcasts, the dequeuing and actual push to the peer is daemon dependent. This also adds the broadcast_state to the routing_state and the last broadcast index to the peer for the legacy daemon. 8 years ago			`#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 broadcast_state {`
gossipd: use u64 for broadcast index. uintmap uses uint64_t, we should here too. Couldn't resist drive-by style fix for increment :) Signed-off-by: Rusty Russell <rusty@rustcorp.com.au> 7 years ago			`u64 next_index;`
broadcast: Added option to replace a specific index We are wasting way too much time looking for announcements and updates in the broadcast. We can just hint where to find the message to be evicted and safe the traversal. Signed-off-by: Christian Decker <decker.christian@gmail.com> 7 years ago			`UINTMAP(struct queued_message *) broadcasts;`
gossip: Moving to intmap-based broadcast for the legacy daemon Moved the broadcast functionality to broadcast.[ch]. So far this includes only the enqueuing side of broadcasts, the dequeuing and actual push to the peer is daemon dependent. This also adds the broadcast_state to the routing_state and the last broadcast index to the peer for the legacy daemon. 8 years ago			`};`

			`struct broadcast_state new_broadcast_state(tal_t ctx);`

broadcast: Added option to replace a specific index We are wasting way too much time looking for announcements and updates in the broadcast. We can just hint where to find the message to be evicted and safe the traversal. Signed-off-by: Christian Decker <decker.christian@gmail.com> 7 years ago			`/* Replace a queued message with @index, if it matches the type and`
			`* tag for the new message. The new message will be queued with the`
			`* next highest index. @index is updated to hold the index of the`
			`* newly queued message*/`
gossipd: remove tag. We only access via index. We do, however, want to clean up when we delete nodes and channels, so we tie lifetimes to that. This leads us to put the index into 'struct queued_message'. Signed-off-by: Rusty Russell <rusty@rustcorp.com.au> 7 years ago			`bool replace_broadcast(const tal_t *ctx,`
			`struct broadcast_state *bstate,`
broadcast: Added option to replace a specific index We are wasting way too much time looking for announcements and updates in the broadcast. We can just hint where to find the message to be evicted and safe the traversal. Signed-off-by: Christian Decker <decker.christian@gmail.com> 7 years ago			`u64 *index,`
gossipd: annotate replace_broadcast that we take() the payload, make it const. We tal_dup_arr() it, which does take. Make it const in the structure; the tal_dup_arr() removes the const, so it compiles without it, but it's misleading. Signed-off-by: Rusty Russell <rusty@rustcorp.com.au> 7 years ago			`const u8 *payload TAKES);`
broadcast: Added option to replace a specific index We are wasting way too much time looking for announcements and updates in the broadcast. We can just hint where to find the message to be evicted and safe the traversal. Signed-off-by: Christian Decker <decker.christian@gmail.com> 7 years ago

gossipd: make struct queued_message private. Callers don't need it, and when we add timestamps it just makes for more places to change. Signed-off-by: Rusty Russell <rusty@rustcorp.com.au> 7 years ago			`const u8 next_broadcast(struct broadcast_state bstate, u64 *last_index);`
gossip: Moving to intmap-based broadcast for the legacy daemon Moved the broadcast functionality to broadcast.[ch]. So far this includes only the enqueuing side of broadcasts, the dequeuing and actual push to the peer is daemon dependent. This also adds the broadcast_state to the routing_state and the last broadcast index to the peer for the legacy daemon. 8 years ago
gossipd: use the broadcast structure to hold gossip messages. We currently keep two copies; one in the broadcast structure to send in order, and one in the routing information. Since we already keep the broadcast index in the routing information, use that. Conveniently, a zero index is the same as the old NULL test. Rename struct node's announcement_idx to node_announce_msgidx to make it match the other users. Signed-off-by: Rusty Russell <rusty@rustcorp.com.au> 7 years ago			`const u8 get_broadcast(struct broadcast_state bstate, u64 msgidx);`
Use expected LIGHTNING_DIR_FILE_H define 7 years ago			`#endif /* LIGHTNING_GOSSIPD_BROADCAST_H */`