[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] [taler-exchange] branch master updated (a57cf67 -> 1eb739c)
|
From: |
gnunet |
|
Subject: |
[GNUnet-SVN] [taler-exchange] branch master updated (a57cf67 -> 1eb739c) |
|
Date: |
Sun, 11 Jun 2017 11:57:48 +0200 |
This is an automated email from the git hooks/post-receive script.
grothoff pushed a change to branch master
in repository exchange.
from a57cf67 a bit more work on #5010
new 110d0cc start test case for #4956
new 30f1d7b add new test to ignore files
new 0ef7116 do not show -v option twice in -h
new 1eb739c add --test option to taler-exchange-wirewatch
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
doc/taler-exchange-wirewatch.1 | 3 +
src/exchange/.gitignore | 1 +
src/exchange/Makefile.am | 18 +-
src/exchange/taler-exchange-aggregator.c | 8 +
src/exchange/taler-exchange-wirewatch.c | 17 +-
...=> test-taler-exchange-wirewatch-postgres.conf} | 4 +-
src/exchange/test_taler_exchange_wirewatch.c | 716 +++++++++++++++++++++
7 files changed, 764 insertions(+), 3 deletions(-)
copy src/exchange/{test-taler-exchange-aggregator-postgres.conf =>
test-taler-exchange-wirewatch-postgres.conf} (94%)
create mode 100644 src/exchange/test_taler_exchange_wirewatch.c
diff --git a/doc/taler-exchange-wirewatch.1 b/doc/taler-exchange-wirewatch.1
index 72006e6..41a4afa 100644
--- a/doc/taler-exchange-wirewatch.1
+++ b/doc/taler-exchange-wirewatch.1
@@ -19,6 +19,9 @@ Use the specified wire plugin and its configuration to talk
to the bank.
.IP "\-h, \-\-help"
Print short help on options.
.B
+.IP "\-T, \-\-test"
+Run in test mode and exit when idle.
+.B
.IP "\-v, \-\-version"
Print version information.
.B
diff --git a/src/exchange/.gitignore b/src/exchange/.gitignore
index 6ea90e7..e54fe49 100644
--- a/src/exchange/.gitignore
+++ b/src/exchange/.gitignore
@@ -5,3 +5,4 @@ taler-exchange-pursemod
taler-exchange-reservemod
taler-exchange-httpd
taler-exchange-wirewatch
+test_taler_exchange_wirewatch-postgres
diff --git a/src/exchange/Makefile.am b/src/exchange/Makefile.am
index 899f396..92a8556 100644
--- a/src/exchange/Makefile.am
+++ b/src/exchange/Makefile.am
@@ -97,8 +97,23 @@ test_taler_exchange_aggregator_postgres_LDADD = \
-ljansson \
-lpthread
+test_taler_exchange_wirewatch_postgres_SOURCES = \
+ test_taler_exchange_wirewatch.c
+test_taler_exchange_wirewatch_postgres_LDADD = \
+ $(LIBGCRYPT_LIBS) \
+ $(top_builddir)/src/exchangedb/libtalerexchangedb.la \
+ $(top_builddir)/src/bank-lib/libtalerfakebank.la \
+ $(top_builddir)/src/json/libtalerjson.la \
+ $(top_builddir)/src/util/libtalerutil.la \
+ -lmicrohttpd \
+ -lgnunetutil \
+ -lgnunetjson \
+ -ljansson \
+ -lpthread
+
check_PROGRAMS = \
- test_taler_exchange_aggregator-postgres
+ test_taler_exchange_aggregator-postgres \
+ test_taler_exchange_wirewatch-postgres
AM_TESTS_ENVIRONMENT=export
TALER_PREFIX=$${TALER_PREFIX:address@hidden@};export
PATH=$${TALER_PREFIX:address@hidden@}/bin:$$PATH;
@@ -109,6 +124,7 @@ TESTS = \
EXTRA_DIST = \
test-taler-exchange-aggregator-postgres.conf \
+ test-taler-exchange-wirewatch-postgres.conf \
test_taler_exchange_httpd_home/.local/share/taler/exchange/offline-keys/master.priv
\
test_taler_exchange_httpd.conf \
exchange.conf \
diff --git a/src/exchange/taler-exchange-aggregator.c
b/src/exchange/taler-exchange-aggregator.c
index d658398..b371135 100644
--- a/src/exchange/taler-exchange-aggregator.c
+++ b/src/exchange/taler-exchange-aggregator.c
@@ -516,6 +516,14 @@ exchange_serve_process_config ()
"Failed to initialize DB subsystem\n");
return GNUNET_SYSERR;
}
+ if (GNUNET_OK !=
+ db_plugin->create_tables (db_plugin->cls))
+ {
+ fprintf (stderr,
+ "Failed to initialize DB tables\n");
+ TALER_EXCHANGEDB_plugin_unload (db_plugin);
+ return GNUNET_SYSERR;
+ }
return GNUNET_OK;
}
diff --git a/src/exchange/taler-exchange-wirewatch.c
b/src/exchange/taler-exchange-wirewatch.c
index aee3083..0a7923a 100644
--- a/src/exchange/taler-exchange-wirewatch.c
+++ b/src/exchange/taler-exchange-wirewatch.c
@@ -95,6 +95,11 @@ static char *type;
static int delay;
/**
+ * Are we run in testing mode and should only do one pass?
+ */
+static int test_mode;
+
+/**
* Next task to run, if any.
*/
static struct GNUNET_SCHEDULER_Task *task;
@@ -234,6 +239,12 @@ history_cb (void *cls,
start_off = last_row_off;
start_off_size = last_row_off_size;
}
+ if ( (GNUNET_YES == delay) &&
+ (test_mode) )
+ {
+ GNUNET_SCHEDULER_shutdown ();
+ return GNUNET_OK;
+ }
if (GNUNET_YES == delay)
task = GNUNET_SCHEDULER_add_delayed (DELAY,
&find_transfers,
@@ -289,6 +300,7 @@ find_transfers (void *cls)
struct TALER_EXCHANGEDB_Session *session;
int ret;
+ task = NULL;
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Checking for incoming wire transfers\n");
@@ -389,7 +401,10 @@ main (int argc,
"PLUGINNAME",
"which wire plugin to use",
&type),
- GNUNET_GETOPT_option_version (VERSION "-" VCS_VERSION),
+ GNUNET_GETOPT_option_flag ('T',
+ "test",
+ "run in test mode and exit when idle",
+ &test_mode),
GNUNET_GETOPT_OPTION_END
};
diff --git a/src/exchange/test-taler-exchange-aggregator-postgres.conf
b/src/exchange/test-taler-exchange-wirewatch-postgres.conf
similarity index 94%
copy from src/exchange/test-taler-exchange-aggregator-postgres.conf
copy to src/exchange/test-taler-exchange-wirewatch-postgres.conf
index f609c0a..2e846d8 100644
--- a/src/exchange/test-taler-exchange-aggregator-postgres.conf
+++ b/src/exchange/test-taler-exchange-wirewatch-postgres.conf
@@ -26,7 +26,9 @@ BASE_URL = "https://exchange.taler.net/";
# as there is no way for wallets to query this value. Thus,
# it is only configurable for testing, and should be treated
# as constant in production.
-IDLE_RESERVE_EXPIRATION_TIME = 4 weeks
+#
+# This is THE test that requires a short reserve expiration time!
+IDLE_RESERVE_EXPIRATION_TIME = 5 s
[exchangedb-postgres]
diff --git a/src/exchange/test_taler_exchange_wirewatch.c
b/src/exchange/test_taler_exchange_wirewatch.c
new file mode 100644
index 0000000..cf3cd49
--- /dev/null
+++ b/src/exchange/test_taler_exchange_wirewatch.c
@@ -0,0 +1,716 @@
+/*
+ This file is part of TALER
+ (C) 2016, 2017 Inria and GNUnet e.V.
+
+ TALER 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 3, or (at your option) any later version.
+
+ TALER 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.
+
+ You should have received a copy of the GNU General Public License along with
+ TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/>
+*/
+
+/**
+ * @file exchange/test_taler_exchange_wirewatch.c
+ * @brief Tests for taler-exchange-wirewatch and taler-exchange-aggregator
logic;
+ * Performs an invalid wire transfer to the exchange, and then checks
that
+ * wirewatch immediately sends the money back.
+ * Then performs a valid wire transfer, waits for the reserve to expire,
+ * and then checks that the aggregator sends the money back.
+ * @author Christian Grothoff <address@hidden>
+ */
+#include "platform.h"
+#include "taler_util.h"
+#include <gnunet/gnunet_json_lib.h>
+#include "taler_json_lib.h"
+#include <microhttpd.h>
+#include "taler_fakebank_lib.h"
+
+
+
+/**
+ * Commands for the interpreter.
+ */
+enum OpCode {
+
+ /**
+ * Terminate testcase with 'skipped' result.
+ */
+ OPCODE_TERMINATE_SKIP,
+
+ /**
+ * Run taler-exchange-aggregator.
+ */
+ OPCODE_RUN_AGGREGATOR,
+
+ /**
+ * Expect that we have exhaustively gone over all transactions.
+ */
+ OPCODE_RUN_WIREWATCH,
+
+ /**
+ * Send money from bank to exchange.
+ */
+ OPCODE_RUN_TRANSFER,
+
+ /**
+ * Wait a certain amount of time.
+ */
+ OPCODE_WAIT,
+
+ /**
+ * Expect that we have received the specified transfer.
+ */
+ OPCODE_EXPECT_TRANSFER,
+
+ /**
+ * Expect that we have 'expected' all wire transfers.
+ */
+ OPCODE_EXPECT_TRANSFERS_EMPTY,
+
+ /**
+ * Finish testcase with success.
+ */
+ OPCODE_TERMINATE_SUCCESS
+};
+
+
+/**
+ * Command state for the interpreter.
+ */
+struct Command
+{
+
+ /**
+ * What instruction should we run?
+ */
+ enum OpCode opcode;
+
+ /**
+ * Human-readable label for the command.
+ */
+ const char *label;
+
+ union {
+
+ /**
+ * If @e opcode is #OPCODE_EXPECT_TRANSFER, this
+ * specifies which transaction we expected. Note that
+ * the WTID will be set, not checked!
+ */
+ struct {
+
+ /**
+ * Amount to be transferred.
+ */
+ const char *amount;
+
+ /**
+ * Account to debit.
+ */
+ uint64_t debit_account;
+
+ /**
+ * Account to credit.
+ */
+ uint64_t credit_account;
+
+ /**
+ * Expected base URL for the exchange.
+ */
+ const char *exchange_base_url;
+
+ /**
+ * Subject of the transfer, set by the command.
+ */
+ struct TALER_WireTransferIdentifierRawP wtid;
+
+ } expect_transfer;
+
+
+ /**
+ * If @e opcode is #OPCODE_RUN_TRANSFER, this
+ * specifies which transaction the bank should do.
+ */
+ struct {
+
+ /**
+ * Amount to be transferred.
+ */
+ const char *amount;
+
+ /**
+ * Account to debit.
+ */
+ uint64_t debit_account;
+
+ /**
+ * Account to credit.
+ */
+ uint64_t credit_account;
+
+ /**
+ * Subject of the transfer, set by the command.
+ */
+ const char *wtid;
+
+ } run_transfer;
+
+ struct {
+
+ /**
+ * The handle for the aggregator process that we are testing.
+ */
+ struct GNUNET_OS_Process *aggregator_proc;
+
+ /**
+ * ID of task called whenever we get a SIGCHILD.
+ */
+ struct GNUNET_SCHEDULER_Task *child_death_task;
+
+ } aggregator;
+
+ struct {
+
+ /**
+ * The handle for the wirewatch process that we are testing.
+ */
+ struct GNUNET_OS_Process *wirewatch_proc;
+
+ /**
+ * ID of task called whenever we get a SIGCHILD.
+ */
+ struct GNUNET_SCHEDULER_Task *child_death_task;
+
+ } wirewatch;
+
+ /**
+ * How long should we wait if the opcode is #OPCODE_WAIT.
+ */
+ struct GNUNET_TIME_Relative wait_delay;
+
+ } details;
+
+};
+
+
+/**
+ * State of the interpreter.
+ */
+struct State
+{
+ /**
+ * Array of commands to run.
+ */
+ struct Command* commands;
+
+ /**
+ * Offset of the next command to be run.
+ */
+ unsigned int ioff;
+};
+
+
+/**
+ * Pipe used to communicate child death via signal.
+ */
+static struct GNUNET_DISK_PipeHandle *sigpipe;
+
+/**
+ * ID of task called whenever we time out.
+ */
+static struct GNUNET_SCHEDULER_Task *timeout_task;
+
+/**
+ * Return value from main().
+ */
+static int result;
+
+/**
+ * Name of the configuration file to use.
+ */
+static char *config_filename;
+
+/**
+ * Task running the interpreter().
+ */
+static struct GNUNET_SCHEDULER_Task *int_task;
+
+/**
+ * Handle for our fake bank.
+ */
+static struct TALER_FAKEBANK_Handle *fb;
+
+
+/**
+ * Interprets the commands from the test program.
+ *
+ * @param cls the `struct State` of the interpreter
+ */
+static void
+interpreter (void *cls);
+
+
+/**
+ * Advance the IP and run the next command.
+ *
+ * @param state interpreter to advance.
+ */
+static void
+next_command (struct State *state)
+{
+ state->ioff++;
+ int_task = GNUNET_SCHEDULER_add_now (&interpreter,
+ state);
+}
+
+
+/**
+ * Fail the testcase at the current command.
+ */
+static void
+fail (struct Command *cmd)
+{
+ fprintf (stderr,
+ "Testcase failed at command `%s'\n",
+ cmd->label);
+ result = 2;
+ GNUNET_SCHEDULER_shutdown ();
+}
+
+
+/**
+ * Task triggered whenever we are to shutdown.
+ *
+ * @param cls closure, NULL if we need to self-restart
+ */
+static void
+timeout_action (void *cls)
+{
+ timeout_task = NULL;
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Test failed: timeout\n");
+ result = 2;
+ GNUNET_SCHEDULER_shutdown ();
+}
+
+
+/**
+ * Task triggered whenever we are to shutdown.
+ *
+ * @param cls our `struct State`
+ */
+static void
+shutdown_action (void *cls)
+{
+ struct State *state = cls;
+
+ if (NULL != timeout_task)
+ {
+ GNUNET_SCHEDULER_cancel (timeout_task);
+ timeout_task = NULL;
+ }
+ if (NULL != int_task)
+ {
+ GNUNET_SCHEDULER_cancel (int_task);
+ int_task = NULL;
+ }
+ if (NULL != fb)
+ {
+ TALER_FAKEBANK_stop (fb);
+ fb = NULL;
+ }
+ for (unsigned int i=0;i<=state->ioff;i++)
+ {
+ struct Command *cmd = &state->commands[i];
+
+ switch (cmd->opcode)
+ {
+ case OPCODE_TERMINATE_SKIP:
+ break;
+ case OPCODE_RUN_AGGREGATOR:
+ if (NULL != cmd->details.aggregator.child_death_task)
+ {
+ GNUNET_SCHEDULER_cancel (cmd->details.aggregator.child_death_task);
+ cmd->details.aggregator.child_death_task = NULL;
+ }
+ if (NULL != cmd->details.aggregator.aggregator_proc)
+ {
+ GNUNET_break (0 == GNUNET_OS_process_kill
(cmd->details.aggregator.aggregator_proc,
+ SIGKILL));
+ GNUNET_OS_process_wait (cmd->details.aggregator.aggregator_proc);
+ GNUNET_OS_process_destroy (cmd->details.aggregator.aggregator_proc);
+ cmd->details.aggregator.aggregator_proc = NULL;
+ }
+ break;
+ case OPCODE_RUN_WIREWATCH:
+ if (NULL != cmd->details.wirewatch.child_death_task)
+ {
+ GNUNET_SCHEDULER_cancel (cmd->details.wirewatch.child_death_task);
+ cmd->details.wirewatch.child_death_task = NULL;
+ }
+ if (NULL != cmd->details.wirewatch.wirewatch_proc)
+ {
+ GNUNET_break (0 == GNUNET_OS_process_kill
(cmd->details.wirewatch.wirewatch_proc,
+ SIGKILL));
+ GNUNET_OS_process_wait (cmd->details.wirewatch.wirewatch_proc);
+ GNUNET_OS_process_destroy (cmd->details.wirewatch.wirewatch_proc);
+ cmd->details.wirewatch.wirewatch_proc = NULL;
+ }
+ break;
+ case OPCODE_RUN_TRANSFER:
+ break;
+ case OPCODE_WAIT:
+ state->ioff++;
+ int_task = GNUNET_SCHEDULER_add_delayed (cmd->details.wait_delay,
+ &interpreter,
+ state);
+ break;
+ case OPCODE_EXPECT_TRANSFER:
+ break;
+ case OPCODE_EXPECT_TRANSFERS_EMPTY:
+ break;
+ case OPCODE_TERMINATE_SUCCESS:
+ break;
+ }
+ }
+}
+
+
+/**
+ * Task triggered whenever we receive a SIGCHLD (child
+ * process died).
+ *
+ * @param cls our `struct State`
+ */
+static void
+maint_child_death (void *cls)
+{
+ struct State *state = cls;
+ const struct GNUNET_DISK_FileHandle *pr;
+ struct Command *cmd = &state->commands[state->ioff];
+ char c[16];
+
+ pr = GNUNET_DISK_pipe_handle (sigpipe,
+ GNUNET_DISK_PIPE_END_READ);
+ GNUNET_break (0 < GNUNET_DISK_file_read (pr,
+ &c,
+ sizeof (c)));
+ switch (cmd->opcode)
+ {
+ case OPCODE_RUN_AGGREGATOR:
+ cmd->details.aggregator.child_death_task = NULL;
+ GNUNET_OS_process_wait (cmd->details.aggregator.aggregator_proc);
+ GNUNET_OS_process_destroy (cmd->details.aggregator.aggregator_proc);
+ cmd->details.aggregator.aggregator_proc = NULL;
+ break;
+ case OPCODE_RUN_WIREWATCH:
+ cmd->details.wirewatch.child_death_task = NULL;
+ GNUNET_OS_process_wait (cmd->details.wirewatch.wirewatch_proc);
+ GNUNET_OS_process_destroy (cmd->details.wirewatch.wirewatch_proc);
+ cmd->details.wirewatch.wirewatch_proc = NULL;
+ break;
+ default:
+ fail (cmd);
+ return;
+ }
+ next_command (state);
+}
+
+
+
+/**
+ * Interprets the commands from the test program.
+ *
+ * @param cls the `struct State` of the interpreter
+ */
+static void
+interpreter (void *cls)
+{
+ struct State *state = cls;
+ struct Command *cmd = &state->commands[state->ioff];
+
+ int_task = NULL;
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "Running command %u (%s)\n",
+ state->ioff,
+ cmd->label);
+ switch (cmd->opcode)
+ {
+ case OPCODE_TERMINATE_SKIP:
+ /* return skip: test not finished, but did not fail either */
+ result = 77;
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ case OPCODE_RUN_AGGREGATOR:
+ cmd->details.aggregator.child_death_task =
+ GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
+ GNUNET_DISK_pipe_handle (sigpipe,
+
GNUNET_DISK_PIPE_END_READ),
+ &maint_child_death,
+ state);
+ cmd->details.aggregator.aggregator_proc
+ = GNUNET_OS_start_process (GNUNET_NO,
+ GNUNET_OS_INHERIT_STD_ALL,
+ NULL, NULL, NULL,
+ "taler-exchange-aggregator",
+ "taler-exchange-aggregator",
+ "-c", config_filename,
+ "-t", /* enable temporary tables */
+ NULL);
+ if (NULL == cmd->details.aggregator.aggregator_proc)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Failed to start taler-exchange-aggregator. Check $PATH.\n");
+ GNUNET_break (0);
+ fail (cmd);
+ return;
+ }
+ return;
+ case OPCODE_RUN_WIREWATCH:
+ cmd->details.wirewatch.child_death_task =
+ GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
+ GNUNET_DISK_pipe_handle (sigpipe,
+
GNUNET_DISK_PIPE_END_READ),
+ &maint_child_death,
+ state);
+ cmd->details.wirewatch.wirewatch_proc
+ = GNUNET_OS_start_process (GNUNET_NO,
+ GNUNET_OS_INHERIT_STD_ALL,
+ NULL, NULL, NULL,
+ "taler-exchange-wirewatch",
+ "taler-exchange-wirewatch",
+ "-c", config_filename,
+ "-t", "test",
+ "-T", /* run in test mode, exit instead of
looping */
+ NULL);
+ if (NULL == cmd->details.wirewatch.wirewatch_proc)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Failed to start taler-exchange-wirewatch. Check $PATH.\n");
+ GNUNET_break (0);
+ fail (cmd);
+ return;
+ }
+ return;
+ case OPCODE_RUN_TRANSFER:
+ GNUNET_break (0); // FIXME: not implemented!
+ return;
+ case OPCODE_WAIT:
+ next_command (state);
+ return;
+ case OPCODE_EXPECT_TRANSFER:
+ {
+ struct TALER_Amount want_amount;
+
+ if (GNUNET_OK !=
+ TALER_string_to_amount (cmd->details.expect_transfer.amount,
+ &want_amount))
+ {
+ GNUNET_break (0);
+ fail (cmd);
+ return;
+ }
+ if (GNUNET_OK !=
+ TALER_FAKEBANK_check (fb,
+ &want_amount,
+ cmd->details.expect_transfer.debit_account,
+ cmd->details.expect_transfer.credit_account,
+ cmd->details.expect_transfer.exchange_base_url,
+ &cmd->details.expect_transfer.wtid))
+ {
+ fail (cmd);
+ return;
+ }
+ next_command (state);
+ return;
+ }
+ case OPCODE_EXPECT_TRANSFERS_EMPTY:
+ if (GNUNET_OK != TALER_FAKEBANK_check_empty (fb))
+ {
+ fail (cmd);
+ return;
+ }
+ next_command (state);
+ break;
+ case OPCODE_TERMINATE_SUCCESS:
+ result = 0;
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+}
+
+
+/**
+ * Main function that will be run by the scheduler.
+ *
+ * @param cls closure with configuration
+ */
+static void
+run (void *cls)
+{
+ static struct Command commands[] = {
+ /* test running with empty DB */
+ {
+ .opcode = OPCODE_EXPECT_TRANSFERS_EMPTY,
+ .label = "expect-empty-transactions-on-start"
+ },
+ {
+ .opcode = OPCODE_RUN_AGGREGATOR,
+ .label = "run-aggregator-on-empty"
+ },
+ {
+ .opcode = OPCODE_RUN_WIREWATCH,
+ .label = "run-wirewatch-on-empty"
+ },
+ {
+ .opcode = OPCODE_EXPECT_TRANSFERS_EMPTY,
+ .label = "expect-empty-transactions-after-dry-run"
+ },
+ {
+ .opcode = OPCODE_TERMINATE_SUCCESS,
+ .label = "testcase-complete-terminating-with-success"
+ },
+ {
+ .opcode = OPCODE_EXPECT_TRANSFER,
+ .label = "expect-deposit-1",
+ .details.expect_transfer.debit_account = 3,
+ .details.expect_transfer.credit_account = 4,
+ .details.expect_transfer.exchange_base_url =
"https://exchange.taler.net/";,
+ .details.expect_transfer.amount = "EUR:0.89"
+ },
+ {
+ .opcode = OPCODE_EXPECT_TRANSFERS_EMPTY,
+ .label = "expect-empty-transactions-on-start"
+ },
+ {
+ .opcode = OPCODE_TERMINATE_SUCCESS,
+ .label = "testcase-complete-terminating-with-success"
+ }
+ };
+ static struct State state = {
+ .commands = commands
+ };
+
+ GNUNET_SCHEDULER_add_shutdown (&shutdown_action,
+ &state);
+ timeout_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES,
+ &timeout_action,
+ &state);
+ result = 1; /* test failed for undefined reason */
+ fb = TALER_FAKEBANK_start (8082);
+ if (NULL == fb)
+ {
+ GNUNET_SCHEDULER_shutdown ();
+ result = 77;
+ return;
+ }
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Launching interpreter\n");
+ int_task = GNUNET_SCHEDULER_add_now (&interpreter,
+ &state);
+}
+
+
+/**
+ * Signal handler called for SIGCHLD. Triggers the
+ * respective handler by writing to the trigger pipe.
+ */
+static void
+sighandler_child_death ()
+{
+ static char c;
+ int old_errno = errno; /* back-up errno */
+
+ GNUNET_break (1 ==
+ GNUNET_DISK_file_write (GNUNET_DISK_pipe_handle
+ (sigpipe, GNUNET_DISK_PIPE_END_WRITE),
+ &c, sizeof (c)));
+ errno = old_errno; /* restore errno */
+}
+
+
+int
+main (int argc,
+ char *const argv[])
+{
+ const char *plugin_name;
+ char *testname;
+ struct GNUNET_OS_Process *proc;
+ struct GNUNET_CONFIGURATION_Handle *cfg;
+ struct GNUNET_SIGNAL_Context *shc_chld;
+
+ result = -1;
+ if (NULL == (plugin_name = strrchr (argv[0], (int) '-')))
+ {
+ GNUNET_break (0);
+ return -1;
+ }
+ plugin_name++;
+ (void) GNUNET_asprintf (&testname,
+ "test-taler-exchange-wirewatch-%s",
+ plugin_name);
+ (void) GNUNET_asprintf (&config_filename,
+ "%s.conf",
+ testname);
+ /* these might get in the way */
+ unsetenv ("XDG_DATA_HOME");
+ unsetenv ("XDG_CONFIG_HOME");
+ GNUNET_log_setup ("test_taler_exchange_wirewatch",
+ "WARNING",
+ NULL);
+ proc = GNUNET_OS_start_process (GNUNET_NO,
+ GNUNET_OS_INHERIT_STD_ALL,
+ NULL, NULL, NULL,
+ "taler-exchange-keyup",
+ "taler-exchange-keyup",
+ "-c", config_filename,
+ NULL);
+ if (NULL == proc)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Failed to run `taler-exchange-keyup`, is your PATH
correct?\n");
+ return 77;
+ }
+ GNUNET_OS_process_wait (proc);
+ GNUNET_OS_process_destroy (proc);
+ if (GNUNET_OK !=
+ GNUNET_NETWORK_test_port_free (IPPROTO_TCP,
+ 8082))
+ {
+ fprintf (stderr,
+ "Required port %u not available, skipping.\n",
+ 8082);
+ return 77;
+ }
+ cfg = GNUNET_CONFIGURATION_create ();
+ if (GNUNET_OK !=
+ GNUNET_CONFIGURATION_parse (cfg,
+ config_filename))
+ {
+ GNUNET_break (0);
+ GNUNET_free (config_filename);
+ GNUNET_free (testname);
+ return 2;
+ }
+ sigpipe = GNUNET_DISK_pipe (GNUNET_NO, GNUNET_NO,
+ GNUNET_NO, GNUNET_NO);
+ GNUNET_assert (NULL != sigpipe);
+ shc_chld =
+ GNUNET_SIGNAL_handler_install (GNUNET_SIGCHLD,
+ &sighandler_child_death);
+ GNUNET_SCHEDULER_run (&run,
+ cfg);
+ GNUNET_SIGNAL_handler_uninstall (shc_chld);
+ GNUNET_DISK_pipe_close (sigpipe);
+ GNUNET_CONFIGURATION_destroy (cfg);
+ GNUNET_free (config_filename);
+ GNUNET_free (testname);
+ return result;
+}
+
+/* end of test_taler_exchange_wirewatch.c */
--
To stop receiving notification emails like this one, please contact
address@hidden
- [GNUnet-SVN] [taler-exchange] branch master updated (a57cf67 -> 1eb739c),
gnunet <=