net.openhft.chronicle.core.Jvm.isArm()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(3.5k)|赞(0)|评价(0)|浏览(100)

本文整理了Java中net.openhft.chronicle.core.Jvm.isArm()方法的一些代码示例,展示了Jvm.isArm()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Jvm.isArm()方法的具体详情如下:
包路径:net.openhft.chronicle.core.Jvm
类名称:Jvm
方法名:isArm

Jvm.isArm介绍

暂无

代码示例

代码示例来源:origin: OpenHFT/Chronicle-Queue

if (Jvm.isArm())
  return "--- !!meta-data #binary\n" +
      "header: !SCQStore {\n" +

代码示例来源:origin: OpenHFT/Chronicle-Queue

appender.writeText("some more text");
long end = appender.lastIndexAppended();
String expectedEager = Jvm.isArm()
    ? "--- !!meta-data #binary\n" +
    "header: !SCQStore {\n" +

代码示例来源:origin: OpenHFT/Chronicle-Queue

@Test
public void testSimpleByteTest() {
  assumeFalse(Jvm.isArm());
  try (final ChronicleQueue chronicle = builder(getTmpDir(), wireType)
      .rollCycle(TEST2_DAILY)
      .build()) {
    final ExcerptAppender appender = chronicle.acquireAppender();
    Bytes steve = Bytes.allocateDirect("Steve".getBytes());
    appender.writeBytes(steve);
    Bytes jobs = Bytes.allocateDirect("Jobs".getBytes());
    appender.writeBytes(jobs);
    final ExcerptTailer tailer = chronicle.createTailer();
    Bytes bytes = Bytes.elasticByteBuffer();
    try {
      tailer.readBytes(bytes);
      Assert.assertEquals("Steve", bytes.toString());
      bytes.clear();
      tailer.readBytes(bytes);
      Assert.assertEquals("Jobs", bytes.toString());
    } finally {
      steve.release();
      jobs.release();
      bytes.release();
    }
  }
}

代码示例来源:origin: OpenHFT/Chronicle-Queue

@Test
public void testWritingIndex() {
  assumeFalse(Jvm.isArm());
  @NotNull File dir = getTmpDir();
  try (@NotNull ChronicleQueue queue = SingleChronicleQueueBuilder.single(dir)
        "msg-1\n" +
        "...\n" +
        (Jvm.isArm()
            ? "# 130672 bytes remaining\n"
            : "# 130674 bytes remaining\n");

代码示例来源:origin: OpenHFT/Chronicle-Queue

@Test
public void writeBytesAndIndexFiveTimesWithOverwriteTest() {
  assumeFalse(Jvm.isArm());
  try (final ChronicleQueue sourceQueue =
         builder(DirectoryUtils.tempDir("to-be-deleted"), wireType).

代码示例来源:origin: OpenHFT/Chronicle-Queue

@Test
public void shouldRollAndAppendToNewFile() throws Exception {
  assumeFalse(Jvm.isArm());

代码示例来源:origin: OpenHFT/Chronicle-Queue

@Test//(timeout = 5000)
public void testTailerReadingEmptyQueue() {
  assumeFalse(Jvm.isArm());
  final File path = DirectoryUtils.tempDir("testTailerReadingEmptyQueue");
  final ChronicleQueue rqueue = SingleChronicleQueueBuilder.fieldlessBinary(path)
      .testBlockSize()
      .rollCycle(TEST_DAILY)
      .build();
  final ExcerptTailer tailer = rqueue.createTailer();
  final ChronicleQueue wqueue = SingleChronicleQueueBuilder.fieldlessBinary(path)
      .testBlockSize()
      .rollCycle(TEST_DAILY)
      .build();
  Bytes bytes = Bytes.elasticByteBuffer();
  assertFalse(tailer.readBytes(bytes));
  final ExcerptAppender appender = wqueue.acquireAppender();
  appender.writeBytes(Bytes.wrapForRead("Hello World".getBytes(ISO_8859_1)));
  bytes.clear();
  assertTrue(tailer.readBytes(bytes));
  assertEquals("Hello World", bytes.toString());
  bytes.release();
}

代码示例来源:origin: OpenHFT/Chronicle-Queue

@Test
public void testWritingTwentyMessagesTinyIndex() throws FileNotFoundException {
  assumeFalse(Jvm.isArm());
  for (int spacing : new int[]{1, 2, 4}) {
    @NotNull File dir = getTmpDir();

代码示例来源:origin: OpenHFT/Chronicle-Queue

@Test
public void writeBytesAndIndexFiveTimesTest() {
  assumeFalse(Jvm.isArm());
  try (final ChronicleQueue sourceQueue =
         builder(DirectoryUtils.tempDir("to-be-deleted"), wireType).

代码示例来源:origin: OpenHFT/Chronicle-Queue

"some: data\n" +
"...\n" +
(Jvm.isArm()
    ? "# 327276 bytes remaining\n"
    : "# 327278 bytes remaining\n");

代码示例来源:origin: net.openhft/chronicle-map

" given");
if (Jvm.isArm() && alignment < 8)
  return this;
this.alignment = alignment;

相关文章