Index

Symbols

--cores-per-node muscle3-resources command line option --data muscle3-snapshot command line option --instances muscle3-profile command line option --location-file muscle_manager command line option --log-level muscle_manager command line option --model muscle_manager command line option --no-start-all muscle_manager command line option --resources muscle3-profile command line option --run-dir muscle_manager command line option --start-all muscle_manager command line option

--timeline muscle3-profile command line option --verbose muscle3-resources command line option muscle3-snapshot command line option -c muscle3-resources command line option -d muscle3-snapshot command line option -i muscle3-profile command line option -m muscle_manager command line option -r muscle3-profile command line option -t muscle3-profile command line option -v muscle3-resources command line option muscle3-snapshot command line option

_

__init__() (libmuscle.Grid method) (libmuscle.Instance method) (libmuscle.Message method) (libmuscle.ProfileDatabase method)

A

add() (libmuscle.manager.hammer.Plate method) (libmuscle.manager.instance_registry.InstanceRegistry method) add_events() (libmuscle.manager.profile_store.ProfileStore method) add_instance_dir() (libmuscle.manager.run_dir.RunDir method) add_node() (libmuscle.planner.resources.Resources method) AFTER_REUSE_LOOP (libmuscle.api_guard.APIPhase attribute) agent_launch_command() (libmuscle.native_instantiator.global_resources.GlobalResources method) (libmuscle.native_instantiator.slurm.SlurmInfo method) AgentCommand (class in libmuscle.native_instantiator.agent.agent_commands) AgentCommandType (class in libmuscle.mcp.protocol) AgentManager (class in libmuscle.native_instantiator.agent_manager)

allocate_all() (libmuscle.planner.planner.Planner method) allow_reuse_address (libmuscle.mcp.tcp_transport_server.TcpTransportServerImpl attribute) AlreadyRegistered api_guard() (in module libmuscle.test.test_instance) APIGuard (class in libmuscle.api_guard) APIPhase (class in libmuscle.api_guard) args (libmuscle.native_instantiator.agent.agent_commands.StartCommand attribute) array (libmuscle.Grid attribute), [1] (libmuscle.grid.Grid attribute) as_python_level() (libmuscle.logging.LogLevel method) as_resources() (libmuscle.planner.planner.ResourceAssignment method) AtCheckpointTrigger (class in libmuscle.checkpoint_triggers)

B

BEFORE_FIRST_REUSE_INSTANCE (libmuscle.api_guard.APIPhase attribute) BEFORE_LOAD_SNAPSHOT (libmuscle.api_guard.APIPhase attribute) BEFORE_RESUMING (libmuscle.api_guard.APIPhase attribute) BEFORE_REUSE_INSTANCE (libmuscle.api_guard.APIPhase attribute) BEFORE_SAVE_FINAL_SNAPSHOT (libmuscle.api_guard.APIPhase attribute) BEFORE_SAVE_SNAPSHOT (libmuscle.api_guard.APIPhase attribute)

BEFORE_SHOULD_INIT (libmuscle.api_guard.APIPhase attribute) BEFORE_SHOULD_SAVE_SNAPSHOT (libmuscle.api_guard.APIPhase attribute) before_tcp_receive() (in module libmuscle.mark) before_tcp_send() (in module libmuscle.mark) by_rank (libmuscle.planner.planner.ResourceAssignment attribute) bytes_to_message() (libmuscle.snapshot.MsgPackSnapshot static method)

C

c1() (in module libmuscle.manager.test.test_hammer) c2() (in module libmuscle.manager.test.test_hammer) c3() (in module libmuscle.manager.test.test_hammer) c4() (in module libmuscle.manager.test.test_hammer) c5() (in module libmuscle.manager.test.test_hammer) calc_consistency() (in module libmuscle.manager.snapshot_registry) calc_consistency_list() (in module libmuscle.manager.snapshot_registry) call() (libmuscle.mcp.tcp_transport_client.TcpTransportClient method) (libmuscle.mcp.transport_client.TransportClient method) can_connect_to() (libmuscle.mcp.tcp_transport_client.TcpTransportClient static method) (libmuscle.mcp.transport_client.TransportClient static method) CANCEL_ALL (libmuscle.mcp.protocol.AgentCommandType attribute) cancel_all() (libmuscle.native_instantiator.agent_manager.AgentManager method) (libmuscle.native_instantiator.process_manager.ProcessManager method) CancelAllCommand (class in libmuscle.native_instantiator.agent.agent_commands) CancelAllRequest (class in libmuscle.manager.instantiator) CANCELED (libmuscle.manager.instantiator.ProcessStatus attribute) check_all_raise_except() (in module libmuscle.test.test_api_guard) check_peer_dimensions() (libmuscle.peer_info.PeerInfo method) check_receive() (libmuscle.mmsf_validator.MMSFValidator method) check_send() (libmuscle.mmsf_validator.MMSFValidator method) Checkpoint checkpoints_considered_until() (libmuscle.checkpoint_triggers.TriggerManager method) CheckpointTrigger (class in libmuscle.checkpoint_triggers) cleanup() (libmuscle.pytest.implementation_tester.ImplementationTester method) (libmuscle.pytest.ImplementationTester method), [1] (libmuscle.pytest.muscle_tester.MuscleTester method) (libmuscle.pytest.MuscleTester method), [1] close() (libmuscle.manager.logger.Logger method) (libmuscle.manager.mmp_server.MMPRequestHandler method) (libmuscle.manager.profile_database.ProfileDatabase method) (libmuscle.mcp.tcp_transport_client.TcpTransportClient method) (libmuscle.mcp.tcp_transport_server.TcpTransportServer method) (libmuscle.mcp.transport_client.TransportClient method) (libmuscle.mcp.transport_server.RequestHandler method) (libmuscle.mcp.transport_server.TransportServer method) (libmuscle.mmp_client.MMPClient method) (libmuscle.mpp_client.MPPClient method) (libmuscle.native_instantiator.agent.map_client.MAPClient method) (libmuscle.ProfileDatabase method), [1]

CLOSE_PORT (libmuscle.mpp_message.ExtTypeId attribute) ClosePort (class in libmuscle.mpp_message) cluster_command() (in module libmuscle.native_instantiator.run_script) CombinedCheckpointTriggers (class in libmuscle.checkpoint_triggers) Communicator (class in libmuscle.communicator) communicator() (in module libmuscle.test.test_communicator) (in module libmuscle.test.test_instance) component() (libmuscle.planner.planner.ModelGraph method) components() (libmuscle.planner.planner.ModelGraph method) conduits (libmuscle.manager.topology_store.TopologyStore attribute) configuration() (in module libmuscle.manager.test.test_instance_manager) ConfigurationError CONNECT (libmuscle.profiling.ProfileEventType attribute) connect_ports() (libmuscle.port_manager.PortManager method) connected_communicator() (in module libmuscle.test.test_communicator) connected_port_manager() (in module libmuscle.test.conftest) ConnectionLockedError consistent (libmuscle.manager.snapshot_registry.SnapshotNode property) consistent_peers (libmuscle.manager.snapshot_registry.SnapshotNode attribute), [1] Contains (class in libmuscle.test.test_mmsf_validator) Core (class in libmuscle.planner.resources) core() (in module libmuscle.test.conftest) cores() (libmuscle.planner.resources.Resources method) CoreSet (class in libmuscle.planner.resources) cpu_bind (libmuscle.native_instantiator.slurm.SlurmQuirks attribute) CrashedResult (class in libmuscle.manager.instantiator) create_instance_env() (in module libmuscle.manager.instantiator) CRITICAL (libmuscle.logging.LogLevel attribute)

D

daemon_threads (libmuscle.mcp.tcp_transport_server.TcpTransportServerImpl attribute) data (libmuscle.communicator.Message attribute) (libmuscle.Message attribute), [1] db_file() (in module libmuscle.manager.test.test_profile_database) Deadlock deadlock_detector() (in module libmuscle.manager.test.conftest) DeadlockDetector (class in libmuscle.manager.deadlock_detector) DEBUG (libmuscle.logging.LogLevel attribute) declared_ports() (in module libmuscle.test.conftest) decode_checkpoint_info() (in module libmuscle.mmp_client) decode_checkpoint_rule() (in module libmuscle.mmp_client) decode_operator() (in module libmuscle.manager.mmp_server) decode_port() (in module libmuscle.manager.mmp_server) deposit() (libmuscle.mpp_server.MPPServer method) (libmuscle.outbox.Outbox method) (libmuscle.post_office.PostOffice method)

deposit_command() (libmuscle.native_instantiator.map_server.MAPServer method) DEREGISTER (libmuscle.profiling.ProfileEventType attribute) DEREGISTER_INSTANCE (libmuscle.mcp.protocol.RequestType attribute) deregister_instance() (libmuscle.mmp_client.MMPClient method) detector() (in module libmuscle.manager.test.test_deadlock_detector) did_register() (libmuscle.manager.instance_registry.InstanceRegistry method) direct_prep_resources() (in module libmuscle.native_instantiator.run_script) DISABLE (libmuscle.logging.LogLevel attribute) DISCONNECT_WAIT (libmuscle.profiling.ProfileEventType attribute) do_consistency_check() (libmuscle.manager.snapshot_registry.SnapshotNode method) DONT_APPLY_OVERLAY (libmuscle.instance.InstanceFlags attribute) (libmuscle.InstanceFlags attribute), [1]

E

elapsed_walltime() (libmuscle.checkpoint_triggers.TriggerManager method) emit() (libmuscle.logging_handler.MuscleManagerHandler method) (libmuscle.manager.instantiator.QueueingLogHandler method) encode_checkpoint_rule() (in module libmuscle.manager.mmp_server) encode_checkpoints() (in module libmuscle.manager.mmp_server) encode_conduit() (in module libmuscle.manager.mmp_server) encode_operator() (in module libmuscle.mmp_client) encode_port() (in module libmuscle.mmp_client) encode_ports() (in module libmuscle.manager.mmp_server) encode_profile_event() (in module libmuscle.mmp_client) encoded() (libmuscle.mpp_message.MPPMessage method)

Endpoint (class in libmuscle.endpoint) env (libmuscle.native_instantiator.agent.agent_commands.StartCommand attribute) ERROR (libmuscle.logging.LogLevel attribute) (libmuscle.manager.instantiator.ProcessStatus attribute) (libmuscle.mcp.protocol.ResponseType attribute) error_msg (libmuscle.manager.instantiator.Process attribute) error_shutdown() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) event_type (libmuscle.profiling.ProfileEvent attribute) exit_code (libmuscle.manager.instantiator.Process attribute) extract_log_file_location() (in module libmuscle.util) ExtTypeId (class in libmuscle.mpp_message)

