summaryrefslogtreecommitdiff
path: root/indra/newview/llviewerthrottle.cpp
diff options
context:
space:
mode:
authorNat Goodspeed <nat@lindenlab.com>2024-05-15 12:18:31 -0400
committerNat Goodspeed <nat@lindenlab.com>2024-05-15 12:18:31 -0400
commit7ccf02515ad3f9e3bf795d651fe4b3c0d773f353 (patch)
treec4adc897c07f652e617e91fbf41c12b823acc808 /indra/newview/llviewerthrottle.cpp
parent1abf5f18d6afc7ae9e1b1562b92e5c1ce33b722f (diff)
parente7eced3c87310b15ac20cc3cd470d67686104a14 (diff)
Merge commit 'e7eced3' into lua-timers for whitespace fixes.
Diffstat (limited to 'indra/newview/llviewerthrottle.cpp')
-rw-r--r--indra/newview/llviewerthrottle.cpp378
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;
+ }
}