libmuscle.test.test_communicator module

libmuscle.test.test_communicator.MPPClient()

libmuscle.test.test_communicator.MPPServer()

libmuscle.test.test_communicator.communicator(connected_port_manager, profiler)

libmuscle.test.test_communicator.connected_communicator(communicator)

libmuscle.test.test_communicator.mpp_client(MPPClient)

libmuscle.test.test_communicator.mpp_server(MPPServer)

libmuscle.test.test_communicator.port_manager()

libmuscle.test.test_communicator.profiler()

libmuscle.test.test_communicator.test_create_communicator(communicator, mpp_server)

libmuscle.test.test_communicator.test_port_count_validation(connected_communicator, mpp_client, connected_port_manager)

libmuscle.test.test_communicator.test_port_discard_error_on_resume(caplog, connected_communicator, mpp_client, connected_port_manager)

libmuscle.test.test_communicator.test_port_discard_success_on_resume(caplog, connected_communicator, mpp_client, connected_port_manager)

libmuscle.test.test_communicator.test_receive_close_port(connected_communicator, mpp_client, port_manager)

libmuscle.test.test_communicator.test_receive_close_port_vector(connected_communicator, mpp_client, port_manager)

libmuscle.test.test_communicator.test_receive_message(connected_communicator, mpp_client)

libmuscle.test.test_communicator.test_receive_message_vector(connected_communicator, mpp_client)

libmuscle.test.test_communicator.test_send_message(connected_communicator, mpp_server)

libmuscle.test.test_communicator.test_send_message_disconnected(connected_communicator, mpp_server)

libmuscle.test.test_communicator.test_shutdown(connected_communicator, mpp_client, connected_port_manager, mpp_server)