Class SlicedFileMessageStorage

Inheritance

System.Object

AbstractFileMessageStorage

FlatFileMessageStorage

SlicedFileMessageStorage

SlicedIndexedMessageStorage

Implements

IMessageStorage

System.IDisposable

Inherited Members

FlatFileMessageStorage.Delta

FlatFileMessageStorage.WriteBufferLengthDef

FlatFileMessageStorage.NewLine

FlatFileMessageStorage.ChannelLength

FlatFileMessageStorage.ChannelPosition

FlatFileMessageStorage.DateFormattedBuffer

FlatFileMessageStorage.MaxStorageGrowSize

FlatFileMessageStorage.StorageGrowSize

FlatFileMessageStorage.TimestampTicks

FlatFileMessageStorage.IsTimestampEnabled

FlatFileMessageStorage.RawTags

FlatFileMessageStorage.MaskedTags

FlatFileMessageStorage.OpenStorageFile()

FlatFileMessageStorage.RetrieveMessagesImplementation(Int64, Int64, IMessageStorageListener, Boolean)

FlatFileMessageStorage.GetNextSequenceNumber()

FlatFileMessageStorage.AppendMessage(Byte[], Byte[], Int32, Int32)

FlatFileMessageStorage.AppendMessage(Byte[], Byte[])

FlatFileMessageStorage.AppendMessageInternal(Byte[], Byte[], Int32, Int32)

FlatFileMessageStorage.RetrieveSequenceNumber(String)

FlatFileMessageStorage.Close()

AbstractFileMessageStorage.FormatLength

AbstractFileMessageStorage.Disposed

AbstractFileMessageStorage.AccessFile

AbstractFileMessageStorage.Configuration

AbstractFileMessageStorage.StorageTimestamp

AbstractFileMessageStorage.RetrieveMessages(Int64, Int64, IMessageStorageListener, Boolean)

AbstractFileMessageStorage.RetrieveMessage(Int64)

AbstractFileMessageStorage.AppendMessage(Byte[])

AbstractFileMessageStorage.AppendMessage(Byte[], Int32, Int32)

AbstractFileMessageStorage.BackupStorage(SessionParameters)

AbstractFileMessageStorage.CalculateFormatLength()

AbstractFileMessageStorage.GetPrefixFormat(Int64)

AbstractFileMessageStorage.GetFile()

AbstractFileMessageStorage.SetFile(String)

AbstractFileMessageStorage.SetBackupFileLocator(ILogFileLocator)

AbstractFileMessageStorage.Initialized()

AbstractFileMessageStorage.OpenStorage()

AbstractFileMessageStorage.NotifyListener(IMessageStorageListener, Boolean, Byte[])

AbstractFileMessageStorage.BackupFile(String, String)

AbstractFileMessageStorage.DeleteFile(String)

AbstractFileMessageStorage.IsClosed()

AbstractFileMessageStorage.Dispose()

AbstractFileMessageStorage.Dispose(Boolean)

AbstractFileMessageStorage.VerifyNotDisposed()

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.Storage.File

Assembly: FixAntenna.Core.dll

Syntax

public class SlicedFileMessageStorage : FlatFileMessageStorage, IMessageStorage, IDisposable

Constructors

SlicedFileMessageStorage(Config)

Declaration

public SlicedFileMessageStorage(Config config)

Parameters

Type	Name	Description
Config	config

Fields

FileManager

Declaration

protected SlicedFileManager FileManager

Field Value

Type	Description
SlicedFileManager

MaxFileSize

Declaration

protected long MaxFileSize

Field Value

Type	Description
System.Int64

Methods

AppendMessageInternal(Int64, Byte[], Int32, Int32)

Appends message to storage

Declaration

protected override long AppendMessageInternal(long timestamp, byte[] message, int offset, int length)

Parameters

Type	Name	Description
System.Int64	timestamp
System.Byte[]	message	the array of bytes
System.Int32	offset
System.Int32	length

Returns

Type	Description
System.Int64

Overrides

FlatFileMessageStorage.AppendMessageInternal(Int64, Byte[], Int32, Int32)

Exceptions

Type	Condition
System.IO.IOException	if I/O error occurred

BackupStorageFile(String, String)

Backups storage file.

Declaration

public override void BackupStorageFile(string fullPathToStorageFile, string fullPathToDestinationBackupFile)

Parameters

Type	Name	Description
System.String	fullPathToStorageFile	the path to file of in/out file
System.String	fullPathToDestinationBackupFile	the destination place to backup file

Overrides

AbstractFileMessageStorage.BackupStorageFile(String, String)

DeleteStorageFile(String)

Deletes storage file.

Declaration

public override void DeleteStorageFile(string fullPathToStorageFile)

Parameters

Type	Name	Description
System.String	fullPathToStorageFile	the path to in/out file

Overrides

AbstractFileMessageStorage.DeleteStorageFile(String)

GetMaxFileSize()

Declaration

public virtual long GetMaxFileSize()

Returns

Type	Description
System.Int64

Initialize()

Initialize the storage.
This method should be called before file storage is used. Storage file and some variable (like FormatLength) are initialized in it.

Declaration

public override long Initialize()

Returns

Type	Description
System.Int64	the last sequence number

Overrides

AbstractFileMessageStorage.Initialize()

Exceptions

Type	Condition
System.IO.IOException	if I/O error occurred

NextChunk()

Declaration

public virtual void NextChunk()

SetMaxFileSize(Int64)

Declaration

public virtual void SetMaxFileSize(long maxFileSize)

Parameters

Type	Name	Description
System.Int64	maxFileSize

Implements

IMessageStorage

System.IDisposable