taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

dead code elimination

Browse Source
This commit is contained in:
Marcello Stanisci 2020-01-16 12:58:42 +01:00
parent a444bf31b7
commit 8a08f73171
No known key found for this signature in database
GPG Key ID: 8D526861953F4C0F
1 changed files with 0 additions and 393 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

393
src/lib/test_taler_exchange_aggregator.c
View File

@ -39,179 +39,6 @@ static struct TALER_TESTING_ExchangeConfiguration ec;
*/
static struct TALER_TESTING_BankConfiguration bc;
/**
* 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_EXPECT_TRANSACTIONS_EMPTY,
/**
* Execute deposit operation against database.
*/
OPCODE_DATABASE_DEPOSIT,
/**
* Wait a certain amount of time.
*/
OPCODE_WAIT,
/**
* Expect that we have received the specified transaction.
*/
OPCODE_EXPECT_TRANSACTION,
/**
* 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_TRANSACTION, 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;
/**
* Base URL of the exchange.
*/
const char *exchange_base_url;
/**
* Subject of the transfer, set by the command.
*/
struct TALER_WireTransferIdentifierRawP wtid;
} expect_transaction;
/**
* If @e opcode is #OPCODE_DATABASE_DEPOST, this
* specifies which deposit operation we should fake.
*/
struct
{
/**
* Each merchant name is automatically mapped to a unique
* merchant public key.
*/
const char *merchant_name;
/**
* Merchant account number, is mapped to wire details.
*/
uint64_t merchant_account;
/**
* By when does the merchant request the funds to be wired.
*/
struct GNUNET_TIME_Relative wire_deadline;
/**
* What is the total amount (including exchange fees).
*/
const char *amount_with_fee;
/**
* How high are the exchange fees? Must be smaller than @e amount_with_fee.
*/
const char *deposit_fee;
} deposit;
/**
* 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 get a SIGCHILD.
*/
static struct GNUNET_SCHEDULER_Task *child_death_task;
/**
* ID of task called whenever we time out.
*/
static struct GNUNET_SCHEDULER_Task *timeout_task;
/**
* Return value from main().
*/
@ -232,22 +59,6 @@ static struct TALER_EXCHANGEDB_Plugin *plugin;
*/
static struct TALER_EXCHANGEDB_Session *session;
/**
* The handle for the aggregator process that we are testing.
*/
static struct GNUNET_OS_Process *aggregator_proc;
/**
* State of our interpreter while we are running the aggregator
* process.
*/
static struct State *aggregator_state;
/**
* Task running the interpreter().
*/
static struct GNUNET_SCHEDULER_Task *int_task;
/**
* Private key we use for fake coins.
*/
@ -258,101 +69,6 @@ static struct GNUNET_CRYPTO_RsaPrivateKey *coin_pk;
*/
static struct GNUNET_CRYPTO_RsaPublicKey *coin_pub;
/**
* Handle for our fake bank.
*/
static struct TALER_FAKEBANK_Handle *fb;
/**
* 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 closure, NULL if we need to self-restart
*/
static void
shutdown_action (void *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;
}
if (NULL != child_death_task)
{
GNUNET_SCHEDULER_cancel (child_death_task);
child_death_task = NULL;
}
if (NULL != aggregator_proc)
{
GNUNET_break (0 == GNUNET_OS_process_kill (aggregator_proc,
SIGKILL));
GNUNET_OS_process_wait (aggregator_proc);
GNUNET_OS_process_destroy (aggregator_proc);
aggregator_proc = NULL;
}
plugin->drop_tables (plugin->cls);
TALER_EXCHANGEDB_plugin_unload (plugin);
plugin = NULL;
}
#if 0
/**
* Task triggered whenever we receive a SIGCHLD (child
* process died).
*
* @param cls closure, NULL if we need to self-restart
*/
static void
maint_child_death (void *cls)
{
const struct GNUNET_DISK_FileHandle *pr;
char c[16];
struct State *state;
child_death_task = NULL;
pr = GNUNET_DISK_pipe_handle (sigpipe, GNUNET_DISK_PIPE_END_READ);
GNUNET_break (0 < GNUNET_DISK_file_read (pr, &c, sizeof (c)));
GNUNET_OS_process_wait (aggregator_proc);
GNUNET_OS_process_destroy (aggregator_proc);
aggregator_proc = NULL;
aggregator_state->ioff++;
state = aggregator_state;
aggregator_state = NULL;
child_death_task = GNUNET_SCHEDULER_add_read_file (
GNUNET_TIME_UNIT_FOREVER_REL,
pr,
&maint_child_death, NULL);
interpreter (state);
}
#endif
/**
* Setup (fake) information about a coin used in deposit.
*
@ -493,21 +209,6 @@ do_deposit (struct Command *cmd)
return ret;
}
/**
* 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 ();
}
/**
* Interprets the commands from the test program.
*
@ -1204,100 +905,6 @@ run (void *cls,
}
/**
* Main function that will be run by the scheduler.
*
* @param cls closure with configuration
*/
#if 0
static void
OLDrun (void *cls)
{
struct GNUNET_CONFIGURATION_Handle *cfg = cls;
struct TALER_EXCHANGEDB_DenominationKeyInformationP issue;
struct TALER_DenominationPublicKey dpk;
plugin = TALER_EXCHANGEDB_plugin_load (cfg);
if (NULL == plugin)
{
GNUNET_break (0);
result = 77;
return;
}
if (GNUNET_OK !=
plugin->create_tables (plugin->cls))
{
GNUNET_break (0);
TALER_EXCHANGEDB_plugin_unload (plugin);
plugin = NULL;
result = 77;
return;
}
session = plugin->get_session (plugin->cls);
GNUNET_assert (NULL != session);
fake_issue (&issue);
dpk.rsa_public_key = coin_pub;
GNUNET_CRYPTO_rsa_public_key_hash (dpk.rsa_public_key,
&issue.properties.denom_hash);
if ( (GNUNET_OK !=
plugin->start (plugin->cls,
session,
"aggregator-test-2")) ||
(GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->insert_denomination_info (plugin->cls,
session,
&dpk,
&issue)) ||
(GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
plugin->commit (plugin->cls,
session)) )
{
GNUNET_break (0);
TALER_EXCHANGEDB_plugin_unload (plugin);
plugin = NULL;
result = 77;
return;
}
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,
NULL);
GNUNET_SCHEDULER_add_shutdown (&shutdown_action,
NULL);
timeout_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES,
&timeout_action,
NULL);
result = 1; /* test failed for undefined reason */
fb = TALER_FAKEBANK_start (8082);
if (NULL == fb)
{
GNUNET_SCHEDULER_shutdown ();
result = 77;
return;
}
run_test ();
}
#endif
/**
* 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[])