Public RecProcess declarations. More...

#include "I_RecCore.h"
#include "I_EventSystem.h"

Include dependency graph for I_RecProcess.h:

This graph shows which files directly or indirectly include this file:

Defines
#define	RecRegisterRawStat(rsb, rec_type, name, data_type, persist_type, id, sync_cb) _RecRegisterRawStat((rsb), (rec_type), (name), (data_type), REC_PERSISTENCE_TYPE(persist_type), (id), (sync_cb))
Functions
int	RecProcessInit (RecModeT mode_type, Diags *diags=NULL)
int	RecProcessInitMessage (RecModeT mode_type)
int	RecProcessStart (void)
void	RecProcess_set_raw_stat_sync_interval_ms (int ms)
void	RecProcess_set_config_update_interval_ms (int ms)
void	RecProcess_set_remote_sync_interval_ms (int ms)
RecRawStatBlock *	RecAllocateRawStatBlock (int num_stats)
int	_RecRegisterRawStat (RecRawStatBlock rsb, RecT rec_type, const char name, RecDataT data_type, RecPersistT persist_type, int id, RecRawStatSyncCb sync_cb)
int	RecRawStatSyncSum (const char name, RecDataT data_type, RecData data, RecRawStatBlock *rsb, int id)
int	RecRawStatSyncCount (const char name, RecDataT data_type, RecData data, RecRawStatBlock *rsb, int id)
int	RecRawStatSyncAvg (const char name, RecDataT data_type, RecData data, RecRawStatBlock *rsb, int id)
int	RecRawStatSyncHrTimeAvg (const char name, RecDataT data_type, RecData data, RecRawStatBlock *rsb, int id)
int	RecRawStatSyncIntMsecsToFloatSeconds (const char name, RecDataT data_type, RecData data, RecRawStatBlock *rsb, int id)
int	RecRawStatSyncMHrTimeAvg (const char name, RecDataT data_type, RecData data, RecRawStatBlock *rsb, int id)
int	RecIncrRawStat (RecRawStatBlock rsb, EThread ethread, int id, int64_t incr=1)
int	RecIncrRawStatSum (RecRawStatBlock rsb, EThread ethread, int id, int64_t incr=1)
int	RecIncrRawStatCount (RecRawStatBlock rsb, EThread ethread, int id, int64_t incr=1)
int	RecIncrRawStatBlock (RecRawStatBlock rsb, EThread ethread, RecRawStat *stat_array)
int	RecSetRawStatSum (RecRawStatBlock *rsb, int id, int64_t data)
int	RecSetRawStatCount (RecRawStatBlock *rsb, int id, int64_t data)
int	RecSetRawStatBlock (RecRawStatBlock rsb, RecRawStat stat_array)
int	RecGetRawStatSum (RecRawStatBlock rsb, int id, int64_t data)
int	RecGetRawStatCount (RecRawStatBlock rsb, int id, int64_t data)
int	RecIncrGlobalRawStat (RecRawStatBlock *rsb, int id, int64_t incr=1)
int	RecIncrGlobalRawStatSum (RecRawStatBlock *rsb, int id, int64_t incr=1)
int	RecIncrGlobalRawStatCount (RecRawStatBlock *rsb, int id, int64_t incr=1)
int	RecSetGlobalRawStatSum (RecRawStatBlock *rsb, int id, int64_t data)
int	RecSetGlobalRawStatCount (RecRawStatBlock *rsb, int id, int64_t data)
int	RecGetGlobalRawStatSum (RecRawStatBlock rsb, int id, int64_t data)
int	RecGetGlobalRawStatCount (RecRawStatBlock rsb, int id, int64_t data)
RecRawStat *	RecGetGlobalRawStatPtr (RecRawStatBlock *rsb, int id)
int64_t *	RecGetGlobalRawStatSumPtr (RecRawStatBlock *rsb, int id)
int64_t *	RecGetGlobalRawStatCountPtr (RecRawStatBlock *rsb, int id)
RecRawStat *	raw_stat_get_tlp (RecRawStatBlock rsb, int id, EThread ethread)
int	RecDecrRawStat (RecRawStatBlock rsb, EThread ethread, int id, int64_t decr)

Detailed Description

Public RecProcess declarations.

License

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Definition in file I_RecProcess.h.

Define Documentation

#define RecRegisterRawStat	(	rsb,
		rec_type,
		name,
		data_type,
		persist_type,
		id,
		sync_cb
	)		_RecRegisterRawStat((rsb), (rec_type), (name), (data_type), REC_PERSISTENCE_TYPE(persist_type), (id), (sync_cb))

Definition at line 51 of file I_RecProcess.h.

Referenced by UpdateConfigManager::init(), ClusterProcessor::init(), ink_aio_init(), ink_dns_init(), ink_hostdb_init(), reg_int(), register_congest_stats(), register_net_stats(), LogConfig::register_stat_callbacks(), register_stat_callbacks(), spdy_config_load(), SSLInitializeStatistics(), start_SocksProxy(), and TSStatCreate().

Function Documentation

int _RecRegisterRawStat	(	RecRawStatBlock *	rsb,
		RecT	rec_type,
		const char *	name,
		RecDataT	data_type,
		RecPersistT	persist_type,
		int	id,
		RecRawStatSyncCb	sync_cb
	)

Definition at line 545 of file RecProcess.cc.

References RecStatMeta::data_raw, Debug, RecRawStatBlock::global, i_am_the_record_owner(), ink_assert, RecRawStat::last_count, RecRawStat::last_sum, RecRecord::rec_type, RecRegisterRawStatSyncCb(), RecRegisterStat(), RecRecord::rsb_id, send_register_message(), RecRecord::stat_meta, and RecRecord::sync_required.

RecRawStat* raw_stat_get_tlp	(	RecRawStatBlock *	rsb,
		int	id,
		EThread *	ethread
	)			`[inline]`

Definition at line 121 of file I_RecProcess.h.

References RecRawStatBlock::ethr_stat_offset, ink_assert, and this_ethread().

Referenced by RecDecrRawStat(), RecIncrRawStat(), RecIncrRawStatCount(), and RecIncrRawStatSum().

RecRawStatBlock* RecAllocateRawStatBlock ( int num_stats )

int RecDecrRawStat	(	RecRawStatBlock *	rsb,
		EThread *	ethread,
		int	id,
		int64_t	decr
	)			`[inline]`

Definition at line 140 of file I_RecProcess.h.

References RecRawStat::count, raw_stat_get_tlp(), and RecRawStat::sum.

Referenced by TSStatIntDecrement().

int RecGetGlobalRawStatCount	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t *	data
	)

Definition at line 811 of file RecProcess.cc.

References RecRawStat::count, and RecRawStatBlock::global.

Referenced by aio_stats_cb().

int64_t* RecGetGlobalRawStatCountPtr	(	RecRawStatBlock *	rsb,
		int	id
	)

Definition at line 834 of file RecProcess.cc.

References RecRawStat::count, and RecRawStatBlock::global.

RecRawStat* RecGetGlobalRawStatPtr	(	RecRawStatBlock *	rsb,
		int	id
	)

Definition at line 822 of file RecProcess.cc.

References RecRawStatBlock::global.

Referenced by dumpICPstatEntry().

int RecGetGlobalRawStatSum	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t *	data
	)

Definition at line 804 of file RecProcess.cc.

References RecRawStatBlock::global, and RecRawStat::sum.

Referenced by aio_stats_cb(), cache_stats_bytes_used_cb(), and TSStatIntGet().

int64_t* RecGetGlobalRawStatSumPtr	(	RecRawStatBlock *	rsb,
		int	id
	)

Definition at line 828 of file RecProcess.cc.

References RecRawStatBlock::global, and RecRawStat::sum.

int RecGetRawStatCount	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t *	data
	)

Definition at line 746 of file RecProcess.cc.

References RecRawStat::count, and raw_stat_get_total().

int RecGetRawStatSum	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t *	data
	)

Definition at line 736 of file RecProcess.cc.

References raw_stat_get_total(), and RecRawStat::sum.

int RecIncrGlobalRawStat	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t	incr = `1`
	)

Definition at line 760 of file RecProcess.cc.

References RecRawStat::count, RecRawStatBlock::global, and RecRawStat::sum.