F

finish() (libmuscle.mcp.tcp_transport_server.TcpHandler method) flatten() (in module libmuscle.manager.hammer) formatMessage() (libmuscle.manager.logger.Formatter method) Formatter (class in libmuscle.manager.logger)

from_bytes() (libmuscle.mpp_message.MPPMessage static method) (libmuscle.snapshot.MsgPackSnapshot class method) (libmuscle.snapshot.Snapshot class method) from_python_level() (libmuscle.logging.LogLevel static method) from_snapshot() (libmuscle.snapshot.SnapshotMetadata static method)

G

generate_indices() (in module libmuscle.util) generic_visit() (libmuscle.native_instantiator.slurm.NCEVisitor method) (libmuscle.native_instantiator.slurm.NREVisitor method) GET_CHECKPOINT_INFO (libmuscle.mcp.protocol.RequestType attribute) get_checkpoint_info() (libmuscle.mmp_client.MMPClient method) GET_COMMAND (libmuscle.mcp.protocol.RequestType attribute) get_command() (libmuscle.native_instantiator.agent.map_client.MAPClient method) get_conduits() (libmuscle.manager.topology_store.TopologyStore method) get_finished() (libmuscle.native_instantiator.agent_manager.AgentManager method) (libmuscle.native_instantiator.process_manager.ProcessManager method) get_first_cores() (libmuscle.planner.resources.CoreSet method) get_length() (libmuscle.port.Port method) get_location() (libmuscle.manager.mmp_server.MMPServer method) (libmuscle.mcp.tcp_transport_server.TcpTransportServer method) (libmuscle.mcp.transport_server.TransportServer method) (libmuscle.native_instantiator.map_server.MAPServer method) get_locations() (libmuscle.communicator.Communicator method) (libmuscle.manager.instance_registry.InstanceRegistry method) (libmuscle.mpp_server.MPPServer method) get_logical_cpus_per_node() (libmuscle.native_instantiator.slurm.SlurmInfo method) get_message() (libmuscle.post_office.PostOffice method) get_message_counts() (libmuscle.port.Port method) (libmuscle.port_manager.PortManager method) GET_NEXT_MESSAGE (libmuscle.mcp.protocol.RequestType attribute) get_nodes() (libmuscle.native_instantiator.slurm.SlurmInfo method) get_num_messages() (libmuscle.port.Port method) get_peer_dimensions() (libmuscle.manager.topology_store.TopologyStore method) get_peer_dims() (libmuscle.peer_info.PeerInfo method) get_peer_endpoints() (libmuscle.peer_info.PeerInfo method)

get_peer_instances() (libmuscle.manager.topology_store.TopologyStore method) get_peer_locations() (libmuscle.peer_info.PeerInfo method) get_peer_ports() (libmuscle.peer_info.PeerInfo method) GET_PEERS (libmuscle.mcp.protocol.RequestType attribute) get_port() (libmuscle.port_manager.PortManager method) get_port_length() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) get_ports() (libmuscle.manager.instance_registry.InstanceRegistry method) (libmuscle.manager.topology_store.TopologyStore method) get_resources() (libmuscle.manager.instance_manager.InstanceManager method) (libmuscle.native_instantiator.agent_manager.AgentManager method) get_server_location() (libmuscle.manager.manager.Manager method) get_setting() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.settings_manager.SettingsManager method) GET_SETTINGS (libmuscle.mcp.protocol.RequestType attribute) get_settings() (libmuscle.mmp_client.MMPClient method) get_triggers() (libmuscle.checkpoint_triggers.TriggerManager method) global_resources() (in module libmuscle.native_instantiator.global_resources) GlobalResources (class in libmuscle.native_instantiator.global_resources) glue_partial_conduits() (in module libmuscle.manager.hammer) Grid (class in libmuscle), [1] (class in libmuscle.grid) GRID_BOOL (libmuscle.mpp_message.ExtTypeId attribute) GRID_FLOAT32 (libmuscle.mpp_message.ExtTypeId attribute) GRID_FLOAT64 (libmuscle.mpp_message.ExtTypeId attribute) GRID_INT32 (libmuscle.mpp_message.ExtTypeId attribute) GRID_INT64 (libmuscle.mpp_message.ExtTypeId attribute) guard() (in module libmuscle.test.conftest)

H

handle() (libmuscle.mcp.tcp_transport_server.TcpHandler method) handle_request() (libmuscle.manager.mmp_server.MMPRequestHandler method) (libmuscle.mcp.transport_server.RequestHandler method) (libmuscle.mpp_server.MPPRequestHandler method) (libmuscle.native_instantiator.map_server.MAPRequestHandler method) harmonise_wall_time() (libmuscle.checkpoint_triggers.TriggerManager method)

has_component() (libmuscle.manager.topology_store.TopologyStore method) has_conduit() (in module libmuscle.manager.test.test_hammer) has_setting_type() (in module libmuscle.settings_manager) have_message() (libmuscle.post_office.PostOffice method) hwthreads() (libmuscle.planner.resources.OnNodeResources method) (libmuscle.planner.resources.Resources method)

I

IAgentManager (class in libmuscle.native_instantiator.iagent_manager) impi_prep_resources() (in module libmuscle.native_instantiator.run_script) ImplementationTester (class in libmuscle.pytest), [1] (class in libmuscle.pytest.implementation_tester) in_slurm_allocation() (libmuscle.native_instantiator.slurm.SlurmInfo method) increment_num_messages() (libmuscle.port.Port method) index() (in module libmuscle.test.test_port_manager) index2() (in module libmuscle.test.test_port_manager) indexes (libmuscle.Grid attribute), [1] (libmuscle.grid.Grid attribute) INFO (libmuscle.logging.LogLevel attribute) Instance (class in libmuscle), [1] (class in libmuscle.instance) instance (libmuscle.manager.instantiator.InstantiationRequest attribute) (libmuscle.manager.instantiator.Process attribute) (libmuscle.manager.snapshot_registry.SnapshotNode attribute), [1] instance() (in module libmuscle.test.test_instance) (libmuscle.endpoint.Endpoint method) instance_argv() (in module libmuscle.test.test_instance) instance_dir (libmuscle.manager.instantiator.InstantiationRequest attribute) instance_dir() (libmuscle.manager.run_dir.RunDir method) instance_dont_apply_overlay() (in module libmuscle.test.test_instance) instance_envvar() (in module libmuscle.test.test_instance) instance_id (libmuscle.logging.LogMessage attribute) instance_indices() (in module libmuscle.util) instance_registry() (in module libmuscle.manager.test.conftest) instance_stats() (libmuscle.manager.profile_database.ProfileDatabase method) (libmuscle.ProfileDatabase method), [1] instance_to_kernel() (in module libmuscle.util) InstanceFlags (class in libmuscle), [1] (class in libmuscle.instance)

InstanceManager (class in libmuscle.manager.instance_manager) InstanceRegistry (class in libmuscle.manager.instance_registry) instances() (in module libmuscle.test.test_util) InstantiationRequest (class in libmuscle.manager.instantiator) InstantiatorRequest (class in libmuscle.manager.instantiator) InsufficientResourcesAvailable is_connected() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.peer_info.PeerInfo method) (libmuscle.port.Port method) IS_DEADLOCKED (libmuscle.mcp.protocol.RequestType attribute) is_deadlocked() (libmuscle.manager.deadlock_detector.DeadlockDetector method) (libmuscle.mmp_client.MMPClient method) is_disconnect() (in module libmuscle.mcp.tcp_util) is_empty() (libmuscle.outbox.Outbox method) is_final_snapshot (libmuscle.snapshot.SnapshotMetadata attribute) is_finished() (libmuscle.manager.instantiator.ProcessStatus method) is_open() (libmuscle.port.Port method) is_resizable() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.port.Port method) is_resuming() (libmuscle.port.Port method) is_vector() (libmuscle.port.Port method) is_vector_port() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) isdisjoint() (libmuscle.planner.resources.Core method) (libmuscle.planner.resources.CoreSet method) (libmuscle.planner.resources.OnNodeResources method) (libmuscle.planner.resources.Resources method)

J

join() (libmuscle.manager.test.test_instance_manager.MockNativeInstantiator method)

K

KEEPS_NO_STATE_FOR_NEXT_USE (libmuscle.instance.InstanceFlags attribute) (libmuscle.InstanceFlags attribute), [1]

L

last_lines() (in module libmuscle.manager.logger) level (libmuscle.logging.LogMessage attribute) libmuscle module, [1] libmuscle (module) libmuscle.api_guard module libmuscle.checkpoint_triggers module libmuscle.communicator module libmuscle.endpoint module libmuscle.errors module libmuscle.grid module libmuscle.instance module libmuscle.logging module libmuscle.logging_handler module libmuscle.manager module libmuscle.manager.deadlock_detector module libmuscle.manager.hammer module libmuscle.manager.instance_manager module libmuscle.manager.instance_registry module libmuscle.manager.instantiator module libmuscle.manager.logger module libmuscle.manager.manager module libmuscle.manager.mmp_server module libmuscle.manager.profile_database module libmuscle.manager.profile_store module libmuscle.manager.run_dir module libmuscle.manager.snapshot_registry module libmuscle.manager.test module libmuscle.manager.test.conftest module libmuscle.manager.test.test_deadlock_detector module libmuscle.manager.test.test_hammer module libmuscle.manager.test.test_instance_manager module libmuscle.manager.test.test_instance_registry module libmuscle.manager.test.test_logger module libmuscle.manager.test.test_mmp_request_handler module libmuscle.manager.test.test_profile_database module libmuscle.manager.test.test_profile_store module libmuscle.manager.test.test_snapshot_registry module libmuscle.manager.test.test_topology_store module libmuscle.manager.topology_store module libmuscle.mark module libmuscle.mcp module libmuscle.mcp.protocol module libmuscle.mcp.session_state module libmuscle.mcp.tcp_transport_client module libmuscle.mcp.tcp_transport_server module libmuscle.mcp.tcp_util module libmuscle.mcp.test module libmuscle.mcp.test.conftest module libmuscle.mcp.test.test_tcp_transport module libmuscle.mcp.test.test_tcp_transport_server module libmuscle.mcp.transport_client module libmuscle.mcp.transport_server module libmuscle.mcp.type_registry module libmuscle.mmp_client module libmuscle.mmsf_validator module libmuscle.mpp_client module libmuscle.mpp_message module libmuscle.mpp_server module libmuscle.native_instantiator module libmuscle.native_instantiator.agent module libmuscle.native_instantiator.agent.agent_commands module libmuscle.native_instantiator.agent.map_client module libmuscle.native_instantiator.agent_manager module libmuscle.native_instantiator.global_resources module libmuscle.native_instantiator.iagent_manager module libmuscle.native_instantiator.map_server module libmuscle.native_instantiator.native_instantiator module libmuscle.native_instantiator.process_manager module libmuscle.native_instantiator.run_script module libmuscle.native_instantiator.slurm module libmuscle.outbox module libmuscle.peer_info module libmuscle.planner module libmuscle.planner.planner module libmuscle.planner.resources module libmuscle.port module libmuscle.port_manager module libmuscle.post_office module libmuscle.profiler module libmuscle.profiling module libmuscle.pytest module, [1] libmuscle.pytest.implementation_tester module libmuscle.pytest.muscle_tester module libmuscle.receive_timeout_handler module libmuscle.runner module, [1] libmuscle.settings_manager module libmuscle.snapshot module libmuscle.snapshot_manager module libmuscle.test module libmuscle.test.conftest module libmuscle.test.test_api_guard module libmuscle.test.test_checkpoint_triggers module libmuscle.test.test_communicator module libmuscle.test.test_grid module libmuscle.test.test_instance module libmuscle.test.test_mmp_client module libmuscle.test.test_mmsf_validator module libmuscle.test.test_mpp_message module libmuscle.test.test_mpp_server module libmuscle.test.test_outbox module libmuscle.test.test_peer_info module libmuscle.test.test_port module libmuscle.test.test_port_manager module libmuscle.test.test_profiler module libmuscle.test.test_settings_manager module libmuscle.test.test_snapshot module libmuscle.test.test_snapshot_manager module libmuscle.test.test_test module libmuscle.test.test_util module libmuscle.timestamp module

