| package impl_test |
| |
| import ( |
| "testing" |
| "veyron2/ipc" |
| "veyron2/rt" |
| ) |
| |
| func startServer(t *testing.T, disp ipc.Dispatcher) (ipc.Server, string, error) { |
| server, err := rt.R().NewServer() |
| if err != nil { |
| t.Fatalf("NewServer failed: %v", err) |
| return nil, "", err |
| } |
| endpoint, err := server.Listen("tcp", "localhost:0") |
| if err != nil { |
| t.Fatalf("Listen failed: %v", err) |
| return nil, "", err |
| } |
| if err := server.Serve("", disp); err != nil { |
| t.Fatalf("Serve failed: %v", err) |
| return nil, "", err |
| } |
| return server, endpoint.String(), nil |
| } |
| |
| func stopServer(t *testing.T, server ipc.Server) { |
| if err := server.Stop(); err != nil { |
| t.Errorf("server.Stop failed: %v", err) |
| } |
| } |
