diff options
| author | Nils Maier <maierman@web.de> | 2013-08-25 18:00:46 +0200 |
|---|---|---|
| committer | Nils Maier <maierman@web.de> | 2013-09-20 23:06:49 +0200 |
| commit | 3590077d5c43d492b3e357d1a50afca4a7d1cfcf (patch) | |
| tree | 592516aa08b74c7e90c41a9b50c227f3f5b877b0 /src/PollEventPoll.cc | |
| parent | a76eeb2b8106dd725097750c3ee4958e505e3c85 (diff) | |
More auto-converts by cpp11-migrate
Diffstat (limited to 'src/PollEventPoll.cc')
| -rw-r--r-- | src/PollEventPoll.cc | 20 |
1 files changed, 9 insertions, 11 deletions
diff --git a/src/PollEventPoll.cc b/src/PollEventPoll.cc index d95078dd..5c64ef84 100644 --- a/src/PollEventPoll.cc +++ b/src/PollEventPoll.cc @@ -101,7 +101,7 @@ void PollEventPoll::poll(const struct timeval& tv) first != last; ++first) { if(first->revents) { se->setSocket(first->fd); - KSocketEntrySet::iterator itr = socketEntries_.find(se); + auto itr = socketEntries_.find(se); if(itr == socketEntries_.end()) { A2_LOG_DEBUG(fmt("Socket %d is not found in SocketEntries.", first->fd)); @@ -119,11 +119,10 @@ void PollEventPoll::poll(const struct timeval& tv) // own timeout and ares may create new sockets or closes socket in // their API. So we call ares_process_fd for all ares_channel and // re-register their sockets. - for(KAsyncNameResolverEntrySet::iterator i = nameResolverEntries_.begin(), - eoi = nameResolverEntries_.end(); i != eoi; ++i) { - (*i)->processTimeout(); - (*i)->removeSocketEvents(this); - (*i)->addSocketEvents(this); + for(auto& r : nameResolverEntries_) { + r->processTimeout(); + r->removeSocketEvents(this); + r->addSocketEvents(this); } #endif // ENABLE_ASYNC_DNS @@ -153,7 +152,7 @@ bool PollEventPoll::addEvents (sock_t socket, const PollEventPoll::KEvent& event) { std::shared_ptr<KSocketEntry> socketEntry(new KSocketEntry(socket)); - KSocketEntrySet::iterator i = socketEntries_.lower_bound(socketEntry); + auto i = socketEntries_.lower_bound(socketEntry); if(i != socketEntries_.end() && *(*i) == *socketEntry) { event.addSelf(*i); for(struct pollfd* first = pollfds_, *last = pollfds_+pollfdNum_; @@ -199,7 +198,7 @@ bool PollEventPoll::deleteEvents (sock_t socket, const PollEventPoll::KEvent& event) { std::shared_ptr<KSocketEntry> socketEntry(new KSocketEntry(socket)); - KSocketEntrySet::iterator i = socketEntries_.find(socketEntry); + auto i = socketEntries_.find(socketEntry); if(i == socketEntries_.end()) { A2_LOG_DEBUG(fmt("Socket %d is not found in SocketEntries.", socket)); return false; @@ -245,8 +244,7 @@ bool PollEventPoll::addNameResolver { std::shared_ptr<KAsyncNameResolverEntry> entry (new KAsyncNameResolverEntry(resolver, command)); - KAsyncNameResolverEntrySet::iterator itr = - nameResolverEntries_.lower_bound(entry); + auto itr = nameResolverEntries_.lower_bound(entry); if(itr != nameResolverEntries_.end() && *(*itr) == *entry) { return false; } else { @@ -261,7 +259,7 @@ bool PollEventPoll::deleteNameResolver { std::shared_ptr<KAsyncNameResolverEntry> entry (new KAsyncNameResolverEntry(resolver, command)); - KAsyncNameResolverEntrySet::iterator itr = nameResolverEntries_.find(entry); + auto itr = nameResolverEntries_.find(entry); if(itr == nameResolverEntries_.end()) { return false; } else { |
