public class InPortPushConnector extends InPortConnector
ConnectorBase.ConnectorInfo, ConnectorBase.ConnectorInfoHolder
m_buffer, m_isLittleEndian, m_orb, m_profile, rtcout
コンストラクタと説明 |
---|
InPortPushConnector(ConnectorBase.ConnectorInfo profile,
InPortProvider provider,
ConnectorListeners listeners,
BufferBase<org.omg.CORBA.portable.OutputStream> buffer)
コンストラクタ
{@.ja InPortPushConnector のコンストラクタはオブジェクト生成時に下記を
引数にとる。
|
修飾子とタイプ | メソッドと説明 |
---|---|
void |
activate()
アクティブ化
このコネクタをアクティブ化する
|
protected ReturnCode |
convertReturn(ReturnCode status)
buffer.ReturnCodeをport.ReturnCodeに変換する。
|
protected BufferBase<org.omg.CORBA.portable.OutputStream> |
createBuffer(ConnectorBase.ConnectorInfo profile)
Bufferの生成
与えられた接続情報に基づきバッファを生成する。
|
void |
deactivate()
非アクティブ化
このコネクタを非アクティブ化する
|
ReturnCode |
disconnect()
接続解除
consumer, publisher, buffer が解体・削除される。
|
protected void |
onConnect()
接続確立時にコールバックを呼ぶ
|
protected void |
onDisconnect()
接続切断時にコールバックを呼ぶ
|
ReturnCode |
read(DataRef<org.omg.CORBA.portable.InputStream> data)
データの読み出し
{@.ja バッファからデータを読み出す。
|
void |
setListener(ConnectorBase.ConnectorInfo profile,
ConnectorListeners listeners)
リスナを設定する。
|
getBuffer, id, isLittleEndian, name, profile, setEndian
public InPortPushConnector(ConnectorBase.ConnectorInfo profile, InPortProvider provider, ConnectorListeners listeners, BufferBase<org.omg.CORBA.portable.OutputStream> buffer) throws java.lang.Exception
InPortPushConnector のコンストラクタはオブジェクト生成時に下記を 引数にとる。ConnectorInfo は接続情報を含み、この情報に従いバッファ 等を生成する。InPort インターフェースのプロバイダオブジェクトへ のポインタを取り、所有権を持つので、InPortPushConnector は InPortProvider の解体責任を持つ。各種イベントに対するコールバッ ク機構を提供する ConnectorListeners を持ち、適切なタイミングでコー ルバックを呼び出す。データバッファがもし InPortBase から提供され る場合はそのポインタを取る。
profile
- ConnectorInfo
provider
- InPortProvider
listeners
- ConnectorListeners 型のリスナオブジェクトリスト
buffer
- CdrBufferBase 型のバッファ
java.lang.Exception
public void setListener(ConnectorBase.ConnectorInfo profile, ConnectorListeners listeners)
InPortConnector
setListener
クラス内 InPortConnector
profile
- 接続情報
listeners
- リスナオブジェクト
public ReturnCode read(DataRef<org.omg.CORBA.portable.InputStream> data)
バッファからデータを読み出す。正常に読み出せた場合、戻り値は PORT_OK となり、data に読み出されたデータが格納される。それ以外 の場合には、エラー値として BUFFER_EMPTY, TIMEOUT, PRECONDITION_NOT_MET, PORT_ERROR が返される。
read
クラス内 InPortConnector
public ReturnCode disconnect()
consumer, publisher, buffer が解体・削除される。
disconnect
クラス内 InPortConnector
public void activate()
このコネクタをアクティブ化する
activate
クラス内 ConnectorBase
public void deactivate()
このコネクタを非アクティブ化する
deactivate
クラス内 ConnectorBase
protected BufferBase<org.omg.CORBA.portable.OutputStream> createBuffer(ConnectorBase.ConnectorInfo profile)
与えられた接続情報に基づきバッファを生成する。
profile
- 接続情報
protected void onConnect()
protected void onDisconnect()
protected ReturnCode convertReturn(ReturnCode status)
status
- jp.go.aist.rtm.RTC.buffer.ReturnCode