Add yet another threaded test of WaitSetDispatcher.

mojo/edk/system/wait_set_dispatcher.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "mojo/edk/system/wait_set_dispatcher.h"
 
 #include <string.h>
 
 #include <algorithm>
 #include <limits>
@@ skipping 101 matching lines @@
 
 void WaitSetDispatcher::CloseImplNoLock() {
   mutex().AssertHeld();
 
   CookieToEntryMap entries;
   std::swap(entries_, entries);
   triggered_head_ = nullptr;
   triggered_tail_ = nullptr;
   triggered_count_ = 0u;
 
-  cv_.Signal();
+  cv_.SignalAll();
 
   // We want to remove the awakables outside the lock, so we have to unlock
   // |mutex()|. Note that while unlocked, |Awake()| may get called.
   // TODO(vtl): This is pretty terrible, but changing it would require pretty
   // invasive changes in many other places. We really count on |Dispatcher| not
   // doing anything interesting after calling |CloseImplNoLock()|, and since
   // |CloseImplNoLock()| is allowed to do nothing all the lock invariants are
   // satisfied.
   DCHECK(is_closed_no_lock());
   mutex().Unlock();
@@ skipping 285 matching lines @@
   }
 }
 
 void WaitSetDispatcher::AddTriggeredNoLock(Entry* entry) {
   DCHECK(!entry->is_triggered);
   DCHECK(!entry->triggered_previous);
   DCHECK(!entry->triggered_next);
 
   entry->is_triggered = true;
   if (!triggered_count_)
-    cv_.Signal();
+    cv_.SignalAll();
   triggered_count_++;
 
   if (!triggered_tail_) {
     DCHECK(!triggered_head_);
     triggered_head_ = entry;
     triggered_tail_ = entry;
     return;
   }
 
   Entry* old_tail = triggered_tail_;
@@ skipping 21 matching lines @@
   } else {
     entry->triggered_next->triggered_previous = entry->triggered_previous;
   }
 
   entry->triggered_previous = nullptr;
   entry->triggered_next = nullptr;
 }
 
 }  // namespace system
 }  // namespace mojo