| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "net/tools/flip_server/flip_config.h" | |
| 6 | |
| 7 #include <unistd.h> | |
| 8 | |
| 9 namespace net { | |
| 10 | |
| 11 FlipAcceptor::FlipAcceptor(enum FlipHandlerType flip_handler_type, | |
| 12 std::string listen_ip, | |
| 13 std::string listen_port, | |
| 14 std::string ssl_cert_filename, | |
| 15 std::string ssl_key_filename, | |
| 16 std::string http_server_ip, | |
| 17 std::string http_server_port, | |
| 18 std::string https_server_ip, | |
| 19 std::string https_server_port, | |
| 20 int spdy_only, | |
| 21 int accept_backlog_size, | |
| 22 bool disable_nagle, | |
| 23 int accepts_per_wake, | |
| 24 bool reuseport, | |
| 25 bool wait_for_iface, | |
| 26 void* memory_cache) | |
| 27 : flip_handler_type_(flip_handler_type), | |
| 28 listen_ip_(listen_ip), | |
| 29 listen_port_(listen_port), | |
| 30 ssl_cert_filename_(ssl_cert_filename), | |
| 31 ssl_key_filename_(ssl_key_filename), | |
| 32 http_server_ip_(http_server_ip), | |
| 33 http_server_port_(http_server_port), | |
| 34 https_server_ip_(https_server_ip), | |
| 35 https_server_port_(https_server_port), | |
| 36 spdy_only_(spdy_only), | |
| 37 accept_backlog_size_(accept_backlog_size), | |
| 38 disable_nagle_(disable_nagle), | |
| 39 accepts_per_wake_(accepts_per_wake), | |
| 40 memory_cache_(memory_cache), | |
| 41 ssl_session_expiry_(300), // TODO(mbelshe): Hook these up! | |
| 42 ssl_disable_compression_(false), | |
| 43 idle_socket_timeout_s_(300) { | |
| 44 VLOG(1) << "Attempting to listen on " << listen_ip_.c_str() << ":" | |
| 45 << listen_port_.c_str(); | |
| 46 if (!https_server_ip_.size()) | |
| 47 https_server_ip_ = http_server_ip_; | |
| 48 if (!https_server_port_.size()) | |
| 49 https_server_port_ = http_server_port_; | |
| 50 | |
| 51 while (1) { | |
| 52 int ret = CreateListeningSocket(listen_ip_, | |
| 53 listen_port_, | |
| 54 true, | |
| 55 accept_backlog_size_, | |
| 56 true, | |
| 57 reuseport, | |
| 58 wait_for_iface, | |
| 59 disable_nagle_, | |
| 60 &listen_fd_); | |
| 61 if (ret == 0) { | |
| 62 break; | |
| 63 } else if (ret == -3 && wait_for_iface) { | |
| 64 // Binding error EADDRNOTAVAIL was encounted. We need | |
| 65 // to wait for the interfaces to raised. try again. | |
| 66 usleep(200000); | |
| 67 } else { | |
| 68 LOG(ERROR) << "Unable to create listening socket for: ret = " << ret | |
| 69 << ": " << listen_ip_.c_str() << ":" << listen_port_.c_str(); | |
| 70 return; | |
| 71 } | |
| 72 } | |
| 73 | |
| 74 FlipSetNonBlocking(listen_fd_); | |
| 75 VLOG(1) << "Listening on socket: "; | |
| 76 if (flip_handler_type == FLIP_HANDLER_PROXY) | |
| 77 VLOG(1) << "\tType : Proxy"; | |
| 78 else if (FLIP_HANDLER_SPDY_SERVER) | |
| 79 VLOG(1) << "\tType : SPDY Server"; | |
| 80 else if (FLIP_HANDLER_HTTP_SERVER) | |
| 81 VLOG(1) << "\tType : HTTP Server"; | |
| 82 VLOG(1) << "\tIP : " << listen_ip_; | |
| 83 VLOG(1) << "\tPort : " << listen_port_; | |
| 84 VLOG(1) << "\tHTTP Server : " << http_server_ip_ << ":" << http_server_port_; | |
| 85 VLOG(1) << "\tHTTPS Server : " << https_server_ip_ << ":" | |
| 86 << https_server_port_; | |
| 87 VLOG(1) << "\tSSL : " << (ssl_cert_filename.size() ? "true" | |
| 88 : "false"); | |
| 89 VLOG(1) << "\tCertificate : " << ssl_cert_filename; | |
| 90 VLOG(1) << "\tKey : " << ssl_key_filename; | |
| 91 VLOG(1) << "\tSpdy Only : " << (spdy_only ? "true" : "false"); | |
| 92 } | |
| 93 | |
| 94 FlipAcceptor::~FlipAcceptor() {} | |
| 95 | |
| 96 FlipConfig::FlipConfig() | |
| 97 : server_think_time_in_s_(0), | |
| 98 log_destination_(logging::LOG_TO_SYSTEM_DEBUG_LOG), | |
| 99 wait_for_iface_(false) {} | |
| 100 | |
| 101 FlipConfig::~FlipConfig() {} | |
| 102 | |
| 103 void FlipConfig::AddAcceptor(enum FlipHandlerType flip_handler_type, | |
| 104 std::string listen_ip, | |
| 105 std::string listen_port, | |
| 106 std::string ssl_cert_filename, | |
| 107 std::string ssl_key_filename, | |
| 108 std::string http_server_ip, | |
| 109 std::string http_server_port, | |
| 110 std::string https_server_ip, | |
| 111 std::string https_server_port, | |
| 112 int spdy_only, | |
| 113 int accept_backlog_size, | |
| 114 bool disable_nagle, | |
| 115 int accepts_per_wake, | |
| 116 bool reuseport, | |
| 117 bool wait_for_iface, | |
| 118 void* memory_cache) { | |
| 119 // TODO(mbelshe): create a struct FlipConfigArgs{} for the arguments. | |
| 120 acceptors_.push_back(new FlipAcceptor(flip_handler_type, | |
| 121 listen_ip, | |
| 122 listen_port, | |
| 123 ssl_cert_filename, | |
| 124 ssl_key_filename, | |
| 125 http_server_ip, | |
| 126 http_server_port, | |
| 127 https_server_ip, | |
| 128 https_server_port, | |
| 129 spdy_only, | |
| 130 accept_backlog_size, | |
| 131 disable_nagle, | |
| 132 accepts_per_wake, | |
| 133 reuseport, | |
| 134 wait_for_iface, | |
| 135 memory_cache)); | |
| 136 } | |
| 137 | |
| 138 } // namespace net | |
| OLD | NEW |