libmuscle.util module libmuscle.version module libmuscle::Data (C++ class) libmuscle::Data::as_byte_array (C++ function) libmuscle::Data::byte_array (C++ function), [1] libmuscle::Data::Data (C++ function), [1] libmuscle::Data::DataConstRef (C++ function), [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11], [12], [13], [14], [15] libmuscle::Data::dict (C++ function), [1] libmuscle::Data::grid (C++ function) libmuscle::Data::list (C++ function), [1] libmuscle::Data::nils (C++ function) libmuscle::Data::operator= (C++ function) libmuscle::Data::operator[] (C++ function), [1] libmuscle::Data::value (C++ function) libmuscle::DataConstRef (C++ class) libmuscle::DataConstRef::as (C++ function) libmuscle::DataConstRef::as_byte_array (C++ function) libmuscle::DataConstRef::DataConstRef (C++ function), [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11], [12], [13], [14], [15] libmuscle::DataConstRef::describe (C++ function) libmuscle::DataConstRef::dict (C++ function), [1] libmuscle::DataConstRef::elements (C++ function) libmuscle::DataConstRef::grid (C++ function) libmuscle::DataConstRef::has_indexes (C++ function) libmuscle::DataConstRef::indexes (C++ function) libmuscle::DataConstRef::is_a (C++ function) libmuscle::DataConstRef::is_a_byte_array (C++ function) libmuscle::DataConstRef::is_a_dict (C++ function) libmuscle::DataConstRef::is_a_grid_of (C++ function) libmuscle::DataConstRef::is_a_list (C++ function) libmuscle::DataConstRef::is_nil (C++ function) libmuscle::DataConstRef::key (C++ function) libmuscle::DataConstRef::list (C++ function), [1] libmuscle::DataConstRef::nils (C++ function) libmuscle::DataConstRef::operator= (C++ function), [1] libmuscle::DataConstRef::operator[] (C++ function), [1] libmuscle::DataConstRef::reseat (C++ function) libmuscle::DataConstRef::shape (C++ function) libmuscle::DataConstRef::size (C++ function) libmuscle::DataConstRef::storage_order (C++ function) libmuscle::DataConstRef::value (C++ function) libmuscle::Instance (C++ class) libmuscle::Instance::error_shutdown (C++ function) libmuscle::Instance::get_port_length (C++ function) libmuscle::Instance::get_setting (C++ function), [1] libmuscle::Instance::get_setting_as (C++ function), [1] libmuscle::Instance::Instance (C++ function), [1], [2], [3] libmuscle::Instance::is_connected (C++ function) libmuscle::Instance::is_resizable (C++ function) libmuscle::Instance::is_vector_port (C++ function) libmuscle::Instance::list_ports (C++ function) libmuscle::Instance::list_settings (C++ function) libmuscle::Instance::load_snapshot (C++ function) libmuscle::Instance::receive (C++ function), [1], [2], [3] libmuscle::Instance::receive_with_settings (C++ function), [1], [2], [3] libmuscle::Instance::resuming (C++ function) libmuscle::Instance::reuse_instance (C++ function) libmuscle::Instance::save_final_snapshot (C++ function) libmuscle::Instance::save_snapshot (C++ function) libmuscle::Instance::send (C++ function), [1] libmuscle::Instance::set_port_length (C++ function) libmuscle::Instance::should_init (C++ function) libmuscle::Instance::should_save_final_snapshot (C++ function) libmuscle::Instance::should_save_snapshot (C++ function) libmuscle::InstanceFlags (C++ enum) libmuscle::InstanceFlags::DONT_APPLY_OVERLAY (C++ enumerator) libmuscle::InstanceFlags::KEEPS_NO_STATE_FOR_NEXT_USE (C++ enumerator) libmuscle::InstanceFlags::NONE (C++ enumerator) libmuscle::InstanceFlags::SKIP_MMSF_SEQUENCE_CHECKS (C++ enumerator) libmuscle::InstanceFlags::STATE_NOT_REQUIRED_FOR_NEXT_USE (C++ enumerator) libmuscle::InstanceFlags::USES_CHECKPOINT_API (C++ enumerator) libmuscle::Message (C++ class) libmuscle::Message::data (C++ function) libmuscle::Message::has_next_timestamp (C++ function) libmuscle::Message::has_settings (C++ function) libmuscle::Message::Message (C++ function), [1], [2], [3], [4], [5], [6] libmuscle::Message::next_timestamp (C++ function) libmuscle::Message::operator= (C++ function), [1] libmuscle::Message::set_data (C++ function) libmuscle::Message::set_next_timestamp (C++ function) libmuscle::Message::set_settings (C++ function) libmuscle::Message::set_timestamp (C++ function) libmuscle::Message::settings (C++ function) libmuscle::Message::timestamp (C++ function) libmuscle::Message::unset_next_timestamp (C++ function) libmuscle::Message::unset_settings (C++ function) libmuscle::PortsDescription (C++ type) LIBMUSCLE_Data (fortran type) LIBMUSCLE_Data_as_byte_array() (fortran subroutine) LIBMUSCLE_Data_as_character() (fortran function) LIBMUSCLE_Data_as_int() (fortran function) LIBMUSCLE_Data_as_int1() (fortran function) LIBMUSCLE_Data_as_int2() (fortran function) LIBMUSCLE_Data_as_int4() (fortran function) LIBMUSCLE_Data_as_int8() (fortran function) LIBMUSCLE_Data_as_logical() (fortran function) LIBMUSCLE_Data_as_real4() (fortran function) LIBMUSCLE_Data_as_real8() (fortran function) LIBMUSCLE_Data_as_settings() (fortran function) LIBMUSCLE_Data_create() (fortran function), [1], [2], [3], [4], [5] LIBMUSCLE_Data_create_byte_array() (fortran function), [1] LIBMUSCLE_Data_create_dict() (fortran function) LIBMUSCLE_Data_create_grid() (fortran function), [1] LIBMUSCLE_Data_create_list() (fortran function) LIBMUSCLE_Data_create_nils() (fortran function) LIBMUSCLE_Data_free() (fortran subroutine) LIBMUSCLE_Data_get_item() (fortran function), [1] LIBMUSCLE_Data_has_indexes() (fortran function) LIBMUSCLE_Data_index() (fortran function) LIBMUSCLE_Data_is_a_byte_array() (fortran function) LIBMUSCLE_Data_is_a_character() (fortran function) LIBMUSCLE_Data_is_a_dict() (fortran function) LIBMUSCLE_Data_is_a_grid_of_int4() (fortran function) LIBMUSCLE_Data_is_a_grid_of_int8() (fortran function) LIBMUSCLE_Data_is_a_grid_of_logical() (fortran function) LIBMUSCLE_Data_is_a_grid_of_real4() (fortran function) LIBMUSCLE_Data_is_a_grid_of_real8() (fortran function) LIBMUSCLE_Data_is_a_int() (fortran function) LIBMUSCLE_Data_is_a_int1() (fortran function) LIBMUSCLE_Data_is_a_int2() (fortran function) LIBMUSCLE_Data_is_a_int4() (fortran function) LIBMUSCLE_Data_is_a_list() (fortran function) LIBMUSCLE_Data_is_a_logical() (fortran function) LIBMUSCLE_Data_is_a_real4() (fortran function) LIBMUSCLE_Data_is_a_real8() (fortran function) LIBMUSCLE_Data_is_a_settings() (fortran function) LIBMUSCLE_Data_is_nil() (fortran function) LIBMUSCLE_Data_key() (fortran function) LIBMUSCLE_Data_num_dims() (fortran function) LIBMUSCLE_Data_set() (fortran subroutine), [1] LIBMUSCLE_Data_set_item() (fortran subroutine), [1] LIBMUSCLE_Data_shape() (fortran subroutine) LIBMUSCLE_Data_size() (fortran function) LIBMUSCLE_Data_value() (fortran function) LIBMUSCLE_DataConstRef (fortran type) LIBMUSCLE_Instance (fortran type) LIBMUSCLE_Instance_create() (fortran function) LIBMUSCLE_Instance_error_shutdown() (fortran subroutine) LIBMUSCLE_Instance_free() (fortran subroutine) LIBMUSCLE_Instance_get_port_length() (fortran function) LIBMUSCLE_Instance_get_setting_as_character() (fortran function) LIBMUSCLE_Instance_get_setting_as_int8() (fortran function) LIBMUSCLE_Instance_get_setting_as_logical() (fortran function) LIBMUSCLE_Instance_get_setting_as_real8() (fortran function) LIBMUSCLE_Instance_get_setting_as_real8array() (fortran subroutine) LIBMUSCLE_Instance_get_setting_as_real8array2() (fortran subroutine) LIBMUSCLE_Instance_is_connected() (fortran function) LIBMUSCLE_Instance_is_resizable() (fortran function) LIBMUSCLE_Instance_is_setting_a_character() (fortran function) LIBMUSCLE_Instance_is_setting_a_int8() (fortran function) LIBMUSCLE_Instance_is_setting_a_logical() (fortran function) LIBMUSCLE_Instance_is_setting_a_real8() (fortran function) LIBMUSCLE_Instance_is_setting_a_real8array() (fortran function) LIBMUSCLE_Instance_is_setting_a_real8array2() (fortran function) LIBMUSCLE_Instance_is_vector_port() (fortran function) LIBMUSCLE_Instance_list_ports() (fortran function) LIBMUSCLE_Instance_load_snapshot() (fortran function) LIBMUSCLE_Instance_receive() (fortran function), [1] LIBMUSCLE_Instance_receive_on_slot() (fortran function), [1] LIBMUSCLE_Instance_receive_with_settings() (fortran function), [1] LIBMUSCLE_Instance_receive_with_settings_on_slot() (fortran function), [1] LIBMUSCLE_Instance_resuming() (fortran function) LIBMUSCLE_Instance_reuse_instance() (fortran function) LIBMUSCLE_Instance_save_final_snapshot() (fortran function) LIBMUSCLE_Instance_save_snapshot() (fortran function) LIBMUSCLE_Instance_send() (fortran subroutine), [1] LIBMUSCLE_Instance_set_port_length() (fortran subroutine) LIBMUSCLE_Instance_should_init() (fortran function) LIBMUSCLE_Instance_should_save_final_snapshot() (fortran function) LIBMUSCLE_Instance_should_save_snapshot() (fortran function) LIBMUSCLE_InstanceFlags (fortran type) LIBMUSCLE_Message (fortran type) LIBMUSCLE_Message_create() (fortran function), [1], [2], [3], [4] LIBMUSCLE_Message_get_data() (fortran function) LIBMUSCLE_Message_get_settings() (fortran function) LIBMUSCLE_Message_has_next_timestamp() (fortran function) LIBMUSCLE_Message_has_settings() (fortran function) LIBMUSCLE_Message_next_timestamp() (fortran function) LIBMUSCLE_Message_set_data() (fortran subroutine), [1] LIBMUSCLE_Message_set_next_timestamp() (fortran subroutine) LIBMUSCLE_Message_set_settings() (fortran subroutine) LIBMUSCLE_Message_set_timestamp() (fortran subroutine) LIBMUSCLE_Message_timestamp() (fortran function) LIBMUSCLE_Message_unset_next_timestamp() (fortran subroutine) LIBMUSCLE_Message_unset_settings() (fortran subroutine) LIBMUSCLE_PortsDescription (fortran type) LIBMUSCLE_PortsDescription_add() (fortran subroutine) LIBMUSCLE_PortsDescription_create() (fortran function) LIBMUSCLE_PortsDescription_free() (fortran subroutine) LIBMUSCLE_PortsDescription_get() (fortran function) LIBMUSCLE_PortsDescription_num_ports() (fortran function) list_incoming_ports() (libmuscle.peer_info.PeerInfo method) list_outgoing_ports() (libmuscle.peer_info.PeerInfo method) list_ports() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.port_manager.PortManager method) list_settings() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.settings_manager.SettingsManager method) list_ymmsl_ports() (libmuscle.peer_info.PeerInfo method) load_snapshot() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.snapshot_manager.SnapshotManager method) load_snapshot_done() (libmuscle.api_guard.APIGuard method) load_snapshot_from_file() (libmuscle.snapshot_manager.SnapshotManager static method) loaded_instance_registry() (in module libmuscle.manager.test.conftest) loaded_instance_registry2() (in module libmuscle.manager.test.conftest) LOCAL (libmuscle.logging.LogLevel attribute) local_command() (in module libmuscle.native_instantiator.run_script) log_message() (libmuscle.manager.logger.Logger method) Logger (class in libmuscle.manager.logger) logger() (in module libmuscle.manager.test.conftest) (in module libmuscle.test.test_instance) LogHandlingThread (class in libmuscle.manager.instance_manager) logical_cpus_per_node (libmuscle.native_instantiator.global_resources.GlobalResources attribute) LogLevel (class in libmuscle.logging) LogMessage (class in libmuscle.logging)

