|
version 1.52, 2004/10/17 20:39:17
|
version 1.53, 2005/01/13 15:08:51
|
|
|
|
| // Dave Rosckes (rosckes@us.ibm.com) | // Dave Rosckes (rosckes@us.ibm.com) |
| // Denise Eckstein (denise.eckstein@hp.com) | // Denise Eckstein (denise.eckstein@hp.com) |
| // Alagaraja Ramasubramanian (alags_raj@in.ibm.com) for Bug#1090 | // Alagaraja Ramasubramanian (alags_raj@in.ibm.com) for Bug#1090 |
| |
// Amit Arora, IBM (amita@in.ibm.com) for Bug#2541 |
| // | // |
| //%///////////////////////////////////////////////////////////////////////////// | //%///////////////////////////////////////////////////////////////////////////// |
| | |
|
|
|
| int index; | int index; |
| | |
| if (-1 == (index = _monitor->solicitSocketMessages( | if (-1 == (index = _monitor->solicitSocketMessages( |
| socket, |
connection->getSocket(), |
| SocketMessage::READ | SocketMessage::EXCEPTION, | SocketMessage::READ | SocketMessage::EXCEPTION, |
| connection->getQueueId(), Monitor::CONNECTION)) ) | connection->getQueueId(), Monitor::CONNECTION)) ) |
| { | { |
|
|
|
| return; | return; |
| } | } |
| | |
| mp_socket.release(); |
|
| |
|
| // Save the socket for cleanup later: | // Save the socket for cleanup later: |
| connection->_entry_index = index; | connection->_entry_index = index; |
| AutoMutex autoMut(_rep->_connection_mut); | AutoMutex autoMut(_rep->_connection_mut); |
Return to
HTTPAcceptor.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common