📌 Nodepp | worker.h update | V1.4.2 📌

Author: EDBCREPO

examples/62-invoker.cpp

@@ -0,0 +1,31 @@
+#include <nodepp/nodepp.h>
+
+using namespace nodepp;
+
+void onMain(){
+
+    string_t addr1 = process::invoke([=]( any_t raw ){
+        auto data = raw.as<ptr_t<ulong>>();
+        console::log( "<-->", data, *data, process::now() );
+    return 1; });
+
+    string_t addr2 = process::invoke([=]( any_t raw ){
+        static ulong x=1; static ulong y=1; ulong z=0;
+        auto data = raw.as<ptr_t<ulong>>();
+        z = x; x = z + y; y = z; *data = x;
+    //  console::log( "<-->", data, *data, process::now(), x );
+    return 1; });
+
+    process::add( coroutine::add( COROUTINE(){
+    coBegin
+
+        while( true ){ do {
+            auto x = ptr_t<ulong>( 0UL, 0 );
+            process::call( addr2, x );
+            process::call( addr1, x );
+        } while(0); coDelay(1000); }
+
+    coFinish
+    }));
+
+}

include/nodepp/evloop.h

@@ -16,15 +16,24 @@
 
 namespace nodepp { namespace process {
 
-    kernel_t& NODEPP_EV_LOOP(){ thread_local static kernel_t evloop; return evloop; }
+    kernel_t& NODEPP_EV_LOOP(){ thread_local static kernel_t out; return out; }
+    invoke_t& NODEPP_INVOKE (){ thread_local static invoke_t out; return out; }
 
     /*─······································································─*/
 
     template< class... T >
-    void await( const T&... args ){ while(NODEPP_EV_LOOP().await( args... )==1){/*unused*/} }
+    void revoke( const T&... args ){ NODEPP_INVOKE().off( args... ); }
+
+    template< class... T >
+    int call( const T&... args ){ return NODEPP_INVOKE().emit( args... ); }
+
+    template< class... T >
+    string_t invoke( const T&... args ){ return NODEPP_INVOKE().add( args... ); }
+    
+    /*─······································································─*/
 
     template< class... T >
-    ptr_t<task_t> foop( const T&... args ){ return NODEPP_EV_LOOP().loop_add( args... ); }
+    void await( const T&... args ){ while(NODEPP_EV_LOOP().await( args... )==1){/*unused*/} }
 
     template< class... T >
     ptr_t<task_t> loop( const T&... args ){ return NODEPP_EV_LOOP().loop_add( args... ); }

include/nodepp/import.h

@@ -64,6 +64,7 @@
 #include "os.h"
 #include "query.h"
 #include "kernel.h"
+#include "invoke.h"
 
 /*────────────────────────────────────────────────────────────────────────────*/
 

include/nodepp/invoke.h

@@ -0,0 +1,65 @@
+/*
+ * Copyright 2023 The Nodepp Project Authors. All Rights Reserved.
+ *
+ * Licensed under the MIT (the "License").  You may not use
+ * this file except in compliance with the License.  You can obtain a copy
+ * in the file LICENSE in the source distribution or at
+ * https://github.com/NodeppOfficial/nodepp/blob/main/LICENSE
+ */
+
+/*────────────────────────────────────────────────────────────────────────────*/
+
+#ifndef NODEPP_DMA_INVOKE
+#define NODEPP_DMA_INVOKE
+
+/*────────────────────────────────────────────────────────────────────────────*/
+
+namespace nodepp { class invoke_t {
+protected:
+
+    using  NODE_CLB = function_t<int,any_t>;
+    struct NODE {
+        queue_t<NODE_CLB> queue;
+    };  ptr_t<NODE> obj;
+
+public:
+
+   ~invoke_t() { if( obj.count() > 1 ){ return; } free(); }
+    invoke_t() : obj( new NODE() ){}
+
+    /*─······································································─*/
+
+    ulong size () const noexcept { return obj->queue.size (); }
+    void  clear() const noexcept { /*--*/ obj->queue.clear(); }
+    void  free () const noexcept { /*--*/ obj->queue.clear(); }
+
+    /*─······································································─*/
+
+    int emit( string_t address, any_t value ) const noexcept {
+        if( address.empty() ) /*-------------*/ { return -1; }
+        auto mem = obj->queue.as( string::to_addr( address ) );
+        if( mem == nullptr ) /*--------------*/ { return -1; }
+        int c = mem->data.emit( value );
+        if( c==-1 ){ off( address ); }
+    return c; }
+
+    int off( string_t address ) const noexcept {
+        if( address.empty() ) /*-------------*/ { return -1; }
+        auto mem = obj->queue.as( string::to_addr( address ) );
+        if( mem == nullptr ) /*--------------*/ { return -1; }
+        memset( address.get(), 0, address.size() );
+        obj->queue.erase(mem); return 1;
+    }
+
+    string_t add( NODE_CLB callback ) const noexcept {
+        obj->queue.push ( callback );
+        void* ID = obj->queue.last();
+    return string::to_string( ID ); }
+
+}; }
+
+/*────────────────────────────────────────────────────────────────────────────*/
+
+#endif
+
+/*────────────────────────────────────────────────────────────────────────────*/

include/nodepp/posix/dns.h

@@ -44,38 +44,38 @@ namespace nodepp { namespace dns {
 
             if( host == "broadcast" || host == "255.255.255.255" ){
                 dns_t tmp ({ "255.255.255.255", host, AF_INET }); 
-                return ptr_t<dns_t>( 0UL, tmp );
+                return ptr_t<dns_t>( 1UL, tmp );
             }
             elif( host == "localhost" || host == "127.0.0.1" ){ 
                 dns_t tmp ({ "127.0.0.1", host, AF_INET }); 
-                return ptr_t<dns_t>( 0UL, tmp );
+                return ptr_t<dns_t>( 1UL, tmp );
             }
             elif( host == "global"    || host == "0.0.0.0" ){ 
                 dns_t tmp ({ "0.0.0.0", host, AF_INET }); 
-                return ptr_t<dns_t>( 0UL, tmp );
+                return ptr_t<dns_t>( 1UL, tmp );
             }
             elif( host == "loopback"  || host == "1.1.1.1" ){
                 dns_t tmp ({ "1.1.1.1", host, AF_INET }); 
-                return ptr_t<dns_t>( 0UL, tmp );
+                return ptr_t<dns_t>( 1UL, tmp );
             }
 
         }  elif( family == AF_INET6 )  {
 
             if( host == "broadcast" || host == "::2" ){
                 dns_t tmp ({ "::2", host, AF_INET6 }); 
-                return ptr_t<dns_t>( 0UL, tmp );
+                return ptr_t<dns_t>( 1UL, tmp );
             }
             elif( host == "localhost" || host == "::1" ){ 
                 dns_t tmp ({ "::1", host, AF_INET6 }); 
-                return ptr_t<dns_t>( 0UL, tmp );
+                return ptr_t<dns_t>( 1UL, tmp );
             }
             elif( host == "global"    || host == "::0" ){ 
                 dns_t tmp ({ "::0", host, AF_INET6 }); 
-                return ptr_t<dns_t>( 0UL, tmp );
+                return ptr_t<dns_t>( 1UL, tmp );
             }
             elif( host == "loopback"  || host == "::3" ){ 
                 dns_t tmp ({ "::3", host, AF_INET6 }); 
-                return ptr_t<dns_t>( 0UL, tmp );
+                return ptr_t<dns_t>( 1UL, tmp );
             }
 
         }