|
@@ -105,13 +105,12 @@ void PollService::prepare(std::vector<struct pollfd> &pfds, optional<clock::time
|
|
|
}
|
|
|
|
|
|
void PollService::process(std::vector<struct pollfd> &pfds) {
|
|
|
+ std::unique_lock lock(mMutex);
|
|
|
auto it = pfds.begin();
|
|
|
if (it != pfds.end()) {
|
|
|
- std::unique_lock lock(mMutex);
|
|
|
mInterrupter->process(*it++);
|
|
|
}
|
|
|
while (it != pfds.end()) {
|
|
|
- std::unique_lock lock(mMutex);
|
|
|
socket_t sock = it->fd;
|
|
|
auto jt = mSocks->find(sock);
|
|
|
if (jt != mSocks->end()) {
|