Referenced by CacheProcessor::mark_storage_offline().

int RecIncrGlobalRawStatCount	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t	incr = `1`
	)

Definition at line 775 of file RecProcess.cc.

References RecRawStat::count, and RecRawStatBlock::global.

int RecIncrGlobalRawStatSum	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t	incr = `1`
	)

Definition at line 768 of file RecProcess.cc.

References RecRawStatBlock::global, and RecRawStat::sum.

int RecIncrRawStat	(	RecRawStatBlock *	rsb,
		EThread *	ethread,
		int	id,
		int64_t	incr = `1`
	)			`[inline]`

Definition at line 131 of file I_RecProcess.h.

References RecRawStat::count, raw_stat_get_tlp(), and RecRawStat::sum.

Referenced by Log::access(), LogFile::close_file(), Log::flush_thread_main(), LogObjectManager::log(), LogFile::open_file(), LogHost::orphan_write_and_try_delete(), LogFile::preproc_and_try_delete(), LogBufferManager::preproc_buffers(), HttpTransact::State::record_transaction_stats(), TSStatIntIncrement(), Log::va_error(), and LogFile::write_ascii_logbuffer3().

int RecIncrRawStatBlock	(	RecRawStatBlock *	rsb,
		EThread *	ethread,
		RecRawStat *	stat_array
	)

Definition at line 698 of file RecProcess.cc.

int RecIncrRawStatCount	(	RecRawStatBlock *	rsb,
		EThread *	ethread,
		int	id,
		int64_t	incr = `1`
	)			`[inline]`

Definition at line 157 of file I_RecProcess.h.

References RecRawStat::count, and raw_stat_get_tlp().

int RecIncrRawStatSum	(	RecRawStatBlock *	rsb,
		EThread *	ethread,
		int	id,
		int64_t	incr = `1`
	)			`[inline]`

Definition at line 149 of file I_RecProcess.h.

References raw_stat_get_tlp(), and RecRawStat::sum.

void RecProcess_set_config_update_interval_ms ( int ms )

Definition at line 100 of file RecProcess.cc.

References Debug, g_rec_config_update_interval_ms, HRTIME_MSECONDS, and Event::schedule_every().

void RecProcess_set_raw_stat_sync_interval_ms ( int ms )

Definition at line 91 of file RecProcess.cc.

References Debug, g_rec_raw_stat_sync_interval_ms, HRTIME_MSECONDS, and Event::schedule_every().

void RecProcess_set_remote_sync_interval_ms ( int ms )

Definition at line 109 of file RecProcess.cc.

References Debug, g_rec_remote_sync_interval_ms, HRTIME_MSECONDS, and Event::schedule_every().

int RecProcessInit	(	RecModeT	mode_type,
		Diags *	diags = `NULL`
	)

Definition at line 409 of file RecProcess.cc.

References g_mode_type, REC_ERR_FAIL, and RecCoreInit().

Referenced by initialize_process_manager().

int RecProcessInitMessage ( RecModeT mode_type )

Definition at line 460 of file RecProcess.cc.

References EventNotify::lock(), RECG_PULL_REQ, RECM_CLIENT, RecMessageInit(), RecMessageRegisterRecvCb(), recv_message_cb__process(), send_pull_message(), EventNotify::unlock(), and EventNotify::wait().

Referenced by initialize_process_manager().

int RecProcessStart ( void )

Definition at line 490 of file RecProcess.cc.

References Debug, ET_TASK, eventProcessor, g_rec_config_update_interval_ms, g_rec_raw_stat_sync_interval_ms, g_rec_remote_sync_interval_ms, g_started, HRTIME_MSECONDS, new_ProxyMutex(), and EventProcessor::schedule_every().

Referenced by main().

int RecRawStatSyncAvg	(	const char *	name,
		RecDataT	data_type,
		RecData *	data,
		RecRawStatBlock *	rsb,
		int	id
	)

Definition at line 619 of file RecProcess.cc.

References RecRawStat::count, Debug, RecRawStatBlock::global, raw_stat_sync_to_global(), RecDataSetFromFloat(), and RecRawStat::sum.

