Base class for all fix messages. More...

#include <message.hpp>

Inheritance diagram for FIX8::MessageBase:

Public Member Functions
template<typename InputIterator >
	MessageBase (const struct F8MetaCntx &ctx, const f8String &msgType, const InputIterator begin, const size_t cnt, const FieldTrait_Hash_Array *ftha)

F8API	MessageBase (const MessageBase &from)
	Copy ctor. More...

F8API MessageBase &	operator= (const MessageBase &that)
	Assignment operator. More...

virtual	~MessageBase ()
	Dtor. More...

virtual void	clear (bool reuse=true)

void	clear_positions ()
	empty the positions map More...

size_t	size () const

F8API unsigned	decode (const f8String &from, unsigned offset, unsigned ignore=0, bool permissive_mode=false)

unsigned	decode_group (GroupBase *grpbase, const unsigned short fnum, const f8String &from, unsigned s_offset, unsigned ignore)

F8API size_t	encode (std::ostream &to) const

F8API size_t	encode (char *to) const

F8API size_t	encode_group (const unsigned short fnum, std::ostream &to) const

F8API size_t	encode_group (const unsigned short fnum, char *to) const

virtual GroupBase *	create_nested_group (unsigned short fnum) const

F8API unsigned	check_positions ()

F8API unsigned	copy_legal (MessageBase *to, bool force=false) const

F8API unsigned	move_legal (MessageBase *to, bool force=false)

void	push_unknown (MessageBase *to) const

void	check_set_rlm (BaseField *where) const

const f8String &	get_msgtype () const

void	add_field_decoder (const unsigned short fnum, const unsigned pos, BaseField *what)

void	add_field (const unsigned short fnum, Presence::const_iterator itr, const unsigned pos, BaseField *what, bool check)

void	add_field (const unsigned short fnum, Fields::iterator fitr, const unsigned pos, BaseField *what, bool check=true)

void	add_field (const unsigned short fnum, const unsigned pos, BaseField *what, bool check=true)

void	set (const unsigned short field, FieldTrait::TraitTypes type=FieldTrait::present)

template<typename T >
bool	add_field (T *what)

bool	add_field (BaseField *what)

Groups &	get_groups ()

template<typename T >
bool	operator+= (T *what)

template<typename T >
MessageBase &	operator<< (T *what)

template<typename T >
bool	get (T &to) const

template<typename T >
bool	has () const

bool	is_legal (unsigned short fnum) const

template<typename T >
bool	is_legal () const

template<typename T >
const T *	get () const

template<typename T >
bool	operator() (T &to) const

template<typename T >
const T *	operator() () const

bool	have (const unsigned short fnum) const

Fields::const_iterator	find_field (const unsigned short fnum) const

BaseField *	get_field (const unsigned short fnum) const

BaseField *	get_field_by_name (const char *tag) const

Fields::const_iterator	fields_begin () const

Fields::const_iterator	fields_end () const

F8API BaseField *	replace (const unsigned short fnum, Presence::const_iterator itr, BaseField *with)

F8API BaseField *	replace (const unsigned short fnum, BaseField *with)

F8API GroupBase *	replace (const unsigned short fnum, GroupBase *with)

F8API BaseField *	remove (const unsigned short fnum, Presence::const_iterator itr)

F8API BaseField *	remove (const unsigned short fnum)

template<typename T >
GroupBase *	find_group () const

GroupBase *	find_group (const unsigned short fnum) const

template<typename T >
GroupBase *	find_add_group (GroupBase *grpbase=nullptr)

GroupBase *	find_add_group (const unsigned short fnum, GroupBase *grpbase=nullptr)

template<typename T >
void	append_group (T *what)

void	add_group (GroupBase *what)

MessageBase &	operator<< (GroupBase *what)

void	operator+= (GroupBase *what)

unsigned short	getPos (const unsigned short field) const

bool	add_trait (const FieldTrait &what)

template<typename InputIterator >
void	add_trait (const InputIterator begin, const size_t cnt)

virtual F8API void	print (std::ostream &os, int depth=0) const

virtual F8API void	print_field (const unsigned short fnum, std::ostream &os) const

virtual F8API void	print_group (const unsigned short fnum, std::ostream &os, int depth=0) const

const FieldTraits &	get_fp () const

void	print_fp (std::ostream &os)

virtual begin_string *	get_begin_string ()

virtual body_length *	get_body_length ()

virtual msg_type *	get_msg_type ()

virtual check_sum *	get_check_sum ()

const f8String &	get_unknown () const

Static Public Member Functions
static unsigned	extract_element (const char from, const unsigned sz, char tag, char *val)

static unsigned	extract_element_fixed_width (const char from, const unsigned sz, const unsigned val_sz, char tag, char *val)

static unsigned	extract_element (const char *from, const unsigned sz, f8String &tag, f8String &val)

static void	set_tabsize (unsigned tabsize)

static unsigned	get_tabsize ()

static bool	has_group_count (const BaseField *bf)

Static Protected Member Functions
static unsigned	extract_header (const f8String &from, char len, char mtype)

static unsigned	extract_trailer (const f8String &from, f8String &chksum)

Protected Attributes
Fields	_fields

FieldTraits	_fp

Positions	_pos

Groups	_groups

const f8String &	_msgType

const F8MetaCntx &	_ctx

Static Protected Attributes
static F8API unsigned	_tabsize = defaults::tabsize

Private Attributes
f8String	_unknown
	pass through for permissive mode More...

Friends
class	Message

std::ostream &	operator<< (std::ostream &os, const MessageBase &what)

Detailed Description

Base class for all fix messages.

Definition at line 381 of file message.hpp.

Constructor & Destructor Documentation

template<typename InputIterator >

FIX8::MessageBase::MessageBase	(	const struct F8MetaCntx &	ctx,
		const f8String &	msgType,
		const InputIterator	begin,
		const size_t	cnt,
		const FieldTrait_Hash_Array *	ftha
	)

inline

Ctor.

Template Parameters

InputIterator input iterator type

Parameters

ctx	reference to generated metadata
msgType	- reference to Fix message type
begin	- InputIterator pointing to begining of field trait table
cnt	- number of elements in field trait table
ftha	- field trait hash array

Definition at line 419 of file message.hpp.

420 : _fp(begin, cnt, ftha),

421 _msgType(msgType), _ctx(ctx) {}

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

FIX8::MessageBase::_ctx

const F8MetaCntx & _ctx

Definition: message.hpp:392

FIX8::TEX::ctx

const F8MetaCntx & ctx()

Compiler generated metadata object, accessed through this function.

Definition: Myfix_classes.cpp:424

FIX8::MessageBase::_msgType

const f8String & _msgType

Definition: message.hpp:391

F8API FIX8::MessageBase::MessageBase ( const MessageBase & from )

Copy ctor.

virtual FIX8::MessageBase::~MessageBase ( )

inlinevirtual

Dtor.

Definition at line 429 of file message.hpp.

References clear().

429 { clear(false); }

FIX8::MessageBase::clear

virtual void clear(bool reuse=true)

Definition: message.hpp:433

Member Function Documentation

void FIX8::MessageBase::add_field	(	const unsigned short	fnum,
		Presence::const_iterator	itr,
		const unsigned	pos,
		BaseField *	what,
		bool	check
	)

inline

Add fix field to this message.

Parameters

fnum	field tag
itr	hint iterator: set to itr of found element
pos	position of field in message
what	pointer to field
check	if false, don't check for presence

Definition at line 556 of file message.hpp.

References FIX8::FieldTraits::get(), glout_debug, FIX8::FieldTrait::present, replace(), and FIX8::FieldTraits::set().

Referenced by add_field(), FIX8::TEX::header::add_preamble(), FIX8::TEX::trailer::add_preamble(), copy_legal(), FIX8::ConsoleMenu::EditMsg(), move_legal(), operator+=(), and operator<<().

    {
       if (check && _fp.get(fnum, itr, FieldTrait::present)) // for now, silently replace duplicate
       {
          glout_debug << _msgType << " replacing field:" << fnum;
          delete replace(fnum, itr, what);
          return;
       }
 
       _fields.insert({fnum, what});
       _pos.insert({pos, what});
       _fp.set(fnum, itr, FieldTrait::present);
    }

void FIX8::MessageBase::add_field	(	const unsigned short	fnum,
		Fields::iterator	fitr,
		const unsigned	pos,
		BaseField *	what,
		bool	check = `true`
	)

inline

Add fix field to this message.

Parameters

fnum	field tag
fitr	hint iterator: set to itr of found element
pos	position of field in message
what	pointer to field
check	if false, don't check for presence

Definition at line 576 of file message.hpp.

References FIX8::presorted_set< unsigned short, FieldTrait, FieldTrait::Compare >::end(), FIX8::FieldTraits::get(), FIX8::FieldTraits::get_presence(), glout_debug, FIX8::FieldTrait::present, replace(), and FIX8::FieldTraits::set().

    {
       Presence::const_iterator itr(_fp.get_presence().end());
       if (check && _fp.get(fnum, itr, FieldTrait::present)) // for now, silently replace duplicate
       {
          glout_debug << _msgType << " replacing field:" << fnum;
          delete replace(fnum, itr, what);
          return;
       }
 
       _fields.insert(fitr, {fnum, what});
       _pos.insert({pos, what});
       _fp.set(fnum, itr, FieldTrait::present);
    }

void FIX8::MessageBase::add_field	(	const unsigned short	fnum,
		const unsigned	pos,
		BaseField *	what,
		bool	check = `true`
	)

inline

Add fix field to this message.

Parameters

fnum	field tag
pos	position of field in message
what	pointer to field
check	if false, don't check for presence

Definition at line 596 of file message.hpp.

References FIX8::presorted_set< unsigned short, FieldTrait, FieldTrait::Compare >::end(), FIX8::FieldTraits::get(), FIX8::FieldTraits::get_presence(), glout_debug, FIX8::FieldTrait::present, replace(), and FIX8::FieldTraits::set().

    {
       Presence::const_iterator itr(_fp.get_presence().end());
       if (check && _fp.get(fnum, itr, FieldTrait::present)) // for now, silently replace duplicate
       {
          glout_debug << _msgType << " replacing field:" << fnum;
          delete replace(fnum, itr, what);
          return;
       }
 
       _fields.insert({fnum, what});
       _pos.insert({pos, what});
       _fp.set(fnum, itr, FieldTrait::present);
    }

template<typename T >

bool FIX8::MessageBase::add_field ( T * what )

inline

Add fix field to this message.

Template Parameters

T	field type

Parameters

what	pointer to field

Returns: true on success; throws InvalidField if not valid

Definition at line 621 of file message.hpp.

References add_field(), FIX8::presorted_set< unsigned short, FieldTrait, FieldTrait::Compare >::end(), FIX8::FieldTraits::get_presence(), FIX8::FieldTraits::getPos(), and FIX8::FieldTraits::has().

    {
       Presence::const_iterator itr(_fp.get_presence().end());
       if (_fp.has(T::get_field_id(), itr))
       {
          add_field(T::get_field_id(), itr, _fp.getPos(T::get_field_id(), itr), what, true);
          return true;
       }
       throw InvalidField(T::get_field_id());
       return false;
    }

bool FIX8::MessageBase::add_field ( BaseField * what )

inline

Add fix field to this message.

Template Parameters

T	field type

Parameters

what	pointer to field

Returns: true on success; throws InvalidField if not valid

Definition at line 637 of file message.hpp.

References FIX8::BaseField::_fnum, add_field(), FIX8::presorted_set< unsigned short, FieldTrait, FieldTrait::Compare >::end(), FIX8::FieldTraits::get_presence(), FIX8::FieldTraits::getPos(), and FIX8::FieldTraits::has().

    {
       const unsigned short& fnum(what->_fnum);
       Presence::const_iterator itr(_fp.get_presence().end());
       if (_fp.has(fnum, itr))
       {
          add_field(fnum, itr, _fp.getPos(fnum, itr), what, true);
          return true;
       }
       throw InvalidField(fnum);
       return false;
    }

void FIX8::MessageBase::add_field_decoder	(	const unsigned short	fnum,
		const unsigned	pos,
		BaseField *	what
	)

inline

Add fix field to this message.

Parameters

fnum	field tag
pos	position of field in message
what	pointer to field

Definition at line 544 of file message.hpp.

    {
       _fields.insert({fnum, what});
       _pos.insert({pos, what});
    }

void FIX8::MessageBase::add_group ( GroupBase * what )

inline

Add a repeating group to a message.

Parameters

what	pointer to group to add

Definition at line 832 of file message.hpp.

References FIX8::GroupBase::_fnum.

Referenced by find_add_group(), operator+=(), and operator<<().

832 { _groups.insert({what->_fnum, what}); }

FIX8::MessageBase::_groups

Groups _groups

Definition: message.hpp:390

bool FIX8::MessageBase::add_trait ( const FieldTrait & what )

inline

Add a fieldtrait to the message.

Parameters

what	FieldTrait to add

Returns: true on success

Definition at line 851 of file message.hpp.

References FIX8::FieldTraits::add().

851 { return _fp.add(what); }

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

FIX8::FieldTraits::add

bool add(const FieldTrait &what)

Definition: traits.hpp:575

template<typename InputIterator >

void FIX8::MessageBase::add_trait	(	const InputIterator	begin,
		const size_t	cnt
	)

inline

Add a range of fieldtraits to the message.

Template Parameters

InputIterator input iterator type

Parameters

begin	first FieldTrait to add
cnt	- number of elements in field trait table

Definition at line 858 of file message.hpp.

References FIX8::FieldTraits::add().

858 { _fp.add(begin, cnt); }

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

FIX8::FieldTraits::add

bool add(const FieldTrait &what)

Definition: traits.hpp:575

template<typename T >

void FIX8::MessageBase::append_group ( T * what )

inline

Add a repeating group at the end of a message group. Assume key is not < last.

Template Parameters

T	type of grop being appended

Parameters

what	pointer to group to add

Definition at line 828 of file message.hpp.

828 { _groups.insert(_groups.end(), {T::_fnum, what}); }

