-
Notifications
You must be signed in to change notification settings - Fork 4
/
sync_stackable.go
43 lines (36 loc) · 1.38 KB
/
sync_stackable.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package smsync
import "github.com/insolar/assured-ledger/ledger-core/conveyor/smachine"
// methods of this interfaces can be protected by mutex
type dependencyStackController interface {
containsInStack(q *dependencyQueueHead, entry *dependencyQueueEntry) smachine.Decision
afterRelease(q *dependencyQueueHead, entry *dependencyQueueEntry)
tryPartialRelease(entry *dependencyQueueEntry) bool
tryPartialAcquire(entry *dependencyQueueEntry, hasActiveCapacity bool) smachine.Decision
}
type dependencyStack struct {
controller dependencyStackController
}
func (p *dependencyStack) contains(q *dependencyQueueHead, entry *dependencyQueueEntry) smachine.Decision {
if p == nil || p.controller == nil {
return smachine.Impossible
}
return p.controller.containsInStack(q, entry)
}
func (p *dependencyStack) updateAfterRelease(entry *dependencyQueueEntry, q *dependencyQueueHead) {
if p == nil || p.controller == nil {
return
}
p.controller.afterRelease(q, entry)
}
func (p *dependencyStack) tryPartialRelease(entry *dependencyQueueEntry) bool {
if p == nil || p.controller == nil {
return false
}
return p.controller.tryPartialRelease(entry)
}
func (p *dependencyStack) tryPartialAcquire(entry *dependencyQueueEntry, hasActiveCapacity bool) smachine.Decision {
if p == nil || p.controller == nil {
return smachine.NotPassed
}
return p.controller.tryPartialAcquire(entry, hasActiveCapacity)
}