From 0f104b93c2f509183434e0b3d1d241b99843762a Mon Sep 17 00:00:00 2001 From: anhthii Date: Fri, 8 Aug 2025 11:00:14 +0700 Subject: [PATCH 1/3] udpate cache size --- pkg/kvstore/badger.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/kvstore/badger.go b/pkg/kvstore/badger.go index 593da52c..b15e47b2 100644 --- a/pkg/kvstore/badger.go +++ b/pkg/kvstore/badger.go @@ -40,8 +40,8 @@ func NewBadgerKVStore(config BadgerConfig) (*BadgerKVStore, error) { opts := badger.DefaultOptions(config.DBPath). WithCompression(options.ZSTD). WithEncryptionKey(config.EncryptionKey). - WithIndexCacheSize(128 << 20). - WithBlockCacheSize(256 << 20). + WithIndexCacheSize(16 << 20). + WithBlockCacheSize(32 << 20). WithSyncWrites(true). WithVerifyValueChecksum(true). // validate every value-log entry's checksum on read, surfacing corruption instead of masking it WithCompactL0OnClose(true). // compacts level-0 SSTables on shutdown, reducing startup work and avoiding stalls on open From 6cb1b2192da10f2f95a430d24419a3ccb95cfd8a Mon Sep 17 00:00:00 2001 From: anhthii Date: Fri, 8 Aug 2025 21:33:48 +0700 Subject: [PATCH 2/3] Fix wrong position of warm up call in resharing --- pkg/eventconsumer/event_consumer.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/pkg/eventconsumer/event_consumer.go b/pkg/eventconsumer/event_consumer.go index 59e2b922..d42e3b9c 100644 --- a/pkg/eventconsumer/event_consumer.go +++ b/pkg/eventconsumer/event_consumer.go @@ -638,13 +638,11 @@ func (ec *eventConsumer) consumeReshareEvent() error { var wg sync.WaitGroup ctx := context.Background() - - ec.warmUpSession() - if oldSession != nil { ctxOld, doneOld := context.WithCancel(ctx) oldSession.Init() oldSession.ListenToIncomingMessageAsync() + ec.warmUpSession() go oldSession.Reshare(doneOld) wg.Add(1) @@ -668,6 +666,7 @@ func (ec *eventConsumer) consumeReshareEvent() error { ctxNew, doneNew := context.WithCancel(ctx) newSession.Init() newSession.ListenToIncomingMessageAsync() + ec.warmUpSession() go newSession.Reshare(doneNew) wg.Add(1) @@ -689,7 +688,6 @@ func (ec *eventConsumer) consumeReshareEvent() error { } wg.Wait() - logger.Info("Reshare session finished", "walletID", walletID, "pubKey", fmt.Sprintf("%x", successEvent.PubKey)) if newSession != nil { From 6408dea14391ada7fbb4492d170383ab2d76305b Mon Sep 17 00:00:00 2001 From: anhthii Date: Fri, 8 Aug 2025 22:40:33 +0700 Subject: [PATCH 3/3] Fix wrong position of warm up call in resharing --- pkg/eventconsumer/event_consumer.go | 23 ++++++++++++----------- 1 file changed, 12 insertions(+), 11 deletions(-) diff --git a/pkg/eventconsumer/event_consumer.go b/pkg/eventconsumer/event_consumer.go index d42e3b9c..ee2e17bc 100644 --- a/pkg/eventconsumer/event_consumer.go +++ b/pkg/eventconsumer/event_consumer.go @@ -635,16 +635,21 @@ func (ec *eventConsumer) consumeReshareEvent() error { KeyType: msg.KeyType, ResultType: event.ResultTypeSuccess, } - - var wg sync.WaitGroup ctx := context.Background() + var wg sync.WaitGroup if oldSession != nil { - ctxOld, doneOld := context.WithCancel(ctx) oldSession.Init() oldSession.ListenToIncomingMessageAsync() - ec.warmUpSession() - go oldSession.Reshare(doneOld) + } + if newSession != nil { + newSession.Init() + newSession.ListenToIncomingMessageAsync() + } + ec.warmUpSession() + if oldSession != nil { + ctxOld, doneOld := context.WithCancel(ctx) + go oldSession.Reshare(doneOld) wg.Add(1) go func() { defer wg.Done() @@ -655,7 +660,7 @@ func (ec *eventConsumer) consumeReshareEvent() error { case err := <-oldSession.ErrChan(): logger.Error("Old reshare session error", err) ec.handleReshareSessionError(walletID, keyType, msg.NewThreshold, err, "Old reshare session error", natMsg) - doneOld() // Cancel the context to stop this session + doneOld() return } } @@ -664,11 +669,7 @@ func (ec *eventConsumer) consumeReshareEvent() error { if newSession != nil { ctxNew, doneNew := context.WithCancel(ctx) - newSession.Init() - newSession.ListenToIncomingMessageAsync() - ec.warmUpSession() go newSession.Reshare(doneNew) - wg.Add(1) go func() { defer wg.Done() @@ -680,7 +681,7 @@ func (ec *eventConsumer) consumeReshareEvent() error { case err := <-newSession.ErrChan(): logger.Error("New reshare session error", err) ec.handleReshareSessionError(walletID, keyType, msg.NewThreshold, err, "New reshare session error", natMsg) - doneNew() // Cancel the context to stop this session + doneNew() return } }