pegasus/src/Pegasus/Common/Monitor.cpp - diff

Return to Monitor.cpp CVS log

Up to [Pegasus] / pegasus / src / Pegasus / Common

version 1.111.2.1, 2006/07/27 23:11:52

version 1.111.2.2, 2006/07/31 17:37:18

Line 387

// unlocked will not result in an ArrayIndexOutOfBounds

// exception.

autoEntryMutex.unlock();

_entry_mut.unlock();

o.enqueue(message);

autoEntryMutex.lock();

_entry_mut.lock();

// After enqueue a message and the autoEntryMutex has been released and locked again,

// the array of _entries can be changed. The ArrayIterator has be reset with the original _entries.

entries.reset(_entries);

Line 423

maxSocketCurrentPass++;

autoEntryMutex.unlock();

_entry_mut.unlock();

// The first argument to select() is ignored on Windows and it is not

Line 435

#else

int events = select(maxSocketCurrentPass, &fdread, NULL, NULL, &tv);

#endif

autoEntryMutex.lock();

_entry_mut.lock();

// After enqueue a message and the autoEntryMutex has been released and locked again,

// the array of _entries can be changed. The ArrayIterator has be reset with the original _entries

entries.reset(_entries);

Line 547

events |= SocketMessage::READ;

Message *msg = new SocketMessage(entries[indx].socket, events);

entries[indx]._status = _MonitorEntry::BUSY;

autoEntryMutex.unlock();

_entry_mut.unlock();

q->enqueue(msg);

autoEntryMutex.lock();

_entry_mut.lock();

// After enqueue a message and the autoEntryMutex has been released and locked again,

// the array of entries can be changed. The ArrayIterator has be reset with the original _entries

entries.reset(_entries);

Legend: