aboutsummaryrefslogtreecommitdiffstats
path: root/src/transport/mod.rs
Commit message (Collapse)AuthorAgeFilesLines
* signatures: up to 4096 in a message, each actor's latest past themtv2 days1-3/+3
| | | | | | | | | | | | | | | | Review 4, F5: a delta, and a message whose changes held more than 256 signatures (a whole document pulled, of any real history), carried each actor's latest signature, the 256 that became latest last. An actor is a node's run, so past 256 runs writing in an epoch, some actors' changes arrived unvouched at the puller under a policy requiring signatures, waited, and every resend carried the same 256: a joiner never finished. A message now carries up to 4096 signatures (`MAX_PER_MESSAGE`, as many as wait for their changes, `MAX_PENDING`: 384 KiB at most), all of its changes' up to there, each actor's latest past it and for a delta, and a receiver takes as many (wire version 47). An epoch with more than 4096 runs writing would still leave some unvouched in such a transfer, which the constant says; sending each actor of the transfer its own latest would need the actors of a delta's changes, which only rebuilding their metadata gives.
* transport: a pushed change written out by its size, never its bytestv2 days1-2/+39
| | | | | | | | | | | | Review 4, F3: the console writes each message out with `{:#?}`, and `SyncBody` derived `Debug`, so `Changes` (changes pushed as they are) printed every byte of every change. Pushes are the small messages, and Automerge deflates no change under 256 bytes: a short value's path and value went into the console in clear, which any user with any capability reads (the page's `messages` events, and since 1266 a subscribed node's `messages/own/{seq}` too), paths it may not read included. `SyncBody` now writes itself out with sizes for the changes, as `SyncPayload` does for an Automerge message; heads and a delta's spec stay as they were.
* swarm: no SIGNATUREStv3 days1-16/+0
| | | | | | | | | | | | | | Signatures sent on their own (SIGNATURES, every second, to each peer not sent them yet) flooded every link: a signature made after its change left, or one that came with changes, went to every neighbour, whether or not it got the change along with its signature elsewhere. With every change of a node signed as it leaves (1217) and signatures going where their changes go (1218), none is left for them to carry: the message, its task and its traffic counter go (wire version 46). Signatures waiting for their changes are offered as before when sync messages bring them, and the changes waiting for signatures judged again with the next batch.
* roots: an epoch's root pinned, and named in every handshaketv3 days1-0/+9
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Review 2, N7, the care it raised: a joining node's empty document took as the first epoch's root whatever dependency-less change came first, from whichever peer it joined through; the first epoch's ID is all zeros, so nothing pinned it. A remake's epoch has its ID, the snapshot change's hash, which the rules hold its root to. * Every node names its epoch's root in HELLO and HELLO_REPLY (the epoch's ID for a remake's, its genesis change for the first; wire version 45). A node whose document starts from another root of the same epoch refuses the handshake, logging it: another history under the swarm's ID, a forged root or a genesis started again. * A joining node with an empty document takes as its root only the one it was given (--genesis-root, new), else the one its peers name, and none while they name different ones (access::screen::RootPin, kept in Screening across documents): one peer hands it another root only if it is all the joiner hears, or never, with --genesis-root. A root refused is listed with the refused, what builds on it with it. * The genesis node logs the root (`The swarm's root`); GET /admin/epochs shows it (`root`). A genesis started again under a remembered swarm ID used to merge with the nodes of it still running; they now refuse it (another root), and the docs say to join them with seeds instead. The epoch's identity stays as it is (generation 0 all zeros): records and epoch metadata name it so, and every comparison of epochs with them.
* swarm: changes taken unjudged, dropped (REFUSALS)tv4 days1-0/+20
| | | | | | | | | A node refusing changes a peer brought tells it which broke a rule; the peer judges them itself, and if its rules refuse them too, drops them with all built on them (its document forked without them, a fresh actor), quarantining its own writes among them. Wire version 42. Auth plan M6 (rejoin on taint).
* signatures: on their own (SIGNATURES)tv4 days1-0/+16
| | | | | | | Signatures no sync message took go on their own within a second, to each peer not sent them yet (wire version bumped). Auth plan M5.
* signatures: with sync messagestv4 days1-0/+4
| | | | | | | Sync messages carry, for each actor's writes, the latest signature the sender checked; the receiver checks it once it holds the change. Auth plan M5.
* dashboard: without LINKS; LINKS removedtv4 days1-97/+0
| | | | | | | | | The dashboard reads every member's links from the members themselves; LINKS and LINKS_REPLY, swarm::links and their wire tags go (wire version bumped). Nodes the browser can't reach are drawn from what the reachable ones measure. Auth plan M3.
* HyParView (slim)tv5 days1-0/+39
|
* plumtreetv5 days1-0/+23
|
* indirect probestv5 days1-0/+40
|
* strangers messages smalltv6 days1-0/+64
|
* round trips in treestv7 days1-0/+5
|
* push by defaulttv7 days1-4/+4
|
* pushed heads as tipstv7 days1-1/+2
|
* push changes experimenttv7 days1-0/+9
|
* suspect pathstv7 days1-0/+7
|
* deflate blob chunkstv7 days1-0/+12
|
* deflate blob chunkstv7 days1-0/+2
|
* epoch tag in synctv7 days1-5/+64
|
* no swarm ID in synctv7 days1-1/+0
|
* dashboard: swarm-wide epoch shinetv7 days1-0/+4
|
* delta from held headstv7 days1-2/+2
|
* time blob messagestv7 days1-0/+3
|
* hop delaystv7 days1-0/+3
|
* any message taken as deliveredtv7 days1-0/+5
|
* announcements answered when lackingtv8 days1-2/+2
| | | | | | | A neighbour now answers an announcement only if it lacks some of the announced heads. Heads that merely differ are no longer enough, since they do while writes go on. The check reads the document, so it runs off the message consumer, as the pull check already does.
* unanswered members not reachedtv8 days1-1/+1
|
* replace eager links by treestv9 days1-8/+0
|
* add writer treestv9 days1-0/+4
|
* measure 2-hop neighbourhoodtv9 days1-0/+4
|
* dashboard: show eager links on the maptv9 days1-0/+4
|
* introduce eager linkstv9 days1-0/+4
|
* announcements answered only if heads differtv9 days1-0/+4
|
* swarm: relay links messagestv9 days1-2/+21
|
* probe when reachabletv10 days1-0/+7
|
* introduce per-transport sync reply timeouttv10 days1-0/+7
|
* bootstrap: replace pull by progress notifytv10 days1-0/+6
|
* config: use individual transport enable flagstv11 days1-1/+1
|
* links report downtv11 days1-0/+3
|
* move SyncSession to documenttv11 days1-2/+2
|
* move changes as bytes to documenttv11 days1-1/+1
|
* sync messages are bytes outside the sessiontv11 days1-15/+4
| | | | | | | | SyncPayload is now an opaque byte container in transport. SyncSession::generate returns the encoded payload, state::decode_sync(&payload) decodes it off the document lock (as before), and receive takes the decoded message, which is a type only the session can open. transport/mod.rs no longer imports Automerge.
* rename AutoMerge to Documenttv11 days1-1/+2
|
* links replies carry clock offsetstv11 days1-0/+3
|
* calculate peer clock drifttv12 days1-0/+7
|
* pong carries timetv12 days1-5/+9
|
* allow links subscriptionstv12 days1-0/+4
|
* farewell means dormanttv12 days1-0/+3
|
* links answers connection typetv12 days1-0/+2
|