* class's static initializer can fall back on a non-Unsafe version.
   */
  @SuppressWarnings("SunApi") // b/345822163
  @VisibleForTesting
  enum UnsafeByteArray implements LittleEndianBytes {
    // Do *not* change the order of these constants!
    UNSAFE_LITTLE_ENDIAN {
      @Override
      public long getLongLittleEndian(byte[] array, int offset) {
        return theUnsafe.getLong(array, (long) offset + BYTE_ARRAY_BASE_OFFSET);

        FileSystemInformation info1 = response.getInfo();

        // Second read with different data
        buffer = prepareAllocationInfoBuffer();
        buffer[8] = 10; // Change some data

        int bytesRead2 = response.readDataWireFormat(buffer, 0, 20);
        FileSystemInformation info2 = response.getInfo();

        // Info should be updated
        assertNotSame(info1, info2);

    void testCommandType() {
        // Verify that the command is not set in constructor (defaults to 0)
        assertEquals(0, response.getCommand());

        // Verify we can change the subcommand
        response.setSubCommand((byte) 0xFF);
        assertEquals((byte) 0xFF, response.getSubCommand());

        // But creating a new instance should have the correct subcommand

your code interacts with the filesystem, network, etc. and uses checkpointed
variables as part of those interactions (ex: using a string variable to build a
filesystem path), a maliciously created checkpoint might be able to change the
targets of those operations, which could result in arbitrary
read/write/executions.

### Running a TensorFlow server

TensorFlow is a platform for distributed computing, and as such there is a

    }

    @Test
    @DisplayName("Test writeParameterWordsWireFormat for secondary NT transaction")
    void testWriteParameterWordsWireFormatSecondary() {
        byte[] dst = new byte[256];

        // Change command to secondary
        transaction.setCommand(ServerMessageBlock.SMB_COM_NT_TRANSACT_SECONDARY);

        // Set up transaction parameters
        transaction.setTotalParameterCount(100);

 * {@link #enqueue} and {@link #dispatch} are 2 different methods. It is expected that the decision
 * to run a particular event is made during the state change, but the decision to actually invoke
 * the listeners can be delayed slightly so that locks can be dropped. Also, because {@link
 * #dispatch} is expected to be called concurrently, it is idempotent.
 */
@J2ktIncompatible

 *
 * @author Kevin Bourrillion
 * @author Jens Nyman
 * @since 1.0
 */
@J2ktIncompatible
@GwtIncompatible
// TODO: b/227335009 - Maybe change interruption behavior, but it requires thought.
@SuppressWarnings("Interruption")
public final class SimpleTimeLimiter implements TimeLimiter {

  private final ExecutorService executor;

	for _, version := range versions {
		version.EncodeMsg(encoder)
	}
	storageLogIf(ctx, encoder.Flush())

	errs = make([]error, len(versions))

	respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1)
	defer xhttp.DrainBody(respBody)
	if err != nil {
		if contextCanceled(ctx) {
			err = ctx.Err()
		}
		for i := range errs {
			errs[i] = err
		}

    @DisplayName("isValid() false when tree id changed or disconnected or closed")
    void isValid_false_inVariousCases() {
        when(cfg.isTraceResourceUsage()).thenReturn(false);
        stubValidTree(10L, true, true);
        SmbFileHandleImpl h = new SmbFileHandleImpl(cfg, new byte[] { 0x01 }, tree, "//x", 0, 0, 0, 0, 0L);

        assertTrue(h.isValid());

        // Tree id change makes it invalid

    assertFalse(fakePool.hasNext());

    // Check that execute can be safely repeated
    e.execute(intCounter);
    e.execute(intCounter);
    e.execute(intCounter);
    // No change yet.
    assertEquals(2, totalCalls.get());
    fakePool.runAll();
    assertEquals(5, totalCalls.get());
    assertFalse(fakePool.hasNext());
  }

  public void testOrdering() {