smeb_y/0g-storage-node
1
0
Fork 0
mirror of https://github.com/0glabs/0g-storage-node.git synced 2025-04-04 15:35:18 +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 8f1fe118ef
commit fb65d257be
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, executor: &TaskExecutor,
store: Store, store: Store,
sync_send: SyncSender, sync_send: SyncSender,
log_sync_recv: broadcast::Receiver<LogSyncEvent>, _log_sync_recv: broadcast::Receiver<LogSyncEvent>,
catch_up_end_recv: oneshot::Receiver<()>, catch_up_end_recv: oneshot::Receiver<()>,
) -> Result<Self> { ) -> Result<Self> {
let (file_announcement_send, file_announcement_recv) = unbounded_channel(); let (file_announcement_send, file_announcement_recv) = unbounded_channel();
@ -53,15 +53,8 @@ impl AutoSyncManager {
let catched_up = Arc::new(AtomicBool::new(false)); let catched_up = Arc::new(AtomicBool::new(false));
// handle new file // handle new file
let sync_store_cloned = sync_store.clone();
executor.spawn( executor.spawn(
async move { Self::handle_new_file(new_file_recv, sync_store.clone()),
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");
}
}
},
"auto_sync_handle_new_file", "auto_sync_handle_new_file",
); );
@ -93,7 +86,7 @@ impl AutoSyncManager {
); );
Ok(Self { Ok(Self {
serial, serial: None,
random, random,
file_announcement_send, file_announcement_send,
new_file_send, new_file_send,