NdrBuffer decodeBuffer = new NdrBuffer(buffer, 0);
        lsarpc.LsarDomainInfo decodedInfo = new lsarpc.LsarDomainInfo();
        decodedInfo.decode(decodeBuffer);

        // Verify nulls are preserved
        assertEquals(0, decodedInfo.name.length);
        assertEquals(0, decodedInfo.name.maximum_length);
        assertNull(decodedInfo.name.buffer);
        assertNull(decodedInfo.sid);
    }

    @Test

  private final OkHttpClient client = new OkHttpClient();

  public void run() throws Exception {
    Request request = new Request.Builder()
        .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay.
        .build();

    final long startNanos = System.nanoTime();
    final Call call = client.newCall(request);

    // Schedule a job to cancel the call in 1 second.

            // Assert
            assertNotNull(unwrapped);
            assertTrue(unwrapped instanceof DosFileFilter);

            // Verify fields preserved (via reflection since they are protected)
            var wildcardField = DosFileFilter.class.getDeclaredField("wildcard");
            wildcardField.setAccessible(true);

        return 0;
    }

    @Override
    protected int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
        // observed two zero bytes here with at least win98
        return 2;
    }

    @Override
    protected int readDataWireFormat(final byte[] buffer, int bufferIndex, final int len) throws SMBProtocolDecodingException {

      }
    }
  }

  companion object {
    val playProviderFactory: DeferredSocketAdapter.Factory =
      factory("com.google.android.gms.org.conscrypt")

    /**
     * Builds a SocketAdapter from an observed implementation class, by grabbing the Class
     * reference to perform reflection on at runtime.
     *
     * @param actualSSLSocketClass the runtime class of Conscrypt class socket.
     */

import okhttp3.Request

class PerCallSettings {
  private val client = OkHttpClient()

  fun run() {
    val request =
      Request
        .Builder()
        .url("http://httpbin.org/delay/1") // This URL is served with a 1 second delay.
        .build()

    // Copy to customize OkHttp for this request.
    val client1 =
      client
        .newBuilder()
        .readTimeout(500, TimeUnit.MILLISECONDS)
        .build()

        // Act
        SMBSignatureValidationException ex = new SMBSignatureValidationException("msg", mocked);

        // Assert
        assertSame(mocked, ex.getCause(), "Mocked cause should be preserved");
        verifyNoInteractions(mocked);
    }

    // Reflection-based check: ensure serialVersionUID remains the declared constant
    @Test
    @DisplayName("serialVersionUID matches declared constant")

        for (String pipeName : pipeNames) {
            TransWaitNamedPipe pipe = new TransWaitNamedPipe(pipeName);
            assertEquals(pipeName, pipe.name, "Pipe name should be preserved: " + pipeName);
            assertEquals(ServerMessageBlock.SMB_COM_TRANSACTION, pipe.command);
            assertEquals(SmbComTransaction.TRANS_WAIT_NAMED_PIPE, pipe.subCommand);
        }
    }

}

// filterObjectsOnly will remove prefix directories.
// Order is preserved, but the underlying slice is modified.
func (m *metaCacheEntriesSorted) filterObjectsOnly() {
	dst := m.o[:0]
	for _, o := range m.o {
		if !o.isDir() {
			dst = append(dst, o)
		}
	}
	m.o = dst
}

// filterPrefixesOnly will remove objects.
// Order is preserved, but the underlying slice is modified.

        // Verify that the cause is correctly set
        assertNotNull(runtimeException);
        assertEquals(servletException, runtimeException.getCause());

        // Verify that the message is preserved from the cause
        assertTrue(runtimeException.getMessage().contains(ServletException.class.getName()));
        assertTrue(runtimeException.getMessage().contains(errorMessage));
    }