hype::queryprocessing::ProcessingDevice Class Reference

#include <processing_device.hpp>

Collaboration diagram for hype::queryprocessing::ProcessingDevice:

List of all members.

Public Member Functions
	ProcessingDevice ()
bool	addOperator (OperatorPtr op)
void	start ()
void	stop ()
void	run ()
bool	isIdle ()
double	getEstimatedTimeUntilIdle ()
double	getTotalProcessingTime ()
Private Types
typedef std::list< OperatorPtr >	OperatorList
Private Member Functions
	ProcessingDevice (const ProcessingDevice &pd)
ProcessingDevice &	operator= (const ProcessingDevice &)
double	getEstimatedTimeUntilOperatorCompletion ()
Private Attributes
OperatorList	operators_
boost::condition_variable	new_operator_available_
boost::condition_variable	operator_queue_full_
boost::mutex	operator_mutex_
boost::thread	thread_
uint64_t	start_timestamp_of_currently_executed_operator_
double	estimated_execution_time_of_currently_executed_operator_
bool	operator_in_execution_
double	estimated_execution_time_for_operators_in_queue_to_complete_
double	total_measured_execution_time_for_all_executed_operators_

---

Member Typedef Documentation

typedef std::list<OperatorPtr> hype::queryprocessing::ProcessingDevice::OperatorList [private]

---

Constructor & Destructor Documentation

hype::queryprocessing::ProcessingDevice::ProcessingDevice

(

)

hype::queryprocessing::ProcessingDevice::ProcessingDevice

(

const ProcessingDevice &

pd

)

[private]

---

Member Function Documentation

bool hype::queryprocessing::ProcessingDevice::addOperator

(

OperatorPtr

op

)

Referenced by hype::queryprocessing::Operation_Benchmark< Type >::run().

Here is the caller graph for this function:

double hype::queryprocessing::ProcessingDevice::getEstimatedTimeUntilIdle

(

)

Todo:

Implement function! sum all Estimated Execution times of operators in operator list! OR better updated on add/remove from queue! Finally, add the rest time of current oeprator, which is provided by getEstimatedTimeUntilOperatorCompletion()

double hype::queryprocessing::ProcessingDevice::getEstimatedTimeUntilOperatorCompletion

(

)

[private]

Todo:

Implement function! store start timestamp of operator currently running and the Estiamted Execution Time for him -> compute rest time using current timestamp

double hype::queryprocessing::ProcessingDevice::getTotalProcessingTime

(

)

Referenced by hype::queryprocessing::Operation_Benchmark< Type >::run().

Here is the caller graph for this function:

bool hype::queryprocessing::ProcessingDevice::isIdle

(

)

Referenced by hype::queryprocessing::Operation_Benchmark< Type >::run().

Here is the caller graph for this function:

ProcessingDevice& hype::queryprocessing::ProcessingDevice::operator=

(

const ProcessingDevice &

)

[private]

void hype::queryprocessing::ProcessingDevice::run

(

)

void hype::queryprocessing::ProcessingDevice::start

(

)

Referenced by hype::queryprocessing::Operation_Benchmark< Type >::setup().

Here is the caller graph for this function:

void hype::queryprocessing::ProcessingDevice::stop

(

)

Referenced by hype::queryprocessing::Operation_Benchmark< Type >::run().

Here is the caller graph for this function:

---

Member Data Documentation

double hype::queryprocessing::ProcessingDevice::estimated_execution_time_for_operators_in_queue_to_complete_ [private]

double hype::queryprocessing::ProcessingDevice::estimated_execution_time_of_currently_executed_operator_ [private]

boost::condition_variable hype::queryprocessing::ProcessingDevice::new_operator_available_ [private]

bool hype::queryprocessing::ProcessingDevice::operator_in_execution_ [private]

boost::mutex hype::queryprocessing::ProcessingDevice::operator_mutex_ [private]

boost::condition_variable hype::queryprocessing::ProcessingDevice::operator_queue_full_ [private]

OperatorList hype::queryprocessing::ProcessingDevice::operators_ [private]

uint64_t hype::queryprocessing::ProcessingDevice::start_timestamp_of_currently_executed_operator_ [private]

boost::thread hype::queryprocessing::ProcessingDevice::thread_ [private]

double hype::queryprocessing::ProcessingDevice::total_measured_execution_time_for_all_executed_operators_ [private]

---

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

• /home/sebastian/gpudbms/trunk/hype-library/include/query_processing/processing_device.hpp