75 #include "../../OperationCaller.hpp" 76 #include "../../rtt-detail-fwd.hpp" 85 : mpoa( PortableServer::POA::_duplicate(the_poa) )
86 , mtask( orig ), mRequest_i(0), mService_i(0)
99 TaskContextServer::ShutdownOrb(
false);
111 return CORBA::string_dup(
mtask->
provides()->doc().c_str() );
207 const char * service_name)
210 return CService::_nil();
217 CDataFlowInterface_i::registerServant(CDataFlowInterface::_narrow(mService), mserv);
220 std::string svc(service_name);
222 return ::RTT::corba::CService::_duplicate(
mService.in() );
223 return mService->getService( service_name );
227 const char * service_name)
229 std::string svc(service_name);
230 if (
mtask->
requires()->requiresService(service_name) ==
false && svc !=
"this")
231 return CServiceRequester::_nil();
242 return ::RTT::corba::CServiceRequester::_duplicate(
mRequest.in() );
243 return mRequest->getRequest( service_name );
250 ::RTT::corba::CTaskContext::CPeerNames_var result = new ::RTT::corba::CTaskContext::CPeerNames();
251 result->length( peers.size() );
252 for (
unsigned int i=0; i != peers.size(); ++i )
253 result[i] = CORBA::string_dup( peers[i].c_str() );
255 return result._retn();
261 std::string pname(name);
266 return TaskContextServer::CreateServer( task,
false );
268 return RTT::corba::CTaskContext::_nil();
274 std::string mname(name);
279 ::RTT::corba::CTaskContext_ptr p,
282 std::string malias(alias);
284 return mtask->
addPeer( TaskContextProxy::Create(p), alias );
291 std::string mname(name);
297 ::RTT::corba::CTaskContext_ptr p)
306 std::string pname(name);
312 ::RTT::corba::CTaskContext_ptr p)
319 ::RTT::corba::CTaskContext_ptr p)
328 ::RTT::corba::CTaskContextDescription_var d = new ::RTT::corba::CTaskContextDescription();
332 d->mainprovider_description = mainprovider_description;
336 d->mainrequester_description = requester_description;
virtual ::CORBA::Boolean cleanup(void)
virtual ::CORBA::Boolean removePeer(const char *name)
The state indicating the component encountered a C++ exception.
virtual ::CORBA::Boolean start(void)
Service::shared_ptr provides()
virtual ~RTT_corba_CTaskContext_i(void)
virtual ::CORBA::Boolean inFatalError(void)
virtual ::CORBA::Boolean inRunTimeError(void)
PortableServer::ServantBase_var mRequest_i
virtual char * getDescription(void)
virtual ::RTT::corba::CServiceRequester_ptr getRequester(const char *service_name)
virtual ::CORBA::Boolean isConfigured(void)
virtual bool connectPeers(TaskContext *peer)
virtual char * getName(void)
virtual void removePeer(const std::string &name)
virtual ::CORBA::Boolean inException(void)
PortableServer::POA_var mpoa
RTT::corba::CServiceRequester_var mRequest
virtual bool isConfigured() const
virtual ::CORBA::Boolean stop(void)
virtual bool isRunning() const
virtual ::RTT::corba::CTaskContextDescription * getCTaskContextDescription(void)
virtual TaskContext * getPeer(const std::string &peer_name) const
virtual ::CORBA::Boolean recover(void)
virtual bool inException() const
virtual bool hasPeer(const std::string &peer_name) const
virtual ::RTT::corba::CTaskState getTaskState(void)
ServiceRequester::shared_ptr requires()
virtual ::CORBA::Boolean disconnectPeers(const char *name)
virtual ::CORBA::Boolean addPeer(::RTT::corba::CTaskContext_ptr p, const char *alias)
PortableServer::ServantBase_var mService_i
virtual ::CORBA::Boolean connectServices(::RTT::corba::CTaskContext_ptr p)
virtual bool inFatalError() const
virtual ::RTT::corba::CDataFlowInterface_ptr ports(void)
virtual PeerList getPeerList() const
std::vector< std::string > PeerList
virtual ::CORBA::Boolean activate(void)
virtual void disconnectPeers(const std::string &name)
RTT_corba_CTaskContext_i(RTT::TaskContext *orig, PortableServer::POA_ptr the_poa)
virtual TaskState getTaskState() const
virtual bool isActive() const
virtual bool inRunTimeError() const
virtual RTT::corba::CServiceRequester_ptr activate_this()
virtual ::RTT::corba::CTaskContext::CPeerNames * getPeerList(void)
virtual ::RTT::corba::CTaskContext_ptr getPeer(const char *name)
virtual RTT::corba::CService_ptr activate_this()
virtual ::CORBA::Boolean connectPeers(::RTT::corba::CTaskContext_ptr p)
virtual ::CORBA::Boolean connectPorts(::RTT::corba::CTaskContext_ptr p)
virtual bool connectPorts(TaskContext *peer)
virtual bool connectServices(TaskContext *peer)
static Service::shared_ptr mserv
Contains TaskContext, Activity, OperationCaller, Operation, Property, InputPort, OutputPort, Attribute.
virtual ::RTT::corba::CService_ptr getProvider(const char *service_name)
virtual ::CORBA::Boolean resetException(void)
virtual ::CORBA::Boolean isRunning(void)
Operation< Signature > & addOperation(Operation< Signature > &op)
virtual ::CORBA::Boolean configure(void)
virtual ::CORBA::Boolean isActive(void)
RTT::corba::CService_var mService
static Logger::LogFunction endlog()
virtual bool addPeer(TaskContext *peer, std::string alias="")
virtual ::CORBA::Boolean hasPeer(const char *name)
virtual const std::string & getName() const