Changeset 85:e5fcd672caff in freeDiameter for libfreeDiameter/sessions.c

Timestamp:

Dec 3, 2009, 2:59:23 PM (14 years ago)

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Phase:

public

Message:

Added new function to retrieve messages sessions easily

File:

• libfreeDiameter/sessions.c (modified) (2 diffs)

libfreeDiameter/sessions.c

@@ -100 +100 @@
         pthread_mutex_t stlock; /* A lock to protect the list of states associated with this session */
         struct fd_list  states; /* Sentinel for the list of states of this session. */
+        int             msg_cnt;/* Reference counter for the messages pointing to this session */
 };
 
@@ -675 +676 @@
 }
 
+/* For the messages module */
+int fd_sess_fromsid_msg ( unsigned char * sid, size_t len, struct session ** session, int * new)
+{
+        TRACE_ENTRY("%p %zd %p %p", sid, len, session, new);
+        CHECK_PARAMS( sid && len && session && VALIDATE_SI(*session) );
+        
+        /* Get the session object */
+        CHECK_FCT( fd_sess_fromsid ( (char *) sid, len, session, new) );
+        
+        /* Update the msg refcount */
+        CHECK_POSIX( pthread_mutex_lock(&(*session)->stlock) );
+        (*session)->msg_cnt++;
+        CHECK_POSIX( pthread_mutex_unlock(&(*session)->stlock) );
+        
+        /* Done */
+        return 0;
+}
+
+int fd_sess_reclaim_msg ( struct session ** session )
+{
+        int reclaim;
+        
+        TRACE_ENTRY("%p", session);
+        CHECK_PARAMS( session && VALIDATE_SI(*session) );
+        
+        /* Update the msg refcount */
+        CHECK_POSIX( pthread_mutex_lock(&(*session)->stlock) );
+        reclaim = (*session)->msg_cnt;
+        (*session)->msg_cnt = reclaim - 1;
+        CHECK_POSIX( pthread_mutex_unlock(&(*session)->stlock) );
+        
+        if (reclaim == 1) {
+                CHECK_FCT(fd_sess_reclaim ( session ));
+        } else {
+                *session = NULL;
+        }
+        return 0;
+}
+
+
 
 /* Dump functions */