Reimplement transaction list

knizhnik · knizhnik · commit 5b6d1c237d41 · 2015-10-14T19:54:04.000+03:00
diff --git a/contrib/pg_dtm/dtmd/src/main.c b/contrib/pg_dtm/dtmd/src/main.c
@@ -282,6 +282,7 @@ static void onbegin(client_t client, int argc, xid_t *argv) {
     } else { 
         free_transactions = t->elem.next;
     }
+    l2_list_link(&active_transactions, &t->elem);
 
     transaction_clear(t);
 
diff --git a/contrib/pg_dtm/dtmd/src/transaction.c b/contrib/pg_dtm/dtmd/src/transaction.c
@@ -1,5 +1,6 @@
 #include <assert.h>
 #include <stdlib.h>
+#include <string.h>
 
 #include "util.h"
 #include "transaction.h"
@@ -25,7 +26,8 @@ int transaction_status(Transaction *t) {
 
 void transaction_clear(Transaction *t) {
 	int i;
-
+    
+    memset(t, 0, sizeof(*t));
 	t->xid = INVALID_XID;
 	t->size = 0;
 	t->votes_for = 0;

Original file line number	Diff line number	Diff line change
`@@ -282,6 +282,7 @@ static void onbegin(client_t client, int argc, xid_t *argv) {`
`282`	`282`	`} else {`
`283`	`283`	`free_transactions = t->elem.next;`
`284`	`284`	`}`
	`285`	`+ l2_list_link(&active_transactions, &t->elem);`
`285`	`286`
`286`	`287`	`transaction_clear(t);`
`287`	`288`