Remove pool subtest

Author: prestonvasquez

x/mongo/driver/topology/pool_test.go

@@ -842,79 +842,6 @@ func TestPool_checkOut(t *testing.T) {
 			assert.Containsf(t, err.Error(), "canceled", `expected error message to contain "canceled"`)
 		}
 
-		p.close(context.Background())
-	})
-	t.Run("discards connections closed by the server side", func(t *testing.T) {
-		t.Parallel()
-
-		cleanup := make(chan struct{})
-		defer close(cleanup)
-
-		ncs := make(chan net.Conn, 2)
-		addr := bootstrapConnections(t, 2, func(nc net.Conn) {
-			// Send all "server-side" connections to a channel so we can
-			// interact with them during the test.
-			ncs <- nc
-
-			<-cleanup
-			_ = nc.Close()
-		})
-
-		d := newdialer(&net.Dialer{})
-		p := newPool(poolConfig{
-			Address: address.Address(addr.String()),
-		}, WithDialer(func(Dialer) Dialer { return d }))
-		err := p.ready()
-		require.NoError(t, err)
-
-		// Add 1 idle connection to the pool by checking-out and checking-in
-		// a connection.
-		conn, err := p.checkOut(context.Background())
-		require.NoError(t, err)
-		err = p.checkIn(conn)
-		require.NoError(t, err)
-		assertConnectionsOpened(t, d, 1)
-		assert.Equalf(t, 1, p.availableConnectionCount(), "should be 1 idle connections in pool")
-		assert.Equalf(t, 1, p.totalConnectionCount(), "should be 1 total connection in pool")
-
-		// Make that connection appear as if it's been idle for a minute.
-		conn.idleStart.Store(time.Now().Add(-1 * time.Minute))
-
-		// Close the "server-side" of the connection we just created. The idle
-		// connection in the pool is now unusable because the "server-side"
-		// closed it.
-		nc := <-ncs
-		err = nc.Close()
-		require.NoError(t, err)
-
-		// In a separate goroutine, write a valid wire message to the 2nd
-		// connection that's about to be created. Stop waiting for a 2nd
-		// connection after 100ms to prevent leaking a goroutine.
-		go func() {
-			select {
-			case nc := <-ncs:
-				_, err := nc.Write([]byte{5, 0, 0, 0, 0})
-				require.NoError(t, err, "Write error")
-			case <-time.After(100 * time.Millisecond):
-			}
-		}()
-
-		// Check out a connection and try to read from it. Expect the pool to
-		// discard the connection that was closed by the "server-side" and
-		// return a newly created connection instead.
-		conn, err = p.checkOut(context.Background())
-		require.NoError(t, err)
-		msg, err := conn.readWireMessage(context.Background())
-		require.NoError(t, err)
-		assert.Equal(t, []byte{5, 0, 0, 0, 0}, msg)
-
-		err = p.checkIn(conn)
-		require.NoError(t, err)
-
-		assertConnectionsOpened(t, d, 2)
-		assert.Equalf(t, 1, p.availableConnectionCount(), "should be 1 idle connections in pool")
-		assert.Equalf(t, 1, p.totalConnectionCount(), "should be 1 total connection in pool")
-
 		p.close(context.Background())
 	})
 }