struct Sender<'a> {Show 15 fields
server: &'a Server,
folder: &'a Path,
memory: &'a Path,
own: &'a str,
url: &'a str,
sealed: &'a BTreeMap<String, u64>,
sending: &'a mut Sending,
pulled: &'a mut Pulled,
now: i64,
frugal: bool,
lane: Lane,
past: Option<u32>,
departed: Departed,
known: &'a BTreeMap<String, Fetched>,
unlisted: BTreeSet<String>,
}Expand description
One send beside the sync app.
Fields§
§server: &'a Server§folder: &'a Path§memory: &'a PathThe sharing’s memory (share::rounds_past reads where its rounds stand).
own: &'a str§url: &'a strThe folder there, an address ending with “/”.
sealed: &'a BTreeMap<String, u64>§sending: &'a mut Sending§pulled: &'a mut Pulled§now: i64§frugal: bool§lane: Lane§past: Option<u32>With a listing: this device’s rounds below this one are past their
time (share::rounds_past), taken out there when still listed.
departed: DepartedWith a listing: what this device took out here of the devices that
no longer count (Departed), taken out there too.
known: &'a BTreeMap<String, Fetched>The others’ files as the pull last saw them there (State::files): a
removed device’s file is taken out only while still as seen.
unlisted: BTreeSet<String>The folders a check could not list (list_own).
Implementations§
Source§impl Sender<'_>
impl Sender<'_>
fn url(&self, relative: &str) -> String
Sourcefn run(
&mut self,
files: &[String],
check: bool,
again: bool,
) -> Result<(), Stop>
fn run( &mut self, files: &[String], check: bool, again: bool, ) -> Result<(), Stop>
files in their order (records first, by round, then the notes to
the others, the claims, the entry, the sealed files last): nothing
large holds back what the others wait for. A records file held back
holds the next ones (records go in order); the other files still go.
Sourcefn list_own(&mut self) -> Result<BTreeMap<String, Item>, Stop>
fn list_own(&mut self) -> Result<BTreeMap<String, Item>, Stop>
The server’s copies of this device’s files, by their path in the
folder: the folder itself, devices/, each part’s claims, blobs/
(when this device sealed any), texts/send/, phone-messages/ask/. A folder not there holds none.
Sourcefn same(
&self,
relative: &str,
there: &Item,
bytes: &[u8],
sha1: &str,
) -> Result<bool, Stop>
fn same( &self, relative: &str, there: &Item, bytes: &[u8], sha1: &str, ) -> Result<bool, Stop>
Whether the server’s copy is this file as it is here: a sealed file by its size (its name is its content’s); records by their size (they only grow, one writer) and their checksum when the server keeps one; the rest by their checksum, else read there and compared.
Sourcefn one(
&mut self,
relative: &str,
listed: Option<Option<Item>>,
again: bool,
look: bool,
) -> Result<Went, Stop>
fn one( &mut self, relative: &str, listed: Option<Option<Item>>, again: bool, look: bool, ) -> Result<Went, Stop>
One of this device’s files, sent when it changed here since it went
(or, there listed, when the server’s copy is not this one), over
what is there as it was seen. Refused because it changed there
meanwhile (412): the server’s copy looked at; the same as here (the
sync app sent it), nothing more; else sent over it. A folder missing
there (409), made first. Too slow or cut: held back (backoff).
look: “Send everything again” while its folder could not be listed:
what is there asked of the server itself, never taken as unchanged
(review of 18 October 2026, L-7).
Sourcefn failed(&mut self, relative: &str, failed: PutFailed) -> Result<Went, Stop>
fn failed(&mut self, relative: &str, failed: PutFailed) -> Result<Went, Stop>
A file that did not go, said in detail (Sending::failure). Too slow
or cut on its way (the connection made, its bytes moving): that file
held back (backoff), the others still going. Else (the server
unreachable, refused, out of time): the send stops.
Sourcefn make_folders(&mut self, relative: &str) -> Result<(), Stop>
fn make_folders(&mut self, relative: &str) -> Result<(), Stop>
The folders a file’s path goes through, made there (MKCOL) when missing.
Sourcefn take_out_gone(&mut self, check: bool) -> Result<(), Stop>
fn take_out_gone(&mut self, check: bool) -> Result<(), Stop>
What this device sent and let go here, taken out there as it was
sent (If-Match): its records past their time (removed here once
every device read past them), never its last round, and nothing while
none of its records is here; the sealed files it swept. Gone there
already: forgotten. Changed there since (412): looked at there, and
taken out when it is still what this device sent (again_after_412).
Any other answer (423 while a sync app sends that very file again, a
server’s error, 403), or a look that fails: left there, the send
going on, never held back for it; a round forgotten here and looked
for again at the next listing (take_out_past), a sealed file kept
here and tried again at the next listing (Sending::refused; check:
this send lists). Until the final review of 15 October 2026 (RES-1)
such an answer failed the whole send, after its files went, and held
the next sends back, the records with them. Another file gone here (a
claim of a part no longer kept) is forgotten, left there.
Sourcefn again_after_412(
&mut self,
relative: &str,
sent: &Sent,
records: bool,
) -> bool
fn again_after_412( &mut self, relative: &str, sent: &Sent, records: bool, ) -> bool
One of this device’s files to take out there, refused as changed
there since it went (412). A sync app sends the same file again:
eDrive sends each file Sioul sent, the same bytes, and Nextcloud gives
it a new ETag. Until 15 October 2026 such a file was forgotten here and
stayed on the server for good (a phone’s past full rounds, 47 MB on the
owner’s). Looked at there now: of the size this device sent (records
only grow and only this device writes them; a sealed file’s name is
its content’s), and for a sealed file still dated as this device sent
it, it is taken out, over its ETag there now. A sealed file dated
otherwise was sent there again by another device that uses that
content again (blobs::put makes it fresh, and its sync app sends the
new time): its use, never taken out. Of another size there (a round
grown there): left there, forgotten here; this device’s past rounds
are looked for again at each listing (take_out_past). Refused again,
or any other answer, a failure too (a server’s error, a timeout): left
there, the send going on and not held back (review of 15 October 2026,
L1), a round forgotten here as above, a sealed file kept here and tried
again at the next listing (Sending::refused). Whether it is settled:
taken out, gone there, or not this device’s to take out.
Sourcefn take_out_past(
&mut self,
listed: &BTreeMap<String, Item>,
past: u32,
) -> Result<(), Stop>
fn take_out_past( &mut self, listed: &BTreeMap<String, Item>, past: u32, ) -> Result<(), Stop>
This device’s records past their time still listed there (below
past, share::rounds_past: every device heard lately read past
them, and none is its last full round or one continuing it) and gone
here: taken out over their ETag there, whatever sent them, so that
those a sync app left there (eDrive passes no deletion on), or that
were forgotten here before 15 October 2026, go too. Only files named
as this device’s records, never another device’s file; nothing while
none of its records is here. Refused, or any other answer: left for
the next listing, the send going on.
Sourcefn take_out_departed(&mut self, listed: &BTreeMap<String, Item>)
fn take_out_departed(&mut self, listed: &BTreeMap<String, Item>)
What this device took out here of the devices that no longer count
(Departed), still listed there and gone here (from the folder and
from what was fetched beside it): their past rounds over the ETag
listed, the sealed files swept when still as old there
(take_out_swept). Any device that counts does the same; a file
another took out first is gone (404), one sent again since is
changed (412): left, as any other answer or failure, for the next
listing, the send going on.
Auto Trait Implementations§
impl<'a> !RefUnwindSafe for Sender<'a>
impl<'a> !UnwindSafe for Sender<'a>
impl<'a> Freeze for Sender<'a>
impl<'a> Send for Sender<'a>
impl<'a> Sync for Sender<'a>
impl<'a> Unpin for Sender<'a>
impl<'a> UnsafeUnpin for Sender<'a>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<T> Conv for T
impl<T> Conv for T
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self to use its Binary implementation when Debug-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self to use its Display implementation when
Debug-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self to use its LowerExp implementation when
Debug-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self to use its LowerHex implementation when
Debug-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self to use its Octal implementation when Debug-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self to use its Pointer implementation when
Debug-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self to use its UpperExp implementation when
Debug-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self to use its UpperHex implementation when
Debug-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self, then passes self.as_ref() into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self, then passes self.as_mut() into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self, then passes self.deref() into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B> of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B> of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R> view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R> view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap() only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut() only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow() only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut() only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref() only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut() only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref() only in debug builds, and is erased in release
builds.