|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectjp.go.aist.rtm.RTC.port.publisher.PublisherBase
jp.go.aist.rtm.RTC.port.publisher.PublisherFlush
public class PublisherFlush
データ送出を待つコンシューマを、送出する側と同じスレッドで動作させる場合に使用します。
フィールドの概要 | |
---|---|
protected Logbuf |
rtcout
|
コンストラクタの概要 | |
---|---|
PublisherFlush()
Constructor |
メソッドの概要 | |
---|---|
ReturnCode |
activate()
activate |
PublisherBase |
creator_()
creator_ |
ReturnCode |
deactivate()
deactivate |
void |
destruct()
当該Publisherが不要となり破棄される際に、PublisherFactoryにより呼び出されます。 |
void |
destructor_(java.lang.Object obj)
destructor_ |
protected void |
finalize()
ファイナライザです。 |
java.lang.String |
getName()
getName |
ReturnCode |
init(Properties prop)
init |
boolean |
isActive()
write |
protected void |
onReceived(org.omg.CORBA.portable.OutputStream data)
|
protected void |
onReceiverError(org.omg.CORBA.portable.OutputStream data)
|
protected void |
onReceiverFull(org.omg.CORBA.portable.OutputStream data)
|
protected void |
onReceiverTimeout(org.omg.CORBA.portable.OutputStream data)
|
protected void |
onSend(org.omg.CORBA.portable.OutputStream data)
Connector data listener functions |
static void |
PublisherFlushInit()
PublisherFlushInit |
ReturnCode |
setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer)
setBuffer |
ReturnCode |
setConsumer(InPortConsumer consumer)
setConsumer |
ReturnCode |
setListener(ConnectorBase.ConnectorInfo info,
ConnectorListeners listeners)
Setting buffer pointer |
ReturnCode |
write(org.omg.CORBA.portable.OutputStream data)
|
ReturnCode |
write(org.omg.CORBA.portable.OutputStream data,
int sec,
int usec)
Write data |
クラス jp.go.aist.rtm.RTC.port.publisher.PublisherBase から継承されたメソッド |
---|
release |
クラス java.lang.Object から継承されたメソッド |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
フィールドの詳細 |
---|
protected Logbuf rtcout
コンストラクタの詳細 |
---|
public PublisherFlush()
メソッドの詳細 |
---|
public void destruct()
当該Publisherが不要となり破棄される際に、PublisherFactoryにより呼び出されます。
protected void finalize() throws java.lang.Throwable
ファイナライザです。
java.lang.Object
内の finalize
java.lang.Throwable
public ReturnCode init(Properties prop)
init
initialization
PublisherBase
内の init
prop
-
public ReturnCode setConsumer(InPortConsumer consumer)
setConsumer
Store InPort consumer
PublisherBase
内の setConsumer
consumer
-
public ReturnCode setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer)
setBuffer
Setting buffer
PublisherBase
内の setBuffer
buffer
-
public ReturnCode setListener(ConnectorBase.ConnectorInfo info, ConnectorListeners listeners)
Setting buffer pointer
PublisherBase
内の setListener
public ReturnCode write(org.omg.CORBA.portable.OutputStream data, int sec, int usec)
This function writes data into the consumer associated with this Publisher. If this function is called without initializing correctly such as a consumer, listeners, etc., error code PRECONDITION_NOT_MET will be returned and no operation of the writing to the consumer etc. will be performed. When publisher writes data to the buffer, if the consumer returns full-status, returns error, is returned with timeout, error codes BUFFER_FULL, BUFFER_ERROR and BUFFER_TIMEOUT will be returned respectively. In other cases, PROT_ERROR will be returned.
PublisherBase
内の write
data
-
Data to be wrote to the buffersec
-
Timeout time in unit secondsusec
-
Timeout time in unit micro-seconds
public ReturnCode write(org.omg.CORBA.portable.OutputStream data)
PublisherBase
内の write
public boolean isActive()
write
PublisherBase
内の isActive
public ReturnCode activate()
activate
PublisherBase
内の activate
public ReturnCode deactivate()
deactivate
PublisherBase
内の deactivate
public PublisherBase creator_()
creator_
ObjectCreator<PublisherBase>
内の creator_
public void destructor_(java.lang.Object obj)
destructor_
ObjectDestructor
内の destructor_
obj
- The target instances for destructionpublic static void PublisherFlushInit()
PublisherFlushInit
public java.lang.String getName()
getName
PublisherBase
内の getName
protected void onSend(org.omg.CORBA.portable.OutputStream data)
Connector data listener functions
protected void onReceived(org.omg.CORBA.portable.OutputStream data)
protected void onReceiverFull(org.omg.CORBA.portable.OutputStream data)
protected void onReceiverTimeout(org.omg.CORBA.portable.OutputStream data)
protected void onReceiverError(org.omg.CORBA.portable.OutputStream data)
|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |