dnxWLM.h File Reference

Types and definitions for work load manager thread. More...

Go to the source code of this file.

Data Structures
struct	DnxWlmCfgData
	A WLM configuration data structure - passed to dnxWlmCreate. More...
struct	DnxWlmStats
	A structure for returning WLM statistics to a caller. More...
struct	DnxWlm
	An abstract data type - the external representation of a WLM object. More...
Functions
void	dnxWlmResetStats (DnxWlm *wlm)
	Reset all WLM statistics counters.
void	dnxWlmGetStats (DnxWlm *wlm, DnxWlmStats *wsp)
	Return a snapshot of WLM statistics.
int	dnxWlmReconfigure (DnxWlm *wlm, DnxWlmCfgData *cfg)
	Reconfigure an existing Work Load Manager object.
int	dnxWlmCreate (DnxWlmCfgData *cfg, DnxWlm **pwlm)
	Creates a new Work Load Manager object.
void	dnxWlmDestroy (DnxWlm *wlm)
	The main thread routine for the work load manager.

---

Detailed Description

Types and definitions for work load manager thread.

Author:

Robert W. Ingraham (dnx-devel@lists.sourceforge.net)

Attention:

Please submit patches to http://dnx.sourceforge.net

Definition in file dnxWLM.h.

---

Function Documentation

int dnxWlmCreate	(	DnxWlmCfgData *	cfg,
		DnxWlm **	pwlm
	)

Creates a new Work Load Manager object.

Parameters:

[in]	cfg	- a reference to the WLM configuration data structure.
[out]	pwlm	- the address of storage for the returned WLM object.

Returns:

Zero on success, or a non-zero error value.

Definition at line 676 of file dnxWLM.c.

References iDnxWlm::cfg, DnxWlmCfgData::collectorUrl, DnxWlmCfgData::dispatcherUrl, DNX_ERR_MEMORY, DNX_OK, DNX_PT_MUTEX_DESTROY, DNX_PT_MUTEX_INIT, DNX_PT_MUTEX_LOCK, DNX_PT_MUTEX_UNLOCK, dnxErrorString(), dnxLog(), growThreadPool(), iDnxWlm::minexectm, iDnxWlm::mutex, iDnxWlm::myipaddr, iDnxWlm::myipaddrstr, iDnxWlm::pool, DnxWlmCfgData::poolInitial, DnxWlmCfgData::poolMax, DnxWlmCfgData::poolMin, iDnxWlm::poolsz, iDnxWlm::threads, xfree, xmalloc, and xstrdup.

Referenced by main().

void dnxWlmDestroy

(

DnxWlm *

wlm

)

The main thread routine for the work load manager.

Parameters:

[in]

wlm

- the work load manager object to be destroyed.

Definition at line 769 of file dnxWLM.c.

References iDnxWlm::cfg, cleanThreadPool(), DnxWlmCfgData::collectorUrl, DnxWlmCfgData::dispatcherUrl, DNX_PT_MUTEX_DESTROY, DNX_PT_MUTEX_LOCK, DNX_PT_MUTEX_UNLOCK, DNX_THREAD_RUNNING, dnxCancelableSleep(), dnxDebug(), dnxLog(), iDnxWlm::mutex, iDnxWlm::pool, DnxWlmCfgData::shutdownGrace, DnxWorkerStatus::state, iDnxWlm::terminate, iDnxWlm::threads, DnxWorkerStatus::tid, and xfree.

Referenced by main().

void dnxWlmGetStats	(	DnxWlm *	wlm,
		DnxWlmStats *	wsp
	)

Return a snapshot of WLM statistics.

Parameters:

[in]	wlm	- the Work Load Manager whose stats are to be returned.
[out]	wsp	- the address of storage for the WLM stats to be returned.

Definition at line 591 of file dnxWLM.c.

References iDnxWlm::active, DnxWlmStats::active_threads, DnxWlmStats::avg_active_threads, DnxWlmStats::avg_exec_time, DnxWlmStats::avg_total_threads, iDnxWlm::avgactive, iDnxWlm::avgexectm, iDnxWlm::avgthreads, DNX_PT_MUTEX_LOCK, DNX_PT_MUTEX_UNLOCK, DnxWlmStats::job_time, DnxWlmStats::jobs_failed, DnxWlmStats::jobs_received, DnxWlmStats::jobs_succeeded, iDnxWlm::jobsfail, iDnxWlm::jobsok, iDnxWlm::jobsrcvd, iDnxWlm::jobtm, DnxWlmStats::max_exec_time, iDnxWlm::maxexectm, DnxWlmStats::min_exec_time, iDnxWlm::minexectm, iDnxWlm::mutex, iDnxWlm::packets_in, DnxWlmStats::packets_in, iDnxWlm::packets_out, DnxWlmStats::packets_out, iDnxWlm::reqsent, DnxWlmStats::requests_sent, iDnxWlm::tcreated, iDnxWlm::tdestroyed, DnxWlmStats::thread_time, iDnxWlm::threads, DnxWlmStats::threads_created, DnxWlmStats::threads_destroyed, iDnxWlm::threadtm, and DnxWlmStats::total_threads.

Referenced by buildMgmtStatsReply().

int dnxWlmReconfigure	(	DnxWlm *	wlm,
		DnxWlmCfgData *	cfg
	)

Reconfigure an existing Work Load Manager object.

Parameters:

[in]	wlm	- the work load manager object to be reconfigured.
[in]	cfg	- the new configuration parameters.

Returns:

Zero on success, or a non-zero error value.

Definition at line 620 of file dnxWLM.c.

References iDnxWlm::cfg, DNX_ERR_MEMORY, DNX_PT_MUTEX_LOCK, DNX_PT_MUTEX_UNLOCK, dnxCancelableSleep(), logConfigChanges(), DnxWlmCfgData::maxResults, DnxWlmCfgData::maxRetries, iDnxWlm::mutex, DnxWlmCfgData::pollInterval, iDnxWlm::pool, DnxWlmCfgData::poolGrow, DnxWlmCfgData::poolInitial, DnxWlmCfgData::poolMax, DnxWlmCfgData::poolMin, iDnxWlm::poolsz, DnxWlmCfgData::reqTimeout, DnxWlmCfgData::showNodeAddr, DnxWlmCfgData::shutdownGrace, iDnxWlm::threads, DnxWlmCfgData::ttlBackoff, and xrealloc.

void dnxWlmResetStats

(

DnxWlm *

wlm

)

Reset all WLM statistics counters.

Parameters:

[in]

wlm

- the Work Load Manager whose stats counters are to be reset.

Definition at line 572 of file dnxWLM.c.

References iDnxWlm::avgactive, iDnxWlm::avgexectm, iDnxWlm::avgthreads, DNX_PT_MUTEX_LOCK, DNX_PT_MUTEX_UNLOCK, iDnxWlm::jobsfail, iDnxWlm::jobsok, iDnxWlm::jobsrcvd, iDnxWlm::jobtm, iDnxWlm::maxexectm, iDnxWlm::minexectm, iDnxWlm::mutex, iDnxWlm::packets_in, iDnxWlm::packets_out, iDnxWlm::reqsent, iDnxWlm::tcreated, iDnxWlm::tdestroyed, and iDnxWlm::threadtm.

Referenced by processCommands().