M

macro_micro() (in module libmuscle.manager.test.test_snapshot_registry) macros() (libmuscle.planner.planner.ModelGraph method) make_script() (in module libmuscle.native_instantiator.run_script) make_server_process() (in module libmuscle.pytest.muscle_tester) make_snapshot() (in module libmuscle.manager.test.test_snapshot_registry) Manager (class in libmuscle.manager.manager) manager_location_argv() (in module libmuscle.test.test_instance) manager_location_envvar() (in module libmuscle.test.test_instance) MAPClient (class in libmuscle.native_instantiator.agent.map_client) MAPRequestHandler (class in libmuscle.native_instantiator.map_server) MAPServer (class in libmuscle.native_instantiator.map_server) merge_node() (libmuscle.planner.resources.Resources method) Message (class in libmuscle), [1] (class in libmuscle.communicator) message() (in module libmuscle.test.conftest) (in module libmuscle.test.test_outbox) message2() (in module libmuscle.test.conftest) message_number (libmuscle.profiling.ProfileEvent attribute) message_size (libmuscle.profiling.ProfileEvent attribute) message_timestamp (libmuscle.profiling.ProfileEvent attribute) message_to_bytes() (libmuscle.snapshot.MsgPackSnapshot static method) micro_is_stateless() (in module libmuscle.manager.test.test_snapshot_registry) micros() (libmuscle.planner.planner.ModelGraph method) mmp_client() (in module libmuscle.test.test_instance) mmp_configuration() (in module libmuscle.manager.test.conftest) mmp_configuration2() (in module libmuscle.manager.test.conftest) mmp_request_handler() (in module libmuscle.manager.test.conftest) MMPClient (class in libmuscle.mmp_client) MMPClient() (in module libmuscle.test.test_instance) MMPRequestHandler (class in libmuscle.manager.mmp_server) MMPServer (class in libmuscle.manager.mmp_server) MMSFValidator (class in libmuscle.mmsf_validator) mock_peer_info() (in module libmuscle.test.test_mmsf_validator) mock_ports() (in module libmuscle.test.conftest) mocked_mmp_client() (in module libmuscle.test.conftest) mocked_profiler() (in module libmuscle.test.conftest) MockNativeInstantiator (class in libmuscle.manager.test.test_instance_manager) MockTransportServer() (in module libmuscle.test.test_mpp_server) ModelGraph (class in libmuscle.planner.planner) module libmuscle, [1] libmuscle.api_guard libmuscle.checkpoint_triggers libmuscle.communicator libmuscle.endpoint libmuscle.errors libmuscle.grid libmuscle.instance libmuscle.logging libmuscle.logging_handler libmuscle.manager libmuscle.manager.deadlock_detector libmuscle.manager.hammer libmuscle.manager.instance_manager libmuscle.manager.instance_registry libmuscle.manager.instantiator libmuscle.manager.logger libmuscle.manager.manager libmuscle.manager.mmp_server libmuscle.manager.profile_database libmuscle.manager.profile_store libmuscle.manager.run_dir libmuscle.manager.snapshot_registry libmuscle.manager.test libmuscle.manager.test.conftest libmuscle.manager.test.test_deadlock_detector libmuscle.manager.test.test_hammer libmuscle.manager.test.test_instance_manager libmuscle.manager.test.test_instance_registry libmuscle.manager.test.test_logger libmuscle.manager.test.test_mmp_request_handler libmuscle.manager.test.test_profile_database libmuscle.manager.test.test_profile_store libmuscle.manager.test.test_snapshot_registry libmuscle.manager.test.test_topology_store libmuscle.manager.topology_store libmuscle.mark libmuscle.mcp libmuscle.mcp.protocol libmuscle.mcp.session_state libmuscle.mcp.tcp_transport_client libmuscle.mcp.tcp_transport_server libmuscle.mcp.tcp_util libmuscle.mcp.test libmuscle.mcp.test.conftest libmuscle.mcp.test.test_tcp_transport libmuscle.mcp.test.test_tcp_transport_server libmuscle.mcp.transport_client libmuscle.mcp.transport_server libmuscle.mcp.type_registry libmuscle.mmp_client libmuscle.mmsf_validator libmuscle.mpp_client libmuscle.mpp_message libmuscle.mpp_server libmuscle.native_instantiator libmuscle.native_instantiator.agent libmuscle.native_instantiator.agent.agent_commands libmuscle.native_instantiator.agent.map_client libmuscle.native_instantiator.agent_manager libmuscle.native_instantiator.global_resources libmuscle.native_instantiator.iagent_manager libmuscle.native_instantiator.map_server libmuscle.native_instantiator.native_instantiator libmuscle.native_instantiator.process_manager libmuscle.native_instantiator.run_script libmuscle.native_instantiator.slurm libmuscle.outbox libmuscle.peer_info libmuscle.planner libmuscle.planner.planner libmuscle.planner.resources libmuscle.port libmuscle.port_manager libmuscle.post_office libmuscle.profiler libmuscle.profiling libmuscle.pytest, [1] libmuscle.pytest.implementation_tester libmuscle.pytest.muscle_tester libmuscle.receive_timeout_handler libmuscle.runner, [1] libmuscle.settings_manager libmuscle.snapshot libmuscle.snapshot_manager libmuscle.test libmuscle.test.conftest libmuscle.test.test_api_guard libmuscle.test.test_checkpoint_triggers libmuscle.test.test_communicator libmuscle.test.test_grid libmuscle.test.test_instance libmuscle.test.test_mmp_client libmuscle.test.test_mmsf_validator libmuscle.test.test_mpp_message libmuscle.test.test_mpp_server libmuscle.test.test_outbox libmuscle.test.test_peer_info libmuscle.test.test_port libmuscle.test.test_port_manager libmuscle.test.test_profiler libmuscle.test.test_settings_manager libmuscle.test.test_snapshot libmuscle.test.test_snapshot_manager libmuscle.test.test_test libmuscle.test.test_util libmuscle.timestamp libmuscle.util libmuscle.version

mpich_prep_resources() (in module libmuscle.native_instantiator.run_script) mpp_client() (in module libmuscle.test.test_communicator) mpp_server() (in module libmuscle.test.test_communicator) (in module libmuscle.test.test_mpp_server) MPPClient (class in libmuscle.mpp_client) MPPClient() (in module libmuscle.test.test_communicator) MPPMessage (class in libmuscle.mpp_message) MPPRequestHandler (class in libmuscle.mpp_server) MPPServer (class in libmuscle.mpp_server) MPPServer() (in module libmuscle.test.test_communicator) MsgPackSnapshot (class in libmuscle.snapshot) muscle3-profile command line option --instances --resources --timeline -i -r -t PERFORMANCE_FILE muscle3-resources command line option --cores-per-node --verbose -c -v YMMSL_FILES muscle3-snapshot command line option --data --verbose -d -v SNAPSHOT_FILES muscle_manager command line option --location-file --log-level --model --no-start-all --run-dir --start-all -m YMMSL_FILES MuscleManagerHandler (class in libmuscle.logging_handler) MuscleTester (class in libmuscle.pytest), [1] (class in libmuscle.pytest.muscle_tester)

