blob: 3989888d16463d3a009b53cb6a18b9c591d84a73 [file] [log] [blame]
package main
import (
"bufio"
"fmt"
_ "log"
"net"
"v.io/x/ref/examples/grpc-fortune/vgrpc"
)
const (
secure = true
)
func main() {
ln, err := net.Listen("tcp", ":8080")
if err != nil {
// handle error
}
for {
conn, err := ln.Accept()
if err != nil {
panic(err)
}
if secure {
vcred := &vgrpc.VanadiumCred{}
secureConn, _, _ := vcred.ServerHandshake(conn)
conn = secureConn
}
status, err := bufio.NewReader(conn).ReadString('.')
// log.Printf("Server received: %s\n", status)
fmt.Fprintf(conn, "I heard: '%s'\n", status)
status, err = bufio.NewReader(conn).ReadString('.')
// log.Printf("Server received: %s\n", status)
fmt.Fprintf(conn, "I heard: '%s'\n", status)
}
}