public class InPortPushConnector extends InPortConnector
ConnectorBase.ConnectorInfo, ConnectorBase.ConnectorInfoHolderm_buffer, m_directOutPort, m_isLittleEndian, m_orb, m_outPortListeners, 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,
DataRef<org.omg.CORBA.portable.OutputStream> data)
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 |
onBufferEmpty() |
protected void |
onBufferRead(DataRef<org.omg.CORBA.portable.OutputStream> data) |
protected void |
onBufferReadTimeout() |
protected void |
onConnect()
接続確立時にコールバックを呼ぶ
|
protected void |
onDisconnect()
接続切断時にコールバックを呼ぶ
|
<DataType> ReturnCode |
read(DataRef<DataType> data)
データの読み出し
{@.ja バッファからデータを読み出す。
|
void |
setListener(ConnectorBase.ConnectorInfo profile,
ConnectorListeners listeners)
リスナを設定する。
|
getBuffer, id, isLittleEndian, name, profile, setEndian, setOutPortpublic 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.Exceptionpublic void setListener(ConnectorBase.ConnectorInfo profile, ConnectorListeners listeners)
InPortConnectorsetListener クラス内 InPortConnectorprofile - 接続情報
listeners - リスナオブジェクト
public <DataType> ReturnCode read(DataRef<DataType> data)
バッファからデータを読み出す。正常に読み出せた場合、戻り値は PORT_OK となり、data に読み出されたデータが格納される。それ以外 の場合には、エラー値として BUFFER_EMPTY, TIMEOUT, PRECONDITION_NOT_MET, PORT_ERROR が返される。
read クラス内 InPortConnectorpublic ReturnCode disconnect()
consumer, publisher, buffer が解体・削除される。
disconnect クラス内 InPortConnectorpublic void activate()
このコネクタをアクティブ化する
activate クラス内 ConnectorBasepublic void deactivate()
このコネクタを非アクティブ化する
deactivate クラス内 ConnectorBaseprotected BufferBase<org.omg.CORBA.portable.OutputStream> createBuffer(ConnectorBase.ConnectorInfo profile)
与えられた接続情報に基づきバッファを生成する。
profile - 接続情報
protected void onConnect()
protected void onDisconnect()
protected void onBufferRead(DataRef<org.omg.CORBA.portable.OutputStream> data)
protected void onBufferEmpty()
protected void onBufferReadTimeout()
protected ReturnCode convertReturn(ReturnCode status, DataRef<org.omg.CORBA.portable.OutputStream> data)
status - jp.go.aist.rtm.RTC.buffer.ReturnCode