1 files changed, 0 insertions, 63 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srvPipe.go b/src/hub/src/spreadspace.org/sfive/s5srvPipe.go
index 6cf2bc4..20e3085 100644
--- a/src/hub/src/spreadspace.org/sfive/s5srvPipe.go
+++ b/src/hub/src/spreadspace.org/sfive/s5srvPipe.go
@@ -33,21 +33,10 @@
 package sfive
 
 import (
-	"bytes"
-	"context"
 	"io"
 	"net"
-	"strings"
 )
 
-const (
-	PipegramMessageSizeLimit = 1024 * 1024 // TODO: is this really needed?
-)
-
-//
-// Unix Socket Interface (streams)
-//
-
 func (srv *Server) pipeHandle(conn net.Conn) {
 	defer conn.Close()
 
@@ -108,55 +97,3 @@ func (srv *Server) ServePipe(cfg PipeInterfaceConfig) {
 		go srv.pipeHandle(conn)
 	}
 }
-
-//
-// Unix Socket Interface (datagrams)
-//
-
-func (srv *Server) pipegramRun() {
-	buffer := make([]byte, PipegramMessageSizeLimit)
-
-	for {
-		n, _, err := srv.interfaces.pipegram.ReadFrom(buffer)
-		if err != nil {
-			if strings.Contains(err.Error(), "use of closed network connection") { // TODO: is this really the best way to do this?
-				return
-			}
-			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("srv|pgram: decoding data message failed: %v\n", err)
-			continue
-		}
-
-		if err = srv.Ingest(update); err != nil {
-			s5l.Printf("srv|pgram: storing data failed: %v\n", err)
-		}
-	}
-}
-
-func (srv *Server) pipegramStop(ctx context.Context) (err error) {
-	// TODO: this is a race condition between a call to webRun and webStop...
-	if srv.interfaces.pipegram == nil {
-		return nil
-	}
-	s5l.Printf("srv|pgram: shutting down")
-	return srv.interfaces.pipegram.Close()
-}
-
-func (srv *Server) ServePipegram(cfg PipegramInterfaceConfig) (err error) {
-	if srv.interfaces.pipegram, err = net.ListenPacket("unixgram", cfg.ListenPath); err != nil {
-		s5l.Printf("srv|pgram: listen() failed: %v", err)
-		return
-	}
-
-	s5l.Printf("srv|pgram: listening on '%s'", cfg.ListenPath)
-	defer s5l.Println("srv|pgram: interface stopped")
-
-	srv.pipegramRun()
-	return
-}