Commit 9edc44ce authored by Philip Carns's avatar Philip Carns
Browse files

consistent oflags, add fallocate

parent def99ec4
...@@ -21,6 +21,8 @@ ...@@ -21,6 +21,8 @@
#define O_DIRECT 0 #define O_DIRECT 0
#endif #endif
#define OFLAGS (O_WRONLY|O_CREAT|O_DIRECT)
/* This is a simple benchmark that measures the /* This is a simple benchmark that measures the
* streaming, concurrent, sequentially-issued write throughput for a * streaming, concurrent, sequentially-issued write throughput for a
* specified number of concurrent operations. It includes an abt-io version and * specified number of concurrent operations. It includes an abt-io version and
...@@ -175,12 +177,14 @@ static void abt_bench(int buffer_per_thread, unsigned int concurrency, size_t si ...@@ -175,12 +177,14 @@ static void abt_bench(int buffer_per_thread, unsigned int concurrency, size_t si
void *buffer; void *buffer;
double start; double start;
fd = open(filename, O_WRONLY|O_CREAT|O_SYNC|O_DIRECT, S_IWUSR|S_IRUSR); fd = open(filename, OFLAGS, S_IWUSR|S_IRUSR);
if(!fd) if(!fd)
{ {
perror("open"); perror("open");
assert(0); assert(0);
} }
ret = fallocate(fd, 0, 0, 10737418240UL);
assert(ret == 0);
tid_array = malloc(concurrency * sizeof(*tid_array)); tid_array = malloc(concurrency * sizeof(*tid_array));
assert(tid_array); assert(tid_array);
...@@ -292,12 +296,14 @@ static void abt_bench_nb(int buffer_per_thread, unsigned int concurrency, size_t ...@@ -292,12 +296,14 @@ static void abt_bench_nb(int buffer_per_thread, unsigned int concurrency, size_t
abt_io_op_t **ops; abt_io_op_t **ops;
ssize_t *wrets; ssize_t *wrets;
fd = open(filename, O_WRONLY|O_CREAT|O_SYNC, S_IWUSR|S_IRUSR); fd = open(filename, OFLAGS, S_IWUSR|S_IRUSR);
if(!fd) if(!fd)
{ {
perror("open"); perror("open");
assert(0); assert(0);
} }
ret = fallocate(fd, 0, 0, 10737418240UL);
assert(ret == 0);
/* initialize abt_io */ /* initialize abt_io */
/* NOTE: for now we are going to use the same number of execution streams /* NOTE: for now we are going to use the same number of execution streams
...@@ -382,12 +388,14 @@ static void pthread_bench(int buffer_per_thread, unsigned int concurrency, size_ ...@@ -382,12 +388,14 @@ static void pthread_bench(int buffer_per_thread, unsigned int concurrency, size_
void *buffer; void *buffer;
double start; double start;
fd = open(filename, O_WRONLY|O_CREAT|O_SYNC, S_IWUSR|S_IRUSR); fd = open(filename, OFLAGS, S_IWUSR|S_IRUSR);
if(!fd) if(!fd)
{ {
perror("open"); perror("open");
assert(0); assert(0);
} }
ret = fallocate(fd, 0, 0, 10737418240UL);
assert(ret == 0);
id_array = malloc(concurrency * sizeof(*id_array)); id_array = malloc(concurrency * sizeof(*id_array));
assert(id_array); assert(id_array);
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment