public abstract class OutPortBase extends PortBase
Publisherの登録やPublisherへのデータ更新通知などの実装を提供する。
修飾子とタイプ | クラスと説明 |
---|---|
protected class |
OutPortBase.Publisher
ポート名です。
|
PortBase.connect_func, PortBase.disconnect_all_func, PortBase.disconnect_func, PortBase.find_conn_id, PortBase.find_interface, PortBase.find_port_ref
修飾子とタイプ | フィールドと説明 |
---|---|
protected java.util.Vector<OutPortConnector> |
m_connectors |
protected java.util.Vector<java.lang.String> |
m_consumerTypes |
protected ConnectorListeners |
m_listeners |
protected Properties |
m_properties |
protected java.util.Vector<java.lang.String> |
m_providerTypes |
protected java.util.List<OutPortBase.Publisher> |
m_publishers |
m_connectionLimit, m_connectorsMutex, m_objref, m_onConnected, m_onConnectionLost, m_onDisconnected, m_onPublishInterfaces, m_onSubscribeInterfaces, m_onUnsubscribeInterfaces, m_ownerInstanceName, m_portconnListeners, m_profile, m_profile_mutex, rtcout
コンストラクタと説明 |
---|
OutPortBase(java.lang.String name,
java.lang.String data_type)
コンストラクタ
|
修飾子とタイプ | メソッドと説明 |
---|---|
void |
activateInterfaces()
OutPortを activates する
Port に登録されている全てのインターフェースを activate する。
|
void |
addConnectorDataListener(int type,
ConnectorDataListenerT listener)
ConnectorDataListener リスナを追加する
バッファ書き込みまたは読み出しイベントに関連する各種リスナを設定する。
|
void |
addConnectorDataListener(int type,
ConnectorDataListenerT listener,
boolean autoclean)
ConnectorDataListener リスナを追加する
バッファ書き込みまたは読み出しイベントに関連する各種リスナを設定する。
|
void |
addConnectorListener(int type,
ConnectorListener listener)
ConnectorListener リスナを追加する
{@.ja バッファ書き込みまたは読み出しイベントに関連する各種リスナを
設定する。
|
void |
addConnectorListener(int type,
ConnectorListener listener,
boolean autoclean)
ConnectorListener リスナを追加する
{@.ja バッファ書き込みまたは読み出しイベントに関連する各種リスナを
設定する。
|
protected void |
configure()
OutPortの設定を行う
propertiesの情報に基づきOutPortの各種設定を行う
|
ReturnCode_t |
connect(ConnectorProfileHolder connector_profile)
[CORBA interface] Port の接続を行う
{@.ja 与えられた ConnectoionProfile の情報に基づき、Port間の接続を確立
する。
|
java.util.Vector<OutPortConnector> |
connectors()
Connector を取得
現在所有しているコネクタを取得する。
|
protected OutPortConnector |
createConnector(ConnectorProfileHolder cprof,
Properties prop,
InPortConsumer consumer)
OutPortPushConnector の生成
|
protected OutPortConnector |
createConnector(ConnectorProfileHolder cprof,
Properties prop,
OutPortProvider provider)
OutPortPullConnector の生成
|
protected InPortConsumer |
createConsumer(ConnectorProfileHolder cprof,
Properties prop)
InPort consumer の生成
|
protected OutPortProvider |
createProvider(ConnectorProfileHolder cprof,
Properties prop)
OutPort provider の生成
|
void |
deactivateInterfaces()
全ての Port のインターフェースを deactivates する
Port に登録されている全てのインターフェースを deactivate する。
|
OutPortConnector |
getConnectorById(java.lang.String id)
ConnectorProfileをIDで取得
現在所有しているコネクタをIDで取得する。
|
(package private) OutPortConnector |
getConnectorByName(java.lang.String name)
ConnectorProfileを名前で取得
現在所有しているコネクタを名前で取得する。
|
java.util.Vector<java.lang.String> |
getConnectorIds()
ConnectorId を取得
現在所有しているコネクタのIDを取得する。
|
java.util.Vector<java.lang.String> |
getConnectorNames()
Connectorの名前を取得
現在所有しているコネクタの名前を取得する。
|
boolean |
getConnectorProfileById(java.lang.String id,
ConnectorBase.ConnectorInfoHolder profh)
ConnectorProfileをnameで取得
現在所有しているコネクタをIDで取得する。
|
boolean |
getConnectorProfileByName(java.lang.String name,
ConnectorBase.ConnectorInfoHolder profh)
ConnectorProfileを名前で取得
現在所有しているコネクタを名前で取得する。
|
java.util.Vector<ConnectorBase.ConnectorInfo> |
getConnectorProfiles()
ConnectorProfile を取得
現在所有しているコネクタのProfileを取得する。
|
void |
init(Properties prop)
プロパティの初期化
指定されたプロパティで初期化する。
|
protected void |
initConsumers()
InPort consumer の初期化
|
protected void |
initProviders()
OutPort provider の初期化
|
boolean |
isLittleEndian()
endian 情報を返す
|
void |
onConnect(java.lang.String id,
PublisherBase publisher)
onConnect
|
void |
onDisconnect(java.lang.String id)
onDisconenct
|
Properties |
properties()
プロパティを取得する
ポートのプロパティを取得する。
|
protected ReturnCode_t |
publishInterfaces(ConnectorProfileHolder cprof)
Interface 情報を公開する
{@.ja このオペレーションは、notify_connect() 処理シーケンスの始めにコール
される純粋仮想関数である。
|
void |
removeConnectorDataListener(int type,
ConnectorDataListenerT listener)
ConnectorDataListener リスナを削除する
設定した各種リスナを削除する。
|
void |
removeConnectorListener(int type,
ConnectorListener listener)
@brief ConnectorDataListener リスナを削除する
設定した各種リスナを削除する。
|
protected ReturnCode_t |
subscribeInterfaces(ConnectorProfileHolder cprof)
Interface に接続する
{@.ja このオペレーションは、notify_connect() 処理シーケンスの中間にコール
される純粋仮想関数である。
|
protected void |
unsubscribeInterfaces(ConnectorProfile connector_profile)
Interfaceへの接続を解除する
{@.ja Interfaceへの接続を解除する。
|
abstract boolean |
write()
データ書き込み
{@.ja ポートへデータを書き込む。
|
_publishInterfaces, _this, addProperty, appendInterface, appendProperty, checkPorts, connectNext, deleteInterface, disconnect_all, disconnect, disconnectNext, eraseConnectorProfile, findConnProfile, findConnProfileIndex, get_connector_profile, get_connector_profiles, get_port_profile, getName, getPortProfile, getPortRef, getProfile, getUUID, isEmptyId, isExistingConnId, notify_connect, notify_disconnect, onConnected, onConnectNextport, onDisconnected, onDisconnectNextport, onNotifyConnect, onNotifyDisconnect, onPublishInterfaces, onSubscribeInterfaces, onUnsubscribeInterfaces, setConnectionLimit, setName, setOnConnected, setOnConnectionLost, setOnDisconnected, setOnPublishInterfaces, setOnSubscribeInterfaces, setOnUnsubscribeInterfaces, setOwner, setPortConnectListenerHolder, setPortRef, setUUID, updateConnectorProfile, updateConnectors
_all_interfaces, _invoke, _this
protected java.util.List<OutPortBase.Publisher> m_publishers
protected Properties m_properties
protected java.util.Vector<OutPortConnector> m_connectors
protected java.util.Vector<java.lang.String> m_providerTypes
protected java.util.Vector<java.lang.String> m_consumerTypes
protected ConnectorListeners m_listeners
public OutPortBase(java.lang.String name, java.lang.String data_type)
name
- ポート名称
data_type
- データタイプ
public void init(Properties prop)
指定されたプロパティで初期化する。
prop
- 設定するプロパティ
public abstract boolean write()
ポートへデータを書き込む。 バインドされた変数に設定された値をポートに書き込む。
public Properties properties()
ポートのプロパティを取得する。
public final java.util.Vector<OutPortConnector> connectors()
現在所有しているコネクタを取得する。
public java.util.Vector<ConnectorBase.ConnectorInfo> getConnectorProfiles()
現在所有しているコネクタのProfileを取得する。
public java.util.Vector<java.lang.String> getConnectorIds()
現在所有しているコネクタのIDを取得する。
public java.util.Vector<java.lang.String> getConnectorNames()
現在所有しているコネクタの名前を取得する。
public OutPortConnector getConnectorById(java.lang.String id)
現在所有しているコネクタをIDで取得する。
id
- Connector ID
OutPortConnector getConnectorByName(java.lang.String name)
現在所有しているコネクタを名前で取得する。
name
- Connector name
public boolean getConnectorProfileById(java.lang.String id, ConnectorBase.ConnectorInfoHolder profh)
現在所有しているコネクタをIDで取得する。
id
- Connector ID
profh
- ConnectorInfoHolder
public boolean getConnectorProfileByName(java.lang.String name, ConnectorBase.ConnectorInfoHolder profh)
現在所有しているコネクタを名前で取得する。
name
- Connector name
profh
- ConnectorInfoHolder
public void onConnect(java.lang.String id, PublisherBase publisher)
onConnect
public void onDisconnect(java.lang.String id)
onDisconenct
public ReturnCode_t connect(ConnectorProfileHolder connector_profile)
与えられた ConnectoionProfile の情報に基づき、Port間の接続を確立 する。この関数は主にアプリケーションプログラムやツールから呼び出 すことを前提としている。
connect
インタフェース内 PortServiceOperations
connect
クラス内 PortBase
connector_profile
- ConnectorProfile
protected ReturnCode_t publishInterfaces(ConnectorProfileHolder cprof)
このオペレーションは、notify_connect() 処理シーケンスの始めにコール される純粋仮想関数である。 notify_connect() では、
publishInterfaces
クラス内 PortBase
cprof
- 接続に関するプロファイル情報
protected ReturnCode_t subscribeInterfaces(ConnectorProfileHolder cprof)
このオペレーションは、notify_connect() 処理シーケンスの中間にコール される純粋仮想関数である。 notify_connect() では、
subscribeInterfaces
クラス内 PortBase
cprof
- 接続に関するプロファイル情報
protected void unsubscribeInterfaces(ConnectorProfile connector_profile)
Interfaceへの接続を解除する。 与えられたConnectorProfileに関連するConsumerに設定された全てのObjectを 解放し接続を解除する。
unsubscribeInterfaces
クラス内 PortBase
connector_profile
- コネクタ・プロファイル
public void activateInterfaces()
Port に登録されている全てのインターフェースを activate する。
activateInterfaces
クラス内 PortBase
public void deactivateInterfaces()
Port に登録されている全てのインターフェースを deactivate する。
deactivateInterfaces
クラス内 PortBase
public void addConnectorDataListener(int type, ConnectorDataListenerT listener, boolean autoclean)
バッファ書き込みまたは読み出しイベントに関連する各種リスナを設定する。 設定できるリスナのタイプとコールバックイベントは以下の通り
ConnectorDataListener::
operator()(const ConnectorProfile&, const cdrStream&)
デフォルトでは、この関数に与えたリスナオブジェクトの所有権は
OutPortに移り、OutPort解体時もしくは、
removeConnectorDataListener() により削除時に自動的に解体される。
リスナオブジェクトの所有権を呼び出し側で維持したい場合は、第3引
数に false を指定し、自動的な解体を抑制することができる。}
type
- リスナタイプ
listener
- リスナオブジェクトへのポインタ
autoclean
- リスナオブジェクトの自動的解体を行うかどうかのフラグ
public void addConnectorDataListener(int type, ConnectorDataListenerT listener)
バッファ書き込みまたは読み出しイベントに関連する各種リスナを設定する。 設定できるリスナのタイプとコールバックイベントは以下の通り
ConnectorDataListener::
operator()(const ConnectorProfile&, const cdrStream&)
デフォルトでは、この関数に与えたリスナオブジェクトの所有権は
OutPortに移り、OutPort解体時もしくは、
removeConnectorDataListener() により削除時に自動的に解体される。}
type
- リスナタイプ
listener
- リスナオブジェクトへのポインタ
public void removeConnectorDataListener(int type, ConnectorDataListenerT listener)
設定した各種リスナを削除する。
type
- リスナタイプ
listener
- リスナオブジェクトへのポインタ
public void addConnectorListener(int type, ConnectorListener listener, boolean autoclean)
バッファ書き込みまたは読み出しイベントに関連する各種リスナを 設定する。 設定できるリスナのタイプは
ConnectorListener::operator()(const ConnectorProfile&)
デフォルトでは、この関数に与えたリスナオブジェクトの所有権は
OutPortに移り、OutPort解体時もしくは、
removeConnectorListener() により削除時に自動的に解体される。
リスナオブジェクトの所有権を呼び出し側で維持したい場合は、第3引
数に false を指定し、自動的な解体を抑制することができる。
type
- リスナタイプ
listener
- リスナオブジェクトへのポインタ
autoclean
- リスナオブジェクトの自動的解体を行うかどうかのフラグ
public void addConnectorListener(int type, ConnectorListener listener)
バッファ書き込みまたは読み出しイベントに関連する各種リスナを 設定する。 設定できるリスナのタイプは
ConnectorListener::operator()(const ConnectorProfile&)
デフォルトでは、この関数に与えたリスナオブジェクトの所有権は
OutPortに移り、OutPort解体時もしくは、
removeConnectorListener() により削除時に自動的に解体される。
type
- リスナタイプ
listener
- リスナオブジェクトへのポインタ
public void removeConnectorListener(int type, ConnectorListener listener)
設定した各種リスナを削除する。
type
- リスナタイプ
listener
- リスナオブジェクトへのポインタ
protected void configure()
propertiesの情報に基づきOutPortの各種設定を行う
protected void initProviders()
protected void initConsumers()
protected OutPortProvider createProvider(ConnectorProfileHolder cprof, Properties prop)
protected InPortConsumer createConsumer(ConnectorProfileHolder cprof, Properties prop)
protected OutPortConnector createConnector(ConnectorProfileHolder cprof, Properties prop, InPortConsumer consumer)
protected OutPortConnector createConnector(ConnectorProfileHolder cprof, Properties prop, OutPortProvider provider)
public boolean isLittleEndian()