FIX8::MessageBase::_groups

Groups _groups

Definition: message.hpp:390

unsigned MessageBase::check_positions ( )

Check to see if positions of fields are as required.

Returns: field number of field not in order, 0 if all ok

Definition at line 218 of file message.cpp.

 {
    return 0; // TODO
 }

void FIX8::MessageBase::check_set_rlm ( BaseField * where ) const

inline

Check that this field has the realm (domain) pointer set; if not then set.

Parameters

where field to check

Definition at line 526 of file message.hpp.

References FIX8::BaseField::_fnum, FIX8::BaseField::_rlm, and FIX8::F8MetaCntx::find_be().

Referenced by copy_legal().

    {
       if (!where->_rlm)
       {
          const BaseEntry *tbe(_ctx.find_be(where->_fnum));
          if (tbe && tbe->_rlm)
             where->_rlm = tbe->_rlm;   // populate realm;
       }
    }

virtual void FIX8::MessageBase::clear ( bool reuse = true )

inlinevirtual

Empty messages from container.

Parameters

reuse if true clear vector

Reimplemented in FIX8::Message.

Definition at line 433 of file message.hpp.

References FIX8::FieldTraits::clear_flag(), and FIX8::FieldTrait::present.

Referenced by FIX8::Message::clear(), and ~MessageBase().

    {
     std::for_each(_fields.begin(), _fields.end(), [](Fields::value_type& pp) { delete pp.second; pp.second = nullptr; });
     std::for_each(_groups.begin(), _groups.end(), [](Groups::value_type& pp) { delete pp.second; pp.second = nullptr; });
       if (reuse)
       {
          _fields.clear();
          //_groups.clear();
          _fp.clear_flag(FieldTrait::present);
          _pos.clear();
       }
    }

void FIX8::MessageBase::clear_positions ( )

inline

empty the positions map

Definition at line 447 of file message.hpp.

447 { _pos.clear(); }

FIX8::MessageBase::_pos

Positions _pos

Definition: message.hpp:389

unsigned MessageBase::copy_legal	(	MessageBase *	to,
		bool	force = `false`
	)		const

Copy all fields from this message to 'to' where the field is legal for 'to' and it is not already present in 'to'; includes nested repeating groups.

Parameters

to	target message
force	if true copy all fields regardless, replacing any existing, adding any new

Returns: number of fields copied

Definition at line 275 of file message.cpp.

References _fp, FIX8::GroupBase::_msgs, add_field(), check_set_rlm(), copy_legal(), FIX8::presorted_set< unsigned short, FieldTrait, FieldTrait::Compare >::end(), find_group(), find_group(), FIX8::FieldTraits::get(), FIX8::FieldTraits::get_presence(), FIX8::FieldTrait::group, FIX8::FieldTraits::has(), FIX8::FieldTrait::present, and replace().

Referenced by copy_legal(), and tex_router_server::operator()().

 {
    unsigned copied{};
    for (const auto& pp : _fp.get_presence())
    {
       if (pp._field_traits & FieldTrait::present && (force || (to->_fp.has(pp._fnum) && !to->_fp.get(pp._fnum))))
       {
          GroupBase *gb;
          if (pp._field_traits & FieldTrait::group && (gb = find_group(pp._fnum)))
          {
             GroupBase *gb1(to->find_group(pp._fnum));
             for (const auto *qq : gb->_msgs)
             {
                MessageBase *grc(gb1->create_group(true));
                copied += qq->copy_legal(grc, force);
                *gb1 += grc;
             }
          }
 
          BaseField *nf(get_field(pp._fnum)->copy());
 #if defined FIX8_POPULATE_METADATA
          to->check_set_rlm(nf);
 #endif
          Presence::const_iterator fpitr(to->_fp.get_presence().end());
          if (force && to->_fp.get(pp._fnum, fpitr, FieldTrait::present))
             delete to->replace(pp._fnum, fpitr, nf);
          else
             to->add_field(nf);
          ++copied;
       }
    }
 
    return copied;
 }

virtual GroupBase* FIX8::MessageBase::create_nested_group ( unsigned short fnum ) const

inlinevirtual

Instantiate a new nested group element.

Parameters

fnum	field number of group to create

Returns: new message

Definition at line 496 of file message.hpp.

Referenced by find_add_group().

496 { return nullptr; }

unsigned MessageBase::decode	(	const f8String &	from,
		unsigned	offset,
		unsigned	ignore = `0`,
		bool	permissive_mode = `false`
	)

Decode from string.

Parameters

from	source string
offset	in bytes to decode from
ignore	bytes to ignore counting back from end of message
permissive_mode	if true, ignore unknown fields

Returns: number of bytes consumed

Definition at line 87 of file message.cpp.

References FIX8::BaseEntry::_name, FIX8::FieldTrait::automatic, FIX8::Common_BodyLength(), FIX8_MAX_FLD_LENGTH, FIX8::FieldTrait::ft_data, FIX8::FieldTrait::ft_Length, FIX8::FieldTrait::group, and FIX8::FieldTrait::present.

Referenced by FIX8::Message::decode().

 {
    const unsigned fsize(static_cast<unsigned>(from.size()) - ignore), npos(0xffffffff);
    unsigned pos(static_cast<unsigned>(_pos.size())), last_valid_pos(npos);
    const char *dptr(from.data());
    char tag[FIX8_MAX_FLD_LENGTH], val[FIX8_MAX_FLD_LENGTH];
    size_t last_valid_offset(0);
 
    for (unsigned result; s_offset <= fsize && (result = extract_element(dptr + s_offset, fsize - s_offset, tag, val));)
    {
       unsigned short tv(fast_atoi<unsigned short>(tag));
       Presence::const_iterator itr(_fp.get_presence().find(tv));
       if (itr == _fp.get_presence().end())
       {
 unknown_field:
          if (permissive_mode)
          {
             if (last_valid_pos == npos)
             {
                last_valid_pos = pos;
                last_valid_offset = s_offset;
             }
             _unknown.append(dptr + s_offset, result);
             s_offset += result;
             continue;
          }
          break;
       }
       s_offset += result;
       if (itr->_field_traits.has(FieldTrait::present))
       {
          if (!itr->_field_traits.has(FieldTrait::automatic))
             throw DuplicateField(tv);
       }
       else for(unsigned ii(0); ii < 2; ++ii)
       {
          const BaseEntry *be(_ctx.find_be(tv));
          if (!be)
             throw UnknownField(tv);
          BaseField *bf(be->_create._do(val, be->_rlm, -1));
          add_field_decoder(tv, ++pos, bf);
          itr->_field_traits.set(FieldTrait::present);
          // check if repeating group and num elements > 0
          if (itr->_field_traits.has(FieldTrait::group) && has_group_count(bf))
             s_offset = decode_group(nullptr, tv, from, s_offset, ignore);
 
          if (itr->_ftype != FieldTrait::ft_Length || tv == Common_BodyLength) // this type expects next field to be data
             break;
 
          const unsigned val_sz(fast_atoi<unsigned>(val));
          if(val_sz > FIX8_MAX_FLD_LENGTH - 1)
             throw f8Exception("Value size too large");
          result = extract_element_fixed_width(dptr + s_offset, fsize - s_offset, val_sz, tag, val);
          if (!result)
             throw MissingMandatoryField("Unable to extract fixed width field");
 
          const unsigned short lasttv(tv);
          tv = fast_atoi<unsigned short>(tag);
          if ((itr = _fp.get_presence().find(tv)) == _fp.get_presence().end())
             goto unknown_field;
          if (itr->_ftype != FieldTrait::ft_data || lasttv + 1 != tv) // next field must be data, tag must be 1 greater than length tag
             break;
          s_offset += result;
       }
    }
 
    const unsigned short missing(_fp.find_missing());
    if (missing)
    {
       const BaseEntry *tbe(_ctx.find_be(missing));
       ostringstream ostr;
       ostr << tbe->_name << " (" << missing << ')';
       throw MissingMandatoryField(ostr.str());
    }
 
    return permissive_mode && last_valid_pos == pos ? static_cast<unsigned>(last_valid_offset) : s_offset;
 }

