Track notified handlers by object rather than simply their name

Due to the fact that roles may be instantiated with different sets of
params (multiple inclusions of the same role or via role dependencies),
simply tracking notified handlers by name does not work. This patch
changes the way we track handler notifications by using the handler
object itself instead of just the name, allowing for multiple internal
instances. Normally this would be bad, but we also modify the way we
search for handlers by first looking at the notifying tasks dependency
chain (ensuring that roles find their own handlers first) and then at
the main list of handlers, using the first match it finds.

This patch also modifies the way we setup the internal list of handlers,
which should allow us to correctly identify if a notified handler exists
more easily.

Fixes #15084

test/units/plugins/strategies/test_strategy_base.py

@@ -171,7 +171,10 @@ class TestStrategyBase(unittest.TestCase):
         mock_tqm._stats = MagicMock()
         mock_tqm._stats.increment.return_value = None
         
+        mock_play = MagicMock()
+
         mock_iterator = MagicMock()
+        mock_iterator._play = mock_play
         mock_iterator.mark_host_failed.return_value = None
         mock_iterator.get_next_task_for_host.return_value = (None, None)
 
@@ -184,6 +187,17 @@ class TestStrategyBase(unittest.TestCase):
         mock_task._role = None
         mock_task.ignore_errors = False
 
+        mock_handler_task = MagicMock(Handler)
+        mock_handler_task.action = 'foo'
+        mock_handler_task.get_name.return_value = "test handler"
+        mock_handler_task.has_triggered.return_value = False
+
+        mock_handler_block = MagicMock()
+        mock_handler_block.block = [mock_handler_task]
+        mock_play.handlers = [mock_handler_block]
+
+        mock_tqm._notified_handlers = {mock_handler_task: []}
+
         mock_group = MagicMock()
         mock_group.add_host.return_value = None
 
@@ -281,8 +295,8 @@ class TestStrategyBase(unittest.TestCase):
         self.assertEqual(len(results), 0)
         self.assertEqual(strategy_base._pending_results, 1)
         self.assertIn('test01', strategy_base._blocked_hosts)
-        self.assertIn('test handler', strategy_base._notified_handlers)
-        self.assertIn(mock_host, strategy_base._notified_handlers['test handler'])
+        self.assertIn(mock_handler_task, strategy_base._notified_handlers)
+        self.assertIn(mock_host, strategy_base._notified_handlers[mock_handler_task])
 
         queue_items.append(('set_host_var', mock_host, mock_task, None, 'foo', 'bar'))
         results = strategy_base._process_pending_results(iterator=mock_iterator)
@@ -379,13 +393,14 @@ class TestStrategyBase(unittest.TestCase):
             passwords=None,
         )
         tqm._initialize_processes(3)
+        tqm._initialize_notified_handlers(mock_play)
         tqm.hostvars = dict()
 
         try:
             strategy_base = StrategyBase(tqm=tqm)
 
             strategy_base._inventory = mock_inventory
-            strategy_base._notified_handlers = {"test handler": [mock_host]}
+            strategy_base._notified_handlers = {mock_handler_task: [mock_host]}
 
             task_result = TaskResult(Host('host01'), Handler(), dict(changed=False))
             tqm._final_q.put(('host_task_ok', task_result))