N

name (libmuscle.native_instantiator.agent.agent_commands.StartCommand attribute) (libmuscle.port.Port attribute) nanoseconds (libmuscle.profiling.ProfileTimestamp attribute) NativeInstantiator (class in libmuscle.native_instantiator.native_instantiator) NCEVisitor (class in libmuscle.native_instantiator.slurm) next_checkpoint() (libmuscle.checkpoint_triggers.AtCheckpointTrigger method) (libmuscle.checkpoint_triggers.CheckpointTrigger method) (libmuscle.checkpoint_triggers.CombinedCheckpointTriggers method) (libmuscle.checkpoint_triggers.RangeCheckpointTrigger method) next_timestamp (libmuscle.communicator.Message attribute) (libmuscle.Message attribute), [1] (libmuscle.snapshot.SnapshotMetadata attribute)

no_resume_snapshot_manager() (in module libmuscle.test.test_instance) Node (in module libmuscle.manager.hammer) nodes (libmuscle.native_instantiator.global_resources.GlobalResources attribute) (libmuscle.planner.resources.Resources attribute) nodes() (libmuscle.planner.resources.Resources method) NONE (libmuscle.native_instantiator.global_resources.Scheduler attribute) NoPendingResponse NREVisitor (class in libmuscle.native_instantiator.slurm) num (libmuscle.manager.snapshot_registry.SnapshotNode attribute), [1] num_mpi_tasks() (in module libmuscle.native_instantiator.run_script)

O

on_cluster() (libmuscle.native_instantiator.global_resources.GlobalResources method) on_node_resources() (in module libmuscle.test.conftest) on_receive() (libmuscle.mcp.transport_client.TimeoutHandler method) (libmuscle.receive_timeout_handler.ReceiveTimeoutHandler method) on_timeout() (libmuscle.mcp.transport_client.TimeoutHandler method) (libmuscle.receive_timeout_handler.ReceiveTimeoutHandler method)

OnNodeResources (class in libmuscle.planner.resources) openmpi_prep_resources() (in module libmuscle.native_instantiator.run_script) operator (libmuscle.port.Port attribute) os_environ() (in module libmuscle.test.test_instance) Outbox (class in libmuscle.outbox) outbox() (in module libmuscle.test.test_outbox) overlap (libmuscle.native_instantiator.slurm.SlurmQuirks attribute)

P

parse_slurm_nodelist() (in module libmuscle.native_instantiator.slurm) parse_slurm_nodes_cores() (in module libmuscle.native_instantiator.slurm) Peer instances peer_info() (in module libmuscle.test.test_peer_info) peer_info2() (in module libmuscle.test.test_peer_info) peer_info3() (in module libmuscle.test.test_peer_info) PeerInfo (class in libmuscle.peer_info) peers (libmuscle.manager.snapshot_registry.SnapshotNode attribute), [1] PENDING (libmuscle.mcp.protocol.ResponseType attribute) PERFORMANCE_FILE muscle3-profile command line option Planner (class in libmuscle.planner.planner) Plate (class in libmuscle.manager.hammer) plate() (in module libmuscle.manager.test.test_hammer) pop_by_receiver() (libmuscle.manager.hammer.Plate method) pop_by_sender() (libmuscle.manager.hammer.Plate method) Port (class in libmuscle.port) port (libmuscle.profiling.ProfileEvent attribute) port() (in module libmuscle.manager.test.test_instance_registry) port_exists() (libmuscle.port_manager.PortManager method) port_length (libmuscle.profiling.ProfileEvent attribute) port_manager() (in module libmuscle.test.test_communicator) (in module libmuscle.test.test_instance) (in module libmuscle.test.test_port_manager) port_manager2() (in module libmuscle.test.test_port_manager) port_message_counts (libmuscle.snapshot.SnapshotMetadata attribute) PortManager (class in libmuscle.port_manager)

post_office() (in module libmuscle.mcp.test.conftest) PostOffice (class in libmuscle.post_office) PostOffice() (in module libmuscle.test.test_mpp_server) predecessors() (libmuscle.planner.planner.ModelGraph method) prep_resources() (in module libmuscle.native_instantiator.run_script) prepare_resume() (libmuscle.snapshot_manager.SnapshotManager method) previous_checkpoint() (libmuscle.checkpoint_triggers.AtCheckpointTrigger method) (libmuscle.checkpoint_triggers.CheckpointTrigger method) (libmuscle.checkpoint_triggers.CombinedCheckpointTriggers method) (libmuscle.checkpoint_triggers.RangeCheckpointTrigger method) Process (class in libmuscle.manager.instantiator) process_components() (in module libmuscle.manager.hammer) process_conduits() (in module libmuscle.manager.hammer) ProcessManager (class in libmuscle.native_instantiator.process_manager) ProcessStatus (class in libmuscle.manager.instantiator) profile_data() (in module libmuscle.test.conftest) profile_store() (in module libmuscle.manager.test.conftest) ProfileDatabase (class in libmuscle), [1] (class in libmuscle.manager.profile_database) ProfileEvent (class in libmuscle.profiling) ProfileEventType (class in libmuscle.profiling) Profiler (class in libmuscle.profiler) profiler() (in module libmuscle.test.test_communicator) (in module libmuscle.test.test_instance) profiler_comm_int_10ms() (in module libmuscle.test.conftest) ProfileStore (class in libmuscle.manager.profile_store) ProfileTimestamp (class in libmuscle.profiling) program (libmuscle.manager.instantiator.InstantiationRequest attribute)

Q

QueueingLogHandler (class in libmuscle.manager.instantiator)

R

raise_error() (in module libmuscle.pytest.muscle_tester) RangeCheckpointTrigger (class in libmuscle.checkpoint_triggers) RECEIVE (libmuscle.profiling.ProfileEventType attribute) receive() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.mpp_client.MPPClient method) (libmuscle.pytest.implementation_tester.ImplementationTester method) (libmuscle.pytest.ImplementationTester method), [1] RECEIVE_DECODE (libmuscle.profiling.ProfileEventType attribute) receive_message() (libmuscle.communicator.Communicator method) RECEIVE_TRANSFER (libmuscle.profiling.ProfileEventType attribute) RECEIVE_WAIT (libmuscle.profiling.ProfileEventType attribute) receive_with_settings() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) receiver() (in module libmuscle.mcp.test.conftest) ReceiveTimeoutHandler (class in libmuscle.receive_timeout_handler) reconfigure_logging() (in module libmuscle.manager.instantiator) record_event() (libmuscle.profiler.Profiler method) recv_all() (in module libmuscle.mcp.tcp_util) recv_frame() (in module libmuscle.mcp.tcp_util) recv_int64() (in module libmuscle.mcp.tcp_util) ref() (libmuscle.endpoint.Endpoint method) REGISTER (libmuscle.profiling.ProfileEventType attribute) REGISTER_INSTANCE (libmuscle.mcp.protocol.RequestType attribute) register_instance() (libmuscle.mmp_client.MMPClient method) register_snapshot() (libmuscle.manager.snapshot_registry.SnapshotRegistry method) registered_mmp_request_handler() (in module libmuscle.manager.test.conftest) registered_mmp_request_handler2() (in module libmuscle.manager.test.conftest) registry() (in module libmuscle.manager.test.test_instance_registry) remove() (libmuscle.manager.instance_registry.InstanceRegistry method) REPORT_RESOURCES (libmuscle.mcp.protocol.RequestType attribute) report_resources() (libmuscle.native_instantiator.agent.map_client.MAPClient method) (libmuscle.native_instantiator.agent_manager.AgentManager method) (libmuscle.native_instantiator.iagent_manager.IAgentManager method) REPORT_RESULT (libmuscle.mcp.protocol.RequestType attribute)

report_result() (libmuscle.native_instantiator.agent.map_client.MAPClient method) (libmuscle.native_instantiator.agent_manager.AgentManager method) (libmuscle.native_instantiator.iagent_manager.IAgentManager method) request_peers() (libmuscle.mmp_client.MMPClient method) RequestHandler (class in libmuscle.mcp.transport_server) RequestType (class in libmuscle.mcp.protocol) res_req (libmuscle.manager.instantiator.InstantiationRequest attribute) resource_stats() (libmuscle.manager.profile_database.ProfileDatabase method) (libmuscle.ProfileDatabase method), [1] ResourceAssignment (class in libmuscle.planner.planner) Resources (class in libmuscle.planner.resources) resources (libmuscle.manager.instantiator.InstantiationRequest attribute) (libmuscle.manager.instantiator.Process attribute) resources() (in module libmuscle.test.conftest) ResponseType (class in libmuscle.mcp.protocol) restore_message_counts() (libmuscle.port.Port method) (libmuscle.port_manager.PortManager method) resuming() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) resuming_done() (libmuscle.api_guard.APIGuard method) resuming_from_final() (libmuscle.snapshot_manager.SnapshotManager method) resuming_from_intermediate() (libmuscle.snapshot_manager.SnapshotManager method) Retrier (class in libmuscle.util) retrieve() (libmuscle.outbox.Outbox method) reuse_instance() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.mmsf_validator.MMSFValidator method) reuse_instance_done() (libmuscle.api_guard.APIGuard method) run() (libmuscle.manager.instance_manager.LogHandlingThread method) (libmuscle.manager.snapshot_registry.SnapshotRegistry method) (libmuscle.native_instantiator.native_instantiator.NativeInstantiator method) run_simulation() (in module libmuscle.runner), [1] run_until_before() (in module libmuscle.test.test_api_guard) RunDir (class in libmuscle.manager.run_dir) RUNNING (libmuscle.manager.instantiator.ProcessStatus attribute)

S

