diff options
| author | Joseph <Joseph.xu@efrei.net> | 2023-01-04 09:43:47 -0500 |
|---|---|---|
| committer | Joseph <Joseph.xu@efrei.net> | 2023-01-04 09:43:47 -0500 |
| commit | 069708205c0b14e311f8916788275b121cae2c0e (patch) | |
| tree | 9abfc8810da5778c54404e68a5251a1f45d67907 /src/exchangedb/pg_batch2_reserves_in_insert.c | |
| parent | 2eb59d9135734b614509adc16fdb0f061d05634a (diff) | |
| download | exchange-069708205c0b14e311f8916788275b121cae2c0e.tar.xz | |
some modifications for batch_test
Diffstat (limited to 'src/exchangedb/pg_batch2_reserves_in_insert.c')
| -rw-r--r-- | src/exchangedb/pg_batch2_reserves_in_insert.c | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/src/exchangedb/pg_batch2_reserves_in_insert.c b/src/exchangedb/pg_batch2_reserves_in_insert.c index 90848e0e6..34c15d1da 100644 --- a/src/exchangedb/pg_batch2_reserves_in_insert.c +++ b/src/exchangedb/pg_batch2_reserves_in_insert.c @@ -764,6 +764,8 @@ TEH_PG_batch2_reserves_in_insert (void *cls, t_duplicate |= transaction_duplicate[i+1]; t_duplicate |= transaction_duplicate[i+2]; t_duplicate |= transaction_duplicate[i+3]; + // fprintf(stdout, "%ld %ld c:%d t:%d %d %d %d\n", reserve_uuid[i], reserve_uuid[i+1], conflicts[i], t_duplicate, t_duplicate, transaction_duplicate[i+2], transaction_duplicate[i+3]); + i += 4; break; case 3: @@ -791,7 +793,6 @@ TEH_PG_batch2_reserves_in_insert (void *cls, t_duplicate |= transaction_duplicate[i]; t_duplicate |= transaction_duplicate[i+1]; - //fprintf(stdout, "%ld %ld c:%d t:%d\n", reserve_uuid[i], reserve_uuid[i+1], conflicts[i], transaction_duplicate[i]); i += 2; break; case 1: @@ -835,13 +836,19 @@ TEH_PG_batch2_reserves_in_insert (void *cls, return cs; } } - if (! need_update) { goto exit; } + /* fprintf(stdout, "t : %d", t_duplicate); if (t_duplicate) - goto exit; + { + GNUNET_break (0); + TEH_PG_rollback (pg); + return GNUNET_DB_STATUS_HARD_ERROR; + } + */ + // begin serializable { if (GNUNET_OK != @@ -864,7 +871,6 @@ TEH_PG_batch2_reserves_in_insert (void *cls, { if (! conflicts[i]) continue; - // fprintf(stdout, "%d\n", conflicts[i]); { bool duplicate; struct GNUNET_PQ_QueryParam params[] = { @@ -889,7 +895,7 @@ TEH_PG_batch2_reserves_in_insert (void *cls, if (qs3<0) { GNUNET_log (GNUNET_ERROR_TYPE_WARNING, - "Failed to update (%d)\n", + "Failed to update reserves (%d)\n", qs3); results[i] = qs3; return qs3; |