|
version 1.139.8.2, 2013/06/03 22:35:13
|
version 1.140, 2011/11/11 10:10:51
|
|
|
|
| #else | #else |
| int events = select(maxSocketCurrentPass, &fdread, NULL, NULL, &tv); | int events = select(maxSocketCurrentPass, &fdread, NULL, NULL, &tv); |
| #endif | #endif |
| |
int selectErrno = getSocketError(); |
| | |
| _entriesMutex.lock(); | _entriesMutex.lock(); |
| | |
|
|
|
| | |
| if (events == PEGASUS_SOCKET_ERROR) | if (events == PEGASUS_SOCKET_ERROR) |
| { | { |
| int selectErrno = 0; |
|
| selectErrno = getSocketError(); |
|
| |
|
| PEG_TRACE((TRC_HTTP, Tracer::LEVEL1, | PEG_TRACE((TRC_HTTP, Tracer::LEVEL1, |
| "Monitor::run - select() returned error %d.", selectErrno)); | "Monitor::run - select() returned error %d.", selectErrno)); |
| // The EBADF error indicates that one or more or the file | // The EBADF error indicates that one or more or the file |
|
|
|
| | |
| try | try |
| { | { |
| dst->run(); |
dst->run(1); |
| } | } |
| catch (...) | catch (...) |
| { | { |
|
|
|
| | |
| int Monitor::solicitSocketMessages( | int Monitor::solicitSocketMessages( |
| SocketHandle socket, | SocketHandle socket, |
| |
Uint32 events, |
| Uint32 queueId, | Uint32 queueId, |
| Uint32 type) | Uint32 type) |
| { | { |
Return to
Monitor.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common