diff options
Diffstat (limited to 'src/hub/src/spreadspace.org/sfive/s5srvPipe.go')
| -rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5srvPipe.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srvPipe.go b/src/hub/src/spreadspace.org/sfive/s5srvPipe.go index 3335878..4755c35 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srvPipe.go +++ b/src/hub/src/spreadspace.org/sfive/s5srvPipe.go @@ -117,19 +117,19 @@ func (srv Server) pipegramHandle(pconn net.PacketConn) { for { n, _, err := pconn.ReadFrom(buffer) if err != nil { - s5l.Printf("pipegram: read() failed: %v", err) + s5l.Printf("srv|pgram: read() failed: %v", err) continue } data := buffer[0:n] update, err := NewStatelessDecoder(bytes.NewReader(data)).Decode() if err != nil { - s5l.Printf("pipegram: decoding data message failed: %v\n", err) + s5l.Printf("srv|pgram: decoding data message failed: %v\n", err) continue } if err = srv.Ingest(update); err != nil { - s5l.Printf("pipegram: storing data failed: %v\n", err) + s5l.Printf("srv|pgram: storing data failed: %v\n", err) } } } @@ -137,13 +137,13 @@ func (srv Server) pipegramHandle(pconn net.PacketConn) { func (srv Server) ServePipegram(cfg PipegramInterfaceConfig) { pconn, err := net.ListenPacket("unixgram", cfg.ListenPath) if err != nil { - s5l.Printf("pipegram: listen() failed: %v", err) + s5l.Printf("srv|pgram: listen() failed: %v", err) return } defer pconn.Close() - s5l.Printf("server|pipegram: listening on '%s'", cfg.ListenPath) - defer s5l.Println("server|pipegram: interface stopped") + s5l.Printf("server|pgram: listening on '%s'", cfg.ListenPath) + defer s5l.Println("server|pgram: interface stopped") srv.pipegramHandle(pconn) } |