From 1a4d27c854857a42b97a71e69fe7361880bb5f94 Mon Sep 17 00:00:00 2001 From: Andreas Steffen Date: Mon, 1 Sep 2008 11:19:07 +0000 Subject: added thread_analysis tool --- scripts/thread_analysis.c | 273 ++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 273 insertions(+) create mode 100644 scripts/thread_analysis.c (limited to 'scripts/thread_analysis.c') diff --git a/scripts/thread_analysis.c b/scripts/thread_analysis.c new file mode 100644 index 000000000..a03e8c994 --- /dev/null +++ b/scripts/thread_analysis.c @@ -0,0 +1,273 @@ +/* Analyzes the concurrent use of charon's threads + * + * Copyright (C) 2008 Andreas Steffen + * Hochschule fuer Technik Rapperswil + * + * This program is free software; you can redistribute it and/or modify it + * under the terms of the GNU General Public License as published by the + * Free Software Foundation; either version 2 of the License, or (at your + * option) any later version. See . + * + * This program is distributed in the hope that it will be useful, but + * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY + * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License + * for more details. + */ + +#include +#include +#include + +#define LOGFILE "moon.daemon.log" +#define LINE_LEN 2048 +#define THREADS 99 + +typedef enum state_t state_t; + +enum state_t { + STATE_IDLE = 0, + STATE_INIT = 1, + STATE_AUTH = 2, + STATE_BUSY = 3, + STATE_RETRY = 4, + STATE_ERROR = 5 +}; + +typedef enum mode_t mode_t; + +enum print_t { + MODE_ANY = 0, + MODE_ADD = 1, + MODE_DEL = 2 +}; + +static char *state_names[] = { "idle", "init", "auth", "busy", "retry", "error" }; + +static int readline(FILE *fd, char *line) +{ + while (fread(line, 1, 1, fd)) + { + if (*line == '\n') + { + *line = '\0'; + return 1; + } + line++; + } + *line = '\0'; + return 0; +} + +static void printline(state_t *state, char *timestamp) +{ + int states[] = { 0, 0, 0, 0, 0}; + int th, total ; + + printf(" \n"); + printf(" %.15s", timestamp); + + for (th = 1; th <= THREADS; th++) + { + states[state[th]]++; + printf("", state_names[state[th]]); + } + total = states[STATE_INIT] + states[STATE_AUTH] + states[STATE_BUSY] + states[STATE_RETRY]; + printf("%d%d%d", + states[STATE_INIT], states[STATE_AUTH], total); + for (th = 10; th <= (THREADS + 2); th += 5) + { + printf("", (th <= total + 2)? "busy":"idle"); + } + printf("\n"); + printf(" \n"); +} + +int main(int argc, char *argv[]) +{ + char line[LINE_LEN]; + int section = 0; + int mode = MODE_ANY; + int th; + FILE *fd; + + state_t state[THREADS + 1]; + + /* threads 1..5 and 9 are always busy */ + for (th = 1; th <= THREADS; th++) + { + state[th] = (th <= 5 || th == 9 )? STATE_BUSY : STATE_IDLE; + } + + /* open the log file */ + fd = fopen(LOGFILE, "r"); + if (!fd) + { + printf("could not open log file '%s'\n"); + return 1; + } + + printf("\n"); + printf("\n"); + printf(" Charon Thread Analysis\n"); + printf(" \n"); + printf("\n"); + printf("\n"); + printf("

Charon Thread Analysis

\n"); + printf(" \n"); + + /* print table header */ + printf(" \n"); + printf(" "); + for (th = 1 ; th <= THREADS; th++) + { + printf("", th); + } + printf(""); + for (th = 10; th <= (THREADS + 2); th += 5) + { + printf("", (th == 100)? 99:th); + } + printf("\n"); + printf(" \n"); + + while (readline(fd, line)) + { + char *p_section, *p_charon, *p_thread, *p_log; + + p_section = strstr(line, "---"); + if (p_section) + { + printline(state, line); + mode = MODE_ANY; + + if (section++ < 1) + { + continue; + } + else + { + break; + } + } + + p_charon = strstr(line, "charon"); + if (!p_charon) + { + continue; + } + + /* determine thread */ + p_thread = p_charon + 8; + th = atol(p_thread); + + /* determine log message */ + p_log = p_charon + 16; + if (strstr(p_log, "received packet")) + { + if (mode == MODE_DEL) + { + printline(state, line); + } + mode = MODE_ADD; + if (state[th] != STATE_IDLE) + { + state[th] = STATE_ERROR; + } + else + { + state[th] = STATE_BUSY; + } + } + if (strstr(p_log, "sending packet")) + { + if (mode == MODE_ADD) + { + printline(state, line); + } + mode = MODE_DEL; + if (state[th] == STATE_IDLE) + { + state[th] = STATE_ERROR; + } + else + { + state[th] = STATE_IDLE; + } + } + if (strstr(p_log, "parsed IKE_SA_INIT request")) + { + if (state[th] != STATE_BUSY) + { + state[th] = STATE_ERROR; + } + else + { + state[th] = STATE_INIT; + } + } + if (strstr(p_log, "parsed IKE_AUTH request")) + { + if (state[th] != STATE_BUSY) + { + state[th] = STATE_ERROR; + } + else + { + state[th] = STATE_AUTH; + } + } + if (strstr(p_log, "already processing")) + { + if (state[th] != STATE_IDLE) + { + state[th] = STATE_ERROR; + } + else + { + state[th] = STATE_RETRY; + } + printline(state, line); + mode = MODE_ANY; + state[th] = STATE_IDLE; + } + } + printf("
Timestamp%02dIAB%d
\n"); + printf("

\n"); + printf(" \n"); + printf(" \n"); + printf(" \n"); + printf(" \n"); + printf(" \n"); + printf(" \n"); + printf(" \n"); + printf(" \n"); + printf("
 I IKE_SA_INIT Thread   A IKE_AUTH Thread   R Retransmit Thread   B Busy Thread   E State Error  
\n"); + printf("

\n"); + printf("

\n"); + printf(" © 2008\n"); + printf(" \n"); + printf(" ITA Institute for Internet Technologies and Applications -\n"); + printf(" \n"); + printf(" HSR Hochschule für Technik Rapperswil\n"); + printf(" \n"); + printf("\n"); + printf("\n"); + + fclose(fd); + return 0; +} -- cgit v1.2.3