Skip to content

Commit 8ec3e04

Browse files
committed
Fix issues found in code review
1 parent 58acbe5 commit 8ec3e04

4 files changed

Lines changed: 13 additions & 8 deletions

File tree

src/code.cloudfoundry.org/gorouter/integration/nats_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -210,6 +210,7 @@ var _ = Describe("NATS Integration", func() {
210210
time.Sleep(heartbeatInterval * 2)
211211

212212
natsRunner.Stop()
213+
test_util.ReleasePort(natsPort2)
213214
natsRunner2.Start()
214215

215216
// Give router time to make a bad decision (i.e. prune routes)

src/code.cloudfoundry.org/gorouter/mbus/subscriber_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -60,13 +60,13 @@ var _ = Describe("Subscriber", func() {
6060
})
6161

6262
AfterEach(func() {
63-
if natsRunner != nil {
64-
natsRunner.Stop()
65-
}
6663
if process != nil {
6764
process.Signal(os.Interrupt)
6865
}
6966
process = nil
67+
if natsRunner != nil {
68+
natsRunner.Stop()
69+
}
7070
})
7171

7272
It("exits when signaled", func() {

src/code.cloudfoundry.org/gorouter/router/router_test.go

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,8 @@ var _ = Describe("Router", func() {
8686
statusTLSPort = test_util.NextAvailPort()
8787
statusRoutesPort = test_util.NextAvailPort()
8888
natsPort = test_util.ReservePort()
89-
config = test_util.SpecConfig(statusPort, statusTLSPort, statusRoutesPort, proxyPort, natsPort)
89+
routeServiceServerPort := test_util.NextAvailPort()
90+
config = test_util.SpecConfig(statusPort, statusTLSPort, statusRoutesPort, proxyPort, routeServiceServerPort, natsPort)
9091
backendIdleTimeout = config.EndpointTimeout
9192
requestTimeout = config.EndpointTimeout
9293
config.EnableSSL = true
@@ -164,8 +165,9 @@ var _ = Describe("Router", func() {
164165
statusPort = test_util.NextAvailPort()
165166
statusTLSPort = test_util.NextAvailPort()
166167
statusRoutesPort = test_util.NextAvailPort()
168+
routeServiceServerPort := test_util.NextAvailPort()
167169

168-
c := test_util.SpecConfig(statusPort, statusTLSPort, statusRoutesPort, proxyPort, natsPort)
170+
c := test_util.SpecConfig(statusPort, statusTLSPort, statusRoutesPort, proxyPort, routeServiceServerPort, natsPort)
169171
c.StartResponseDelayInterval = 1 * time.Second
170172

171173
rtr, err := initializeRouter(c, c.EndpointTimeout, c.EndpointTimeout, registry, varz, mbusClient, logger.Logger, rss)
@@ -186,8 +188,9 @@ var _ = Describe("Router", func() {
186188
statusPort = test_util.NextAvailPort()
187189
statusTLSPort = test_util.NextAvailPort()
188190
statusRoutesPort = test_util.NextAvailPort()
191+
routeServiceServerPort := test_util.NextAvailPort()
189192

190-
c := test_util.SpecConfig(statusPort, statusTLSPort, statusRoutesPort, proxyPort, natsPort)
193+
c := test_util.SpecConfig(statusPort, statusTLSPort, statusRoutesPort, proxyPort, routeServiceServerPort, natsPort)
191194
c.StartResponseDelayInterval = 1 * time.Second
192195

193196
rss := &sharedfakes.RouteServicesServer{}
@@ -220,7 +223,8 @@ var _ = Describe("Router", func() {
220223
statusPort = test_util.NextAvailPort()
221224
statusTLSPort = test_util.NextAvailPort()
222225
statusRoutesPort = test_util.NextAvailPort()
223-
c = test_util.SpecConfig(statusPort, statusTLSPort, statusRoutesPort, proxyPort, natsPort)
226+
routeServiceServerPort := test_util.NextAvailPort()
227+
c = test_util.SpecConfig(statusPort, statusTLSPort, statusRoutesPort, proxyPort, routeServiceServerPort, natsPort)
224228
c.StartResponseDelayInterval = 1 * time.Second
225229
})
226230

0 commit comments

Comments
 (0)