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

Unified Diff: mojo/edk/system/request_context.cc

Issue 1811433002: [mojo-edk] Expose notification source to MojoWatch callbacks (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 9 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: mojo/edk/system/request_context.cc
diff --git a/mojo/edk/system/request_context.cc b/mojo/edk/system/request_context.cc
index c30d8bb821c501af2d424baac908ef6130b742d4..731f44248294f0f915c71520154914c8e99a3cb5 100644
--- a/mojo/edk/system/request_context.cc
+++ b/mojo/edk/system/request_context.cc
@@ -18,7 +18,10 @@ base::LazyInstance<base::ThreadLocalPointer<RequestContext>>::Leaky
} // namespace
-RequestContext::RequestContext() : tls_context_(g_current_context.Pointer()){
+RequestContext::RequestContext() : RequestContext(Source::LOCAL_API_CALL) {}
+
+RequestContext::RequestContext(Source source)
+ : source_(source), tls_context_(g_current_context.Pointer()) {
// We allow nested RequestContexts to exist as long as they aren't actually
// used for anything.
if (!tls_context_->Get())
@@ -29,15 +32,20 @@ RequestContext::~RequestContext() {
// NOTE: Callbacks invoked by this destructor are allowed to initiate new
// EDK requests on this thread, so we need to reset the thread-local context
// pointer before calling them.
+ RequestContext::Source notification_source = tls_context_->Get()->source();
Anand Mistry (off Chromium) 2016/03/17 01:53:09 I don't think this is what we want. Consider a sta
Ken Rockot(use gerrit already) 2016/03/17 01:56:36 That was the intent. I thought that's what you wer
Ken Rockot(use gerrit already) 2016/03/17 15:44:29 I've updated the destructor. Do you agree that al
if (IsCurrent())
tls_context_->Set(nullptr);
+ MojoWatchNotificationFlags flags = MOJO_WATCH_NOTIFICATION_FLAG_NONE;
+ if (notification_source == Source::SYSTEM)
+ flags |= MOJO_WATCH_NOTIFICATION_FLAG_FROM_SYSTEM;
+
for (const WatchNotifyFinalizer& watch :
watch_notify_finalizers_.container()) {
// Establish a new request context for the extent of each callback to ensure
// that they don't themselves invoke callbacks while holding a watcher lock.
- RequestContext request_context;
- watch.watcher->MaybeInvokeCallback(watch.result, watch.state);
+ RequestContext request_context(notification_source);
+ watch.watcher->MaybeInvokeCallback(watch.result, watch.state, flags);
}
for (const scoped_refptr<Watcher>& watcher :

Powered by Google App Engine
This is Rietveld 408576698