Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(698)

Unified Diff: net/tools/quic/test_tools/server_thread.cc

Issue 992733002: Remove //net (except for Android test stuff) and sdch (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/tools/quic/test_tools/server_thread.h ('k') | net/tools/quic/test_tools/simple_client.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/tools/quic/test_tools/server_thread.cc
diff --git a/net/tools/quic/test_tools/server_thread.cc b/net/tools/quic/test_tools/server_thread.cc
deleted file mode 100644
index f654b7df1902f9a2bbdd197d0f9ca64a8cf33475..0000000000000000000000000000000000000000
--- a/net/tools/quic/test_tools/server_thread.cc
+++ /dev/null
@@ -1,113 +0,0 @@
-// Copyright 2013 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "net/tools/quic/test_tools/server_thread.h"
-
-#include "net/tools/quic/quic_dispatcher.h"
-#include "net/tools/quic/test_tools/quic_server_peer.h"
-
-namespace net {
-namespace tools {
-namespace test {
-
-ServerThread::ServerThread(QuicServer* server,
- IPEndPoint address,
- bool strike_register_no_startup_period)
- : SimpleThread("server_thread"),
- confirmed_(true, false),
- pause_(true, false),
- paused_(true, false),
- resume_(true, false),
- quit_(true, false),
- server_(server),
- address_(address),
- port_(0),
- initialized_(false) {
- if (strike_register_no_startup_period) {
- server_->SetStrikeRegisterNoStartupPeriod();
- }
-}
-
-ServerThread::~ServerThread() {}
-
-void ServerThread::Initialize() {
- if (initialized_) {
- return;
- }
-
- server_->Listen(address_);
-
- port_lock_.Acquire();
- port_ = server_->port();
- port_lock_.Release();
-
- initialized_ = true;
-}
-
-void ServerThread::Run() {
- if (!initialized_) {
- Initialize();
- }
-
- while (!quit_.IsSignaled()) {
- if (pause_.IsSignaled() && !resume_.IsSignaled()) {
- paused_.Signal();
- resume_.Wait();
- }
- server_->WaitForEvents();
- MaybeNotifyOfHandshakeConfirmation();
- }
-
- server_->Shutdown();
-}
-
-int ServerThread::GetPort() {
- port_lock_.Acquire();
- int rc = port_;
- port_lock_.Release();
- return rc;
-}
-
-void ServerThread::WaitForCryptoHandshakeConfirmed() {
- confirmed_.Wait();
-}
-
-void ServerThread::Pause() {
- DCHECK(!pause_.IsSignaled());
- pause_.Signal();
- paused_.Wait();
-}
-
-void ServerThread::Resume() {
- DCHECK(!resume_.IsSignaled());
- DCHECK(pause_.IsSignaled());
- resume_.Signal();
-}
-
-void ServerThread::Quit() {
- if (pause_.IsSignaled() && !resume_.IsSignaled()) {
- resume_.Signal();
- }
- quit_.Signal();
-}
-
-void ServerThread::MaybeNotifyOfHandshakeConfirmation() {
- if (confirmed_.IsSignaled()) {
- // Only notify once.
- return;
- }
- QuicDispatcher* dispatcher = QuicServerPeer::GetDispatcher(server());
- if (dispatcher->session_map().empty()) {
- // Wait for a session to be created.
- return;
- }
- QuicSession* session = dispatcher->session_map().begin()->second;
- if (session->IsCryptoHandshakeConfirmed()) {
- confirmed_.Signal();
- }
-}
-
-} // namespace test
-} // namespace tools
-} // namespace net
« no previous file with comments | « net/tools/quic/test_tools/server_thread.h ('k') | net/tools/quic/test_tools/simple_client.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698