Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
The waitqueue needed to store messages received without corresponding callback
authormquinson <mquinson@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Thu, 30 Nov 2006 09:29:17 +0000 (09:29 +0000)
committermquinson <mquinson@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Thu, 30 Nov 2006 09:29:17 +0000 (09:29 +0000)
git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@2945 48e7efb5-ca39-0410-a469-dd3cf9ba447f

src/gras/Msg/msg_interface.h

index f7605c6..7c72a76 100644 (file)
@@ -25,9 +25,12 @@ typedef struct {
   char        *name;
   unsigned int name_len;
 
   char        *name;
   unsigned int name_len;
 
-  /*queue of msgs storing the ones got while msg_wait'ing for something else */
+  /* queue storing the msgs got while msg_wait'ing for something else. Reuse them ASAP. */
   xbt_dynar_t msg_queue; /* elm type: s_gras_msg_t */
 
   xbt_dynar_t msg_queue; /* elm type: s_gras_msg_t */
 
+  /* queue storing the msgs without callback got when handling. Feed them to wait() */
+  xbt_dynar_t msg_waitqueue; /* elm type: s_gras_msg_t */
+
   /* registered callbacks for each message */
   xbt_dynar_t cbl_list; /* elm type: gras_cblist_t */
    
   /* registered callbacks for each message */
   xbt_dynar_t cbl_list; /* elm type: gras_cblist_t */