return server_sock;
}
-sockaddr_in6 CreateAnyAddress(int port)
+sockaddr_in6 create_any_address(int port)
{
sockaddr_in6 sin6;
memset(&sin6, 0, sizeof(sin6));
return sin6;
}
-sockaddr_in6 ExtractAddressFromAcceptorProto(const AcceptorProto &proto)
+sockaddr_in6 extract_address_from_acceptor_proto(const AcceptorProto &proto)
{
sockaddr_in6 sin6;
memset(&sin6, 0, sizeof(sin6));
Acceptor::Acceptor(const AcceptorProto &serialized)
: server_sock(serialized.server_sock()),
- addr(ExtractAddressFromAcceptorProto(serialized))
+ addr(extract_address_from_acceptor_proto(serialized))
{
}
class AcceptorProto;
-sockaddr_in6 CreateAnyAddress(int port);
-sockaddr_in6 ExtractAddressFromAcceptorProto(const AcceptorProto &proto);
+sockaddr_in6 create_any_address(int port);
+sockaddr_in6 extract_address_from_acceptor_proto(const AcceptorProto &proto);
// A thread that accepts new connections on a given socket,
// and hands them off to the server pool.
}
AcceptorConfig acceptor;
- acceptor.addr = CreateAnyAddress(port);
+ acceptor.addr = create_any_address(port);
config->acceptors.push_back(acceptor);
return true;
// Deserialize the acceptors.
for (int i = 0; i < loaded_state.acceptors_size(); ++i) {
- sockaddr_in6 sin6 = ExtractAddressFromAcceptorProto(loaded_state.acceptors(i));
+ sockaddr_in6 sin6 = extract_address_from_acceptor_proto(loaded_state.acceptors(i));
deserialized_acceptors.insert(make_pair(
sin6,
new Acceptor(loaded_state.acceptors(i))));
while (!should_stop()) {
if (sock == -1) {
int port_num = atoi(port.c_str());
- sockaddr_in6 addr = CreateAnyAddress(port_num);
+ sockaddr_in6 addr = create_any_address(port_num);
sock = create_server_socket(addr, UDP_SOCKET);
if (sock == -1) {
log(WARNING, "[%s] UDP socket creation failed. Waiting 0.2 seconds and trying again...",