| Commit message (Collapse) | Author | Age | Files | Lines |
|---|
| |
|
|
|
|
|
| |
Sync messages are now being decoded only where they are applied: after
membership has been checked, in the sync lane's blocking task.
Debug now shows only the size instead of the whole message.
|
| |
|
|
|
|
| |
When there are more than 32 heads that can be send in a single keepalive
message, the digest is accompanied by 32 heads, a different window each
time, so after a few keepalives every head has been listed.
|
| |
|
|
| |
This prevents late hellos from resetting the session.
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
|
|
|
|
|
|
|
|
| |
This introduces a new wrapper that counts messages and payload bytes per
peer, split by kind (hello, helloReply, sync, ping, pong), each sent,
received and refused.
The traffic counter goes around the firewall, which means messages
dropped outbound are still counted as sent, and messages dropped inbound
don't count as received.
|
| | |
|
| |
|
|
|
| |
To prevent stale hello replies to cause joins and thus stale sessions,
each run gets a random ID, which used as nonce in the handshake.
|
| |
|
|
|
|
|
|
|
|
| |
Ready nodes will leave the first message to the pear that isn't ready.
Hello and hello reply now carry ready, so readiness is known from the
very first contact, before any sync. Together with the sync messages
and keepalives, reports_ready is always current.
After epoch switch, pings go to everyone except ready members already
on the new epoch, these learn from the lagging peer's opening.
|
| | |
|
| |
|
|
|
| |
Instead of arbitrarily limiting the number to 16, allow filling
keepalive messages as long as they don't cause mycelium to chunk it.
|
| |
|
|
|
|
|
| |
Add ready and syncs_with_you flags as well as actual heads, so the peer
- ready: same meaning as in the sync message
- syncs_with_you: sender counts recipient as member and in same epoch
- heads: allows to tell who's behind or if both sides have changes
|
| |
|
|
|
|
| |
Sync messages now carries a ready flag, telling whether the sending peer
itself is joined or is itself still (re-)joining. In the latter case,
the peer won't be used as sync source.
|
| | |
|
| | |
|
| | |
|
| |
|
