protocols::wum::MPI_Relax Class Reference

#include <MPI_Relax.hh>

Public Member Functions
	MPI_Relax ()
virtual	~MPI_Relax ()
virtual void	register_work_units ()
Public Member Functions inherited from protocols::wum::MPI_WorkUnitManager
	MPI_WorkUnitManager (char machine_letter)
virtual	~MPI_WorkUnitManager ()
virtual void	go ()=0
Public Member Functions inherited from protocols::wum::WorkUnitManager
	WorkUnitManager ()
virtual	~WorkUnitManager ()
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
virtual void	init_master ()
virtual void	init_slave ()
virtual void	process_inbound_wus_master ()
virtual void	process_outbound_wus_master ()
bool	fill_outbound_queue ()
Protected Member Functions inherited from protocols::wum::MPI_WorkUnitManager
virtual void	init ()=0
virtual void	process_inbound_wus ()=0
virtual void	process_outbound_wus ()=0
virtual void	print_stats ()
	Print a line with general run statistics, now. More...
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...
Protected Member Functions inherited from protocols::wum::WorkUnitManager
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::import_pose::pose_stream::MetaPoseInputStream	input_
core::Size	max_out_queue_size_

Additional Inherited Members
Public Types inherited from protocols::wum::WorkUnitManager
typedef WorkUnitQueue::iterator	iterator
typedef WorkUnitQueue::const_iterator	const_iterator
Protected Types inherited from protocols::wum::MPI_WorkUnitManager
enum	MPI_TIMING {   TIMING_WAIT =0, TIMING_TRANSFER_SEND, TIMING_TRANSFER_RECV, TIMING_CPU,   TIMING_IO_WRITE, TIMING_IO_READ, TIMING_IDLE, TIMING_end }

Constructor & Destructor Documentation

protocols::wum::MPI_Relax::MPI_Relax ( )

inline

References register_work_units().

virtual protocols::wum::MPI_Relax::~MPI_Relax ( )

inlinevirtual

Member Function Documentation

bool protocols::wum::MPI_Relax::fill_outbound_queue ( )

protected

References protocols::wum::WorkUnitQueue::add(), core::import_pose::pose_stream::MetaPoseInputStream::fill_pose(), in::file::fullatom, core::chemical::ChemicalManager::get_instance(), protocols::wum::WorkUnitList::get_work_unit(), core::import_pose::pose_stream::MetaPoseInputStream::has_another_pose(), input_, max_out_queue_size_, option, protocols::wum::WorkUnitManager::outbound(), core::chemical::ChemicalManager::residue_type_set(), protocols::wum::WorkUnitQueue::size(), protocols::wum::TR, and protocols::wum::WorkUnitManager::work_unit_list().

Referenced by process_outbound_wus_master().

void protocols::wum::MPI_Relax::init_master ( )

protectedvirtual

References input_, core::import_pose::pose_stream::streams_from_cmd_line(), and protocols::wum::TR.

void protocols::wum::MPI_Relax::init_slave ( )

protectedvirtual

References protocols::wum::TR.

void protocols::wum::MPI_Relax::process_inbound_wus_master ( )

protectedvirtual

References protocols::wum::SilentStructStore::begin(), protocols::wum::WorkUnit_SilentStructStore::decoys(), protocols::wum::SilentStructStore::end(), filename(), protocols::wum::WorkUnitManager::inbound(), option, protocols::wum::WorkUnitQueue::pop_next(), size(), protocols::wum::SilentStructStore::size(), protocols::wum::TR, and core::io::silent::SilentFileData::write_silent_struct().

void protocols::wum::MPI_Relax::process_outbound_wus_master ( )

protectedvirtual

References fill_outbound_queue().

void protocols::wum::MPI_Relax::register_work_units ( )

virtual

References protocols::relax::generate_relax_from_cmd(), protocols::wum::WorkUnitList::register_work_unit(), protocols::relax::relax_pose(), protocols::wum::TR, and protocols::wum::WorkUnitManager::work_unit_list().

Referenced by MPI_Relax().

Member Data Documentation

core::import_pose::pose_stream::MetaPoseInputStream protocols::wum::MPI_Relax::input_

private

Referenced by fill_outbound_queue(), and init_master().

core::Size protocols::wum::MPI_Relax::max_out_queue_size_

private

Referenced by fill_outbound_queue().

---

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

• src/protocols/wum/MPI_Relax.hh
• src/protocols/wum/MPI_Relax.cc