1 // Copyright 2013 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.
5 #ifndef NET_TOOLS_QUIC_SERVER_THREAD_H_
6 #define NET_TOOLS_QUIC_SERVER_THREAD_H_
8 #include "base/threading/simple_thread.h"
9 #include "net/base/ip_endpoint.h"
10 #include "net/quic/quic_config.h"
11 #include "net/tools/quic/quic_server.h"
17 // Simple wrapper class to run server in a thread.
18 class ServerThread : public base::SimpleThread {
20 ServerThread(QuicServer* server,
22 bool strike_register_no_startup_period);
24 virtual ~ServerThread();
26 // Prepares the server, but does not start accepting connections. Useful for
30 // Runs the event loop. Will initialize if necessary.
31 virtual void Run() OVERRIDE;
33 // Waits for the handshake to be confirmed for the first session created.
34 void WaitForCryptoHandshakeConfirmed();
36 // Pauses execution of the server until Resume() is called. May only be
40 // Resumes execution of the server after Pause() has been called. May only
44 // Stops the server from executing and shuts it down, destroying all
48 // Returns the underlying server. Care must be taken to avoid data races
49 // when accessing the server. It is always safe to access the server
50 // after calling Pause() and before calling Resume().
51 QuicServer* server() { return server_.get(); }
53 // Returns the port that the server is listening on.
57 void MaybeNotifyOfHandshakeConfirmation();
59 base::WaitableEvent confirmed_; // Notified when the first handshake is
61 base::WaitableEvent pause_; // Notified when the server should pause.
62 base::WaitableEvent paused_; // Notitied when the server has paused
63 base::WaitableEvent resume_; // Notified when the server should resume.
64 base::WaitableEvent quit_; // Notified when the server should quit.
66 scoped_ptr<QuicServer> server_;
68 base::Lock port_lock_;
73 DISALLOW_COPY_AND_ASSIGN(ServerThread);
80 #endif // NET_TOOLS_QUIC_SERVER_THREAD_H_