40 #include "../FactoryExceptions.hpp" 42 #include "../Service.hpp" 43 #include "../Logger.hpp" 50 using namespace detail;
90 if (ms && autocollect) {
94 }
catch (std::exception&) {
115 std::vector<DataSourceBase::shared_ptr>
args;
124 if ( sz == args.size() ) {
126 args.insert( args.begin(), msh );
131 log(
Error) <<
"Failed to produce collector for "<< mname <<
" with " << sz <<
" arguments." <<
endlog();
140 this->args.push_back( na );
141 this->checkAndCreate();
145 : mofp(ofp), mname(name), s(), msh(sh), blocking( new
ValueDataSource<bool>(false) )
147 this->checkAndCreate();
151 : mofp(other.mofp), mname(other.mname),
152 args( other.args ), s( other.s ), msh(other.msh), blocking(new
ValueDataSource<bool>(false))
163 : d(0), e( new
E(0) )
168 :
d( ofp ? new
D( sh, ofp, name ) : 0 ),
e( new
E(op) )
181 :
d( other.
d ? new
D(*other.
d) : 0 ),
e( new
E(*other.
e) )
187 if ( &other ==
this )
190 d = ( other.
d ?
new D(*other.
d) : 0 );
base::DataSourceBase::shared_ptr mop
internal::DataSource< SendStatus >::shared_ptr s
E(base::DataSourceBase::shared_ptr op)
D(base::DataSourceBase::shared_ptr sh, OperationInterfacePart *ofp, const std::string &name)
std::vector< DataSourceBase::shared_ptr > args
OperationInterfacePart * getOrp()
OperationInterfacePart * orp
SendHandleC & operator=(const SendHandleC &other)
DataSource< SendStatus >::shared_ptr s
virtual void set(param_t t)=0
static std::ostream & nl(std::ostream &__os)
AssignableDataSource< bool >::shared_ptr blocking
void setAutoCollect(bool on_off)
DataSourceBase::shared_ptr msh
OperationInterfacePart * mofp
SendHandleC & arg(base::DataSourceBase::shared_ptr a)
base::DataSourceBase::shared_ptr getSendHandleDataSource()
AssignableDataSource< bool >::shared_ptr mb
static std::ostream & endl(std::ostream &__os)
SendStatus collectIfDone()
internal::AssignableDataSource< bool >::shared_ptr b
void newarg(DataSourceBase::shared_ptr na)
boost::intrusive_ptr< DataSource< T > > shared_ptr
boost::intrusive_ptr< AssignableDataSource< T > > shared_ptr
virtual base::DataSourceBase::shared_ptr produceCollect(const std::vector< base::DataSourceBase::shared_ptr > &args, internal::DataSource< bool >::shared_ptr blocking) const =0
DataSource< SendStatus >::shared_ptr ms
virtual unsigned int collectArity() const =0
virtual result_t value() const =0
boost::shared_ptr< OperationKeeper > mopkeeper
boost::intrusive_ptr< DataSourceBase > shared_ptr
Contains TaskContext, Activity, OperationCaller, Operation, Property, InputPort, OutputPort, Attribute.
static Logger::LogFunction endlog()
OperationKeeper(DataSource< SendStatus >::shared_ptr s, AssignableDataSource< bool >::shared_ptr b)
virtual bool evaluate() const