Class SyncBlockingMessagePumper.MessageBufferWorker
Inheritance
System.Object
SyncBlockingMessagePumper.MessageBufferWorker
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: FixAntenna.FixEngine.Session.IOThreads
Assembly: FixAntenna.Core.dll
Syntax
public class MessageBufferWorker
Constructors
MessageBufferWorker(SyncBlockingMessagePumper, Int32)
Declaration
public MessageBufferWorker(SyncBlockingMessagePumper outerInstance, int maxMessagesInBatch)
Parameters
Type | Name | Description |
---|---|---|
SyncBlockingMessagePumper | outerInstance | |
System.Int32 | maxMessagesInBatch |
Methods
GetBuffer()
Declaration
public virtual ByteBuffer GetBuffer()
Returns
Type | Description |
---|---|
ByteBuffer |
GetCounter()
Declaration
public virtual int GetCounter()
Returns
Type | Description |
---|---|
System.Int32 |
GetFullLength()
Declaration
public virtual int GetFullLength()
Returns
Type | Description |
---|---|
System.Int32 |
GetLength(Int32)
Declaration
public virtual int GetLength(int position)
Parameters
Type | Name | Description |
---|---|---|
System.Int32 | position |
Returns
Type | Description |
---|---|
System.Int32 |
GetOffset()
Declaration
public virtual int GetOffset()
Returns
Type | Description |
---|---|
System.Int32 |
GetStartOffset(Int32)
Declaration
public virtual int GetStartOffset(int position)
Parameters
Type | Name | Description |
---|---|---|
System.Int32 | position |
Returns
Type | Description |
---|---|
System.Int32 |
IncrementCounter()
Declaration
public virtual void IncrementCounter()
MarkEndOffset()
Declaration
public virtual void MarkEndOffset()
MarkStartOffset()
Declaration
public virtual void MarkStartOffset()
ResetBuffer()
Declaration
public virtual void ResetBuffer()