Commit 9f6f2e91 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent eea1a4f6
...@@ -55,7 +55,7 @@ type Client struct { ...@@ -55,7 +55,7 @@ type Client struct {
// node *xneo.NodeApp // node *xneo.NodeApp
node *_MasteredNode node *_MasteredNode
runWG *xsync.WorkGroup // runWG *xsync.WorkGroup
runCancel func() runCancel func()
/* /*
...@@ -153,7 +153,7 @@ func (c *Client) Run(ctx context.Context) (err error) { ...@@ -153,7 +153,7 @@ func (c *Client) Run(ctx context.Context) (err error) {
// Close implements zodb.IStorageDriver. // Close implements zodb.IStorageDriver.
func (c *Client) Close() (err error) { func (c *Client) Close() (err error) {
c.runCancel() c.runCancel()
err = c.runWG.Wait() // err = c.runWG.Wait() XXX reenable
// close networker if configured to do so // close networker if configured to do so
if c.ownNet { if c.ownNet {
......
...@@ -362,11 +362,11 @@ func (node *_MasteredNode) updateOperational(δf func()) { ...@@ -362,11 +362,11 @@ func (node *_MasteredNode) updateOperational(δf func()) {
operational := (node.mlink != nil) && node.state.IsOperational() operational := (node.mlink != nil) && node.state.IsOperational()
fmt.Printf("\nupdateOperatinal: %v\n", operational) //fmt.Printf("\nupdateOperatinal: %v\n", operational)
fmt.Printf(" mlink: %s\n", node.mlink) //fmt.Printf(" mlink: %s\n", node.mlink)
fmt.Printf(" state: %s\n", node.state.Code) //fmt.Printf(" state: %s\n", node.state.Code)
fmt.Printf(" partTab:\n%s", node.state.PartTab) //fmt.Printf(" partTab:\n%s", node.state.PartTab)
fmt.Printf(" nodeTab:\n%s", node.state.NodeTab) //fmt.Printf(" nodeTab:\n%s", node.state.NodeTab)
if operational != node.operational { if operational != node.operational {
node.operational = operational node.operational = operational
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment