|
version 1.31, 2006/07/21 18:44:08
|
version 1.31.2.1, 2006/07/27 23:12:06
|
|
|
|
| // | // |
| //%///////////////////////////////////////////////////////////////////////////// | //%///////////////////////////////////////////////////////////////////////////// |
| | |
| |
#include <Pegasus/Common/Signal.h> |
| #include <Pegasus/Common/Config.h> | #include <Pegasus/Common/Config.h> |
| #include <Pegasus/Common/Constants.h> | #include <Pegasus/Common/Constants.h> |
| #include <Pegasus/Common/AutoPtr.h> | #include <Pegasus/Common/AutoPtr.h> |
|
|
|
| the connection is closed. | the connection is closed. |
| */ | */ |
| void _processResponses(); | void _processResponses(); |
| static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL |
static ThreadReturnType PEGASUS_THREAD_CDECL |
| _responseProcessor(void* arg); | _responseProcessor(void* arg); |
| | |
| // | // |
|
|
|
| // Wait for the responseProcessor thread to exit | // Wait for the responseProcessor thread to exit |
| while (isInitialized()) | while (isInitialized()) |
| { | { |
| pegasus_yield(); |
Threads::yield(); |
| } | } |
| } | } |
| } | } |
|
|
|
| { | { |
| if (rtn == PEGASUS_THREAD_INSUFFICIENT_RESOURCES) | if (rtn == PEGASUS_THREAD_INSUFFICIENT_RESOURCES) |
| { | { |
| pegasus_yield(); |
Threads::yield(); |
| } | } |
| else | else |
| { | { |
|
|
|
| | |
| } | } |
| | |
| PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL |
ThreadReturnType PEGASUS_THREAD_CDECL |
| ProviderAgentContainer::_responseProcessor(void* arg) | ProviderAgentContainer::_responseProcessor(void* arg) |
| { | { |
| ProviderAgentContainer* pa = | ProviderAgentContainer* pa = |
|
|
|
| | |
| pa->_processResponses(); | pa->_processResponses(); |
| | |
| return(PEGASUS_THREAD_RETURN(0)); |
return(ThreadReturnType(0)); |
| } | } |
| | |
| ///////////////////////////////////////////////////////////////////////////// | ///////////////////////////////////////////////////////////////////////////// |
Return to
OOPProviderManagerRouter.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / Attic