vitalif
/
mdtest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge pull request #326 from hpc/fix-mdworkbench-check 

MDWorkbench: Fix new verification option
master
Julian Kunkel 2021-02-05 11:14:26 +00:00 committed by GitHub
parent 3f465c61ff 265cdb2a42
commit e5e1053405
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/md-workbench.c
View File

@ -582,7 +582,7 @@ void run_precreate(phase_stat_t * s, int current_index){
add_timed_result(op_timer, s->phase_start_timer, s->time_create, pos, & s->max_op_time, & op_time);
if (o.verbosity >= 2){
oprintf("%d: write %s:%s (%d)\n", o.rank, dset, obj_name, ret);
oprintf("%d: write %s:%s (%d) pretend: %d\n", o.rank, dset, obj_name, ret, o.rank);
}
}
}
@ -639,7 +639,7 @@ void run_benchmark(phase_stat_t * s, int * current_index_p){
s->obj_stat.suc++;
if (o.verbosity >= 2){
oprintf("%d: read %s \n", o.rank, obj_name);
oprintf("%d: read %s pretend: %d\n", o.rank, obj_name, readRank);
}
op_timer = GetTimeStamp();
@ -649,7 +649,7 @@ void run_benchmark(phase_stat_t * s, int * current_index_p){
}
if ( o.file_size == (int) o.backend->xfer(READ, aiori_fh, (IOR_size_t *) buf, o.file_size, 0, o.backend_options) ) {
if(o.verify_read){
if(verify_memory_pattern(f * o.dset_count + d, buf, o.file_size, o.random_buffer_offset, readRank) == 0){
if(verify_memory_pattern(prevFile * o.dset_count + d, buf, o.file_size, o.random_buffer_offset, readRank) == 0){
s->obj_read.suc++;
}else{
s->obj_read.err++;
@ -684,11 +684,15 @@ void run_benchmark(phase_stat_t * s, int * current_index_p){
s->obj_delete.suc++;
int writeRank = (o.rank + o.offset * (d+1)) % o.size;
def_obj_name(obj_name, writeRank, d, o.precreate + prevFile);
const int newFileIndex = o.precreate + prevFile;
def_obj_name(obj_name, writeRank, d, newFileIndex);
op_timer = GetTimeStamp();
aiori_fh = o.backend->create(obj_name, IOR_WRONLY | IOR_CREAT, o.backend_options);
if (NULL != aiori_fh){
generate_memory_pattern(buf, o.file_size, o.random_buffer_offset, writeRank);
update_write_memory_pattern(newFileIndex * o.dset_count + d, buf, o.file_size, o.random_buffer_offset, writeRank);
if ( o.file_size == (int) o.backend->xfer(WRITE, aiori_fh, (IOR_size_t *) buf, o.file_size, 0, o.backend_options)) {
s->obj_create.suc++;
}else{
@ -711,7 +715,7 @@ void run_benchmark(phase_stat_t * s, int * current_index_p){
}
if (o.verbosity >= 2){
oprintf("%d: write %s (%d)\n", o.rank, obj_name, ret);
oprintf("%d: write %s (%d) pretend: %d\n", o.rank, obj_name, ret, writeRank);
}
} // end loop