Memory based message persister. More...

#include <persist.hpp>

Inheritance diagram for FIX8::MemoryPersister:

Public Member Functions
	MemoryPersister ()
	Ctor. More...

virtual	~MemoryPersister ()
	Dtor. More...

virtual F8API bool	put (const unsigned seqnum, const f8String &what)

virtual F8API bool	put (const unsigned sender_seqnum, const unsigned target_seqnum)

virtual F8API bool	get (const unsigned seqnum, f8String &to) const

virtual F8API unsigned	get (const unsigned from, const unsigned to, Session &session, bool(Session::*)(const Session::SequencePair &with, Session::RetransmissionContext &rctx)) const

virtual F8API unsigned	get_last_seqnum (unsigned &to) const

virtual F8API bool	get (unsigned &sender_seqnum, unsigned &target_seqnum) const

virtual F8API unsigned	find_nearest_highest_seqnum (const unsigned requested, const unsigned last) const

Public Member Functions inherited from FIX8::Persister
	Persister ()=default
	Ctor. More...

virtual	~Persister ()
	Dtor. More...

	Persister (const Persister &)=delete

Persister &	operator= (const Persister &)=delete

virtual bool	put (const f8String &key, const f8String &what)

virtual bool	get (const f8String &key, f8String &to) const

virtual bool	del (const f8String &key)

virtual bool	purge ()

virtual void	stop ()
	Stop the persister thread. More...

Private Types
using	Store = std::map< unsigned, const f8String >

Private Attributes
Store	_store

Additional Inherited Members
Public Types inherited from FIX8::Persister
enum	{ MaxMsgLen = FIX8_MAX_MSG_LENGTH }
	Maximum length of persisted FIX message. More...

Protected Attributes inherited from FIX8::Persister
bool	_opened = false

Detailed Description

Memory based message persister.

Definition at line 292 of file persist.hpp.

Member Typedef Documentation

using FIX8::MemoryPersister::Store = std::map<unsigned, const f8String>

private

Definition at line 294 of file persist.hpp.

Constructor & Destructor Documentation

FIX8::MemoryPersister::MemoryPersister ( )

inline

Ctor.

Definition at line 299 of file persist.hpp.

299 {}

virtual FIX8::MemoryPersister::~MemoryPersister ( )

inlinevirtual

Dtor.

Definition at line 301 of file persist.hpp.

301 {}

Member Function Documentation

unsigned MemoryPersister::find_nearest_highest_seqnum	(	const unsigned	requested,
		const unsigned	last
	)		const

virtual

Find the nearest highest sequence number from the sequence to last provided.

Parameters

requested	sequence number to start
last	highest sequence

Returns: the nearest sequence number or 0 if not found

Implements FIX8::Persister.

Definition at line 401 of file persist.cpp.

 {
    if (last)
    {
       for (unsigned startseqnum(requested); startseqnum <= last; ++startseqnum)
       {
          Store::const_iterator itr(_store.find(startseqnum));
          if (itr != _store.end())
             return itr->first;
       }
    }
 
    return 0;
 }

bool MemoryPersister::get	(	const unsigned	seqnum,
		f8String &	to
	)		const

virtual

Retrieve a persisted message.

Parameters

seqnum	sequence number of message
to	target message string

Returns: true on success

Implements FIX8::Persister.

Definition at line 389 of file persist.cpp.

 {
    if (!seqnum)
       return false;
    Store::const_iterator itr(_store.find(seqnum));
    if (itr == _store.end())
       return false;
    to = itr->second;
    return true;
 }

unsigned MemoryPersister::get	(	const unsigned	from,
		const unsigned	to,
		Session &	session,
		bool(Session::*)(const Session::SequencePair &with, Session::RetransmissionContext &rctx)	callback
	)		const

virtual

Retrieve a range of persisted messages.

Parameters

from	start at sequence number
to	end sequence number
session	session containing callback method
callback	method to call with each retrieved message

Returns: number of messages retrieved

Implements FIX8::Persister.

Definition at line 322 of file persist.cpp.

References FIX8::Session::RetransmissionContext::_no_more_records, FIX8::Session::get_next_send_seq(), glout_error, and glout_warn.

 {
    unsigned last_seq(0);
    get_last_seqnum(last_seq);
    unsigned recs_sent(0), startSeqNum(find_nearest_highest_seqnum (from, last_seq));
    const unsigned finish(to == 0 ? last_seq : to);
    Session::RetransmissionContext rctx(from, to, session.get_next_send_seq());
 
    if (!startSeqNum || from > finish)
    {
       glout_warn << "No records found";
       rctx._no_more_records = true;
       (session.*callback)(Session::SequencePair(0, ""), rctx);
       return 0;
    }
 
    Store::const_iterator itr(_store.find(startSeqNum));
    if (itr != _store.end())
    {
       do
       {
          if (!itr->first || itr->first > finish)
             break;
          Session::SequencePair result(itr->first, itr->second);
          ++recs_sent;
          if (!(session.*callback)(result, rctx))
             break;
       }
       while(++itr != _store.end());
 
       Session::SequencePair result(0, "");
       rctx._no_more_records = true;
       (session.*callback)(result, rctx);
    }
    else
       glout_error << "record not found (" << startSeqNum << ')';
 
    return recs_sent;
 }

bool MemoryPersister::get	(	unsigned &	sender_seqnum,
		unsigned &	target_seqnum
	)		const

virtual

Retrieve a sequence control record.

Parameters

sender_seqnum	sequence number of last sent message
target_seqnum	sequence number of last received message

Returns: true on success

Implements FIX8::Persister.

Definition at line 377 of file persist.cpp.

 {
    Store::const_iterator itr(_store.find(0));
    if (itr == _store.end())
       return false;
    const unsigned *loc(reinterpret_cast<const unsigned *>(&itr->second));
    sender_seqnum = *loc++;
    target_seqnum = *loc;
    return true;
 }

unsigned MemoryPersister::get_last_seqnum ( unsigned & to ) const

virtual

Retrieve sequence number of last peristed message.

Parameters

to	target sequence number

Returns: sequence number of last peristed message on success

Implements FIX8::Persister.

Definition at line 417 of file persist.cpp.

 {
    return to = (_store.empty() ? 0 : _store.rbegin()->first);
 }

bool MemoryPersister::put	(	const unsigned	seqnum,
		const f8String &	what
	)

virtual

Persist a message.

Parameters

seqnum	sequence number of message
what	message string

Returns: true on success

Implements FIX8::Persister.

Definition at line 371 of file persist.cpp.

 {
    return !seqnum ? false : _store.insert({seqnum, what}).second;
 }

bool MemoryPersister::put	(	const unsigned	sender_seqnum,
		const unsigned	target_seqnum
	)

virtual

Persist a sequence control record.

Parameters

sender_seqnum	sequence number of last sent message
target_seqnum	sequence number of last received message

Returns: true on success

Implements FIX8::Persister.

Definition at line 364 of file persist.cpp.

 {
    const unsigned arr[2] { sender_seqnum, target_seqnum };
    return _store.insert({0, f8String(reinterpret_cast<const char *>(arr), sizeof(arr))}).second;
 }

Member Data Documentation

Store FIX8::MemoryPersister::_store

private

Definition at line 295 of file persist.hpp.

The documentation for this class was generated from the following files:

Public Member Functions

Private Types

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation