Commit 263e0c2f authored by danakj's avatar danakj Committed by Commit Bot

Convert Callback to {Once,Repeating}Callback in //jingle.

Use OnceCallback where possible, and use BindRepeating() where it is
meant to be a RepeatingCallback.

TBR=sergeyu@chromium.org

Bug: 1007709
Change-Id: I4408f77d876e5b72017892ebc2195dafabadfccd
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/1943048Reviewed-by: default avatardanakj <danakj@chromium.org>
Reviewed-by: default avatarvmpstr <vmpstr@chromium.org>
Commit-Queue: danakj <danakj@chromium.org>
Cr-Commit-Position: refs/heads/master@{#720028}
parent 72de22a2
...@@ -384,7 +384,6 @@ _NOT_CONVERTED_TO_MODERN_BIND_AND_CALLBACK = '|'.join(( ...@@ -384,7 +384,6 @@ _NOT_CONVERTED_TO_MODERN_BIND_AND_CALLBACK = '|'.join((
'^ios/web/', '^ios/web/',
'^ios/web_view/', '^ios/web_view/',
'^ipc/', '^ipc/',
'^jingle/',
'^media/audio/', '^media/audio/',
'^media/base/', '^media/base/',
'^media/blink/', '^media/blink/',
......
...@@ -194,8 +194,8 @@ void FakeSSLClientSocket::DoHandshakeLoopWithUserConnectCallback() { ...@@ -194,8 +194,8 @@ void FakeSSLClientSocket::DoHandshakeLoopWithUserConnectCallback() {
} }
int FakeSSLClientSocket::DoConnect() { int FakeSSLClientSocket::DoConnect() {
int status = transport_socket_->Connect( int status = transport_socket_->Connect(base::BindOnce(
base::Bind(&FakeSSLClientSocket::OnConnectDone, base::Unretained(this))); &FakeSSLClientSocket::OnConnectDone, base::Unretained(this)));
if (status != net::OK) { if (status != net::OK) {
return status; return status;
} }
...@@ -224,8 +224,8 @@ void FakeSSLClientSocket::ProcessConnectDone() { ...@@ -224,8 +224,8 @@ void FakeSSLClientSocket::ProcessConnectDone() {
int FakeSSLClientSocket::DoSendClientHello() { int FakeSSLClientSocket::DoSendClientHello() {
int status = transport_socket_->Write( int status = transport_socket_->Write(
write_buf_.get(), write_buf_->BytesRemaining(), write_buf_.get(), write_buf_->BytesRemaining(),
base::Bind(&FakeSSLClientSocket::OnSendClientHelloDone, base::BindOnce(&FakeSSLClientSocket::OnSendClientHelloDone,
base::Unretained(this)), base::Unretained(this)),
TRAFFIC_ANNOTATION_FOR_TESTS); TRAFFIC_ANNOTATION_FOR_TESTS);
if (status < net::OK) { if (status < net::OK) {
return status; return status;
...@@ -258,10 +258,9 @@ void FakeSSLClientSocket::ProcessSendClientHelloDone(size_t written) { ...@@ -258,10 +258,9 @@ void FakeSSLClientSocket::ProcessSendClientHelloDone(size_t written) {
int FakeSSLClientSocket::DoVerifyServerHello() { int FakeSSLClientSocket::DoVerifyServerHello() {
int status = transport_socket_->Read( int status = transport_socket_->Read(
read_buf_.get(), read_buf_.get(), read_buf_->BytesRemaining(),
read_buf_->BytesRemaining(), base::BindOnce(&FakeSSLClientSocket::OnVerifyServerHelloDone,
base::Bind(&FakeSSLClientSocket::OnVerifyServerHelloDone, base::Unretained(this)));
base::Unretained(this)));
if (status < net::OK) { if (status < net::OK) {
return status; return status;
} }
......
...@@ -30,8 +30,7 @@ class NonBlockingPushClient::Core ...@@ -30,8 +30,7 @@ class NonBlockingPushClient::Core
// This is separated out from the constructor since posting tasks // This is separated out from the constructor since posting tasks
// from the constructor is dangerous. // from the constructor is dangerous.
void CreateOnDelegateThread( void CreateOnDelegateThread(
const CreateBlockingPushClientCallback& CreateBlockingPushClientCallback create_blocking_push_client_callback);
create_blocking_push_client_callback);
// Must be called before being destroyed. // Must be called before being destroyed.
void DestroyOnDelegateThread(); void DestroyOnDelegateThread();
...@@ -78,11 +77,10 @@ NonBlockingPushClient::Core::~Core() { ...@@ -78,11 +77,10 @@ NonBlockingPushClient::Core::~Core() {
} }
void NonBlockingPushClient::Core::CreateOnDelegateThread( void NonBlockingPushClient::Core::CreateOnDelegateThread(
const CreateBlockingPushClientCallback& CreateBlockingPushClientCallback create_blocking_push_client_callback) {
create_blocking_push_client_callback) {
DCHECK(delegate_task_runner_->BelongsToCurrentThread()); DCHECK(delegate_task_runner_->BelongsToCurrentThread());
DCHECK(!delegate_push_client_.get()); DCHECK(!delegate_push_client_.get());
delegate_push_client_ = create_blocking_push_client_callback.Run(); delegate_push_client_ = std::move(create_blocking_push_client_callback).Run();
delegate_push_client_->AddObserver(this); delegate_push_client_->AddObserver(this);
} }
...@@ -154,14 +152,13 @@ void NonBlockingPushClient::Core::OnPingResponse() { ...@@ -154,14 +152,13 @@ void NonBlockingPushClient::Core::OnPingResponse() {
NonBlockingPushClient::NonBlockingPushClient( NonBlockingPushClient::NonBlockingPushClient(
const scoped_refptr<base::SingleThreadTaskRunner>& delegate_task_runner, const scoped_refptr<base::SingleThreadTaskRunner>& delegate_task_runner,
const CreateBlockingPushClientCallback& CreateBlockingPushClientCallback create_blocking_push_client_callback)
create_blocking_push_client_callback)
: delegate_task_runner_(delegate_task_runner) { : delegate_task_runner_(delegate_task_runner) {
core_ = new Core(delegate_task_runner_, weak_ptr_factory_.GetWeakPtr()); core_ = new Core(delegate_task_runner_, weak_ptr_factory_.GetWeakPtr());
delegate_task_runner_->PostTask( delegate_task_runner_->PostTask(
FROM_HERE, FROM_HERE,
base::BindOnce(&NonBlockingPushClient::Core::CreateOnDelegateThread, base::BindOnce(&NonBlockingPushClient::Core::CreateOnDelegateThread,
core_, create_blocking_push_client_callback)); core_, std::move(create_blocking_push_client_callback)));
} }
NonBlockingPushClient::~NonBlockingPushClient() { NonBlockingPushClient::~NonBlockingPushClient() {
......
...@@ -31,15 +31,14 @@ class NonBlockingPushClient : public PushClient { ...@@ -31,15 +31,14 @@ class NonBlockingPushClient : public PushClient {
public: public:
// The type for a function that creates a (blocking) PushClient. // The type for a function that creates a (blocking) PushClient.
// Will be called on the delegate task runner. // Will be called on the delegate task runner.
typedef base::Callback<std::unique_ptr<PushClient>()> using CreateBlockingPushClientCallback =
CreateBlockingPushClientCallback; base::OnceCallback<std::unique_ptr<PushClient>()>;
// Runs the given callback on the given task runner, and delegates // Runs the given callback on the given task runner, and delegates
// to that PushClient. // to that PushClient.
explicit NonBlockingPushClient( explicit NonBlockingPushClient(
const scoped_refptr<base::SingleThreadTaskRunner>& delegate_task_runner, const scoped_refptr<base::SingleThreadTaskRunner>& delegate_task_runner,
const CreateBlockingPushClientCallback& CreateBlockingPushClientCallback create_blocking_push_client_callback);
create_blocking_push_client_callback);
~NonBlockingPushClient() override; ~NonBlockingPushClient() override;
// PushClient implementation. // PushClient implementation.
......
...@@ -31,11 +31,10 @@ class NonBlockingPushClientTest : public testing::Test { ...@@ -31,11 +31,10 @@ class NonBlockingPushClientTest : public testing::Test {
~NonBlockingPushClientTest() override {} ~NonBlockingPushClientTest() override {}
void SetUp() override { void SetUp() override {
push_client_.reset( push_client_ = std::make_unique<NonBlockingPushClient>(
new NonBlockingPushClient( base::ThreadTaskRunnerHandle::Get(),
base::ThreadTaskRunnerHandle::Get(), base::BindOnce(&NonBlockingPushClientTest::CreateFakePushClient,
base::Bind(&NonBlockingPushClientTest::CreateFakePushClient, base::Unretained(this)));
base::Unretained(this))));
push_client_->AddObserver(&fake_observer_); push_client_->AddObserver(&fake_observer_);
// Pump message loop to run CreateFakePushClient. // Pump message loop to run CreateFakePushClient.
base::RunLoop().RunUntilIdle(); base::RunLoop().RunUntilIdle();
...@@ -54,10 +53,11 @@ class NonBlockingPushClientTest : public testing::Test { ...@@ -54,10 +53,11 @@ class NonBlockingPushClientTest : public testing::Test {
std::unique_ptr<PushClient> CreateFakePushClient() { std::unique_ptr<PushClient> CreateFakePushClient() {
if (fake_push_client_) { if (fake_push_client_) {
ADD_FAILURE(); ADD_FAILURE();
return std::unique_ptr<PushClient>(); return nullptr;
} }
fake_push_client_ = new FakePushClient(); auto client = std::make_unique<FakePushClient>();
return std::unique_ptr<PushClient>(fake_push_client_); fake_push_client_ = client.get();
return client;
} }
base::test::SingleThreadTaskEnvironment task_environment_; base::test::SingleThreadTaskEnvironment task_environment_;
......
...@@ -26,9 +26,9 @@ std::unique_ptr<PushClient> CreateXmppPushClient( ...@@ -26,9 +26,9 @@ std::unique_ptr<PushClient> CreateXmppPushClient(
std::unique_ptr<PushClient> PushClient::CreateDefault( std::unique_ptr<PushClient> PushClient::CreateDefault(
const NotifierOptions& notifier_options) { const NotifierOptions& notifier_options) {
return std::unique_ptr<PushClient>(new NonBlockingPushClient( return std::make_unique<NonBlockingPushClient>(
notifier_options.network_config.task_runner, notifier_options.network_config.task_runner,
base::Bind(&CreateXmppPushClient, notifier_options))); base::BindOnce(&CreateXmppPushClient, notifier_options));
} }
std::unique_ptr<PushClient> PushClient::CreateDefaultOnIOThread( std::unique_ptr<PushClient> PushClient::CreateDefaultOnIOThread(
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment