diff options
Diffstat (limited to 'linden/indra/llplugin/llpluginmessagepipe.cpp')
-rwxr-xr-x | linden/indra/llplugin/llpluginmessagepipe.cpp | 28 |
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 | ||
101 | LLPluginMessagePipe::LLPluginMessagePipe(LLPluginMessagePipeOwner *owner, LLSocket::ptr_t socket): | 101 | LLPluginMessagePipe::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(); |