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

Unified Diff: net/tools/quic/quic_simple_server.cc

Issue 1036023002: Move remaining QUIC server files from net/quic/ to net/tools/quic/. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: correctly fix cronet 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/quic_simple_server.h ('k') | net/tools/quic/quic_simple_server_bin.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/tools/quic/quic_simple_server.cc
diff --git a/net/quic/quic_server.cc b/net/tools/quic/quic_simple_server.cc
similarity index 79%
rename from net/quic/quic_server.cc
rename to net/tools/quic/quic_simple_server.cc
index b3b20ba14054aa96c26d74cc9ee676307974934f..864411f35efb0e59a1409e363e15e6226da8dad1 100644
--- a/net/quic/quic_server.cc
+++ b/net/tools/quic/quic_simple_server.cc
@@ -2,7 +2,7 @@
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
-#include "net/quic/quic_server.h"
+#include "net/tools/quic/quic_simple_server.h"
#include <string.h>
@@ -12,15 +12,14 @@
#include "net/quic/crypto/quic_random.h"
#include "net/quic/quic_crypto_stream.h"
#include "net/quic/quic_data_reader.h"
-#include "net/quic/quic_per_connection_packet_writer.h"
#include "net/quic/quic_protocol.h"
-#include "net/quic/quic_server_packet_writer.h"
#include "net/tools/quic/quic_dispatcher.h"
+#include "net/tools/quic/quic_simple_per_connection_packet_writer.h"
+#include "net/tools/quic/quic_simple_server_packet_writer.h"
#include "net/udp/udp_server_socket.h"
namespace net {
-
-using tools::QuicDispatcher;
+namespace tools {
namespace {
@@ -30,10 +29,10 @@ const char kSourceAddressTokenSecret[] = "secret";
// the limit.
const int kReadBufferSize = 2 * kMaxPacketSize;
-// A packet writer factory which wraps a shared QuicServerPacketWriter
+// A packet writer factory which wraps a shared QuicSimpleServerPacketWriter
// inside of a QuicPerConnectionPacketWriter. Instead of checking that
// the shared_writer is the expected writer, this could instead cast
-// from QuicPacketWriter to QuicServerPacketWriter.
+// from QuicPacketWriter to QuicSimpleServerPacketWriter.
class CustomPacketWriterFactory : public QuicDispatcher::PacketWriterFactory {
public:
~CustomPacketWriterFactory() override {}
@@ -48,21 +47,21 @@ class CustomPacketWriterFactory : public QuicDispatcher::PacketWriterFactory {
LOG(DFATAL) << "writer mismatch";
return nullptr;
}
- return new QuicPerConnectionPacketWriter(shared_writer_, connection);
+ return new QuicSimplePerConnectionPacketWriter(shared_writer_, connection);
}
- void set_shared_writer(QuicServerPacketWriter* shared_writer) {
+ void set_shared_writer(QuicSimpleServerPacketWriter* shared_writer) {
shared_writer_ = shared_writer;
}
private:
- QuicServerPacketWriter* shared_writer_; // Not owned.
+ QuicSimpleServerPacketWriter* shared_writer_; // Not owned.
};
} // namespace
-QuicServer::QuicServer(const QuicConfig& config,
- const QuicVersionVector& supported_versions)
+QuicSimpleServer::QuicSimpleServer(const QuicConfig& config,
+ const QuicVersionVector& supported_versions)
: helper_(base::MessageLoop::current()->message_loop_proxy().get(),
&clock_,
QuicRandom::GetInstance()),
@@ -76,7 +75,7 @@ QuicServer::QuicServer(const QuicConfig& config,
Initialize();
}
-void QuicServer::Initialize() {
+void QuicSimpleServer::Initialize() {
#if MMSG_MORE
use_recvmmsg_ = true;
#endif
@@ -102,10 +101,10 @@ void QuicServer::Initialize() {
QuicCryptoServerConfig::ConfigOptions()));
}
-QuicServer::~QuicServer() {
+QuicSimpleServer::~QuicSimpleServer() {
}
-int QuicServer::Listen(const IPEndPoint& address) {
+int QuicSimpleServer::Listen(const IPEndPoint& address) {
scoped_ptr<UDPServerSocket> socket(
new UDPServerSocket(&net_log_, NetLog::Source()));
@@ -118,8 +117,8 @@ int QuicServer::Listen(const IPEndPoint& address) {
}
// These send and receive buffer sizes are sized for a single connection,
- // because the default usage of QuicServer is as a test server with one or
- // two clients. Adjust higher for use with many clients.
+ // because the default usage of QuicSimpleServer is as a test server with
+ // one or two clients. Adjust higher for use with many clients.
rc = socket->SetReceiveBufferSize(
static_cast<int32>(kDefaultSocketReceiveBuffer));
if (rc < 0) {
@@ -150,7 +149,7 @@ int QuicServer::Listen(const IPEndPoint& address) {
supported_versions_,
factory,
&helper_));
- QuicServerPacketWriter* writer = new QuicServerPacketWriter(
+ QuicSimpleServerPacketWriter* writer = new QuicSimpleServerPacketWriter(
socket_.get(),
dispatcher_.get());
factory->set_shared_writer(writer);
@@ -161,7 +160,7 @@ int QuicServer::Listen(const IPEndPoint& address) {
return OK;
}
-void QuicServer::Shutdown() {
+void QuicSimpleServer::Shutdown() {
// Before we shut down the epoll server, give all active sessions a chance to
// notify clients that they're closing.
dispatcher_->Shutdown();
@@ -170,7 +169,7 @@ void QuicServer::Shutdown() {
socket_.reset();
}
-void QuicServer::StartReading() {
+void QuicSimpleServer::StartReading() {
if (read_pending_) {
return;
}
@@ -180,7 +179,7 @@ void QuicServer::StartReading() {
read_buffer_.get(),
read_buffer_->size(),
&client_address_,
- base::Bind(&QuicServer::OnReadComplete, base::Unretained(this)));
+ base::Bind(&QuicSimpleServer::OnReadComplete, base::Unretained(this)));
if (result == ERR_IO_PENDING) {
synchronous_read_count_ = 0;
@@ -193,7 +192,7 @@ void QuicServer::StartReading() {
// recursion and 2) avoid blocking the thread for too long.
base::MessageLoop::current()->PostTask(
FROM_HERE,
- base::Bind(&QuicServer::OnReadComplete,
+ base::Bind(&QuicSimpleServer::OnReadComplete,
weak_factory_.GetWeakPtr(),
result));
} else {
@@ -201,13 +200,13 @@ void QuicServer::StartReading() {
}
}
-void QuicServer::OnReadComplete(int result) {
+void QuicSimpleServer::OnReadComplete(int result) {
read_pending_ = false;
if (result == 0)
result = ERR_CONNECTION_CLOSED;
if (result < 0) {
- LOG(ERROR) << "QuicServer read failed: " << ErrorToString(result);
+ LOG(ERROR) << "QuicSimpleServer read failed: " << ErrorToString(result);
Shutdown();
return;
}
@@ -218,4 +217,5 @@ void QuicServer::OnReadComplete(int result) {
StartReading();
}
+} // namespace tools
} // namespace net
« no previous file with comments | « net/tools/quic/quic_simple_server.h ('k') | net/tools/quic/quic_simple_server_bin.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698