summaryrefslogtreecommitdiff
path: root/src/LibuvEventPoll.cc
diff options
context:
space:
mode:
authorNils Maier <maierman@web.de>2013-08-21 05:06:53 +0200
committerNils Maier <maierman@web.de>2013-08-21 05:56:17 +0200
commit8526ceeb452d23d7aa73d01c6cb0fc8ae5e0377b (patch)
tree825b4f5d2a0f18331fbbf24773e80ee0b44b50dc /src/LibuvEventPoll.cc
parentd8f44ef4f6c5ad86b08658ecba41a84b775b6e69 (diff)
Convert to autos and ranged loops
Diffstat (limited to 'src/LibuvEventPoll.cc')
-rw-r--r--src/LibuvEventPoll.cc28
1 files changed, 12 insertions, 16 deletions
diff --git a/src/LibuvEventPoll.cc b/src/LibuvEventPoll.cc
index 43298e43..07d60a1e 100644
--- a/src/LibuvEventPoll.cc
+++ b/src/LibuvEventPoll.cc
@@ -128,7 +128,7 @@ void LibuvEventPoll::poll(const struct timeval& tv)
// timeout == 0 will tick once
if (timeout >= 0) {
- uv_timer_t* timer = new uv_timer_t;
+ auto timer = new uv_timer_t;
uv_timer_init(loop_, timer);
uv_timer_start(timer, timer_callback, timeout, timeout);
@@ -147,11 +147,10 @@ void LibuvEventPoll::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
@@ -219,8 +218,8 @@ void LibuvEventPoll::pollCallback(KPoll* poll, int status, int events)
bool LibuvEventPoll::addEvents(sock_t socket,
const LibuvEventPoll::KEvent& event)
{
- std::shared_ptr<KSocketEntry> socketEntry(new KSocketEntry(socket));
- KSocketEntrySet::iterator i = socketEntries_.lower_bound(socketEntry);
+ auto socketEntry = std::make_shared<KSocketEntry>(socket);
+ auto i = socketEntries_.lower_bound(socketEntry);
if (i != socketEntries_.end() && **i == *socketEntry) {
event.addSelf(*i);
@@ -234,7 +233,7 @@ bool LibuvEventPoll::addEvents(sock_t socket,
socketEntries_.insert(i, socketEntry);
event.addSelf(socketEntry);
- KPoll* poll = new KPoll(this, socketEntry.get(), socket);
+ auto poll = new KPoll(this, socketEntry.get(), socket);
polls_[socket] = poll;
poll->start();
return true;
@@ -302,10 +301,8 @@ bool LibuvEventPoll::deleteEvents(sock_t socket, Command* command,
bool LibuvEventPoll::addNameResolver(const std::shared_ptr<AsyncNameResolver>& resolver,
Command* command)
{
- std::shared_ptr<KAsyncNameResolverEntry> entry(
- new KAsyncNameResolverEntry(resolver, command));
- KAsyncNameResolverEntrySet::iterator itr =
- nameResolverEntries_.lower_bound(entry);
+ auto entry = std::make_shared<KAsyncNameResolverEntry>(resolver, command);
+ auto itr = nameResolverEntries_.lower_bound(entry);
if (itr != nameResolverEntries_.end() && *(*itr) == *entry) {
return false;
}
@@ -317,9 +314,8 @@ bool LibuvEventPoll::addNameResolver(const std::shared_ptr<AsyncNameResolver>& r
bool LibuvEventPoll::deleteNameResolver(const std::shared_ptr<AsyncNameResolver>& resolver,
Command* command)
{
- std::shared_ptr<KAsyncNameResolverEntry> entry(
- new KAsyncNameResolverEntry(resolver, command));
- KAsyncNameResolverEntrySet::iterator itr = nameResolverEntries_.find(entry);
+ auto entry = std::make_shared<KAsyncNameResolverEntry>(resolver, command);
+ auto itr = nameResolverEntries_.find(entry);
if (itr == nameResolverEntries_.end()) {
return false;
}