mirror of
https://github.com/coder/coder.git
synced 2025-07-18 14:17:22 +00:00
chore: dial the remote socket continually until connect (#6891)
It's possible that the command starts but the socket isn't ready even when the file exists.
This commit is contained in:
@ -673,13 +673,14 @@ func TestAgent_UnixRemoteForwarding(t *testing.T) {
|
|||||||
err = cmd.Start()
|
err = cmd.Start()
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
// It's possible that the socket is created but the server is not ready to
|
||||||
|
// accept connections yet. We need to retry until we can connect.
|
||||||
|
var conn net.Conn
|
||||||
require.Eventually(t, func() bool {
|
require.Eventually(t, func() bool {
|
||||||
_, err := os.Stat(remoteSocketPath)
|
var err error
|
||||||
|
conn, err = net.Dial("unix", remoteSocketPath)
|
||||||
return err == nil
|
return err == nil
|
||||||
}, testutil.WaitLong, testutil.IntervalFast)
|
}, testutil.WaitShort, testutil.IntervalFast)
|
||||||
|
|
||||||
conn, err := net.Dial("unix", remoteSocketPath)
|
|
||||||
require.NoError(t, err)
|
|
||||||
defer conn.Close()
|
defer conn.Close()
|
||||||
_, err = conn.Write([]byte("test"))
|
_, err = conn.Write([]byte("test"))
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
Reference in New Issue
Block a user