jp.go.aist.rtm.RTC.port
Class InPortCorbaCdrConsumer

java.lang.Object
  jp.go.aist.rtm.RTC.port.CorbaConsumerBase
      jp.go.aist.rtm.RTC.port.CorbaConsumer<InPortCdr>
          jp.go.aist.rtm.RTC.port.InPortCorbaCdrConsumer

All Implemented Interfaces:

ObjectCreator<InPortConsumer>, ObjectDestructor, InPortConsumer

public class InPortCorbaCdrConsumer
extends CorbaConsumer<InPortCdr>
implements InPortConsumer, ObjectCreator<InPortConsumer>, ObjectDestructor

InPortCorbaCdrConsumer class

This is an implementation class of the input port Consumer

that uses CORBA for means of communication.

The InPort consumer class which uses the OpenRTM::InPortCdr interface in CORBA for data transfer and realizes a push-type dataflow.

Field Summary

Fields inherited from class jp.go.aist.rtm.RTC.port.CorbaConsumer

m_var

Fields inherited from class jp.go.aist.rtm.RTC.port.CorbaConsumerBase

m_objref

Constructor Summary

InPortCorbaCdrConsumer()
Constructor

Method Summary

protected ReturnCode	convertReturn(PortStatus status) Converts PortStatus into ReturnCode.
InPortConsumer	creator_() Creats InPortCorbaCdrConsumer
void	destructor_(java.lang.Object obj) Destructs Object
void	init(Properties prop) Initializing configuration
static void	InPortCorbaCdrConsumerInit() Module initialization
void	publishInterfaceProfile(NVListHolder properties) Publish InterfaceProfile information
ReturnCode	put(org.omg.CORBA.portable.OutputStream data) Send data to the destination port
void	setConnector(OutPortConnector connector) set Connector
boolean	subscribeInterface(NVListHolder properties) Subscribe to the data sending notification
void	unsubscribeInterface(NVListHolder properties) Unsubscribe the data send notification

Methods inherited from class jp.go.aist.rtm.RTC.port.CorbaConsumer

_ptr, releaseObject, setObject

Methods inherited from class jp.go.aist.rtm.RTC.port.CorbaConsumerBase

getObject

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InPortCorbaCdrConsumer

public InPortCorbaCdrConsumer()

Constructor

buffer 当該コンシューマに割り当てるバッファオブジェクト buffer The buffer object that is attached to this Consumer

Method Detail

init

public void init(Properties prop)

Initializing configuration

This operation would be called to configure in initialization. In the concrete class, configuration should be performed getting appropriate information from the given Properties data. This function might be called right after instantiation and connection sequence respectivly. Therefore, this function should be implemented assuming multiple call.

Specified by:

init in interface InPortConsumer

Parameters:

prop - Configuration information

put

public ReturnCode put(org.omg.CORBA.portable.OutputStream data)

Send data to the destination port

Pure virtual function to send data to the destination port. This function might the following return codes

• - PORT_OK: Normal return
• - PORT_ERROR: Error occurred in data transfer process
• - SEND_FULL: Buffer full although OutPort tried to send data
• - SEND_TIMEOUT: Timeout although OutPort tried to send data
• - UNKNOWN_ERROR: Unknown error

Specified by:

put in interface InPortConsumer

Parameters:

data - Data sent by this operation.

Returns:

ReturnCode

publishInterfaceProfile

public void publishInterfaceProfile(NVListHolder properties)

Publish InterfaceProfile information

Publish interfaceProfile information. Check the dataport.interface_type value of the NameValue object specified by an argument in property information and get information only when the interface type of the specified port is matched.

Specified by:

publishInterfaceProfile in interface InPortConsumer

Parameters:

properties - Properties to get InterfaceProfile information

subscribeInterface

public boolean subscribeInterface(NVListHolder properties)

Subscribe to the data sending notification

Subscribe to the data sending notification based on specified property information.

Specified by:

subscribeInterface in interface InPortConsumer

Parameters:

properties - Information for subscription

Returns:

Subscription result (Successful:true, Failed:false)

unsubscribeInterface

public void unsubscribeInterface(NVListHolder properties)

Unsubscribe the data send notification

Unsubscribe the data send notification.

Specified by:

unsubscribeInterface in interface InPortConsumer

Parameters:

properties - Information for unsubscription

convertReturn

protected ReturnCode convertReturn(PortStatus status)

Converts PortStatus into ReturnCode.

Parameters:

status - PortStatus

Returns:

ReturnCode

creator_

public InPortConsumer creator_()

Creats InPortCorbaCdrConsumer

Specified by:

creator_ in interface ObjectCreator<InPortConsumer>

Returns:

Object Created instances

destructor_

public void destructor_(java.lang.Object obj)

Destructs Object

Specified by:

destructor_ in interface ObjectDestructor

Parameters:

obj - The target instances for destruction

InPortCorbaCdrConsumerInit

public static void InPortCorbaCdrConsumerInit()

Module initialization

This initialization function registers InPortCorbaCdrConsumer's factory.

setConnector

public void setConnector(OutPortConnector connector)

set Connector

Specified by:

setConnector in interface InPortConsumer

Parameters:

connector - OutPortConnector