public class PublisherNew extends PublisherBase implements java.lang.Runnable, ObjectCreator<PublisherBase>, ObjectDestructor
データ送出タイミングを待つコンシューマを、送出する側とは異なるスレッドで動作させる場合に使用します。
Publisherの駆動は、データ送出のタイミングになるまでブロックされ、送出タイミングの通知を受けると、 即座にコンシューマの送出処理を呼び出します。
Modifier and Type | Class and Description |
---|---|
protected static class |
PublisherNew.Policy |
Constructor and Description |
---|
PublisherNew()
Constructor
|
Modifier and Type | Method and Description |
---|---|
ReturnCode |
activate()
activate
|
protected ReturnCode |
convertReturn(ReturnCode status,
org.omg.CORBA.portable.OutputStream data)
convertReturn
|
protected boolean |
createTask(Properties prop)
Setting Task
|
PublisherBase |
creator_()
creator_
|
ReturnCode |
deactivate()
deactivate
|
void |
destructor_(java.lang.Object obj)
destructor_
|
java.lang.String |
getName()
getName
|
ReturnCode |
init(Properties prop)
init
|
protected ReturnCode |
invokeListener(ReturnCode status,
org.omg.CORBA.portable.OutputStream data) |
boolean |
isActive()
write
|
protected void |
onBufferFull(org.omg.CORBA.portable.OutputStream data) |
protected void |
onBufferRead(org.omg.CORBA.portable.OutputStream data) |
protected void |
onBufferWriteOverwrite(org.omg.CORBA.portable.OutputStream data) |
protected void |
onBufferWriteTimeout(org.omg.CORBA.portable.OutputStream data) |
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) |
protected void |
onSenderError()
Connector listener functions
|
int |
open(java.lang.Object[] args)
当該Publisherの駆動を開始します。
|
static void |
PublisherNewInit()
PublisherNewInit
|
protected ReturnCode |
pushAll()
pushAll
|
protected ReturnCode |
pushFifo()
pushFifo
|
protected ReturnCode |
pushNew()
pushNew
|
protected ReturnCode |
pushSkip()
pushSkip
|
void |
release()
駆動フラグがオフとなり、Publisherの駆動が停止します。
|
void |
run()
当該Publisherオブジェクトのスレッドコンテキストです。
送出タイミングが通知されるまでブロックします。
|
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
|
protected void |
setPushPolicy(Properties prop)
Setting PushPolicy
|
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 data
|
protected Logbuf rtcout
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 int open(java.lang.Object[] args)
当該Publisherの駆動を開始します。
args
- (本Publisherでは使用されません。)public void release()
駆動フラグがオフとなり、Publisherの駆動が停止します。
ただし、すでに駆動スレッドがブロックされている場合には、 最大1回のみコンシューマの送出処理が呼び出されることがあります。
release
in class PublisherBase
public void run()
当該Publisherオブジェクトのスレッドコンテキストです。 送出タイミングが通知されるまでブロックします。
run
in interface java.lang.Runnable
public ReturnCode init(Properties prop)
init
initialization
init
in class PublisherBase
prop
- protected void setPushPolicy(Properties prop)
Setting PushPolicy
prop
- Propertiesprotected boolean createTask(Properties prop)
Setting Task
prop
- Propertiespublic ReturnCode setConsumer(InPortConsumer consumer)
setConsumer
Store InPort consumer
setConsumer
in class PublisherBase
consumer
- public ReturnCode setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer)
setBuffer
Setting buffer
setBuffer
in class PublisherBase
buffer
- public ReturnCode setListener(ConnectorBase.ConnectorInfo info, ConnectorListeners listeners)
Setting buffer pointer
setListener
in class PublisherBase
public ReturnCode write(org.omg.CORBA.portable.OutputStream data, int sec, int usec)
This function writes data into the buffer associated with this Publisher. If a Publisher object calls this function, without initializing correctly such as a consumer, a buffer, listeners, etc., error code PRECONDITION_NOT_MET will be returned and no operation of the writing to a buffer etc. will be performed. Since writing into the buffer and sending data to InPort are performed asynchronously, occasionally this function returns return-codes such as CONNECTION_LOST and BUFFER_FULL that indicate the result of sending data to InPort. In this case, writing data into buffer will not be performed. When publisher writes data to the buffer, if the buffer is filled, returns error, is returned with timeout and returns precondition error, error codes BUFFER_FULL, BUFFER_ERROR, BUFFER_TIMEOUT and PRECONDITION_NOT_MET will be returned respectively. In other cases, PROT_ERROR will be returned.
write
in class PublisherBase
data
-
Data to be wrote to the buffersec
-
Timeout time in unit secondsusec
-
Timeout time in unit micor-secondspublic ReturnCode write(org.omg.CORBA.portable.OutputStream data)
write
in class PublisherBase
public boolean isActive()
write
isActive
in class PublisherBase
public ReturnCode activate()
activate
activate
in class PublisherBase
public ReturnCode deactivate()
deactivate
deactivate
in class PublisherBase
public PublisherBase creator_()
creator_
creator_
in interface ObjectCreator<PublisherBase>
public void destructor_(java.lang.Object obj)
destructor_
destructor_
in interface ObjectDestructor
obj
- The target instances for destructionpublic static void PublisherNewInit()
PublisherNewInit
protected ReturnCode convertReturn(ReturnCode status, org.omg.CORBA.portable.OutputStream data)
convertReturn
protected ReturnCode invokeListener(ReturnCode status, org.omg.CORBA.portable.OutputStream data)
public java.lang.String getName()
getName
getName
in class PublisherBase
protected void onBufferFull(org.omg.CORBA.portable.OutputStream data)
protected void onBufferWriteTimeout(org.omg.CORBA.portable.OutputStream data)
protected void onBufferWriteOverwrite(org.omg.CORBA.portable.OutputStream data)
protected void onBufferRead(org.omg.CORBA.portable.OutputStream data)
protected void onSend(org.omg.CORBA.portable.OutputStream data)
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)
protected void onSenderError()
Connector listener functions