MetzNet
/
graphvent
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Handle timeouts better in lockable

gql_cataclysm
noah metz 2023-11-03 22:54:28 -06:00
parent f41160da68
commit ddb3854d00
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
lockable.go
Unescape Escape View File

@ -298,12 +298,26 @@ func (ext *LockableExt) HandleTimeoutSignal(ctx *Context, node *Node, source Nod
var messages Messages = nil var messages Messages = nil
var changes Changes = nil var changes Changes = nil
//TODO: Handle timeout errors better
wait_info, found := node.ProcessResponse(ext.WaitInfos, signal) wait_info, found := node.ProcessResponse(ext.WaitInfos, signal)
if found == true { if found == true {
state, found := ext.Requirements[wait_info.NodeID] state, found := ext.Requirements[wait_info.NodeID]
if found == true { if found == true {
ctx.Log.Logf("lockable", "%s timed out %s", wait_info.NodeID, ReqStateStrings[state]) ctx.Log.Logf("lockable", "%s timed out %s", wait_info.NodeID, ReqStateStrings[state])
switch state {
case Locking:
ext.State = AbortingLock
ext.Requirements[wait_info.NodeID] = Unlocked
for id, state := range(ext.Requirements) {
if state == Locked {
ext.Requirements[id] = Unlocking
lock_signal := NewLockSignal("unlock")
ext.WaitInfos[lock_signal.Id] = node.QueueTimeout(id, lock_signal, 100*time.Millisecond)
messages = messages.Add(ctx, id, node, nil, lock_signal)
ctx.Log.Logf("lockable", "sent abort unlock to %s from %s", id, node.ID)
}
}
case Unlocking:
}
} else { } else {
ctx.Log.Logf("lockable", "%s timed out", wait_info.NodeID) ctx.Log.Logf("lockable", "%s timed out", wait_info.NodeID)
} }