6 func readLineSafe(rw *bufio.ReadWriter) (string, error) {
9 for isPrefix:=true;isPrefix; {
12 lineBuf,isPrefix,err = rw.ReadLine()
23 fmt.Println("line too long")
24 fmt.Fprintf(rw,"line too long\n")
31 func connToReadWriter(c net.Conn) (*bufio.ReadWriter) {
32 client_r := bufio.NewReaderSize(c,14)
33 client_w := bufio.NewWriterSize(c,14)
34 return bufio.NewReadWriter(client_r,client_w)
37 func handleConnection(c net.Conn) () {
38 client:=connToReadWriter(c)
39 fmt.Println("new connection")
41 line,err:=readLineSafe(client)
43 fmt.Println(err.Error())
50 fmt.Printf("Received: %v\n", string(line))
56 ln, err := net.Listen("unix", "/tmp/test.sock")
58 fmt.Printf("Error: %s\n",err.Error())
61 fmt.Printf("Listener started\n")
63 conn, err := ln.Accept()
68 go handleConnection(conn)