|
version 1.102, 2007/08/03 00:56:52
|
version 1.105, 2007/09/07 20:08:37
|
|
|
|
| PEGASUS_NAMESPACE_BEGIN | PEGASUS_NAMESPACE_BEGIN |
| | |
| | |
| static int MAX_CONNECTION_QUEUE_LENGTH = -1; |
static int _maxConnectionQueueLength = -1; |
| | |
| //////////////////////////////////////////////////////////////////////////////// | //////////////////////////////////////////////////////////////////////////////// |
| // | // |
|
|
|
| Socket::initializeInterface(); | Socket::initializeInterface(); |
| | |
| /* | /* |
| Platforms interpret the value of MAX_CONNECTION_QUEUE_LENGTH |
Platforms interpret the value of _maxConnectionQueueLength |
| differently. Some platforms interpret the value literally, while | differently. Some platforms interpret the value literally, while |
| others multiply a fudge factor. When the server is under stress from | others multiply a fudge factor. When the server is under stress from |
| multiple clients with multiple requests, toggling this number may | multiple clients with multiple requests, toggling this number may |
|
|
|
| value, we allow an environment variable to be set which specifies a | value, we allow an environment variable to be set which specifies a |
| number greater than the maximum concurrent client connections | number greater than the maximum concurrent client connections |
| possible. If this environment var is not specified, then | possible. If this environment var is not specified, then |
| MAX_CONNECTION_QUEUE_LENGTH = 15. |
_maxConnectionQueueLength = 15. |
| */ | */ |
| | |
| //To engage runtime backlog queue length: uncomment the following block AND | //To engage runtime backlog queue length: uncomment the following block AND |
| //comment out the line MAX_CONNECTION_QUEUE_LENGTH = 15 |
//comment out the line _maxConnectionQueueLength = 15 |
| | |
| /* | /* |
| if (MAX_CONNECTION_QUEUE_LENGTH == -1) |
if (_maxConnectionQueueLength == -1) |
| { | { |
| const char* env = getenv("PEGASUS_MAX_BACKLOG_CONNECTION_QUEUE"); | const char* env = getenv("PEGASUS_MAX_BACKLOG_CONNECTION_QUEUE"); |
| if (!env) | if (!env) |
| { | { |
| MAX_CONNECTION_QUEUE_LENGTH = 15; |
_maxConnectionQueueLength = 15; |
| } | } |
| else | else |
| { | { |
| char* end = NULL; | char* end = NULL; |
| MAX_CONNECTION_QUEUE_LENGTH = strtol(env, &end, 10); |
_maxConnectionQueueLength = strtol(env, &end, 10); |
| if (*end) | if (*end) |
| MAX_CONNECTION_QUEUE_LENGTH = 15; |
_maxConnectionQueueLength = 15; |
| cout << " MAX_CONNECTION_QUEUE_LENGTH = " << |
cout << " _maxConnectionQueueLength = " << |
| MAX_CONNECTION_QUEUE_LENGTH << endl; |
_maxConnectionQueueLength << endl; |
| } | } |
| } | } |
| */ | */ |
| MAX_CONNECTION_QUEUE_LENGTH = 15; |
#ifdef PEGASUS_WMIMAPPER |
| |
//The WMI Mapper can be used as a proxy to multiple WMI Servers. |
| |
//If a client application simultaneously initiates connections |
| |
//to many Windows systems, many of these connections may be routed |
| |
//to a single WMI Mapper. A larger _maxConnectionQueueLength |
| |
//value is required to allow these connections to be initiated |
| |
//successfully. |
| |
_maxConnectionQueueLength = 40; |
| |
#else |
| |
_maxConnectionQueueLength = 15; |
| |
#endif |
| } | } |
| | |
| HTTPAcceptor::~HTTPAcceptor() | HTTPAcceptor::~HTTPAcceptor() |
|
|
|
| | |
| // Set up listening on the given socket: | // Set up listening on the given socket: |
| | |
| //int const MAX_CONNECTION_QUEUE_LENGTH = 15; |
//int const _maxConnectionQueueLength = 15; |
| | |
| if (listen(_rep->socket, MAX_CONNECTION_QUEUE_LENGTH) < 0) |
if (listen(_rep->socket, _maxConnectionQueueLength) < 0) |
| { | { |
| Socket::close(_rep->socket); | Socket::close(_rep->socket); |
| delete _rep; | delete _rep; |
Return to
HTTPAcceptor.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common