Fix replication slowness (#10632)

- Increase channel buffer length
- Avoid blocking wait on replicaCh
This commit is contained in:
Poorna Krishnamoorthy 2020-10-05 14:45:42 -07:00 committed by GitHub
parent 9dda9fb903
commit 7fbfdceba3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -310,7 +310,7 @@ func newReplicationState() *replicationState {
globalReplicationConcurrent = 1
}
rs := &replicationState{
replicaCh: make(chan ObjectInfo, globalReplicationConcurrent*2),
replicaCh: make(chan ObjectInfo, 10000),
}
go func() {
<-GlobalContext.Done()
@ -332,6 +332,7 @@ func (r *replicationState) addWorker(ctx context.Context, objectAPI ObjectLayer)
return
}
replicateObject(ctx, oi, objectAPI)
default:
}
}
}()