minor updates

gopalshankar · Oct 26, 2011 · 924790e · 924790e
1 parent 8e422e4
commit 924790e
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/servers_pm/msgque.c b/servers_pm/msgque.c
@@ -550,7 +550,7 @@ PUBLIC int do_mrecv(void)
 
 	/* Wake-up Sender if they are sleeping */
 	user = mq->userHead;
-	while( user ) {
+	while(( user )&&(mq->queueLen < MQ_MAX_MESSAGES )) {
 		printf("\nCS551 DBG: do_mrecv loop %d", user->state);
 		if( user->type==MQ_SENDER && user->state==MQ_USER_BLOCKED ) { 
 			printf("\nCS551 DBG: do_mrecv unblocking sender %d", user->proc_nr);

diff --git a/servers_pm/msgque.h b/servers_pm/msgque.h
@@ -20,7 +20,7 @@
   */
 struct MsgNode {
 	unsigned long messageNo;
-	char *message;   
+	void *message;   
 	int len;
 	struct MsgNode *next;
 };

diff --git a/servers_pm/msgque_const.h b/servers_pm/msgque_const.h
@@ -10,7 +10,7 @@
 #define MQ_MAX_MSGQUES 128
 #define MQ_MAX_MESSAGES 512
 #define MQ_MAX_BYTES_IN_MSG 256 /* Single msg que can hold 512 * 256 bytes */
-#define MQ_CLEANUP_TIMER 500 /* number of ticks after which cleanup is to be run */
+#define MQ_CLEANUP_TIMER 1500 /* number of ticks after which cleanup is to be run */
 
 
 /* OTHERS */