lldb/unittests/Utility/BroadcasterTest.cpp

   1 //===-- BroadcasterTest.cpp -----------------------------------------------===//
   2 //
   3 // Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
   4 // See https://llvm.org/LICENSE.txt for license information.
   5 // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
   6 //
   7 //===----------------------------------------------------------------------===//
   8
   9 #include "gtest/gtest.h"
  10
  11 #include "lldb/Utility/Broadcaster.h"
  12 #include "lldb/Utility/Event.h"
  13 #include "lldb/Utility/Listener.h"
  14 #include "lldb/Utility/Predicate.h"
  15
  16 #include <thread>
  17
  18 using namespace lldb;
  19 using namespace lldb_private;
  20
  21 TEST(BroadcasterTest, BroadcastEvent) {
  22   EventSP event_sp;
  23   Broadcaster broadcaster(nullptr, "test-broadcaster");
  24   std::chrono::seconds timeout(0);
  25
  26   // Create a listener, sign it up, make sure it receives an event.
  27   ListenerSP listener1_sp = Listener::MakeListener("test-listener1");
  28   const uint32_t event_mask1 = 1;
  29   EXPECT_EQ(event_mask1,
  30             listener1_sp->StartListeningForEvents(&broadcaster, event_mask1));
  31   broadcaster.BroadcastEvent(event_mask1, nullptr);
  32   EXPECT_TRUE(listener1_sp->GetEvent(event_sp, timeout));
  33   EXPECT_EQ(event_mask1, event_sp->GetType());
  34
  35   {
  36     // Add one more listener, make sure it works as well.
  37     ListenerSP listener2_sp = Listener::MakeListener("test-listener2");
  38     const uint32_t event_mask2 = 1;
  39     EXPECT_EQ(event_mask2, listener2_sp->StartListeningForEvents(
  40                                &broadcaster, event_mask1 | event_mask2));
  41     broadcaster.BroadcastEvent(event_mask2, nullptr);
  42     EXPECT_TRUE(listener2_sp->GetEvent(event_sp, timeout));
  43     EXPECT_EQ(event_mask2, event_sp->GetType());
  44
  45     // Both listeners should get this event.
  46     broadcaster.BroadcastEvent(event_mask1, nullptr);
  47     EXPECT_TRUE(listener1_sp->GetEvent(event_sp, timeout));
  48     EXPECT_EQ(event_mask1, event_sp->GetType());
  49     EXPECT_TRUE(listener2_sp->GetEvent(event_sp, timeout));
  50     EXPECT_EQ(event_mask2, event_sp->GetType());
  51   }
  52
  53   // Now again only one listener should be active.
  54   broadcaster.BroadcastEvent(event_mask1, nullptr);
  55   EXPECT_TRUE(listener1_sp->GetEvent(event_sp, timeout));
  56   EXPECT_EQ(event_mask1, event_sp->GetType());
  57 }
  58
  59 TEST(BroadcasterTest, EventTypeHasListeners) {
  60   EventSP event_sp;
  61   Broadcaster broadcaster(nullptr, "test-broadcaster");
  62
  63   const uint32_t event_mask = 1;
  64   EXPECT_FALSE(broadcaster.EventTypeHasListeners(event_mask));
  65
  66   {
  67     ListenerSP listener_sp = Listener::MakeListener("test-listener");
  68     EXPECT_EQ(event_mask,
  69               listener_sp->StartListeningForEvents(&broadcaster, event_mask));
  70     EXPECT_TRUE(broadcaster.EventTypeHasListeners(event_mask));
  71   }
  72
  73   EXPECT_FALSE(broadcaster.EventTypeHasListeners(event_mask));
  74 }