#include <CmiBinaryProtocol.h>
|
bool | canSendHeartbeats (bool initiator) |
|
| CmiBinaryProtocol () |
|
const char * | convertToBinary (LiteFixMessage *ownerMsg, Utils::RawBuffer *rawFixMsg, int *size, bool isIncoming) |
|
Engine::FIXMessage * | createHBMessage (Engine::FixSessionUProtocol *sn) |
|
int | handleHBI (int hbi) |
|
void | handleSessionParams (Engine::SessionExtraParametersImpl ¶ms) |
|
const char * | operator() (const Utils::RawBuffer &buffer, const char **msgStart, const char **bufEnd, int *procceedBytes) const |
|
int | parseSome (LiteFixMessage *ownerMsg, const char *buf, size_t len, int *offset, bool clearTheMessageBeforeUse, bool isMakeStandalone, Engine::FIXTagVisitor *callback, ParseError &error, bool isIncoming) |
|
void | refineLogonMessage (Engine::FixSessionUProtocol *sn, Engine::FIXMessage *logonMsg, int outSeqnum) |
|
void | validateMessage (const char *buf, int len) |
|
virtual void | parse (LiteFixMessage *ownerMsg, const char *buf, size_t len, bool clearTheMessageBeforeUse, bool isMakeStandalone, Engine::FIXTagVisitor *callback, bool isIncoming) |
|
virtual void | setMapping (std::shared_ptr< BinaryFixMappingI > defMapping, std::shared_ptr< BinaryFixMappingI > userMapping) |
|
virtual void | setSessionParams (const Engine::SessionExtraParametersImpl ¶ms) |
|
virtual void | setSessionRole (bool isInitiator) |
|
|
static const char * | handleGarbledMsg (const char *aStartPsn, int aSize) |
|
static const char * | try_parse (const char **msgStart, const char **bufEnd) |
|
static const char * | try_parse (const Utils::RawBuffer &buffer, const char **msgStart, const char **bufEnd, int *procceedBytes) |
|
Parser::CmiBinaryProtocol::CmiBinaryProtocol |
( |
| ) |
|
bool Parser::CmiBinaryProtocol::canSendHeartbeats |
( |
bool |
initiator | ) |
|
|
virtual |
Engine::FIXMessage* Parser::CmiBinaryProtocol::createHBMessage |
( |
Engine::FixSessionUProtocol * |
sn | ) |
|
|
virtual |
static const char* Parser::CmiBinaryProtocol::handleGarbledMsg |
( |
const char * |
aStartPsn, |
|
|
int |
aSize |
|
) |
| |
|
inlinestatic |
int Parser::CmiBinaryProtocol::handleHBI |
( |
int |
hbi | ) |
|
|
virtual |
const char* Parser::CmiBinaryProtocol::operator() |
( |
const Utils::RawBuffer & |
buffer, |
|
|
const char ** |
msgStart, |
|
|
const char ** |
bufEnd, |
|
|
int * |
procceedBytes |
|
) |
| const |
|
inline |
int Parser::CmiBinaryProtocol::parseSome |
( |
LiteFixMessage * |
ownerMsg, |
|
|
const char * |
buf, |
|
|
size_t |
len, |
|
|
int * |
offset, |
|
|
bool |
clearTheMessageBeforeUse, |
|
|
bool |
isMakeStandalone, |
|
|
Engine::FIXTagVisitor * |
callback, |
|
|
ParseError & |
error, |
|
|
bool |
isIncoming |
|
) |
| |
|
virtual |
void Parser::CmiBinaryProtocol::refineLogonMessage |
( |
Engine::FixSessionUProtocol * |
sn, |
|
|
Engine::FIXMessage * |
logonMsg, |
|
|
int |
outSeqnum |
|
) |
| |
|
virtual |
static const char* Parser::CmiBinaryProtocol::try_parse |
( |
const char ** |
msgStart, |
|
|
const char ** |
bufEnd |
|
) |
| |
|
inlinestatic |
static const char* Parser::CmiBinaryProtocol::try_parse |
( |
const Utils::RawBuffer & |
buffer, |
|
|
const char ** |
msgStart, |
|
|
const char ** |
bufEnd, |
|
|
int * |
procceedBytes |
|
) |
| |
|
static |
void Parser::CmiBinaryProtocol::validateMessage |
( |
const char * |
buf, |
|
|
int |
len |
|
) |
| |
|
virtual |
const unsigned char Parser::CmiBinaryProtocol::CMI_MARKER = 0xCE |
|
static |
const int Parser::CmiBinaryProtocol::MIN_MSG_SIZE = 16 |
|
static |