base_client_t Class Reference

#include <shore_client.h>

Inheritance diagram for base_client_t:

Public Types
typedef map< int, string >	mapSupTrxs
typedef mapSupTrxs::iterator	mapSupTrxsIt
typedef mapSupTrxs::const_iterator	mapSupTrxsConstIt

Public Member Functions
	base_client_t ()
	base_client_t (std::string tname, const int id, ShoreEnv *env, const MeasurementType aType, const int trxid, const int numOfTrxs)
virtual	~base_client_t ()
void	work ()
int	id ()
bool	is_bound () const
int	rv ()
w_rc_t	run_xcts (int xct_type, int num_xct)
int	powerrun ()
w_rc_t	submit_batch (int xct_type, int &trx_cnt, const int batch_size)
virtual w_rc_t	submit_one (int xct_type, int num_xct)=0
void	print_tables ()
Public Member Functions inherited from thread_t
bool	delete_me ()
std::string	thread_name ()
randgen_t *	randgen ()
	Returns pointer to thread_t's randgen_t object. More...
int	rand ()
	Returns a pseudo-random integer between 0 and RAND_MAX. More...
int	rand (int n)
virtual	~thread_t ()
Public Member Functions inherited from thread_wrapper_t
	thread_wrapper_t ()
virtual	~thread_wrapper_t ()
virtual void	before_run ()
virtual void	after_run ()
void	spawn ()
void	fork ()
void	join ()

Static Public Member Functions
static void	abort_test ()
static void	resume_test ()
static bool	is_test_aborted ()
static int	load_sup_xct (mapSupTrxs &map)

Protected Attributes
ShoreEnv *	_env
MeasurementType	_measure_type
int	_trxid
int	_notrxs
guard< condex_pair >	_cp
bool	_is_bound
int	_id
int	_rv
boost::program_options::variables_map	optionValues
Protected Attributes inherited from thread_t
bool	_delete_me

Private Member Functions
	base_client_t (base_client_t const &)
void	operator= (base_client_t const &)

Additional Inherited Members
Protected Member Functions inherited from thread_t
	thread_t (const std::string &name)

Member Typedef Documentation

mapSupTrxs

typedef map<int, string> base_client_t::mapSupTrxs

mapSupTrxsConstIt

typedef mapSupTrxs::const_iterator base_client_t::mapSupTrxsConstIt

mapSupTrxsIt

typedef mapSupTrxs::iterator base_client_t::mapSupTrxsIt

Constructor & Destructor Documentation

base_client_t() [1/3]

base_client_t::base_client_t ( )

inline

base_client_t() [2/3]

base_client_t::base_client_t ( std::string  tname, const int  id, ShoreEnv *  env, const MeasurementType  aType, const int  trxid, const int  numOfTrxs  )

inline

~base_client_t()

virtual base_client_t::~base_client_t ( )

inlinevirtual

base_client_t() [3/3]

base_client_t::base_client_t ( base_client_t const &  )

private

Member Function Documentation

abort_test()

void base_client_t::abort_test ( )

static

id()

int base_client_t::id ( )

inline

is_bound()

bool base_client_t::is_bound ( ) const

inline

is_test_aborted()

bool base_client_t::is_test_aborted ( )

static

load_sup_xct()

static int base_client_t::load_sup_xct ( mapSupTrxs &  map )

inlinestatic

operator=()

void base_client_t::operator= ( base_client_t const &  )

private

powerrun()

int base_client_t::powerrun ( )

inline

print_tables()

void base_client_t::print_tables ( )

inline

resume_test()

void base_client_t::resume_test ( )

static

run_xcts()

w_rc_t base_client_t::run_xcts	(	int	xct_type,
		int	num_xct
	)

rv()

int base_client_t::rv ( )

inline

submit_batch()

w_rc_t base_client_t::submit_batch	(	int	xct_type,
		int &	trx_cnt,
		const int	batch_size
	)

submit_one()

virtual w_rc_t base_client_t::submit_one ( int  xct_type, int  num_xct  )

pure virtual

Implemented in ycsb::baseline_ycsb_client_t, tpcc::baseline_tpcc_client_t, and tpcb::baseline_tpcb_client_t.

work()

void base_client_t::work ( )

inlinevirtual

The previously used run() is already used by smthread core. Thus, run() now does the thread_t specific setup and calls work(). That is, work() is the new entry function for thread_t instead of run().

Implements thread_t.

Member Data Documentation

_cp

guard<condex_pair> base_client_t::_cp

protected

_env

ShoreEnv* base_client_t::_env

protected

_id

int base_client_t::_id

protected

_is_bound

bool base_client_t::_is_bound

protected

_measure_type

MeasurementType base_client_t::_measure_type

protected

_notrxs

int base_client_t::_notrxs

protected

_rv

int base_client_t::_rv

protected

_trxid

int base_client_t::_trxid

protected

optionValues

boost::program_options::variables_map base_client_t::optionValues

protected

---

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

• src/cmd/kits/shore_client.h
• src/cmd/kits/shore_client.cpp