diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-11-09 14:43:47 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-11-09 14:43:47 +0000 |
| commit | 228b4c50d757b80efe493728a658ae145eaf67ef (patch) | |
| tree | aefd6e605ca52f6e4125f6e25d405e56a1ef681a /src/SelectEventPoll.cc | |
| parent | 02f725cab581063a0570402032f0b328e6f3a8a3 (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.cc | 22 |
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); |
