f.Close()
err = os.Rename(from, to)
if err == nil {
- fmt.Printf("renamed %v -> %v\n", from, to)
+ me.logger().Debug("renamed file", "from", from, "to", to)
}
return
}
"iter"
"log/slog"
"math/rand"
- "slices"
"sync"
"time"
func (ws *webseedPeer) inactiveRequests() iter.Seq[RequestIndex] {
return func(yield func(RequestIndex) bool) {
- sorted := slices.Sorted(ws.peer.requestState.Requests.Iterator())
- if len(sorted) != 0 {
- fmt.Println("inactiveRequests", sorted)
- }
+ // This is used to determine contiguity of requests.
+ //sorted := slices.Sorted(ws.peer.requestState.Requests.Iterator())
+ //if len(sorted) != 0 {
+ // fmt.Println("inactiveRequests", sorted)
+ //}
for reqIndex := range ws.peer.requestState.Requests.Iterator() {
if !ws.inactiveRequestIndex(reqIndex) {
continue