diff options
Diffstat (limited to 'src/hub/src/spreadspace.org/sfive/s5srv.go')
| -rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5srv.go | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srv.go b/src/hub/src/spreadspace.org/sfive/s5srv.go index 979cd83..2a312bd 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srv.go +++ b/src/hub/src/spreadspace.org/sfive/s5srv.go @@ -67,7 +67,7 @@ func (srv Server) transform(update *UpdateFull) *UpdateFull { if srv.geoip != nil { if info, err := srv.geoip.Lookup(client.IP); err != nil { - s5l.Printf("server|transform: Geo-IP lookup failed: %v", err) + s5l.Printf("srv|xfrm: Geo-IP lookup failed: %v", err) } else { client.GeoInfo = *info } @@ -75,7 +75,7 @@ func (srv Server) transform(update *UpdateFull) *UpdateFull { if srv.anonymization != nil { if aIP, err := srv.anonymization.Anonymize(client.IP); err != nil { - s5l.Printf("server|transform: anonymization failed: %v", err) + s5l.Printf("srv|xfrm: anonymization failed: %v", err) } else { client.IP = aIP } @@ -87,13 +87,13 @@ func (srv Server) transform(update *UpdateFull) *UpdateFull { if uint(len(update.Data.Clients)) > update.Data.ClientCount { if update.Data.ClientCount > 0 { - s5l.Printf("server|transform: fixing client-count: %d -> %d", update.Data.ClientCount, len(update.Data.Clients)) + s5l.Printf("srv|xfrm: fixing client-count: %d -> %d", update.Data.ClientCount, len(update.Data.Clients)) } update.Data.ClientCount = uint(len(update.Data.Clients)) } if bytesSentTotal > update.Data.BytesSent { if update.Data.BytesSent > 0 { - s5l.Printf("server|transform: fixing bytes-sent: %d -> %d", update.Data.BytesSent, bytesSentTotal) + s5l.Printf("srv|xfrm: fixing bytes-sent: %d -> %d", update.Data.BytesSent, bytesSentTotal) } update.Data.BytesSent = bytesSentTotal } @@ -137,14 +137,14 @@ func (srv Server) IngestMany(updates []*UpdateFull) error { } func (srv Server) Close() { - s5l.Printf("server: shutting down") + s5l.Printf("srv: shutting down") close(srv.quit) srv.done.Wait() close(srv.ingestChan) close(srv.ingestManyChan) srv.store.Close() - s5l.Printf("server: finished") + s5l.Printf("srv: finished") } func NewServer(cfg SrvConfig) (srv *Server, err error) { @@ -159,7 +159,7 @@ func NewServer(cfg SrvConfig) (srv *Server, err error) { err = errors.New("failed to initialize IP address anonymization: " + err.Error()) return } - s5l.Printf("server|transform: using IP address anonymization: %s", srv.anonymization) + s5l.Printf("srv|xfrm: using IP address anonymization: %s", srv.anonymization) } if cfg.Transform.GeoipDB != "" { @@ -167,7 +167,7 @@ func NewServer(cfg SrvConfig) (srv *Server, err error) { err = errors.New("failed to initialize Geo-IP Lookup: " + err.Error()) return } - s5l.Printf("server|transform: using Geo-IP Lookup: %s", srv.geoip) + s5l.Printf("srv|xfrm: using Geo-IP Lookup: %s", srv.geoip) } srv.numWorker = runtime.NumCPU() // TODO: make this configurable @@ -182,6 +182,6 @@ func NewServer(cfg SrvConfig) (srv *Server, err error) { srv.ingestWorker(idx) }(i) } - s5l.Printf("server: started") + s5l.Printf("srv: started") return } |