Commit 40953b04 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 0a7b04d6
...@@ -220,6 +220,13 @@ func (m *Master) Run(ctx context.Context, l xnet.Listener) (err error) { ...@@ -220,6 +220,13 @@ func (m *Master) Run(ctx context.Context, l xnet.Listener) (err error) {
return err return err
} }
m.node.MasterAddr = addr.String() m.node.MasterAddr = addr.String()
m.node.Addr = naddr
m.node.ModifyState(func(s *xneo.State) {
s.MyNID = mynid
// s.MyState = proto.RUNNING XXX needed?
s.IdTime = proto.IdTimeNone // XXX ok?
})
/*
m.node.MyInfo = proto.NodeInfo{ m.node.MyInfo = proto.NodeInfo{
Type: proto.MASTER, Type: proto.MASTER,
Addr: naddr, Addr: naddr,
...@@ -227,6 +234,7 @@ func (m *Master) Run(ctx context.Context, l xnet.Listener) (err error) { ...@@ -227,6 +234,7 @@ func (m *Master) Run(ctx context.Context, l xnet.Listener) (err error) {
State: proto.RUNNING, State: proto.RUNNING,
IdTime: proto.IdTimeNone, // XXX ok? IdTime: proto.IdTimeNone, // XXX ok?
} }
*/
// update nodeTab with self // update nodeTab with self
m.updateNodeTab(ctx, m.node.MyInfo) m.updateNodeTab(ctx, m.node.MyInfo)
......
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