Skip to content
Snippets Groups Projects
Commit 578b4c22 authored by Oliver Heidmann's avatar Oliver Heidmann
Browse files

removed parentProcesses from Process

parent 0571f844
No related branches found
No related tags found
1 merge request!286removed parentProcesses from Process
Pipeline #89235 passed
......@@ -148,18 +148,12 @@ Process::add_pipe_in_stream()
void
Process::add_parent(const std::shared_ptr<Process> &parentProcess)
{
parentProcesses.push_back(parentProcess);
m_posInParent = parentProcess->inputStreams.size() - 1;
add_pipe_out_stream();
}
void
Process::add_pipe_out_stream()
{
outputStreams.push_back(parentProcesses[0]->inputStreams[m_posInParent]);
outputStreams.push_back(parentProcess->inputStreams[m_posInParent]);
m_streamCnt++;
}
void *
execute(void *process)
{
......
......@@ -42,7 +42,6 @@ public:
const CdoModule &m_module;
int m_posInParent;
std::vector<std::shared_ptr<Process>> childProcesses;
std::vector<std::shared_ptr<Process>> parentProcesses;
std::vector<CdoStreamID> inputStreams;
std::vector<CdoStreamID> outputStreams;
......@@ -63,7 +62,7 @@ public:
/* Member Functions */
Process(int p_ID, const std::string &p_operatorName, const std::vector<std::string> &p_arguments, const CdoModule &p_module);
virtual ~Process() {}
virtual ~Process() {Debug(PROCESS,"destruction of %s",operatorName);}
pthread_t start_thread();
virtual void init() = 0;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment