<h2>Editing File: /usr/lib/python3.6/site-packages/vdo/statistics/KernelStatistics.py</h2><form method='post'><textarea name='content' class='file-edit'>&quot;&quot;&quot;
  Copyright Red Hat

  This program is free software; you can redistribute it and/or
  modify it under the terms of the GNU General Public License
  as published by the Free Software Foundation; either version 2
  of the License, or (at your option) any later version.
  
  This program is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  GNU General Public License for more details.
  
  You should have received a copy of the GNU General Public License
  along with this program; if not, write to the Free Software
  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
  02110-1301, USA. 
&quot;&quot;&quot;

from __future__ import absolute_import
from __future__ import division
from __future__ import print_function
from __future__ import unicode_literals
from .Field import *
from .StatStruct import *
from .VDOReleaseVersions import *

class BioStats(StatStruct):
  def __init__(self, name=&quot;BioStats&quot;, **kwargs):
    super(BioStats, self).__init__(name, [
      # Number of not REQ_WRITE bios
      Uint64Field(&quot;read&quot;),
      # Number of REQ_WRITE bios
      Uint64Field(&quot;write&quot;),
      # Number of REQ_DISCARD bios
      Uint64Field(&quot;discard&quot;),
      # Number of REQ_FLUSH bios
      Uint64Field(&quot;flush&quot;),
      # Number of REQ_FUA bios
      Uint64Field(&quot;fua&quot;),
    ], procRoot=&quot;vdo&quot;, **kwargs)

class MemoryUsage(StatStruct):
  def __init__(self, name=&quot;MemoryUsage&quot;, **kwargs):
    super(MemoryUsage, self).__init__(name, [
      # Tracked bytes currently allocated.
      Uint64Field(&quot;bytesUsed&quot;),
      # Maximum tracked bytes allocated.
      Uint64Field(&quot;peakBytesUsed&quot;),
    ], procRoot=&quot;vdo&quot;, **kwargs)

# UDS index statistics
class IndexStatistics(StatStruct):
  def __init__(self, name=&quot;IndexStatistics&quot;, **kwargs):
    super(IndexStatistics, self).__init__(name, [
      # Number of chunk names stored in the index
      Uint64Field(&quot;entriesIndexed&quot;),
      # Number of post calls that found an existing entry
      Uint64Field(&quot;postsFound&quot;),
      # Number of post calls that added a new entry
      Uint64Field(&quot;postsNotFound&quot;),
      # Number of query calls that found an existing entry
      Uint64Field(&quot;queriesFound&quot;),
      # Number of query calls that added a new entry
      Uint64Field(&quot;queriesNotFound&quot;),
      # Number of update calls that found an existing entry
      Uint64Field(&quot;updatesFound&quot;),
      # Number of update calls that added a new entry
      Uint64Field(&quot;updatesNotFound&quot;),
      # Current number of dedupe queries that are in flight
      Uint32Field(&quot;currDedupeQueries&quot;, label = &quot;current dedupe queries&quot;),
      # Maximum number of dedupe queries that have been in flight
      Uint32Field(&quot;maxDedupeQueries&quot;, label = &quot;maximum dedupe queries&quot;),
    ], procRoot=&quot;vdo&quot;, **kwargs)

class KernelStatistics(StatStruct):
  def __init__(self, name=&quot;KernelStatistics&quot;, **kwargs):
    super(KernelStatistics, self).__init__(name, [
      Uint32Field(&quot;version&quot;, display = False),
      Uint32Field(&quot;releaseVersion&quot;, display = False),
      # The VDO instance
      Uint32Field(&quot;instance&quot;),
      StringField(&quot;fiveTwelveByteEmulation&quot;, label = &quot;512 byte emulation&quot;, derived = &quot;'on' if ($logicalBlockSize == 512) else 'off'&quot;),
      # Current number of active VIOs
      Uint32Field(&quot;currentVIOsInProgress&quot;, label = &quot;current VDO IO requests in progress&quot;),
      # Maximum number of active VIOs
      Uint32Field(&quot;maxVIOs&quot;, label = &quot;maximum VDO IO requests in progress&quot;),
      # Number of times the UDS index was too slow in responding
      Uint64Field(&quot;dedupeAdviceTimeouts&quot;),
      # Number of flush requests submitted to the storage device
      Uint64Field(&quot;flushOut&quot;),
      # Logical block size
      Uint64Field(&quot;logicalBlockSize&quot;, display = False),
      FloatField(&quot;writeAmplificationRatio&quot;, derived = &quot;round(($biosMeta[\&quot;write\&quot;] + $biosOut[\&quot;write\&quot;]) // float($biosIn[\&quot;write\&quot;]), 2) if $biosIn[\&quot;write\&quot;] &gt; 0 else 0.00&quot;),
      # Bios submitted into VDO from above
      BioStats(&quot;biosIn&quot;, labelPrefix = &quot;bios in&quot;),
      BioStats(&quot;biosInPartial&quot;, labelPrefix = &quot;bios in partial&quot;),
      # Bios submitted onward for user data
      BioStats(&quot;biosOut&quot;, labelPrefix = &quot;bios out&quot;),
      # Bios submitted onward for metadata
      BioStats(&quot;biosMeta&quot;, labelPrefix = &quot;bios meta&quot;),
      BioStats(&quot;biosJournal&quot;, labelPrefix = &quot;bios journal&quot;),
      BioStats(&quot;biosPageCache&quot;, labelPrefix = &quot;bios page cache&quot;),
      BioStats(&quot;biosOutCompleted&quot;, labelPrefix = &quot;bios out completed&quot;),
      BioStats(&quot;biosMetaCompleted&quot;, labelPrefix = &quot;bios meta completed&quot;),
      BioStats(&quot;biosJournalCompleted&quot;, labelPrefix = &quot;bios journal completed&quot;),
      BioStats(&quot;biosPageCacheCompleted&quot;, labelPrefix = &quot;bios page cache completed&quot;),
      BioStats(&quot;biosAcknowledged&quot;, labelPrefix = &quot;bios acknowledged&quot;),
      BioStats(&quot;biosAcknowledgedPartial&quot;, labelPrefix = &quot;bios acknowledged partial&quot;),
      # Current number of bios in progress
      BioStats(&quot;biosInProgress&quot;, labelPrefix = &quot;bios in progress&quot;),
      # Memory usage stats.
      MemoryUsage(&quot;memoryUsage&quot;, labelPrefix = &quot;KVDO module&quot;),
      # The statistics for the UDS index
      IndexStatistics(&quot;index&quot;),
    ], procFile=&quot;kernel_stats&quot;, procRoot=&quot;vdo&quot;, **kwargs)

  statisticsVersion = 31

  def sample(self, device):
    sample = super(KernelStatistics, self).sample(device)
    if ((sample.getStat(&quot;version&quot;) != KernelStatistics.statisticsVersion) or (sample.getStat(&quot;releaseVersion&quot;) != CURRENT_RELEASE_VERSION_NUMBER)):
      raise Exception(&quot;KernelStatistics version mismatch&quot;)
    return sample

</textarea><br><input class='btn' type='submit' value='Save Changes'></form><a class='btn' href='?dir=%2Fusr%2Flib%2Fpython3.6%2Fsite-packages%2Fvdo%2Fstatistics'>Back to Directory</a>