diff libfdcore/p_psm.c @ 767:c47c16436f71

Added a limit on fifo queues to avoid memory exaustion when messages are received faster than handled
author Sebastien Decugis <sdecugis@nict.go.jp>
date Sun, 23 Oct 2011 23:43:32 +0200
parents 4a9f08d6b6ba
children fbf77629cb7b
line wrap: on
line diff
--- a/libfdcore/p_psm.c	Sat Oct 22 22:56:55 2011 +0200
+++ b/libfdcore/p_psm.c	Sun Oct 23 23:43:32 2011 +0200
@@ -855,7 +855,7 @@
 	CHECK_PARAMS( fd_peer_getstate(peer) == STATE_NEW );
 	
 	/* 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 */
 	CHECK_POSIX( pthread_create( &peer->p_psm, NULL, p_psm_th, peer ) );
"Welcome to our mercurial repository"