()
| 104 | } |
| 105 | |
| 106 | func (n *NodeLock) unlock() { |
| 107 | if lockDebug { |
| 108 | fmt.Printf("start NodeLock.unlock gid=%d node=%s\n", getGID(), n.Id) |
| 109 | } |
| 110 | n.IsLocked = false |
| 111 | n.Updated = time.Now() |
| 112 | n.writeLock <- 1 // Release the ticket |
| 113 | if lockDebug { |
| 114 | fmt.Printf("end NodeLock.unlock gid=%d node=%s\n", getGID(), n.Id) |
| 115 | } |
| 116 | } |
| 117 | |
| 118 | func (l *NodeLocker) LockNode(id string) (err error) { |
| 119 | l.Add(id) |