summaryrefslogtreecommitdiff
path: root/src/SelectEventPoll.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-11-09 14:43:47 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-11-09 14:43:47 +0000
commit228b4c50d757b80efe493728a658ae145eaf67ef (patch)
treeaefd6e605ca52f6e4125f6e25d405e56a1ef681a /src/SelectEventPoll.cc
parent02f725cab581063a0570402032f0b328e6f3a8a3 (diff)
2010-11-09 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Capture errno right after system/library call to avoid it to get overwritten. Use util::safeStrerror instead of strerror directly because strerror might return NULL. We don't check errno for std::fstream anymore. * src/AbstractDiskWriter.cc * src/CookieStorage.cc * src/DHTAutoSaveCommand.cc * src/DHTRoutingTableDeserializer.cc * src/DHTRoutingTableSerializer.cc * src/DefaultBtProgressInfoFile.cc * src/EpollEventPoll.cc * src/IteratableChunkChecksumValidator.cc * src/KqueueEventPoll.cc * src/Logger.cc * src/MessageDigestHelper.cc * src/PortEventPoll.cc * src/SelectEventPoll.cc * src/SocketCore.cc * src/message.h * src/util.cc * src/util.h
Diffstat (limited to 'src/SelectEventPoll.cc')
-rw-r--r--src/SelectEventPoll.cc22
1 files changed, 2 insertions, 20 deletions
diff --git a/src/SelectEventPoll.cc b/src/SelectEventPoll.cc
index 9b3950fd..473091e3 100644
--- a/src/SelectEventPoll.cc
+++ b/src/SelectEventPoll.cc
@@ -40,7 +40,6 @@
#include <cstring>
#include <algorithm>
#include <numeric>
-#include <iostream>
#include "Command.h"
#include "LogFactory.h"
@@ -280,7 +279,6 @@ bool SelectEventPoll::addEvents(sock_t socket, Command* command,
SharedHandle<SocketEntry> socketEntry(new SocketEntry(socket));
std::deque<SharedHandle<SocketEntry> >::iterator i =
std::lower_bound(socketEntries_.begin(), socketEntries_.end(), socketEntry);
- int r = 0;
if(i != socketEntries_.end() && (*i) == socketEntry) {
(*i)->addCommandEvent(command, events);
} else {
@@ -288,15 +286,7 @@ bool SelectEventPoll::addEvents(sock_t socket, Command* command,
socketEntry->addCommandEvent(command, events);
}
updateFdSet();
- if(r == -1) {
- if(logger_->debug()) {
- logger_->debug("Failed to add socket event %d:%s",
- socket, strerror(errno));
- }
- return false;
- } else {
- return true;
- }
+ return true;
}
bool SelectEventPoll::deleteEvents(sock_t socket, Command* command,
@@ -307,19 +297,11 @@ bool SelectEventPoll::deleteEvents(sock_t socket, Command* command,
std::lower_bound(socketEntries_.begin(), socketEntries_.end(), socketEntry);
if(i != socketEntries_.end() && (*i) == socketEntry) {
(*i)->removeCommandEvent(command, events);
- int r = 0;
if((*i)->eventEmpty()) {
socketEntries_.erase(i);
}
updateFdSet();
- if(r == -1) {
- if(logger_->debug()) {
- logger_->debug("Failed to delete socket event:%s", strerror(errno));
- }
- return false;
- } else {
- return true;
- }
+ return true;
} else {
if(logger_->debug()) {
logger_->debug("Socket %d is not found in SocketEntries.", socket);