greg/stasis-aries-wal
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

check ring buffer error handling, deallocation

Browse source
This commit is contained in:
Sears Russell 2008-10-04 01:39:23 +00:00
parent c8d368f4b1
commit 35216c4ee4
1 changed files with 15 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
test/stasis/check_ringbuffer.c
View file

@ -89,6 +89,9 @@ static int rb_test(double readBlock, double writeBlock) {
for(i = 0; i < numToWrite; i++) {
if(!ringBufferAppend(log, array[writePos], length[writePos])) {
// printf("W"); fflush(stdout);
if(writePos == 0) {
assert((-2 == ringBufferAppend(log, array[writePos], 1+NUM_ENTRIES - length[writePos])));
}
writePos++;
if(writePos == NUM_ENTRIES) { break; }
} else {
@ -96,6 +99,17 @@ static int rb_test(double readBlock, double writeBlock) {
}
}
}
// try to truncate a chunk longer than the whole ringbuffer.
// should be a no-op
// note: passing 0 for buffer argument is illegal
assert(-1 == ringBufferTruncateRead(0, log, NUM_ENTRIES * 10));
// try to append more than the ring buffer can hold
// should also be a no-op.
assert(-1 == ringBufferAppend(log, 0, NUM_ENTRIES * 10));
int numToRead = 1.0 + readBlock * ((double)rand() / (double)RAND_MAX);
// printf("%d\n", numToRead);
for(i = 0; i < numToRead; i++) {
@ -121,6 +135,7 @@ static int rb_test(double readBlock, double writeBlock) {
doneWriting = 1;
}
}
closeLogRingBuffer(log);
return 0;
}