Tools-2525 throttle async

integration_tests.sh

@@ -19,5 +19,5 @@ else
 	. "${1}"/bin/activate
 fi
 
-pytest src/test/integration
+pytest -sv src/test/integration
 

src/include/benchmark.h

@@ -166,6 +166,9 @@ typedef struct threaddata_s {
 	// which workload stage we're currrently on
 	_Atomic(uint32_t) stage_idx;
 
+	// For async linear workloads
+	_Atomic(uint64_t) current_key;
+
 	/*
 	 * note: to stop threads, tdata->finished must be set before tdata->do_work
 	 * to prevent deadlocking

src/include/common.h

@@ -99,6 +99,11 @@ static inline void timespec_add_us(struct timespec* ts, uint64_t us)
 	ts->tv_nsec = nsec % 1000000000LU;
 }
 
+static inline void timespec_add_s(struct timespec* ts, uint64_t s)
+{
+	ts->tv_sec += s;
+}
+
 
 /*
  * returns the length of the given number were it to be printed in decimal
@@ -186,4 +191,3 @@ char* parse_string_literal(const char* restrict str,
 
 void print_hdr_percentiles(struct hdr_histogram* h, const char* name,
 		uint64_t elapsed_s, as_vector* percentiles, FILE *out_file);
-

src/main/benchmark.c

@@ -322,6 +322,7 @@ init_tdata(const args_t* args, cdata_t* cdata, thr_coord_t* coord,
 	tdata->t_idx = t_idx;
 	// always start on the first stage
 	atomic_init(&tdata->stage_idx, 0);
+	atomic_init(&tdata->current_key, args->start_key);
 
 	atomic_init(&tdata->do_work, true);
 	atomic_init(&tdata->finished, false);

src/main/benchmark_init.c

@@ -544,6 +544,8 @@ print_usage(const char* program)
 
 	printf("-z --threads <count> # Default: 16\n");
 	printf("   Load generating thread count.\n");
+	printf("   This is set to 1 if using --async.\n");
+	printf("   Use --event-loops in async mode.\n");
 	printf("\n");
 
 	printf("-g --throughput <tps> # Default: 0\n");
@@ -745,6 +747,7 @@ print_usage(const char* program)
 
 	printf("-a --async # Default: synchronous mode\n");
 	printf("   Enable asynchronous mode.\n");
+	printf("   Use --event-loops to tune performance in async mode.\n");
 	printf("\n");
 
 	printf("-c --async-max-commands <command count> # Default: 50\n");

src/main/common.c

@@ -456,7 +456,6 @@ void print_hdr_percentiles(struct hdr_histogram* h, const char* name,
 	fprintf(out_file, "\n");
 }
 
-
 //==========================================================
 // Local helpers.
 //