@Override
        protected URLConnection openConnection(URL u) {
            return null; // not used
        }
    };

    @BeforeEach
    void setup() {
        when(ctx.getConfig()).thenReturn(config);
        when(ctx.getCredentials()).thenReturn(creds);
        when(ctx.getNameServiceClient()).thenReturn(nsc);
    }

    private static URL smbUrl(String spec) {

    private static final long TEST_PREVIOUS_SESSION_ID = 0x1234567890ABCDEFL;
    private static final byte[] TEST_TOKEN = { 0x01, 0x02, 0x03, 0x04, 0x05 };

    @BeforeEach
    void setUp() {
        mockConfig = mock(Configuration.class);
        mockContext = mock(CIFSContext.class);
        when(mockContext.getConfig()).thenReturn(mockConfig);

     * #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED}
     *
     * <p>To avoid races between threads doing release and acquire, we transition to the final state
     * in two steps. One thread will successfully CAS from RUNNING to COMPLETING, that thread will
     * then set the result of the computation, and only then transition to COMPLETED, CANCELLED, or
     * INTERRUPTED.
     *

 * default} methods. Instead, it inherits their default implementations. When those implementations
 * invoke methods, they invoke methods on the {@code ForwardingNavigableSet}.
 *
 * <p>Each of the {@code standard} methods uses the set's comparator (or the natural ordering of the
 * elements, if there is no comparator) to test element equality. As a result, if the comparator is
 * not consistent with equals, some of the standard implementations may violate the {@code Set}

  workflow_dispatch:

permissions:
  contents: read

jobs:
  rbe:
    name: Update RBE Configs
    runs-on: ubuntu-latest
    if: github.repository == 'tensorflow/tensorflow' # Don't do this in forks
    steps:
    - name: Checkout code
      uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
    - name: Update the RBE Configs
      run: |
        function map() {

@Suppress("deprecation")
@Timeout(30)
@Tag("Slow")
class MockWebServerTest {
  @RegisterExtension
  var platform = PlatformRule()
  private val server = MockWebServer()

  @BeforeEach
  fun setUp() {
    server.start()
  }

  @AfterEach
  fun tearDown() {
    server.shutdown()
  }

  @Test
  fun defaultMockResponse() {
    val response = MockResponse()

@DisplayName("Smb2QueryDirectoryResponse Tests")
class Smb2QueryDirectoryResponseTest {

    @Mock
    private Configuration mockConfig;

    private Smb2QueryDirectoryResponse response;

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
        when(mockConfig.isUseUnicode()).thenReturn(true);
        when(mockConfig.getMaximumBufferSize()).thenReturn(65536);
    }

    @Test

import jcifs.smb.SID;

/**
 * Test class for SecurityDescriptor
 */
class SecurityDescriptorTest {

    private SecurityDescriptor securityDescriptor;
    private byte[] testBuffer;

    @BeforeEach
    void setUp() {
        securityDescriptor = new SecurityDescriptor();
        testBuffer = new byte[1024];
    }

    @Test
    @DisplayName("Test default constructor creates empty SecurityDescriptor")

            addrEntry[addrIndex] = new NbtAddress(dummyName, 0, false, NbtAddress.B_NODE);
            return 6; // NbtAddress is 6 bytes
        }
    }

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
        packet = new TestNameServicePacket(mockConfig);
        packet.questionName = mockQuestionName;
        packet.recordName = mockRecordName;
    }

    @Test

    assertEquals(68, (int) mmHeap.peek());
    assertEquals(0, (int) mmHeap.peekLast());
  }

  private <T extends Comparable<T>> void runIterator(List<T> values, int steps) throws Exception {
    IteratorTester<T> tester =
        new IteratorTester<T>(
            steps,
            IteratorFeature.MODIFIABLE,
            new LinkedList<>(values),
            IteratorTester.KnownOrder.UNKNOWN_ORDER) {