今後のファイルのクロニクル 'ファイルが見つかりません'

Question

クロニクルキューv4.5.15を使用しています。私は私にキュー内にある要素の数を伝えるための方法を作成しました：

public long getQueueSize() { 
    long index = getQueueIndex(); // I store the index in a persistent map so this method simply retrieves the current index from the map. 

    ExcerptTailer tailer = queue.createTailer(); 

    long lastIndex = tailer.toEnd().index(); // Get the last index in our queue. 
    long count = queue.countExcerpts(queueIndex, lastIndex); 

    return count 

} 

私は一晩テストを実行し、私のコンポーネントは、12月22日のために書かれcq4キューファイルを持っていました。それは毎日のサイクルです。今日キューにいくつかの要素を追加しようとしましたが、例外がスローされました'IllegalStateException: 'file not found' for the upperCycle, file ../path_to_queue/20161314.cq4。

スタックトレース：

Caused by java.lang.IllegalStateException: java.lang.IllegalStateException: 'file not found' for the upperCycle, file=/var/tmp/app/20161224.cq4 
at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.countExcertps(SingleChronicleQueue.java:359(
at ... 

12月23日の今日、なぜクロニクルは将来のファイルを探していると見て？

私は最後のインデックスを取得する方法と関係がありますか？

おかげで

Answer 1

多分それはすべての日カウンタ変数についてですあなたには、いくつかの要素のコードを追加したときに、私は一日のサイクルのためにそれをカウントした後、1日ごとに変更することができますを意味します。何度も要素を追加しようとしましたか？もし何が起こったのですか？

Answer 2

最後のバージョンで再テストできますか？以下のテストケースを追加しました。

は、以下を参照してください。RollingChronicleQueueTest

@Test 
public void testCountExcerptsWhenTheCycleIsRolled() throws Exception { 

    final AtomicLong time = new AtomicLong(); 

    final SingleChronicleQueue q = binary(getTmpDir()) 
      .timeProvider(time::get) 
      .rollCycle(TEST_SECONDLY) 
      .build(); 

    final ExcerptAppender appender = q.acquireAppender(); 
    time.set(0); 

    appender.writeText("1. some text"); 
    long start = appender.lastIndexAppended(); 
    appender.writeText("2. some more text"); 
    time.set(1000); 
    appender.writeText("3. some text - first cycle"); 
    time.set(2000); 
    time.set(3000); // large gap to miss a cycle file 
    time.set(4000); 
    appender.writeText("4. some text - second cycle"); 
    appender.writeText("some more text"); 
    long end = appender.lastIndexAppended(); 

    Assert.assertEquals(4, q.countExcerpts(start, end)); 
}