continue;
AsyncCall::Pointer call = commCbCall(5,5, "SomeCommAcceptHandler(httpAccept)",
- CommAcceptCbPtrFun(httpAccept, s));
+ CommAcceptCbPtrFun(httpAccept, s));
s->listener = new Comm::ListenStateData(fd, call, true);
continue;
AsyncCall::Pointer call = commCbCall(5,5, "SomeCommAcceptHandler(httpsAccept)",
- CommAcceptCbPtrFun(httpsAccept, s));
+ CommAcceptCbPtrFun(httpsAccept, s));
s->listener = new Comm::ListenStateData(fd, call, true);
}
Comm::ListenStateData::ListenStateData(int aFd, AsyncCall::Pointer &call, bool accept_many) :
- fd(aFd),
- theCallback(call),
- mayAcceptMore(accept_many)
+ fd(aFd),
+ theCallback(call),
+ mayAcceptMore(accept_many)
{
assert(aFd >= 0);
debugs(5, 5, HERE << "FD " << fd << " AsyncCall: " << call);
if (!okToAccept()) {
AcceptLimiter::Instance().defer(afd);
- }
- else {
+ } else {
afd->acceptNext();
}
commSetSelect(fd, COMM_SELECT_READ, Comm::ListenStateData::doAccept, afd, 0);
}
/**
- * accept() and process
+ * accept() and process
* Wait for an incoming connection on FD.
*/
int
comm_remove_close_handler(fd, closer);
closer = NULL;
fd = -1;
- }
- else if (fd >= 0) {
+ } else if (fd >= 0) {
comm_remove_close_handler(fd, closer);
closer = NULL;
comm_close(fd); // we do not expect to be called back