OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 // | 4 // |
5 // A toy server, which listens on a specified address for QUIC traffic and | 5 // A toy server, which listens on a specified address for QUIC traffic and |
6 // handles incoming responses. | 6 // handles incoming responses. |
7 | 7 |
8 #ifndef NET_TOOLS_QUIC_QUIC_SERVER_H_ | 8 #ifndef NET_TOOLS_QUIC_QUIC_SERVER_H_ |
9 #define NET_TOOLS_QUIC_QUIC_SERVER_H_ | 9 #define NET_TOOLS_QUIC_QUIC_SERVER_H_ |
10 | 10 |
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
51 void OnUnregistration(int fd, bool replaced) override {} | 51 void OnUnregistration(int fd, bool replaced) override {} |
52 | 52 |
53 // Reads a packet from the given fd, and then passes it off to | 53 // Reads a packet from the given fd, and then passes it off to |
54 // the QuicDispatcher. Returns true if a packet is read, false | 54 // the QuicDispatcher. Returns true if a packet is read, false |
55 // otherwise. | 55 // otherwise. |
56 // If packets_dropped is non-null, the socket is configured to track | 56 // If packets_dropped is non-null, the socket is configured to track |
57 // dropped packets, and some packets are read, it will be set to the number of | 57 // dropped packets, and some packets are read, it will be set to the number of |
58 // dropped packets. | 58 // dropped packets. |
59 static bool ReadAndDispatchSinglePacket(int fd, int port, | 59 static bool ReadAndDispatchSinglePacket(int fd, int port, |
60 ProcessPacketInterface* processor, | 60 ProcessPacketInterface* processor, |
61 uint32* packets_dropped); | 61 QuicPacketCount* packets_dropped); |
62 | 62 |
63 void OnShutdown(EpollServer* eps, int fd) override {} | 63 void OnShutdown(EpollServer* eps, int fd) override {} |
64 | 64 |
65 void SetStrikeRegisterNoStartupPeriod() { | 65 void SetStrikeRegisterNoStartupPeriod() { |
66 crypto_config_.set_strike_register_no_startup_period(); | 66 crypto_config_.set_strike_register_no_startup_period(); |
67 } | 67 } |
68 | 68 |
69 // SetProofSource sets the ProofSource that will be used to verify the | 69 // SetProofSource sets the ProofSource that will be used to verify the |
70 // server's certificate, and takes ownership of |source|. | 70 // server's certificate, and takes ownership of |source|. |
71 void SetProofSource(ProofSource* source) { | 71 void SetProofSource(ProofSource* source) { |
72 crypto_config_.SetProofSource(source); | 72 crypto_config_.SetProofSource(source); |
73 } | 73 } |
74 | 74 |
75 bool overflow_supported() { return overflow_supported_; } | 75 bool overflow_supported() { return overflow_supported_; } |
76 | 76 |
77 uint32 packets_dropped() { return packets_dropped_; } | 77 QuicPacketCount packets_dropped() { return packets_dropped_; } |
78 | 78 |
79 int port() { return port_; } | 79 int port() { return port_; } |
80 | 80 |
81 protected: | 81 protected: |
82 virtual QuicDispatcher* CreateQuicDispatcher(); | 82 virtual QuicDispatcher* CreateQuicDispatcher(); |
83 | 83 |
84 const QuicConfig& config() const { return config_; } | 84 const QuicConfig& config() const { return config_; } |
85 const QuicCryptoServerConfig& crypto_config() const { | 85 const QuicCryptoServerConfig& crypto_config() const { |
86 return crypto_config_; | 86 return crypto_config_; |
87 } | 87 } |
(...skipping 15 matching lines...) Expand all Loading... |
103 | 103 |
104 // The port the server is listening on. | 104 // The port the server is listening on. |
105 int port_; | 105 int port_; |
106 | 106 |
107 // Listening connection. Also used for outbound client communication. | 107 // Listening connection. Also used for outbound client communication. |
108 int fd_; | 108 int fd_; |
109 | 109 |
110 // If overflow_supported_ is true this will be the number of packets dropped | 110 // If overflow_supported_ is true this will be the number of packets dropped |
111 // during the lifetime of the server. This may overflow if enough packets | 111 // during the lifetime of the server. This may overflow if enough packets |
112 // are dropped. | 112 // are dropped. |
113 uint32 packets_dropped_; | 113 QuicPacketCount packets_dropped_; |
114 | 114 |
115 // True if the kernel supports SO_RXQ_OVFL, the number of packets dropped | 115 // True if the kernel supports SO_RXQ_OVFL, the number of packets dropped |
116 // because the socket would otherwise overflow. | 116 // because the socket would otherwise overflow. |
117 bool overflow_supported_; | 117 bool overflow_supported_; |
118 | 118 |
119 // If true, use recvmmsg for reading. | 119 // If true, use recvmmsg for reading. |
120 bool use_recvmmsg_; | 120 bool use_recvmmsg_; |
121 | 121 |
122 // config_ contains non-crypto parameters that are negotiated in the crypto | 122 // config_ contains non-crypto parameters that are negotiated in the crypto |
123 // handshake. | 123 // handshake. |
(...skipping 11 matching lines...) Expand all Loading... |
135 // connections. | 135 // connections. |
136 uint32 server_initial_flow_control_receive_window_; | 136 uint32 server_initial_flow_control_receive_window_; |
137 | 137 |
138 DISALLOW_COPY_AND_ASSIGN(QuicServer); | 138 DISALLOW_COPY_AND_ASSIGN(QuicServer); |
139 }; | 139 }; |
140 | 140 |
141 } // namespace tools | 141 } // namespace tools |
142 } // namespace net | 142 } // namespace net |
143 | 143 |
144 #endif // NET_TOOLS_QUIC_QUIC_SERVER_H_ | 144 #endif // NET_TOOLS_QUIC_QUIC_SERVER_H_ |
OLD | NEW |