summaryrefslogtreecommitdiff
path: root/indra/llplugin
diff options
context:
space:
mode:
Diffstat (limited to 'indra/llplugin')
-rw-r--r--indra/llplugin/llpluginmessagepipe.cpp9
-rw-r--r--indra/llplugin/llpluginprocessparent.cpp78
-rw-r--r--indra/llplugin/llpluginprocessparent.h2
3 files changed, 46 insertions, 43 deletions
diff --git a/indra/llplugin/llpluginmessagepipe.cpp b/indra/llplugin/llpluginmessagepipe.cpp
index a62534de95..89f8b44569 100644
--- a/indra/llplugin/llpluginmessagepipe.cpp
+++ b/indra/llplugin/llpluginmessagepipe.cpp
@@ -117,10 +117,9 @@ LLPluginMessagePipe::~LLPluginMessagePipe()
bool LLPluginMessagePipe::addMessage(const std::string &message)
{
// queue the message for later output
- mOutputMutex.lock();
+ LLMutexLock lock(&mOutputMutex);
mOutput += message;
mOutput += MESSAGE_DELIMITER; // message separator
- mOutputMutex.unlock();
return true;
}
@@ -173,7 +172,7 @@ bool LLPluginMessagePipe::pumpOutput()
apr_status_t status;
apr_size_t size;
- mOutputMutex.lock();
+ LLMutexLock lock(&mOutputMutex);
if(!mOutput.empty())
{
// write any outgoing messages
@@ -225,7 +224,6 @@ bool LLPluginMessagePipe::pumpOutput()
result = false;
}
}
- mOutputMutex.unlock();
}
return result;
@@ -288,9 +286,8 @@ bool LLPluginMessagePipe::pumpInput(F64 timeout)
if(size > 0)
{
- mInputMutex.lock();
+ LLMutexLock lock(&mInputMutex);
mInput.append(input_buf, size);
- mInputMutex.unlock();
}
if(status == APR_SUCCESS)
diff --git a/indra/llplugin/llpluginprocessparent.cpp b/indra/llplugin/llpluginprocessparent.cpp
index c61a903a2c..9d510e737d 100644
--- a/indra/llplugin/llpluginprocessparent.cpp
+++ b/indra/llplugin/llpluginprocessparent.cpp
@@ -50,7 +50,7 @@ apr_pollset_t *LLPluginProcessParent::sPollSet = NULL;
bool LLPluginProcessParent::sPollsetNeedsRebuild = false;
LLMutex *LLPluginProcessParent::sInstancesMutex;
std::list<LLPluginProcessParent*> LLPluginProcessParent::sInstances;
-LLThread *LLPluginProcessParent::sPollThread = NULL;
+LLThread *LLPluginProcessParent::sReadThread = NULL;
class LLPluginProcessParentPollThread: public LLThread
@@ -108,9 +108,10 @@ LLPluginProcessParent::LLPluginProcessParent(LLPluginProcessParentOwner *owner):
mHeartbeat.stop();
// Don't add to the global list until fully constructed.
- sInstancesMutex->lock();
- sInstances.push_back(this);
- sInstancesMutex->unlock();
+ {
+ LLMutexLock lock(sInstancesMutex);
+ sInstances.push_back(this);
+ }
}
LLPluginProcessParent::~LLPluginProcessParent()
@@ -118,9 +119,14 @@ LLPluginProcessParent::~LLPluginProcessParent()
LL_DEBUGS("Plugin") << "destructor" << LL_ENDL;
// Remove from the global list before beginning destruction.
- sInstancesMutex->lock();
- sInstances.remove(this);
- sInstancesMutex->unlock();
+ {
+ // Make sure to get the global mutex _first_ here, to avoid a possible deadlock against LLPluginProcessParent::poll()
+ LLMutexLock lock(sInstancesMutex);
+ {
+ LLMutexLock lock2(&mIncomingQueueMutex);
+ sInstances.remove(this);
+ }
+ }
// Destroy any remaining shared memory regions
sharedMemoryRegionsType::iterator iter;
@@ -139,9 +145,11 @@ LLPluginProcessParent::~LLPluginProcessParent()
void LLPluginProcessParent::killSockets(void)
{
- mIncomingQueueMutex.lock();
- killMessagePipe();
- mIncomingQueueMutex.unlock();
+ {
+ LLMutexLock lock(&mIncomingQueueMutex);
+ killMessagePipe();
+ }
+
mListenSocket.reset();
mSocket.reset();
}
@@ -619,10 +627,10 @@ void LLPluginProcessParent::dirtyPollSet()
{
sPollsetNeedsRebuild = true;
- if(sPollThread)
+ if(sReadThread)
{
- LL_DEBUGS("PluginPoll") << "unpausing polling thread " << LL_ENDL;
- sPollThread->unpause();
+ LL_DEBUGS("PluginPoll") << "unpausing read thread " << LL_ENDL;
+ sReadThread->unpause();
}
}
@@ -634,7 +642,7 @@ void LLPluginProcessParent::updatePollset()
return;
}
- sInstancesMutex->lock();
+ LLMutexLock lock(sInstancesMutex);
if(sPollSet)
{
@@ -658,7 +666,7 @@ void LLPluginProcessParent::updatePollset()
}
}
- if(sUseReadThread && sPollThread && !sPollThread->isQuitting())
+ if(sUseReadThread && sReadThread && !sReadThread->isQuitting())
{
if(!sPollSet && (count > 0))
{
@@ -692,7 +700,6 @@ void LLPluginProcessParent::updatePollset()
}
}
}
- sInstancesMutex->unlock();
}
void LLPluginProcessParent::setUseReadThread(bool use_read_thread)
@@ -703,26 +710,26 @@ void LLPluginProcessParent::setUseReadThread(bool use_read_thread)
if(sUseReadThread)
{
- if(!sPollThread)
+ if(!sReadThread)
{
// start up the read thread
- LL_INFOS("PluginPoll") << "creating polling thread " << LL_ENDL;
+ LL_INFOS("PluginPoll") << "creating read thread " << LL_ENDL;
// make sure the pollset gets rebuilt.
sPollsetNeedsRebuild = true;
- sPollThread = new LLPluginProcessParentPollThread;
- sPollThread->start();
+ sReadThread = new LLPluginProcessParentPollThread;
+ sReadThread->start();
}
}
else
{
- if(sPollThread)
+ if(sReadThread)
{
// shut down the read thread
- LL_INFOS("PluginPoll") << "destroying polling thread " << LL_ENDL;
- delete sPollThread;
- sPollThread = NULL;
+ LL_INFOS("PluginPoll") << "destroying read thread " << LL_ENDL;
+ delete sReadThread;
+ sReadThread = NULL;
}
}
@@ -756,21 +763,22 @@ void LLPluginProcessParent::poll(F64 timeout)
if(self)
{
// Make sure this pointer is still in the instances list
- sInstancesMutex->lock();
bool valid = false;
- for(std::list<LLPluginProcessParent*>::iterator iter = sInstances.begin(); iter != sInstances.end(); ++iter)
{
- if(*iter == self)
+ LLMutexLock lock(sInstancesMutex);
+ for(std::list<LLPluginProcessParent*>::iterator iter = sInstances.begin(); iter != sInstances.end(); ++iter)
{
- // Lock the instance's mutex before unlocking the global mutex.
- // This avoids a possible race condition where the instance gets deleted between this check and the servicePoll() call.
- self->mIncomingQueueMutex.lock();
- valid = true;
- break;
+ if(*iter == self)
+ {
+ // Lock the instance's mutex before unlocking the global mutex.
+ // This avoids a possible race condition where the instance gets deleted between this check and the servicePoll() call.
+ self->mIncomingQueueMutex.lock();
+ valid = true;
+ break;
+ }
}
}
- sInstancesMutex->unlock();
-
+
if(valid)
{
// The instance is still valid.
@@ -872,9 +880,7 @@ void LLPluginProcessParent::receiveMessageEarly(const LLPluginMessage &message)
if(!handled)
{
// any message that wasn't handled early needs to be queued.
-// mIncomingQueueMutex.lock();
mIncomingQueue.push(message);
-// mIncomingQueueMutex.unlock();
}
}
diff --git a/indra/llplugin/llpluginprocessparent.h b/indra/llplugin/llpluginprocessparent.h
index 1ad0fbf059..4dff835b6a 100644
--- a/indra/llplugin/llpluginprocessparent.h
+++ b/indra/llplugin/llpluginprocessparent.h
@@ -188,7 +188,7 @@ private:
static void dirtyPollSet();
static void updatePollset();
void servicePoll();
- static LLThread *sPollThread;
+ static LLThread *sReadThread;
LLMutex mIncomingQueueMutex;
std::queue<LLPluginMessage> mIncomingQueue;
generated by cgit v1.2.3 (git 2.25.1) at 2025-10-31 13:38:51 +0000