/
exec.go
50 lines (43 loc) · 1.4 KB
/
exec.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
44
45
46
47
48
49
50
package hybsterx
import pb "github.com/ibalajiarun/go-consensus/protocols/hybsterx/hybsterxpb"
func (p *hybsterx) exec() {
for {
oinst, ok := p.olog[p.oexecIdx]
if !ok || !oinst.is.IsCommitted() {
p.logger.Debugf("Replica %d oinst not committed [oseq=%d]\n",
p.id, p.oexecIdx)
return
}
for _, nextIID := range oinst.is.Instances {
// nextIID := pb.InstanceID{
// ReplicaID: nextRID,
// Index: s.execIdx[nextRID],
// }
inst, ok := p.log[nextIID]
if !ok || !inst.is.IsCommitted() || inst.is.Command == nil {
p.logger.Debugf("Replica %d inst not committed [oseq=%d, r=%d, s=%d, cmd=%d]\n",
p.id, p.oexecIdx, nextIID.PeerID, p.execIdx[nextIID.PeerID], inst)
return
}
}
for _, nextIID := range oinst.is.Instances {
// nextIID := pb.InstanceID{
// ReplicaID: nextRID,
// Index: s.execIdx[nextRID],
// }
inst := p.log[nextIID]
p.logger.Debugf("Replica %d execIdx [oseq=%d, r=%d, s=%d, cmd=%d]\n",
p.id, p.oexecIdx, nextIID.PeerID, p.execIdx[nextIID.PeerID], inst)
if inst == nil {
p.logger.Errorf("Replica %d execIdx [oseq=%d, r=%d, s=%d, cmd=%d]\n",
p.id, p.oexecIdx, nextIID.PeerID, p.execIdx[nextIID.PeerID], inst)
}
p.Execute(inst.is.Command)
inst.is.Command = nil
p.execIdx[nextIID.PeerID]++
inst.is.Status = pb.InstanceState_Executed
}
oinst.is.Status = pb.OInstanceState_Executed
p.oexecIdx++
}
}