aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/linden/indra/llplugin/llpluginmessagepipe.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'linden/indra/llplugin/llpluginmessagepipe.cpp')
-rwxr-xr-xlinden/indra/llplugin/llpluginmessagepipe.cpp28
1 files changed, 13 insertions, 15 deletions
diff --git a/linden/indra/llplugin/llpluginmessagepipe.cpp b/linden/indra/llplugin/llpluginmessagepipe.cpp
index 8168b32..ac3a902 100755
--- a/linden/indra/llplugin/llpluginmessagepipe.cpp
+++ b/linden/indra/llplugin/llpluginmessagepipe.cpp
@@ -82,10 +82,10 @@ bool LLPluginMessagePipeOwner::writeMessageRaw(const std::string &message)
82 } 82 }
83 else 83 else
84 { 84 {
85 LL_WARNS("Plugin") << "dropping message: " << message << LL_ENDL; 85 LL_WARNS("PluginPipe") << "dropping message: " << message << LL_ENDL;
86 result = false; 86 result = false;
87 } 87 }
88 88
89 return result; 89 return result;
90} 90}
91 91
@@ -99,8 +99,6 @@ void LLPluginMessagePipeOwner::killMessagePipe(void)
99} 99}
100 100
101LLPluginMessagePipe::LLPluginMessagePipe(LLPluginMessagePipeOwner *owner, LLSocket::ptr_t socket): 101LLPluginMessagePipe::LLPluginMessagePipe(LLPluginMessagePipeOwner *owner, LLSocket::ptr_t socket):
102 mInputMutex(gAPRPoolp),
103 mOutputMutex(gAPRPoolp),
104 mOwner(owner), 102 mOwner(owner),
105 mSocket(socket) 103 mSocket(socket)
106{ 104{
@@ -179,18 +177,18 @@ bool LLPluginMessagePipe::pumpOutput()
179 { 177 {
180 // write any outgoing messages 178 // write any outgoing messages
181 size = (apr_size_t)mOutput.size(); 179 size = (apr_size_t)mOutput.size();
182 180
183 setSocketTimeout(0); 181 setSocketTimeout(0);
184 182
185// LL_INFOS("Plugin") << "before apr_socket_send, size = " << size << LL_ENDL; 183// LL_INFOS("PluginPipe") << "before apr_socket_send, size = " << size << LL_ENDL;
186 184
187 status = apr_socket_send( 185 status = apr_socket_send(
188 mSocket->getSocket(), 186 mSocket->getSocket(),
189 (const char*)mOutput.data(), 187 (const char*)mOutput.data(),
190 &size); 188 &size);
191 189
192// LL_INFOS("Plugin") << "after apr_socket_send, size = " << size << LL_ENDL; 190// LL_INFOS("PluginPipe") << "after apr_socket_send, size = " << size << LL_ENDL;
193 191
194 if(status == APR_SUCCESS) 192 if(status == APR_SUCCESS)
195 { 193 {
196 // success 194 // success
@@ -277,15 +275,15 @@ bool LLPluginMessagePipe::pumpInput(F64 timeout)
277 { 275 {
278 size = request_size; 276 size = request_size;
279 277
280// LL_INFOS("Plugin") << "before apr_socket_recv, size = " << size << LL_ENDL; 278// LL_INFOS("PluginPipe") << "before apr_socket_recv, size = " << size << LL_ENDL;
281 279
282 status = apr_socket_recv( 280 status = apr_socket_recv(
283 mSocket->getSocket(), 281 mSocket->getSocket(),
284 input_buf, 282 input_buf,
285 &size); 283 &size);
286 284
287// LL_INFOS("Plugin") << "after apr_socket_recv, size = " << size << LL_ENDL; 285// LL_INFOS("PluginPipe") << "after apr_socket_recv, size = " << size << LL_ENDL;
288 286
289 if(size > 0) 287 if(size > 0)
290 { 288 {
291 LLMutexLock lock(&mInputMutex); 289 LLMutexLock lock(&mInputMutex);
@@ -379,7 +377,7 @@ void LLPluginMessagePipe::processInput(void)
379 } 377 }
380 else 378 else
381 { 379 {
382 LL_WARNS("Plugin") << "!mOwner" << LL_ENDL; 380 LL_WARNS("PluginPipe") << "!mOwner" << LL_ENDL;
383 } 381 }
384 } 382 }
385 mInputMutex.unlock(); 383 mInputMutex.unlock();