File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -14,9 +14,10 @@ import (
1414)
1515
1616// SyncSize specifies how much we batch data before committing and syncing.
17- var SyncSize uint64 = 10 * 1024 * 1024 // 10MiB
17+ var SyncSize uint64 = 20 * 1024 * 1024 // 20MiB
1818
19- // NWorkers sets the number of swapping threads to run.
19+ // NWorkers sets the number of swapping threads to run when applying a
20+ // migration.
2021var NWorkers int = 4
2122
2223// Swap holds the datastore keys for the original CID and for the
@@ -260,6 +261,7 @@ func (sw *swapWorker) swap(old, new ds.Key) error {
260261}
261262
262263func (sw * swapWorker ) sync () error {
264+ log .Log ("Syncing after %d objects migrated" , sw .swapped )
263265 // Sync all the new keys to disk
264266 err := sw .store .Sync (sw .syncPrefix )
265267 if err != nil {
You can’t perform that action at this time.
0 commit comments