struct Sender<'a> {
server: &'a Server,
folder: &'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,
}Expand description
One send beside the sync app.
Fields§
§server: &'a Server§folder: &'a Path§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: LaneImplementations§
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/. 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,
) -> Result<Went, Stop>
fn one( &mut self, relative: &str, listed: Option<Option<Item>>, again: 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).
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) -> Result<(), Stop>
fn take_out_gone(&mut self) -> 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, or changed there since: forgotten all the same. Another file
gone here (a claim of a part no longer kept) is forgotten, left there.
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.