safe_get() (in module libmuscle.manager.snapshot_registry) save_final_snapshot() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) save_final_snapshot_done() (libmuscle.api_guard.APIGuard method) save_snapshot() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.snapshot_manager.SnapshotManager method) save_snapshot_done() (libmuscle.api_guard.APIGuard method) Scheduler (class in libmuscle.native_instantiator.global_resources) scheduler (libmuscle.native_instantiator.global_resources.GlobalResources attribute) SEND (libmuscle.profiling.ProfileEventType attribute) send() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) (libmuscle.pytest.implementation_tester.ImplementationTester method) (libmuscle.pytest.ImplementationTester method), [1] send_frame() (in module libmuscle.mcp.tcp_util) send_int64() (in module libmuscle.mcp.tcp_util) send_message() (libmuscle.communicator.Communicator method) ServerNotSupported SessionState (class in libmuscle.mcp.session_state) set_checkpoint_info() (libmuscle.checkpoint_triggers.TriggerManager method) set_closed() (libmuscle.port.Port method) set_length() (libmuscle.port.Port method) set_level() (libmuscle.profiler.Profiler method) set_manager_location() (libmuscle.manager.instance_manager.InstanceManager method) set_peer_info() (libmuscle.communicator.Communicator method) set_port_length() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) set_receive_timeout() (libmuscle.communicator.Communicator method) set_response() (libmuscle.mcp.session_state.SessionState method) set_resumed() (libmuscle.port.Port method) settings (libmuscle.communicator.Message attribute) (libmuscle.Message attribute), [1] SETTINGS (libmuscle.mpp_message.ExtTypeId attribute) settings_in_connected() (libmuscle.port_manager.PortManager method) settings_manager() (in module libmuscle.test.test_instance) (in module libmuscle.test.test_settings_manager) SettingsManager (class in libmuscle.settings_manager) should_give_up() (libmuscle.util.Retrier method) should_init() (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) should_init_done() (libmuscle.api_guard.APIGuard method) should_save_final_snapshot() (libmuscle.checkpoint_triggers.TriggerManager method) (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) should_save_final_snapshot_done() (libmuscle.api_guard.APIGuard method) should_save_snapshot() (libmuscle.checkpoint_triggers.TriggerManager method) (libmuscle.Instance method), [1] (libmuscle.instance.Instance method) should_save_snapshot_done() (libmuscle.api_guard.APIGuard method) SHUTDOWN (libmuscle.mcp.protocol.AgentCommandType attribute) (libmuscle.profiling.ProfileEventType attribute) shutdown() (libmuscle.communicator.Communicator method) (libmuscle.manager.instance_manager.InstanceManager method) (libmuscle.manager.instance_manager.LogHandlingThread method) (libmuscle.manager.profile_store.ProfileStore method) (libmuscle.manager.snapshot_registry.SnapshotRegistry method) (libmuscle.mpp_server.MPPServer method) (libmuscle.native_instantiator.agent_manager.AgentManager method) (libmuscle.profiler.Profiler method) SHUTDOWN_WAIT (libmuscle.profiling.ProfileEventType attribute) ShutdownCommand (class in libmuscle.native_instantiator.agent.agent_commands) ShutdownRequest (class in libmuscle.manager.instantiator) skip_f_init() (libmuscle.mmsf_validator.MMSFValidator method)

SKIP_MMSF_SEQUENCE_CHECKS (libmuscle.instance.InstanceFlags attribute) (libmuscle.InstanceFlags attribute), [1] sleep() (libmuscle.util.Retrier method) slot (libmuscle.profiling.ProfileEvent attribute) SLURM (libmuscle.native_instantiator.global_resources.Scheduler attribute) slurm() (in module libmuscle.native_instantiator.slurm) SlurmInfo (class in libmuscle.native_instantiator.slurm) SlurmQuirks (class in libmuscle.native_instantiator.slurm) Snapshot (class in libmuscle.snapshot) snapshot (libmuscle.manager.snapshot_registry.SnapshotNode attribute), [1] snapshot() (in module libmuscle.test.test_snapshot) snapshot_dir() (libmuscle.manager.run_dir.RunDir method) snapshot_filename (libmuscle.snapshot.SnapshotMetadata attribute) SNAPSHOT_FILES muscle3-snapshot command line option snapshot_manager() (in module libmuscle.test.test_instance) snapshot_registry() (in module libmuscle.manager.test.conftest) snapshot_registry2() (in module libmuscle.manager.test.conftest) SNAPSHOT_VERSION_BYTE (libmuscle.snapshot.MsgPackSnapshot attribute) (libmuscle.snapshot.Snapshot attribute) SnapshotManager (class in libmuscle.snapshot_manager) SnapshotMetadata (class in libmuscle.snapshot) SnapshotNode (class in libmuscle.manager.snapshot_registry) SnapshotRegistry (class in libmuscle.manager.snapshot_registry) SocketClosed srun_prep_resources() (in module libmuscle.native_instantiator.run_script) START (libmuscle.mcp.protocol.AgentCommandType attribute) start() (libmuscle.manager.test.test_instance_manager.MockNativeInstantiator method) (libmuscle.native_instantiator.agent_manager.AgentManager method) (libmuscle.native_instantiator.process_manager.ProcessManager method) (libmuscle.profiling.ProfileEvent method) start_all() (libmuscle.manager.instance_manager.InstanceManager method) start_implementation() (libmuscle.pytest.muscle_tester.MuscleTester method) (libmuscle.pytest.MuscleTester method), [1] start_instances() (libmuscle.manager.manager.Manager method) start_mmp_server() (in module libmuscle.pytest.muscle_tester) start_time (libmuscle.profiling.ProfileEvent attribute) StartCommand (class in libmuscle.native_instantiator.agent.agent_commands) STARTED (libmuscle.manager.instantiator.ProcessStatus attribute) STATE_NOT_REQUIRED_FOR_NEXT_USE (libmuscle.instance.InstanceFlags attribute) (libmuscle.InstanceFlags attribute), [1] status (libmuscle.manager.instantiator.Process attribute) stderr (libmuscle.native_instantiator.agent.agent_commands.StartCommand attribute) stderr_path (libmuscle.manager.instantiator.InstantiationRequest attribute) stdout (libmuscle.native_instantiator.agent.agent_commands.StartCommand attribute) stdout_path (libmuscle.manager.instantiator.InstantiationRequest attribute) stop() (libmuscle.manager.manager.Manager method) (libmuscle.manager.mmp_server.MMPServer method) (libmuscle.native_instantiator.map_server.MAPServer method) (libmuscle.profiling.ProfileEvent method) stop_time (libmuscle.profiling.ProfileEvent attribute) store_instances() (libmuscle.manager.profile_store.ProfileStore method) store_resources() (libmuscle.manager.profile_store.ProfileStore method) SUBMIT_LOG_MESSAGE (libmuscle.mcp.protocol.RequestType attribute) submit_log_message() (libmuscle.mmp_client.MMPClient method) SUBMIT_PROFILE_EVENTS (libmuscle.mcp.protocol.RequestType attribute) submit_profile_events() (libmuscle.mmp_client.MMPClient method) SUBMIT_SNAPSHOT (libmuscle.mcp.protocol.RequestType attribute) submit_snapshot_metadata() (libmuscle.mmp_client.MMPClient method) SUCCESS (libmuscle.manager.instantiator.ProcessStatus attribute) (libmuscle.mcp.protocol.ResponseType attribute) successors() (libmuscle.planner.planner.ModelGraph method) sys_argv() (in module libmuscle.test.test_instance)

T

