summaryrefslogtreecommitdiff
path: root/src/exchangedb
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2016-11-17 14:31:44 +0100
committerChristian Grothoff <christian@grothoff.org>2016-11-17 14:31:44 +0100
commite3ec645b0da594ccc3bf915b94f7ad77ca1e2a81 (patch)
treefb8191fda96c9b84a69fa61438e52cf007b4883c /src/exchangedb
parent2faa711fba76114bdad190d64f2d12c26754bc4a (diff)
downloadexchange-e3ec645b0da594ccc3bf915b94f7ad77ca1e2a81.tar.gz
exchange-e3ec645b0da594ccc3bf915b94f7ad77ca1e2a81.tar.bz2
exchange-e3ec645b0da594ccc3bf915b94f7ad77ca1e2a81.zip
change rowid type to uint64_t everywhere; start with reserve-analysis in auditor
Diffstat (limited to 'src/exchangedb')
-rw-r--r--src/exchangedb/plugin_exchangedb_postgres.c15
-rw-r--r--src/exchangedb/test_exchangedb.c23
2 files changed, 18 insertions, 20 deletions
diff --git a/src/exchangedb/plugin_exchangedb_postgres.c b/src/exchangedb/plugin_exchangedb_postgres.c
index c29396875..e92600cd4 100644
--- a/src/exchangedb/plugin_exchangedb_postgres.c
+++ b/src/exchangedb/plugin_exchangedb_postgres.c
@@ -2289,11 +2289,10 @@ postgres_have_deposit (void *cls,
static int
postgres_mark_deposit_tiny (void *cls,
struct TALER_EXCHANGEDB_Session *session,
- unsigned long long rowid)
+ uint64_t rowid)
{
- uint64_t serial_id = rowid;
struct GNUNET_PQ_QueryParam params[] = {
- GNUNET_PQ_query_param_uint64 (&serial_id),
+ GNUNET_PQ_query_param_uint64 (&rowid),
GNUNET_PQ_query_param_end
};
PGresult *result;
@@ -2393,11 +2392,10 @@ postgres_test_deposit_done (void *cls,
static int
postgres_mark_deposit_done (void *cls,
struct TALER_EXCHANGEDB_Session *session,
- unsigned long long rowid)
+ uint64_t rowid)
{
- uint64_t serial_id = rowid;
struct GNUNET_PQ_QueryParam params[] = {
- GNUNET_PQ_query_param_uint64 (&serial_id),
+ GNUNET_PQ_query_param_uint64 (&rowid),
GNUNET_PQ_query_param_end
};
PGresult *result;
@@ -4171,11 +4169,10 @@ postgres_wire_prepare_data_insert (void *cls,
static int
postgres_wire_prepare_data_mark_finished (void *cls,
struct TALER_EXCHANGEDB_Session *session,
- unsigned long long rowid)
+ uint64_t rowid)
{
- uint64_t prewire_uuid = rowid;
struct GNUNET_PQ_QueryParam params[] = {
- GNUNET_PQ_query_param_uint64 (&prewire_uuid),
+ GNUNET_PQ_query_param_uint64 (&rowid),
GNUNET_PQ_query_param_end
};
PGresult *result;
diff --git a/src/exchangedb/test_exchangedb.c b/src/exchangedb/test_exchangedb.c
index d0ec63f46..1e76de16b 100644
--- a/src/exchangedb/test_exchangedb.c
+++ b/src/exchangedb/test_exchangedb.c
@@ -70,7 +70,7 @@ static struct TALER_EXCHANGEDB_Plugin *plugin;
*/
static void
dead_prepare_cb (void *cls,
- unsigned long long rowid,
+ uint64_t rowid,
const char *wire_method,
const char *buf,
size_t buf_size)
@@ -78,6 +78,7 @@ dead_prepare_cb (void *cls,
GNUNET_assert (0);
}
+
/**
* Counter used in auditor-related db functions. Used to count
* expected rows.
@@ -91,7 +92,7 @@ unsigned int auditor_row_cnt;
*/
static void
mark_prepare_cb (void *cls,
- unsigned long long rowid,
+ uint64_t rowid,
const char *wire_method,
const char *buf,
size_t buf_size)
@@ -122,7 +123,7 @@ mark_prepare_cb (void *cls,
*/
void
audit_wire_cb (void *cls,
- unsigned long long rowid,
+ uint64_t rowid,
const char *wire_method,
const char *buf,
size_t buf_size,
@@ -523,7 +524,7 @@ check_transfer_data (void *cls,
*/
int
audit_refresh_session_cb (void *cls,
- unsigned long long rowid, /* FIXME: decide data type for serial_id! */
+ uint64_t rowid,
const struct TALER_CoinSpendPublicKeyP *coin_pub,
const struct TALER_CoinSpendSignatureP *coin_sig,
const struct TALER_Amount *amount_with_fee,
@@ -883,7 +884,7 @@ cb_wtid_check (void *cls,
/**
* Here #deposit_cb() will store the row ID of the deposit.
*/
-static unsigned long long deposit_rowid;
+static uint64_t deposit_rowid;
/**
@@ -908,7 +909,7 @@ static unsigned long long deposit_rowid;
*/
static int
deposit_cb (void *cls,
- unsigned long long rowid,
+ uint64_t rowid,
const struct TALER_MerchantPublicKeyP *merchant_pub,
const struct TALER_CoinSpendPublicKeyP *coin_pub,
const struct TALER_Amount *amount_with_fee,
@@ -968,10 +969,10 @@ deposit_cb (void *cls,
* @param receiver_wire_account wire details for the merchant, NULL from iterate_matching_deposits()
* @param done flag set if the deposit was already executed (or not)
* @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop
- */
+ */
int
audit_deposit_cb (void *cls,
- unsigned long long rowid,
+ uint64_t rowid,
const struct TALER_MerchantPublicKeyP *merchant_pub,
const struct TALER_CoinSpendPublicKeyP *coin_pub,
const struct TALER_CoinSpendSignatureP *coin_sig,
@@ -1005,7 +1006,7 @@ audit_deposit_cb (void *cls,
*/
int
audit_refund_cb (void *cls,
- unsigned long long rowid, /* FIXME: decide data type for serial_id! */
+ uint64_t rowid,
const struct TALER_CoinSpendPublicKeyP *coin_pub,
const struct TALER_MerchantPublicKeyP *merchant_pub,
const struct TALER_MerchantSignatureP *merchant_sig,
@@ -1033,7 +1034,7 @@ audit_refund_cb (void *cls,
*/
int
audit_reserve_in_cb (void *cls,
- unsigned long long rowid, /* FIXME: decide data type for serial_id! */
+ uint64_t rowid,
const struct TALER_ReservePublicKeyP *reserve_pub,
const struct TALER_Amount *credit,
const json_t *sender_account_details,
@@ -1060,7 +1061,7 @@ audit_reserve_in_cb (void *cls,
*/
int
audit_reserve_out_cb (void *cls,
- unsigned long long rowid, /* FIXME: decide data type for serial_id! */
+ uint64_t rowid,
const struct GNUNET_HashCode *h_blind_ev,
const struct TALER_DenominationPublicKey *denom_pub,
const struct TALER_DenominationSignature *denom_sig,