)

    taskFaker.advanceUntil(260.ms)
    assertEvents(
      "plan 0 TCP connect canceled",
    )
  }

  @Test
  fun secondPlanConnectedBeforeFirstPlan() {
    val plan0 = routePlanner.addPlan()
    plan0.tcpConnectDelayNanos = 270.ms
    val plan1 = routePlanner.addPlan()
    plan1.tcpConnectDelayNanos = 10.ms // Connect at time = 260 ms.

    taskRunner.newQueue().execute("connect") {

        SMBUtil.writeInt2(0, buffer, 22);

        // Network address offset (2 bytes)
        SMBUtil.writeInt2(0, buffer, 24);

        // Padding to align string data
        buffer[26] = 0;
        buffer[27] = 0;

        // Add the path string at stringDataStart
        System.arraycopy(pathBytes, 0, buffer, stringDataStart, pathBytes.length);
        // Null terminator

        }
      i++
    }
    return result
  }

  private val Int.punycodeDigit: Int
    get() =
      when {
        this < 26 -> this + 'a'.code
        this < 36 -> (this - 26) + '0'.code
        else -> error("unexpected digit: $this")
      }

	_ = x[ErrLexerInvalidLiteral-255]
	_ = x[ErrLexerInvalidIONLiteral-256]
	_ = x[ErrParseExpectedDatePart-257]
	_ = x[ErrParseExpectedKeyword-258]
	_ = x[ErrParseExpectedTokenType-259]
	_ = x[ErrParseExpected2TokenTypes-260]
	_ = x[ErrParseExpectedNumber-261]
	_ = x[ErrParseExpectedRightParenBuiltinFunctionCall-262]
	_ = x[ErrParseExpectedTypeName-263]
	_ = x[ErrParseExpectedWhenClause-264]
	_ = x[ErrParseUnsupportedToken-265]

        securityDescriptorBytes[24] = 0; // ACE count (low byte) - 0 ACEs
        securityDescriptorBytes[25] = 0; // ACE count (high byte)
        securityDescriptorBytes[26] = 0; // sbz2 (low byte)
        securityDescriptorBytes[27] = 0; // sbz2 (high byte)

        info502.security_descriptor = securityDescriptorBytes;
        info502.sd_size = securityDescriptorBytes.length;

        message[20] = 24; // Length
        message[21] = 0;
        message[22] = 24; // Max Length
        message[23] = 0;
        message[24] = 88; // Offset
        message[25] = 0;
        message[26] = 0;
        message[27] = 0;

        // Domain (12 bytes "DOMAIN" in Unicode at offset 112)
        message[28] = 12; // Length
        message[29] = 0;
        message[30] = 12; // Max Length

    assertThat(pool.connectionCount()).isEqualTo(1)
    assertThat(c1.socket().isClosed).isFalse()

    // Running at time 160, the pool returns that nothing can be evicted until time 260.
    assertThat(pool.closeConnections(160L)).isEqualTo(100L)
    assertThat(pool.connectionCount()).isEqualTo(1)
    assertThat(c1.socket().isClosed).isFalse()
  }

  @Test fun cleanupPrioritizesEarliestEviction() {

 * </ul>
 *
 * <p>If you don't need the features of this class, you may prefer {@code newSequentialExecutor} for
 * its simplicity and ability to accommodate interruption.
 *
 * @since 26.0
 */
@J2ktIncompatible
@GwtIncompatible
public final class ExecutionSequencer {

  private ExecutionSequencer() {}

  /** Creates a new instance. */
  public static ExecutionSequencer create() {

- go.uber.org/zap: v1.26.0 → v1.27.0
- golang.org/x/crypto: v0.24.0 → v0.28.0
- golang.org/x/exp: f3d0a9c → 8a7402a
- golang.org/x/lint: 1621716 → d0100b6
- golang.org/x/mod: v0.17.0 → v0.21.0
- golang.org/x/net: v0.26.0 → v0.30.0
- golang.org/x/oauth2: v0.21.0 → v0.23.0
- golang.org/x/sync: v0.7.0 → v0.8.0
- golang.org/x/sys: v0.21.0 → v0.26.0
- golang.org/x/telemetry: f48c80b → bda5523

  /**
   * <a href="https://tools.ietf.org/html/draft-kelly-json-hal-08#section-3">JSON Hypertext
   * Application Language (HAL) documents</a>.
   *
   * @since 26.0
   */
  public static final MediaType HAL_JSON = createConstant(APPLICATION_TYPE, "hal+json");

  /**
   * <a href="http://www.rfc-editor.org/rfc/rfc4329.txt">RFC 4329</a> declares this to be the