| 26 | } |
| 27 | |
| 28 | void process() |
| 29 | { |
| 30 | // Don't service any newly queued events |
| 31 | for(unsigned n = count; n != 0; --n) { |
| 32 | mutex.lock(); |
| 33 | auto evt = events[read]; |
| 34 | read = (read + 1) % length; |
| 35 | --count; |
| 36 | mutex.unlock(); |
| 37 | callback(&evt); |
| 38 | } |
| 39 | } |
| 40 | |
| 41 | private: |
| 42 | static CMutex mutex; |
no test coverage detected