Changeset 187 for soft/giet_vm/memo/src

Timestamp:

Jul 30, 2012, 6:14:22 PM (12 years ago)

Author:

alain

Message:

Introducing support for distributed schedulers in the "memo" tool.

File:

• soft/giet_vm/memo/src/memo.cpp (modified) (5 diffs)

soft/giet_vm/memo/src/memo.cpp

@@ -39 +39 @@
 #include "memo.h"
 
-//#define MOVER_DEBUG
+//#define MOVER_DEBUG 
 
 MeMo::MeMo( const std::string &filename, 
@@ -203 +203 @@
 // various mapping_info data structure access functions
 /////////////////////////////////////////////////////////////////////////////
-
+mapping_cluster_t* MeMo::get_cluster_base( mapping_header_t* header )
+{
+    return   (mapping_cluster_t*) ((char*)header +
+                                  MAPPING_HEADER_SIZE);
+}
 /////////////////////////////////////////////////////////////////////////////
 mapping_pseg_t* MeMo::get_pseg_base( mapping_header_t* header )
@@ -332 +336 @@
 } // end print_mapping_info()
 
-//////////////////////////////////////////
-void MeMo::pseg_map( mapping_pseg_t* pseg) 
-{
-    std::string name(pseg->name);
-    m_psegh.m_pSegs.push_back(PSeg(name, pseg->base, pseg->length));
-}
-
 
 //////////////////////////////////////////
@@ -536 +533 @@
     mapping_header_t*   header = (mapping_header_t*)desc;  
 
+    mapping_cluster_t*  cluster = get_cluster_base( header );     
     mapping_vspace_t*   vspace = get_vspace_base( header );     
     mapping_pseg_t*     pseg   = get_pseg_base( header ); 
@@ -546 +544 @@
 #endif
 
-    for ( size_t pseg_id = 0 ; pseg_id < header->psegs ; pseg_id++ )
-    {
-        pseg_map( &pseg[pseg_id]);
+#ifdef DISTRIBUTED_SCHEDULERS 
+    char found;
+#endif
+
+    for ( size_t cluster_id = 0 ; cluster_id < header->clusters ; cluster_id++ )
+    {
+
+#ifdef DISTRIBUTED_SCHEDULERS 
+        found    = 0;
+#endif
+
+        for ( size_t pseg_id = cluster[cluster_id].pseg_offset ;
+              pseg_id < cluster[cluster_id].pseg_offset + cluster[cluster_id].psegs ;
+              pseg_id++ )
+        {
+            //build pseg
+            std::string name(pseg[pseg_id].name);
+            PSeg *ps = new PSeg(name, pseg[pseg_id].base, pseg[pseg_id].length);
+
+#ifdef DISTRIBUTED_SCHEDULERS 
+            if ( (pseg[pseg_id].type == PSEG_TYPE_RAM) && (found == 0) )
+            {
+                ps->incNextLma( (cluster[cluster_id].procs << 12) );
+                found  = 1;
+            }
+#endif
+            m_psegh.m_pSegs.push_back(*ps);
+
+        }
     }