RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-03-11 02:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

msgr: stop accepter on socket error

Browse Source 
Only if we get a few in a row.
This commit is contained in:
Sage Weil 2008-12-17 10:30:42 -08:00
parent 82b0bc39e5
commit ba140b5a6d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/msg/SimpleMessenger.cc
View File

@ -208,6 +208,7 @@ void *Rank::Accepter::entry()
dout(10) << "accepter starting" << dendl;
fd_set fds;
int errors = 0;
while (!done) {
FD_ZERO(&fds);
FD_SET(listen_sd, &fds);
@ -222,6 +223,7 @@ void *Rank::Accepter::entry()
socklen_t slen = sizeof(addr);
int sd = ::accept(listen_sd, (sockaddr*)&addr, &slen);
if (sd >= 0) {
errors = 0;
opened_socket();
dout(10) << "accepted incoming on sd " << sd << dendl;
@ -242,7 +244,9 @@ void *Rank::Accepter::entry()
}
rank.lock.Unlock();
} else {
dout(10) << "accepter no incoming connection? sd = " << sd << " errno " << errno << " " << strerror(errno) << dendl;
dout(0) << "accepter no incoming connection? sd = " << sd << " errno " << errno << " " << strerror(errno) << dendl;
if (++errors > 4)
break;
}
}