*/
  fun timeoutEarlyExit() {
    check(!timeoutEarlyExit)
    timeoutEarlyExit = true
    timeout.exit()
  }

  /**
   * @param closeExchange true if the current exchange should be closed because it will not be used.
   *     This is usually due to either an exception or a retry.
   */
  internal fun exitNetworkInterceptorExchange(closeExchange: Boolean) {
    withLock {

   * - The second request discovers it "lost the race" and closes the connection it just opened.
   * - The second request uses the coalesced connection from request1.
   * - The coalesced connection is violently closed after servicing the first request.
   * - The second request discovers the coalesced connection is unhealthy just after acquiring it.
   */
  @Test
  fun coalescedConnectionDestroyedAfterAcquire() {

    of unacknowledged data per stream and no per-connection limit.

 *  Fix: Don't close a `Deflater` while we're still using it to compress a web socket message. We
    had a severe bug where web sockets were closed on the wrong thread, which caused
    `NullPointerException` crashes in `Deflater`.

 *  Fix: Don't crash after a web socket fails its connection upgrade. We incorrectly released

            }
        });
        nonPooledConnections.clear();

        activeConnections.set(0);
        log.info("Transport pool closed");
    }

    /**
     * Connection metrics for monitoring individual connections
     */
    private static class ConnectionMetrics {
        private final AtomicLong connectionsCreated = new AtomicLong(0);

            }

            // should we disconnect the transport here? otherwise we make an additional attempt to detect that if the
            // server closed the connection as a result
            log.debug("Disconnecting tree on send retry", last);
            disconnect(true);

            if (retries >= maxRetries) {
                break;
            }

         */
        try {
            this.socket.setSoTimeout(this.transportContext.getConfig().getConnTimeout());
            if (peekKey() == null) { /* try to read header */
                throw new IOException("transport closed in negotiate");
            }
        } finally {
            this.socket.setSoTimeout(this.transportContext.getConfig().getSoTimeout());
        }
        final int size = Encdec.dec_uint16be(this.sbuf, 2) & 0xFFFF;

        // This test verifies that ProtwordsUpdater constructor properly handles exceptions
        // The actual exception handling is tested by ensuring the updater can be created
        // and properly closed even when errors might occur

        protwordsFile.reload(null);

        // Test normal creation and cleanup of ProtwordsUpdater
        ProtwordsItem testItem = new ProtwordsItem(0, "testWord");

        // This test verifies that close() handles errors gracefully
        CharMappingItem newItem = new CharMappingItem(0, new String[] { "x", "y" }, "z");

        // Insert will trigger MappingUpdater which will be closed automatically
        charMappingFile.insert(newItem);

        // Verify the operation completed successfully despite any internal errors
        PagingList<CharMappingItem> result = charMappingFile.selectList(0, 10);

		}
	}
	if !truncated {
		return entries, io.EOF
	}
	return entries, nil
}

// listMerged will list across all sets and return a merged results stream.
// The result channel is closed when no more results are expected.
func (z *erasureServerPools) listMerged(ctx context.Context, o listPathOptions, results chan<- metaCacheEntry) error {
	var mu sync.Mutex
	var wg sync.WaitGroup
	var errs []error

    handler: Handler,
    length: Int,
    flags: Int,
    streamId: Int,
  ) {
    if (streamId == 0) throw IOException("PROTOCOL_ERROR: TYPE_DATA streamId == 0")

    // TODO: checkState open or half-closed (local) or raise STREAM_CLOSED
    val inFinished = flags and FLAG_END_STREAM != 0
    val gzipped = flags and FLAG_COMPRESSED != 0
    if (gzipped) {