Changeset 767:c47c16436f71 in freeDiameter for libfdcore

Timestamp:

Oct 24, 2011, 6:43:32 AM (13 years ago)

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Phase:

public

Message:

Added a limit on fifo queues to avoid memory exaustion when messages are received faster than handled

Location:

libfdcore

Files:

• cnxctx.c (modified) (1 diff)
• config.c (modified) (1 diff)
• p_psm.c (modified) (1 diff)
• peers.c (modified) (1 diff)
• queues.c (modified) (1 diff)
• sctps.c (modified) (1 diff)

libfdcore/cnxctx.c

@@ -90 +90 @@
 
         if (full) {
-                CHECK_FCT_DO( fd_fifo_new ( &conn->cc_incoming ), return NULL );
+                CHECK_FCT_DO( fd_fifo_new ( &conn->cc_incoming, 5 ), return NULL );
         }
 

libfdcore/config.c

@@ -69 +69 @@
         
         CHECK_FCT( fd_dict_init(&fd_g_config->cnf_dict) );
-        CHECK_FCT( fd_fifo_new(&fd_g_config->cnf_main_ev) );
+        CHECK_FCT( fd_fifo_new(&fd_g_config->cnf_main_ev, 0) );
         
         /* TLS parameters */

libfdcore/p_psm.c

@@ -856 +856 @@
         
         /* Create the FIFO for events */
-        CHECK_FCT( fd_fifo_new(&peer->p_events) );
+        CHECK_FCT( fd_fifo_new(&peer->p_events, 0) );
         
         /* Create the PSM controler thread */

libfdcore/peers.c

@@ -77 +77 @@
         fd_list_init(&p->p_actives, p);
         fd_list_init(&p->p_expiry, p);
-        CHECK_FCT( fd_fifo_new(&p->p_tosend) );
+        CHECK_FCT( fd_fifo_new(&p->p_tosend, 5) );
         p->p_hbh = lrand48();
         

libfdcore/queues.c

@@ -45 +45 @@
 {
         TRACE_ENTRY();
-        CHECK_FCT( fd_fifo_new ( &fd_g_incoming ) );
-        CHECK_FCT( fd_fifo_new ( &fd_g_outgoing ) );
-        CHECK_FCT( fd_fifo_new ( &fd_g_local ) );
+        CHECK_FCT( fd_fifo_new ( &fd_g_incoming, 20 ) );
+        CHECK_FCT( fd_fifo_new ( &fd_g_outgoing, 30 ) );
+        CHECK_FCT( fd_fifo_new ( &fd_g_local, 25 ) );
         return 0;
 }

libfdcore/sctps.c

@@ -497 +497 @@
                 conn->cc_sctps_data.array[i].parent = conn;
                 conn->cc_sctps_data.array[i].strid  = i;
-                CHECK_FCT( fd_fifo_new(&conn->cc_sctps_data.array[i].raw_recv) );
+                CHECK_FCT( fd_fifo_new(&conn->cc_sctps_data.array[i].raw_recv, 10) );
         }