gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #427 from nats-io/update_test

Browse Source 
Update client connect to route port test
This commit is contained in:
Derek Collison
2017-01-27 19:18:42 -05:00
committed by GitHub
parent fdf1a24d78 1c5a34ea42
commit 33afedcc70
1 changed files with 13 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
server/routes_test.go
View File

@@ -486,37 +486,22 @@ func TestClientConnectToRoutePort(t *testing.T) {
url := fmt.Sprintf("nats://%s:%d", opts.Cluster.Host, opts.Cluster.Port)
clientURL := fmt.Sprintf("nats://%s:%d", opts.Host, opts.Port)
total := 100
// When connecting to the ROUTE port, the client library will receive the
// CLIENT port in the INFO protocol. This URL is added to the client's pool
// and will be tried after the initial connect failure. So all those
// nats.Connect() should succeed.
// The only reason for a failure would be if there are too many FDs in time-wait
// which would delay the creation of TCP connection. So keep the total of
// attempts rather small.
total := 10
for i := 0; i < total; i++ {
nc, err := nats.Connect(url)
if err == nil {
// It is possible that the client reconnects because
// it gets from the initial connect to the route the
// connectedUrl array and may be able to reconnects
// to the client URL.
// If connected, it should be to the client URL
if nc.ConnectedUrl() != clientURL {
t.Fatalf("Expected client to be connected to %v, got %v", clientURL, nc.ConnectedUrl())
}
nc.Close()
if err != nil {
t.Fatalf("Unexepected error on connect: %v", err)
}
// If error, it could be ErrClientConnectingToRoutePort or
// other (EOF, etc)... so not checking for specific one.
}
// When disabling randomization, the client URL is added to the server
// pool and so should be tried after the connection is closed trying
// to connect to the route port. Connect must always succeed and
// must be connected to client URL.
for i := 0; i < total; i++ {
nc, err := nats.Connect(url, nats.DontRandomize())
if err == nil {
if nc.ConnectedUrl() != clientURL {
t.Fatalf("Expected client to be connected to %v, got %v", clientURL, nc.ConnectedUrl())
}
nc.Close()
continue
defer nc.Close()
if nc.ConnectedUrl() != clientURL {
t.Fatalf("Expected client to be connected to %v, got %v", clientURL, nc.ConnectedUrl())
}
t.Fatalf("Error on connect: %v", err)
}
}