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

Unified Diff: components/cast_channel/cast_socket.cc

Issue 2913033003: [cast_channel] Move cast_channel related files from //extensions to //components (Closed)
Patch Set: fix buildbot compile errors Created 3 years, 6 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 | « components/cast_channel/cast_socket.h ('k') | components/cast_channel/cast_socket_service.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: components/cast_channel/cast_socket.cc
diff --git a/extensions/browser/api/cast_channel/cast_socket.cc b/components/cast_channel/cast_socket.cc
similarity index 95%
rename from extensions/browser/api/cast_channel/cast_socket.cc
rename to components/cast_channel/cast_socket.cc
index cb25862539fe78646410009226394f066d8bc9af..3675874ec571c660cac2d6d4af0c0b6c629b0cb6 100644
--- a/extensions/browser/api/cast_channel/cast_socket.cc
+++ b/components/cast_channel/cast_socket.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 "extensions/browser/api/cast_channel/cast_socket.h"
+#include "components/cast_channel/cast_socket.h"
#include <stdlib.h>
#include <string.h>
@@ -22,12 +22,12 @@
#include "base/sys_byteorder.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/time/time.h"
-#include "extensions/browser/api/cast_channel/cast_auth_util.h"
-#include "extensions/browser/api/cast_channel/cast_framer.h"
-#include "extensions/browser/api/cast_channel/cast_message_util.h"
-#include "extensions/browser/api/cast_channel/cast_transport.h"
-#include "extensions/browser/api/cast_channel/logger.h"
-#include "extensions/common/api/cast_channel/cast_channel.pb.h"
+#include "components/cast_channel/cast_auth_util.h"
+#include "components/cast_channel/cast_framer.h"
+#include "components/cast_channel/cast_message_util.h"
+#include "components/cast_channel/cast_transport.h"
+#include "components/cast_channel/logger.h"
+#include "components/cast_channel/proto/cast_channel.pb.h"
#include "net/base/address_list.h"
#include "net/base/host_port_pair.h"
#include "net/base/net_errors.h"
@@ -57,8 +57,6 @@
#define VLOG_WITH_CONNECTION(level) VLOG(level) << CONNECTION_INFO()
#define LOG_WITH_CONNECTION(level) LOG(level) << CONNECTION_INFO()
-namespace extensions {
-namespace api {
namespace cast_channel {
namespace {
@@ -207,8 +205,8 @@ std::unique_ptr<net::SSLClientSocket> CastSocketImpl::CreateSslSocket(
std::unique_ptr<net::ClientSocketHandle> connection(
new net::ClientSocketHandle);
connection->SetSocket(std::move(socket));
- net::HostPortPair host_and_port = net::HostPortPair::FromIPEndPoint(
- ip_endpoint_);
+ net::HostPortPair host_and_port =
+ net::HostPortPair::FromIPEndPoint(ip_endpoint_);
return net::ClientSocketFactory::GetDefaultFactory()->CreateSSLClientSocket(
std::move(connection), host_and_port, ssl_config, context);
@@ -254,7 +252,7 @@ void CastSocketImpl::SetTransportForTesting(
void CastSocketImpl::Connect(std::unique_ptr<CastTransport::Delegate> delegate,
base::Callback<void(ChannelError)> callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
VLOG_WITH_CONNECTION(1) << "Connect readyState = "
<< ::cast_channel::ReadyStateToString(ready_state_);
DCHECK_EQ(proto::CONN_STATE_START_CONNECT, connect_state_);
@@ -275,8 +273,7 @@ void CastSocketImpl::Connect(std::unique_ptr<CastTransport::Delegate> delegate,
DCHECK(connect_timeout_callback_.IsCancelled());
connect_timeout_callback_.Reset(
base::Bind(&CastSocketImpl::OnConnectTimeout, base::Unretained(this)));
- GetTimer()->Start(FROM_HERE,
- connect_timeout_,
+ GetTimer()->Start(FROM_HERE, connect_timeout_,
connect_timeout_callback_.callback());
}
@@ -288,7 +285,7 @@ CastTransport* CastSocketImpl::transport() const {
}
void CastSocketImpl::OnConnectTimeout() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
// Stop all pending connection setup tasks and report back to the client.
is_canceled_ = true;
VLOG_WITH_CONNECTION(1) << "Timeout while establishing a connection.";
@@ -303,7 +300,7 @@ void CastSocketImpl::ResetConnectLoopCallback() {
}
void CastSocketImpl::PostTaskToStartConnectLoop(int result) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
ResetConnectLoopCallback();
base::ThreadTaskRunnerHandle::Get()->PostTask(
@@ -508,8 +505,7 @@ void CastSocketImpl::AuthTransportDelegate::OnMessage(
}
}
-void CastSocketImpl::AuthTransportDelegate::Start() {
-}
+void CastSocketImpl::AuthTransportDelegate::Start() {}
int CastSocketImpl::DoAuthChallengeReplyComplete(int result) {
VLOG_WITH_CONNECTION(1) << "DoAuthChallengeReplyComplete: " << result;
@@ -556,7 +552,7 @@ void CastSocketImpl::DoConnectCallback() {
}
void CastSocketImpl::Close(const net::CompletionCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
CloseInternal();
// Run this callback last. It may delete the socket.
callback.Run(net::OK);
@@ -565,7 +561,7 @@ void CastSocketImpl::Close(const net::CompletionCallback& callback) {
void CastSocketImpl::CloseInternal() {
// TODO(mfoltz): Enforce this when CastChannelAPITest is rewritten to create
// and free sockets on the same thread. crbug.com/398242
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
if (ready_state_ == ReadyState::CLOSED) {
return;
}
@@ -587,10 +583,6 @@ void CastSocketImpl::CloseInternal() {
SetReadyState(ReadyState::CLOSED);
}
-bool CastSocketImpl::CalledOnValidThread() const {
- return thread_checker_.CalledOnValidThread();
-}
-
base::Timer* CastSocketImpl::GetTimer() {
return connect_timeout_timer_.get();
}
@@ -615,6 +607,4 @@ void CastSocketImpl::SetErrorState(ChannelError error_state) {
}
} // namespace cast_channel
-} // namespace api
-} // namespace extensions
#undef VLOG_WITH_CONNECTION
« no previous file with comments | « components/cast_channel/cast_socket.h ('k') | components/cast_channel/cast_socket_service.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698