opentxs::OTMessageBuffer Class Reference

#include <OTMessageBuffer.hpp>

Public Member Functions
	OTMessageBuffer ()
EXPORT	~OTMessageBuffer ()
EXPORT void	Clear ()
EXPORT void	Push (OTMessage &message)
EXPORT OTMessage *	Pop (const int64_t &requestNum, const OTString &serverId, const OTString &nymId)

Detailed Description

Definition at line 144 of file OTMessageBuffer.hpp.

Constructor & Destructor Documentation

opentxs::OTMessageBuffer::OTMessageBuffer ( )

inline

Definition at line 147 of file OTMessageBuffer.hpp.

    {
    }

opentxs::OTMessageBuffer::~OTMessageBuffer

(

)

Definition at line 251 of file OTMessageBuffer.cpp.

{
    Clear();
}

Member Function Documentation

void opentxs::OTMessageBuffer::Clear

(

)

Definition at line 256 of file OTMessageBuffer.cpp.

{
    while (!messages_.empty()) {
        OTMessage* pMsg = messages_.front();
        messages_.pop_front();

        if (nullptr != pMsg) delete pMsg;
        pMsg = nullptr;
    }
}

OTMessage * opentxs::OTMessageBuffer::Pop	(	const int64_t &	requestNum,
		const OTString &	serverId,
		const OTString &	nymId
	)

Definition at line 174 of file OTMessageBuffer.cpp.

{
    OTMessage* pReturnValue = nullptr;

    Messages temp_list;

    while (!messages_.empty()) {

        OTMessage* pMsg = messages_.front();

        messages_.pop_front();

        if (nullptr == pMsg) {
            otErr << "OTMessageBuffer::Pop: Error: List of incoming server "
                     "replies "
                     "is NOT empty, yet when Pop was called, pMsg was nullptr! "
                     "(Skipping.)\n";
            continue;
        }

        // Below this point, pMsg has been popped, and it's NOT nullptr, and it
        // will be lost if not tracked or returned.
        //
        if (!strServerID.Compare(pMsg->m_strServerID) ||
            !strNymID.Compare(pMsg->m_strNymID)) {
            temp_list.push_front(
                pMsg); // Save it, so we can push it back again after this loop.
            continue;
        }
        // Below this point, we KNOW that pMsg has the CORRECT ServerID and
        // NymID.
        // (And that all others, though popped, were pushed to temp_list in
        // order.)

        const int64_t lMsgRequest = atol(pMsg->m_strRequestNum.Get());

        // Now we only need to see if the request number matches...
        //
        if (lMsgRequest == lRequestNum) {
            pReturnValue = pMsg;
            break;
        }
        else // Server/Nym IDs match, BUT -- Wrong request num! (Discard
               // message and skip.)
        {
            otOut << "OTMessageBuffer::Pop: Warning: While looking for server ("
                  << strServerID << ") reply to request number " << lRequestNum
                  << " for Nym (" << strNymID
                  << "), "
                     "discovered (and discarded) an old server reply for "
                     "request number " << lMsgRequest << " "
                                                         "(A "
                  << pMsg->m_strCommand
                  << " command. The client should have flushed it by now "
                     "anyway, so it was probably slow on the network "
                     "and then assumed to have been dropped. It's okay--the "
                     "protocol is designed to handle these occurrences.)\n";
            delete pMsg;
            pMsg = nullptr;
            continue;
        }

    } // while

    // Put the other messages back, in order...
    //
    while (!temp_list.empty()) {
        OTMessage* pMsg = temp_list.front();
        temp_list.pop_front();
        messages_.push_front(pMsg);
    }

    return pReturnValue;
}

void opentxs::OTMessageBuffer::Push

(

OTMessage &

message

)

Definition at line 148 of file OTMessageBuffer.cpp.

{
    messages_.push_back(&theMessage);
}

---

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

• /usr/local/src/opentxs/include/opentxs/client/OTMessageBuffer.hpp
• /usr/local/src/opentxs/src/client/OTMessageBuffer.cpp