version 1.58, 2006/08/09 21:12:41
|
version 1.58.14.1, 2006/11/03 05:56:42
|
|
|
// | // |
//============================================================================== | //============================================================================== |
// | // |
// Author: Jair Santos, Hewlett-Packard Company (jair.santos@hp.com) |
|
// |
|
// Modified By: Dan Gorey (djgorey@us.ibm.com) |
|
// Amit Arora (amita@in.ibm.com) for Bug#1170 |
|
// Marek Szermutzky (MSzermutzky@de.ibm.com) for PEP#139 Stage1 |
|
// Seema Gupta (gseema@in.ibm.com) for PEP135 |
|
// Brian G. Campbell, EMC (campbell_brian@emc.com) - PEP140/phase1 |
|
// Robert Kieninger, IBM (kieningr@de.ibm.com) for Bug#667 |
|
// Amit Arora (amita@in.ibm.com) for Bug#2040 |
|
// Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com) |
|
// Willis White, IBM <whiwill@us.ibm.com) |
|
// Josephine Eskaline Joyce, IBM <jojustin@in.ibm.com) for Bug#2108 |
|
// David Dillard, Symantec Corp. (david_dillard@symantec.com) |
|
// John Alex, IBM (johnalex@us.ibm.com) - Bug#2290 |
|
// | // |
//%///////////////////////////////////////////////////////////////////////////// | //%///////////////////////////////////////////////////////////////////////////// |
| |
|
|
_responseDecoder->setDataStorePointer(&perfDataStore); | _responseDecoder->setDataStorePointer(&perfDataStore); |
| |
_connected = true; | _connected = true; |
|
#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET) |
|
if (_connectHost.size()) |
|
{ |
|
#endif |
|
|
_httpConnection->setSocketWriteTimeout(_timeoutMilliseconds/1000+1); | _httpConnection->setSocketWriteTimeout(_timeoutMilliseconds/1000+1); |
|
#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET) |
|
} |
|
#endif |
|
|
} | } |
| |
void CIMClientRep::_disconnect() | void CIMClientRep::_disconnect() |
|
|
_connectSSLContext.reset(); | _connectSSLContext.reset(); |
| |
_connect(); | _connect(); |
|
|
} | } |
catch(const CannotConnectException &) | catch(const CannotConnectException &) |
{ | { |
|
|
// | // |
// Wait until the timeout expires or an event occurs: | // Wait until the timeout expires or an event occurs: |
// | // |
|
#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET) |
|
// if it is a local connection and NamedPipe feature is supported |
|
// run monitor for timeout in a period of 1000 milliseconds |
|
if (!_connectHost.size()) |
|
{ |
|
_monitor->handlePipe(); |
|
} |
|
else |
|
{ |
|
#endif |
|
|
_monitor->run(Uint32(stopMilliseconds - nowMilliseconds)); | _monitor->run(Uint32(stopMilliseconds - nowMilliseconds)); |
|
#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET) |
|
} |
|
#endif |
|
|
| |
// | // |
// Check to see if incoming queue has a message | // Check to see if incoming queue has a message |