Initial P2P implementation for WebRTC on QUIC prototype

net/quic/quic_p2p_session_factory.cc

+// Copyright 2014 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/quic/quic_p2p_session_factory.h"
+
+#include "net/cert/x509_certificate.h"
+#include "net/quic/crypto/quic_random.h"
+#include "net/quic/quic_connection.h"
+#include "net/quic/quic_p2p_client_session.h"
+#include "net/quic/quic_p2p_server_session.h"
+
+namespace net {
+
+namespace {
+string MakeSecret(QuicRandom* random) {
+  uint8 buf[16];
+  random->RandBytes(buf, sizeof(buf));
+  return string(reinterpret_cast<char*>(buf), sizeof(buf));
+}
+}  // namespace
+
+QuicP2PSessionFactory::QuicP2PSessionFactory(
+    QuicConnectionHelperInterface* helper)
+    : helper_(helper),
+      server_config_(MakeSecret(helper->GetRandomGenerator()),
+                     helper->GetRandomGenerator()) {
+  client_config_.SetDefaults();
+  client_config_.set_user_agent_id("P2P");
+  // TODO(dmz) more on server_config_
+  server_config_.AddDefaultConfig(helper->GetRandomGenerator(),
+                                  helper->GetClock(),
+                                  QuicCryptoServerConfig::ConfigOptions());
+}
+
+QuicP2PSession* QuicP2PSessionFactory::Create(
+    bool is_server_role,
+    X509Certificate* local_identity,
+    base::StringPiece private_key,
+    HashValue remote_fingerprint,
+    QuicPacketWriter* writer,
+    QuicP2PSession::Delegate* delegate,
+    QuicMessageStream::ReadDelegate* read_delegate) {
+  QuicConnection* connection = new QuicConnection(
+    0xa5adface,  // TODO(dmz)
+    IPEndPoint(),
+    helper_,
+    is_server_role,
+    QuicSupportedVersions());
+  connection->set_writer(writer, /* owned= */ false);
+  QuicConfig config;
+  config.SetDefaults();
+  // Let P2PTransportChannel handle the timeouts
+  config.set_idle_connection_state_lifetime(
+      QuicTime::Delta::FromSeconds(1000),
+      QuicTime::Delta::FromSeconds(1000));
+  // TODO(dmz) This should probably use the same options as the normal QUIC
+  // running in the I/O thread. We need to get at
+  // IOThread::globals_->quic_connection_options somehow.
+  QuicTagVector connection_options;
+  connection_options.push_back(net::kPACE);
+  connection_options.push_back(net::kTIME);
+  config.SetConnectionOptionsToSend(connection_options);
+  QuicP2PSession* session;
+  if (is_server_role) {
+    session = new QuicP2PServerSession(config,
+                                       &server_config_,
+                                       connection,
+                                       delegate,
+                                       read_delegate);
+  } else {
+    // TODO(dmz) more on client_config_
+    // TODO(dmz) QuicServerId has to match
+    session = new QuicP2PClientSession(config,
+                                       QuicServerId(),
+                                       &client_config_,
+                                       connection,
+                                       delegate,
+                                       read_delegate);
+  }
+  session->InitializeSession();
+  return session;
+}
+
+}  // namespace net