caproto.server.stats.PeriodicStatusHelper

class caproto.server.stats.PeriodicStatusHelper(*args, **kwargs)

An IocStats-like tool for caproto IOCs. Includes values which update on a periodic basis (update_period, PV UPD_TIME).

PeriodicStatusHelper pvproperties

Attribute	Suffix	Docs	Type	Notes	Alarm Group
access	ACCESS	CA Security access level to this IOC	ENUM (mbbo)
ca_client_count	CA_CLNT_CNT	Number of CA clients [not implemented]	int (longin)	Read-only
ca_connection_count	CA_CONN_CNT	Number of CA Connections [not implemented]	int (longin)	Read-only
fd_count	FD_CNT	Allocated File Descriptors	int (ai)	Read-only
fd_free	FD_FREE	Available FDs	int (calc)	Read-only
fd_max	FD_MAX	Max File Descriptors	int (ai)	Read-only
heartbeat	HEARTBEAT	1 Hz counter since startup	int (calcout)	Read-only
ioc_cpu_load	IOC_CPU_LOAD		float (ai)	Read-only
mem_free	MEM_FREE	Memory free (including swap).	int (ai)	Read-only
mem_max	MEM_MAX		int (ai)	Read-only
mem_used	MEM_USED	Memory used.	int (ai)	Read-only
num_threads	NumThreads	Number of threads in use	int (longin)	Read-only
record_count	RECORD_CNT	Number of records	int (ai)	Read-only
start_count	START_CNT	Startup count, if autosave is working	int (calcout)	Read-only Startup
start_tod	STARTTOD	Time and date of startup	str (stringin)	Read-only Length(100) Startup
susp_task_count	SUSP_TASK_CNT	Number of Suspended Tasks [not implemented]	int (longin)	Read-only
sys_cpu_load	SYS_CPU_LOAD	CPU load	float (ai)	Read-only
time_of_day	TOD	Current time and date	str (stringin)	Read-only Length(100)
update_period	UPD_TIME	Basic stats update rate	float (ao)	Startup
uptime	UPTIME	Elapsed time since start	int (longin)	Read-only

Methods

group_read(instance)	Generic read called for channels without get defined
group_write(instance, value)	Generic write called for channels without put defined

Attributes

default_values
type_map
type_map_read_only

pvproperty methods

start_count.startup(self, instance, async_lib)

@start_count.startup
async def start_count(self, instance, async_lib):
    # Give autosave some time to load
    await async_lib.library.sleep(3)
    await self.start_count.write(value=self.start_count.value + 1)

start_tod.startup(self, instance, async_lib)

@start_tod.startup
async def start_tod(self, instance, async_lib):
    await self.start_tod.write(value=str(datetime.datetime.now()))

update_period.startup(self, instance, async_lib)

Source code: update_period.startup

    @update_period.startup
    async def update_period(self, instance, async_lib):
        self._startup_time = datetime.datetime.now()
        if resource is not None:
            try:
                soft_limit, hard = resource.getrlimit(resource.RLIMIT_NOFILE)
                await self.fd_max.write(value=soft_limit)
            except Exception:
                self.log.warning('Failed to get maximum file descriptors')

        while True:
            try:
                await self._update()
            except Exception as ex:
                self.log.warning('Status update failure: %s', ex)
            await async_lib.library.sleep(self.update_period.value)