unsigned MessageBase::decode_group	(	GroupBase *	grpbase,
		const unsigned short	fnum,
		const f8String &	from,
		unsigned	s_offset,
		unsigned	ignore
	)

Decode repeating group from string using nested group method

Parameters

grpbase	pointer to groupbase of holding object
fnum	repeating group fix field num (no...)
from	source string
s_offset	in bytes to decode from
ignore	bytes to ignore counting back from end of message

Returns: number of bytes consumed

Definition at line 166 of file message.cpp.

References FIX8::BaseEntry::_name, FIX8::GroupBase::create_group(), FILE_LINE, FIX8_MAX_FLD_LENGTH, and FIX8::FieldTrait::present.

 {
    unsigned result;
    if (!(grpbase = find_add_group(fnum, grpbase)))
       throw InvalidRepeatingGroup(fnum, FILE_LINE);
    const unsigned fsize(static_cast<unsigned>(from.size()) - ignore);
    const char *dptr(from.data());
    char tag[FIX8_MAX_FLD_LENGTH], val[FIX8_MAX_FLD_LENGTH];
 
    for (bool ok(true); ok && s_offset < fsize; )
    {
       unique_ptr<MessageBase> grp(grpbase->create_group(false)); // shallow create
 
       for (unsigned pos(0); s_offset < fsize && (result = extract_element(dptr + s_offset, fsize - s_offset, tag, val));)
       {
          const unsigned tv(fast_atoi<unsigned>(tag));
          Presence::const_iterator itr(grp->_fp.get_presence().end());
          if (grp->_fp.get(tv, itr, FieldTrait::present)) // already present; next group?
             break;
          if (pos == 0 && grp->_fp.getPos(tv, itr) != 1)  // first field in group is mandatory
             throw MissingRepeatingGroupField(tv);
          const BaseEntry *be(_ctx.find_be(tv));
          if (!be || !grp->_fp.has(tv, itr))  // unknown field or field not found in sub-group - end of repeats?
          {
             ok = false;
             break;
          }
          s_offset += result;
          BaseField *bf(be->_create._do(val, be->_rlm, -1));
          grp->add_field(tv, itr, ++pos, bf, false);
          grp->_fp.set(tv, itr, FieldTrait::present);  // is present
          // nested group (check if not zero elements)
          if (grp->_fp.is_group(tv, itr) && has_group_count(bf))
             s_offset = grp->decode_group(grpbase, tv, from, s_offset, ignore);
       }
 
       const unsigned short missing(grp->_fp.find_missing());
       if (missing)
       {
          const BaseEntry *tbe(_ctx.find_be(missing));
          ostringstream ostr;
          ostr << tbe->_name << " (" << missing << ')';
          throw MissingMandatoryField(ostr.str());
       }
       *grpbase << grp.release();
    }
 
    return s_offset;
 }

size_t MessageBase::encode ( std::ostream & to ) const

Encode message to stream.

Parameters

to	stream to encode to

Returns: number of bytes encoded

Definition at line 373 of file message.cpp.

References FIX8::FieldTrait::group, and FIX8::FieldTrait::suppress.

Referenced by FIX8::Message::encode().

 {
    const std::ios::pos_type where(to.tellp());
    for (const auto& pp : _pos)
    {
 #if defined FIX8_POPULATE_METADATA
       check_set_rlm(pp.second);
 #endif
       Presence::const_iterator fpitr(_fp.get_presence().end());
       if (!_fp.get(pp.second->_fnum, fpitr, FieldTrait::suppress))   // some fields are not encoded until unsuppressed (eg. checksum)
       {
          pp.second->encode(to);
          if (fpitr->_field_traits.has(FieldTrait::group) && has_group_count(pp.second))
             encode_group(pp.second->_fnum, to);
       }
    }
 
    if (_unknown.size())
       to << _unknown;
 
    return to.tellp() - where;
 }

size_t MessageBase::encode ( char * to ) const

Encode message to buffer.

Parameters

to	buffer to encode to

Returns: number of bytes encoded

Definition at line 349 of file message.cpp.

References FIX8::FieldTrait::group, and FIX8::FieldTrait::suppress.

 {
    const char *where(to);
    for (const auto& pp : _pos)
    {
 #if defined FIX8_POPULATE_METADATA
       check_set_rlm(pp.second);
 #endif
       Presence::const_iterator fpitr(_fp.get_presence().end());
       if (!_fp.get(pp.second->_fnum, fpitr, FieldTrait::suppress))   // some fields are not encoded until unsuppressed (eg. checksum)
       {
          to += pp.second->encode(to);
          if (fpitr->_field_traits.has(FieldTrait::group) && has_group_count(pp.second))
             to += encode_group(pp.second->_fnum, to);
       }
    }
 
    if (_unknown.size())
       to += _unknown.copy(to, _unknown.size());
 
    return to - where;
 }

size_t MessageBase::encode_group	(	const unsigned short	fnum,
		std::ostream &	to
	)		const

Encode group message to stream.

Parameters

fnum	repeating group fix field num (no...)
to	stream to encode to

Returns: number of bytes encoded

Definition at line 409 of file message.cpp.

References FILE_LINE, and find_group().

 {
    const std::ios::pos_type where(to.tellp());
    GroupBase *grpbase(find_group(fnum));
    if (!grpbase)
       throw InvalidRepeatingGroup(fnum, FILE_LINE);
    for (const auto *pp : grpbase->_msgs)
       pp->encode(to);
    return to.tellp() - where;
 }

size_t MessageBase::encode_group	(	const unsigned short	fnum,
		char *	to
	)		const

Encode group message to buffer.

Parameters

fnum	repeating group fix field num (no...)
to	buffer to encode to

Returns: number of bytes encoded

Definition at line 397 of file message.cpp.

References FIX8::GroupBase::_msgs, FILE_LINE, and find_group().

 {
    const char *where(to);
    GroupBase *grpbase(find_group(fnum));
    if (!grpbase)
       throw InvalidRepeatingGroup(fnum, FILE_LINE);
    for (const auto *pp : grpbase->_msgs)
       to += pp->encode(to);
    return to - where;
 }