tcp_transport_server() (in module libmuscle.mcp.test.conftest) TcpHandler (class in libmuscle.mcp.tcp_transport_server) TcpTransportClient (class in libmuscle.mcp.tcp_transport_client) TcpTransportServer (class in libmuscle.mcp.tcp_transport_server) TcpTransportServerImpl (class in libmuscle.mcp.tcp_transport_server) test_add_events() (in module libmuscle.manager.test.test_profile_store) test_at_checkpoint_trigger() (in module libmuscle.test.test_checkpoint_triggers) test_auto_stop_time() (in module libmuscle.test.test_profiler) test_calc_consistency() (in module libmuscle.manager.test.test_snapshot_registry) test_calc_consistency_list() (in module libmuscle.manager.test.test_snapshot_registry) test_calc_consistency_with_restart() (in module libmuscle.manager.test.test_snapshot_registry) test_checkpoint_support() (in module libmuscle.test.test_instance) test_combined_checkpoint_trigger_at_ranges() (in module libmuscle.test.test_checkpoint_triggers) test_combined_checkpoint_trigger_every_at() (in module libmuscle.test.test_checkpoint_triggers) test_connect_inferred_ports() (in module libmuscle.test.test_port_manager) test_connect_inferred_ports_oi_s() (in module libmuscle.test.test_port_manager) test_connect_multidimensional_ports() (in module libmuscle.test.test_port_manager) test_connect_ports() (in module libmuscle.test.test_port_manager) test_connect_vector_ports() (in module libmuscle.test.test_port_manager) test_connection_fail() (in module libmuscle.test.test_mmp_client) test_connections() (in module libmuscle.manager.test.test_snapshot_registry) test_create() (in module libmuscle.mcp.test.test_tcp_transport_server) (in module libmuscle.test.test_mpp_message) (in module libmuscle.test.test_settings_manager) test_create_communicator() (in module libmuscle.test.test_communicator) test_create_instance_connecting() (in module libmuscle.test.test_instance) test_create_instance_manager_location_argv() (in module libmuscle.test.test_instance) test_create_instance_manager_location_default() (in module libmuscle.test.test_instance) test_create_instance_manager_location_envvar() (in module libmuscle.test.test_instance) test_create_instance_profiling() (in module libmuscle.test.test_instance) test_create_instance_registration() (in module libmuscle.test.test_instance) test_create_instance_set_up_checkpointing() (in module libmuscle.test.test_instance) test_create_instance_set_up_logging() (in module libmuscle.test.test_instance) test_create_invalid_port() (in module libmuscle.test.test_port) test_create_logger() (in module libmuscle.manager.test.test_logger) test_create_outbox() (in module libmuscle.test.test_outbox) test_create_peer_info() (in module libmuscle.test.test_peer_info) test_create_port() (in module libmuscle.test.test_port) test_create_profile_store() (in module libmuscle.manager.test.test_profile_store) test_create_servicer() (in module libmuscle.manager.test.test_mmp_request_handler) test_create_topology_store() (in module libmuscle.manager.test.test_topology_store) test_deadlock() (in module libmuscle.manager.test.test_deadlock_detector) test_deadlock_cancelled() (in module libmuscle.manager.test.test_deadlock_detector) test_deposit_message() (in module libmuscle.test.test_outbox) test_deposit_retrieve_order() (in module libmuscle.test.test_outbox) test_deregister_instance() (in module libmuscle.manager.test.test_mmp_request_handler) (in module libmuscle.test.test_mmp_client) test_deregister_instance_error() (in module libmuscle.test.test_mmp_client) test_double_deadlock() (in module libmuscle.manager.test.test_deadlock_detector) test_double_register_instance() (in module libmuscle.manager.test.test_mmp_request_handler) test_double_should_save() (in module libmuscle.test.test_api_guard) test_double_waiting_log_error() (in module libmuscle.manager.test.test_deadlock_detector) test_final_snapshot_only() (in module libmuscle.test.test_api_guard) test_flatten_conduit_filters() (in module libmuscle.manager.test.test_hammer) test_flatten_deep() (in module libmuscle.manager.test.test_hammer) test_flatten_multicast() (in module libmuscle.manager.test.test_hammer) test_flatten_nested_ensemble() (in module libmuscle.manager.test.test_hammer) test_flatten_passthrough_overload() (in module libmuscle.manager.test.test_hammer) test_flatten_simple() (in module libmuscle.manager.test.test_hammer) test_full_checkpointing() (in module libmuscle.test.test_api_guard) test_get_checkpoint_info() (in module libmuscle.manager.test.test_mmp_request_handler) test_get_checkpoint_info2() (in module libmuscle.manager.test.test_mmp_request_handler) test_get_conduits() (in module libmuscle.manager.test.test_topology_store) test_get_locations() (in module libmuscle.test.test_mpp_server) test_get_peer_dimensions() (in module libmuscle.manager.test.test_topology_store) test_get_peer_dims() (in module libmuscle.test.test_peer_info) test_get_peer_endpoint() (in module libmuscle.test.test_peer_info) test_get_peer_locations() (in module libmuscle.test.test_peer_info) test_get_peer_port() (in module libmuscle.test.test_peer_info) test_get_peers_pending() (in module libmuscle.manager.test.test_mmp_request_handler) test_get_port_length() (in module libmuscle.test.test_instance) test_get_setting() (in module libmuscle.test.test_instance) (in module libmuscle.test.test_settings_manager) test_get_setting_with_default() (in module libmuscle.test.test_instance) test_get_setting_with_default_and_type() (in module libmuscle.test.test_instance) test_get_setting_without_default_raises_keyerror() (in module libmuscle.test.test_settings_manager) test_get_settings() (in module libmuscle.manager.test.test_mmp_request_handler) (in module libmuscle.test.test_mmp_client) test_get_ymmsl_ports() (in module libmuscle.test.test_peer_info) test_grid() (in module libmuscle.test.test_grid) test_grid_decode() (in module libmuscle.test.test_mpp_message) test_grid_encode() (in module libmuscle.test.test_mpp_message) test_grid_roundtrip() (in module libmuscle.test.test_mpp_message) test_heuristic_rollbacks() (in module libmuscle.manager.test.test_snapshot_registry) test_implementation() (in module libmuscle.manager.test.test_snapshot_registry) test_implicit_snapshot() (in module libmuscle.test.test_snapshot) test_init() (in module libmuscle.test.test_mmp_client) test_instance_indices() (in module libmuscle.test.test_util) test_instance_stats() (in module libmuscle.manager.test.test_profile_database) test_instance_to_kernel() (in module libmuscle.test.test_util) test_is_connected() (in module libmuscle.test.test_instance) (in module libmuscle.test.test_peer_info) test_is_resizable() (in module libmuscle.test.test_instance) test_is_vector_port() (in module libmuscle.test.test_instance) test_list_ports() (in module libmuscle.test.test_instance) test_list_settings() (in module libmuscle.test.test_instance) test_list_settings_globals() (in module libmuscle.test.test_settings_manager) test_list_settings_overlay() (in module libmuscle.test.test_settings_manager) test_list_settings_overlay_override() (in module libmuscle.test.test_settings_manager) test_list_settings_override() (in module libmuscle.test.test_settings_manager) test_list_settings_specifics() (in module libmuscle.test.test_settings_manager) test_location() (in module libmuscle.mcp.test.test_tcp_transport_server) test_log_level() (in module libmuscle.manager.test.test_logger) test_log_message() (in module libmuscle.manager.test.test_logger) (in module libmuscle.manager.test.test_mmp_request_handler) test_macro_micro_snapshots() (in module libmuscle.manager.test.test_snapshot_registry) test_manual_instances_not_counted_in_num_running() (in module libmuscle.manager.test.test_instance_manager) test_message_with_settings() (in module libmuscle.test.test_snapshot) test_micro() (in module libmuscle.test.test_mmsf_validator) test_missing_resuming() (in module libmuscle.test.test_api_guard) test_missing_should_save_final() (in module libmuscle.test.test_api_guard) test_missing_step() (in module libmuscle.test.test_api_guard) test_nested_custom_implementations() (in module libmuscle.manager.test.test_hammer) test_no_checkpointing() (in module libmuscle.test.test_checkpoint_triggers) (in module libmuscle.test.test_snapshot_manager) test_no_checkpointing_support() (in module libmuscle.test.test_api_guard)

test_no_deadlock() (in module libmuscle.manager.test.test_deadlock_detector) test_non_contiguous_grid_roundtrip() (in module libmuscle.test.test_mpp_message) test_not_all_ports_used() (in module libmuscle.test.test_mmsf_validator) test_not_waiting_log_error() (in module libmuscle.manager.test.test_deadlock_detector) test_only_f_i() (in module libmuscle.test.test_mmsf_validator) test_only_o_f() (in module libmuscle.test.test_mmsf_validator) test_peers() (in module libmuscle.manager.test.test_snapshot_registry) test_plate() (in module libmuscle.manager.test.test_hammer) test_plate2() (in module libmuscle.manager.test.test_hammer) test_port() (in module libmuscle.manager.test.test_instance_registry) test_port_count_validation() (in module libmuscle.test.test_communicator) test_port_discard_error_on_resume() (in module libmuscle.test.test_communicator) test_port_discard_success_on_resume() (in module libmuscle.test.test_communicator) test_port_message_counts() (in module libmuscle.test.test_port_manager) test_port_properties() (in module libmuscle.test.test_port) test_range_checkpoint_trigger() (in module libmuscle.test.test_checkpoint_triggers) test_range_checkpoint_trigger_default_start() (in module libmuscle.test.test_checkpoint_triggers) test_range_checkpoint_trigger_default_stop() (in module libmuscle.test.test_checkpoint_triggers) test_receive_close_port() (in module libmuscle.test.test_communicator) test_receive_close_port_vector() (in module libmuscle.test.test_communicator) test_receive_default() (in module libmuscle.test.test_instance) test_receive_default_f_init() (in module libmuscle.test.test_instance) test_receive_f_init() (in module libmuscle.test.test_instance) test_receive_inconsistent_settings() (in module libmuscle.test.test_instance) test_receive_message() (in module libmuscle.test.test_communicator) test_receive_message_vector() (in module libmuscle.test.test_communicator) test_receive_no_default() (in module libmuscle.test.test_instance) test_receive_on_invalid_port() (in module libmuscle.test.test_instance) test_receive_on_sending_port() (in module libmuscle.test.test_instance) test_receive_with_settings() (in module libmuscle.test.test_instance) test_receive_with_settings_default() (in module libmuscle.test.test_instance) test_recording_events() (in module libmuscle.test.test_profiler) test_register_instance() (in module libmuscle.manager.test.test_mmp_request_handler) (in module libmuscle.test.test_mmp_client) test_register_instance_no_version() (in module libmuscle.manager.test.test_mmp_request_handler) test_register_instance_version_mismatch() (in module libmuscle.manager.test.test_mmp_request_handler) test_registry_add() (in module libmuscle.manager.test.test_instance_registry) test_registry_get() (in module libmuscle.manager.test.test_instance_registry) test_registry_remove() (in module libmuscle.manager.test.test_instance_registry) test_remove_no_implementation() (in module libmuscle.manager.test.test_hammer) test_request() (in module libmuscle.mcp.test.test_tcp_transport_server) test_request_peers() (in module libmuscle.test.test_mmp_client) test_request_peers_bidir() (in module libmuscle.manager.test.test_mmp_request_handler) test_request_peers_error() (in module libmuscle.test.test_mmp_client) test_request_peers_fanin() (in module libmuscle.manager.test.test_mmp_request_handler) test_request_peers_fanout() (in module libmuscle.manager.test.test_mmp_request_handler) test_request_peers_own_conduits() (in module libmuscle.manager.test.test_mmp_request_handler) test_request_peers_timeout() (in module libmuscle.test.test_mmp_client) test_request_peers_unknown() (in module libmuscle.manager.test.test_mmp_request_handler) test_resource_stats() (in module libmuscle.manager.test.test_profile_database) test_retrieve_message() (in module libmuscle.test.test_outbox) test_reuse_closed_port() (in module libmuscle.test.test_instance) test_reuse_f_init_vector_port() (in module libmuscle.test.test_instance) test_reuse_no_f_init_ports() (in module libmuscle.test.test_instance) test_reuse_set_overlay() (in module libmuscle.test.test_instance) test_safe_get() (in module libmuscle.manager.test.test_snapshot_registry) test_save_load_implicit_snapshot() (in module libmuscle.test.test_snapshot_manager) test_save_load_snapshot() (in module libmuscle.test.test_snapshot_manager) test_send_after_resize() (in module libmuscle.test.test_instance) test_send_message() (in module libmuscle.test.test_communicator) (in module libmuscle.test.test_instance) test_send_message_disconnected() (in module libmuscle.test.test_communicator) test_send_on_invalid_port() (in module libmuscle.test.test_instance) test_send_on_receiving_port() (in module libmuscle.test.test_instance) test_send_to_manager() (in module libmuscle.test.test_profiler) test_set_port_length() (in module libmuscle.test.test_instance) test_shutdown() (in module libmuscle.test.test_communicator) test_shutdown_instance() (in module libmuscle.test.test_instance) test_simple_correct() (in module libmuscle.test.test_mmsf_validator) test_simple_skip_f_init() (in module libmuscle.test.test_mmsf_validator) test_simple_skip_o_f() (in module libmuscle.test.test_mmsf_validator) test_simple_skip_o_i() (in module libmuscle.test.test_mmsf_validator) test_simple_skip_reuse_instance() (in module libmuscle.test.test_mmsf_validator) test_simple_skip_s() (in module libmuscle.test.test_mmsf_validator) test_snapshot() (in module libmuscle.test.test_snapshot) test_snapshot_config() (in module libmuscle.manager.test.test_snapshot_registry) test_snapshot_metadata() (in module libmuscle.test.test_snapshot) test_start_all_skips_manual_instances() (in module libmuscle.manager.test.test_instance_manager) test_submit_log_message() (in module libmuscle.test.test_mmp_client) test_submit_snapshot() (in module libmuscle.manager.test.test_mmp_request_handler) test_tcp_transport() (in module libmuscle.mcp.test.test_tcp_transport) test_test() (in module libmuscle.test.test_test) test_time_taken() (in module libmuscle.manager.test.test_profile_database) test_trigger_manager() (in module libmuscle.test.test_checkpoint_triggers) test_trigger_manager_reference_time() (in module libmuscle.test.test_checkpoint_triggers) test_uq() (in module libmuscle.manager.test.test_snapshot_registry) test_vector_port_message_counts() (in module libmuscle.test.test_port_manager) test_waiting_for_different_instance_log_error() (in module libmuscle.manager.test.test_deadlock_detector) test_waiting_for_different_port_log_error() (in module libmuscle.manager.test.test_deadlock_detector) test_write_ymmsl() (in module libmuscle.manager.test.test_snapshot_registry) text (libmuscle.logging.LogMessage attribute) time_taken() (libmuscle.manager.profile_database.ProfileDatabase method) (libmuscle.ProfileDatabase method), [1] timeout (libmuscle.mcp.transport_client.TimeoutHandler property) (libmuscle.receive_timeout_handler.ReceiveTimeoutHandler property) TimeoutHandler (class in libmuscle.mcp.transport_client) Timestamp (class in libmuscle.timestamp) timestamp (libmuscle.communicator.Message attribute) (libmuscle.logging.LogMessage attribute) (libmuscle.Message attribute), [1] (libmuscle.snapshot.SnapshotMetadata attribute) to_asctime() (libmuscle.timestamp.Timestamp method) to_bytes() (libmuscle.snapshot.MsgPackSnapshot method) (libmuscle.snapshot.Snapshot method) topology_store() (in module libmuscle.manager.test.conftest) topology_store2() (in module libmuscle.manager.test.conftest) TopologyStore (class in libmuscle.manager.topology_store) total_cores() (libmuscle.planner.resources.OnNodeResources method) (libmuscle.planner.resources.Resources method) transport_server() (in module libmuscle.test.test_mpp_server) transport_server_types() (in module libmuscle.test.test_mpp_server) TransportClient (class in libmuscle.mcp.transport_client) TransportServer (class in libmuscle.mcp.transport_server) triage_request() (libmuscle.mcp.session_state.SessionState method) trigger_manager() (in module libmuscle.test.test_instance) TriggerManager (class in libmuscle.checkpoint_triggers) triggers (libmuscle.snapshot.SnapshotMetadata attribute)

