(t *testing.T, hs func(net.Conn, string) (AuthInfo, error), lisAddr string)
| 255 | } |
| 256 | |
| 257 | func clientHandle(t *testing.T, hs func(net.Conn, string) (AuthInfo, error), lisAddr string) AuthInfo { |
| 258 | conn, err := net.Dial("tcp", lisAddr) |
| 259 | if err != nil { |
| 260 | t.Fatalf("Client failed to connect to %s. Error: %v", lisAddr, err) |
| 261 | } |
| 262 | defer conn.Close() |
| 263 | clientAuthInfo, err := hs(conn, lisAddr) |
| 264 | if err != nil { |
| 265 | t.Fatalf("Error on client while handshake. Error: %v", err) |
| 266 | } |
| 267 | return clientAuthInfo |
| 268 | } |
| 269 | |
| 270 | // Server handshake implementation in gRPC. |
| 271 | func gRPCServerHandshake(conn net.Conn) (AuthInfo, error) { |
no test coverage detected