Name change

conductor.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import "errors"
 

daemons.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"errors"

debug.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"sync"
@@ -57,9 +57,9 @@ func (s *Swamp) dbgPrint(str string) {
 		case debugChan <- str:
 			return
 		default:
-			println("Prox5 overflow: " + str)
+			println("prox5 overflow: " + str)
 			return
 		}
 	}
-	println("Prox5: " + str)
+	println("prox5: " + str)
 }

defs.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"fmt"

dispense.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"sync/atomic"
@@ -96,7 +96,11 @@ func (s *Swamp) stillGood(sock *Proxy) bool {
 		return false
 	}
 
-	if time.Since(sock.lastValidated.Load().(time.Time)) > s.swampopt.stale.Load().(time.Duration) {
+	if s.swampopt.stale.Load().(time.Duration) == 0 {
+		return true
+	}
+	since := time.Since(sock.lastValidated.Load().(time.Time))
+	if since > s.swampopt.stale.Load().(time.Duration) {
 		s.dbgPrint("proxy stale: " + sock.Endpoint)
 		go s.Stats.stale()
 		return false

example/main.go

@@ -8,16 +8,16 @@ import (
 
 	"github.com/mattn/go-tty"
 
-	"git.tcp.direct/kayos/Prox5"
+	"git.tcp.direct/kayos/prox5"
 )
 
-var swamp *Prox5.Swamp
+var swamp *prox5.Swamp
 var quit chan bool
 var t *tty.TTY
 
 func init() {
 	quit = make(chan bool)
-	swamp = Prox5.NewDefaultSwamp()
+	swamp = prox5.NewDefaultSwamp()
 	swamp.SetMaxWorkers(5)
 	swamp.EnableDebug()
 

getters.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"strconv"

go.mod

@@ -1,4 +1,4 @@
-module git.tcp.direct/kayos/Prox5
+module git.tcp.direct/kayos/prox5
 
 go 1.17
 

list_management.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"bufio"

mrworldwide.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"crypto/tls"

mystery_dialer.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"context"

setters.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"time"

socks5_server.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"fmt"

stats.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"sync"

util.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	quiccmaffs "math/rand"

validator_engine.go

@@ -1,4 +1,4 @@
-package Prox5
+package prox5
 
 import (
 	"bytes"