commit fadd9dfae90e56085d177a8f243e7dae12715bb0
author Nicolas Capens <capn@google.com> Thu Oct 29 00:34:36 2020 -0400
committer Nicolas Capens <capn@google.com> Thu Oct 29 00:34:37 2020 -0400
tree 116f1f0aeabfa6c5e61d2ba6733d5021b2c39c5c
parent 2be25f08deafe1fb1eada032cd3b2aae3021f367
parent b66407c627d33f6adfe049f3d9f7349974090dc7

Update Marl to 3285a2dfb

Changes:
    3285a2dfb Workaround MSAN false-positive
    6bf128cab Assert that threads are joined before destruction
    06b72af16 Scheduler: Add a couple of asserts

Commands:
    ./third_party/update-marl.sh --squash

Bug: b/140546382
Change-Id: I8df3d233e0dd6bf2e9ebfe85bbd7630c902a6678

third_party/marl/src/scheduler.cpp

diff --git a/third_party/marl/src/scheduler.cpp b/third_party/marl/src/scheduler.cpp
index be20ed1..027565d 100644
--- a/third_party/marl/src/scheduler.cpp
+++ b/third_party/marl/src/scheduler.cpp
@@ -17,6 +17,7 @@
 #include "marl/scheduler.h"
 
 #include "marl/debug.h"
+#include "marl/sanitizers.h"
 #include "marl/thread.h"
 #include "marl/trace.h"
 
@@ -91,7 +92,13 @@
 }
 
 void Scheduler::bind() {
+#if !MEMORY_SANITIZER_ENABLED
+  // thread_local variables in shared libraries are initialized at load-time,
+  // but this is not observed by MemorySanitizer if the loader itself was not
+  // instrumented, leading to false-positive unitialized variable errors.
+  // See https://github.com/google/marl/issues/184
   MARL_ASSERT(bound == nullptr, "Scheduler already bound");
+#endif
   bound = this;
   {
     marl::lock lock(singleThreadedWorkers.mutex);
@@ -237,10 +244,16 @@
 }
 
 void Scheduler::Fiber::wait(marl::lock& lock, const Predicate& pred) {
+  MARL_ASSERT(worker == Worker::getCurrent(),
+              "Scheduler::Fiber::wait() must only be called on the currently "
+              "executing fiber");
   worker->wait(lock, nullptr, pred);
 }
 
 void Scheduler::Fiber::switchTo(Fiber* to) {
+  MARL_ASSERT(worker == Worker::getCurrent(),
+              "Scheduler::Fiber::switchTo() must only be called on the "
+              "currently executing fiber");
   if (to != this) {
     impl->switchTo(to->impl.get());
   }

third_party/marl/src/thread.cpp

diff --git a/third_party/marl/src/thread.cpp b/third_party/marl/src/thread.cpp
index 3febe62..d0750fa 100644
--- a/third_party/marl/src/thread.cpp
+++ b/third_party/marl/src/thread.cpp
@@ -402,11 +402,13 @@
     : impl(new Thread::Impl(std::move(affinity), std::move(func))) {}
 
 Thread::~Thread() {
-  delete impl;
+  MARL_ASSERT(!impl, "Thread::join() was not called before destruction");
 }
 
 void Thread::join() {
   impl->thread.join();
+  delete impl;
+  impl = nullptr;
 }
 
 void Thread::setName(const char* fmt, ...) {