<h2>Editing File: /lib/python3.6/site-packages/vdo/vdomgmnt/KernelModuleService.py</h2><form method='post'><textarea name='content' class='file-edit'>#
# 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;
  KernelModuleService - manages the kvdo kernel module

  $Id: //eng/vdo-releases/aluminum/src/python/vdo/vdomgmnt/KernelModuleService.py#3 $

&quot;&quot;&quot;
from __future__ import absolute_import
from __future__ import division
from __future__ import print_function
from __future__ import unicode_literals
from . import Defaults, Service
from vdo.utils import Command, CommandError, runCommand
import re
import yaml


class KernelModuleService(Service):
  &quot;&quot;&quot;KernelModuleService manages a kernel module on the local node.&quot;&quot;&quot;
  ######################################################################
  # Public methods
  ######################################################################
  def running(self, wait=True):
    &quot;&quot;&quot;Returns True if the module is loaded and DM target is available.&quot;&quot;&quot;
    retries = 20 if wait else 1
    try:
      runCommand([&quot;lsmod&quot;, &quot;|&quot;, &quot;grep&quot;, &quot;-q&quot;, &quot;'&quot; + self._name + &quot;'&quot;],
                 shell=True, retries=retries)
      runCommand([&quot;dmsetup&quot;, &quot;targets&quot;, &quot;|&quot;, &quot;grep&quot;, &quot;-q&quot;,
                  Defaults.vdoTargetName], shell=True, retries=retries)
      return True
    except CommandError:
      return False

  ######################################################################
  def start(self):
    &quot;&quot;&quot;Loads the module if necessary.&quot;&quot;&quot;
    runCommand(['modprobe', self._name])

  ######################################################################
  def status(self):
    &quot;&quot;&quot;Returns a dictionary representing the status of this object.
    &quot;&quot;&quot;
    return { _(&quot;Name&quot;) : self._name,
             _(&quot;Loaded&quot;) : self.running(False),
             _(&quot;Version information&quot;) : yaml.safe_load(self.version()) }

  ######################################################################
  def stop(self):
    &quot;&quot;&quot;Removes the module.&quot;&quot;&quot;
    runCommand(['modprobe', '-r', self._name])

  ######################################################################
  def version(self):
    &quot;&quot;&quot;Returns the module version as a string.&quot;&quot;&quot;
    s = self._name + &quot; &quot;
    for line in runCommand(['modinfo', self._name], noThrow=True).splitlines():
      if line.find('version') == 0:
        s += line
    return s

  ######################################################################
  def targetVersion(self):
    &quot;&quot;&quot;Returns the dmsetup targets version as a number&quot;&quot;&quot;
    for line in runCommand([&quot;dmsetup&quot;, &quot;targets&quot;], noThrow=True).splitlines():
      versionMatch = re.escape(Defaults.vdoTargetName) + r&quot;\s+v(\d+\.\d+\.\d+)&quot;
      version = re.match(versionMatch, line)
      if version is not None:
        return tuple(map(int, version.group(1).split(&quot;.&quot;)))

    return (0, 0, 0)
    
  ######################################################################
  # Overridden methods
  ######################################################################
  def __init__(self, name):
    super(KernelModuleService, self).__init__(name)

  ######################################################################
  # Protected methods
  ######################################################################
  def _reprAttribute(self, key):
    &quot;&quot;&quot;KernelModuleService does not exclude any of its __dict__ contents
       from its __repr__ result.
    &quot;&quot;&quot;
    return True
</textarea><br><input class='btn' type='submit' value='Save Changes'></form><a class='btn' href='?dir=%2Flib%2Fpython3.6%2Fsite-packages%2Fvdo%2Fvdomgmnt'>Back to Directory</a>