HistogramStopTestCase Class Reference

Inheritance diagram for HistogramStopTestCase:

Public Member Functions
def	testStopPropagation (self)

Static Public Attributes
HLTZMQTestCase	input_port = HLTZMQTestCase.get_free_port()
	input_port
HLTZMQTestCase	monitoring_port = HLTZMQTestCase.get_free_port()
	monitoring_port
dict	needed_programs
	needed_programs
open	histogram_data = open(basf2.find_file("daq/hbasf2/tests/histos.raw"), "br").read()
	histogram_data
b	event_data
	event_data

Detailed Description

Test case

Definition at line 215 of file test_histogram.py.

Member Function Documentation

testStopPropagation()

def testStopPropagation

(

self

)

test function

Definition at line 247 of file test_histogram.py.

    def testStopPropagation(self):
        """test function"""
        monitoring_socket = self.create_socket(self.monitoring_port)
 
        input_socket = self.create_socket(self.input_port)
        self.send(input_socket, "h")
        self.assertIsMsgType(input_socket, "c")
 
        second_input_socket = self.create_socket(self.input_port, identity="other_socket")
        self.send(second_input_socket, "h")
        self.assertIsMsgType(second_input_socket, "c")
 
        # At the beginning, everything should be at normal state
        self.assertMonitoring(monitoring_socket, "input.registered_workers", 2)
        self.assertNotHasOutputFile("outputFile.root", timeout=1)
 
        # So far no stop messages should be there
        self.assertMonitoring(monitoring_socket, "input.received_stop_messages", 0)
        self.assertMonitoring(monitoring_socket, "input.all_stop_messages", False)
 
        # the first stop message should not trigger a transmission
        self.send(input_socket, "l")
        self.assertIsMsgType(input_socket, "c")
        self.assertMonitoring(monitoring_socket, "input.received_stop_messages", 1)
        self.assertMonitoring(monitoring_socket, "input.all_stop_messages", False)
        self.assertNotHasOutputFile("outputFile.root", timeout=1)
 
        # The second stop message should also not, as there are no histograms so far
        self.send(second_input_socket, "l")
        self.assertIsMsgType(second_input_socket, "c")
        self.assertMonitoring(monitoring_socket, "input.received_stop_messages", 2)
        self.assertMonitoring(monitoring_socket, "input.all_stop_messages", True)
        self.assertNotHasOutputFile("outputFile.root", timeout=1)
 
        # Reset everything
        self.send(monitoring_socket, "n")
        self.assertMonitoring(monitoring_socket, "input.received_stop_messages", 0)
        self.assertMonitoring(monitoring_socket, "input.all_stop_messages", False)
 
        # Now lets send some events
        self.send(input_socket, "v", self.histogram_data, self.event_data)
        self.assertIsMsgType(input_socket, "c")
 
        self.send(input_socket, "v", self.histogram_data, self.event_data)
        self.assertIsMsgType(input_socket, "c")
 
        self.send(second_input_socket, "v", self.histogram_data, self.event_data)
        self.assertIsMsgType(second_input_socket, "c")
 
        self.send(input_socket, "v", self.histogram_data, self.event_data)
        self.assertIsMsgType(input_socket, "c")
 
        self.send(second_input_socket, "v", self.histogram_data, self.event_data)
        self.assertIsMsgType(second_input_socket, "c")
 
        self.send(second_input_socket, "v", self.histogram_data, self.event_data)
        self.assertIsMsgType(second_input_socket, "c")
 
        # This should not be enough to trigger a merge
        self.assertMonitoring(monitoring_socket, "input.received_events", 6)
        self.assertNotHasOutputFile("outputFile.root", timeout=1)
 
        # But if we again send the stop messages
        self.send(input_socket, "l")
        self.assertIsMsgType(input_socket, "c")
        self.send(second_input_socket, "l")
        self.assertIsMsgType(second_input_socket, "c")
 
        # .. it should have merged it. We expect 2 entries, as we have 2 clients (no matter how often they sent)
        self.assertMonitoring(monitoring_socket, "input.received_stop_messages", 2)
        self.assertMonitoring(monitoring_socket, "input.all_stop_messages", True)
        self.assertHasOutputFile("outputFile.root", unlink=False)
        self.assertTrue(check_histogram_output("outputFile.root", 2))
 
        # Now send a terminate message
        self.send(input_socket, "x")
        self.assertIsMsgType(input_socket, "c")
        self.send(second_input_socket, "x")
        self.assertIsMsgType(second_input_socket, "c")
 
        # There should be no merge happening, as the files are already written
        self.assertNotHasOutputFile("outputFile.root")
 
        self.assertIsDown("histoserver")
 
 

Member Data Documentation

event_data

b event_data

static

Initial value:

=  b"""{
        "_typename" : "Belle2::EventMetaData",
        "fUniqueID" : 0,
        "fBits" : 33554432,
        "m_event" : 1,
        "m_run" : 1,
        "m_subrun" : 0,
        "m_experiment" : 1,
        "m_production" : 0,
        "m_time" : 0,
        "m_parentLfn" : "",
        "m_generatedWeight" : 1,
        "m_errorFlag" : 0
        }"""

event_data

Definition at line 232 of file test_histogram.py.

histogram_data

open histogram_data = open(basf2.find_file("daq/hbasf2/tests/histos.raw"), "br").read()

static

histogram_data

Definition at line 230 of file test_histogram.py.

input_port

HLTZMQTestCase input_port = HLTZMQTestCase.get_free_port()

static

input_port

Definition at line 218 of file test_histogram.py.

monitoring_port

HLTZMQTestCase monitoring_port = HLTZMQTestCase.get_free_port()

static

monitoring_port

Definition at line 220 of file test_histogram.py.

needed_programs

dict needed_programs

static

Initial value:

=  {"histoserver": ["b2hlt_finalhistoserver", "--input", f"tcp://*:{input_port}",
                                       "--rootFileName", "outputFile.root",
                                       "--timeout", "0",  # we remove the timeout on purpose
                                       "--monitor", f"tcp://*:{monitoring_port}"],
                       }

needed_programs

Definition at line 223 of file test_histogram.py.

---

The documentation for this class was generated from the following file:

• daq/hbasf2/tests/test_histogram.py