Changeset 771:eac79a449c06 in freeDiameter for extensions/app_acct

Timestamp:

Oct 31, 2011, 4:57:59 AM (13 years ago)

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Phase:

public

Message:

Making app_acct thread_safe for PGsql. NOT TESTED.

File:

• extensions/app_acct/acct_db.c (modified) (6 diffs)

extensions/app_acct/acct_db.c

@@ -36 +36 @@
 /* Database interface module */
 
+/* There is one connection to the db per thread. 
+The connection is stored in the pthread_key_t variable */
+
+
 #include "app_acct.h"
 #include <libpq-fe.h>
@@ -54 +58 @@
 static 
 #endif /* TEST_DEBUG */
-PGconn *conn = NULL;
+pthread_key_t connk;
+
 
 /* Initialize the database context: connection to the DB, prepared statement to insert new records */
@@ -66 +71 @@
         int idx = 0;
         PGresult * res;
+        PGconn *conn;
         #define REALLOC_SIZE    1024    /* We extend the buffer by this amount */
         
@@ -195 +201 @@
         acct_rec_empty(&emptyrecords);
         
+        CHECK_POSIX( pthread_key_create(&connk, (void (*)(void*))PQfinish) );
+        CHECK_POSIX( pthread_setspecific(connk, conn) );
+        
         /* Ok, ready */
         return 0;
@@ -202 +211 @@
 void acct_db_free(void)
 {       
-        if (conn) {
-                /* Note: the prepared statement is automatically freed when the session terminates */
-                PQfinish(conn);
-                conn = NULL;
-        }
+        CHECK_POSIX_DO(pthread_key_delete(connk) , );
 }
 
@@ -219 +224 @@
         PGresult *res;
         struct fd_list *li;
+        PGconn *conn;
         
         TRACE_ENTRY("%p", records);
-        CHECK_PARAMS( conn && records );
+        CHECK_PARAMS( records );
+        
+        conn = pthread_getspecific(connk);
+        if (!conn) {
+                conn = PQconnectdb(acct_config->conninfo);
+                CHECK_POSIX( pthread_setspecific(connk, conn) );
+        }
         
         /* First, check if the connection with the DB has not staled, and eventually try to fix it */