lllogtextmessage.cpp

Go to the documentation of this file.

#include "linden_common.h"
#include "lllogtextmessage.h"

#include "message.h"


LLLogTextMessage::~LLLogTextMessage()
{
        S32 queue_size = (S32)mQueue.size();
        if(queue_size > 0)
        {
                llwarns << "Deleting queus with messages still on it." << llendl;
        }
}

void LLLogTextMessage::log(
        const LLUUID& from,
        const LLUUID& to,
        const char* mesg)
{
        const F64 F64_ZERO = 0.0;
        log(from, to, F64_ZERO, F64_ZERO, mesg);
}

void LLLogTextMessage::log(
        const LLUUID& from,
        F64 global_x,
        F64 global_y,
        const char* mesg)
{
        log(from, LLUUID::null, global_x, global_y, mesg);
}

void LLLogTextMessage::log(
        const LLUUID& from,
        const LLUUID& to,
        F64 global_x,
        F64 global_y,
        const char* mesg)
{
        const S32 OVERHEAD = (2*sizeof(LLUUID))+(2*sizeof(F64))+(sizeof(S32));
        const U32 MAX_LOGS_PER_MSG = 100;
        const U32 LOG_MTU = 4000;
        LLLogTextMessageData data(from, to, global_x, global_y, mesg);
        mQueue.push_back(data);
        mPendingSize += (S32)(OVERHEAD + data.mMessage.size());
        if((mQueue.size() >= MAX_LOGS_PER_MSG) || (mPendingSize > (S32)LOG_MTU))
        {
                flush();
        }
}

void LLLogTextMessage::flush()
{
        mPendingSize = 0;
        if(mQueue.empty()) return;
        LLMessageSystem* msg = gMessageSystem;
        msg->newMessageFast(_PREHASH_LogTextMessage);
        while(!mQueue.empty())
        {
                LLLogTextMessageData data(mQueue.front());
                mQueue.pop_front();
                msg->nextBlockFast(_PREHASH_DataBlock);
                msg->addUUIDFast(_PREHASH_FromAgentId, data.mFromID);
                msg->addUUIDFast(_PREHASH_ToAgentId, data.mToID);
                msg->addF64Fast(_PREHASH_GlobalX, data.mGlobalX);
                msg->addF64Fast(_PREHASH_GlobalY, data.mGlobalY);
                msg->addU32Fast(_PREHASH_Time, data.mTime);
                msg->addStringFast(_PREHASH_Message, data.mMessage.c_str());
        }

        // Try to make this reliable, but don't try too hard
        msg->sendReliable(mDataserver, 3, TRUE, 0.f, NULL, NULL);
}

LLLogTextMessage::LLLogTextMessageData::LLLogTextMessageData(
        const LLUUID& from,
        const LLUUID& to,
        const F64& global_x,
        const F64& gloabl_y,
        const char* message) :
        mFromID(from),
        mToID(to),
        mGlobalX(global_x),
        mGlobalY(gloabl_y),
        mMessage(message)
{
        mTime = (S32)time(NULL);
}

---