diff options
Diffstat (limited to 'indra/llmessage')
| -rw-r--r-- | indra/llmessage/llpacketring.cpp | 6 | ||||
| -rw-r--r-- | indra/llmessage/llpacketring.h | 1 | ||||
| -rw-r--r-- | indra/llmessage/message.h | 4 | 
3 files changed, 8 insertions, 3 deletions
| diff --git a/indra/llmessage/llpacketring.cpp b/indra/llmessage/llpacketring.cpp index da3c502e9d..eb6650c6c5 100644 --- a/indra/llmessage/llpacketring.cpp +++ b/indra/llmessage/llpacketring.cpp @@ -344,6 +344,12 @@ bool LLPacketRing::expandRing()      return true;  } +F32 LLPacketRing::getBufferLoadRate() const +{ +    // goes up to MAX_BUFFER_RING_SIZE +    return (F32)mNumBufferedPackets / (F32)DEFAULT_BUFFER_RING_SIZE; +} +  void LLPacketRing::dumpPacketRingStats()  {      mNumDroppedPacketsTotal += mNumDroppedPackets; diff --git a/indra/llmessage/llpacketring.h b/indra/llmessage/llpacketring.h index 237efc12e0..572dcbd271 100644 --- a/indra/llmessage/llpacketring.h +++ b/indra/llmessage/llpacketring.h @@ -64,6 +64,7 @@ public:      S32 getNumBufferedBytes() const { return mNumBufferedBytes; }      S32 getNumDroppedPackets() const { return mNumDroppedPacketsTotal + mNumDroppedPackets; } +    F32 getBufferLoadRate() const; // from 0 to 4 (0 - empty, 1 - default size is full)      void dumpPacketRingStats();  protected:      // returns 'true' if we should intentionally drop a packet diff --git a/indra/llmessage/message.h b/indra/llmessage/message.h index 1844d5e7cd..30945cac51 100644 --- a/indra/llmessage/message.h +++ b/indra/llmessage/message.h @@ -538,7 +538,6 @@ public:      //void  buildMessage(); -    S32     zeroCode(U8 **data, S32 *data_size);      S32     zeroCodeExpand(U8 **data, S32 *data_size);      S32     zeroCodeAdjustCurrentSendTotal(); @@ -755,6 +754,7 @@ public:      S32     getReceiveBytes() const;      S32     getUnackedListSize() const          { return mUnackedListSize; } +    F32     getBufferLoadRate() const           { return mPacketRing.getBufferLoadRate(); }      //const char* getCurrentSMessageName() const { return mCurrentSMessageName; }      //const char* getCurrentSBlockName() const { return mCurrentSBlockName; } @@ -842,12 +842,10 @@ private:      LLUUID mSessionID;      void    addTemplate(LLMessageTemplate *templatep); -    bool        decodeTemplate( const U8* buffer, S32 buffer_size, LLMessageTemplate** msg_template );      void        logMsgFromInvalidCircuit( const LLHost& sender, bool recv_reliable );      void        logTrustedMsgFromUntrustedCircuit( const LLHost& sender );      void        logValidMsg(LLCircuitData *cdp, const LLHost& sender, bool recv_reliable, bool recv_resent, bool recv_acks ); -    void        logRanOffEndOfPacket( const LLHost& sender );      class LLMessageCountInfo      { | 
