commit d9e8f8f6479a8b4abe31eb5bfb9023de1bbca8af
Author: David Fifield <[email protected]>
Date: Tue Oct 17 21:45:36 2017 -0700
Log once a day how many connections had client_ip.
This is a sanity check against any catastrophic failure of our parsing
code.
---
server/server.go | 2 ++
server/stats.go | 42 ++++++++++++++++++++++++++++++++++++++++++
2 files changed, 44 insertions(+)
diff --git a/server/server.go b/server/server.go
index 3c97e06..1b33661 100644
--- a/server/server.go
+++ b/server/server.go
@@ -269,6 +269,8 @@ func main() {
log.Fatalf("error in setup: %s", err)
}
+ go statsThread()
+
var certManager *autocert.Manager
if !disableTLS {
log.Printf("ACME hostnames: %q", acmeHostnames)
diff --git a/server/stats.go b/server/stats.go
new file mode 100644
index 0000000..1aeefb5
--- /dev/null
+++ b/server/stats.go
@@ -0,0 +1,42 @@
+package main
+
+// This code handled periodic statistics logging.
+//
+// The only thing it keeps track of is how many connections had the client_ip
+// parameter. Write true to statsChannel to record a connection with client_ip;
+// write false for without.
+
+import (
+ "log"
+ "time"
+)
+
+const (
+ statsInterval = 24 * time.Hour
+)
+
+var (
+ statsChannel = make(chan bool)
+)
+
+func statsThread() {
+ var numClientIP, numConnections uint64
+ prevTime := time.Now()
+ for {
+ select {
+ case v := <-statsChannel:
+ if v {
+ numClientIP += 1
+ }
+ numConnections += 1
+ case <-time.After(statsInterval):
+ now := time.Now()
+ log.Printf("in the past %.g s, %d/%d connections had
client_ip",
+ (now.Sub(prevTime)).Seconds(),
+ numClientIP, numConnections)
+ numClientIP = 0
+ numConnections = 0
+ prevTime = now
+ }
+ }
+}
_______________________________________________
tor-commits mailing list
[email protected]
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits
