Commit fa60a7c1 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 28586317
...@@ -179,7 +179,7 @@ func (m *Master) Run(ctx context.Context) (err error) { ...@@ -179,7 +179,7 @@ func (m *Master) Run(ctx context.Context) (err error) {
// for storages the only incoming connection is for RequestIdentification // for storages the only incoming connection is for RequestIdentification
// and then master only drives it. So close accept as noone will be // and then master only drives it. So close accept as noone will be
// listening for it on your side anymore. // listening for it on our side anymore.
switch idReq.NodeType { switch idReq.NodeType {
case neo.CLIENT: case neo.CLIENT:
// ok // ok
...@@ -214,7 +214,7 @@ func (m *Master) Run(ctx context.Context) (err error) { ...@@ -214,7 +214,7 @@ func (m *Master) Run(ctx context.Context) (err error) {
} }
// runMain is the process which implements main master cluster management logic: node tracking, cluster // runMain is the process which implements main master cluster management logic: node tracking, cluster
// state updates, scheduling data movement between storage nodes etc // state updates, scheduling data movement between storage nodes etc.
func (m *Master) runMain(ctx context.Context) (err error) { func (m *Master) runMain(ctx context.Context) (err error) {
defer task.Running(&ctx, "main")(&err) defer task.Running(&ctx, "main")(&err)
......
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