Module type `S.GOSSIP_DISSEM`

Gossip + Dissemination combined

include GOSSIP with type node := node and type view := view

val initiate : view:view -> xview:view -> me:node -> view_len:int -> xchg_len:int -> node option * view * view

initiate ~view ~xview ~me ~xchg_len ?distance initiates gossip exchange.

val respond : view:view -> xview:view -> recvd:view -> src:node -> me:node -> view_len:int -> xchg_len:int -> view

respond ~view ~xview ~recvd ~src ~me ~xchg_len responds to a gossip exchange.

val merge : view:view -> xview:view -> sent:view -> recvd:view -> src:node -> me:node -> view_len:int -> xchg_len:int -> view

merge ~view ~view_len ~sent ~recvd ~xchg_len ~me merges received entries during a gossip exchange.

include DISSEMINATION with type nid := nid and type node := node and type view := view and type mid := mid and type seen := seen

val init_seen : int -> seen: init_seen len initializes the queue of last seen messages with maximum queue length len.

val forward : view:view -> seen:seen -> mid:mid -> src:node -> me:node -> fanout:int -> view * seen

Select recipients to forward an incoming or outgoing message. If mid was already seen before, the message is not fowarded.