(t *testing.T)
| 906 | } |
| 907 | |
| 908 | func TestGetRTT(t *testing.T) { |
| 909 | s := RunServerOnPort(-1) |
| 910 | defer s.Shutdown() |
| 911 | |
| 912 | nc, err := nats.Connect(s.ClientURL(), nats.ReconnectWait(10*time.Millisecond), nats.ReconnectJitter(0, 0)) |
| 913 | if err != nil { |
| 914 | t.Fatalf("Expected to connect to server, got %v", err) |
| 915 | } |
| 916 | defer nc.Close() |
| 917 | |
| 918 | rtt, err := nc.RTT() |
| 919 | if err != nil { |
| 920 | t.Fatalf("Unexpected error getting RTT: %v", err) |
| 921 | } |
| 922 | if rtt > time.Second { |
| 923 | t.Fatalf("RTT value too large: %v", rtt) |
| 924 | } |
| 925 | // We should not get a value when in any disconnected state. |
| 926 | s.Shutdown() |
| 927 | time.Sleep(5 * time.Millisecond) |
| 928 | if _, err = nc.RTT(); err != nats.ErrDisconnected { |
| 929 | t.Fatalf("Expected disconnected error getting RTT when disconnected, got %v", err) |
| 930 | } |
| 931 | } |
| 932 | |
| 933 | func TestGetClientIP(t *testing.T) { |
| 934 | s := RunServerOnPort(-1) |
nothing calls this directly
no test coverage detected