zerotier/sequential-exchange
0
0
Fork 0
mirror of https://github.com/zerotier/sequential-exchange.git synced 2026-05-22 16:28:28 -07:00
Code Issues Packages Projects Releases Wiki Activity

fixed file download

Browse Source
This commit is contained in:
Monica Moniot
2023-08-17 13:22:35 -04:00
parent aef48ee7ca
commit ac024d9da9
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
examples/file_download.rs
+5 -5
View File
@@ -127,14 +127,14 @@ fn receive(peer: &Peer) {
fn main() {
let mut filesystem2 = HashMap::new();
let mut file = vec![0; 1 << 14];
OsRng.fill_bytes(&mut file);
filesystem2.insert("File1".to_string(), file);
let mut file = vec![0; 1 << 16];
OsRng.fill_bytes(&mut file);
filesystem2.insert("File2".to_string(), file);
filesystem2.insert("File1".to_string(), file);
let mut file = vec![0; 1 << 18];
OsRng.fill_bytes(&mut file);
filesystem2.insert("File2".to_string(), file);
let mut file = vec![0; 1 << 20];
OsRng.fill_bytes(&mut file);
filesystem2.insert("File3".to_string(), file);
let (send1, recv2) = channel();
@@ -157,7 +157,7 @@ fn main() {
peer1.seqex.send(&peer1.transport, Packet::RequestFile { filename: "File3".to_string() });
peer1.seqex.send(&peer1.transport, Packet::RequestFile { filename: "File2".to_string() });
for _ in 0..3000 {
for _ in 0..300 {
receive(&peer1);
receive(&peer2);
thread::sleep(Duration::from_millis(1));
src/seq_queue.rs
+1 -2
View File
@@ -378,9 +378,8 @@ impl<SendData, RecvData, const CAP: usize> SeqEx<SendData, RecvData, CAP> {
if entry.next_resend_time <= current_time {
entry.next_resend_time = next_resend_time;
app.send(entry.seq_no, entry.reply_no, &entry.data);
} else {
next_activity = next_activity.min(entry.next_resend_time);
}
next_activity = next_activity.min(entry.next_resend_time);
}
self.next_service_timestamp = next_activity;
app.update_service_time(next_activity, current_time);