summaryrefslogtreecommitdiffstats
path: root/lf_ringbuffer_test.c
diff options
context:
space:
mode:
authorJérémy Zurcher <jeremy@asynk.ch>2010-01-12 12:58:49 +0100
committerJérémy Zurcher <jeremy@asynk.ch>2010-01-12 12:58:49 +0100
commit1b393afeafa57a1a9baf72834b4f75388361931e (patch)
tree9ddf7cec7c650ca7fe9428ba38604961a61d279d /lf_ringbuffer_test.c
parented364de0e13fcb70d890ffa3763e7c7ec5a5797b (diff)
downloadlock_free-1b393afeafa57a1a9baf72834b4f75388361931e.zip
lock_free-1b393afeafa57a1a9baf72834b4f75388361931e.tar.gz
rename struct ring_buffer into ringbuffer
Diffstat (limited to 'lf_ringbuffer_test.c')
-rw-r--r--lf_ringbuffer_test.c34
1 files changed, 17 insertions, 17 deletions
diff --git a/lf_ringbuffer_test.c b/lf_ringbuffer_test.c
index 8c41b97..eca1cca 100644
--- a/lf_ringbuffer_test.c
+++ b/lf_ringbuffer_test.c
@@ -27,7 +27,7 @@ static void report( char* op, int n, uint64_t dt, int redo ) {
}
struct thread_params {
- lf_ring_buffer_t *ring;
+ lf_ringbuffer_t *ring;
int n;
int flags;
uint64_t dt;
@@ -42,16 +42,16 @@ static void feed_data( int n){
}
*/
-static uint64_t sequential_writes( lf_ring_buffer_t *ring, int n, int flags ) {
+static uint64_t sequential_writes( lf_ringbuffer_t *ring, int n, int flags ) {
int i, redo=0;
rb_data_t data[RB_DATA_LEN];
struct timespec start, end;
clock_gettime(CLOCK_MONOTONIC, &start);
if(flags==0) {
- for(i=0; i<n; i++) lf_ring_buffer_write( ring, data, flags );
+ for(i=0; i<n; i++) lf_ringbuffer_write( ring, data, flags );
} else {
for(i=0; i<n;) {
- if(lf_ring_buffer_write( ring, data, flags )==0) { i++; } else { redo+=1; }
+ if(lf_ringbuffer_write( ring, data, flags )==0) { i++; } else { redo+=1; }
}
}
clock_gettime(CLOCK_MONOTONIC, &end);
@@ -59,16 +59,16 @@ static uint64_t sequential_writes( lf_ring_buffer_t *ring, int n, int flags ) {
return time_diff( &start, &end );
}
-static uint64_t sequential_reads( lf_ring_buffer_t *ring, int n, int flags ) {
+static uint64_t sequential_reads( lf_ringbuffer_t *ring, int n, int flags ) {
int i,redo=0;
rb_data_t data[RB_DATA_LEN];
struct timespec start, end;
clock_gettime(CLOCK_MONOTONIC, &start);
if(flags==0) {
- for(i=0; i<n; i++) lf_ring_buffer_read( ring, data, flags );
+ for(i=0; i<n; i++) lf_ringbuffer_read( ring, data, flags );
} else {
for(i=0; i<n;) {
- if(lf_ring_buffer_read( ring, data, flags )==0) { i++; } else { redo+=1; }
+ if(lf_ringbuffer_read( ring, data, flags )==0) { i++; } else { redo+=1; }
}
}
clock_gettime(CLOCK_MONOTONIC, &end);
@@ -90,7 +90,7 @@ void* reader_thread( void* param ) {
return NULL;
}
-static void parallel_op( int op, int nt, lf_ring_buffer_t *ring, int n, int flags ) {
+static void parallel_op( int op, int nt, lf_ringbuffer_t *ring, int n, int flags ) {
int i;
uint64_t dt;
@@ -139,11 +139,11 @@ int main( int argc, char** argv ) {
int i;
int b_len = BUFFER_LEN;
- lf_ring_buffer_t *ring;
+ lf_ringbuffer_t *ring;
- ring = lf_ring_buffer_create( b_len );
+ ring = lf_ringbuffer_create( b_len );
if(ring==NULL){
- fprintf(stderr,"ERROR : lf_ring_buffer_create( %d );\n",b_len);
+ fprintf(stderr,"ERROR : lf_ringbuffer_create( %d );\n",b_len);
exit( EXIT_FAILURE );
}
@@ -157,34 +157,34 @@ int main( int argc, char** argv ) {
sequential_writes( ring, b_len, 0 );
printf("sequential non blocking read operations ...\n");
sequential_reads( ring, b_len, 0 );
- if(!lf_ring_buffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
+ if(!lf_ringbuffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
printf("sequential blocking write operations ...\n");
sequential_writes( ring, b_len, LFRB_NO_BLOCK );
printf("sequential blocking read operations ...\n");
sequential_reads( ring, b_len, LFRB_NO_BLOCK );
- if(!lf_ring_buffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
+ if(!lf_ringbuffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
for(i=5; i<=50;i*=2) {
printf("%d parallel blocking with backoff inc write operations .... \n",i);
parallel_op( 0, i, ring, b_len, 0 );
printf("parallel blocking read operations ...\n");
sequential_reads( ring, b_len, 0 );
- if(!lf_ring_buffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
+ if(!lf_ringbuffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
}
for(i=5; i<=50;i*=2) {
printf("%d parallel non blocking write operations .... \n",i);
parallel_op( 0, i, ring, b_len, LFRB_NO_BLOCK );
printf("non blocking read operations ...\n");
sequential_reads( ring, b_len, LFRB_NO_BLOCK );
- if(!lf_ring_buffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
+ if(!lf_ringbuffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
}
for(i=10; i<=50;i*=2) {
printf("%d parallel blocking write and read operations .... \n",i*2);
parallel_op( 3, i, ring, b_len, 0 );
- if(!lf_ring_buffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
+ if(!lf_ringbuffer_empty(ring)) { fprintf(stderr,"ring should be empty but is not\n"); exit( EXIT_FAILURE ); }
}
- lf_ring_buffer_destroy( ring );
+ lf_ringbuffer_destroy( ring );
return EXIT_SUCCESS;
}