Rosetta
|
#include <MPI_Refinement.hh>
Public Member Functions | |
MPI_Refinement (char machine_letter) | |
void | set_defaults () |
~MPI_Refinement () override=default | |
![]() | |
MPI_WorkUnitManager (char machine_letter) | |
~MPI_WorkUnitManager () override=default | |
void | go () override=0 |
![]() | |
WorkUnitManager () | |
~WorkUnitManager () override=default | |
void | register_work_units (const protocols::wum::WorkUnitList &work_unit_list) |
WorkUnitQueue & | outbound () |
WorkUnitQueue & | inbound () |
const WorkUnitQueue & | outbound () const |
const WorkUnitQueue & | inbound () const |
Protected Member Functions | |
void | load_structures_from_cmdline_into_library (protocols::wum::SilentStructStore &library) |
void | save_state (std::string prefix="default") |
void | save_state_auto () |
void | load_state (std::string prefix="default") |
void | print_stats () override |
Print a line with general run statistics, now. More... | |
void | print_summary (std::string const prefix="SUMM ") |
void | print_library (protocols::wum::SilentStructStore &library, std::string const prefix="LIB ") |
virtual bool | add_structures_to_library (protocols::wum::SilentStructStore &new_structs, std::string add_algorithm="") |
virtual bool | add_structure_to_library (core::io::silent::SilentStructOP pss, std::string add_algorithm="") |
bool | add_structure_to_library_direct (core::io::silent::SilentStruct &pss) |
bool | add_structure_to_library_add_n_replace (core::io::silent::SilentStruct &pss) |
bool | add_structure_to_library_single_replace (core::io::silent::SilentStruct &pss) |
void | update_library_NSGAII (protocols::wum::SilentStructStore &new_structs) |
void | setup_multi_objective () |
void | send_sortedpick_library_structs (core::Size dest_rank, core::Size nsend, std::string const scorename, bool const weighted, bool const inverse=false, core::Real const kT=0.2) |
void | send_random_library_structs (core::Size dest_rank, core::Size nsend) |
void | send_random_library_struct (core::Size dest_rank, core::Size ssid) const |
void | limit_library () |
void | shave_library (protocols::wum::SilentStructStore &new_structs, std::string const scorename, core::Real const frac) const |
void | dump_structures (const protocols::wum::SilentStructStore &new_structs, bool score_only=true, std::string const prefix="") const |
void | set_ident_string (std::string new_ident) |
void | report_time () const |
const std::string & | mpi_resume () |
core::Size & | totaltime_loophash () |
protocols::wum::SilentStructStore & | library_central () |
protocols::wum::SilentStructStore & | library_ref () |
const std::string & | mpi_feedback () |
void | set_mpi_feedback (const std::string &mpi_feedback) |
core::Size | max_lib_size () |
core::Size | max_ref_lib_size () |
void | set_max_lib_size (core::Size max_lib_size) |
void | set_max_ref_lib_size (core::Size max_ref_lib_size) |
core::Real | score (const core::io::silent::SilentStructOP &ss) const |
void | retag_library (protocols::wum::SilentStructStore &store, std::string const prefix) const |
std::string | format_silent_struct (const core::io::silent::SilentStructOP &ss) const |
core::Real | score (const core::io::silent::SilentStruct &ss) const |
std::string | format_silent_struct (const core::io::silent::SilentStruct &ss) const |
![]() | |
virtual void | init ()=0 |
virtual void | process_inbound_wus ()=0 |
virtual void | process_outbound_wus ()=0 |
virtual void | print_stats_auto () |
Print a line with general run statistics, only if enough time has pased since the last statistics printout. More... | |
void | reset_timing_stats () |
Reset all the stats counters. More... | |
void | process_incoming_msgs (bool wait_until_message=false) |
MPI Communication function. More... | |
void | send_MPI_workunit (const WorkUnitBaseOP &wu, int dest_rank) const |
Send a workunit to an arbitrary recipient. More... | |
void | receive_MPI_workunit (core::Size node_rank=MPI_ANY_SOURCE) |
Receive a workunit and add it to the inbound queue. By default accept any workunit or accept a specific source rank. Note that this function is blocking and will onyl return once a workunit has been received. More... | |
void | send_next_WU_on_request () |
char | get_machine_letter () |
How many masters are there in total ? More... | |
core::Real | start_timer (MPI_TIMING timing_mode) const |
This initiates a new timer block. Note that there is no end_timer() function - you just keep calling start_timer, which automatically ends the previous block (and records times etc) More... | |
void | print_timing_stats () |
Display the timing statistics. More... | |
long | wall_time () const |
Return the total life time of this class in seconds. More... | |
![]() | |
const protocols::wum::WorkUnitList & | work_unit_list () const |
protocols::wum::WorkUnitList & | work_unit_list () |
void | write_queues_to_file (const std::string &prefix="default") const |
void | write_work_unit (const WorkUnitBaseOP &wu, std::ostream &out) const |
void | write_queue (const WorkUnitQueue &the_queue, std::ostream &out) const |
void | read_queues_from_file (const std::string &prefix="default") |
bool | read_work_unit (WorkUnitBaseOP &qualified_wu, std::istream &in) |
void | read_queue (WorkUnitQueue &the_queue, std::istream &in) |
core::Size | mem_foot_print () const |
return total memory foot print in bytes More... | |
Private Attributes | |
core::Size | max_lib_size_ |
core::Size | max_ref_lib_size_ |
core::Size | save_state_interval_ |
std::string | mpi_feedback_ |
core::Real | mpi_metropolis_temp_ |
core::Real | rms_limit_ |
std::string | objective_function_ |
std::string | mpi_resume_ |
std::string | jobname_ |
protocols::wum::SilentStructStore | library_central_ |
protocols::wum::SilentStructStore | library_ref_ |
core::Size | last_save_state_ |
std::string | ident_string_ |
std::string | sim_replace_obj_ |
Additional Inherited Members | |
![]() | |
typedef WorkUnitQueue::iterator | iterator |
typedef WorkUnitQueue::const_iterator | const_iterator |
![]() | |
enum | MPI_TIMING { TIMING_WAIT =0 , TIMING_TRANSFER_SEND , TIMING_TRANSFER_RECV , TIMING_CPU , TIMING_IO_WRITE , TIMING_IO_READ , TIMING_IDLE , TIMING_end } |
protocols::mpi_refinement::MPI_Refinement::MPI_Refinement | ( | char | machine_letter | ) |
References set_defaults().
|
overridedefault |
|
protectedvirtual |
Reimplemented in protocols::mpi_refinement::MPI_Refine_Master.
References add_structure_to_library_add_n_replace(), add_structure_to_library_direct(), add_structure_to_library_single_replace(), fobj_, library_central(), and mpi_feedback_.
Referenced by add_structures_to_library().
|
protected |
References protocols::wum::SilentStructStore::add(), add_structure_to_library_direct(), protocols::wum::SilentStructStore::begin(), protocols::mpi_refinement::CA_Sscore(), core::io::silent::SilentStruct::clone(), core::sequence::end, protocols::wum::SilentStructStore::end(), protocols::wum::SilentStructStore::erase(), core::chemical::element::F, fobj_, format_silent_struct(), library_central_, sim_replace_obj_, protocols::wum::SilentStructStore::size(), protocols::wum::SilentStructStore::sort_by(), protocols::wum::MPI_WorkUnitManager::start_timer(), protocols::wum::SilentStructStore::store(), protocols::wum::MPI_WorkUnitManager::TIMING_CPU, protocols::mpi_refinement::TR(), and TRDEBUG.
Referenced by add_structure_to_library().
|
protected |
References protocols::wum::SilentStructStore::add(), library_central_, and protocols::mpi_refinement::TR().
Referenced by add_structure_to_library(), and add_structure_to_library_add_n_replace().
|
protected |
References protocols::wum::SilentStructStore::begin(), core::scoring::rna::chemical_shift::dround(), protocols::wum::SilentStructStore::end(), core::chemical::element::F, fobj_, format_silent_struct(), core::io::silent::SilentStruct::get_energy(), core::io::silent::SilentStruct::get_self_ptr(), library_central_, mpi_metropolis_temp_, core::scoring::rg, total_metropolis_, total_metropolis_accepts_, and protocols::mpi_refinement::TR().
Referenced by add_structure_to_library().
|
protectedvirtual |
|
protected |
References protocols::abinitio::filename(), jobname_, protocols::wum::mpi_rank(), protocols::wum::MPI_WorkUnitManager::start_timer(), protocols::wum::MPI_WorkUnitManager::TIMING_CPU, protocols::wum::MPI_WorkUnitManager::TIMING_IO_WRITE, TRDEBUG, and core::io::silent::SilentFileData::write_silent_struct().
|
protected |
|
protected |
|
inlineprotected |
References library_central_.
Referenced by add_structure_to_library().
|
inlineprotected |
References library_ref_.
|
protected |
References format_silent_struct(), protocols::wum::SilentStructStore::get_struct(), library_central_, max_lib_size_, sim_replace_obj_, protocols::wum::SilentStructStore::size(), protocols::wum::SilentStructStore::sort_by(), protocols::wum::SilentStructStore::store(), and protocols::mpi_refinement::TR().
Referenced by add_structures_to_library().
|
protected |
References protocols::wum::SilentStructStore::clear(), protocols::wum::WorkUnitQueue::clear(), protocols::wum::WorkUnitManager::inbound(), library_central_, protocols::wum::mpi_rank(), protocols::wum::WorkUnitManager::outbound(), protocols::wum::SilentStructStore::read_from_file(), protocols::wum::WorkUnitManager::read_queues_from_file(), protocols::wum::MPI_WorkUnitManager::start_timer(), protocols::wum::MPI_WorkUnitManager::TIMING_CPU, and protocols::wum::MPI_WorkUnitManager::TIMING_IO_READ.
|
protected |
References protocols::wum::SilentStructStore::add(), core::scoring::constraints::add_fa_constraints_from_cmdline_to_scorefxn(), protocols::mpi_refinement::add_poseinfo_to_ss(), protocols::relax::AtomCoordinateCstMover::apply(), core::scoring::CA_rmsd(), core::pose::Pose::constraint_set(), core::scoring::coordinate_constraint, protocols::relax::AtomCoordinateCstMover::cst_sd(), core::import_pose::pose_stream::MetaPoseInputStream::fill_pose(), fobj_, core::scoring::constraints::get_cst_fa_file_option(), core::import_pose::pose_stream::MetaPoseInputStream::has_another_pose(), library_central_, max_lib_size_, native_given_, native_pose_, pose0_, print_library(), protocols::mpi_refinement::ramp_minpack_pose(), core::pose::set_ss_from_phipsi(), protocols::wum::SilentStructStore::size(), protocols::wum::MPI_WorkUnitManager::start_timer(), core::import_pose::pose_stream::streams_from_cmd_line(), protocols::wum::MPI_WorkUnitManager::TIMING_CPU, protocols::wum::MPI_WorkUnitManager::TIMING_IO_READ, and protocols::mpi_refinement::TR().
|
inlineprotected |
References max_lib_size_.
Referenced by add_structures_to_library(), and set_max_lib_size().
|
inlineprotected |
References max_ref_lib_size_.
Referenced by set_max_ref_lib_size().
|
inlineprotected |
References mpi_feedback_.
Referenced by set_mpi_feedback().
|
inlineprotected |
References mpi_resume_.
|
protected |
|
overrideprotectedvirtual |
Print a line with general run statistics, now.
Reimplemented from protocols::wum::MPI_WorkUnitManager.
References core::chemical::element::F, library_central_, protocols::wum::SilentStructStore::mem_footprint(), n_batchrelax_, n_loophash_, total_metropolis_, total_metropolis_accepts_, total_structures_, total_structures_relax_, totaltime_batchrelax_, totaltime_loophash_, protocols::mpi_refinement::TR(), and protocols::wum::MPI_WorkUnitManager::wall_time().
|
protected |
|
protected |
References starttime_, and protocols::mpi_refinement::TR().
|
protected |
|
protected |
References protocols::wum::WorkUnitManager::inbound(), library_central_, protocols::wum::mpi_rank(), protocols::wum::WorkUnitManager::outbound(), protocols::wum::SilentStructStore::serialize_to_file(), protocols::wum::SilentStructStore::size(), protocols::wum::WorkUnitQueue::size(), protocols::wum::MPI_WorkUnitManager::start_timer(), protocols::wum::MPI_WorkUnitManager::TIMING_CPU, protocols::wum::MPI_WorkUnitManager::TIMING_IO_WRITE, protocols::mpi_refinement::TR(), and protocols::wum::WorkUnitManager::write_queues_to_file().
Referenced by save_state_auto().
|
protected |
References ident_string_, last_save_state_, save_state(), save_state_interval_, and protocols::mpi_refinement::TR().
|
protected |
References core::io::silent::SilentStruct::get_energy().
|
protected |
Referenced by send_sortedpick_library_structs().
|
protected |
|
protected |
|
protected |
References protocols::wum::SilentStructStore::begin(), protocols::cryst::denom(), protocols::wum::SilentStructStore::end(), core::chemical::element::F, protocols::wum::SilentStructStore::get_struct(), library_central_, core::scoring::rg, score(), protocols::wum::MPI_WorkUnitManager::send_MPI_workunit(), protocols::wum::SilentStructStore::size(), protocols::wum::SilentStructStore::sort_by(), and protocols::mpi_refinement::TR().
void protocols::mpi_refinement::MPI_Refinement::set_defaults | ( | ) |
References fobj_, ident_string_, jobname_, last_save_state_, max_lib_size_, max_ref_lib_size_, mpi_feedback_, mpi_metropolis_temp_, mpi_resume_, native_given_, native_pose_, core::import_pose::PDB_file, pose0_, core::import_pose::pose_from_file(), core::scoring::rg, rms_limit_, save_state_interval_, sim_replace_obj_, starttime_, and protocols::mpi_refinement::TR().
Referenced by MPI_Refinement().
|
inlineprotected |
References ident_string_.
|
inlineprotected |
References max_lib_size(), and max_lib_size_.
|
inlineprotected |
References max_ref_lib_size(), and max_ref_lib_size_.
|
inlineprotected |
References mpi_feedback(), and mpi_feedback_.
|
protected |
|
protected |
|
inlineprotected |
References totaltime_loophash_.
|
protected |
|
protected |
|
private |
Referenced by save_state_auto(), set_defaults(), and set_ident_string().
|
private |
Referenced by dump_structures(), and set_defaults().
|
private |
Referenced by save_state_auto(), and set_defaults().
|
private |
Referenced by add_structure_to_library_add_n_replace(), add_structure_to_library_direct(), add_structure_to_library_single_replace(), add_structures_to_library(), library_central(), limit_library(), load_state(), load_structures_from_cmdline_into_library(), print_stats(), print_summary(), save_state(), send_random_library_struct(), send_random_library_structs(), and send_sortedpick_library_structs().
|
private |
Referenced by library_ref().
|
private |
Referenced by limit_library(), load_structures_from_cmdline_into_library(), max_lib_size(), set_defaults(), and set_max_lib_size().
|
private |
Referenced by max_ref_lib_size(), set_defaults(), and set_max_ref_lib_size().
|
private |
Referenced by add_structure_to_library(), mpi_feedback(), set_defaults(), and set_mpi_feedback().
|
private |
Referenced by add_structure_to_library_single_replace(), and set_defaults().
|
private |
Referenced by mpi_resume(), and set_defaults().
|
protected |
Referenced by print_stats().
|
protected |
Referenced by print_stats().
|
protected |
Referenced by format_silent_struct(), load_structures_from_cmdline_into_library(), print_library(), and set_defaults().
|
protected |
Referenced by load_structures_from_cmdline_into_library(), and set_defaults().
|
private |
|
protected |
Referenced by load_structures_from_cmdline_into_library(), and set_defaults().
|
private |
Referenced by set_defaults().
|
private |
Referenced by save_state_auto(), and set_defaults().
|
private |
Referenced by add_structure_to_library_add_n_replace(), limit_library(), and set_defaults().
|
protected |
Referenced by print_summary(), report_time(), and set_defaults().
|
protected |
Referenced by add_structure_to_library_single_replace(), and print_stats().
|
protected |
Referenced by add_structure_to_library_single_replace(), and print_stats().
|
protected |
Referenced by print_stats().
|
protected |
Referenced by print_stats().
|
protected |
Referenced by print_stats().
|
protected |
Referenced by print_stats(), and totaltime_loophash().