-bugfixes, and FTBFS

src/bank-lib/fakebank.c

@@ -1403,7 +1403,8 @@ handle_debit_history (struct TALER_FAKEBANK_Handle *h,
   {
     struct Transaction *t = h->transactions[ha.start_idx % h->ram_limit];
 
-    if (NULL == t)
+    if ( (NULL == t) ||
+         (t->row_id != ha.start_idx) )
     {
       GNUNET_assert (0 ==
                      pthread_mutex_unlock (&h->big_lock));
@@ -1524,7 +1525,8 @@ handle_credit_history (struct TALER_FAKEBANK_Handle *h,
   {
     struct Transaction *t = h->transactions[ha.start_idx % h->ram_limit];
 
-    if (NULL == t)
+    if ( (NULL == t) ||
+         (t->row_id != ha.start_idx) )
     {
       GNUNET_assert (0 ==
                      pthread_mutex_unlock (&h->big_lock));

src/exchangedb/plugin_exchangedb_postgres.c

@@ -436,7 +436,8 @@ postgres_get_session (void *cls)
                               ",gc_date"
                               ") VALUES "
                               "($1, $2, $3, $4, $5, $6)"
-                              " ON CONFLICT DO NOTHING;",
+                              " ON CONFLICT DO NOTHING"
+                              " RETURNING reserve_uuid;",
                               6),
       /* Used in #postgres_insert_reserve_closed() */
       GNUNET_PQ_make_prepare ("reserves_close_insert",
@@ -478,6 +479,19 @@ postgres_get_session (void *cls)
                               "  WHERE reserve_pub=$1"
                               " ON CONFLICT DO NOTHING;",
                               7),
+      /* Used in #postgres_reserves_in_insert() to store transaction details */
+      GNUNET_PQ_make_prepare ("reserves_in_add_by_uuid",
+                              "INSERT INTO reserves_in "
+                              "(reserve_uuid"
+                              ",wire_reference"
+                              ",credit_val"
+                              ",credit_frac"
+                              ",exchange_account_section"
+                              ",sender_account_details"
+                              ",execution_date"
+                              ") VALUES ($1, $2, $3, $4, $5, $6, $7)"
+                              " ON CONFLICT DO NOTHING;",
+                              7),
       /* Used in postgres_select_reserves_in_above_serial_id() to obtain inbound
          transactions for reserves with serial id '\geq' the given parameter */
       GNUNET_PQ_make_prepare ("reserves_in_get_latest_wire_reference",
@@ -3488,6 +3502,7 @@ postgres_reserves_in_insert (void *cls,
   struct GNUNET_TIME_Absolute expiry;
   struct GNUNET_TIME_Absolute gc;
   struct GNUNET_TIME_Absolute now;
+  uint64_t reserve_uuid;
 
   now = GNUNET_TIME_absolute_get ();
   (void) GNUNET_TIME_round_abs (&now);
@@ -3517,34 +3532,61 @@ postgres_reserves_in_insert (void *cls,
       TALER_PQ_query_param_absolute_time (&gc),
       GNUNET_PQ_query_param_end
     };
+    struct GNUNET_PQ_ResultSpec rs[] = {
+      GNUNET_PQ_result_spec_uint64 ("reserve_uuid",
+                                    &reserve_uuid),
+      GNUNET_PQ_result_spec_end
+    };
 
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Reserve does not exist; creating a new one\n");
     /* Note: query uses 'on conflict do nothing' */
-    qs1 = GNUNET_PQ_eval_prepared_non_select (session->conn,
+    qs1 = GNUNET_PQ_eval_prepared_singleton_select (session->conn,
-                                              "reserve_create",
+                                                    "reserve_create",
-                                              params);
+                                                    params,
+                                                    rs);
     if (qs1 < 0)
       return qs1;
   }
 
   /* Create new incoming transaction, "ON CONFLICT DO NOTHING"
      is again used to guard against duplicates. */
+
   {
-    struct GNUNET_PQ_QueryParam params[] = {
-      GNUNET_PQ_query_param_auto_from_type (&reserve.pub),
-      GNUNET_PQ_query_param_uint64 (&wire_ref),
-      TALER_PQ_query_param_amount (balance),
-      GNUNET_PQ_query_param_string (exchange_account_section),
-      GNUNET_PQ_query_param_string (sender_account_details),
-      TALER_PQ_query_param_absolute_time (&execution_time),
-      GNUNET_PQ_query_param_end
-    };
     enum GNUNET_DB_QueryStatus qs2;
 
-    qs2 = GNUNET_PQ_eval_prepared_non_select (session->conn,
+    if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS == qs1)
-                                              "reserves_in_add_transaction",
+    {
-                                              params);
+      struct GNUNET_PQ_QueryParam params[] = {
+        GNUNET_PQ_query_param_auto_from_type (&reserve.pub),
+        GNUNET_PQ_query_param_uint64 (&wire_ref),
+        TALER_PQ_query_param_amount (balance),
+        GNUNET_PQ_query_param_string (exchange_account_section),
+        GNUNET_PQ_query_param_string (sender_account_details),
+        TALER_PQ_query_param_absolute_time (&execution_time),
+        GNUNET_PQ_query_param_end
+      };
+
+      qs2 = GNUNET_PQ_eval_prepared_non_select (session->conn,
+                                                "reserves_in_add_transaction",
+                                                params);
+    }
+    else
+    {
+      struct GNUNET_PQ_QueryParam params[] = {
+        GNUNET_PQ_query_param_uint64 (&reserve_uuid),
+        GNUNET_PQ_query_param_uint64 (&wire_ref),
+        TALER_PQ_query_param_amount (balance),
+        GNUNET_PQ_query_param_string (exchange_account_section),
+        GNUNET_PQ_query_param_string (sender_account_details),
+        TALER_PQ_query_param_absolute_time (&execution_time),
+        GNUNET_PQ_query_param_end
+      };
+
+      qs2 = GNUNET_PQ_eval_prepared_non_select (session->conn,
+                                                "reserves_in_add_by_uuid",
+                                                params);
+    }
     if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT != qs2)
     {
       GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR != qs2);

src/include/taler_exchangedb_plugin.h

@@ -2094,6 +2094,21 @@ struct TALER_EXCHANGEDB_Plugin
             const char *name);
 
 
+  /**
+   * Start a READ COMMITTED transaction.
+   *
+   * @param cls the `struct PostgresClosure` with the plugin-specific state
+   * @param session the database connection
+   * @param name unique name identifying the transaction (for debugging)
+   *             must point to a constant
+   * @return #GNUNET_OK on success
+   */
+  int
+  (*start_read_committed)(void *cls,
+                          struct TALER_EXCHANGEDB_Session *session,
+                          const char *name);
+
+
   /**
    * Commit a transaction.
    *