diff options
Diffstat (limited to 'src/exchange/taler-exchange-aggregator.c')
-rw-r--r-- | src/exchange/taler-exchange-aggregator.c | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/src/exchange/taler-exchange-aggregator.c b/src/exchange/taler-exchange-aggregator.c index 21a29e506..69c73746c 100644 --- a/src/exchange/taler-exchange-aggregator.c +++ b/src/exchange/taler-exchange-aggregator.c | |||
@@ -330,6 +330,8 @@ refund_by_coin_cb (void *cls, | |||
330 | * | 330 | * |
331 | * @param cls a `struct AggregationUnit` | 331 | * @param cls a `struct AggregationUnit` |
332 | * @param row_id identifies database entry | 332 | * @param row_id identifies database entry |
333 | * @param exchange_timestamp when did the deposit happen | ||
334 | * @param wallet_timestamp when did the contract happen | ||
333 | * @param merchant_pub public key of the merchant | 335 | * @param merchant_pub public key of the merchant |
334 | * @param coin_pub public key of the coin | 336 | * @param coin_pub public key of the coin |
335 | * @param amount_with_fee amount that was deposited including fee | 337 | * @param amount_with_fee amount that was deposited including fee |
@@ -343,6 +345,8 @@ refund_by_coin_cb (void *cls, | |||
343 | static enum GNUNET_DB_QueryStatus | 345 | static enum GNUNET_DB_QueryStatus |
344 | deposit_cb (void *cls, | 346 | deposit_cb (void *cls, |
345 | uint64_t row_id, | 347 | uint64_t row_id, |
348 | struct GNUNET_TIME_Absolute exchange_timestamp, | ||
349 | struct GNUNET_TIME_Absolute wallet_timestamp, | ||
346 | const struct TALER_MerchantPublicKeyP *merchant_pub, | 350 | const struct TALER_MerchantPublicKeyP *merchant_pub, |
347 | const struct TALER_CoinSpendPublicKeyP *coin_pub, | 351 | const struct TALER_CoinSpendPublicKeyP *coin_pub, |
348 | const struct TALER_Amount *amount_with_fee, | 352 | const struct TALER_Amount *amount_with_fee, |
@@ -358,6 +362,8 @@ deposit_cb (void *cls, | |||
358 | /* NOTE: potential optimization: use custom SQL API to not | 362 | /* NOTE: potential optimization: use custom SQL API to not |
359 | fetch this one: */ | 363 | fetch this one: */ |
360 | (void) wire_deadline; /* already checked by SQL query */ | 364 | (void) wire_deadline; /* already checked by SQL query */ |
365 | (void) exchange_timestamp; | ||
366 | (void) wallet_timestamp; | ||
361 | au->merchant_pub = *merchant_pub; | 367 | au->merchant_pub = *merchant_pub; |
362 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | 368 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, |
363 | "Aggregator processing payment %s with amount %s\n", | 369 | "Aggregator processing payment %s with amount %s\n", |
@@ -501,6 +507,8 @@ deposit_cb (void *cls, | |||
501 | * | 507 | * |
502 | * @param cls a `struct AggregationUnit` | 508 | * @param cls a `struct AggregationUnit` |
503 | * @param row_id identifies database entry | 509 | * @param row_id identifies database entry |
510 | * @param exchange_timestamp when did the exchange receive the deposit | ||
511 | * @param wallet_timestamp when did the wallet sign the contract | ||
504 | * @param merchant_pub public key of the merchant | 512 | * @param merchant_pub public key of the merchant |
505 | * @param coin_pub public key of the coin | 513 | * @param coin_pub public key of the coin |
506 | * @param amount_with_fee amount that was deposited including fee | 514 | * @param amount_with_fee amount that was deposited including fee |
@@ -514,6 +522,8 @@ deposit_cb (void *cls, | |||
514 | static enum GNUNET_DB_QueryStatus | 522 | static enum GNUNET_DB_QueryStatus |
515 | aggregate_cb (void *cls, | 523 | aggregate_cb (void *cls, |
516 | uint64_t row_id, | 524 | uint64_t row_id, |
525 | struct GNUNET_TIME_Absolute exchange_timestamp, | ||
526 | struct GNUNET_TIME_Absolute wallet_timestamp, | ||
517 | const struct TALER_MerchantPublicKeyP *merchant_pub, | 527 | const struct TALER_MerchantPublicKeyP *merchant_pub, |
518 | const struct TALER_CoinSpendPublicKeyP *coin_pub, | 528 | const struct TALER_CoinSpendPublicKeyP *coin_pub, |
519 | const struct TALER_Amount *amount_with_fee, | 529 | const struct TALER_Amount *amount_with_fee, |
@@ -529,6 +539,8 @@ aggregate_cb (void *cls, | |||
529 | /* NOTE: potential optimization: use custom SQL API to not | 539 | /* NOTE: potential optimization: use custom SQL API to not |
530 | fetch these: */ | 540 | fetch these: */ |
531 | (void) wire_deadline; /* checked by SQL */ | 541 | (void) wire_deadline; /* checked by SQL */ |
542 | (void) exchange_timestamp; | ||
543 | (void) wallet_timestamp; | ||
532 | (void) wire; /* must match */ | 544 | (void) wire; /* must match */ |
533 | GNUNET_break (0 == GNUNET_memcmp (&au->merchant_pub, | 545 | GNUNET_break (0 == GNUNET_memcmp (&au->merchant_pub, |
534 | merchant_pub)); | 546 | merchant_pub)); |