mirror
/
reticulum
kopia lustrzana https://github.com/markqvist/reticulum
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Work on resource timing.

pull/8/head
Mark Qvist 2021-09-03 22:20:16 +02:00
rodzic aa794514b3
commit 83232f0446
1 zmienionych plików z 9 dodań i 4 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

13
RNS/Resource.py
Wyświetl plik

@ -399,11 +399,11 @@ class Resource:
else:
rtt = self.rtt
window_remaining = self.window - self.window_index
window_remaining = self.outstanding_parts
sleep_time = self.last_activity + (rtt*(self.part_timeout_factor+window_remaining)) + Resource.RETRY_GRACE_TIME - time.time()
# TODO: Remove
# TODO: Remove debug info
RNS.log("rtt "+str(rtt))
RNS.log("ptof "+str(self.part_timeout_factor))
RNS.log("wait "+str((rtt*self.part_timeout_factor) + Resource.RETRY_GRACE_TIME))
@ -602,9 +602,14 @@ class Resource:
if self.__progress_callback != None:
self.__progress_callback(self)
# TODO: Remove
# TODO: Remove debug info
RNS.log("outstanding_parts "+str(self.outstanding_parts))
if self.outstanding_parts == 0 and self.received_count == self.total_parts:
RNS.log("total_parts "+str(self.total_parts))
RNS.log("received_count "+str(self.received_count))
# TODO: Remove
#if self.outstanding_parts == 0 and self.received_count == self.total_parts:
if self.received_count == self.total_parts:
self.assemble()
elif self.outstanding_parts == 0:
# TODO: Figure out if there is a mathematically