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

Unified Diff: components/sync/engine_impl/attachments/attachment_uploader_impl_unittest.cc

Issue 2915453002: Deprecate NonThreadSafe in components/sync in favor of SequenceChecker. (Closed)
Patch Set: fix comment Created 3 years, 7 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
Index: components/sync/engine_impl/attachments/attachment_uploader_impl_unittest.cc
diff --git a/components/sync/engine_impl/attachments/attachment_uploader_impl_unittest.cc b/components/sync/engine_impl/attachments/attachment_uploader_impl_unittest.cc
index cc226e8e32e7da57e46634cdc476912720a81d45..fd9e7f1047b8f8a78678eec9601d9e28c187c3a2 100644
--- a/components/sync/engine_impl/attachments/attachment_uploader_impl_unittest.cc
+++ b/components/sync/engine_impl/attachments/attachment_uploader_impl_unittest.cc
@@ -15,6 +15,7 @@
#include "base/memory/ref_counted_memory.h"
#include "base/message_loop/message_loop.h"
#include "base/run_loop.h"
+#include "base/sequence_checker.h"
#include "base/single_thread_task_runner.h"
#include "base/strings/string_number_conversions.h"
#include "base/strings/stringprintf.h"
@@ -144,8 +145,7 @@ void MockOAuth2TokenService::InvalidateAccessTokenImpl(
}
class TokenServiceProvider
- : public OAuth2TokenServiceRequest::TokenServiceProvider,
- base::NonThreadSafe {
+ : public OAuth2TokenServiceRequest::TokenServiceProvider {
public:
explicit TokenServiceProvider(OAuth2TokenService* token_service);
@@ -159,6 +159,8 @@ class TokenServiceProvider
scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
OAuth2TokenService* token_service_;
+
+ SEQUENCE_CHECKER(sequence_checker_);
};
TokenServiceProvider::TokenServiceProvider(OAuth2TokenService* token_service)
@@ -167,7 +169,9 @@ TokenServiceProvider::TokenServiceProvider(OAuth2TokenService* token_service)
DCHECK(token_service_);
}
-TokenServiceProvider::~TokenServiceProvider() {}
+TokenServiceProvider::~TokenServiceProvider() {
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
+}
scoped_refptr<base::SingleThreadTaskRunner>
TokenServiceProvider::GetTokenServiceTaskRunner() {
@@ -183,13 +187,13 @@ OAuth2TokenService* TokenServiceProvider::GetTokenService() {
//
// This fixture provides an embedded HTTP server and a mock OAuth2 token service
// for interacting with AttachmentUploaderImpl
-class AttachmentUploaderImplTest : public testing::Test,
- public base::NonThreadSafe {
+class AttachmentUploaderImplTest : public testing::Test {
public:
void OnRequestReceived(const HttpRequest& request);
protected:
AttachmentUploaderImplTest();
+ ~AttachmentUploaderImplTest() override;
void SetUp() override;
void TearDown() override;
@@ -228,6 +232,8 @@ class AttachmentUploaderImplTest : public testing::Test,
std::vector<AttachmentId> attachment_ids_;
std::unique_ptr<MockOAuth2TokenService> token_service_;
+ SEQUENCE_CHECKER(sequence_checker_);
+
// Must be last data member.
base::WeakPtrFactory<AttachmentUploaderImplTest> weak_ptr_factory_;
};
@@ -235,7 +241,7 @@ class AttachmentUploaderImplTest : public testing::Test,
// Handles HTTP requests received by the EmbeddedTestServer.
//
// Responds with HTTP_OK by default. See |SetStatusCode|.
-class RequestHandler : public base::NonThreadSafe {
+class RequestHandler {
public:
// Construct a RequestHandler that will PostTask to |test| using
// |test_task_runner|.
@@ -260,18 +266,24 @@ class RequestHandler : public base::NonThreadSafe {
scoped_refptr<base::SingleThreadTaskRunner> test_task_runner_;
base::WeakPtr<AttachmentUploaderImplTest> test_;
+
+ SEQUENCE_CHECKER(sequence_checker_);
};
AttachmentUploaderImplTest::AttachmentUploaderImplTest()
: weak_ptr_factory_(this) {}
+AttachmentUploaderImplTest::~AttachmentUploaderImplTest() {
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
+}
+
void AttachmentUploaderImplTest::OnRequestReceived(const HttpRequest& request) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
http_requests_received_.push_back(request);
}
void AttachmentUploaderImplTest::SetUp() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
request_handler_ = base::MakeUnique<RequestHandler>(
message_loop_.task_runner(), weak_ptr_factory_.GetWeakPtr());
url_request_context_getter_ =
@@ -359,7 +371,7 @@ RequestHandler& AttachmentUploaderImplTest::request_handler() {
void AttachmentUploaderImplTest::UploadDone(
const AttachmentUploader::UploadResult& result,
const AttachmentId& attachment_id) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
upload_results_.push_back(result);
attachment_ids_.push_back(attachment_id);
DCHECK(!signal_upload_done_.is_null());
@@ -372,16 +384,14 @@ RequestHandler::RequestHandler(
: status_code_(net::HTTP_OK),
test_task_runner_(test_task_runner),
test_(test) {
- DetachFromThread();
+ DETACH_FROM_SEQUENCE(sequence_checker_);
}
-RequestHandler::~RequestHandler() {
- DetachFromThread();
-}
+RequestHandler::~RequestHandler() = default;
std::unique_ptr<HttpResponse> RequestHandler::HandleRequest(
const HttpRequest& request) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
test_task_runner_->PostTask(
FROM_HERE, base::Bind(&AttachmentUploaderImplTest::OnRequestReceived,
test_, request));

Powered by Google App Engine
This is Rietveld 408576698