X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=door_daemon_go%2Funix_socket_server.go;h=ee5429f13047741afc8fdbfbe4b52b1978e62dd3;hb=bbbad3e45ac405f5511349d4fdf2d8af5240ac44;hp=eb34e0c41df9f917338c5f27e1ae5d9e46db2ddc;hpb=432e02ae6007b8f85c3d7692dbe4ff7066d70a25;p=svn42.git

diff --git a/door_daemon_go/unix_socket_server.go b/door_daemon_go/unix_socket_server.go
index eb34e0c..ee5429f 100644
--- a/door_daemon_go/unix_socket_server.go
+++ b/door_daemon_go/unix_socket_server.go
@@ -4,6 +4,11 @@ import "net"
 import "bufio"
 import "strings"
 
+var cmdHandler = map[string]func([]string,string) {
+  "test":handleCmdTest,
+}
+
+
 func readLineSafe(rw *bufio.ReadWriter) (string, error) {
   wasPrefix:=false
   var line string
@@ -41,7 +46,11 @@ func handleConnection(c net.Conn) () {
     for {
          line,err:=readLineSafe(client)
          if err != nil {
-          fmt.Println(err.Error())
+          if err.Error() != "EOF" {
+            fmt.Printf("Error: readLineSafe returned %v\n",err.Error())
+          } else {
+            fmt.Printf("Connection closed by remote host\n");
+          }
           c.Close()
           return
          }
@@ -57,8 +66,19 @@ func handleConnection(c net.Conn) () {
 
 func handleCmd(tokens []string, remainStr string) {
   cmd:=tokens[0]
-  fmt.Printf("Handling Cmd: %v\n", cmd)
+  func_ptr,present := cmdHandler[cmd]
+  if present {
+    func_ptr(tokens, remainStr)
+  } else {
+    fmt.Printf("Error: unknown Cmd: %v\n", cmd)
+  }
 }
+
+func handleCmdTest(tokens []string, remainStr string) {
+  //cmd:=tokens[0]
+  fmt.Printf("Test: %v\n", remainStr)
+}
+
 func main() {
   ln, err := net.Listen("unix", "/tmp/test.sock")
   if err != nil {