diff --git a/misc/headerimport.h b/misc/headerimport.h index 84b1842..ee25f9e 100644 --- a/misc/headerimport.h +++ b/misc/headerimport.h @@ -18,3 +18,4 @@ #include "../src/stream/type.h" #include "../src/runtime/execute.h" #include "../src/runtime/memory.h" +#include "../src/stream/codeprovider.h" diff --git a/src/stream/process.h b/src/stream/process.h index 66fb456..fc06097 100644 --- a/src/stream/process.h +++ b/src/stream/process.h @@ -66,7 +66,9 @@ class Process { // connect perf_func_n to perf_func_node_ (push) void ConnectPerform(PerformFunction* perf_func_n) { - perf_func_node_->perf_func_next_ = perf_func_n; + PerformFunction* node_std = perf_func_node_; + while(node_std->perf_func_next_ != NULL) node_std = node_std->perf_func_next_; + node_std->perf_func_next_ = perf_func_n; } }; #endif diff --git a/src/stream/stream.h b/src/stream/stream.h index 5419d47..edb0a96 100644 --- a/src/stream/stream.h +++ b/src/stream/stream.h @@ -37,7 +37,9 @@ class Stream { // connnect proc_n to proc_node (push) void ConnectProc(Process* proc_n) { - proc_node_->proc_next = proc_n; + Process* node_std = proc_node_; + while(node_std->perf_func_next_ != NULL) node_std = node_std->perf_func_next_; + node_std->perf_func_next_ = perf_func_n; } };