|
version 1.103.10.4, 2006/06/10 21:56:57
|
version 1.103.10.5, 2006/06/10 23:53:37
|
|
|
|
| #ifdef PEGASUS_OS_TYPE_WINDOWS | #ifdef PEGASUS_OS_TYPE_WINDOWS |
| if(entries[indx].isNamedPipeConnection()) | if(entries[indx].isNamedPipeConnection()) |
| { | { |
| |
|
| //entering this clause mean that a Named Pipe connection is at entries[indx] | //entering this clause mean that a Named Pipe connection is at entries[indx] |
| //cout << "In Monitor::run in clause to to create array of for WaitformultipuleObjects" << endl; | //cout << "In Monitor::run in clause to to create array of for WaitformultipuleObjects" << endl; |
| | |
| cout << "In Monitor::run - pipe being added to array is " << | cout << "In Monitor::run - pipe being added to array is " << |
| entries[indx].namedPipe.getName() << endl; | entries[indx].namedPipe.getName() << endl; |
| cout << " overlap event is "<< |
|
| (int) (entries[indx].namedPipe.getOverlap()).hEvent << endl; |
|
| | |
| entries[indx].pipeSet = false; | entries[indx].pipeSet = false; |
| |
|
| // We can Keep a counter in the Monitor class for the number of named pipes ... | // We can Keep a counter in the Monitor class for the number of named pipes ... |
| // Which can be used here to create the array size for hEvents..( obviously before this for loop.:-) ) | // Which can be used here to create the array size for hEvents..( obviously before this for loop.:-) ) |
| if (pipeEntryCount >= MaxPipes) | if (pipeEntryCount >= MaxPipes) |
| { | { |
| |
cout << "Monitor::run 'if (pipeEntryCount >= MaxPipes)' begining - pipeEntryCount=" << |
| |
pipeEntryCount << " MaxPipes=" << MaxPipes << endl; |
| MaxPipes += PIPE_INCREMENT; | MaxPipes += PIPE_INCREMENT; |
| HANDLE* temp_hEvents = new HANDLE[MaxPipes]; | HANDLE* temp_hEvents = new HANDLE[MaxPipes]; |
| |
|
| for (Uint32 i =0;i<pipeEntryCount;i++) | for (Uint32 i =0;i<pipeEntryCount;i++) |
| { | { |
| temp_hEvents[i] = hEvents[i]; | temp_hEvents[i] = hEvents[i]; |
| } | } |
| |
|
| delete [] hEvents; | delete [] hEvents; |
| |
|
| hEvents = temp_hEvents; | hEvents = temp_hEvents; |
| |
cout << "Monitor::run 'if (pipeEntryCount >= MaxPipes)' ending"<< endl; |
| |
|
| } | } |
| | |
| //pipeEventArray.append((entries[indx].namedPipe.getOverlap()).hEvent); | //pipeEventArray.append((entries[indx].namedPipe.getOverlap()).hEvent); |
|
|
|
| events, _idleEntries); | events, _idleEntries); |
| for( int indx = 0; indx < (int)entries.size(); indx++) | for( int indx = 0; indx < (int)entries.size(); indx++) |
| { | { |
| cout << "Monitor::run at start of 'for( int indx = 0; indx ' - index = " << indx << endl; |
//cout << "Monitor::run at start of 'for( int indx = 0; indx ' - index = " << indx << endl; |
| // The Monitor should only look at entries in the table that are IDLE (i.e., | // The Monitor should only look at entries in the table that are IDLE (i.e., |
| // owned by the Monitor). | // owned by the Monitor). |
| if(((entries[indx]._status.get() == _MonitorEntry::IDLE) && | if(((entries[indx]._status.get() == _MonitorEntry::IDLE) && |
|
|
|
| { | { |
| cout << "In Monitor::run Monitor::CONNECTION clause" << endl; | cout << "In Monitor::run Monitor::CONNECTION clause" << endl; |
| | |
| continue; |
|
| |
|
| Tracer::trace(TRC_HTTP, Tracer::LEVEL4, | Tracer::trace(TRC_HTTP, Tracer::LEVEL4, |
| "entries[indx].type for indx = %d is Monitor::CONNECTION", indx); | "entries[indx].type for indx = %d is Monitor::CONNECTION", indx); |
| static_cast<HTTPConnection *>(q)->_entry_index = indx; | static_cast<HTTPConnection *>(q)->_entry_index = indx; |
Return to
Monitor.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common