summaryrefslogtreecommitdiff
path: root/src/PollEventPoll.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-06-22 01:10:38 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-06-22 01:10:38 +0900
commit07d270c87e6f9184aea4ca17eb26e466712e8db2 (patch)
tree2dfbaa2e0d2ad0f38cb73098608f7d67a64320f8 /src/PollEventPoll.cc
parent126a4bde612eb0e6c48cf2f13ebe3eac45cc71a8 (diff)
Require -std=c++11 and use std::shared_ptr instead of SharedHandle
Diffstat (limited to 'src/PollEventPoll.cc')
-rw-r--r--src/PollEventPoll.cc18
1 files changed, 9 insertions, 9 deletions
diff --git a/src/PollEventPoll.cc b/src/PollEventPoll.cc
index ba4f479b..eee58e4c 100644
--- a/src/PollEventPoll.cc
+++ b/src/PollEventPoll.cc
@@ -96,7 +96,7 @@ void PollEventPoll::poll(const struct timeval& tv)
while((res = ::poll(pollfds_, pollfdNum_, timeout)) == -1 &&
errno == EINTR);
if(res > 0) {
- SharedHandle<KSocketEntry> se(new KSocketEntry(0));
+ std::shared_ptr<KSocketEntry> se(new KSocketEntry(0));
for(struct pollfd* first = pollfds_, *last = pollfds_+pollfdNum_;
first != last; ++first) {
if(first->revents) {
@@ -152,7 +152,7 @@ int PollEventPoll::translateEvents(EventPoll::EventType events)
bool PollEventPoll::addEvents
(sock_t socket, const PollEventPoll::KEvent& event)
{
- SharedHandle<KSocketEntry> socketEntry(new KSocketEntry(socket));
+ std::shared_ptr<KSocketEntry> socketEntry(new KSocketEntry(socket));
KSocketEntrySet::iterator i = socketEntries_.lower_bound(socketEntry);
if(i != socketEntries_.end() && *(*i) == *socketEntry) {
event.addSelf(*i);
@@ -189,7 +189,7 @@ bool PollEventPoll::addEvents
#ifdef ENABLE_ASYNC_DNS
bool PollEventPoll::addEvents
(sock_t socket, Command* command, int events,
- const SharedHandle<AsyncNameResolver>& rs)
+ const std::shared_ptr<AsyncNameResolver>& rs)
{
return addEvents(socket, KADNSEvent(rs, command, socket, events));
}
@@ -198,7 +198,7 @@ bool PollEventPoll::addEvents
bool PollEventPoll::deleteEvents
(sock_t socket, const PollEventPoll::KEvent& event)
{
- SharedHandle<KSocketEntry> socketEntry(new KSocketEntry(socket));
+ std::shared_ptr<KSocketEntry> socketEntry(new KSocketEntry(socket));
KSocketEntrySet::iterator i = socketEntries_.find(socketEntry);
if(i == socketEntries_.end()) {
A2_LOG_DEBUG(fmt("Socket %d is not found in SocketEntries.", socket));
@@ -226,7 +226,7 @@ bool PollEventPoll::deleteEvents
#ifdef ENABLE_ASYNC_DNS
bool PollEventPoll::deleteEvents
-(sock_t socket, Command* command, const SharedHandle<AsyncNameResolver>& rs)
+(sock_t socket, Command* command, const std::shared_ptr<AsyncNameResolver>& rs)
{
return deleteEvents(socket, KADNSEvent(rs, command, socket, 0));
}
@@ -241,9 +241,9 @@ bool PollEventPoll::deleteEvents
#ifdef ENABLE_ASYNC_DNS
bool PollEventPoll::addNameResolver
-(const SharedHandle<AsyncNameResolver>& resolver, Command* command)
+(const std::shared_ptr<AsyncNameResolver>& resolver, Command* command)
{
- SharedHandle<KAsyncNameResolverEntry> entry
+ std::shared_ptr<KAsyncNameResolverEntry> entry
(new KAsyncNameResolverEntry(resolver, command));
KAsyncNameResolverEntrySet::iterator itr =
nameResolverEntries_.lower_bound(entry);
@@ -257,9 +257,9 @@ bool PollEventPoll::addNameResolver
}
bool PollEventPoll::deleteNameResolver
-(const SharedHandle<AsyncNameResolver>& resolver, Command* command)
+(const std::shared_ptr<AsyncNameResolver>& resolver, Command* command)
{
- SharedHandle<KAsyncNameResolverEntry> entry
+ std::shared_ptr<KAsyncNameResolverEntry> entry
(new KAsyncNameResolverEntry(resolver, command));
KAsyncNameResolverEntrySet::iterator itr = nameResolverEntries_.find(entry);
if(itr == nameResolverEntries_.end()) {