Changes in src/libcfa/concurrency/kernel [de94a60:14a61b5]

File:

• src/libcfa/concurrency/kernel (modified) (4 diffs)

src/libcfa/concurrency/kernel

@@ -40 +40 @@
 
 //-----------------------------------------------------------------------------
+// Cluster
+struct cluster {
+        // Ready queue locks
+        __spinlock_t ready_queue_lock;
+
+        // Ready queue for threads
+        __queue_t(thread_desc) ready_queue;
+
+        // Name of the cluster
+        const char * name;
+
+        // Preemption rate on this cluster
+        Duration preemption_rate;
+
+        // List of idle processors
+        // __dllist_t(struct processor) idles;
+};
+
+extern struct cluster * mainCluster;
+extern Duration default_preemption();
+
+void ?{} (cluster & this, const char * name, Duration preemption_rate);
+void ^?{}(cluster & this);
+
+static inline void ?{} (cluster & this)                           { this{"Anonymous Cluster", default_preemption()}; }
+static inline void ?{} (cluster & this, Duration preemption_rate) { this{"Anonymous Cluster", preemption_rate}; }
+static inline void ?{} (cluster & this, const char * name)        { this{name, default_preemption()}; }
+
+//-----------------------------------------------------------------------------
 // Processor
-extern struct cluster * mainCluster;
-
 enum FinishOpCode { No_Action, Release, Schedule, Release_Schedule, Release_Multi, Release_Multi_Schedule };
 
@@ -74 +101 @@
 
         // Cluster from which to get threads
-        struct cluster * cltr;
+        cluster * cltr;
 
         // Name of the processor
@@ -100 +127 @@
         bool pending_preemption;
 
-        // Idle lock
-
-        // Link lists fields
         struct {
-                struct processor * next;
-                struct processor * prev;
-        } node;
+                pthread_mutex_t lock;
+                pthread_cond_t  cond;
+        } idle;
 
 #ifdef __CFA_DEBUG__
@@ -114 +138 @@
 };
 
-void  ?{}(processor & this, const char * name, struct cluster & cltr);
+void  ?{}(processor & this, const char * name, cluster & cltr);
 void ^?{}(processor & this);
 
 static inline void  ?{}(processor & this)                    { this{ "Anonymous Processor", *mainCluster}; }
-static inline void  ?{}(processor & this, struct cluster & cltr)    { this{ "Anonymous Processor", cltr}; }
+static inline void  ?{}(processor & this, cluster & cltr)    { this{ "Anonymous Processor", cltr}; }
 static inline void  ?{}(processor & this, const char * name) { this{name, *mainCluster }; }
-
-static inline [processor *&, processor *& ] __get( processor & this ) {
-        return this.node.[next, prev];
-}
-
-//-----------------------------------------------------------------------------
-// Cluster
-struct cluster {
-        // Ready queue locks
-        __spinlock_t ready_queue_lock;
-
-        // Ready queue for threads
-        __queue_t(thread_desc) ready_queue;
-
-        // Name of the cluster
-        const char * name;
-
-        // Preemption rate on this cluster
-        Duration preemption_rate;
-
-        // List of processors
-        __spinlock_t proc_list_lock;
-        __dllist_t(struct processor) procs;
-        __dllist_t(struct processor) idles;
-
-        // Link lists fields
-        struct {
-                cluster * next;
-                cluster * prev;
-        } node;
-};
-extern Duration default_preemption();
-
-void ?{} (cluster & this, const char * name, Duration preemption_rate);
-void ^?{}(cluster & this);
-
-static inline void ?{} (cluster & this)                           { this{"Anonymous Cluster", default_preemption()}; }
-static inline void ?{} (cluster & this, Duration preemption_rate) { this{"Anonymous Cluster", preemption_rate}; }
-static inline void ?{} (cluster & this, const char * name)        { this{name, default_preemption()}; }
-
-static inline [cluster *&, cluster *& ] __get( cluster & this ) {
-        return this.node.[next, prev];
-}
 
 // Local Variables: //