unistack-org/micro
4
0
Fork 2
Code Issues 18 Pull Requests Actions 1 Packages Projects Releases 331 Wiki Activity

Remove data race; Unlock once done pruning/deleting

Browse Source
This commit is contained in:
Milos Gajdos
2019-09-19 11:53:13 +01:00
parent ee74e26582
commit a38482ffcb
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
network/node.go
View File

@@ -30,8 +30,6 @@ type node struct {
address string address string
// peers are nodes with direct link to this node // peers are nodes with direct link to this node
peers map[string]*node peers map[string]*node
// edges store the node edges
edges map[string]map[string]*node
// network returns the node network // network returns the node network
network Network network Network
// lastSeen keeps track of node lifetime and updates // lastSeen keeps track of node lifetime and updates
@@ -196,7 +194,7 @@ func (n *node) GetPeerNode(id string) *node {
// DeletePeerNode removes peer node from node topology // DeletePeerNode removes peer node from node topology
func (n *node) DeletePeerNode(id string) error { func (n *node) DeletePeerNode(id string) error {
n.Lock() n.Lock()
n.Unlock() defer n.Unlock()
untilNoMorePeers := func(node *node) bool { untilNoMorePeers := func(node *node) bool {
return node == nil return node == nil
@@ -223,7 +221,7 @@ func (n *node) DeletePeerNode(id string) error {
// It returns a map of the the nodes that got pruned // It returns a map of the the nodes that got pruned
func (n *node) PruneStalePeerNodes(pruneTime time.Duration) map[string]*node { func (n *node) PruneStalePeerNodes(pruneTime time.Duration) map[string]*node {
n.Lock() n.Lock()
n.Unlock() defer n.Unlock()
untilNoMorePeers := func(node *node) bool { untilNoMorePeers := func(node *node) bool {
return node == nil return node == nil