static unsigned FIX8::MessageBase::extract_element	(	const char *	from,
		const unsigned	sz,
		char *	tag,
		char *	val
	)

inlinestatic

Extract a tag/value element from a char buffer. ULL version.

Parameters

from	source buffer
sz	size of string
tag	tag to extract to
val	value to extract to

Returns: number of bytes consumed

Definition at line 886 of file message.hpp.

References FIX8::default_assignment_separator(), FIX8::default_field_separator(), and FIX8::get_value().

Referenced by FIX8::FIXReader::read().

    {
       enum { get_tag, get_value } state(get_tag);
 
       for (unsigned ii(0); ii < sz; ++ii)
       {
          switch (state)
          {
          case get_tag:
             if (!isdigit(from[ii]))
             {
                if (from[ii] != default_assignment_separator)
                   return *val = *tag = 0;
                state = get_value;
             }
             else
                *tag++ = from[ii];
             break;
          case get_value:
             if (from[ii] == default_field_separator)
             {
                *val = *tag = 0;
                return ++ii;
             }
             *val++ = from[ii];
             break;
          }
       }
       return *val = *tag = 0;
    }

static unsigned FIX8::MessageBase::extract_element	(	const char *	from,
		const unsigned	sz,
		f8String &	tag,
		f8String &	val
	)

inlinestatic

Extract a tag/value element from a char buffer.

Parameters

from	source buffer
sz	size of string
tag	tag to extract to
val	value to extract to

Returns: number of bytes consumed

Definition at line 951 of file message.hpp.

References FIX8::default_assignment_separator(), FIX8::default_field_separator(), and FIX8::get_value().

    {
       enum { get_tag, get_value } state(get_tag);
       tag.clear();
       val.clear();
 
       for (unsigned ii(0); ii < sz; ++ii)
       {
          switch (state)
          {
          case get_tag:
             if (!isdigit(from[ii]))
             {
                if (from[ii] != default_assignment_separator)
                   return 0;
                state = get_value;
             }
             else
                tag += from[ii];
             break;
          case get_value:
             if (from[ii] == default_field_separator)
                return ++ii;
             val += from[ii];
             break;
          }
       }
       return 0;
    }

static unsigned FIX8::MessageBase::extract_element_fixed_width	(	const char *	from,
		const unsigned	sz,
		const unsigned	val_sz,
		char *	tag,
		char *	val
	)

inlinestatic

Extract a tag and fixed width value element from a char buffer. ULL version.

Parameters

from	source buffer
sz	size of string
tag	tag to extract to
val_sz	size of value to be extracted, not including field separator
val	value to extract to

Returns: number of bytes consumed

Definition at line 924 of file message.hpp.

References FIX8::default_assignment_separator().

    {
       *val = *tag = 0;
       for (unsigned ii(0); ii < sz; ++ii)
       {
          if(isdigit(from[ii]))
          {
             *tag++ = from[ii];
             continue;
          }
 
          if (from[ii++] != default_assignment_separator || sz < (ii + val_sz))
             break;
 
          ::memcpy(val, &from[ii], val_sz);
          val[val_sz] = 0;
          return ii + val_sz + 1; // account for field separator
       }
       return *val = *tag = 0;
    }

unsigned MessageBase::extract_header	(	const f8String &	from,
		char *	len,
		char *	mtype
	)

staticprotected

Extract length and message type from a header buffer

Parameters

from	source buffer
len	length to extract to
mtype	message type to extract to

Returns: number of bytes consumed

Definition at line 51 of file message.cpp.

References FIX8_MAX_FLD_LENGTH, and FIX8::MAX_MSGTYPE_FIELD_LEN().

 {
    const char *dptr(from.data());
    const unsigned flen(static_cast<unsigned>(from.size()));
    char tag[MAX_MSGTYPE_FIELD_LEN], val[FIX8_MAX_FLD_LENGTH];
    unsigned s_offset(0), result;
 
    if ((result = extract_element(dptr, flen, tag, val)))
    {
       if (*tag != '8')
          return 0;
       s_offset += result;
       if ((result = extract_element(dptr + s_offset, flen - s_offset, tag, len)))
       {
          if (*tag != '9')
             return 0;
          s_offset += result;
          if ((result = extract_element(dptr + s_offset, flen - s_offset, tag, mtype)))
          {
             if (*tag != '3' || *(tag + 1) != '5')
                return 0;
             s_offset += result;
          }
       }
    }
    return s_offset;
 }

unsigned MessageBase::extract_trailer	(	const f8String &	from,
		f8String &	chksum
	)

staticprotected

Extract chksum from a trailer buffer

Parameters

from	source buffer
chksum	chksum to extract to

Returns: number of bytes consumed

Definition at line 80 of file message.cpp.

 {
    f8String tag;
    return extract_element(from.data() + from.size() - 7, 6, tag, chksum);
 }

Fields::const_iterator FIX8::MessageBase::fields_begin ( ) const

inline

Get an iterator to fields present in this message.

Returns: iterator to the first field or Fields::const_iterator::end

Definition at line 752 of file message.hpp.

752 { return _fields.begin(); }

FIX8::MessageBase::_fields

Fields _fields

Definition: message.hpp:387

Fields::const_iterator FIX8::MessageBase::fields_end ( ) const

inline

Get an iterator to fields present in this message.

Returns: iterator to the last field + 1

Definition at line 756 of file message.hpp.

756 { return _fields.end(); }

FIX8::MessageBase::_fields

Fields _fields

Definition: message.hpp:387

template<typename T >

GroupBase* FIX8::MessageBase::find_add_group ( GroupBase * grpbase = nullptr )

inline

Find a group of a specified type. If not found attempt to add.

Template Parameters

T	type of group to get

Parameters

grpbase parent group (if group nested) or nullptr if no parent

Returns: pointer to found group or 0 if not found

Definition at line 808 of file message.hpp.

References find_add_group().

Referenced by find_add_group(), and MyMenu::generate_new_order_single_alternate().

808 { return find_add_group(T::_fnum, grpbase); }

FIX8::MessageBase::find_add_group

GroupBase * find_add_group(GroupBase *grpbase=nullptr)

Definition: message.hpp:808

GroupBase* FIX8::MessageBase::find_add_group	(	const unsigned short	fnum,
		GroupBase *	grpbase = `nullptr`
	)

inline

Find a group of a specified type. If not found attempt to add.

Parameters

fnum	field number
grpbase	parent group (if group nested) or nullptr if no parent

Returns: pointer to found group or 0 if not found

Definition at line 814 of file message.hpp.

References add_group(), and create_nested_group().

    {
       auto gitr(_groups.find(fnum));
       if (gitr != _groups.end())
          return gitr->second;
       GroupBase *gb1(grpbase ? grpbase->create_nested_group(fnum) : create_nested_group(fnum));
       add_group(gb1);
       return gb1;
    }

Fields::const_iterator FIX8::MessageBase::find_field ( const unsigned short fnum ) const

inline

Check if a field is present in this message.

Parameters

fnum	field number

Returns: iterator to field or Fields::const_iterator::end

