Skip to content

Commit

Permalink
fix: use time.Duration for time, not floats
Browse files Browse the repository at this point in the history
  • Loading branch information
Stebalien committed Apr 9, 2020
1 parent 6f708c1 commit e3c58ad
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
10 changes: 5 additions & 5 deletions table.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,13 +50,13 @@ type RoutingTable struct {
PeerAdded func(peer.ID)

// usefulnessGracePeriod is the maximum grace period we will give to a
// peer in the bucket to be useful to us, failing which, we will evict it to make place for a new peer if the bucket
// is full
usefulnessGracePeriod float64
// peer in the bucket to be useful to us, failing which, we will evict
// it to make place for a new peer if the bucket is full
usefulnessGracePeriod time.Duration
}

// NewRoutingTable creates a new routing table with a given bucketsize, local ID, and latency tolerance.
func NewRoutingTable(bucketsize int, localID ID, latency time.Duration, m peerstore.Metrics, usefulnessGracePeriod float64) (*RoutingTable, error) {
func NewRoutingTable(bucketsize int, localID ID, latency time.Duration, m peerstore.Metrics, usefulnessGracePeriod time.Duration) (*RoutingTable, error) {
rt := &RoutingTable{
buckets: []*bucket{newBucket()},
bucketsize: bucketsize,
Expand Down Expand Up @@ -154,7 +154,7 @@ func (rt *RoutingTable) addPeer(p peer.ID, queryPeer bool) (bool, error) {
// in that bucket with a LastSuccessfulOutboundQuery value above the maximum threshold and replace it.
allPeers := bucket.peers()
for _, pc := range allPeers {
if float64(time.Since(pc.LastUsefulAt)) > rt.usefulnessGracePeriod {
if time.Since(pc.LastUsefulAt) > rt.usefulnessGracePeriod {
// let's evict it and add the new peer
if bucket.remove(pc.Id) {
bucket.pushFront(&PeerInfo{Id: p, LastUsefulAt: lastUsefulAt, LastSuccessfulOutboundQueryAt: time.Now(),
Expand Down
4 changes: 2 additions & 2 deletions table_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ import (
"github.com/stretchr/testify/require"
)

var NoOpThreshold = float64(100 * time.Hour)
var NoOpThreshold = 100 * time.Hour

func TestPrint(t *testing.T) {
t.Parallel()
Expand Down Expand Up @@ -248,7 +248,7 @@ func TestUpdateLastUsefulAt(t *testing.T) {
}

func TestTryAddPeer(t *testing.T) {
minThreshold := float64(24 * 1 * time.Hour)
minThreshold := 24 * 1 * time.Hour
t.Parallel()

local := test.RandPeerIDFatal(t)
Expand Down

0 comments on commit e3c58ad

Please sign in to comment.