Add burst_function

Author: bengsig

man/man2rwl/oltpsetup.2rwl

@@ -440,13 +440,31 @@ To include a burst with higher arrival rate, include these parameters:
 \fBburst_length\fR
 \fBburst_factor\fR
 \fBburst_repeat\fR
+\fBburst_function\fR
 .fi
 .RS 4
 The two first parameters set the time to start and length of the burst, and
 the third parameter is the factor that is applied to the arrival rate during the burst.
 If burst_repeat is set to a value larger than the sum of burst_start and burst_length, 
 the burst will be repeated very burst_repeat seconds.
 By default, the burst is not repeated.
+.P
+You can additionally declare a function named \fBburst_function\fR with the following 
+shape:
+.P
+.nf
+function burst_function(double runsec)
+return double
+is
+  # your code here
+  return 1.0;
+end burst_function;
+.fi
+.P
+If the function is declared, it will be given runseconds() as its argument and it should
+return a factor that will be used as a multiplier to the ratefactor otherwise in use.
+The sample code shown here will have no impact as it always returns the value 1.0.
+Note that this is an experimental feature and that it may be changed in a later release.
 .RE
 .P
 To include a burst with extra worker threads, include these parameters:

oltp/parameters.rwl

@@ -505,10 +505,15 @@ if show_changed_values then
     else
       printf "arrival rate burst factor %.2f (to %.0f tps) from %.0fs until %.0fs\n"
       , burst_factor, xeqpsec * burst_factor, burst_start, burst_start+burst_length;
+      if burst_repeat > 0.0 and burst_repeat <= burst_start + burst_length then
+	printf "burst_repeat (%.0f) must be larger than %.0f to have effect\n"
+	, burst_repeat, burst_start + burst_length;
+      end if;
     end if;
   else
     printline "no arrival rate burst";
   end if;
+  $if defined(burst_function) $then printline "Arrival rate bursts are defined by burst_function"; $endif
   if wburst_count > 0 then
     printf "%d extra workers (total %.0f tps), from %.0fs until %.0fs (possibly different period in different processes)\n"
     , wburst_count,  xeqpsec *(1.0+1.0*wburst_count/threadcount), wburst_start, wburst_start + wburst_length;

oltp/run.rwl

@@ -283,6 +283,9 @@ $if !simulatebatch $then
 	       $if rategradient is not null $then
 		 * (1.0+rategradient*(runseconds()-halfperiod)/halfperiod)
 	       $endif
+	       $if defined(burst_function) $then
+	         * burst_function(runseconds())
+	       $endif
 	    )
 	)
 	$else
@@ -310,6 +313,9 @@ $if !simulatebatch $then
 	       $if rategradient is not null $then
 		 * (1.0+rategradient*(runseconds()-halfperiod)/halfperiod)
 	       $endif
+	       $if defined(burst_function) $then
+	         * burst_function(runseconds())
+	       $endif
 	    )
 	)
 	# If before the time AND we are an inactive thread