gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GNUnet-SVN] [taler-exchange] branch master updated: ensure transaction_


From: gnunet
Subject: [GNUnet-SVN] [taler-exchange] branch master updated: ensure transaction_name is also set for deferred_wire_out transaction, re-use postgres_start logic
Date: Mon, 12 Mar 2018 11:39:40 +0100

This is an automated email from the git hooks/post-receive script.

grothoff pushed a commit to branch master
in repository exchange.

The following commit(s) were added to refs/heads/master by this push:
     new cb623d4  ensure transaction_name is also set for deferred_wire_out 
transaction, re-use postgres_start logic
cb623d4 is described below

commit cb623d44cba8b60a0d5120dbfeefe93fac2f79ff
Author: Christian Grothoff <address@hidden>
AuthorDate: Mon Mar 12 11:39:31 2018 +0100

    ensure transaction_name is also set for deferred_wire_out transaction, 
re-use postgres_start logic
---
 src/exchangedb/plugin_exchangedb_postgres.c | 21 ++++++++-------------
 1 file changed, 8 insertions(+), 13 deletions(-)

diff --git a/src/exchangedb/plugin_exchangedb_postgres.c 
b/src/exchangedb/plugin_exchangedb_postgres.c
index d6a9b28..6c63305 100644
--- a/src/exchangedb/plugin_exchangedb_postgres.c
+++ b/src/exchangedb/plugin_exchangedb_postgres.c
@@ -1560,7 +1560,6 @@ postgres_start (void *cls,
                      PQerrorMessage (session->conn));
     GNUNET_break (0);
     PQclear (result);
-    session->transaction_name = NULL;
     return GNUNET_SYSERR;
   }
   PQclear (result);
@@ -4852,19 +4851,13 @@ postgres_start_deferred_wire_out (void *cls,
   PGresult *result;
   ExecStatusType ex;
 
-  result = PQexec (session->conn,
-                   "START TRANSACTION ISOLATION LEVEL SERIALIZABLE");
-  if (PGRES_COMMAND_OK !=
-      (ex = PQresultStatus (result)))
-  {
-    TALER_LOG_ERROR ("Failed to start transaction (%s): %s\n",
-                     PQresStatus (ex),
-                     PQerrorMessage (session->conn));
-    GNUNET_break (0);
-    PQclear (result);
+  postgres_preflight (cls,
+                      session);
+  if (GNUNET_OK !=
+      postgres_start (cls,
+                      session,
+                      "deferred wire out"))
     return GNUNET_SYSERR;
-  }
-  PQclear (result);
   result = PQexec (session->conn,
                    "SET CONSTRAINTS wire_out_ref DEFERRED");
   if (PGRES_COMMAND_OK !=
@@ -4875,6 +4868,8 @@ postgres_start_deferred_wire_out (void *cls,
                      PQerrorMessage (session->conn));
     GNUNET_break (0);
     PQclear (result);
+    postgres_rollback (cls,
+                       session);
     return GNUNET_SYSERR;
   }
   PQclear (result);

-- 
To stop receiving notification emails like this one, please contact
address@hidden



reply via email to

[Prev in Thread] Current Thread [Next in Thread]