Skip to content

Commit

Permalink
prints
Browse files Browse the repository at this point in the history
  • Loading branch information
czarcas7ic committed Jun 24, 2024
1 parent 1d43e9d commit b57bf72
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions p2p/pex/addrbook.go
Original file line number Diff line number Diff line change
Expand Up @@ -343,7 +343,7 @@ func (a *addrBook) pickAddress(biasTowardsNewAddrs int, region string, matchRegi
filteredBucket := make(map[string]*knownAddress)
for addrStr, ka := range bucket {
if ka.Region == "" && a.curRegionQueryCount < a.regionQueriesPerPeerQueryPeriod {
fmt.Println("Getting region from IP", ka.Addr.IP.String())
// fmt.Println("Getting region from IP", ka.Addr.IP.String())
region, err := getRegionFromIP(ka.Addr.IP.String())
if err != nil {
a.Logger.Error("Failed to get region from IP", "err", err)
Expand All @@ -356,10 +356,10 @@ func (a *addrBook) pickAddress(biasTowardsNewAddrs int, region string, matchRegi
fmt.Println("Region already set", ka.Addr, "region", ka.Region)
}
if (matchRegion && ka.Region == region) || (!matchRegion && ka.Region != region && ka.Region != "") {
fmt.Println("Adding address", ka.Addr, "region", ka.Region)
// fmt.Println("Adding address", ka.Addr, "region", ka.Region)
filteredBucket[addrStr] = ka
} else {
fmt.Println("Skipping address", ka.Addr, "region", ka.Region)
// fmt.Println("Skipping address", ka.Addr, "region", ka.Region)
}
}

Expand All @@ -378,6 +378,9 @@ func (a *addrBook) pickAddress(biasTowardsNewAddrs int, region string, matchRegi
randIndex := a.rand.Intn(len(bucket))
for _, ka := range bucket {
if randIndex == 0 {
if !matchRegion {
fmt.Println("THIS IP USED FOR NON SAME REGION", ka.Addr.IP.String(), "REGION", ka.Region)
}
return ka.Addr
}
randIndex--
Expand Down

0 comments on commit b57bf72

Please sign in to comment.