Definition at line 730 of file message.hpp.

730 { return _fields.find(fnum); }

FIX8::MessageBase::_fields

Fields _fields

Definition: message.hpp:387

template<typename T >

GroupBase* FIX8::MessageBase::find_group ( ) const

inline

Find a group of a specified type.

Template Parameters

T	type of group to get

Returns: pointer to found group or 0 if not found

Definition at line 792 of file message.hpp.

References find_group().

Referenced by copy_legal(), FIX8::ConsoleMenu::EditMsg(), find_group(), MyMenu::generate_new_order_single(), and move_legal().

792 { return find_group(T::_fnum); }

FIX8::MessageBase::find_group

GroupBase * find_group() const

Definition: message.hpp:792

GroupBase* FIX8::MessageBase::find_group ( const unsigned short fnum ) const

inline

Find a group of a specified type.

Parameters

fnum	field number

Returns: pointer to found group or 0 if not found

Definition at line 797 of file message.hpp.

    {
       auto gitr(_groups.find(fnum));
       return gitr != _groups.cend() ? gitr->second : nullptr;
    }

template<typename T >

bool FIX8::MessageBase::get ( T & to ) const

inline

Populate supplied field with value from message.

Template Parameters

T	type of field to get

Parameters

to	field to populate

Returns: true on success

Definition at line 671 of file message.hpp.

Referenced by FIX8::Session::compid_check(), FIX8::Session::handle_logon(), FIX8::Session::handle_resend_request(), FIX8::Session::handle_sequence_reset(), FIX8::Session::handle_test_request(), MyMenu::load_msgs(), tex_router_server::operator()(), FIX8::Session::send_process(), and FIX8::Session::sequence_check().

    {
       Fields::const_iterator fitr(_fields.find(T::get_field_id()));
       if (fitr == _fields.end())
          return false;
       to.set(fitr->second->from<T>().get());
       if (fitr->second->_rlm)
          to._rlm = fitr->second->_rlm;
       return true;
    }

template<typename T >

const T* FIX8::MessageBase::get ( ) const

inline

Get a pointer to a field. Inplace, 0 copy.

Template Parameters

T	type of field to get

Returns: pointer to field or 0 if not present

Definition at line 703 of file message.hpp.

    {
       Fields::const_iterator fitr(_fields.find(T::get_field_id()));
       return fitr == _fields.cend() ? nullptr : &fitr->second->from<T>();
    }

virtual begin_string* FIX8::MessageBase::get_begin_string ( )

inlinevirtual

Get pointer to begin_string Field; used by header/trailer.

Returns: Field

Reimplemented in FIX8::TEX::header, and FIX8::TEX::header.

Definition at line 1007 of file message.hpp.

1007 { return nullptr; }

virtual body_length* FIX8::MessageBase::get_body_length ( )

inlinevirtual

Get pointer to body_length Field; used by header/trailer.

Returns: Field

Reimplemented in FIX8::TEX::header, and FIX8::TEX::header.

Definition at line 1011 of file message.hpp.

1011 { return nullptr; }

virtual check_sum* FIX8::MessageBase::get_check_sum ( )

inlinevirtual

Get pointer to check_sum Field; used by header/trailer.

Returns: Field

Reimplemented in FIX8::TEX::trailer, and FIX8::TEX::trailer.

Definition at line 1019 of file message.hpp.

1019 { return nullptr; }

BaseField* FIX8::MessageBase::get_field ( const unsigned short fnum ) const

inline

Search for field in this message.

Parameters

fnum	field number

Returns: pointer to field or 0 if not found

Definition at line 735 of file message.hpp.

    {
       auto itr(_fields.find(fnum));
       return itr != _fields.cend() ? itr->second : nullptr;
    }

BaseField* FIX8::MessageBase::get_field_by_name ( const char * tag ) const

inline

Search for field by longname in this message.

Parameters

tag	field longname

Returns: pointer to field or 0 if not found

Definition at line 744 of file message.hpp.

References FIX8::F8MetaCntx::reverse_find_fnum().

    {
       auto itr(_fields.find(_ctx.reverse_find_fnum(tag)));
       return itr != _fields.cend() ? itr->second : nullptr;
    }

const FieldTraits& FIX8::MessageBase::get_fp ( ) const

inline

Get the FieldTraits

Returns: reference to FieldTraits object

Definition at line 878 of file message.hpp.

References _fp.

Referenced by FIX8::ConsoleMenu::EditMsg(), and FIX8::ConsoleMenu::SelectField().

878 { return _fp; }

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

Groups& FIX8::MessageBase::get_groups ( )

inline

Definition at line 650 of file message.hpp.

References _groups.

650 { return _groups; }

FIX8::MessageBase::_groups

Groups _groups

Definition: message.hpp:390

virtual msg_type* FIX8::MessageBase::get_msg_type ( )

inlinevirtual

Get pointer to msg_type Field; used by header/trailer.

Returns: Field

Reimplemented in FIX8::TEX::header, and FIX8::TEX::header.

Definition at line 1015 of file message.hpp.

1015 { return nullptr; }

const f8String& FIX8::MessageBase::get_msgtype ( ) const

inline

Get the message type as a string.

Returns: the Fix message type as a string

Definition at line 538 of file message.hpp.

References _msgType.

Referenced by FIX8::Session::enforce(), FIX8::Session::generate_business_reject(), FIX8::Session::handle_logon(), FIX8::Session::handle_outbound_reject(), FIX8::Session::process(), and FIX8::ConsoleMenu::SelectField().

538 { return _msgType; }

FIX8::MessageBase::_msgType

const f8String & _msgType

Definition: message.hpp:391

static unsigned FIX8::MessageBase::get_tabsize ( )

inlinestatic

get the tabsize used by the printer

Returns: tabsize of spaces in a tab

Definition at line 994 of file message.hpp.

References _tabsize.

994 { return _tabsize; }

FIX8::MessageBase::_tabsize

static F8API unsigned _tabsize

Definition: message.hpp:408

const f8String& FIX8::MessageBase::get_unknown ( ) const

inline

Get pass through fields (permissive mode only)

Returns: string of unknown pass through fields

Definition at line 1023 of file message.hpp.

References _unknown.

1023 { return _unknown; }

FIX8::MessageBase::_unknown

f8String _unknown

pass through for permissive mode

Definition: message.hpp:384

unsigned short FIX8::MessageBase::getPos ( const unsigned short field ) const

inline

Find the position of a field in a message.

Parameters

field field number

Returns: position of field

Definition at line 846 of file message.hpp.

References FIX8::FieldTraits::getPos().

846 { return _fp.getPos(field); }

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

FIX8::FieldTraits::getPos

unsigned short getPos(const unsigned short field, Presence::const_iterator &itr) const

Definition: traits.hpp:639

template<typename T >

bool FIX8::MessageBase::has ( ) const

inline

Check if a field is present.

Template Parameters

T	type of field to get

Returns: true if present

Definition at line 686 of file message.hpp.

References FIX8::FieldTraits::get().

686 { return _fp.get(T::get_field_id()); }

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

FIX8::FieldTraits::get

