Sophie

Sophie

distrib > Scientific%20Linux > 5x > x86_64 > by-pkgid > 58cebef081c94cb5f88b9fe2fbddfdc8 > files > 27

openais-0.80.6-28.el5_6.1.src.rpm

Index: exec/totemsrp.c
===================================================================
--- exec/totemsrp.c	(revision 2094)
+++ exec/totemsrp.c	(revision 2095)
@@ -86,7 +86,7 @@
 #define QUEUE_RTR_ITEMS_SIZE_MAX		16384 /* allow 256 retransmit items */
 #define RETRANS_MESSAGE_QUEUE_SIZE_MAX		500 /* allow 500 messages to be queued */
 #define RECEIVED_MESSAGE_QUEUE_SIZE_MAX		500 /* allow 500 messages to be queued */
-#define MAXIOVS					5	
+#define MAXIOVS					10
 #define RETRANSMIT_ENTRIES_MAX			30
 #define TOKEN_SIZE_MAX				64000 /* bytes */
 
@@ -2017,6 +2017,8 @@
 	message_item.mcast->guarantee = guarantee;
 	srp_addr_copy (&message_item.mcast->system_from, &instance->my_id);
 
+	assert (iov_len <= MAXIOVS);
+
 	for (i = 0; i < iov_len; i++) {
 // TODO LEAK
 		message_item.iovec[i].iov_base = malloc (iovec[i].iov_len);
@@ -2263,6 +2265,7 @@
 		message_item->mcast->seq = ++token->seq;
 		message_item->mcast->this_seqno = instance->global_seqno++;
 
+		assert (message_item->iov_len < MAXIOVS);
 		/*
 		 * Build IO vector
 		 */
@@ -2279,8 +2282,6 @@
 
 		sort_queue_item.iov_len = message_item->iov_len + 1;
 
-		assert (sort_queue_item.iov_len < 16);
-
 		/*
 		 * Add message to retransmit queue
 		 */