B:BD[
4.506855] → [
7.35714:35777]
B:BD[
7.35777] → [
3.29319:29345]
∅:D[
3.29345] → [
4.506992:507032]
B:BD[
4.506992] → [
4.506992:507032]
B:BD[
4.507032] → [
8.12447:12495]
∅:D[
8.12495] → [
4.507067:507318]
B:BD[
4.507067] → [
4.507067:507318]
B:BD[
4.507318] → [
3.29346:29384]
∅:D[
3.29384] → [
4.507352:507479]
B:BD[
4.507352] → [
4.507352:507479]
B:BD[
4.507479] → [
3.29385:29427]
∅:D[
3.29427] → [
4.507517:507547]
B:BD[
4.507517] → [
4.507517:507547]
fn modified_since_last_commit<T: ChannelTxnT, W: WorkingCopy>(
channel: &T::Channel,
working_copy: &W,
prefix: &str,
) -> Result<bool, std::time::SystemTimeError> {
if let Ok(last_modified) = working_copy.modified_time(prefix) {
debug!(
"last_modified = {:?}, channel.last = {:?}",
last_modified
.duration_since(std::time::UNIX_EPOCH)?
.as_secs(),
T::last_modified(channel)
);
Ok(last_modified
.duration_since(std::time::UNIX_EPOCH)?
.as_secs()
+ 2
>= T::last_modified(channel))
} else {
Ok(true)
fn modified_since_last_commit<T: ChannelTxnT, W: WorkingCopy>(
&mut self,
channel: &T::Channel,
working_copy: &W,
prefix: &str,
) -> Result<bool, std::time::SystemTimeError> {
if let Ok(last_modified) = working_copy.modified_time(prefix) {
debug!(
"last_modified = {:?}, channel.last = {:?}",
last_modified
.duration_since(std::time::UNIX_EPOCH)?
.as_secs(),
T::last_modified(channel)
);
Ok(last_modified
.duration_since(std::time::UNIX_EPOCH)?
.as_secs()
+ 2
>= T::last_modified(channel))
} else {
Ok(true)
}