bool get(const unsigned short field, FieldTrait::TraitTypes type=FieldTrait::present) const

Definition: traits.hpp:490

static bool FIX8::MessageBase::has_group_count ( const BaseField * bf )

inlinestatic

Determine if this repeating group count field has any elements (> 0)

Parameters

bf	Basefield *

Returns: true if has count

Definition at line 999 of file message.hpp.

999 { return static_cast<const Field<int, 0> *>(bf)->get() > 0; }

bool FIX8::MessageBase::have ( const unsigned short fnum ) const

inline

Check if a field is present in this message.

Parameters

fnum	field number

Returns: true is present

Definition at line 725 of file message.hpp.

References FIX8::FieldTraits::get(), and FIX8::FieldTrait::present.

Referenced by FIX8::Session::handle_logon(), FIX8::ConsoleMenu::SelectField(), and FIX8::Session::send_process().

725 { return _fp.get(fnum, FieldTrait::present); }

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

FIX8::FieldTrait::present

Definition: traits.hpp:78

FIX8::FieldTraits::get

bool get(const unsigned short field, FieldTrait::TraitTypes type=FieldTrait::present) const

Definition: traits.hpp:490

bool FIX8::MessageBase::is_legal ( unsigned short fnum ) const

inline

Check if a field is legal in a message.

Parameters

fnum	field number

Returns: true if present

Definition at line 691 of file message.hpp.

References FIX8::FieldTraits::has().

Referenced by FIX8::Session::generate_logon().

691 { return _fp.has(fnum); }

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

FIX8::FieldTraits::has

bool has(const unsigned short field, Presence::const_iterator &itr) const

Definition: traits.hpp:457

template<typename T >

bool FIX8::MessageBase::is_legal ( ) const

inline

Check if a field is legal.

Template Parameters

T	type of field to check

Returns: true if present

Definition at line 697 of file message.hpp.

References FIX8::FieldTraits::has().

697 { return _fp.has(T::get_field_id()); }

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

FIX8::FieldTraits::has

bool has(const unsigned short field, Presence::const_iterator &itr) const

Definition: traits.hpp:457

unsigned MessageBase::move_legal	(	MessageBase *	to,
		bool	force = `false`
	)

Move all fields from this message to 'to' where the field is legal for 'to' and it is not already present in 'to'; includes nested repeating groups. Not thread safe. Source message must be heap based. Source message is invalidated (but can be deleted).

Parameters

to	target message
force	if true move all fields regardless, replacing any existing, adding any new

Returns: number of fields moved

Definition at line 315 of file message.cpp.

References _fp, add_field(), find_group(), FIX8::FieldTraits::get(), FIX8::FieldTrait::group, FIX8::FieldTraits::has(), FIX8::FieldTrait::present, and replace().

 {
    unsigned moved{};
    for (const auto& pp : _fp.get_presence())
    {
       if (pp._field_traits & FieldTrait::present && (force || (to->_fp.has(pp._fnum) && !to->_fp.get(pp._fnum))))
       {
          if (pp._field_traits & FieldTrait::group)
          {
             auto gitr(_groups.find(pp._fnum));
             GroupBase *gb1(to->find_group(pp._fnum));
             if (gb1)
                delete to->replace(pp._fnum, gitr->second);
             else
                *to += gitr->second;
             gitr->second = nullptr;
          }
 
          auto itr(_fields.find(pp._fnum));
          Presence::const_iterator fpitr(_fp.get_presence().end());
          if (force && to->_fp.get(pp._fnum, fpitr, FieldTrait::present))
             delete to->replace(pp._fnum, fpitr, itr->second);
          else
             to->add_field(itr->second);
          itr->second = nullptr;
          ++moved;
       }
    }
    clear_positions();
 
    return moved;
 }

template<typename T >

bool FIX8::MessageBase::operator() ( T & to ) const

inline

Populate supplied field with value from message.

Template Parameters

T	type of field to get

Parameters

to	field to populate

Returns: true on success

Definition at line 714 of file message.hpp.

714 { return get(to); }

template<typename T >

const T* FIX8::MessageBase::operator() ( ) const

inline

Get a pointer to a field. Inplace, 0 copy.

Template Parameters

T	type of field to get

Returns: pointer to field or 0 if not present

Definition at line 720 of file message.hpp.

720 { return get<T>(); }

template<typename T >

bool FIX8::MessageBase::operator+= ( T * what )

inline

Add fix field to this message.

Template Parameters

T	field type

Parameters

what	pointer to field

Returns: true on success; throws InvalidField if not valid

Definition at line 657 of file message.hpp.

References add_field().

657 { return add_field(what); }

FIX8::MessageBase::add_field

void add_field(const unsigned short fnum, Presence::const_iterator itr, const unsigned pos, BaseField *what, bool check)

Definition: message.hpp:556

void FIX8::MessageBase::operator+= ( GroupBase * what )

inline

Add a repeating group to a message.

Parameters

what	pointer to group to add

Definition at line 841 of file message.hpp.

References add_group().

841 { add_group(what); }

FIX8::MessageBase::add_group

void add_group(GroupBase *what)

Definition: message.hpp:832

template<typename T >

MessageBase& FIX8::MessageBase::operator<< ( T * what )

inline

Add fix field to this message.

Template Parameters

T	field type

Parameters

what	pointer to field

Returns: reference to MessageBase on success

Definition at line 664 of file message.hpp.

References add_field().

664 { add_field(what); return *this; }

FIX8::MessageBase::add_field

void add_field(const unsigned short fnum, Presence::const_iterator itr, const unsigned pos, BaseField *what, bool check)

Definition: message.hpp:556

MessageBase& FIX8::MessageBase::operator<< ( GroupBase * what )

inline

Add a repeating group to a message.

Parameters

what	pointer to field

Returns: reference to MessageBase on success

Definition at line 837 of file message.hpp.

References add_group().

837 { add_group(what); return *this; }

FIX8::MessageBase::add_group

void add_group(GroupBase *what)

Definition: message.hpp:832

F8API MessageBase& FIX8::MessageBase::operator= ( const MessageBase & that )

Assignment operator.

void MessageBase::print	(	std::ostream &	os,
		int	depth = `0`
	)		const

virtual

Print the message to the specified stream.

Parameters

os	refererence to stream to print to
depth	nesting depth

Reimplemented in FIX8::Message.

Definition at line 509 of file message.cpp.

References FIX8::BaseMsgEntry::_name.

Referenced by FIX8::Message::print().

 {
    const string dspacer((depth + 1) * _tabsize, ' ');
    const BaseMsgEntry *tbme(_ctx._bme.find_ptr(_msgType.c_str()));
    if (tbme)
       os << string(depth * _tabsize, ' ') << tbme->_name << " (\"" << _msgType << "\")" << endl;
    for (const auto& pp : _pos)
    {
       const BaseEntry *tbe(_ctx.find_be(pp.second->_fnum));
       if (!tbe)
          throw InvalidField(pp.second->_fnum);
       os << dspacer << tbe->_name;
       const unsigned short comp(_fp.getComp(pp.second->_fnum));
       if (comp)
          os << " [" << _ctx._cn[comp] << ']';
       os << " (" << pp.second->_fnum << "): ";
       int idx;
       if (pp.second->_rlm && (idx = (pp.second->get_rlm_idx())) >= 0)
          os << pp.second->_rlm->_descriptions[idx] << " (" << *pp.second << ')' << endl;
       else
          os << *pp.second << endl;
       if (_fp.is_group(pp.second->_fnum) && has_group_count(pp.second))
          print_group(pp.second->_fnum, os, depth);
    }
 }

