diff options
Diffstat (limited to 'indra/newview/llviewerthrottle.cpp')
-rw-r--r-- | indra/newview/llviewerthrottle.cpp | 378 |
1 files changed, 189 insertions, 189 deletions
diff --git a/indra/newview/llviewerthrottle.cpp b/indra/newview/llviewerthrottle.cpp index 20390a316a..8482bc603b 100644 --- a/indra/newview/llviewerthrottle.cpp +++ b/indra/newview/llviewerthrottle.cpp @@ -1,25 +1,25 @@ -/** +/** * @file llviewerthrottle.cpp * @brief LLViewerThrottle class implementation * * $LicenseInfo:firstyear=2002&license=viewerlgpl$ * Second Life Viewer Source Code * Copyright (C) 2010, Linden Research, Inc. - * + * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; * version 2.1 of the License only. - * + * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. - * + * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA - * + * * Linden Research, Inc., 945 Battery Street, San Francisco, CA 94111 USA * $/LicenseInfo$ */ @@ -56,14 +56,14 @@ LLViewerThrottle gViewerThrottle; // static const std:: string LLViewerThrottle::sNames[TC_EOF] = { - "Resend", - "Land", - "Wind", - "Cloud", - "Task", - "Texture", - "Asset" - }; + "Resend", + "Land", + "Wind", + "Cloud", + "Task", + "Texture", + "Asset" + }; // Bandwidth settings for different bit rates, they're interpolated/extrapolated. @@ -75,260 +75,260 @@ const F32 BW_PRESET_1000[TC_EOF] = { 100, 100, 20, 20, 310, 310, 140 }; LLViewerThrottleGroup::LLViewerThrottleGroup() { - S32 i; - for (i = 0; i < TC_EOF; i++) - { - mThrottles[i] = 0.f; - } - mThrottleTotal = 0.f; + S32 i; + for (i = 0; i < TC_EOF; i++) + { + mThrottles[i] = 0.f; + } + mThrottleTotal = 0.f; } LLViewerThrottleGroup::LLViewerThrottleGroup(const F32 settings[TC_EOF]) { - mThrottleTotal = 0.f; - S32 i; - for (i = 0; i < TC_EOF; i++) - { - mThrottles[i] = settings[i]; - mThrottleTotal += settings[i]; - } + mThrottleTotal = 0.f; + S32 i; + for (i = 0; i < TC_EOF; i++) + { + mThrottles[i] = settings[i]; + mThrottleTotal += settings[i]; + } } LLViewerThrottleGroup LLViewerThrottleGroup::operator*(const F32 frac) const { - LLViewerThrottleGroup res; - res.mThrottleTotal = 0.f; + LLViewerThrottleGroup res; + res.mThrottleTotal = 0.f; - S32 i; - for (i = 0; i < TC_EOF; i++) - { - res.mThrottles[i] = mThrottles[i] * frac; - res.mThrottleTotal += res.mThrottles[i]; - } + S32 i; + for (i = 0; i < TC_EOF; i++) + { + res.mThrottles[i] = mThrottles[i] * frac; + res.mThrottleTotal += res.mThrottles[i]; + } - return res; + return res; } LLViewerThrottleGroup LLViewerThrottleGroup::operator+(const LLViewerThrottleGroup &b) const { - LLViewerThrottleGroup res; - res.mThrottleTotal = 0.f; + LLViewerThrottleGroup res; + res.mThrottleTotal = 0.f; - S32 i; - for (i = 0; i < TC_EOF; i++) - { - res.mThrottles[i] = mThrottles[i] + b.mThrottles[i]; - res.mThrottleTotal += res.mThrottles[i]; - } + S32 i; + for (i = 0; i < TC_EOF; i++) + { + res.mThrottles[i] = mThrottles[i] + b.mThrottles[i]; + res.mThrottleTotal += res.mThrottles[i]; + } - return res; + return res; } LLViewerThrottleGroup LLViewerThrottleGroup::operator-(const LLViewerThrottleGroup &b) const { - LLViewerThrottleGroup res; - res.mThrottleTotal = 0.f; + LLViewerThrottleGroup res; + res.mThrottleTotal = 0.f; - S32 i; - for (i = 0; i < TC_EOF; i++) - { - res.mThrottles[i] = mThrottles[i] - b.mThrottles[i]; - res.mThrottleTotal += res.mThrottles[i]; - } + S32 i; + for (i = 0; i < TC_EOF; i++) + { + res.mThrottles[i] = mThrottles[i] - b.mThrottles[i]; + res.mThrottleTotal += res.mThrottles[i]; + } - return res; + return res; } void LLViewerThrottleGroup::sendToSim() const { - LL_INFOS() << "Sending throttle settings, total BW " << mThrottleTotal << LL_ENDL; - LLMessageSystem* msg = gMessageSystem; - - msg->newMessageFast(_PREHASH_AgentThrottle); - msg->nextBlockFast(_PREHASH_AgentData); - msg->addUUIDFast(_PREHASH_AgentID, gAgent.getID()); - msg->addUUIDFast(_PREHASH_SessionID, gAgent.getSessionID()); - msg->addU32Fast(_PREHASH_CircuitCode, msg->mOurCircuitCode); - - msg->nextBlockFast(_PREHASH_Throttle); - msg->addU32Fast(_PREHASH_GenCounter, 0); - - // Pack up the throttle data - U8 tmp[64]; - LLDataPackerBinaryBuffer dp(tmp, MAX_THROTTLE_SIZE); - S32 i; - for (i = 0; i < TC_EOF; i++) - { - //sim wants BPS, not KBPS - dp.packF32(mThrottles[i] * 1024.0f, "Throttle"); - } - S32 len = dp.getCurrentSize(); - msg->addBinaryDataFast(_PREHASH_Throttles, tmp, len); - - gAgent.sendReliableMessage(); + LL_INFOS() << "Sending throttle settings, total BW " << mThrottleTotal << LL_ENDL; + LLMessageSystem* msg = gMessageSystem; + + msg->newMessageFast(_PREHASH_AgentThrottle); + msg->nextBlockFast(_PREHASH_AgentData); + msg->addUUIDFast(_PREHASH_AgentID, gAgent.getID()); + msg->addUUIDFast(_PREHASH_SessionID, gAgent.getSessionID()); + msg->addU32Fast(_PREHASH_CircuitCode, msg->mOurCircuitCode); + + msg->nextBlockFast(_PREHASH_Throttle); + msg->addU32Fast(_PREHASH_GenCounter, 0); + + // Pack up the throttle data + U8 tmp[64]; + LLDataPackerBinaryBuffer dp(tmp, MAX_THROTTLE_SIZE); + S32 i; + for (i = 0; i < TC_EOF; i++) + { + //sim wants BPS, not KBPS + dp.packF32(mThrottles[i] * 1024.0f, "Throttle"); + } + S32 len = dp.getCurrentSize(); + msg->addBinaryDataFast(_PREHASH_Throttles, tmp, len); + + gAgent.sendReliableMessage(); } void LLViewerThrottleGroup::dump() { - S32 i; - for (i = 0; i < TC_EOF; i++) - { - LL_DEBUGS("Throttle") << LLViewerThrottle::sNames[i] << ": " << mThrottles[i] << LL_ENDL; - } - LL_DEBUGS("Throttle") << "Total: " << mThrottleTotal << LL_ENDL; + S32 i; + for (i = 0; i < TC_EOF; i++) + { + LL_DEBUGS("Throttle") << LLViewerThrottle::sNames[i] << ": " << mThrottles[i] << LL_ENDL; + } + LL_DEBUGS("Throttle") << "Total: " << mThrottleTotal << LL_ENDL; } class LLBPSListener : public LLSimpleListener { public: - virtual bool handleEvent(LLPointer<LLEvent> event, const LLSD& userdata) - { - gViewerThrottle.setMaxBandwidth((F32) event->getValue().asReal()*1024); - return true; - } + virtual bool handleEvent(LLPointer<LLEvent> event, const LLSD& userdata) + { + gViewerThrottle.setMaxBandwidth((F32) event->getValue().asReal()*1024); + return true; + } }; LLViewerThrottle::LLViewerThrottle() : - mMaxBandwidth(0.f), - mCurrentBandwidth(0.f), - mThrottleFrac(1.f) + mMaxBandwidth(0.f), + mCurrentBandwidth(0.f), + mThrottleFrac(1.f) { - // Need to be pushed on in bandwidth order - mPresets.push_back(LLViewerThrottleGroup(BW_PRESET_50)); - mPresets.push_back(LLViewerThrottleGroup(BW_PRESET_300)); - mPresets.push_back(LLViewerThrottleGroup(BW_PRESET_500)); - mPresets.push_back(LLViewerThrottleGroup(BW_PRESET_1000)); + // Need to be pushed on in bandwidth order + mPresets.push_back(LLViewerThrottleGroup(BW_PRESET_50)); + mPresets.push_back(LLViewerThrottleGroup(BW_PRESET_300)); + mPresets.push_back(LLViewerThrottleGroup(BW_PRESET_500)); + mPresets.push_back(LLViewerThrottleGroup(BW_PRESET_1000)); } void LLViewerThrottle::setMaxBandwidth(F32 kbits_per_second, BOOL from_event) { - if (!from_event) - { - gSavedSettings.setF32("ThrottleBandwidthKBPS", kbits_per_second); - } - gViewerThrottle.load(); - - if (gAgent.getRegion()) - { - gViewerThrottle.sendToSim(); - } + if (!from_event) + { + gSavedSettings.setF32("ThrottleBandwidthKBPS", kbits_per_second); + } + gViewerThrottle.load(); + + if (gAgent.getRegion()) + { + gViewerThrottle.sendToSim(); + } } void LLViewerThrottle::load() { - mMaxBandwidth = gSavedSettings.getF32("ThrottleBandwidthKBPS")*1024; - resetDynamicThrottle(); - mCurrent.dump(); + mMaxBandwidth = gSavedSettings.getF32("ThrottleBandwidthKBPS")*1024; + resetDynamicThrottle(); + mCurrent.dump(); } void LLViewerThrottle::save() const { - gSavedSettings.setF32("ThrottleBandwidthKBPS", mMaxBandwidth/1024); + gSavedSettings.setF32("ThrottleBandwidthKBPS", mMaxBandwidth/1024); } void LLViewerThrottle::sendToSim() const { - mCurrent.sendToSim(); + mCurrent.sendToSim(); } LLViewerThrottleGroup LLViewerThrottle::getThrottleGroup(const F32 bandwidth_kbps) { - //Clamp the bandwidth users can set. - F32 set_bandwidth = llclamp(bandwidth_kbps, MIN_BANDWIDTH, MAX_BANDWIDTH); - - S32 count = mPresets.size(); - - S32 i; - for (i = 0; i < count; i++) - { - if (mPresets[i].getTotal() > set_bandwidth) - { - break; - } - } - - if (i == 0) - { - // We return the minimum if it's less than the minimum - return mPresets[0]; - } - else if (i == count) - { - // Higher than the highest preset, we extrapolate out based on the - // last two presets. This allows us to keep certain throttle channels from - // growing in bandwidth - F32 delta_bw = set_bandwidth - mPresets[count-1].getTotal(); - LLViewerThrottleGroup delta_throttle = mPresets[count - 1] - mPresets[count - 2]; - F32 delta_total = delta_throttle.getTotal(); - F32 delta_frac = delta_bw / delta_total; - delta_throttle = delta_throttle * delta_frac; - return mPresets[count-1] + delta_throttle; - } - else - { - // In between two presets, just interpolate - F32 delta_bw = set_bandwidth - mPresets[i - 1].getTotal(); - LLViewerThrottleGroup delta_throttle = mPresets[i] - mPresets[i - 1]; - F32 delta_total = delta_throttle.getTotal(); - F32 delta_frac = delta_bw / delta_total; - delta_throttle = delta_throttle * delta_frac; - return mPresets[i - 1] + delta_throttle; - } + //Clamp the bandwidth users can set. + F32 set_bandwidth = llclamp(bandwidth_kbps, MIN_BANDWIDTH, MAX_BANDWIDTH); + + S32 count = mPresets.size(); + + S32 i; + for (i = 0; i < count; i++) + { + if (mPresets[i].getTotal() > set_bandwidth) + { + break; + } + } + + if (i == 0) + { + // We return the minimum if it's less than the minimum + return mPresets[0]; + } + else if (i == count) + { + // Higher than the highest preset, we extrapolate out based on the + // last two presets. This allows us to keep certain throttle channels from + // growing in bandwidth + F32 delta_bw = set_bandwidth - mPresets[count-1].getTotal(); + LLViewerThrottleGroup delta_throttle = mPresets[count - 1] - mPresets[count - 2]; + F32 delta_total = delta_throttle.getTotal(); + F32 delta_frac = delta_bw / delta_total; + delta_throttle = delta_throttle * delta_frac; + return mPresets[count-1] + delta_throttle; + } + else + { + // In between two presets, just interpolate + F32 delta_bw = set_bandwidth - mPresets[i - 1].getTotal(); + LLViewerThrottleGroup delta_throttle = mPresets[i] - mPresets[i - 1]; + F32 delta_total = delta_throttle.getTotal(); + F32 delta_frac = delta_bw / delta_total; + delta_throttle = delta_throttle * delta_frac; + return mPresets[i - 1] + delta_throttle; + } } // static void LLViewerThrottle::resetDynamicThrottle() { - mThrottleFrac = MAX_FRACTIONAL; + mThrottleFrac = MAX_FRACTIONAL; - mCurrentBandwidth = mMaxBandwidth*MAX_FRACTIONAL; - mCurrent = getThrottleGroup(mCurrentBandwidth / 1024.0f); + mCurrentBandwidth = mMaxBandwidth*MAX_FRACTIONAL; + mCurrent = getThrottleGroup(mCurrentBandwidth / 1024.0f); } void LLViewerThrottle::updateDynamicThrottle() { - if (mUpdateTimer.getElapsedTimeF32() < DYNAMIC_UPDATE_DURATION) - { - return; - } - mUpdateTimer.reset(); - - LLUnit<F32, LLUnits::Percent> mean_packets_lost = LLViewerStats::instance().getRecording().getMean(LLStatViewer::PACKETS_LOST_PERCENT); - if (mean_packets_lost > TIGHTEN_THROTTLE_THRESHOLD) - { - if (mThrottleFrac <= MIN_FRACTIONAL || mCurrentBandwidth / 1024.0f <= MIN_BANDWIDTH) - { - return; - } - mThrottleFrac -= STEP_FRACTIONAL; - mThrottleFrac = llmax(MIN_FRACTIONAL, mThrottleFrac); - mCurrentBandwidth = mMaxBandwidth * mThrottleFrac; - mCurrent = getThrottleGroup(mCurrentBandwidth / 1024.0f); - mCurrent.sendToSim(); - LL_INFOS() << "Tightening network throttle to " << mCurrentBandwidth << LL_ENDL; - } - else if (mean_packets_lost <= EASE_THROTTLE_THRESHOLD) - { - if (mThrottleFrac >= MAX_FRACTIONAL || mCurrentBandwidth / 1024.0f >= MAX_BANDWIDTH) - { - return; - } - mThrottleFrac += STEP_FRACTIONAL; - mThrottleFrac = llmin(MAX_FRACTIONAL, mThrottleFrac); - mCurrentBandwidth = mMaxBandwidth * mThrottleFrac; - mCurrent = getThrottleGroup(mCurrentBandwidth/1024.0f); - mCurrent.sendToSim(); - LL_INFOS() << "Easing network throttle to " << mCurrentBandwidth << LL_ENDL; - } + if (mUpdateTimer.getElapsedTimeF32() < DYNAMIC_UPDATE_DURATION) + { + return; + } + mUpdateTimer.reset(); + + LLUnit<F32, LLUnits::Percent> mean_packets_lost = LLViewerStats::instance().getRecording().getMean(LLStatViewer::PACKETS_LOST_PERCENT); + if (mean_packets_lost > TIGHTEN_THROTTLE_THRESHOLD) + { + if (mThrottleFrac <= MIN_FRACTIONAL || mCurrentBandwidth / 1024.0f <= MIN_BANDWIDTH) + { + return; + } + mThrottleFrac -= STEP_FRACTIONAL; + mThrottleFrac = llmax(MIN_FRACTIONAL, mThrottleFrac); + mCurrentBandwidth = mMaxBandwidth * mThrottleFrac; + mCurrent = getThrottleGroup(mCurrentBandwidth / 1024.0f); + mCurrent.sendToSim(); + LL_INFOS() << "Tightening network throttle to " << mCurrentBandwidth << LL_ENDL; + } + else if (mean_packets_lost <= EASE_THROTTLE_THRESHOLD) + { + if (mThrottleFrac >= MAX_FRACTIONAL || mCurrentBandwidth / 1024.0f >= MAX_BANDWIDTH) + { + return; + } + mThrottleFrac += STEP_FRACTIONAL; + mThrottleFrac = llmin(MAX_FRACTIONAL, mThrottleFrac); + mCurrentBandwidth = mMaxBandwidth * mThrottleFrac; + mCurrent = getThrottleGroup(mCurrentBandwidth/1024.0f); + mCurrent.sendToSim(); + LL_INFOS() << "Easing network throttle to " << mCurrentBandwidth << LL_ENDL; + } } |