From 8d5bcf7a23044d68348526c2294fd48360ccf989 Mon Sep 17 00:00:00 2001
From: "Julian M. Kunkel" <juliankunkel@googlemail.com>
Date: Tue, 25 May 2021 09:40:50 +0200
Subject: [PATCH] Dummy plugin, add delay for close and sync.

Example usage:
ior -a DUMMY --dummy.delay-create=10000 --dummy.delay-close=100000 --dummy.delay-xfer=20000
---
 src/aiori-DUMMY.c | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/src/aiori-DUMMY.c b/src/aiori-DUMMY.c
index 4769de0..8a4d814 100755
--- a/src/aiori-DUMMY.c
+++ b/src/aiori-DUMMY.c
@@ -19,6 +19,8 @@
 /************************** O P T I O N S *****************************/
 typedef struct {
   uint64_t delay_creates;
+  uint64_t delay_close;
+  uint64_t delay_sync;
   uint64_t delay_xfer;
   int delay_rank_0_only;
 } dummy_options_t;
@@ -37,6 +39,8 @@ static option_help * DUMMY_options(aiori_mod_opt_t ** init_backend_options, aior
 
   option_help h [] = {
       {0, "dummy.delay-create",        "Delay per create in usec", OPTION_OPTIONAL_ARGUMENT, 'l', & o->delay_creates},
+      {0, "dummy.delay-close",         "Delay per close in usec", OPTION_OPTIONAL_ARGUMENT, 'l', & o->delay_close},
+      {0, "dummy.delay-sync",          "Delay for sync in usec", OPTION_OPTIONAL_ARGUMENT, 'l', & o->delay_sync},
       {0, "dummy.delay-xfer",          "Delay per xfer in usec", OPTION_OPTIONAL_ARGUMENT, 'l', & o->delay_xfer},
       {0, "dummy.delay-only-rank0",    "Delay only Rank0", OPTION_FLAG, 'd', & o->delay_rank_0_only},
       LAST_OPTION
@@ -87,6 +91,13 @@ static void DUMMY_Fsync(aiori_fd_t *fd, aiori_mod_opt_t * options)
 
 static void DUMMY_Sync(aiori_mod_opt_t * options)
 {
+  dummy_options_t * o = (dummy_options_t*) options;
+  if (o->delay_sync){
+    if (! o->delay_rank_0_only || (o->delay_rank_0_only && rank == 0)){
+      struct timespec wait = { o->delay_sync / 1000 / 1000, 1000l * (o->delay_sync % 1000000)};
+      nanosleep( & wait, NULL);
+    }
+  }
 }
 
 static void DUMMY_Close(aiori_fd_t *fd, aiori_mod_opt_t * options)
@@ -94,6 +105,14 @@ static void DUMMY_Close(aiori_fd_t *fd, aiori_mod_opt_t * options)
   if(verbose > 4){
     fprintf(out_logfile, "DUMMY close %p\n", fd);
   }
+  
+  dummy_options_t * o = (dummy_options_t*) options;
+  if (o->delay_close){
+    if (! o->delay_rank_0_only || (o->delay_rank_0_only && rank == 0)){
+      struct timespec wait = { o->delay_close / 1000 / 1000, 1000l * (o->delay_close % 1000000)};
+      nanosleep( & wait, NULL);
+    }
+  }
 }
 
 static void DUMMY_Delete(char *testFileName, aiori_mod_opt_t * options)