| 132 | } |
| 133 | |
| 134 | func checkDirNoNewPluginServer(t *testing.T) { |
| 135 | t.Helper() |
| 136 | |
| 137 | files, err := os.ReadDir(".") |
| 138 | assert.NilError(t, err, "failed to list files in dir to check for leaked sockets") |
| 139 | |
| 140 | for _, f := range files { |
| 141 | info, err := f.Info() |
| 142 | assert.NilError(t, err, "failed to check file info") |
| 143 | // check for a socket with `docker_cli_` in the name (from `SetupConn()`) |
| 144 | if strings.Contains(f.Name(), "docker_cli_") && info.Mode().Type() == fs.ModeSocket { |
| 145 | t.Fatal("found socket in a local directory") |
| 146 | } |
| 147 | } |
| 148 | } |
| 149 | |
| 150 | func TestConnectAndWait(t *testing.T) { |
| 151 | t.Run("calls cancel func on EOF", func(t *testing.T) { |