summaryrefslogtreecommitdiff
path: root/indra/llcorehttp/_httprequestqueue.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/llcorehttp/_httprequestqueue.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/llcorehttp/_httprequestqueue.cpp')
-rw-r--r--indra/llcorehttp/_httprequestqueue.cpp116
1 files changed, 58 insertions, 58 deletions
diff --git a/indra/llcorehttp/_httprequestqueue.cpp b/indra/llcorehttp/_httprequestqueue.cpp
index ad72bdcce6..df89fb85ec 100644
--- a/indra/llcorehttp/_httprequestqueue.cpp
+++ b/indra/llcorehttp/_httprequestqueue.cpp
@@ -1,6 +1,6 @@
/**
* @file _httprequestqueue.cpp
- * @brief
+ * @brief
*
* $LicenseInfo:firstyear=2012&license=viewerlgpl$
* Second Life Viewer Source Code
@@ -39,8 +39,8 @@ HttpRequestQueue * HttpRequestQueue::sInstance(NULL);
HttpRequestQueue::HttpRequestQueue()
- : RefCounted(true),
- mQueueStopped(false)
+ : RefCounted(true),
+ mQueueStopped(false)
{
}
@@ -53,99 +53,99 @@ HttpRequestQueue::~HttpRequestQueue()
void HttpRequestQueue::init()
{
- llassert_always(! sInstance);
- sInstance = new HttpRequestQueue();
+ llassert_always(! sInstance);
+ sInstance = new HttpRequestQueue();
}
void HttpRequestQueue::term()
{
- if (sInstance)
- {
- sInstance->release();
- sInstance = NULL;
- }
+ if (sInstance)
+ {
+ sInstance->release();
+ sInstance = NULL;
+ }
}
HttpStatus HttpRequestQueue::addOp(const HttpRequestQueue::opPtr_t &op)
{
- bool wake(false);
- {
- HttpScopedLock lock(mQueueMutex);
-
- if (mQueueStopped)
- {
- // Return op and error to caller
- return HttpStatus(HttpStatus::LLCORE, HE_SHUTTING_DOWN);
- }
- wake = mQueue.empty();
- mQueue.push_back(op);
- }
- if (wake)
- {
- mQueueCV.notify_all();
- }
- return HttpStatus();
+ bool wake(false);
+ {
+ HttpScopedLock lock(mQueueMutex);
+
+ if (mQueueStopped)
+ {
+ // Return op and error to caller
+ return HttpStatus(HttpStatus::LLCORE, HE_SHUTTING_DOWN);
+ }
+ wake = mQueue.empty();
+ mQueue.push_back(op);
+ }
+ if (wake)
+ {
+ mQueueCV.notify_all();
+ }
+ return HttpStatus();
}
HttpRequestQueue::opPtr_t HttpRequestQueue::fetchOp(bool wait)
{
- HttpOperation::ptr_t result;
+ HttpOperation::ptr_t result;
- {
- HttpScopedLock lock(mQueueMutex);
+ {
+ HttpScopedLock lock(mQueueMutex);
- while (mQueue.empty())
- {
- if (! wait || mQueueStopped)
+ while (mQueue.empty())
+ {
+ if (! wait || mQueueStopped)
return HttpOperation::ptr_t();
- mQueueCV.wait(lock);
- }
+ mQueueCV.wait(lock);
+ }
- result = mQueue.front();
- mQueue.erase(mQueue.begin());
- }
+ result = mQueue.front();
+ mQueue.erase(mQueue.begin());
+ }
- // Caller also acquires the reference count
- return result;
+ // Caller also acquires the reference count
+ return result;
}
void HttpRequestQueue::fetchAll(bool wait, OpContainer & ops)
{
- // Not valid putting something back on the queue...
- llassert_always(ops.empty());
+ // Not valid putting something back on the queue...
+ llassert_always(ops.empty());
- {
- HttpScopedLock lock(mQueueMutex);
+ {
+ HttpScopedLock lock(mQueueMutex);
- while (mQueue.empty())
- {
- if (! wait || mQueueStopped)
- return;
- mQueueCV.wait(lock);
- }
+ while (mQueue.empty())
+ {
+ if (! wait || mQueueStopped)
+ return;
+ mQueueCV.wait(lock);
+ }
- mQueue.swap(ops);
- }
+ mQueue.swap(ops);
+ }
- // Caller also acquires the reference counts on each op.
- return;
+ // Caller also acquires the reference counts on each op.
+ return;
}
void HttpRequestQueue::wakeAll()
{
- mQueueCV.notify_all();
+ mQueueCV.notify_all();
}
bool HttpRequestQueue::stopQueue()
{
- {
- HttpScopedLock lock(mQueueMutex);
+ {
+ HttpScopedLock lock(mQueueMutex);
if (!mQueueStopped)
{
@@ -155,7 +155,7 @@ bool HttpRequestQueue::stopQueue()
}
wakeAll();
return false;
- }
+ }
}