aboutsummaryrefslogtreecommitdiff
path: root/src/bank-lib
diff options
context:
space:
mode:
Diffstat (limited to 'src/bank-lib')
-rw-r--r--src/bank-lib/fakebank.c114
1 files changed, 87 insertions, 27 deletions
diff --git a/src/bank-lib/fakebank.c b/src/bank-lib/fakebank.c
index 545901ef..c5e758ec 100644
--- a/src/bank-lib/fakebank.c
+++ b/src/bank-lib/fakebank.c
@@ -754,7 +754,7 @@ make_transfer (
GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
GNUNET_assert (0 ==
pthread_mutex_unlock (&h->uuid_map_lock));
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Making transfer %llu from %s to %s over %s and subject %s; for exchange: %s\n",
(unsigned long long) t->row_id,
debit_account,
@@ -1296,7 +1296,8 @@ struct HistoryArgs
* @return #GNUNET_OK only if the parsing succeeds.
*/
static int
-parse_history_common_args (struct MHD_Connection *connection,
+parse_history_common_args (struct TALER_FAKEBANK_Handle *h,
+ struct MHD_Connection *connection,
struct HistoryArgs *ha)
{
const char *start;
@@ -1338,7 +1339,7 @@ parse_history_common_args (struct MHD_Connection *connection,
return GNUNET_NO;
}
if (NULL == start)
- ha->start_idx = (d > 0) ? 0 : UINT64_MAX;
+ ha->start_idx = (d > 0) ? 0 : h->serial_counter;
else
ha->start_idx = (uint64_t) sval;
ha->delta = (int64_t) d;
@@ -1350,6 +1351,10 @@ parse_history_common_args (struct MHD_Connection *connection,
ha->lp_timeout
= GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MILLISECONDS,
lp_timeout);
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "Request for %lld records from %llu\n",
+ (long long) ha->delta,
+ (unsigned long long) ha->start_idx);
return GNUNET_OK;
}
@@ -1374,7 +1379,8 @@ handle_debit_history (struct TALER_FAKEBANK_Handle *h,
char *debit_payto;
if (GNUNET_OK !=
- parse_history_common_args (connection,
+ parse_history_common_args (h,
+ connection,
&ha))
{
GNUNET_break (0);
@@ -1404,9 +1410,26 @@ handle_debit_history (struct TALER_FAKEBANK_Handle *h,
else
{
struct Transaction *t = h->transactions[ha.start_idx % h->ram_limit];
-
+ bool overflow;
+ uint64_t dir;
+ bool skip = true;
+
+ dir = (0 > ha.delta) ? (h->ram_limit - 1) : 1;
+ overflow = (t->row_id != ha.start_idx);
+ /* If account does not match, linear scan for
+ first matching account. */
+ while ( (! overflow) &&
+ (NULL != t) &&
+ (t->debit_account != acc) )
+ {
+ skip = false;
+ t = h->transactions[(t->row_id + dir) % h->ram_limit];
+ if ( (NULL != t) &&
+ (t->row_id == ha.start_idx) )
+ overflow = true; /* full circle, give up! */
+ }
if ( (NULL == t) ||
- (t->row_id != ha.start_idx) )
+ overflow)
{
GNUNET_assert (0 ==
pthread_mutex_unlock (&h->big_lock));
@@ -1430,12 +1453,27 @@ handle_debit_history (struct TALER_FAKEBANK_Handle *h,
json_decref (history);
return MHD_NO;
}
- /* range is exclusive, skip the matching entry */
- if (0 > ha.delta)
- pos = t->prev_out;
+ if (skip)
+ {
+ /* range is exclusive, skip the matching entry */
+ if (0 > ha.delta)
+ pos = t->prev_out;
+ else
+ pos = t->next_out;
+ }
else
- pos = t->next_out;
+ {
+ pos = t;
+ }
}
+ if (NULL != pos)
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "Returning %lld debit transactions starting (inclusive) from %llu\n",
+ (long long) ha.delta,
+ (unsigned long long) pos->row_id);
+ else
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "No debit transactions exist after given starting point\n");
while ( (0 != ha.delta) &&
(NULL != pos) )
{
@@ -1502,7 +1540,8 @@ handle_credit_history (struct TALER_FAKEBANK_Handle *h,
char *credit_payto;
if (GNUNET_OK !=
- parse_history_common_args (connection,
+ parse_history_common_args (h,
+ connection,
&ha))
{
GNUNET_break (0);
@@ -1526,9 +1565,26 @@ handle_credit_history (struct TALER_FAKEBANK_Handle *h,
else
{
struct Transaction *t = h->transactions[ha.start_idx % h->ram_limit];
-
+ bool overflow;
+ uint64_t dir;
+ bool skip = true;
+
+ overflow = (t->row_id != ha.start_idx);
+ dir = (0 > ha.delta) ? (h->ram_limit - 1) : 1;
+ /* If account does not match, linear scan for
+ first matching account. */
+ while ( (! overflow) &&
+ (NULL != t) &&
+ (t->credit_account != acc) )
+ {
+ skip = false;
+ t = h->transactions[(t->row_id + dir) % h->ram_limit];
+ if ( (NULL != t) &&
+ (t->row_id == ha.start_idx) )
+ overflow = true; /* full circle, give up! */
+ }
if ( (NULL == t) ||
- (t->row_id != ha.start_idx) )
+ overflow)
{
GNUNET_assert (0 ==
pthread_mutex_unlock (&h->big_lock));
@@ -1540,24 +1596,28 @@ handle_credit_history (struct TALER_FAKEBANK_Handle *h,
"incoming_transactions",
history);
}
- if (t->credit_account != acc)
+ if (skip)
{
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- "Invalid start specified, transaction %llu not with account %s!\n",
- (unsigned long long) ha.start_idx,
- account);
- GNUNET_assert (0 ==
- pthread_mutex_unlock (&h->big_lock));
- json_decref (history);
- GNUNET_free (credit_payto);
- return MHD_NO;
+ /* range from application is exclusive, skip the
+ matching entry */
+ if (0 > ha.delta)
+ pos = t->prev_in;
+ else
+ pos = t->next_in;
}
- /* range is exclusive, skip the matching entry */
- if (0 > ha.delta)
- pos = t->prev_in;
else
- pos = t->next_in;
+ {
+ pos = t;
+ }
}
+ if (NULL != pos)
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "Returning %lld credit transactions starting (inclusive) from %llu\n",
+ (long long) ha.delta,
+ (unsigned long long) pos->row_id);
+ else
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "No credit transactions exist after given starting point\n");
while ( (0 != ha.delta) &&
(NULL != pos) )
{
generated by cgit v1.2.3 (git 2.39.1) at 2025-11-04 04:26:22 +0000