YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove separator byte from the binary api format

Browse source
This commit is contained in:
yggverse 2025-07-08 14:04:19 +03:00
parent 7a62417d18
commit e51c1dc7b1
1 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

12
crates/udp/src/swarm.rs
View file

@ -175,17 +175,18 @@ impl TorrentMaps {
if config.statistics.write_bin_to_file { if config.statistics.write_bin_to_file {
use anyhow::{Context, Result}; use anyhow::{Context, Result};
use std::{fs::File, io::Read, path::PathBuf}; use std::{fs::File, io::Read, path::PathBuf};
/// Prevent extra write operations by compare the file content is same /// Prevent extra write operations by compare the file content is up to date
fn is_same(path: &PathBuf, info_hashes: &Vec<InfoHash>) -> Result<bool> { fn is_same(path: &PathBuf, info_hashes: &Vec<InfoHash>) -> Result<bool> {
if !std::fs::exists(path)? { if !std::fs::exists(path)? {
return Ok(false); return Ok(false);
} }
const L: usize = 20; // v1 only
let mut t = 0; let mut t = 0;
let mut f = File::open(path)?; let mut f = File::open(path)?;
loop { loop {
let mut b = vec![0; 20]; let mut b = vec![0; L];
let n = f.read_to_end(&mut b)?; let n = f.read(&mut b)?;
if n == 0 { if n != L {
break; break;
} }
if info_hashes.iter().any(|i| i.0 != b[..n]) { if info_hashes.iter().any(|i| i.0 != b[..n]) {
@ -204,8 +205,7 @@ impl TorrentMaps {
format!("File path: {}", path.to_string_lossy()) format!("File path: {}", path.to_string_lossy())
})?; })?;
for i in info_hashes { for i in info_hashes {
f.write_all(&i.0)?; f.write_all(&i.0)?
f.write_all(b"\n")?
} }
Ok(()) Ok(())
} }