MySessionStorage Class Reference

Public Types
using	Message = std::vector<char>
using	Messages = std::list<Message>

Public Member Functions
	MySessionStorage ()
const std::string &	id () const override
SeqNumber	inSeqNum () const override
void	inSeqNum (SeqNumber msgSeqNum) override
SeqNumber	outSeqNum () const override
void	outSeqNum (SeqNumber msgSeqNum) override
Timestamp	sessionCreationTime () const override
void	sessionCreationTime (Timestamp) override
void	close (bool doBackup=false) override
void	storeInboundMessage (const NetworkMessage message, SeqNumber msgSeqNum, Timestamp messageReceivingUtcTimestamp=Timestamp()) override
void	storeOutboundMessage (const NetworkMessage message, SeqNumber msgSeqNum, Timestamp messageSendingUtcTimestamp=Timestamp()) override
void	flush () override
void	warmup (size_t, Timestamp) override
Public Member Functions inherited from SessionStorage
virtual	~SessionStorage ()=default

Detailed Description

Definition at line 31 of file MySessionStorage.h.

Member Typedef Documentation

Message

using Message = std::vector<char>

Definition at line 60 of file MySessionStorage.h.

Messages

using Messages = std::list<Message>

Definition at line 61 of file MySessionStorage.h.

Constructor & Destructor Documentation

MySessionStorage()

MySessionStorage

(

)

Definition at line 46 of file MySessionStorage.cpp.

                                  :
    inSeqNum_(1),
    outSeqNum_(1),
    id_(std::to_string(IdGenerator::newId())),
    terminated_(false),
    sessionCreationTime_()
{}

Member Function Documentation

close()

void close ( bool doBackup = false )

overridevirtual

Closes the storage.

Implements SessionStorage.

Definition at line 54 of file MySessionStorage.cpp.

{
    std::clog << "\nClose the session storage (doBackup=" << doBackup <<  ").\n";
 
    inSeqNum_ = 1;
    outSeqNum_ = 1;
    terminated_ = false;
    inboundMessages_.clear();
    outboundMessages_.clear();
}

flush()

void flush ( )

overridevirtual

Flushes all internal buffers.

Implements SessionStorage.

Definition at line 119 of file MySessionStorage.cpp.

{
}

id()

const std::string & id ( ) const

overridevirtual

Returns

Storage Id.

Implements SessionStorage.

Definition at line 65 of file MySessionStorage.cpp.

{
    return id_;
}

inSeqNum() [1/2]

SeqNumber inSeqNum ( ) const

overridevirtual

Returns

the expected sequence number of the next inbound message.

Implements SessionStorage.

Definition at line 70 of file MySessionStorage.cpp.

{
    return inSeqNum_;
}

inSeqNum() [2/2]

void inSeqNum ( SeqNumber msgSeqNum )

overridevirtual

Sets the expected sequence number of the next inbound message.

Implements SessionStorage.

Definition at line 75 of file MySessionStorage.cpp.

{
    std::clog << "\nSet inSeqNum to " << msgSeqNum << ".\n";
    inSeqNum_ = msgSeqNum;
}

outSeqNum() [1/2]

SeqNumber outSeqNum ( ) const

overridevirtual

Returns

the sequence number of the next outgoing message.

Implements SessionStorage.

Definition at line 81 of file MySessionStorage.cpp.

{
    return outSeqNum_;
}

outSeqNum() [2/2]

void outSeqNum ( SeqNumber msgSeqNum )

overridevirtual

Sets the sequence number of the next outgoing message.

Implements SessionStorage.

Definition at line 86 of file MySessionStorage.cpp.

{
    std::clog << "\nSet outSeqNum to " << msgSeqNum << ".\n";
    outSeqNum_ = msgSeqNum;
}

sessionCreationTime() [1/2]

Timestamp sessionCreationTime ( ) const

overridevirtual

Returns

the session creation time.

Implements SessionStorage.

Definition at line 92 of file MySessionStorage.cpp.

{
    return sessionCreationTime_;
}

sessionCreationTime() [2/2]

void sessionCreationTime ( Timestamp )

overridevirtual

Sets the session creation time.

Implements SessionStorage.

Definition at line 97 of file MySessionStorage.cpp.

{
    std::clog << "\nSet sessionCreationTime to " << time << "\n";
    sessionCreationTime_ = time;
}

storeInboundMessage()

void storeInboundMessage ( const NetworkMessage message, SeqNumber msgSeqNum, Timestamp messageReceivingUtcTimestamp = Timestamp() )

overridevirtual

Logs the given inbound message.

Implements SessionStorage.

Definition at line 103 of file MySessionStorage.cpp.

{
    std::clog << "\nStore inbound message:\n";
    storeMessage(inboundMessages_, message);
 
    inSeqNum_ = msgSeqNum;
}

storeOutboundMessage()

void storeOutboundMessage ( const NetworkMessage message, SeqNumber msgSeqNum, Timestamp messageSendingUtcTimestamp = Timestamp() )

overridevirtual

Logs the given outgoing message.

Implements SessionStorage.

Definition at line 111 of file MySessionStorage.cpp.

{
    std::clog << "\nStore outbound message:\n";
    storeMessage(outboundMessages_, message);
 
    outSeqNum_ = msgSeqNum;
}

warmup()

void warmup ( size_t messageSize, Timestamp ts )

overridevirtual

Warmup the storage.

Implements SessionStorage.

Definition at line 123 of file MySessionStorage.cpp.

{
}