libmuscle.native_instantiator package

Subpackages

• libmuscle.native_instantiator.agent package
  • Submodules
    • libmuscle.native_instantiator.agent.agent_commands module
      • AgentCommand
      • CancelAllCommand
      • ShutdownCommand
      • StartCommand
    • libmuscle.native_instantiator.agent.map_client module
      • MAPClient

Submodules

• libmuscle.native_instantiator.agent_manager module
  • AgentManager
    • AgentManager.cancel_all()
    • AgentManager.get_finished()
    • AgentManager.get_resources()
    • AgentManager.report_resources()
    • AgentManager.report_result()
    • AgentManager.shutdown()
    • AgentManager.start()
• libmuscle.native_instantiator.global_resources module
  • GlobalResources
    • GlobalResources.scheduler
    • GlobalResources.nodes
    • GlobalResources.logical_cpus_per_node
    • GlobalResources.agent_launch_command()
    • GlobalResources.on_cluster()
  • Scheduler
    • Scheduler.NONE
    • Scheduler.SLURM
  • global_resources()
• libmuscle.native_instantiator.iagent_manager module
  • IAgentManager
    • IAgentManager.report_resources()
    • IAgentManager.report_result()
• libmuscle.native_instantiator.map_server module
  • MAPRequestHandler
    • MAPRequestHandler.handle_request()
  • MAPServer
    • MAPServer.deposit_command()
    • MAPServer.get_location()
    • MAPServer.stop()
• libmuscle.native_instantiator.native_instantiator module
  • NativeInstantiator
    • NativeInstantiator.run()
• libmuscle.native_instantiator.process_manager module
  • ProcessManager
    • ProcessManager.cancel_all()
    • ProcessManager.get_finished()
    • ProcessManager.start()
• libmuscle.native_instantiator.run_script module
  • cluster_command()
  • direct_prep_resources()
  • impi_prep_resources()
  • local_command()
  • make_script()
  • mpich_prep_resources()
  • num_mpi_tasks()
  • openmpi_prep_resources()
  • prep_resources()
  • srun_prep_resources()
• libmuscle.native_instantiator.slurm module
  • NCEVisitor
    • NCEVisitor.generic_visit()
    • NCEVisitor.visit_int()
    • NCEVisitor.visit_nce()
    • NCEVisitor.visit_nce_run()
    • NCEVisitor.visit_run_length()
  • NREVisitor
    • NREVisitor.generic_visit()
    • NREVisitor.visit_identifier()
    • NREVisitor.visit_index_range()
    • NREVisitor.visit_index_set()
    • NREVisitor.visit_int()
    • NREVisitor.visit_integer()
    • NREVisitor.visit_nre()
    • NREVisitor.visit_nre_part()
    • NREVisitor.visit_nre_parts()
    • NREVisitor.visit_padded_int()
  • SlurmInfo
    • SlurmInfo.agent_launch_command()
    • SlurmInfo.get_logical_cpus_per_node()
    • SlurmInfo.get_nodes()
    • SlurmInfo.in_slurm_allocation()
  • SlurmQuirks
    • SlurmQuirks.cpu_bind
    • SlurmQuirks.overlap
  • parse_slurm_nodelist()
  • parse_slurm_nodes_cores()
  • slurm()