Skip to content

Commit bb52b5e

Browse files
committed
Remove check except.
1 parent cbe4594 commit bb52b5e

File tree

2 files changed

+0
-15
lines changed

2 files changed

+0
-15
lines changed

rabit/include/rabit/internal/socket.h

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -609,14 +609,6 @@ struct PollHelper {
609609
const auto& pfd = fds.find(fd);
610610
return pfd != fds.end() && ((pfd->second.events & POLLOUT) != 0);
611611
}
612-
/*!
613-
* \brief Check if the descriptor has any exception
614-
* \param fd file descriptor to check status
615-
*/
616-
inline bool CheckExcept(SOCKET fd) const {
617-
const auto& pfd = fds.find(fd);
618-
return pfd != fds.end() && ((pfd->second.events & POLLPRI) != 0);
619-
}
620612

621613
/*!
622614
* \brief peform poll on the set defined, read, write, exception

rabit/src/allreduce_base.cc

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -724,13 +724,6 @@ AllreduceBase::TryBroadcast(void *sendrecvbuf_, size_t total_size, int root) {
724724
if (finished) break;
725725
// select
726726
watcher.Poll(timeout_sec);
727-
// exception handling
728-
for (int i = 0; i < nlink; ++i) {
729-
// recive OOB message from some link
730-
if (watcher.CheckExcept(links[i].sock)) {
731-
return ReportError(&links[i], kGetExcept);
732-
}
733-
}
734727
if (in_link == -2) {
735728
// probe in-link
736729
for (int i = 0; i < nlink; ++i) {

0 commit comments

Comments
 (0)