|
version 1.103.10.26, 2006/10/10 08:33:26
|
version 1.103.10.27, 2006/10/18 04:24:42
|
|
|
|
| entries.reset(_entries); | entries.reset(_entries); |
| entries[indx]._status = _MonitorEntry::IDLE; | entries[indx]._status = _MonitorEntry::IDLE; |
| handled_events = true; | handled_events = true; |
| |
delete [] hPipeList; |
| |
return handled_events; |
| | |
| } | } |
| } | } |
|
|
|
| handled_events = true; | handled_events = true; |
| } | } |
| } | } |
| return(handled_events); |
delete [] hPipeList; |
| |
return handled_events; |
| } | } |
| | |
| | |
|
|
|
| for (int pipeIndex = 0; pipeIndex < pipeEntryCount; pipeIndex++) | for (int pipeIndex = 0; pipeIndex < pipeEntryCount; pipeIndex++) |
| { | { |
| dwBytesAvail = 0; | dwBytesAvail = 0; |
| Tracer::trace(TRC_HTTP,Tracer::LEVEL4," PIPE_PEEKING for PIPE = %u ", hPipeList[pipeIndex]); |
|
| bPeekPipe = ::PeekNamedPipe(hPipeList[pipeIndex], | bPeekPipe = ::PeekNamedPipe(hPipeList[pipeIndex], |
| NULL, | NULL, |
| NULL, | NULL, |
|
|
|
| Tracer::trace(TRC_HTTP,Tracer::LEVEL4," PIPE_PEEKING FOUND = %u BYTES", dwBytesAvail); | Tracer::trace(TRC_HTTP,Tracer::LEVEL4," PIPE_PEEKING FOUND = %u BYTES", dwBytesAvail); |
| | |
| pEvents = 1; | pEvents = 1; |
| Tracer::trace(TRC_HTTP, Tracer::LEVEL4, "EVENT TRIGGERED in Pipe = %u ",entries[indexPipeCountAssociator[pipeIndex]].namedPipe.getPipe()); |
|
| entries[indexPipeCountAssociator[pipeIndex]].pipeSet = true; | entries[indexPipeCountAssociator[pipeIndex]].pipeSet = true; |
| Tracer::trace(TRC_HTTP, Tracer::LEVEL4, | Tracer::trace(TRC_HTTP, Tracer::LEVEL4, |
| "Monitor::run select event received events = %d, \ | "Monitor::run select event received events = %d, \ |
|
|
|
| autoEntryMutex.lock(); | autoEntryMutex.lock(); |
| entries.reset(_entries); | entries.reset(_entries); |
| entries[pIndx]._status = _MonitorEntry::IDLE; | entries[pIndx]._status = _MonitorEntry::IDLE; |
| return true; |
delete [] hPipeList; |
| |
return(handled_events); |
| |
|
| } | } |
| | |
| | |
Return to
Monitor.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common