) {
    lock.withLock {
      val oldLimit = allocationLimit
      allocationLimit = settings.getMaxConcurrentStreams()

      if (allocationLimit < oldLimit) {
        // We might need new connections to keep policies satisfied
        connectionPool.scheduleOpener(route.address)
      } else if (allocationLimit > oldLimit) {
        // We might no longer need some connections
        connectionPool.scheduleCloser()
      }

    //     we find them, regardless of what the address policies need.
    //
    //  2. EVICTABLE: Connections not required by any address policy. This matches connections that
    //     don't participate in any policy, plus connections whose policies won't be violated if the
    //     connection is closed. We only close these if the idle connection limit is exceeded.
    //

        logger.fine(
          "${this@MockWebServer} received request: $request and responded: $response",
        )
      }

      // See warnings associated with these socket policies in SocketPolicy.
      when (response.socketPolicy) {
        DisconnectAtEnd, is DoNotReadRequestBody -> {
          socket.close()
          return false
        }