Skip to content

Commit 02ae8d9

Browse files
Unexport RequestID from snowman engine (#2384)
1 parent be422a0 commit 02ae8d9

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

snow/engine/snowman/transitive.go

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ type Transitive struct {
5959
common.AppHandler
6060
validators.Connector
6161

62-
RequestID uint32
62+
requestID uint32
6363

6464
// track outstanding preference requests
6565
polls poll.Set
@@ -409,7 +409,7 @@ func (t *Transitive) Context() *snow.ConsensusContext {
409409
}
410410

411411
func (t *Transitive) Start(ctx context.Context, startReqID uint32) error {
412-
t.RequestID = startReqID
412+
t.requestID = startReqID
413413
lastAcceptedID, err := t.VM.LastAccepted(ctx)
414414
if err != nil {
415415
return err
@@ -774,20 +774,20 @@ func (t *Transitive) sendRequest(ctx context.Context, nodeID ids.NodeID, blkID i
774774
return
775775
}
776776

777-
t.RequestID++
777+
t.requestID++
778778
t.blkReqs.Put(
779779
common.Request{
780780
NodeID: nodeID,
781-
RequestID: t.RequestID,
781+
RequestID: t.requestID,
782782
},
783783
blkID,
784784
)
785785
t.Ctx.Log.Verbo("sending Get request",
786786
zap.Stringer("nodeID", nodeID),
787-
zap.Uint32("requestID", t.RequestID),
787+
zap.Uint32("requestID", t.requestID),
788788
zap.Stringer("blkID", blkID),
789789
)
790-
t.Sender.SendGet(ctx, nodeID, t.RequestID, blkID)
790+
t.Sender.SendGet(ctx, nodeID, t.requestID, blkID)
791791

792792
// Tracks performance statistics
793793
t.metrics.numRequests.Set(float64(t.blkReqs.Len()))
@@ -828,21 +828,21 @@ func (t *Transitive) sendQuery(
828828
}
829829

830830
vdrBag := bag.Of(vdrIDs...)
831-
t.RequestID++
832-
if !t.polls.Add(t.RequestID, vdrBag) {
831+
t.requestID++
832+
if !t.polls.Add(t.requestID, vdrBag) {
833833
t.Ctx.Log.Error("dropped query for block",
834834
zap.String("reason", "failed to add poll"),
835835
zap.Stringer("blkID", blkID),
836-
zap.Uint32("requestID", t.RequestID),
836+
zap.Uint32("requestID", t.requestID),
837837
)
838838
return
839839
}
840840

841841
vdrSet := set.Of(vdrIDs...)
842842
if push {
843-
t.Sender.SendPushQuery(ctx, vdrSet, t.RequestID, blkBytes, nextHeightToAccept)
843+
t.Sender.SendPushQuery(ctx, vdrSet, t.requestID, blkBytes, nextHeightToAccept)
844844
} else {
845-
t.Sender.SendPullQuery(ctx, vdrSet, t.RequestID, blkID, nextHeightToAccept)
845+
t.Sender.SendPullQuery(ctx, vdrSet, t.requestID, blkID, nextHeightToAccept)
846846
}
847847
}
848848

0 commit comments

Comments
 (0)