aboutsummaryrefslogtreecommitdiffstats
path: root/scripts
diff options
context:
space:
mode:
authorAndreas Steffen <andreas.steffen@strongswan.org>2008-09-01 11:19:07 +0000
committerAndreas Steffen <andreas.steffen@strongswan.org>2008-09-01 11:19:07 +0000
commit1a4d27c854857a42b97a71e69fe7361880bb5f94 (patch)
treec88eff14d2c4688afd12385498fdf055e5eee24c /scripts
parenteb3e27059bd8e27ece7bb039141359d2eb5c0cff (diff)
downloadstrongswan-1a4d27c854857a42b97a71e69fe7361880bb5f94.tar.bz2
strongswan-1a4d27c854857a42b97a71e69fe7361880bb5f94.tar.xz
added thread_analysis tool
Diffstat (limited to 'scripts')
-rw-r--r--scripts/Makefile.am3
-rw-r--r--scripts/thread_analysis.c273
2 files changed, 275 insertions, 1 deletions
diff --git a/scripts/Makefile.am b/scripts/Makefile.am
index baf69ed0a..14e460eab 100644
--- a/scripts/Makefile.am
+++ b/scripts/Makefile.am
@@ -1,12 +1,13 @@
INCLUDES = -I$(top_srcdir)/src/libstrongswan
AM_CFLAGS =-DIPSEC_PLUGINDIR=\"${plugindir}\"
-noinst_PROGRAMS = bin2array bin2sql id2sql key2keyid keyid2sql
+noinst_PROGRAMS = bin2array bin2sql id2sql key2keyid keyid2sql thread_analysis
bin2array_SOURCES = bin2array.c
bin2sql_SOURCES = bin2sql.c
id2sql_SOURCES = id2sql.c
key2keyid_SOURCES = key2keyid.c
keyid2sql_SOURCES = keyid2sql.c
+thread_analysis_SOURCES = thread_analysis.c
id2sql_LDADD = $(top_builddir)/src/libstrongswan/libstrongswan.la
key2keyid_LDADD = $(top_builddir)/src/libstrongswan/libstrongswan.la
keyid2sql_LDADD = $(top_builddir)/src/libstrongswan/libstrongswan.la
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 <http://www.fsf.org/copyleft/gpl.txt>.
+ *
+ * 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 <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+#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(" <tr>\n");
+ printf(" <td class=\"log\">%.15s</td>", timestamp);
+
+ for (th = 1; th <= THREADS; th++)
+ {
+ states[state[th]]++;
+ printf("<td class=\"%s\"></td>", state_names[state[th]]);
+ }
+ total = states[STATE_INIT] + states[STATE_AUTH] + states[STATE_BUSY] + states[STATE_RETRY];
+ printf("<td class=\"init\">%d</td><td class=\"auth\">%d</td><td class=\"busy\">%d</td>",
+ states[STATE_INIT], states[STATE_AUTH], total);
+ for (th = 10; th <= (THREADS + 2); th += 5)
+ {
+ printf("<td class=\"%s\"></td>", (th <= total + 2)? "busy":"idle");
+ }
+ printf("\n");
+ printf(" </tr>\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("<html>\n");
+ printf("<head>\n");
+ printf(" <title>Charon Thread Analysis</title>\n");
+ printf(" <style>\n");
+ printf(" body { font: 11px verdana,arial, helvetica, sans-serif }\n");
+ printf(" td { font: 10px verdana,arial, helvetica, sans-serif;\n");
+ printf(" text-align: center; padding: 0px 1px 0px 1px; background: #FFFF66 }\n");
+ printf(" td.log { text-align: left; background: #FFFF66; white-space: nowrap }\n");
+ printf(" td.idle { background: #FFFF66 }\n");
+ printf(" td.init { background: #FFA522 }\n");
+ printf(" td.auth { background: #90EE90 }\n");
+ printf(" td.busy { background: #ADD8E6 }\n");
+ printf(" td.retry { background: #7B68EE }\n");
+ printf(" td.error { background: #FF6347 }\n");
+ printf(" hr { background-color: #000000; border: 0; height: 1px; }\n");
+ printf(" a:visited { color: #000000 }\n");
+ printf(" a:link { color: #000000 }\n");
+ printf(" a:hover { color: #0000FF }\n");
+ printf(" </style>\n");
+ printf("</head>\n");
+ printf("<body>\n");
+ printf(" <h1>Charon Thread Analysis</h1>\n");
+ printf(" <table>\n");
+
+ /* print table header */
+ printf(" <tr>\n");
+ printf(" <td class=\"log\">Timestamp</td>");
+ for (th = 1 ; th <= THREADS; th++)
+ {
+ printf("<td>%02d</td>", th);
+ }
+ printf("<td class=\"init\">I</td><td class=\"auth\">A</td><td class=\"busy\">B</td>");
+ for (th = 10; th <= (THREADS + 2); th += 5)
+ {
+ printf("<td class=\"busy\">%d</td>", (th == 100)? 99:th);
+ }
+ printf("\n");
+ printf(" </tr>\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(" </table>\n");
+ printf(" <p>\n");
+ printf(" <table>\n");
+ printf(" <tr>\n");
+ printf(" <td class=\"init\">&nbsp;I&nbsp;</td><td>IKE_SA_INIT Thread &nbsp;</td>\n");
+ printf(" <td class=\"auth\">&nbsp;A&nbsp;</td><td>IKE_AUTH Thread &nbsp;</td>\n");
+ printf(" <td class=\"retry\">&nbsp;R&nbsp;</td><td>Retransmit Thread &nbsp;</td>\n");
+ printf(" <td class=\"busy\">&nbsp;B&nbsp;</td><td>Busy Thread &nbsp;</td>\n");
+ printf(" <td class=\"error\">&nbsp;E&nbsp;</td><td>State Error &nbsp;</td>\n");
+ printf(" </tr>\n");
+ printf(" </table>\n");
+ printf(" <p>\n");
+ printf(" <hr/>\n");
+ printf(" <em>&copy; 2008\n");
+ printf(" <a href=\"http://ita.hsr.ch?&L=1\" target=\"popup\">\n");
+ printf(" ITA Institute for Internet Technologies and Applications</a> -\n");
+ printf(" <a href=\"http://www.hsr.ch/?&L=1\" target=\"popup\">\n");
+ printf(" HSR Hochschule f&uuml;r Technik Rapperswil</a>\n");
+ printf(" </em>\n");
+ printf("</body>\n");
+ printf("</html>\n");
+
+ fclose(fd);
+ return 0;
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-09-30 02:17:11 +0000