Subscription::Pointer sub = new CallSubscription<AcceptCall>(subCall);
AsyncCall::Pointer listenCall = asyncCall(33,2, "clientListenerConnectionOpened",
- ListeningStartedDialer(&clientListenerConnectionOpened, openFlags, s, Ipc::fdnHttpSocket, sub));
+ ListeningStartedDialer(&clientListenerConnectionOpened, openFlags, s, Ipc::fdnHttpSocket, sub));
Ipc::StartListening(SOCK_STREAM, IPPROTO_TCP, s->s, openFlags, Ipc::fdnHttpSocket, listenCall);
HttpSockets[NHttpSockets++] = -1; // set in clientListenerConnectionOpened
Subscription::Pointer sub = new CallSubscription<AcceptCall>(subCall);
AsyncCall::Pointer listenCall = asyncCall(33, 2, "clientListenerConnectionOpened",
- ListeningStartedDialer(&clientListenerConnectionOpened, openFlags,
- &s->http, Ipc::fdnHttpsSocket, sub));
+ ListeningStartedDialer(&clientListenerConnectionOpened, openFlags,
+ &s->http, Ipc::fdnHttpsSocket, sub));
Ipc::StartListening(SOCK_STREAM, IPPROTO_TCP, s->s, openFlags, Ipc::fdnHttpsSocket, listenCall);
#include "protos.h"
#include "SquidTime.h"
-namespace Comm {
- CBDATA_CLASS_INIT(TcpAcceptor);
+namespace Comm
+{
+CBDATA_CLASS_INIT(TcpAcceptor);
};
Comm::TcpAcceptor::TcpAcceptor(const int listenFd, const Ip::Address &laddr, int flags,
}
SetSelect(fd, COMM_SELECT_READ, Comm::TcpAcceptor::doAccept, afd, 0);
- } catch(const std::exception &e) {
+ } catch (const std::exception &e) {
fatalf("FATAL: error while accepting new client connection: %s\n", e.what());
- } catch(...) {
+ } catch (...) {
fatal("FATAL: error while accepting new client connection: [unkown]\n");
}
}