Lines Matching refs:RWR
47 final private static int RWR = 3; field in TestWriteToReplica
172 blocks[RWR].getLocalBlock(), vol, vol.createRbwFile(bpid, in setup()
173 blocks[RWR].getLocalBlock()).getParentFile())); in setup()
190 Assert.fail("Should not have space to append to an RWR replica" + blocks[RWR]); in testAppend()
223 dataSet.append(blocks[RWR], blocks[RWR].getGenerationStamp()+1, in testAppend()
225 Assert.fail("Should not have appended to an RWR replica" + blocks[RWR]); in testAppend()
228 blocks[RWR], e.getMessage()); in testAppend()
271 dataSet.recoverAppend(blocks[RWR], blocks[RWR].getGenerationStamp()+1, in testAppend()
273 Assert.fail("Should not have appended to an RWR replica" + blocks[RWR]); in testAppend()
321 dataSet.recoverClose(blocks[RWR], blocks[RWR].getGenerationStamp()+1, in testClose()
323 Assert.fail("Should not have recovered close an RWR replica" + blocks[RWR]); in testClose()
398 dataSet.recoverRbw(blocks[RWR], blocks[RWR].getGenerationStamp()+1, in testWriteToRbw()
399 0L, blocks[RWR].getNumBytes()); in testWriteToRbw()
400 Assert.fail("Should not have recovered a RWR replica " + blocks[RWR]); in testWriteToRbw()
407 dataSet.createRbw(StorageType.DEFAULT, blocks[RWR], false); in testWriteToRbw()
409 "recovered " + blocks[RWR]); in testWriteToRbw()
466 dataSet.createTemporary(StorageType.DEFAULT, blocks[RWR]); in testWriteToTemporary()
468 "recovered " + blocks[RWR]); in testWriteToTemporary()