| 229 | } |
| 230 | |
| 231 | func TestCloserStack_PushAfterClose_ConnClosed(t *testing.T) { |
| 232 | t.Parallel() |
| 233 | ctx := testutil.Context(t, testutil.WaitShort) |
| 234 | logger := slogtest.Make(t, &slogtest.Options{IgnoreErrors: true}).Leveled(slog.LevelDebug) |
| 235 | uut := newCloserStack(ctx, logger, quartz.NewMock(t)) |
| 236 | |
| 237 | uut.close(xerrors.New("canceled")) |
| 238 | |
| 239 | closes := new([]*fakeCloser) |
| 240 | fc := &fakeCloser{closes: closes} |
| 241 | err := uut.push("conn", fc) |
| 242 | require.Error(t, err) |
| 243 | require.Equal(t, []*fakeCloser{fc}, *closes, "should close conn on failed push") |
| 244 | } |
| 245 | |
| 246 | func TestCoderConnectDialer_DefaultTimeout(t *testing.T) { |
| 247 | t.Parallel() |