Changeset 2133 in Sophya for trunk/ArchTOIPipe

Timestamp:

Jul 26, 2002, 10:52:43 AM (23 years ago)

Author:

vfebvre

Message:

startAll sur TOIManager

Location:

trunk/ArchTOIPipe/Kernel

Files:

• toimanager.cc (modified) (3 diffs)
• toimanager.h (modified) (5 diffs)
• toiprocessor.cc (modified) (4 diffs)

trunk/ArchTOIPipe/Kernel/toimanager.cc

@@ -3 +3 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: toimanager.cc,v 1.15 2002-06-18 21:15:19 ansari Exp $
+// $Id: toimanager.cc,v 1.16 2002-07-26 08:52:43 vfebvre Exp $
 
 #include "toimanager.h"
@@ -27 +27 @@
 }
 
+// enregistrement d'un processeur dans la liste des processeurs pour une execution en groupe
+
+void TOIManager::registerProcessor(TOIProcessor* proc) {
+  
+  cout << "Adding processor to TOIManager for group execution" << endl;
+  processors.push_back(proc);
+  
+}
+
+
+// demarrage de tous les processeurs
+
+void TOIManager::startAll() {
+  for (vector<TOIProcessor*>::iterator i = processors.begin();
+       i != processors.end(); i++) {
+    TOIProcessor* proc = *i;
+    cout << "******************" <<  endl;
+    cout << "starting processor  " <<  endl;
+    cout << "******************" << endl;
+    proc->start();
+    cout << "processor started " << endl;
+    cout << "******************" << endl;
+  }
+}
+
+
+
 void TOIManager::setRequestedSample(int begin, int end) {
   reqBegin = begin;
@@ -46 +73 @@
 
 void TOIManager::joinAll() {
+  waitForAll();
+}
+
+void TOIManager::waitForAll() {
   for (vector<pthread_t*>::iterator i = threads.begin();
        i != threads.end(); i++) {

trunk/ArchTOIPipe/Kernel/toimanager.h

@@ -5 +5 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: toimanager.h,v 1.13 2002-05-14 13:06:57 ansari Exp $
+// $Id: toimanager.h,v 1.14 2002-07-26 08:52:43 vfebvre Exp $
 
 
@@ -15 +15 @@
 #include <vector>
 
+#include "toiprocessor.h"
+
 using namespace std;
 
@@ -23 +25 @@
   int getRequestedBegin();
   int getRequestedEnd();
-  void addThread(pthread_t*);
-  void joinAll();
   
+  void startAll();
+  void waitForAll();
+
+  void joinAll();  // deprecated. Use waitForAll();
+   
 protected:
   TOIManager();
@@ -33 +38 @@
 
   vector<pthread_t*> threads;
+  void addThread(pthread_t*);
+
+  vector<TOIProcessor*> processors;
+  void registerProcessor(TOIProcessor* proc);
+
+
+  friend class TOIProcessor;
 };
 
@@ -69 +81 @@
 #endif
 
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+

trunk/ArchTOIPipe/Kernel/toiprocessor.cc

@@ -3 +3 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: toiprocessor.cc,v 1.24 2002-05-30 11:51:26 ansari Exp $
+// $Id: toiprocessor.cc,v 1.25 2002-07-26 08:52:43 vfebvre Exp $
 
 #include "toiprocessor.h"
 #include "toimanager.h"
 #include <pthread.h>
-
+#include <typeinfo>        // ajout pour linux
 #ifdef HAVE_VALUES_H
 #include <values.h>
@@ -28 +28 @@
 
 #define pthread_mutexattr_setkind_np pthread_mutexattr_settype
+
 
 TOIProcessor::TOIProcessor() {
@@ -45 +46 @@
   wontNeedValue = -1;
 
-}
+  // Pour referencer un TOIProcessor, il faut recuperer le TOIManager correspondant
+  TOIManager::getManager()->registerProcessor(this);
+
+}
+
+
 
 TOIProcessor::~TOIProcessor() {
@@ -440 +446 @@
 */
 
+
+
+
+
+
+
+
+