Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
/*
* PackingAbstraction.hpp
*
* Created on: 29. 5. 2018
* Author: Jan Travnicek
*/
#ifndef _PACKING_ABSTRACTION_HPP_
#define _PACKING_ABSTRACTION_HPP_
#include <abstraction/ValueOperationAbstraction.hpp>
#include <alib/memory>
#include <alib/array>
#include <registry/Registry.h>
namespace abstraction {
template < class ... ParamTypes >
class PackingAbstraction : public OperationAbstraction {
struct ConnectionTarget {
unsigned targetId;
unsigned paramPosition;
};
ext::vector < std::shared_ptr < abstraction::OperationAbstraction > > m_abstractions;
ext::array < ext::vector < ConnectionTarget >, sizeof ... ( ParamTypes ) > m_connections;
unsigned m_resultId;
public:
PackingAbstraction ( ext::vector < std::shared_ptr < abstraction::OperationAbstraction > > abstractions, unsigned resultId ) : m_abstractions ( std::move ( abstractions ) ), m_resultId ( resultId ) {
}
bool setInnerConnection ( unsigned sourceId, unsigned targetId, unsigned paramPosition, bool move ) {
return m_abstractions [ targetId ]->attachInput ( m_abstractions [ sourceId ], paramPosition, move );
}
bool clearInnerConnection ( unsigned targetId, unsigned paramPosition ) {
return m_abstractions [ targetId ]->detachInput ( paramPosition );
}
void setOuterConnection ( unsigned sourceId, unsigned targetId, unsigned paramPosition ) {
m_connections [ sourceId ].push_back ( ConnectionTarget { targetId, paramPosition } );
}
private:
virtual bool attachInput ( const std::shared_ptr < OperationAbstraction > & input, unsigned index, bool move ) override {
for ( const ConnectionTarget & target : m_connections [ index ] )
m_abstractions [ target.targetId ]->attachInput ( input, target.paramPosition, move );
return true;
}
virtual bool detachInput ( unsigned index ) override {
for ( const ConnectionTarget & target : m_connections [ index ] )
m_abstractions [ target.targetId ]->detachInput ( target.paramPosition );
return true;
}
public:
virtual bool inputsReady ( ) const override {
for ( const std::shared_ptr < abstraction::OperationAbstraction > & operation : m_abstractions )
if ( operation->inputsReady ( ) == false )
return false;
return true;
}
virtual bool inputsAttached ( ) const override {
for ( const std::shared_ptr < abstraction::OperationAbstraction > & operation : m_abstractions )
if ( operation->inputsAttached ( ) == false )
return false;
return true;
}
virtual bool run ( ) override {
if ( ! this->inputsReady ( ) )
return false;
if ( this->cached ( ) )
return true;
return m_abstractions [ m_resultId ]->run ( );
}
virtual bool eval ( ) override {
if ( ! inputsAttached ( ) )
return false;
if ( this->cached ( ) )
return true;
return m_abstractions [ m_resultId ]->eval ( );
}
virtual unsigned numberOfParams ( ) const override {
return sizeof ... ( ParamTypes );
}
virtual bool isReady ( ) const override {
return m_abstractions [ m_resultId ]->isReady ( );
}
virtual bool cached ( ) const override {
return isReady ( );
}
virtual ext::type_index getParamTypeIndex ( unsigned index ) const override {
return m_abstractions [ m_connections.at ( index ) [ 0 ].targetId ]->getParamTypeIndex ( m_connections.at ( index ) [ 0 ].paramPosition );
}
virtual ext::type_index getReturnTypeIndex ( ) const override {
return m_abstractions [ m_resultId ]->getReturnTypeIndex ( );
}
virtual ext::type_index getRuntimeReturnTypeIndex ( ) const override {
return m_abstractions [ m_resultId ]->getRuntimeReturnTypeIndex ( );
}
virtual std::shared_ptr < abstraction::OperationAbstraction > getProxyAbstraction ( ) override {
return m_abstractions [ m_resultId ]->getProxyAbstraction ( );
}
};
} /* namespace abstraction */
#endif /* _PACKING_ABSTRACTION_HPP_ */