nodepp V1.4.0_5

Author: EDBCREPO

.gitignore

@@ -1,4 +1,5 @@
 image.jpg
 main.exe
 build
-main
+main
+www

examples/0-isolated-module/CMakeLists.txt

@@ -0,0 +1,40 @@
+cmake_minimum_required(VERSION 3.16)
+project(Isolated_Modules_System CXX) 
+
+set(CMAKE_CXX_STANDARD 11)
+set(CMAKE_CXX_STANDARD_REQUIRED ON)
+set(CMAKE_CXX_EXTENSIONS OFF)
+
+find_package(Threads REQUIRED)
+find_package(OpenSSL REQUIRED)
+find_package(ZLIB    REQUIRED)
+
+set(NODEPP_INCLUDE_DIR "${CMAKE_CURRENT_SOURCE_DIR}/../../include")
+
+add_library(Modules_Lib SHARED 
+    module1.cpp 
+    module2.cpp
+)
+
+target_include_directories(Modules_Lib PRIVATE 
+    ${NODEPP_INCLUDE_DIR}
+    ${CMAKE_CURRENT_SOURCE_DIR}
+)
+
+add_executable(main main.cpp)
+
+target_link_libraries(main PRIVATE 
+    Modules_Lib
+    Threads::Threads
+    OpenSSL::SSL
+    OpenSSL::Crypto
+    ZLIB::ZLIB
+)
+
+target_include_directories(main PRIVATE 
+    ${NODEPP_INCLUDE_DIR}
+    ${CMAKE_CURRENT_SOURCE_DIR}
+)
+
+target_compile_options(main PRIVATE -fpermissive)
+target_compile_options(Modules_Lib PRIVATE -fpermissive)

examples/0-isolated-module/compile.sh

@@ -0,0 +1,13 @@
+mkdir -p build
+
+if [ ! -d "./build/_deps" ]; then
+   ( cd build ; cmake .. )
+fi
+
+( cd build ; make )
+
+if [ ! $? -eq 0 ]; then
+    echo "exit error"; exit;
+fi
+
+./build/main

examples/0-isolated-module/main.cpp

@@ -0,0 +1,48 @@
+#include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
+#include <nodepp/channel.h>
+#include <nodepp/encoder.h>
+
+using namespace nodepp;
+
+#include "module1.h"
+#include "module2.h"
+
+void onMain(){
+
+    pair_t<worker_t,channel_t<coroutine_t>> module2 = module_2_start();
+    pair_t<worker_t,channel_t<coroutine_t>> module1 = module_1_start();
+
+    module2.second.write( coroutine_t( COROUTINE(){
+    coBegin
+
+        while( true ){
+            console::log( "hello from module 2" );
+        coDelay(100); }
+
+    coFinish
+    }));
+
+    module1.second.write( coroutine_t( COROUTINE(){
+    coBegin
+
+        while( true ){
+            console::log( "hello from module 1" );
+        coDelay(300); }
+
+    coFinish
+    }));
+
+    process::add( coroutine::add( COROUTINE(){
+    coBegin
+
+        while( true ){
+            console::log( "<---------------->" );
+            console::log( "<2>", module2.first.is_closed() );
+            console::log( "<2>", module1.first.is_closed() );
+        coDelay(1000); }
+
+    coFinish
+    }));
+
+}

examples/0-isolated-module/module1.cpp

@@ -0,0 +1,24 @@
+#include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
+#include <nodepp/channel.h>
+
+using namespace nodepp;
+
+#include "module1.h"
+
+pair_t<worker_t,channel_t<coroutine_t>> module_1_start(){
+
+     channel_t<coroutine_t> chn;
+
+     return { worker::add( coroutine::add( COROUTINE(){
+     coBegin
+
+          while( true ){
+          if   ( !chn.empty() ){
+          for  ( auto &x: chn.read() ){ process::add( x ); }}
+          if   ( process::size() == 0 ){ coDelay(1000); } process::next(); }
+
+     coFinish
+     }) ), chn };
+     
+}

examples/0-isolated-module/module1.h

@@ -0,0 +1,6 @@
+#ifndef MODULE_H_1
+#define MODULE_H_1
+
+pair_t<worker_t,channel_t<coroutine_t>> module_1_start();
+
+#endif

examples/0-isolated-module/module2.cpp

@@ -0,0 +1,24 @@
+#include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
+#include <nodepp/channel.h>
+
+using namespace nodepp;
+
+#include "module2.h"
+
+pair_t<worker_t,channel_t<coroutine_t>> module_2_start(){
+
+     channel_t<coroutine_t> chn;
+
+     return { worker::add( coroutine::add( COROUTINE(){
+     coBegin
+
+          while( true ){
+          if   ( !chn.empty() ){
+          for  ( auto &x: chn.read() ){ process::add( x ); }}
+          if   ( process::size() == 0 ){ coDelay(1000); } process::next(); }
+
+     coFinish
+     }) ), chn };
+     
+}

examples/0-isolated-module/module2.h

@@ -0,0 +1,6 @@
+#ifndef MODULE_H_2
+#define MODULE_H_2
+
+pair_t<worker_t,channel_t<coroutine_t>> module_2_start();
+
+#endif

examples/0-stl_interop.cpp

@@ -0,0 +1,33 @@
+#include <nodepp/nodepp.h>
+#include <nodepp/event.h>
+
+#include <string>
+#include <queue>
+#include <vector>
+#include <functional>
+
+using namespace nodepp;
+
+void onMain(){
+
+    ptr_t<int> ptr ( 0UL, 10 ); // as value
+//  ptr_t<int> ptr ( 1UL, 10 ); // as buffer
+
+    std::function<void(int)> clb ([=]( int value ){
+        console::log( value, *ptr );
+    });
+
+    event_t<int> ev; ev.once( clb );
+    ev.emit( 100 );
+
+    std::string str = "hello world";
+    console::log( ">>", str );
+
+    std::vector<int> arr ({ 10, 20, 30, 40, 50 });
+    console::log( ">>", array_t<int>( arr ).join() );
+
+    std::queue<int> st ({ 10, 20, 30, 40 });
+    queue_t<int> que ( st );
+    que.map([=]( int value ){ console::log( "<>", value ); });
+
+}

examples/15-TCP.cpp

@@ -1,4 +1,5 @@
 #include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
 #include <nodepp/tcp.h>
 #include <nodepp/fs.h>
 
@@ -74,9 +75,12 @@ void client(){
 
 void onMain() {
 
-    if( process::env::get("mode")=="client" ) 
-      { client(); } else { server(); }
+    worker::add( coroutine::add( COROUTINE(){
+    coBegin /*--*/ ; server();
+    process::wait(); coFinish }));
 
-}
+    worker::add( coroutine::add( COROUTINE(){
+    coBegin /*--*/ ; client();
+    process::wait(); coFinish }));
 
-// g++ -o main main.cpp -I./include ; ./main ?mode=client
+}