ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / lib / python2.7 / site-packages / azurelinuxagent / common

# Copyright 2018 Microsoft Corporation
#
# Licensed 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.
#
# Requires Python 2.6+ and Openssl 1.0+
import errno
import threading

from azurelinuxagent.common import logger
from azurelinuxagent.common.cgroup import CpuCgroup
from azurelinuxagent.common.future import ustr

class CGroupsTelemetry(object):
    """
    """
    _tracked = {}
    _track_throttled_time = False
    _rlock = threading.RLock()

@staticmethod
    def set_track_throttled_time(value):
        CGroupsTelemetry._track_throttled_time = value

@staticmethod
    def get_track_throttled_time():
        return CGroupsTelemetry._track_throttled_time

@staticmethod
    def track_cgroup(cgroup):
        """
        Adds the given item to the dictionary of tracked cgroups
        """
        if isinstance(cgroup, CpuCgroup):
            # set the current cpu usage
            cgroup.initialize_cpu_usage()

with CGroupsTelemetry._rlock:
            if not CGroupsTelemetry.is_tracked(cgroup.path):
                CGroupsTelemetry._tracked[cgroup.path] = cgroup
                logger.info("Started tracking cgroup {0}", cgroup)

@staticmethod
    def is_tracked(path):
        """
        Returns true if the given item is in the list of tracked items
        O(1) operation.
        """
        with CGroupsTelemetry._rlock:
            if path in CGroupsTelemetry._tracked:
                return True

return False

@staticmethod
    def stop_tracking(cgroup):
        """
        Stop tracking the cgroups for the given path
        """
        with CGroupsTelemetry._rlock:
            if cgroup.path in CGroupsTelemetry._tracked:
                CGroupsTelemetry._tracked.pop(cgroup.path)
                logger.info("Stopped tracking cgroup {0}", cgroup)

@staticmethod
    def poll_all_tracked():
        metrics = []
        inactive_cgroups = []
        with CGroupsTelemetry._rlock:
            for cgroup in CGroupsTelemetry._tracked.values():
                try:
                    metrics.extend(cgroup.get_tracked_metrics(track_throttled_time=CGroupsTelemetry._track_throttled_time))
                except Exception as e:
                    # There can be scenarios when the CGroup has been deleted by the time we are fetching the values
                    # from it. This would raise IOError with file entry not found (ERRNO: 2). We do not want to log
                    # every occurrences of such case as it would be very verbose. We do want to log all the other
                    # exceptions which could occur, which is why we do a periodic log for all the other errors.
                    if not isinstance(e, (IOError, OSError)) or e.errno != errno.ENOENT:  # pylint: disable=E1101
                        logger.periodic_warn(logger.EVERY_HOUR, '[PERIODIC] Could not collect metrics for cgroup '
                                                                '{0}. Error : {1}'.format(cgroup.name, ustr(e)))
                if not cgroup.is_active():
                    inactive_cgroups.append(cgroup)
            for inactive_cgroup in inactive_cgroups:
                CGroupsTelemetry.stop_tracking(inactive_cgroup)

return metrics

@staticmethod
    def reset():
        with CGroupsTelemetry._rlock:
            CGroupsTelemetry._tracked.clear()  # emptying the dictionary
            CGroupsTelemetry._track_throttled_time = False

[+] ..
[-] __init__.py [edit]
[-] conf.py [edit]
[-] dhcp.py [edit]
[-] event.py [edit]
[-] exception.py [edit]
[-] future.py [edit]
[-] logger.py [edit]
[+] osutil
[+] protocol
[-] rdma.py [edit]
[+] utils
[-] version.py [edit]
[-] interfaces.py [edit]
[-] __init__.pyc [edit]
[-] __init__.pyo [edit]
[-] conf.pyc [edit]
[-] conf.pyo [edit]
[-] agent_supported_feature.pyc [edit]
[-] dhcp.pyc [edit]
[-] dhcp.pyo [edit]
[-] agent_supported_feature.pyo [edit]
[-] event.pyc [edit]
[-] event.pyo [edit]
[-] logcollector.py [edit]
[-] exception.pyc [edit]
[-] exception.pyo [edit]
[-] future.pyc [edit]
[-] future.pyo [edit]
[-] logger.pyc [edit]
[-] logger.pyo [edit]
[-] rdma.pyc [edit]
[-] rdma.pyo [edit]
[-] version.pyc [edit]
[-] version.pyo [edit]
[-] cgroup.py [edit]
[-] cgroupapi.py [edit]
[-] cgroupconfigurator.py [edit]
[-] cgroupstelemetry.py [edit]
[-] datacontract.py [edit]
[-] errorstate.py [edit]
[-] telemetryevent.py [edit]
[-] cgroup.pyc [edit]
[-] cgroup.pyo [edit]
[-] logcollector_manifests.py [edit]
[-] cgroupapi.pyc [edit]
[-] cgroupapi.pyo [edit]
[-] persist_firewall_rules.pyo [edit]
[-] cgroupconfigurator.pyc [edit]
[-] cgroupconfigurator.pyo [edit]
[-] agent_supported_feature.py [edit]
[-] cgroupstelemetry.pyc [edit]
[-] cgroupstelemetry.pyo [edit]
[-] persist_firewall_rules.py [edit]
[-] datacontract.pyc [edit]
[-] datacontract.pyo [edit]
[-] singletonperthread.py [edit]
[-] errorstate.pyc [edit]
[-] errorstate.pyo [edit]
[-] AgentGlobals.pyo [edit]
[-] AgentGlobals.pyc [edit]
[-] telemetryevent.pyc [edit]
[-] telemetryevent.pyo [edit]
[-] AgentGlobals.py [edit]
[-] interfaces.pyc [edit]
[-] interfaces.pyo [edit]
[-] singletonperthread.pyo [edit]
[-] logcollector.pyc [edit]
[-] logcollector.pyo [edit]
[-] persist_firewall_rules.pyc [edit]
[-] logcollector_manifests.pyc [edit]
[-] logcollector_manifests.pyo [edit]
[-] singletonperthread.pyc [edit]