2 * Copyright 2014 Facebook, Inc.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
17 #ifndef __STDC_FORMAT_MACROS
18 #define __STDC_FORMAT_MACROS
21 #include <folly/io/async/AsyncServerSocket.h>
23 #include <folly/io/async/EventBase.h>
24 #include <folly/io/async/NotificationQueue.h>
25 #include <folly/SocketAddress.h>
31 #include <sys/types.h>
32 #include <sys/socket.h>
33 #include <netinet/tcp.h>
37 const uint32_t AsyncServerSocket::kDefaultMaxAcceptAtOnce;
38 const uint32_t AsyncServerSocket::kDefaultCallbackAcceptAtOnce;
39 const uint32_t AsyncServerSocket::kDefaultMaxMessagesInQueue;
41 int setCloseOnExec(int fd, int value) {
42 // Read the current flags
43 int old_flags = fcntl(fd, F_GETFD, 0);
45 // If reading the flags failed, return error indication now
49 // Set just the flag we want to set
52 new_flags = old_flags | FD_CLOEXEC;
54 new_flags = old_flags & ~FD_CLOEXEC;
56 // Store modified flag word in the descriptor
57 return fcntl(fd, F_SETFD, new_flags);
60 void AsyncServerSocket::RemoteAcceptor::start(
61 EventBase* eventBase, uint32_t maxAtOnce, uint32_t maxInQueue) {
62 setMaxReadAtOnce(maxAtOnce);
63 queue_.setMaxQueueSize(maxInQueue);
65 if (!eventBase->runInEventBaseThread([=](){
66 callback_->acceptStarted();
67 this->startConsuming(eventBase, &queue_);
69 throw std::invalid_argument("unable to start waiting on accept "
70 "notification queue in the specified "
75 void AsyncServerSocket::RemoteAcceptor::stop(
76 EventBase* eventBase, AcceptCallback* callback) {
77 if (!eventBase->runInEventBaseThread([=](){
78 callback->acceptStopped();
81 throw std::invalid_argument("unable to start waiting on accept "
82 "notification queue in the specified "
87 void AsyncServerSocket::RemoteAcceptor::messageAvailable(
91 case MessageType::MSG_NEW_CONN:
93 callback_->connectionAccepted(msg.fd, msg.address);
96 case MessageType::MSG_ERROR:
98 std::runtime_error ex(msg.msg);
99 callback_->acceptError(ex);
104 LOG(ERROR) << "invalid accept notification message type "
106 std::runtime_error ex(
107 "received invalid accept notification message type");
108 callback_->acceptError(ex);
114 * AsyncServerSocket::BackoffTimeout
116 class AsyncServerSocket::BackoffTimeout : public AsyncTimeout {
118 BackoffTimeout(AsyncServerSocket* socket)
119 : AsyncTimeout(socket->getEventBase()),
122 virtual void timeoutExpired() noexcept {
123 socket_->backoffTimeoutExpired();
127 AsyncServerSocket* socket_;
131 * AsyncServerSocket methods
134 AsyncServerSocket::AsyncServerSocket(EventBase* eventBase)
135 : eventBase_(eventBase),
137 maxAcceptAtOnce_(kDefaultMaxAcceptAtOnce),
138 maxNumMsgsInQueue_(kDefaultMaxMessagesInQueue),
139 acceptRateAdjustSpeed_(0),
141 lastAccepTimestamp_(std::chrono::steady_clock::now()),
142 numDroppedConnections_(0),
144 backoffTimeout_(nullptr),
146 keepAliveEnabled_(true),
148 shutdownSocketSet_(nullptr) {
151 void AsyncServerSocket::setShutdownSocketSet(ShutdownSocketSet* newSS) {
152 if (shutdownSocketSet_ == newSS) {
155 if (shutdownSocketSet_) {
156 for (auto& h : sockets_) {
157 shutdownSocketSet_->remove(h.socket_);
160 shutdownSocketSet_ = newSS;
161 if (shutdownSocketSet_) {
162 for (auto& h : sockets_) {
163 shutdownSocketSet_->add(h.socket_);
168 AsyncServerSocket::~AsyncServerSocket() {
169 assert(callbacks_.empty());
172 int AsyncServerSocket::stopAccepting(int shutdownFlags) {
174 for (auto& handler : sockets_) {
175 VLOG(10) << "AsyncServerSocket::stopAccepting " << this <<
178 assert(eventBase_ == nullptr || eventBase_->isInEventBaseThread());
180 // When destroy is called, unregister and close the socket immediately
183 for (auto& handler : sockets_) {
184 handler.unregisterHandler();
185 if (shutdownSocketSet_) {
186 shutdownSocketSet_->close(handler.socket_);
187 } else if (shutdownFlags >= 0) {
188 result = ::shutdown(handler.socket_, shutdownFlags);
189 pendingCloseSockets_.push_back(handler.socket_);
191 ::close(handler.socket_);
196 // Destroy the backoff timout. This will cancel it if it is running.
197 delete backoffTimeout_;
198 backoffTimeout_ = nullptr;
200 // Close all of the callback queues to notify them that they are being
201 // destroyed. No one should access the AsyncServerSocket any more once
202 // destroy() is called. However, clear out callbacks_ before invoking the
203 // accept callbacks just in case. This will potentially help us detect the
204 // bug if one of the callbacks calls addAcceptCallback() or
205 // removeAcceptCallback().
206 std::vector<CallbackInfo> callbacksCopy;
207 callbacks_.swap(callbacksCopy);
208 for (std::vector<CallbackInfo>::iterator it = callbacksCopy.begin();
209 it != callbacksCopy.end();
211 it->consumer->stop(it->eventBase, it->callback);
217 void AsyncServerSocket::destroy() {
219 for (auto s: pendingCloseSockets_) {
222 // Then call DelayedDestruction::destroy() to take care of
223 // whether or not we need immediate or delayed destruction
224 DelayedDestruction::destroy();
227 void AsyncServerSocket::attachEventBase(EventBase *eventBase) {
228 assert(eventBase_ == nullptr);
229 assert(eventBase->isInEventBaseThread());
231 eventBase_ = eventBase;
232 for (auto& handler : sockets_) {
233 handler.attachEventBase(eventBase);
237 void AsyncServerSocket::detachEventBase() {
238 assert(eventBase_ != nullptr);
239 assert(eventBase_->isInEventBaseThread());
242 eventBase_ = nullptr;
243 for (auto& handler : sockets_) {
244 handler.detachEventBase();
248 void AsyncServerSocket::useExistingSockets(const std::vector<int>& fds) {
249 assert(eventBase_ == nullptr || eventBase_->isInEventBaseThread());
251 if (sockets_.size() > 0) {
252 throw std::invalid_argument(
253 "cannot call useExistingSocket() on a "
254 "AsyncServerSocket that already has a socket");
258 // Set addressFamily_ from this socket.
259 // Note that the socket may not have been bound yet, but
260 // setFromLocalAddress() will still work and get the correct address family.
261 // We will update addressFamily_ again anyway if bind() is called later.
262 SocketAddress address;
263 address.setFromLocalAddress(fd);
267 ServerEventHandler(eventBase_, fd, this, address.getFamily()));
268 sockets_.back().changeHandlerFD(fd);
272 void AsyncServerSocket::useExistingSocket(int fd) {
273 useExistingSockets({fd});
276 void AsyncServerSocket::bind(const SocketAddress& address) {
277 assert(eventBase_ == nullptr || eventBase_->isInEventBaseThread());
279 // useExistingSocket() may have been called to initialize socket_ already.
280 // However, in the normal case we need to create a new socket now.
281 // Don't set socket_ yet, so that socket_ will remain uninitialized if an
284 if (sockets_.size() == 0) {
285 fd = createSocket(address.getFamily());
286 } else if (sockets_.size() == 1) {
287 if (address.getFamily() != sockets_[0].addressFamily_) {
288 throw std::invalid_argument(
289 "Attempted to bind address to socket with "
290 "different address family");
292 fd = sockets_[0].socket_;
294 throw std::invalid_argument(
295 "Attempted to bind to multiple fds");
298 // Bind to the socket
299 sockaddr_storage addrStorage;
300 address.getAddress(&addrStorage);
301 sockaddr* saddr = reinterpret_cast<sockaddr*>(&addrStorage);
302 if (::bind(fd, saddr, address.getActualSize()) != 0) {
303 if (sockets_.size() == 0) {
306 folly::throwSystemError(errno,
307 "failed to bind to async server socket: " +
311 // Record the address family that we are using,
312 // so we know how much address space we need to record accepted addresses.
314 // If we just created this socket, update the EventHandler and set socket_
315 if (sockets_.size() == 0) {
317 ServerEventHandler(eventBase_, fd, this, address.getFamily()));
318 sockets_[0].changeHandlerFD(fd);
322 void AsyncServerSocket::bind(uint16_t port) {
323 struct addrinfo hints, *res, *res0;
324 char sport[sizeof("65536")];
326 memset(&hints, 0, sizeof(hints));
327 hints.ai_family = AF_UNSPEC;
328 hints.ai_socktype = SOCK_STREAM;
329 hints.ai_flags = AI_PASSIVE;
330 snprintf(sport, sizeof(sport), "%u", port);
332 if (getaddrinfo(nullptr, sport, &hints, &res0)) {
333 throw std::invalid_argument(
334 "Attempted to bind address to socket with "
338 folly::ScopeGuard guard = folly::makeGuard([&]{
343 for (res = res0; res; res = res->ai_next) {
344 int s = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
345 // IPv6/IPv4 may not be supported by the kernel
346 if (s < 0 && errno == EAFNOSUPPORT) {
358 if (res->ai_family == AF_INET6) {
360 CHECK(0 == setsockopt(s, IPPROTO_IPV6, IPV6_V6ONLY,
361 &v6only, sizeof(v6only)));
364 SocketAddress address;
365 address.setFromLocalAddress(s);
368 ServerEventHandler(eventBase_, s, this, address.getFamily()));
370 // Bind to the socket
371 if (::bind(s, res->ai_addr, res->ai_addrlen) != 0) {
372 folly::throwSystemError(
374 "failed to bind to async server socket for port");
377 if (sockets_.size() == 0) {
378 throw std::runtime_error(
379 "did not bind any async server socket for port");
383 void AsyncServerSocket::listen(int backlog) {
384 assert(eventBase_ == nullptr || eventBase_->isInEventBaseThread());
387 for (auto& handler : sockets_) {
388 if (::listen(handler.socket_, backlog) == -1) {
389 folly::throwSystemError(errno,
390 "failed to listen on async server socket");
395 void AsyncServerSocket::getAddress(SocketAddress* addressReturn) const {
396 CHECK(sockets_.size() >= 1);
397 if (sockets_.size() > 1) {
398 VLOG(2) << "Warning: getAddress can return multiple addresses, " <<
399 "but getAddress was called, so only returning the first";
401 addressReturn->setFromLocalAddress(sockets_[0].socket_);
404 std::vector<SocketAddress> AsyncServerSocket::getAddresses()
406 CHECK(sockets_.size() >= 1);
407 auto tsaVec = std::vector<SocketAddress>(sockets_.size());
408 auto tsaIter = tsaVec.begin();
409 for (const auto& socket : sockets_) {
410 (tsaIter++)->setFromLocalAddress(socket.socket_);
415 void AsyncServerSocket::addAcceptCallback(AcceptCallback *callback,
416 EventBase *eventBase,
417 uint32_t maxAtOnce) {
418 assert(eventBase_ == nullptr || eventBase_->isInEventBaseThread());
420 // If this is the first accept callback and we are supposed to be accepting,
421 // start accepting once the callback is installed.
422 bool runStartAccepting = accepting_ && callbacks_.empty();
425 eventBase = eventBase_; // Run in AsyncServerSocket's eventbase
428 callbacks_.push_back(CallbackInfo(callback, eventBase));
430 // Start the remote acceptor.
432 // It would be nice if we could avoid starting the remote acceptor if
433 // eventBase == eventBase_. However, that would cause issues if
434 // detachEventBase() and attachEventBase() were ever used to change the
435 // primary EventBase for the server socket. Therefore we require the caller
436 // to specify a nullptr EventBase if they want to ensure that the callback is
437 // always invoked in the primary EventBase, and to be able to invoke that
438 // callback more efficiently without having to use a notification queue.
439 RemoteAcceptor* acceptor = nullptr;
441 acceptor = new RemoteAcceptor(callback);
442 acceptor->start(eventBase, maxAtOnce, maxNumMsgsInQueue_);
444 callbacks_.pop_back();
448 callbacks_.back().consumer = acceptor;
450 // If this is the first accept callback and we are supposed to be accepting,
452 if (runStartAccepting) {
457 void AsyncServerSocket::removeAcceptCallback(AcceptCallback *callback,
458 EventBase *eventBase) {
459 assert(eventBase_ == nullptr || eventBase_->isInEventBaseThread());
461 // Find the matching AcceptCallback.
462 // We just do a simple linear search; we don't expect removeAcceptCallback()
463 // to be called frequently, and we expect there to only be a small number of
465 std::vector<CallbackInfo>::iterator it = callbacks_.begin();
468 if (it == callbacks_.end()) {
469 throw std::runtime_error("AsyncServerSocket::removeAcceptCallback(): "
470 "accept callback not found");
472 if (it->callback == callback &&
473 (it->eventBase == eventBase || eventBase == nullptr)) {
480 // Remove this callback from callbacks_.
482 // Do this before invoking the acceptStopped() callback, in case
483 // acceptStopped() invokes one of our methods that examines callbacks_.
485 // Save a copy of the CallbackInfo first.
486 CallbackInfo info(*it);
487 callbacks_.erase(it);
488 if (n < callbackIndex_) {
489 // We removed an element before callbackIndex_. Move callbackIndex_ back
490 // one step, since things after n have been shifted back by 1.
493 // We removed something at or after callbackIndex_.
494 // If we removed the last element and callbackIndex_ was pointing at it,
495 // we need to reset callbackIndex_ to 0.
496 if (callbackIndex_ >= callbacks_.size()) {
501 info.consumer->stop(info.eventBase, info.callback);
503 // If we are supposed to be accepting but the last accept callback
504 // was removed, unregister for events until a callback is added.
505 if (accepting_ && callbacks_.empty()) {
506 for (auto& handler : sockets_) {
507 handler.unregisterHandler();
512 void AsyncServerSocket::startAccepting() {
513 assert(eventBase_ == nullptr || eventBase_->isInEventBaseThread());
516 if (callbacks_.empty()) {
517 // We can't actually begin accepting if no callbacks are defined.
518 // Wait until a callback is added to start accepting.
522 for (auto& handler : sockets_) {
523 if (!handler.registerHandler(
524 EventHandler::READ | EventHandler::PERSIST)) {
525 throw std::runtime_error("failed to register for accept events");
530 void AsyncServerSocket::pauseAccepting() {
531 assert(eventBase_ == nullptr || eventBase_->isInEventBaseThread());
533 for (auto& handler : sockets_) {
534 handler. unregisterHandler();
537 // If we were in the accept backoff state, disable the backoff timeout
538 if (backoffTimeout_) {
539 backoffTimeout_->cancelTimeout();
543 int AsyncServerSocket::createSocket(int family) {
544 int fd = socket(family, SOCK_STREAM, 0);
546 folly::throwSystemError(errno, "error creating async server socket");
558 void AsyncServerSocket::setupSocket(int fd) {
559 // Get the address family
560 SocketAddress address;
561 address.setFromLocalAddress(fd);
562 auto family = address.getFamily();
564 // Put the socket in non-blocking mode
565 if (fcntl(fd, F_SETFL, O_NONBLOCK) != 0) {
566 folly::throwSystemError(errno,
567 "failed to put socket in non-blocking mode");
570 // Set reuseaddr to avoid 2MSL delay on server restart
572 if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one)) != 0) {
573 // This isn't a fatal error; just log an error message and continue
574 LOG(ERROR) << "failed to set SO_REUSEADDR on async server socket " << errno;
577 // Set keepalive as desired
579 if (setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE,
580 (keepAliveEnabled_) ? &one : &zero, sizeof(int)) != 0) {
581 LOG(ERROR) << "failed to set SO_KEEPALIVE on async server socket: " <<
585 // Setup FD_CLOEXEC flag
587 (-1 == folly::setCloseOnExec(fd, closeOnExec_))) {
588 LOG(ERROR) << "failed to set FD_CLOEXEC on async server socket: " <<
592 // Set TCP nodelay if available, MAC OS X Hack
593 // See http://lists.danga.com/pipermail/memcached/2005-March/001240.html
595 if (family != AF_UNIX) {
596 if (setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, &one, sizeof(one)) != 0) {
597 // This isn't a fatal error; just log an error message and continue
598 LOG(ERROR) << "failed to set TCP_NODELAY on async server socket: " <<
604 if (shutdownSocketSet_) {
605 shutdownSocketSet_->add(fd);
609 void AsyncServerSocket::handlerReady(
610 uint16_t events, int fd, sa_family_t addressFamily) noexcept {
611 assert(!callbacks_.empty());
612 DestructorGuard dg(this);
614 // Only accept up to maxAcceptAtOnce_ connections at a time,
615 // to avoid starving other I/O handlers using this EventBase.
616 for (uint32_t n = 0; n < maxAcceptAtOnce_; ++n) {
617 SocketAddress address;
619 sockaddr_storage addrStorage;
620 socklen_t addrLen = sizeof(addrStorage);
621 sockaddr* saddr = reinterpret_cast<sockaddr*>(&addrStorage);
623 // In some cases, accept() doesn't seem to update these correctly.
624 saddr->sa_family = addressFamily;
625 if (addressFamily == AF_UNIX) {
626 addrLen = sizeof(struct sockaddr_un);
629 // Accept a new client socket
631 int clientSocket = accept4(fd, saddr, &addrLen, SOCK_NONBLOCK);
633 int clientSocket = accept(fd, saddr, &addrLen);
636 address.setFromSockaddr(saddr, addrLen);
638 std::chrono::time_point<std::chrono::steady_clock> nowMs =
639 std::chrono::steady_clock::now();
640 int64_t timeSinceLastAccept = std::max(
642 nowMs.time_since_epoch().count() -
643 lastAccepTimestamp_.time_since_epoch().count());
644 lastAccepTimestamp_ = nowMs;
645 if (acceptRate_ < 1) {
646 acceptRate_ *= 1 + acceptRateAdjustSpeed_ * timeSinceLastAccept;
647 if (acceptRate_ >= 1) {
649 } else if (rand() > acceptRate_ * RAND_MAX) {
650 ++numDroppedConnections_;
651 if (clientSocket >= 0) {
652 ::close(clientSocket);
658 if (clientSocket < 0) {
659 if (errno == EAGAIN) {
660 // No more sockets to accept right now.
661 // Check for this code first, since it's the most common.
663 } else if (errno == EMFILE || errno == ENFILE) {
664 // We're out of file descriptors. Perhaps we're accepting connections
665 // too quickly. Pause accepting briefly to back off and give the server
666 // a chance to recover.
667 LOG(ERROR) << "accept failed: out of file descriptors; entering accept "
671 // Dispatch the error message
672 dispatchError("accept() failed", errno);
674 dispatchError("accept() failed", errno);
679 #ifndef SOCK_NONBLOCK
680 // Explicitly set the new connection to non-blocking mode
681 if (fcntl(clientSocket, F_SETFL, O_NONBLOCK) != 0) {
682 ::close(clientSocket);
683 dispatchError("failed to set accepted socket to non-blocking mode",
689 // Inform the callback about the new connection
690 dispatchSocket(clientSocket, std::move(address));
692 // If we aren't accepting any more, break out of the loop
693 if (!accepting_ || callbacks_.empty()) {
699 void AsyncServerSocket::dispatchSocket(int socket,
700 SocketAddress&& address) {
701 uint32_t startingIndex = callbackIndex_;
703 // Short circuit if the callback is in the primary EventBase thread
705 CallbackInfo *info = nextCallback();
706 if (info->eventBase == nullptr) {
707 info->callback->connectionAccepted(socket, address);
711 // Create a message to send over the notification queue
713 msg.type = MessageType::MSG_NEW_CONN;
714 msg.address = std::move(address);
717 // Loop until we find a free queue to write to
719 if (info->consumer->getQueue()->tryPutMessageNoThrow(std::move(msg))) {
724 // We couldn't add to queue. Fall through to below
726 ++numDroppedConnections_;
727 if (acceptRateAdjustSpeed_ > 0) {
728 // aggressively decrease accept rate when in trouble
729 static const double kAcceptRateDecreaseSpeed = 0.1;
730 acceptRate_ *= 1 - kAcceptRateDecreaseSpeed;
734 if (callbackIndex_ == startingIndex) {
735 // The notification queue was full
736 // We can't really do anything at this point other than close the socket.
738 // This should only happen if a user's service is behaving extremely
739 // badly and none of the EventBase threads are looping fast enough to
740 // process the incoming connections. If the service is overloaded, it
741 // should use pauseAccepting() to temporarily back off accepting new
742 // connections, before they reach the point where their threads can't
743 // even accept new messages.
744 LOG(ERROR) << "failed to dispatch newly accepted socket:"
745 << " all accept callback queues are full";
750 info = nextCallback();
754 void AsyncServerSocket::dispatchError(const char *msgstr, int errnoValue) {
755 uint32_t startingIndex = callbackIndex_;
756 CallbackInfo *info = nextCallback();
758 // Create a message to send over the notification queue
760 msg.type = MessageType::MSG_ERROR;
761 msg.err = errnoValue;
762 msg.msg = std::move(msgstr);
765 // Short circuit if the callback is in the primary EventBase thread
766 if (info->eventBase == nullptr) {
767 std::runtime_error ex(msgstr + errnoValue);
768 info->callback->acceptError(ex);
772 if (info->consumer->getQueue()->tryPutMessageNoThrow(std::move(msg))) {
775 // Fall through and try another callback
777 if (callbackIndex_ == startingIndex) {
778 // The notification queues for all of the callbacks were full.
779 // We can't really do anything at this point.
780 LOG(ERROR) << "failed to dispatch accept error: all accept callback "
781 "queues are full: error msg: " <<
782 msg.msg.c_str() << errnoValue;
785 info = nextCallback();
789 void AsyncServerSocket::enterBackoff() {
790 // If this is the first time we have entered the backoff state,
791 // allocate backoffTimeout_.
792 if (backoffTimeout_ == nullptr) {
794 backoffTimeout_ = new BackoffTimeout(this);
795 } catch (const std::bad_alloc& ex) {
796 // Man, we couldn't even allocate the timer to re-enable accepts.
797 // We must be in pretty bad shape. Don't pause accepting for now,
798 // since we won't be able to re-enable ourselves later.
799 LOG(ERROR) << "failed to allocate AsyncServerSocket backoff"
800 << " timer; unable to temporarly pause accepting";
805 // For now, we simply pause accepting for 1 second.
807 // We could add some smarter backoff calculation here in the future. (e.g.,
808 // start sleeping for longer if we keep hitting the backoff frequently.)
809 // Typically the user needs to figure out why the server is overloaded and
810 // fix it in some other way, though. The backoff timer is just a simple
811 // mechanism to try and give the connection processing code a little bit of
812 // breathing room to catch up, and to avoid just spinning and failing to
813 // accept over and over again.
814 const uint32_t timeoutMS = 1000;
815 if (!backoffTimeout_->scheduleTimeout(timeoutMS)) {
816 LOG(ERROR) << "failed to schedule AsyncServerSocket backoff timer;"
817 << "unable to temporarly pause accepting";
821 // The backoff timer is scheduled to re-enable accepts.
822 // Go ahead and disable accepts for now. We leave accepting_ set to true,
823 // since that tracks the desired state requested by the user.
824 for (auto& handler : sockets_) {
825 handler.unregisterHandler();
829 void AsyncServerSocket::backoffTimeoutExpired() {
830 // accepting_ should still be true.
831 // If pauseAccepting() was called while in the backoff state it will cancel
832 // the backoff timeout.
834 // We can't be detached from the EventBase without being paused
835 assert(eventBase_ != nullptr && eventBase_->isInEventBaseThread());
837 // If all of the callbacks were removed, we shouldn't re-enable accepts
838 if (callbacks_.empty()) {
842 // Register the handler.
843 for (auto& handler : sockets_) {
844 if (!handler.registerHandler(
845 EventHandler::READ | EventHandler::PERSIST)) {
846 // We're hosed. We could just re-schedule backoffTimeout_ to
847 // re-try again after a little bit. However, we don't want to
848 // loop retrying forever if we can't re-enable accepts. Just
849 // abort the entire program in this state; things are really bad
850 // and restarting the entire server is probably the best remedy.
852 << "failed to re-enable AsyncServerSocket accepts after backoff; "