coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-23 03:17:25 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

move pebble close to Stop()

Browse Source
This commit is contained in:
Vasyl Tretiakov 2025-10-21 21:36:54 +03:00
parent d5a094116c
commit 3da121978d
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
node/app/data_worker_node.go
View File

@ -70,7 +70,15 @@ func (n *DataWorkerNode) Start() error {
n.logger.Info("data worker node started", zap.Uint("core_id", n.coreId))
defer func() {
<-n.quit
return nil
}
func (n *DataWorkerNode) Stop() {
n.logger.Info("stopping data worker node")
if n.pebble != nil {
err := n.pebble.Close()
if err != nil {
n.logger.Error(
@ -84,15 +92,7 @@ func (n *DataWorkerNode) Start() error {
zap.Uint("core_id", n.coreId),
)
}
}()
<-n.quit
return nil
}
func (n *DataWorkerNode) Stop() {
n.logger.Info("stopping data worker node")
}
// Signal quit
if n.quit != nil {