U

union() (libmuscle.planner.resources.Resources static method) update_checkpoints() (libmuscle.checkpoint_triggers.TriggerManager method) uq() (in module libmuscle.manager.test.test_snapshot_registry)

USES_CHECKPOINT_API (libmuscle.instance.InstanceFlags attribute) (libmuscle.InstanceFlags attribute), [1] usesTime() (libmuscle.manager.logger.Formatter method)

V

validator_simple() (in module libmuscle.test.test_mmsf_validator) verify_load_snapshot() (libmuscle.api_guard.APIGuard method) verify_resuming() (libmuscle.api_guard.APIGuard method) verify_reuse_instance() (libmuscle.api_guard.APIGuard method) verify_save_final_snapshot() (libmuscle.api_guard.APIGuard method) verify_save_snapshot() (libmuscle.api_guard.APIGuard method) verify_should_init() (libmuscle.api_guard.APIGuard method) verify_should_save_final_snapshot() (libmuscle.api_guard.APIGuard method) verify_should_save_snapshot() (libmuscle.api_guard.APIGuard method) visit_identifier() (libmuscle.native_instantiator.slurm.NREVisitor method) visit_index_range() (libmuscle.native_instantiator.slurm.NREVisitor method)

visit_index_set() (libmuscle.native_instantiator.slurm.NREVisitor method) visit_int() (libmuscle.native_instantiator.slurm.NCEVisitor method) (libmuscle.native_instantiator.slurm.NREVisitor method) visit_integer() (libmuscle.native_instantiator.slurm.NREVisitor method) visit_nce() (libmuscle.native_instantiator.slurm.NCEVisitor method) visit_nce_run() (libmuscle.native_instantiator.slurm.NCEVisitor method) visit_nre() (libmuscle.native_instantiator.slurm.NREVisitor method) visit_nre_part() (libmuscle.native_instantiator.slurm.NREVisitor method) visit_nre_parts() (libmuscle.native_instantiator.slurm.NREVisitor method) visit_padded_int() (libmuscle.native_instantiator.slurm.NREVisitor method) visit_run_length() (libmuscle.native_instantiator.slurm.NCEVisitor method)

W

wait() (libmuscle.manager.instance_manager.InstanceManager method) (libmuscle.manager.instance_registry.InstanceRegistry method) (libmuscle.manager.manager.Manager method) wait_for_receivers() (libmuscle.mpp_server.MPPServer method) (libmuscle.post_office.PostOffice method) wait_get_response() (libmuscle.mcp.session_state.SessionState method) WAITING_FOR_RECEIVE (libmuscle.mcp.protocol.RequestType attribute) waiting_for_receive() (libmuscle.manager.deadlock_detector.DeadlockDetector method) (libmuscle.mmp_client.MMPClient method)

WAITING_FOR_RECEIVE_DONE (libmuscle.mcp.protocol.RequestType attribute) waiting_for_receive_done() (libmuscle.manager.deadlock_detector.DeadlockDetector method) (libmuscle.mmp_client.MMPClient method) wallclock_time (libmuscle.snapshot.SnapshotMetadata attribute) WARNING (libmuscle.logging.LogLevel attribute) work_dir (libmuscle.manager.instantiator.InstantiationRequest attribute) (libmuscle.native_instantiator.agent.agent_commands.StartCommand attribute) Workflow snapshot

Y

ymmsl (module) ymmsl::allows_receiving (C++ function) ymmsl::allows_sending (C++ function) ymmsl::Conduit (C++ class) ymmsl::Conduit::Conduit (C++ function) ymmsl::Conduit::operator std::string (C++ function) ymmsl::Conduit::operator== (C++ function) ymmsl::Conduit::receiving_component (C++ function) ymmsl::Conduit::receiving_port (C++ function) ymmsl::Conduit::receiving_slot (C++ function) ymmsl::Conduit::sending_component (C++ function) ymmsl::Conduit::sending_port (C++ function) ymmsl::Conduit::sending_slot (C++ function) ymmsl::Identifier (C++ class) ymmsl::Identifier::Identifier (C++ function), [1] ymmsl::Identifier::operator std::string (C++ function) ymmsl::Identifier::operator!= (C++ function), [1], [2] ymmsl::Identifier::operator== (C++ function), [1], [2] ymmsl::Operator (C++ enum) ymmsl::Operator::F_INIT (C++ enumerator) ymmsl::Operator::NONE (C++ enumerator) ymmsl::Operator::O_F (C++ enumerator) ymmsl::Operator::O_I (C++ enumerator) ymmsl::Operator::S (C++ enumerator) ymmsl::operator<< (C++ function), [1], [2], [3] ymmsl::Port (C++ struct) ymmsl::Port::oper (C++ member) ymmsl::Port::Port (C++ function) ymmsl::Reference (C++ class) ymmsl::Reference::begin (C++ function) ymmsl::Reference::cbegin (C++ function) ymmsl::Reference::cend (C++ function) ymmsl::Reference::const_iterator (C++ type) ymmsl::Reference::end (C++ function) ymmsl::Reference::length (C++ function) ymmsl::Reference::operator std::string (C++ function) ymmsl::Reference::operator!= (C++ function), [1], [2] ymmsl::Reference::operator+ (C++ function), [1], [2] ymmsl::Reference::operator+= (C++ function), [1] ymmsl::Reference::operator== (C++ function), [1], [2] ymmsl::Reference::operator[] (C++ function) ymmsl::Reference::Reference (C++ function), [1], [2] ymmsl::ReferencePart (C++ class) ymmsl::ReferencePart::identifier (C++ function) ymmsl::ReferencePart::index (C++ function) ymmsl::ReferencePart::is_identifier (C++ function) ymmsl::ReferencePart::is_index (C++ function) ymmsl::ReferencePart::operator!= (C++ function) ymmsl::ReferencePart::operator== (C++ function) ymmsl::ReferencePart::ReferencePart (C++ function), [1]

ymmsl::Settings (C++ class) ymmsl::Settings::at (C++ function) ymmsl::Settings::begin (C++ function) ymmsl::Settings::clear (C++ function) ymmsl::Settings::contains (C++ function) ymmsl::Settings::empty (C++ function) ymmsl::Settings::end (C++ function) ymmsl::Settings::erase (C++ function) ymmsl::Settings::operator!= (C++ function) ymmsl::Settings::operator== (C++ function) ymmsl::Settings::operator[] (C++ function) ymmsl::Settings::Settings (C++ function), [1] ymmsl::Settings::size (C++ function) ymmsl::SettingValue (C++ class) ymmsl::SettingValue::as (C++ function) ymmsl::SettingValue::is_a (C++ function) ymmsl::SettingValue::operator!= (C++ function) ymmsl::SettingValue::operator= (C++ function), [1] ymmsl::SettingValue::operator== (C++ function) ymmsl::SettingValue::SettingValue (C++ function), [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11], [12], [13], [14], [15], [16], [17] ymmsl::SettingValue::~SettingValue (C++ function) YMMSL_FILES muscle3-resources command line option muscle_manager command line option YMMSL_Settings (fortran type) YMMSL_Settings_clear() (fortran subroutine) YMMSL_Settings_contains() (fortran function) YMMSL_Settings_create() (fortran function) YMMSL_Settings_empty() (fortran function) YMMSL_Settings_equals() (fortran function) YMMSL_Settings_erase() (fortran function) YMMSL_Settings_free() (fortran subroutine) YMMSL_Settings_get_as_character() (fortran function) YMMSL_Settings_get_as_int4() (fortran function) YMMSL_Settings_get_as_int8() (fortran function) YMMSL_Settings_get_as_int8array() (fortran subroutine) YMMSL_Settings_get_as_logical() (fortran function) YMMSL_Settings_get_as_real8() (fortran function) YMMSL_Settings_get_as_real8array() (fortran subroutine) YMMSL_Settings_get_as_real8array2() (fortran subroutine) YMMSL_Settings_is_a_character() (fortran function) YMMSL_Settings_is_a_int4() (fortran function) YMMSL_Settings_is_a_int8() (fortran function) YMMSL_Settings_is_a_int8array() (fortran function) YMMSL_Settings_is_a_logical() (fortran function) YMMSL_Settings_is_a_real8() (fortran function) YMMSL_Settings_is_a_real8array() (fortran function) YMMSL_Settings_is_a_real8array2() (fortran function) YMMSL_Settings_key() (fortran function) YMMSL_Settings_set() (fortran subroutine) YMMSL_Settings_size() (fortran function)