|
version 1.106.2.6, 2008/01/25 21:46:34
|
version 1.112, 2008/01/25 18:54:22
|
|
|
|
| _rep->socket, | _rep->socket, |
| SocketMessage::READ | SocketMessage::EXCEPTION, | SocketMessage::READ | SocketMessage::EXCEPTION, |
| getQueueId(), | getQueueId(), |
| Monitor::ACCEPTOR))) |
MonitorEntry::TYPE_ACCEPTOR))) |
| { | { |
| Socket::close(_rep->socket); | Socket::close(_rep->socket); |
| delete _rep; | delete _rep; |
|
|
|
| "HTTPAcceptor: accept() failed"); | "HTTPAcceptor: accept() failed"); |
| return; | return; |
| } | } |
| |
#ifndef(PEGASUS_OS_TYPE_WINDOWS) |
| // We need to ensure that the socket number is not higher than | // We need to ensure that the socket number is not higher than |
| // what fits into FD_SETSIZE, because we else won't be able to select on it | // what fits into FD_SETSIZE, because we else won't be able to select on it |
| // and won't ever communicate correct on that socket. | // and won't ever communicate correct on that socket. |
|
|
|
| Socket::close(socket); | Socket::close(socket); |
| return; | return; |
| } | } |
| |
#endif |
| | |
| String ipAddress; | String ipAddress; |
| | |
|
|
|
| if (-1 == (index = _monitor->solicitSocketMessages( | if (-1 == (index = _monitor->solicitSocketMessages( |
| connection->getSocket(), | connection->getSocket(), |
| SocketMessage::READ | SocketMessage::EXCEPTION, | SocketMessage::READ | SocketMessage::EXCEPTION, |
| connection->getQueueId(), Monitor::CONNECTION)) ) |
connection->getQueueId(), MonitorEntry::TYPE_CONNECTION)) ) |
| { | { |
| // ATTN-DE-P2-2003100503::TODO::Need to enhance code to return | // ATTN-DE-P2-2003100503::TODO::Need to enhance code to return |
| // an error message to Client application. | // an error message to Client application. |
Return to
HTTPAcceptor.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common