void MessageBase::print_field	(	const unsigned short	fnum,
		std::ostream &	os
	)		const

virtual

Print the field specified by the field num from message to the specified stream.

Parameters

fnum	field number
os	refererence to stream to print to

Definition at line 554 of file message.cpp.

Referenced by FIX8::ConsoleMenu::SelectField().

 {
    Fields::const_iterator fitr(_fields.find(fnum));
    if (fitr != _fields.end())
    {
       const BaseEntry *tbe(_ctx.find_be(fnum));
       if (!tbe)
          throw InvalidField(fnum);
       os << tbe->_name << " (" << fnum << "): ";
       int idx;
       if (fitr->second->_rlm && (idx = (fitr->second->get_rlm_idx())) >= 0)
          os << fitr->second->_rlm->_descriptions[idx] << " (" << *fitr->second << ')';
       else
          os << *fitr->second;
       if (_fp.is_group(fnum) && has_group_count(fitr->second))
          print_group(fnum, os, 0);
    }
 }

void FIX8::MessageBase::print_fp ( std::ostream & os )

inline

Presence printer

Parameters

os	stream to send to

Definition at line 1003 of file message.hpp.

References _fp.

1003 { os << _fp; }

FIX8::MessageBase::_fp

FieldTraits _fp

Definition: message.hpp:388

void MessageBase::print_group	(	const unsigned short	fnum,
		std::ostream &	os,
		int	depth = `0`
	)		const

virtual

Print the repeating group to the specified stream.

Parameters

fnum	field number
os	refererence to stream to print to
depth	nesting depth

Definition at line 536 of file message.cpp.

References FIX8::GroupBase::_msgs, FILE_LINE, and find_group().

 {
    const GroupBase *grpbase(find_group(fnum));
    if (!grpbase)
       throw InvalidRepeatingGroup(fnum, FILE_LINE);
 
    ++depth;
    const string dspacer(depth * _tabsize, ' ');
    size_t cnt(1);
    for (const auto *pp : grpbase->_msgs)
    {
       os << dspacer << pp->_msgType << " (Repeating group " << cnt << '/' << grpbase->_msgs.size() << ')' << endl;
       pp->print(os, depth);
       ++cnt;
    }
 }

void FIX8::MessageBase::push_unknown ( MessageBase * to ) const

inline

Copy _unknown string from this message to given message

Definition at line 518 of file message.hpp.

References _unknown.

Referenced by FIX8::Message::push_unknown().

    {
       if (_unknown.size() && to)
          to->_unknown = _unknown;
    }

BaseField * MessageBase::remove	(	const unsigned short	fnum,
		Presence::const_iterator	itr
	)

Remove a field from this message.

Parameters

fnum	field number
itr	hint iterator: if end, set to itr of found element, if not end use it to locate element

Returns: pointer to original field or 0 if not found

Definition at line 646 of file message.cpp.

References FIX8::FieldTrait::present.

Referenced by MyMenu::load_msgs(), FIX8::Session::send_process(), and FIX8::Message::setup_reuse().

 {
    BaseField *old(nullptr);
    Fields::iterator itr(_fields.find(fnum));
    if (itr != _fields.end())
    {
       old = itr->second;
       for (Positions::iterator pitr(_pos.begin()); pitr != _pos.end(); ++pitr)
       {
          if (pitr->second == old)
          {
             _pos.erase(pitr);
             break;
          }
       }
       _fp.clear(fnum, fitr, FieldTrait::present);
       _fields.erase(itr);
    }
    return old;
 }

BaseField * MessageBase::remove ( const unsigned short fnum )

Remove a field from this message.

Parameters

fnum	field number

Returns: pointer to original field or 0 if not found

Definition at line 624 of file message.cpp.

References FIX8::FieldTrait::present.

 {
    BaseField *old(nullptr);
    Fields::iterator itr(_fields.find(fnum));
    if (itr != _fields.end())
    {
       old = itr->second;
       for (Positions::iterator pitr(_pos.begin()); pitr != _pos.end(); ++pitr)
       {
          if (pitr->second == old)
          {
             _pos.erase(pitr);
             break;
          }
       }
       _fp.clear(fnum, FieldTrait::present);
       _fields.erase(itr);
    }
    return old;
 }

BaseField * MessageBase::replace	(	const unsigned short	fnum,
		Presence::const_iterator	itr,
		BaseField *	with
	)

Replace a field value with another field value.

Parameters

fnum	field number
itr	hint iterator: if end, set to itr of found element, if not end use it to locate element
with	field to replace with

Returns: pointer to original field or 0 if not found

Definition at line 599 of file message.cpp.

References FIX8::FieldTrait::present.

Referenced by add_field(), copy_legal(), and move_legal().

 {
    BaseField *old(nullptr);
    Fields::iterator itr(_fields.find(fnum));
    if (itr != _fields.end())
    {
       old = itr->second;
       unsigned pos(_fp.getPos(fnum, fitr));
       for (Positions::iterator pitr(_pos.begin()); pitr != _pos.end(); ++pitr)
       {
          if (pitr->second == old)
          {
             pos = pitr->first;
             _pos.erase(pitr);
             break;
          }
       }
       _pos.insert({pos, with});
       itr->second = with;
       _fp.set(fnum, fitr, FieldTrait::present);
    }
    return old;
 }

BaseField * MessageBase::replace	(	const unsigned short	fnum,
		BaseField *	with
	)

Replace a field value with another field value.

Parameters

fnum	field number
with	field to replace with

Returns: pointer to original field or 0 if not found

Definition at line 574 of file message.cpp.

References FIX8::FieldTrait::present.

 {
    BaseField *old(nullptr);
    Fields::iterator itr(_fields.find(fnum));
    if (itr != _fields.end())
    {
       old = itr->second;
       unsigned pos(_fp.getPos(fnum));
       for (Positions::iterator pitr(_pos.begin()); pitr != _pos.end(); ++pitr)
       {
          if (pitr->second == old)
          {
             pos = pitr->first;
             _pos.erase(pitr);
             break;
          }
       }
       _pos.insert({pos, with});
       itr->second = with;
       _fp.set(fnum, FieldTrait::present);
    }
    return old;
 }

GroupBase * MessageBase::replace	(	const unsigned short	fnum,
		GroupBase *	with
	)

Replace a group with another group.

Parameters

fnum	group field number
with	group to replace with

Returns: pointer to original group or 0 if not found

Definition at line 721 of file message.cpp.

 {
    GroupBase *old(nullptr);
    auto itr(_groups.find(fnum));
    if (itr != _groups.end())
    {
       old = itr->second;
       itr->second = with;
    }
    return old;
 }