Changeset bf55f32

Timestamp:

Jul 17, 2023, 3:59:29 PM (9 months ago)

Author:

caparsons <caparson@…>

Branches:

master

Children:

5adb277

Parents:

1d66a91

Message:

added support for general channel operators

Location:

libcfa/src

Files:

• bits/weakso_locks.hfa (modified) (2 diffs)
• concurrency/channel.hfa (modified) (3 diffs)
• concurrency/future.hfa (modified) (1 diff)
• concurrency/locks.hfa (modified) (3 diffs)
• concurrency/select.hfa (modified) (2 diffs)

libcfa/src/bits/weakso_locks.hfa

@@ -63 +63 @@
 bool unregister_select( blocking_lock & this, select_node & node ) OPTIONAL_THREAD;
 bool on_selected( blocking_lock & this, select_node & node ) OPTIONAL_THREAD;
+blocking_lock __CFA_select_get_type( blocking_lock this ) OPTIONAL_THREAD;
 
 //----------
@@ -81 +82 @@
 static inline bool   unregister_select( multiple_acquisition_lock & this, select_node & node ) { return unregister_select( (blocking_lock &)this, node ); }
 static inline bool   on_selected( multiple_acquisition_lock & this, select_node & node ) { return on_selected( (blocking_lock &)this, node ); }
+multiple_acquisition_lock __CFA_select_get_type( multiple_acquisition_lock this );

libcfa/src/concurrency/channel.hfa

@@ -330 +330 @@
 ///////////////////////////////////////////////////////////////////////////////////////////
 
-// static inline void ?>>?( T elem, channel(T) & chan ) { insert( chan, elem ); }
-// static inline void ?<<?( T & ret, channel(T) & chan ) { ret = remove( chan ); }
+static inline void ?>>?( T elem, channel(T) & chan ) { insert( chan, elem ); }
+static inline void ?<<?( T & ret, channel(T) & chan ) { ret = remove( chan ); }
 
 ///////////////////////////////////////////////////////////////////////////////////////////
@@ -372 +372 @@
     channel(T) & chan;
 };
+__CFA_SELECT_GET_TYPE( chan_read(T) );
 
 static inline void ?{}( chan_read(T) & cr, channel(T) & chan, T & ret ) {
@@ -464 +465 @@
     channel(T) & chan;
 };
+__CFA_SELECT_GET_TYPE( chan_write(T) );
 
 static inline void ?{}( chan_write(T) & cw, channel(T) & chan, T elem ) {

libcfa/src/concurrency/future.hfa

@@ -39 +39 @@
         futex_mutex lock;
         };
+    __CFA_SELECT_GET_TYPE( future(T) );
 
     struct future_node {

libcfa/src/concurrency/locks.hfa

@@ -113 +113 @@
 static inline bool   unregister_select( single_acquisition_lock & this, select_node & node ) { return unregister_select( (blocking_lock &)this, node ); }
 static inline bool   on_selected( single_acquisition_lock & this, select_node & node ) { return on_selected( (blocking_lock &)this, node ); }
+__CFA_SELECT_GET_TYPE( single_acquisition_lock );
 
 //----------
@@ -130 +131 @@
 static inline bool   unregister_select( owner_lock & this, select_node & node ) { return unregister_select( (blocking_lock &)this, node ); }
 static inline bool   on_selected( owner_lock & this, select_node & node ) { return on_selected( (blocking_lock &)this, node ); }
+__CFA_SELECT_GET_TYPE( owner_lock );
 
 //-----------------------------------------------------------------------------
@@ -620 +622 @@
 
 static inline bool on_selected( simple_owner_lock & this, select_node & node ) { return true; }
-
+__CFA_SELECT_GET_TYPE( simple_owner_lock );
 
 //-----------------------------------------------------------------------------

libcfa/src/concurrency/select.hfa

@@ -94 +94 @@
 
     // This routine is run on the selecting thread prior to executing the statement corresponding to the select_node
-    //    passed as an arg to this routine
-    // If on_selected returns false, the statement is not run if the on_selected call occured as 
-    //    part of a statement block that only ran due to an unregister_select that returned true
-    //    In all other executions the return value is ignored.
+    //    passed as an arg to this routine. If true is returned proceed as normal, if false is returned the statement is skipped
     bool on_selected( T &, select_node & );
 };
+// Used inside the compiler to allow for overloading on return type for operations such as '?<<?' for channels
+// YOU MUST USE THIS MACRO OR INCLUDE AN EQUIVALENT DECL FOR YOUR TYPE TO SUPPORT WAITUNTIL
+#define __CFA_SELECT_GET_TYPE( typename ) typename __CFA_select_get_type( typename __CFA_t )
+
 
 //=============================================================================================
@@ -211 +212 @@
 bool unregister_select( select_timeout_node & this, select_node & node );
 bool on_selected( select_timeout_node & this, select_node & node );
+select_timeout_node __CFA_select_get_type( select_timeout_node this );
 
 // Gateway routines to waituntil on duration
 select_timeout_node timeout( Duration duration );
 select_timeout_node sleep( Duration duration );
+