http: fix tests incorrectly using HTTPAddr to get the address of the
https server. In #8234 I changed a few tests to use TestAgent.HTTPAddr() to find the addr used in the test. Due to the way HTTPAddr() was implemented these tests were passing, but I think the pass was incidental. HTTPAddr() was not matching any servers, and was instead returning the last server, which happened to be the one these tests wanted. This commit fixes the implementation of HTTPAddr to panic if no match was found. The tests which require an HTTPS server are changed to use a new firstAddr() to look up the correct address.
This commit is contained in:
parent
a14a31ccf1
commit
4eb514a59f
|
@ -1917,13 +1917,15 @@ func TestAgent_HTTPCheck_EnableAgentTLSForChecks(t *testing.T) {
|
||||||
Status: api.HealthCritical,
|
Status: api.HealthCritical,
|
||||||
}
|
}
|
||||||
|
|
||||||
url := fmt.Sprintf("https://%s/v1/agent/self", a.HTTPAddr())
|
addr, err := firstAddr(a.Agent.apiServers, "https")
|
||||||
|
require.NoError(t, err)
|
||||||
|
url := fmt.Sprintf("https://%s/v1/agent/self", addr.String())
|
||||||
chk := &structs.CheckType{
|
chk := &structs.CheckType{
|
||||||
HTTP: url,
|
HTTP: url,
|
||||||
Interval: 20 * time.Millisecond,
|
Interval: 20 * time.Millisecond,
|
||||||
}
|
}
|
||||||
|
|
||||||
err := a.AddCheck(health, chk, false, "", ConfigSourceLocal)
|
err = a.AddCheck(health, chk, false, "", ConfigSourceLocal)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("err: %v", err)
|
t.Fatalf("err: %v", err)
|
||||||
}
|
}
|
||||||
|
|
|
@ -1351,9 +1351,11 @@ func TestHTTPServer_HandshakeTimeout(t *testing.T) {
|
||||||
})
|
})
|
||||||
defer a.Shutdown()
|
defer a.Shutdown()
|
||||||
|
|
||||||
|
addr, err := firstAddr(a.Agent.apiServers, "https")
|
||||||
|
require.NoError(t, err)
|
||||||
// Connect to it with a plain TCP client that doesn't attempt to send HTTP or
|
// Connect to it with a plain TCP client that doesn't attempt to send HTTP or
|
||||||
// complete a TLS handshake.
|
// complete a TLS handshake.
|
||||||
conn, err := net.Dial("tcp", a.HTTPAddr())
|
conn, err := net.Dial("tcp", addr.String())
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
defer conn.Close()
|
defer conn.Close()
|
||||||
|
|
||||||
|
@ -1413,7 +1415,8 @@ func TestRPC_HTTPSMaxConnsPerClient(t *testing.T) {
|
||||||
})
|
})
|
||||||
defer a.Shutdown()
|
defer a.Shutdown()
|
||||||
|
|
||||||
addr := a.HTTPAddr()
|
addr, err := firstAddr(a.Agent.apiServers, strings.ToLower(tc.name))
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
assertConn := func(conn net.Conn, wantOpen bool) {
|
assertConn := func(conn net.Conn, wantOpen bool) {
|
||||||
retry.Run(t, func(r *retry.R) {
|
retry.Run(t, func(r *retry.R) {
|
||||||
|
@ -1433,21 +1436,21 @@ func TestRPC_HTTPSMaxConnsPerClient(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// Connect to the server with bare TCP
|
// Connect to the server with bare TCP
|
||||||
conn1, err := net.DialTimeout("tcp", addr, time.Second)
|
conn1, err := net.DialTimeout("tcp", addr.String(), time.Second)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
defer conn1.Close()
|
defer conn1.Close()
|
||||||
|
|
||||||
assertConn(conn1, true)
|
assertConn(conn1, true)
|
||||||
|
|
||||||
// Two conns should succeed
|
// Two conns should succeed
|
||||||
conn2, err := net.DialTimeout("tcp", addr, time.Second)
|
conn2, err := net.DialTimeout("tcp", addr.String(), time.Second)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
defer conn2.Close()
|
defer conn2.Close()
|
||||||
|
|
||||||
assertConn(conn2, true)
|
assertConn(conn2, true)
|
||||||
|
|
||||||
// Third should succeed negotiating TCP handshake...
|
// Third should succeed negotiating TCP handshake...
|
||||||
conn3, err := net.DialTimeout("tcp", addr, time.Second)
|
conn3, err := net.DialTimeout("tcp", addr.String(), time.Second)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
defer conn3.Close()
|
defer conn3.Close()
|
||||||
|
|
||||||
|
@ -1460,7 +1463,7 @@ func TestRPC_HTTPSMaxConnsPerClient(t *testing.T) {
|
||||||
require.NoError(t, a.reloadConfigInternal(&newCfg))
|
require.NoError(t, a.reloadConfigInternal(&newCfg))
|
||||||
|
|
||||||
// Now another conn should be allowed
|
// Now another conn should be allowed
|
||||||
conn4, err := net.DialTimeout("tcp", addr, time.Second)
|
conn4, err := net.DialTimeout("tcp", addr.String(), time.Second)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
defer conn4.Close()
|
defer conn4.Close()
|
||||||
|
|
||||||
|
|
|
@ -9,6 +9,7 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"math/rand"
|
"math/rand"
|
||||||
|
"net"
|
||||||
"net/http/httptest"
|
"net/http/httptest"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"strconv"
|
"strconv"
|
||||||
|
@ -313,13 +314,23 @@ func (a *TestAgent) DNSAddr() string {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *TestAgent) HTTPAddr() string {
|
func (a *TestAgent) HTTPAddr() string {
|
||||||
var srv apiServer
|
addr, err := firstAddr(a.Agent.apiServers, "http")
|
||||||
for _, srv = range a.Agent.apiServers.servers {
|
if err != nil {
|
||||||
if srv.Protocol == "http" {
|
// TODO: t.Fatal instead of panic
|
||||||
break
|
panic("no http server registered")
|
||||||
|
}
|
||||||
|
return addr.String()
|
||||||
|
}
|
||||||
|
|
||||||
|
// firstAddr is used by tests to look up the address for the first server which
|
||||||
|
// matches the protocol
|
||||||
|
func firstAddr(s *apiServers, protocol string) (net.Addr, error) {
|
||||||
|
for _, srv := range s.servers {
|
||||||
|
if srv.Protocol == protocol {
|
||||||
|
return srv.Addr, nil
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return srv.Addr.String()
|
return nil, fmt.Errorf("no server registered with protocol %v", protocol)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *TestAgent) SegmentAddr(name string) string {
|
func (a *TestAgent) SegmentAddr(name string) string {
|
||||||
|
|
Loading…
Reference in New Issue