Changeset 8bee858 for libcfa/src/concurrency/io/setup.cfa

Timestamp:

Aug 15, 2022, 11:19:28 AM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, master, pthread-emulation

Children:

d93ea1d

Parents:

41a6a78

Message:

Changed io types to have trailing $ instead of leading

File:

• libcfa/src/concurrency/io/setup.cfa (modified) (10 diffs)

libcfa/src/concurrency/io/setup.cfa

@@ -28 +28 @@
         void ?{}(io_context_params & this) libcfa_public {}
 
-        void  ?{}($io_context & this, struct cluster & cl) {}
-        void ^?{}($io_context & this) {}
+        void  ?{}(io_context$ & this, struct cluster & cl) {}
+        void ^?{}(io_context$ & this) {}
 
         void __cfa_io_start( processor * proc ) {}
@@ -37 +37 @@
         void __cfa_io_stop ( processor * proc ) {}
 
-        $io_arbiter * create(void) { return 0p; }
-        void destroy($io_arbiter *) {}
+        io_arbiter$ * create(void) { return 0p; }
+        void destroy(io_arbiter$ *) {}
 
 #else
@@ -105 +105 @@
 
 
-        static void __io_uring_setup ( $io_context & this, const io_context_params & params_in, int procfd );
-        static void __io_uring_teardown( $io_context & this );
-        static void __epoll_register($io_context & ctx);
-        static void __epoll_unregister($io_context & ctx);
-        void __ioarbiter_register( $io_arbiter & mutex, $io_context & ctx );
-        void __ioarbiter_unregister( $io_arbiter & mutex, $io_context & ctx );
-
-        void ?{}($io_context & this, processor * proc, struct cluster & cl) {
+        static void __io_uring_setup ( io_context$ & this, const io_context_params & params_in, int procfd );
+        static void __io_uring_teardown( io_context$ & this );
+        static void __epoll_register(io_context$ & ctx);
+        static void __epoll_unregister(io_context$ & ctx);
+        void __ioarbiter_register( io_arbiter$ & mutex, io_context$ & ctx );
+        void __ioarbiter_unregister( io_arbiter$ & mutex, io_context$ & ctx );
+
+        void ?{}(io_context$ & this, processor * proc, struct cluster & cl) {
                 /* paranoid */ verify( cl.io.arbiter );
                 this.proc = proc;
@@ -122 +122 @@
         }
 
-        void ^?{}($io_context & this) {
+        void ^?{}(io_context$ & this) {
                 __cfadbg_print_safe(io_core, "Kernel I/O : tearing down io_context %u\n", this.fd);
 
@@ -129 +129 @@
         }
 
-        static void __io_uring_setup( $io_context & this, const io_context_params & params_in, int procfd ) {
+        static void __io_uring_setup( io_context$ & this, const io_context_params & params_in, int procfd ) {
                 // Step 1 : call to setup
                 struct io_uring_params params;
@@ -270 +270 @@
         }
 
-        static void __io_uring_teardown( $io_context & this ) {
+        static void __io_uring_teardown( io_context$ & this ) {
                 // Shutdown the io rings
                 struct __sub_ring_t & sq = this.sq;
@@ -313 +313 @@
 // I/O Context Sleep
 //=============================================================================================
-        // static inline void __epoll_ctl($io_context & ctx, int op, const char * error) {
+        // static inline void __epoll_ctl(io_context$ & ctx, int op, const char * error) {
         //      struct epoll_event ev;
         //      ev.events = EPOLLIN | EPOLLONESHOT;
@@ -323 +323 @@
         // }
 
-        // static void __epoll_register($io_context & ctx) {
+        // static void __epoll_register(io_context$ & ctx) {
         //      __epoll_ctl(ctx, EPOLL_CTL_ADD, "ADD");
         // }
 
-        // static void __epoll_unregister($io_context & ctx) {
+        // static void __epoll_unregister(io_context$ & ctx) {
         //      // Read the current epoch so we know when to stop
         //      size_t curr = __atomic_load_n(&iopoll.epoch, __ATOMIC_SEQ_CST);
@@ -346 +346 @@
         // }
 
-        // void __ioctx_prepare_block($io_context & ctx) {
+        // void __ioctx_prepare_block(io_context$ & ctx) {
         //      __cfadbg_print_safe(io_core, "Kernel I/O - epoll : Re-arming io poller %d (%p)\n", ctx.fd, &ctx);
         //      __epoll_ctl(ctx, EPOLL_CTL_MOD, "REARM");
@@ -355 +355 @@
 // I/O Context Misc Setup
 //=============================================================================================
-        void ?{}( $io_arbiter & this ) {
+        void ?{}( io_arbiter$ & this ) {
                 this.pending.empty = true;
         }
 
-        void ^?{}( $io_arbiter & mutex this ) {}
-
-        $io_arbiter * create(void) {
+        void ^?{}( io_arbiter$ & mutex this ) {}
+
+        io_arbiter$ * create(void) {
                 return new();
         }
-        void destroy($io_arbiter * arbiter) {
+        void destroy(io_arbiter$ * arbiter) {
                 delete(arbiter);
         }