#NEWLINE# def _forward_event( self , msg ) : #NEWLINE# #INDENT# '\n        Forward an event message to all subscribed yards\n        Event message has a route\n        Also rebroadcast to all masters in cluster\n        ' #NEWLINE# super ( SaltRaetEventerMaster , self ) . _forward_event ( msg ) #NEWLINE# if self . opts . value . get ( 'cluster_mode' ) : #NEWLINE# #INDENT# if ( msg . get ( 'origin' ) is None ) : #NEWLINE# #INDENT# masters = ( self . availables . value & set ( ( remote . name for remote in list ( self . road_stack . value . remotes . values ( ) ) if ( remote . kind == kinds . applKinds . master ) ) ) ) #NEWLINE# for name in masters : #NEWLINE# #INDENT# remote = self . road_stack . value . nameRemotes [ name ] #NEWLINE# msg [ 'origin' ] = self . road_stack . value . name #NEWLINE# ( s_estate , s_yard , s_share ) = msg [ 'route' ] [ 'src' ] #NEWLINE# msg [ 'route' ] [ 'src' ] = ( self . road_stack . value . name , s_yard , s_share ) #NEWLINE# msg [ 'route' ] [ 'dst' ] = ( remote . name , None , 'event_fire' ) #NEWLINE# self . road_stack . value . message ( msg , remote . uid )