From c06ab2595b203a31f0d7dbec085e8f3a7cb0f58e Mon Sep 17 00:00:00 2001 From: Dmitrii Stepanov Date: Sat, 2 Nov 2024 12:40:52 +0300 Subject: [PATCH] [#1468] tree: Sync replication Async replication leads to a lot of log undo/redo during background replication. This leads to performance drop to almost zero. Signed-off-by: Dmitrii Stepanov --- pkg/services/tree/replicator.go | 2 +- pkg/services/tree/service.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/services/tree/replicator.go b/pkg/services/tree/replicator.go index 346198b3c..0949cd4c6 100644 --- a/pkg/services/tree/replicator.go +++ b/pkg/services/tree/replicator.go @@ -190,7 +190,7 @@ func (s *Service) pushToQueue(cid cidSDK.ID, treeID string, op *pilorama.Move) { treeID: treeID, op: op, }: - default: + case <-s.closeCh: } } diff --git a/pkg/services/tree/service.go b/pkg/services/tree/service.go index b74f6d2b4..08d72c415 100644 --- a/pkg/services/tree/service.go +++ b/pkg/services/tree/service.go @@ -626,7 +626,7 @@ func sortByFilename(nodes []pilorama.NodeInfo, d GetSubTreeRequest_Body_Order_Di } // Apply locally applies operation from the remote node to the tree. -func (s *Service) Apply(_ context.Context, req *ApplyRequest) (*ApplyResponse, error) { +func (s *Service) Apply(ctx context.Context, req *ApplyRequest) (*ApplyResponse, error) { err := verifyMessage(req) if err != nil { return nil, err @@ -664,7 +664,7 @@ func (s *Service) Apply(_ context.Context, req *ApplyRequest) (*ApplyResponse, e Meta: meta, }, }: - default: + case <-s.closeCh: } return &ApplyResponse{Body: &ApplyResponse_Body{}, Signature: &Signature{}}, nil }