nit(session): improve naming

session/session.go

@@ -81,14 +81,14 @@ type Session struct {
 	interest            *lru.Cache
 	pastWants           *cidQueue
 	liveWants           map[cid.Cid]time.Time
-	tick             *time.Timer
-	rebroadcast      *time.Timer
+	idleTick            *time.Timer
+	periodicSearchTimer *time.Timer
 	baseTickDelay       time.Duration
 	latTotal            time.Duration
 	fetchcnt            int
 	consecutiveTicks    int
-	provSearchDelay  time.Duration
-	rebroadcastDelay delay.D
+	initialSearchDelay  time.Duration
+	periodicSearchDelay delay.D
 	// identifiers
 	notif notifications.PubSub
 	uuid  logging.Loggable
@@ -102,8 +102,8 @@ func New(ctx context.Context,
 	wm WantManager,
 	pm PeerManager,
 	srs RequestSplitter,
-	provSearchDelay time.Duration,
-	rebroadcastDelay delay.D) *Session {
+	initialSearchDelay time.Duration,
+	periodicSearchDelay delay.D) *Session {
 	s := &Session{
 		liveWants:           make(map[cid.Cid]time.Time),
 		newReqs:             make(chan []cid.Cid),
@@ -122,8 +122,8 @@ func New(ctx context.Context,
 		uuid:                loggables.Uuid("GetBlockRequest"),
 		baseTickDelay:       time.Millisecond * 500,
 		id:                  id,
-		provSearchDelay:  provSearchDelay,
-		rebroadcastDelay: rebroadcastDelay,
+		initialSearchDelay:  initialSearchDelay,
+		periodicSearchDelay: periodicSearchDelay,
 	}
 
 	cache, _ := lru.New(2048)
@@ -239,8 +239,8 @@ func (s *Session) SetBaseTickDelay(baseTickDelay time.Duration) {
 // Session run loop -- everything function below here should not be called
 // of this loop
 func (s *Session) run(ctx context.Context) {
-	s.tick = time.NewTimer(s.provSearchDelay)
-	s.rebroadcast = time.NewTimer(s.rebroadcastDelay.NextWaitTime())
+	s.idleTick = time.NewTimer(s.initialSearchDelay)
+	s.periodicSearchTimer = time.NewTimer(s.periodicSearchDelay.NextWaitTime())
 	for {
 		select {
 		case blk := <-s.incoming:
@@ -253,10 +253,10 @@ func (s *Session) run(ctx context.Context) {
 			s.handleNewRequest(ctx, keys)
 		case keys := <-s.cancelKeys:
 			s.handleCancel(keys)
-		case <-s.tick.C:
-			s.handleTick(ctx)
-		case <-s.rebroadcast.C:
-			s.handleRebroadcast(ctx)
+		case <-s.idleTick.C:
+			s.handleIdleTick(ctx)
+		case <-s.periodicSearchTimer.C:
+			s.handlePeriodicSearch(ctx)
 		case lwchk := <-s.interestReqs:
 			lwchk.resp <- s.cidIsWanted(lwchk.c)
 		case resp := <-s.latencyReqs:
@@ -271,7 +271,7 @@ func (s *Session) run(ctx context.Context) {
 }
 
 func (s *Session) handleIncomingBlock(ctx context.Context, blk blkRecv) {
-	s.tick.Stop()
+	s.idleTick.Stop()
 
 	if blk.from != "" {
 		s.pm.RecordPeerResponse(blk.from, blk.blk.Cid())
@@ -279,7 +279,7 @@ func (s *Session) handleIncomingBlock(ctx context.Context, blk blkRecv) {
 
 	s.receiveBlock(ctx, blk.blk)
 
-	s.resetTick()
+	s.resetIdleTick()
 }
 
 func (s *Session) handleNewRequest(ctx context.Context, keys []cid.Cid) {
@@ -307,7 +307,7 @@ func (s *Session) handleCancel(keys []cid.Cid) {
 	}
 }
 
-func (s *Session) handleTick(ctx context.Context) {
+func (s *Session) handleIdleTick(ctx context.Context) {
 
 	live := make([]cid.Cid, 0, len(s.liveWants))
 	now := time.Now()
@@ -321,18 +321,18 @@ func (s *Session) handleTick(ctx context.Context) {
 	s.wm.WantBlocks(ctx, live, nil, s.id)
 
 	// do no find providers on consecutive ticks
-	// -- just rely on periodic rebroadcast
+	// -- just rely on periodic search widening
 	if len(live) > 0 && (s.consecutiveTicks == 0) {
 		s.pm.FindMorePeers(ctx, live[0])
 	}
-	s.resetTick()
+	s.resetIdleTick()
 
 	if len(s.liveWants) > 0 {
 		s.consecutiveTicks++
 	}
 }
 
-func (s *Session) handleRebroadcast(ctx context.Context) {
+func (s *Session) handlePeriodicSearch(ctx context.Context) {
 
 	if len(s.liveWants) == 0 {
 		return
@@ -342,7 +342,7 @@ func (s *Session) handleRebroadcast(ctx context.Context) {
 	// for new providers for blocks.
 	s.pm.FindMorePeers(ctx, s.randomLiveWant())
 
-	s.rebroadcast.Reset(s.rebroadcastDelay.NextWaitTime())
+	s.periodicSearchTimer.Reset(s.periodicSearchDelay.NextWaitTime())
 }
 
 func (s *Session) randomLiveWant() cid.Cid {
@@ -357,7 +357,7 @@ func (s *Session) randomLiveWant() cid.Cid {
 	return cid.Cid{}
 }
 func (s *Session) handleShutdown() {
-	s.tick.Stop()
+	s.idleTick.Stop()
 	s.notif.Shutdown()
 
 	live := make([]cid.Cid, 0, len(s.liveWants))
@@ -436,16 +436,16 @@ func (s *Session) averageLatency() time.Duration {
 	return s.latTotal / time.Duration(s.fetchcnt)
 }
 
-func (s *Session) resetTick() {
+func (s *Session) resetIdleTick() {
 	var tickDelay time.Duration
 	if s.latTotal == 0 {
-		tickDelay = s.provSearchDelay
+		tickDelay = s.initialSearchDelay
 	} else {
 		avLat := s.averageLatency()
 		tickDelay = s.baseTickDelay + (3 * avLat)
 	}
 	tickDelay = tickDelay * time.Duration(1+s.consecutiveTicks)
-	s.tick.Reset(tickDelay)
+	s.idleTick.Reset(tickDelay)
 }
 
 func (s *Session) wantBudget() int {