add svLock

liuxiaolong

2020-04-20 a4ea6380ed70468b1bbaca0328a65686960fcd52

add svLock

 server.go

@@ -3,6 +3,7 @@
import (
    "encoding/json"
    "log"
    "sync"
    "time"

    "golang.org/x/net/context"
@@ -52,6 +53,7 @@
    publisher *Publisher

    svInfo map[string][]byte
    svLock sync.RWMutex
}

type Publisher struct {
@@ -162,7 +164,9 @@
        } else {
            if  json.Unmarshal(msg, &si) == nil {
                responses.Add(si.ServiceId)
                d.services.svLock.Lock()
                d.services.svInfo[si.ServiceId] = si.Info
                d.services.svLock.Unlock()
            }
        }
    }
@@ -244,6 +248,8 @@
}

func (d *DiscoveryServer) SvInfo() map[string][]byte {
    d.services.svLock.Lock()
    defer d.services.svLock.Unlock()
    m := make(map[string][]byte)
    for k,v := range d.services.svInfo {
        m[k] = v