X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=door_daemon_go%2Funix_socket_server.go;h=eb34e0c41df9f917338c5f27e1ae5d9e46db2ddc;hb=432e02ae6007b8f85c3d7692dbe4ff7066d70a25;hp=a2e710a80156058c3544a193b60668829d0f3ad1;hpb=204ca2fe92c8bedf87ab5ae4d1c1bc0660b1a3dd;p=svn42.git diff --git a/door_daemon_go/unix_socket_server.go b/door_daemon_go/unix_socket_server.go index a2e710a..eb34e0c 100644 --- a/door_daemon_go/unix_socket_server.go +++ b/door_daemon_go/unix_socket_server.go @@ -2,6 +2,7 @@ package main import "fmt" import "net" import "bufio" +import "strings" func readLineSafe(rw *bufio.ReadWriter) (string, error) { wasPrefix:=false @@ -47,11 +48,17 @@ func handleConnection(c net.Conn) () { if line == "" { continue } - fmt.Printf("Received: %v\n", string(line)) + fmt.Printf("Received: %v\n", line) + tokens:=strings.Fields(line) + remainStr:=strings.Join(tokens[1:]," ") + handleCmd(tokens,remainStr) } } - +func handleCmd(tokens []string, remainStr string) { + cmd:=tokens[0] + fmt.Printf("Handling Cmd: %v\n", cmd) +} func main() { ln, err := net.Listen("unix", "/tmp/test.sock") if err != nil {