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

Unified Diff: third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h

Issue 1369933004: Revert of Implement a simple ThreadChecker for Mojo and add to |internal::SharedData| and |internal::Router|. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 2 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: third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h
diff --git a/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h b/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h
index 1999947e0420961de172f70572aae381e85a6050..d7e5a68d6e25c837c9bfd778ddba412586a4d00b 100644
--- a/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h
+++ b/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.h
@@ -11,9 +11,7 @@
#include "mojo/public/cpp/bindings/lib/connector.h"
#include "mojo/public/cpp/bindings/lib/filter_chain.h"
#include "mojo/public/cpp/bindings/lib/shared_data.h"
-#include "mojo/public/cpp/bindings/lib/thread_checker.h"
#include "mojo/public/cpp/environment/environment.h"
-#include "mojo/public/cpp/environment/logging.h"
namespace mojo {
namespace internal {
@@ -39,24 +37,14 @@
// Returns true if an error was encountered while reading from the pipe or
// waiting to read from the pipe.
- bool encountered_error() const {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- return connector_.encountered_error();
- }
+ bool encountered_error() const { return connector_.encountered_error(); }
// Is the router bound to a MessagePipe handle?
- bool is_valid() const {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- return connector_.is_valid();
- }
+ bool is_valid() const { return connector_.is_valid(); }
- void CloseMessagePipe() {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- connector_.CloseMessagePipe();
- }
+ void CloseMessagePipe() { connector_.CloseMessagePipe(); }
ScopedMessagePipeHandle PassMessagePipe() {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
return connector_.PassMessagePipe();
}
@@ -68,17 +56,14 @@
// Blocks the current thread until the first incoming method call, i.e.,
// either a call to a client method or a callback method, or |deadline|.
bool WaitForIncomingMessage(MojoDeadline deadline) {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
return connector_.WaitForIncomingMessage(deadline);
}
// See Binding for details of pause/resume.
void PauseIncomingMethodCallProcessing() {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
connector_.PauseIncomingMethodCallProcessing();
}
void ResumeIncomingMethodCallProcessing() {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
connector_.ResumeIncomingMethodCallProcessing();
}
@@ -92,10 +77,7 @@
MessagePipeHandle handle() const { return connector_.handle(); }
// Returns true if this Router has any pending callbacks.
- bool has_pending_responders() const {
- MOJO_DCHECK(thread_checker_.CalledOnValidThread());
- return !responders_.empty();
- }
+ bool has_pending_responders() const { return !responders_.empty(); }
private:
typedef std::map<uint64_t, MessageReceiver*> ResponderMap;
@@ -124,7 +106,6 @@
ResponderMap responders_;
uint64_t next_request_id_;
bool testing_mode_;
- ThreadChecker thread_checker_;
};
} // namespace internal
« no previous file with comments | « third_party/mojo/src/mojo/public/cpp/bindings/BUILD.gn ('k') | third_party/mojo/src/mojo/public/cpp/bindings/lib/router.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698