(id string)
| 150 | } |
| 151 | |
| 152 | func (l *NodeLocker) Add(id string) { |
| 153 | // add if missing, may happen if shock restarted |
| 154 | l.Lock() |
| 155 | defer l.Unlock() |
| 156 | if _, ok := l.nodes[id]; !ok { |
| 157 | l.nodes[id] = NewNodeLock(id) |
| 158 | } |
| 159 | } |
| 160 | |
| 161 | func (l *NodeLocker) Remove(id string) { |
| 162 | l.Lock() |
no test coverage detected