Referenced by ClusterProcessor::init(), ink_hostdb_init(), and register_stat_callbacks().

int RecRawStatSyncCount	(	const char *	name,
		RecDataT	data_type,
		RecData *	data,
		RecRawStatBlock *	rsb,
		int	id
	)

Definition at line 605 of file RecProcess.cc.

References RecRawStat::count, Debug, RecRawStatBlock::global, raw_stat_sync_to_global(), RecDataSetFromInk64(), and RecRawStat::sum.

Referenced by UpdateConfigManager::init(), ClusterProcessor::init(), ink_hostdb_init(), LogConfig::register_stat_callbacks(), register_stat_callbacks(), spdy_config_load(), SSLInitializeStatistics(), SSLRecRawStatSyncCount(), and start_SocksProxy().

int RecRawStatSyncHrTimeAvg	(	const char *	name,
		RecDataT	data_type,
		RecData *	data,
		RecRawStatBlock *	rsb,
		int	id
	)

Definition at line 635 of file RecProcess.cc.

References RecRawStat::count, Debug, RecRawStatBlock::global, HRTIME_SECOND, raw_stat_sync_to_global(), RecDataSetFromFloat(), and RecRawStat::sum.

Referenced by ClusterProcessor::init(), and ink_dns_init().

int RecRawStatSyncIntMsecsToFloatSeconds	(	const char *	name,
		RecDataT	data_type,
		RecData *	data,
		RecRawStatBlock *	rsb,
		int	id
	)

Definition at line 655 of file RecProcess.cc.

References RecRawStat::count, Debug, RecRawStatBlock::global, raw_stat_sync_to_global(), RecDataSetFromFloat(), and RecRawStat::sum.

Referenced by register_stat_callbacks().

int RecRawStatSyncMHrTimeAvg	(	const char *	name,
		RecDataT	data_type,
		RecData *	data,
		RecRawStatBlock *	rsb,
		int	id
	)

Definition at line 674 of file RecProcess.cc.

References RecRawStat::count, Debug, RecRawStatBlock::global, HRTIME_MSECOND, raw_stat_sync_to_global(), RecDataSetFromFloat(), and RecRawStat::sum.

int RecRawStatSyncSum	(	const char *	name,
		RecDataT	data_type,
		RecData *	data,
		RecRawStatBlock *	rsb,
		int	id
	)

Definition at line 591 of file RecProcess.cc.

References RecRawStat::count, Debug, RecRawStatBlock::global, raw_stat_sync_to_global(), RecDataSetFromInk64(), and RecRawStat::sum.

Referenced by cache_stats_bytes_used_cb(), ClusterProcessor::init(), ink_dns_init(), ink_hostdb_init(), register_congest_stats(), register_net_stats(), LogConfig::register_stat_callbacks(), register_stat_callbacks(), spdy_config_load(), and SSLInitializeStatistics().

int RecSetGlobalRawStatCount	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t	data
	)

Definition at line 793 of file RecProcess.cc.

References RecRawStat::count, and RecRawStatBlock::global.

Referenced by aio_stats_cb().

int RecSetGlobalRawStatSum	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t	data
	)

Definition at line 786 of file RecProcess.cc.

References RecRawStatBlock::global, and RecRawStat::sum.

Referenced by aio_stats_cb(), cache_stats_bytes_used_cb(), and TSStatIntSet().

int RecSetRawStatBlock	(	RecRawStatBlock *	rsb,
		RecRawStat *	stat_array
	)

Definition at line 725 of file RecProcess.cc.

int RecSetRawStatCount	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t	data
	)

Definition at line 717 of file RecProcess.cc.

References RecRawStat::count, RecRawStatBlock::global, and raw_stat_clear_count().

Referenced by Log::init(), and LogConfig::update_space_used().

int RecSetRawStatSum	(	RecRawStatBlock *	rsb,
		int	id,
		int64_t	data
	)

Definition at line 709 of file RecProcess.cc.

References RecRawStatBlock::global, raw_stat_clear_sum(), and RecRawStat::sum.

Referenced by Log::init(), and LogConfig::update_space_used().

I_RecProcess.h File Reference

Defines

Functions

Detailed Description

License

Define Documentation

Function Documentation