summaryrefslogtreecommitdiff
path: root/indra/llcommon/llheartbeat.cpp
diff options
context:
space:
mode:
authorAnsariel <ansariel.hiller@phoenixviewer.com>2024-05-22 19:04:52 +0200
committerAnsariel <ansariel.hiller@phoenixviewer.com>2024-05-22 19:04:52 +0200
commit1b67dd855c41f5a0cda7ec2a68d98071986ca703 (patch)
treeab243607f74f78200787bba5b9b88f07ef1b966f /indra/llcommon/llheartbeat.cpp
parent6d6eabca44d08d5b97bfe3e941d2b9687c2246ea (diff)
parente1623bb276f83a43ce7a197e388720c05bdefe61 (diff)
Merge remote-tracking branch 'origin/main' into DRTVWR-600-maint-A
# Conflicts: # autobuild.xml # indra/cmake/CMakeLists.txt # indra/cmake/GoogleMock.cmake # indra/llaudio/llaudioengine_fmodstudio.cpp # indra/llaudio/llaudioengine_fmodstudio.h # indra/llaudio/lllistener_fmodstudio.cpp # indra/llaudio/lllistener_fmodstudio.h # indra/llaudio/llstreamingaudio_fmodstudio.cpp # indra/llaudio/llstreamingaudio_fmodstudio.h # indra/llcharacter/llmultigesture.cpp # indra/llcharacter/llmultigesture.h # indra/llimage/llimage.cpp # indra/llimage/llimagepng.cpp # indra/llimage/llimageworker.cpp # indra/llimage/tests/llimageworker_test.cpp # indra/llmessage/tests/llmockhttpclient.h # indra/llprimitive/llgltfmaterial.h # indra/llrender/llfontfreetype.cpp # indra/llui/llcombobox.cpp # indra/llui/llfolderview.cpp # indra/llui/llfolderviewmodel.h # indra/llui/lllineeditor.cpp # indra/llui/lllineeditor.h # indra/llui/lltextbase.cpp # indra/llui/lltextbase.h # indra/llui/lltexteditor.cpp # indra/llui/lltextvalidate.cpp # indra/llui/lltextvalidate.h # indra/llui/lluictrl.h # indra/llui/llview.cpp # indra/llwindow/llwindowmacosx.cpp # indra/newview/app_settings/settings.xml # indra/newview/llappearancemgr.cpp # indra/newview/llappearancemgr.h # indra/newview/llavatarpropertiesprocessor.cpp # indra/newview/llavatarpropertiesprocessor.h # indra/newview/llbreadcrumbview.cpp # indra/newview/llbreadcrumbview.h # indra/newview/llbreastmotion.cpp # indra/newview/llbreastmotion.h # indra/newview/llconversationmodel.h # indra/newview/lldensityctrl.cpp # indra/newview/lldensityctrl.h # indra/newview/llface.inl # indra/newview/llfloatereditsky.cpp # indra/newview/llfloatereditwater.cpp # indra/newview/llfloateremojipicker.h # indra/newview/llfloaterimsessiontab.cpp # indra/newview/llfloaterprofiletexture.cpp # indra/newview/llfloaterprofiletexture.h # indra/newview/llgesturemgr.cpp # indra/newview/llgesturemgr.h # indra/newview/llimpanel.cpp # indra/newview/llimpanel.h # indra/newview/llinventorybridge.cpp # indra/newview/llinventorybridge.h # indra/newview/llinventoryclipboard.cpp # indra/newview/llinventoryclipboard.h # indra/newview/llinventoryfunctions.cpp # indra/newview/llinventoryfunctions.h # indra/newview/llinventorygallery.cpp # indra/newview/lllistbrowser.cpp # indra/newview/lllistbrowser.h # indra/newview/llpanelobjectinventory.cpp # indra/newview/llpanelprofile.cpp # indra/newview/llpanelprofile.h # indra/newview/llpreviewgesture.cpp # indra/newview/llsavedsettingsglue.cpp # indra/newview/llsavedsettingsglue.h # indra/newview/lltooldraganddrop.cpp # indra/newview/llurllineeditorctrl.cpp # indra/newview/llvectorperfoptions.cpp # indra/newview/llvectorperfoptions.h # indra/newview/llviewerparceloverlay.cpp # indra/newview/llviewertexlayer.cpp # indra/newview/llviewertexturelist.cpp # indra/newview/macmain.h # indra/test/test.cpp
Diffstat (limited to 'indra/llcommon/llheartbeat.cpp')
-rw-r--r--indra/llcommon/llheartbeat.cpp196
1 files changed, 98 insertions, 98 deletions
diff --git a/indra/llcommon/llheartbeat.cpp b/indra/llcommon/llheartbeat.cpp
index 19b7452748..96480050a5 100644
--- a/indra/llcommon/llheartbeat.cpp
+++ b/indra/llcommon/llheartbeat.cpp
@@ -5,21 +5,21 @@
* $LicenseInfo:firstyear=2008&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$
*/
@@ -33,28 +33,28 @@
#include "llheartbeat.h"
LLHeartbeat::LLHeartbeat(F32 secs_between_heartbeat,
- F32 aggressive_heartbeat_panic_secs,
- F32 aggressive_heartbeat_max_blocking_secs)
- : mSecsBetweenHeartbeat(secs_between_heartbeat),
- mAggressiveHeartbeatPanicSecs(aggressive_heartbeat_panic_secs),
- mAggressiveHeartbeatMaxBlockingSecs(aggressive_heartbeat_max_blocking_secs),
- mSuppressed(false)
+ F32 aggressive_heartbeat_panic_secs,
+ F32 aggressive_heartbeat_max_blocking_secs)
+ : mSecsBetweenHeartbeat(secs_between_heartbeat),
+ mAggressiveHeartbeatPanicSecs(aggressive_heartbeat_panic_secs),
+ mAggressiveHeartbeatMaxBlockingSecs(aggressive_heartbeat_max_blocking_secs),
+ mSuppressed(false)
{
- mBeatTimer.reset();
- mBeatTimer.setTimerExpirySec(mSecsBetweenHeartbeat);
- mPanicTimer.reset();
- mPanicTimer.setTimerExpirySec(mAggressiveHeartbeatPanicSecs);
+ mBeatTimer.reset();
+ mBeatTimer.setTimerExpirySec(mSecsBetweenHeartbeat);
+ mPanicTimer.reset();
+ mPanicTimer.setTimerExpirySec(mAggressiveHeartbeatPanicSecs);
}
LLHeartbeat::~LLHeartbeat()
{
- // do nothing.
+ // do nothing.
}
void
LLHeartbeat::setSuppressed(bool is_suppressed)
{
- mSuppressed = is_suppressed;
+ mSuppressed = is_suppressed;
}
// returns 0 on success, -1 on permanent failure, 1 on temporary failure
@@ -62,104 +62,104 @@ int
LLHeartbeat::rawSend()
{
#if LL_WINDOWS
- return 0; // Pretend we succeeded.
+ return 0; // Pretend we succeeded.
#else
- if (mSuppressed)
- return 0; // Pretend we succeeded.
+ if (mSuppressed)
+ return 0; // Pretend we succeeded.
- int result;
+ int result;
#ifndef LL_DARWIN
- union sigval dummy;
- result = sigqueue(getppid(), LL_HEARTBEAT_SIGNAL, dummy);
+ union sigval dummy;
+ result = sigqueue(getppid(), LL_HEARTBEAT_SIGNAL, dummy);
#else
- result = kill(getppid(), LL_HEARTBEAT_SIGNAL);
+ result = kill(getppid(), LL_HEARTBEAT_SIGNAL);
#endif
- if (result == 0)
- return 0; // success
+ if (result == 0)
+ return 0; // success
- int err = errno;
- if (err == EAGAIN)
- return 1; // failed to queue, try again
+ int err = errno;
+ if (err == EAGAIN)
+ return 1; // failed to queue, try again
- return -1; // other failure.
+ return -1; // other failure.
#endif
}
int
LLHeartbeat::rawSendWithTimeout(F32 timeout_sec)
{
- int result = 0;
-
- // Spin tightly until our heartbeat is digested by the watchdog
- // or we time-out. We don't really want to sleep because our
- // wake-up time might be undesirably synchronised to a hidden
- // clock by the system's scheduler.
- mTimeoutTimer.reset();
- mTimeoutTimer.setTimerExpirySec(timeout_sec);
- do {
- result = rawSend();
- //LL_INFOS() << " HEARTSENDc=" << result << LL_ENDL;
- } while (result==1 && !mTimeoutTimer.hasExpired());
-
- return result;
+ int result = 0;
+
+ // Spin tightly until our heartbeat is digested by the watchdog
+ // or we time-out. We don't really want to sleep because our
+ // wake-up time might be undesirably synchronised to a hidden
+ // clock by the system's scheduler.
+ mTimeoutTimer.reset();
+ mTimeoutTimer.setTimerExpirySec(timeout_sec);
+ do {
+ result = rawSend();
+ //LL_INFOS() << " HEARTSENDc=" << result << LL_ENDL;
+ } while (result==1 && !mTimeoutTimer.hasExpired());
+
+ return result;
}
bool
LLHeartbeat::send(F32 timeout_sec)
{
- bool total_success = false;
- int result = 1;
-
- if (timeout_sec > 0.f) {
- // force a spin until success or timeout
- result = rawSendWithTimeout(timeout_sec);
- } else {
- if (mBeatTimer.hasExpired()) {
- // zero-timeout; we don't care too much whether our
- // heartbeat was digested.
- result = rawSend();
- //LL_INFOS() << " HEARTSENDb=" << result << LL_ENDL;
- }
- }
-
- if (result == -1) {
- // big failure.
- } else if (result == 0) {
- total_success = true;
- } else {
- // need to retry at some point
- }
-
- if (total_success) {
- mBeatTimer.reset();
- mBeatTimer.setTimerExpirySec(mSecsBetweenHeartbeat);
- // reset the time until we start panicking about lost
- // heartbeats again.
- mPanicTimer.reset();
- mPanicTimer.setTimerExpirySec(mAggressiveHeartbeatPanicSecs);
- } else {
- // leave mBeatTimer as expired so we'll lazily poke the
- // watchdog again next time through.
- }
-
- if (mPanicTimer.hasExpired()) {
- // It's been ages since we successfully had a heartbeat
- // digested by the watchdog. Sit here and spin a while
- // in the hope that we can force it through.
- LL_WARNS() << "Unable to deliver heartbeat to launcher for " << mPanicTimer.getElapsedTimeF32() << " seconds. Going to try very hard for up to " << mAggressiveHeartbeatMaxBlockingSecs << " seconds." << LL_ENDL;
- result = rawSendWithTimeout(mAggressiveHeartbeatMaxBlockingSecs);
- if (result == 0) {
- total_success = true;
- } else {
- // we couldn't even force it through. That's bad,
- // but we'll try again in a while.
- LL_WARNS() << "Could not deliver heartbeat to launcher even after trying very hard for " << mAggressiveHeartbeatMaxBlockingSecs << " seconds." << LL_ENDL;
- }
-
- // in any case, reset the panic timer.
- mPanicTimer.reset();
- mPanicTimer.setTimerExpirySec(mAggressiveHeartbeatPanicSecs);
- }
-
- return total_success;
+ bool total_success = false;
+ int result = 1;
+
+ if (timeout_sec > 0.f) {
+ // force a spin until success or timeout
+ result = rawSendWithTimeout(timeout_sec);
+ } else {
+ if (mBeatTimer.hasExpired()) {
+ // zero-timeout; we don't care too much whether our
+ // heartbeat was digested.
+ result = rawSend();
+ //LL_INFOS() << " HEARTSENDb=" << result << LL_ENDL;
+ }
+ }
+
+ if (result == -1) {
+ // big failure.
+ } else if (result == 0) {
+ total_success = true;
+ } else {
+ // need to retry at some point
+ }
+
+ if (total_success) {
+ mBeatTimer.reset();
+ mBeatTimer.setTimerExpirySec(mSecsBetweenHeartbeat);
+ // reset the time until we start panicking about lost
+ // heartbeats again.
+ mPanicTimer.reset();
+ mPanicTimer.setTimerExpirySec(mAggressiveHeartbeatPanicSecs);
+ } else {
+ // leave mBeatTimer as expired so we'll lazily poke the
+ // watchdog again next time through.
+ }
+
+ if (mPanicTimer.hasExpired()) {
+ // It's been ages since we successfully had a heartbeat
+ // digested by the watchdog. Sit here and spin a while
+ // in the hope that we can force it through.
+ LL_WARNS() << "Unable to deliver heartbeat to launcher for " << mPanicTimer.getElapsedTimeF32() << " seconds. Going to try very hard for up to " << mAggressiveHeartbeatMaxBlockingSecs << " seconds." << LL_ENDL;
+ result = rawSendWithTimeout(mAggressiveHeartbeatMaxBlockingSecs);
+ if (result == 0) {
+ total_success = true;
+ } else {
+ // we couldn't even force it through. That's bad,
+ // but we'll try again in a while.
+ LL_WARNS() << "Could not deliver heartbeat to launcher even after trying very hard for " << mAggressiveHeartbeatMaxBlockingSecs << " seconds." << LL_ENDL;
+ }
+
+ // in any case, reset the panic timer.
+ mPanicTimer.reset();
+ mPanicTimer.setTimerExpirySec(mAggressiveHeartbeatPanicSecs);
+ }
+
+ return total_success;
}