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 client, which connects to a specified port and sends QUIC | 5 // A toy client, which connects to a specified port and sends QUIC |
6 // request to that endpoint. | 6 // request to that endpoint. |
7 | 7 |
8 #ifndef NET_TOOLS_QUIC_QUIC_CLIENT_H_ | 8 #ifndef NET_TOOLS_QUIC_QUIC_CLIENT_H_ |
9 #define NET_TOOLS_QUIC_QUIC_CLIENT_H_ | 9 #define NET_TOOLS_QUIC_QUIC_CLIENT_H_ |
10 | 10 |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
64 // each to complete. | 64 // each to complete. |
65 void SendRequestsAndWaitForResponse(const CommandLine::StringVector& args); | 65 void SendRequestsAndWaitForResponse(const CommandLine::StringVector& args); |
66 | 66 |
67 // Returns a newly created CreateReliableClientStream, owned by the | 67 // Returns a newly created CreateReliableClientStream, owned by the |
68 // QuicClient. | 68 // QuicClient. |
69 QuicReliableClientStream* CreateReliableClientStream(); | 69 QuicReliableClientStream* CreateReliableClientStream(); |
70 | 70 |
71 // Wait for events until the stream with the given ID is closed. | 71 // Wait for events until the stream with the given ID is closed. |
72 void WaitForStreamToClose(QuicStreamId id); | 72 void WaitForStreamToClose(QuicStreamId id); |
73 | 73 |
| 74 // Wait for events until the handshake is confirmed. |
| 75 void WaitForCryptoHandshakeConfirmed(); |
| 76 |
74 // Wait up to 50ms, and handle any events which occur. | 77 // Wait up to 50ms, and handle any events which occur. |
75 // Returns true if there are any outstanding requests. | 78 // Returns true if there are any outstanding requests. |
76 bool WaitForEvents(); | 79 bool WaitForEvents(); |
77 | 80 |
78 // From EpollCallbackInterface | 81 // From EpollCallbackInterface |
79 virtual void OnRegistration( | 82 virtual void OnRegistration( |
80 EpollServer* eps, int fd, int event_mask) OVERRIDE {} | 83 EpollServer* eps, int fd, int event_mask) OVERRIDE {} |
81 virtual void OnModification(int fd, int event_mask) OVERRIDE {} | 84 virtual void OnModification(int fd, int event_mask) OVERRIDE {} |
82 virtual void OnEvent(int fd, EpollEvent* event) OVERRIDE; | 85 virtual void OnEvent(int fd, EpollEvent* event) OVERRIDE; |
83 // |fd_| can be unregistered without the client being disconnected. This | 86 // |fd_| can be unregistered without the client being disconnected. This |
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
164 // because the socket would otherwise overflow. | 167 // because the socket would otherwise overflow. |
165 bool overflow_supported_; | 168 bool overflow_supported_; |
166 | 169 |
167 DISALLOW_COPY_AND_ASSIGN(QuicClient); | 170 DISALLOW_COPY_AND_ASSIGN(QuicClient); |
168 }; | 171 }; |
169 | 172 |
170 } // namespace tools | 173 } // namespace tools |
171 } // namespace net | 174 } // namespace net |
172 | 175 |
173 #endif // NET_TOOLS_QUIC_QUIC_CLIENT_H_ | 176 #endif // NET_TOOLS_QUIC_QUIC_CLIENT_H_ |
OLD | NEW |