diff --git a/lockable.go b/lockable.go index b8f0228..e4118a0 100644 --- a/lockable.go +++ b/lockable.go @@ -247,7 +247,7 @@ func (ext *LockableExt) HandleLockSignal(ctx *Context, node *Node, source NodeID } lock_signal := NewLockSignal("lock") - ext.WaitInfos[lock_signal.Id] = node.QueueTimeout(id, lock_signal, 100*time.Millisecond) + ext.WaitInfos[lock_signal.Id] = node.QueueTimeout(id, lock_signal, 5000*time.Millisecond) ext.Requirements[id] = Locking messages = messages.Add(ctx, id, node, nil, lock_signal) diff --git a/lockable_test.go b/lockable_test.go index 8e8f235..15106df 100644 --- a/lockable_test.go +++ b/lockable_test.go @@ -87,7 +87,7 @@ func Test100Lock(t *testing.T) { return l } - reqs := make([]NodeID, 100) + reqs := make([]NodeID, 1000) for i := range(reqs) { new_lockable := NewLockable() reqs[i] = new_lockable.ID diff --git a/node.go b/node.go index 206505a..6743115 100644 --- a/node.go +++ b/node.go @@ -733,7 +733,6 @@ func WriteNodeChanges(ctx *Context, node *Node, changes Changes) error { return err } ext_serialized[ext_type] = serialized_ext - ctx.Log.Logf("db", "extension 0x%x - %+v - %+v", ext_type, serialized_ext.TypeStack, serialized_ext.Data) } }