smeb_y/0g-storage-node
1
0
Fork 0
mirror of https://github.com/0glabs/0g-storage-node.git synced 2025-11-03 16:17:27 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Disable sequential sync and store new file in v2 sync store

Browse Source
This commit is contained in:
boqiu 2024-10-24 15:30:07 +08:00 committed by Peter Zhang
parent 57ba8f9bb7
commit e338dca318
1 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
node/sync/src/auto_sync/manager.rs
View File

@ -35,7 +35,7 @@ impl AutoSyncManager {
executor: &TaskExecutor,
store: Store,
sync_send: SyncSender,
log_sync_recv: broadcast::Receiver<LogSyncEvent>,
_log_sync_recv: broadcast::Receiver<LogSyncEvent>,
catch_up_end_recv: oneshot::Receiver<()>,
) -> Result<Self> {
let (file_announcement_send, file_announcement_recv) = unbounded_channel();
@ -53,15 +53,8 @@ impl AutoSyncManager {
let catched_up = Arc::new(AtomicBool::new(false));
// handle new file
let sync_store_cloned = sync_store.clone();
executor.spawn(
async move {
while let Some(tx_seq) = new_file_recv.recv().await {
if let Err(err) = sync_store_cloned.insert(tx_seq, Queue::Ready).await {
warn!(?err, %tx_seq, "Failed to insert new file to ready queue");
}
}
},
Self::handle_new_file(new_file_recv, sync_store.clone()),
"auto_sync_handle_new_file",
);
@ -93,7 +86,7 @@ impl AutoSyncManager {
);
Ok(Self {
serial,
serial: None,
random,
file_announcement_send,
new_file_send,