summaryrefslogtreecommitdiff
path: root/src/exchange/taler-exchange-httpd.c
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2018-10-02 17:21:12 +0200
committerFlorian Dold <florian.dold@gmail.com>2018-10-02 17:21:12 +0200
commit97afbe6364867a6585fe6af701b7bcd097782002 (patch)
treee72c669f1e326241e1a3475392156ebd5726db20 /src/exchange/taler-exchange-httpd.c
parente9c9ca736f6a9cd63695f6e425ad801658081991 (diff)
downloadexchange-97afbe6364867a6585fe6af701b7bcd097782002.tar.gz
exchange-97afbe6364867a6585fe6af701b7bcd097782002.tar.bz2
exchange-97afbe6364867a6585fe6af701b7bcd097782002.zip
write exchange stats on exit
Diffstat (limited to 'src/exchange/taler-exchange-httpd.c')
-rw-r--r--src/exchange/taler-exchange-httpd.c49
1 files changed, 49 insertions, 0 deletions
diff --git a/src/exchange/taler-exchange-httpd.c b/src/exchange/taler-exchange-httpd.c
index cd6d7793f..5fc491a5d 100644
--- a/src/exchange/taler-exchange-httpd.c
+++ b/src/exchange/taler-exchange-httpd.c
@@ -26,6 +26,7 @@
#include <jansson.h>
#include <microhttpd.h>
#include <pthread.h>
+#include <sys/resource.h>
#include "taler-exchange-httpd_parsing.h"
#include "taler-exchange-httpd_mhd.h"
#include "taler-exchange-httpd_deposit.h"
@@ -845,6 +846,52 @@ open_unix_path (const char *unix_path,
/**
+ * Called when the main thread exits, writes out performance
+ * stats if requested.
+ */
+static void
+write_stats ()
+{
+
+ struct GNUNET_DISK_FileHandle *fh;
+ pid_t pid = getpid ();
+ char *benchmark_dir;
+ char *s;
+ struct rusage usage;
+
+ benchmark_dir = getenv ("GNUNET_BENCHMARK_DIR");
+
+ if (NULL == benchmark_dir)
+ return;
+
+ GNUNET_asprintf (&s, "%s/taler-exchange-%llu-%llu.txt",
+ benchmark_dir,
+ (unsigned long long) pid);
+
+ fh = GNUNET_DISK_file_open (s,
+ (GNUNET_DISK_OPEN_WRITE |
+ GNUNET_DISK_OPEN_TRUNCATE |
+ GNUNET_DISK_OPEN_CREATE),
+ (GNUNET_DISK_PERM_USER_READ |
+ GNUNET_DISK_PERM_USER_WRITE));
+ GNUNET_assert (NULL != fh);
+ GNUNET_free (s);
+
+ /* Collect stats, summed up for all threads */
+ GNUNET_assert (0 == getrusage(RUSAGE_SELF, &usage));
+
+ GNUNET_asprintf (&s, "time_exchange sys %llu user %llu\n", \
+ (unsigned long long) (usage.ru_stime.tv_sec * 1000 * 1000 + usage.ru_stime.tv_usec),
+ (unsigned long long) (usage.ru_utime.tv_sec * 1000 * 1000 + usage.ru_utime.tv_usec));
+ GNUNET_assert (GNUNET_SYSERR != GNUNET_DISK_file_write_blocking (fh, s, strlen (s)));
+ GNUNET_free (s);
+
+ GNUNET_assert (GNUNET_OK == GNUNET_DISK_file_close (fh));
+}
+
+
+
+/**
* The main function of the taler-exchange-httpd server ("the exchange").
*
* @param argc number of arguments from the command line
@@ -982,6 +1029,8 @@ main (int argc,
return 1;
}
+ atexit (write_stats);
+
#if HAVE_DEVELOPER
if (NULL != input_filename)
{