Package com._1c.g5.v8.dt.internal.pm.connection.mmf

Class ByteBufferIpcMessageProvider

java.lang.Object

com._1c.g5.v8.dt.internal.pm.connection.mmf.ByteBufferIpcMessageProvider

public class ByteBufferIpcMessageProvider
extends Object

Reads IpcMessages from ByteBuffer using IpcMessageBuilder.

Constructor Summary

Constructors

Constructor	Description
ByteBufferIpcMessageProvider(ByteBuffer buffer, Lock bufferLock)	Constructs new instance with given ByteBuffer and Lock.

Method Summary

Modifier and Type	Method	Description
IpcMessage	getNextMessage()	Provides the next message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ByteBufferIpcMessageProvider

public ByteBufferIpcMessageProvider(ByteBuffer buffer,
 Lock bufferLock)

Constructs new instance with given ByteBuffer and Lock.

Parameters:

buffer - given ByteBuffer, which is appended to IpcMessageBuilder to build message (not null)

bufferLock - given lock, used to controll access to given ByteBuffer. IpcMessageBuilder.append(ByteBuffer) with given ByteBuffer is called between Lock.lockInterruptibly() and Lock.unlock() on given lock. Not null.

Method Details

getNextMessage

public IpcMessage getNextMessage()
                          throws InterruptedException

Provides the next message.

Creates new instance of IpcMessageBuilder, then until IpcMessageBuilder.isCompleted(), between Lock.lock() and Lock.unlock() calls IpcMessageBuilder.append(ByteBuffer). Those ByteBuffer and Lock are passed to ByteBufferIpcMessageProvider(ByteBuffer, Lock).

Blocks until all packets of message obtained from buffer.

Returns:

resulting message (not null)

Throws:

InterruptedException - if Lock.lockInterruptibly() throws InterruptedException