Merged.
--Subrata
On Thu, 2008-02-14 at 13:37 +0100, Sebastien Dugue wrote:
> Add latency tracing capability to pthread_kill_latency as is already
> done on a few other latency tests (gtod_latency, sched_latency, ...)
>
> Signed-off-by: Sebastien Dugue <[EMAIL PROTECTED]>
> Cc: Sripathi Kodi <[EMAIL PROTECTED]>
> Cc: Darren Hart <[EMAIL PROTECTED]>
> Cc: Tim Chavez <[EMAIL PROTECTED]>
> ---
> .../pthread_kill_latency/pthread_kill_latency.c | 38
> +++++++++++++++++++-
> 1 files changed, 37 insertions(+), 1 deletions(-)
>
> diff --git
> a/testcases/realtime/func/pthread_kill_latency/pthread_kill_latency.c
> b/testcases/realtime/func/pthread_kill_latency/pthread_kill_latency.c
> index 518bd2f..68e7e4f 100644
> --- a/testcases/realtime/func/pthread_kill_latency/pthread_kill_latency.c
> +++ b/testcases/realtime/func/pthread_kill_latency/pthread_kill_latency.c
> @@ -42,6 +42,8 @@
> * HISTORY
> * 2006-Jun-28: Initial version by Sripathi Kodi <[EMAIL PROTECTED]>
> * 2007-Nov-07: Added libstats support by Darren Hart <[EMAIL PROTECTED]>
> + * 2008-Jan-23: Latency tracing added by
> + * Sebastien Dugue <[EMAIL PROTECTED]>
> *
>
> *****************************************************************************/
>
> @@ -64,6 +66,7 @@
> /* Get the pthread structure corresponding to this thread id */
> #define PTHREADOF(tid) get_thread(tid)->pthread
>
> +static long latency_threshold = 0;
> nsec_t begin, end;
> int fail;
>
> @@ -76,6 +79,7 @@ void usage(void)
> rt_help();
> printf("pthread_kill_latency specific options:\n");
> printf(" -j enable jvmsim\n");
> + printf(" -l threshold trace latency with given threshold in us\n");
> }
>
> int parse_args(int c, char *v)
> @@ -86,6 +90,9 @@ int parse_args(int c, char *v)
> case 'j':
> run_jvmsim = 1;
> break;
> + case 'l':
> + latency_threshold = strtoull(v, NULL, 0);
> + break;
> case 'h':
> usage();
> exit(0);
> @@ -143,6 +150,11 @@ void *signal_receiving_thread(void *arg)
>
> debug(DBG_DEBUG, "Signal receiving thread ready to receive\n");
>
> + if (latency_threshold) {
> + latency_trace_enable();
> + latency_trace_start();
> + }
> +
> /* Warm up */
> for (i = 0; i < 5; i++) {
> sigwait(&set, &sig);
> @@ -152,6 +164,7 @@ void *signal_receiving_thread(void *arg)
> max = min = 0;
> fail = 0;
> debug(DBG_INFO, "\n\n");
> +
> for (i = 0; i < ITERATIONS; i++) {
> sigwait(&set, &sig);
> end = rt_gettime();
> @@ -172,9 +185,28 @@ void *signal_receiving_thread(void *arg)
>
> fflush(stdout);
> buffer_print();
> +
> + if (latency_threshold && (delta > latency_threshold)) {
> + atomic_set(2, &flag);
> + break;
> + }
> +
> atomic_set(1, &flag);
> }
>
> + if (latency_threshold) {
> + latency_trace_stop();
> +
> + if (i != ITERATIONS) {
> + printf("Latency threshold (%luus) exceeded at iteration
> %d\n",
> + latency_threshold, i);
> + fflush(stdout);
> + buffer_print();
> + latency_trace_print();
> + stats_container_resize(&dat, i + 1);
> + }
> + }
> +
> stats_hist(&hist, &dat);
> stats_container_save("samples", "pthread_kill Latency Scatter Plot",
> "Iteration", "Latency (us)", &dat, "points");
> @@ -235,6 +267,10 @@ void *signal_sending_thread(void *arg)
> while (!atomic_get(&flag)) {
> usleep(100);
> }
> +
> + if (atomic_get(&flag) == 2)
> + break;
> +
> atomic_set(0, &flag);
> }
> return NULL;
> @@ -247,7 +283,7 @@ int main(int argc, char *argv[])
> atomic_set(0,&flag);
> setup();
>
> - rt_init("jh", parse_args, argc, argv); /* we need the buffered print
> system */
> + rt_init("jl:h", parse_args, argc, argv); /* we need the buffered
> print system */
>
> printf("-------------------------------\n");
> printf("pthread_kill Latency\n");
-------------------------------------------------------------------------
This SF.net email is sponsored by: Microsoft
Defy all challenges. Microsoft(R) Visual Studio 2008.
http://clk.atdmt.com/MRT/go/vse0120000070mrt/direct/01/
_______________________________________________
Ltp-list mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/ltp-list
