|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectjp.go.aist.rtm.RTC.port.publisher.PublisherBase
jp.go.aist.rtm.RTC.port.publisher.PublisherPeriodic
public class PublisherPeriodic
一定時間おきにコンシューマの送出処理を呼び出すPublisherです。
入れ子のクラスの概要 | |
---|---|
protected static class |
PublisherPeriodic.Policy
|
フィールドの概要 | |
---|---|
protected Logbuf |
rtcout
|
コンストラクタの概要 | |
---|---|
PublisherPeriodic()
コンストラクタです。 |
メソッドの概要 | |
---|---|
ReturnCode |
activate()
activate |
protected ReturnCode |
convertReturn(ReturnCode status)
convertReturn |
PublisherBase |
creator_()
creator_ |
ReturnCode |
deactivate()
deactivate |
void |
destructor_(java.lang.Object obj)
destructor_ |
java.lang.String |
getName()
getName |
ReturnCode |
init(Properties prop)
init initialization |
boolean |
isActive()
write |
int |
open()
当該Publisherの駆動を開始します。 |
static void |
PublisherPeriodicInit()
PublisherPeriodicInit |
protected ReturnCode |
pushAll()
pushAll push all policy |
protected ReturnCode |
pushFifo()
pushFifo push "fifo" policy |
protected ReturnCode |
pushNew()
pushNew push "new" policy |
protected ReturnCode |
pushSkip()
pushSkip push "skip" policy |
void |
release()
駆動フラグがオフとなり、Publisherの駆動が停止します。 |
void |
run()
当該Publisherを駆動するスレッドコンテキストです。 |
ReturnCode |
setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer)
setBuffer Setting buffer |
ReturnCode |
setConsumer(InPortConsumer consumer)
setConsumer Store InPort consumer |
int |
svc()
当該Publisherを駆動するスレッドコンテキストです。 |
void |
update()
本Publisher実装では、何も行いません。 |
ReturnCode |
write(org.omg.CORBA.portable.OutputStream data)
|
ReturnCode |
write(org.omg.CORBA.portable.OutputStream data,
int sec,
int usec)
write |
クラス java.lang.Object から継承されたメソッド |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
フィールドの詳細 |
---|
protected Logbuf rtcout
コンストラクタの詳細 |
---|
public PublisherPeriodic()
コンストラクタです。
送出処理の呼び出し間隔を、Propertyオブジェクトのdataport.push_rateメンバに 設定しておく必要があります。間隔は、Hz単位の浮動小数文字列で指定します。 たとえば、1000.0Hzの場合は、「1000.0」を設定します。
メソッドの詳細 |
---|
public void update()
本Publisher実装では、何も行いません。
public int svc()
当該Publisherを駆動するスレッドコンテキストです。コンシューマの送出処理が呼び出されます。
protected ReturnCode pushAll()
pushAll
push all policy
protected ReturnCode pushFifo()
pushFifo
push "fifo" policy
protected ReturnCode pushSkip()
pushSkip
push "skip" policy
protected ReturnCode pushNew()
pushNew
push "new" policy
public void run()
当該Publisherを駆動するスレッドコンテキストです。コンシューマの送出処理が呼び出されます。
java.lang.Runnable
内の run
public int open()
当該Publisherの駆動を開始します。
public void release()
駆動フラグがオフとなり、Publisherの駆動が停止します。
ただし、最大1回のみコンシューマの送出処理が呼び出されることがあります。
PublisherBase
内の release
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 write(org.omg.CORBA.portable.OutputStream data, int sec, int usec)
write
PublisherBase
内の write
data
- sec
- usec
-
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 destructionprotected ReturnCode convertReturn(ReturnCode status)
convertReturn
public static void PublisherPeriodicInit()
PublisherPeriodicInit
public java.lang.String getName()
getName
PublisherBase
内の getName
|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |