Coverage for drivers/tapdisk-pause: 47%

Hot-keys on this page

r m x p toggle line displays

j k next/prev highlighted chunk

0 (zero) top of page

1 (one) first highlighted chunk

1#!/usr/bin/python3

3# Copyright (C) Citrix Systems Inc.

5# This program is free software; you can redistribute it and/or modify

6# it under the terms of the GNU Lesser General Public License as published

7# by the Free Software Foundation; version 2.1 only.

9# This program is distributed in the hope that it will be useful,

10# but WITHOUT ANY WARRANTY; without even the implied warranty of

11# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

12# GNU Lesser General Public License for more details.

13#

14# You should have received a copy of the GNU Lesser General Public License

15# along with this program; if not, write to the Free Software Foundation, Inc.,

16# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA

17#

18# Pause/unpause tapdisk on the local host

20import os

21import sys

22import XenAPIPlugin

23sys.path.append("/opt/xensource/sm/")

24import blktap2, util

25from lock import Lock

26import xs_errors

27import XenAPI

28import lvmcache

29import VDI

31from constants import NS_PREFIX_LVM, VG_PREFIX

32from cowutil import getCowUtil

33from lvmcowutil import LV_PREFIX, LV_PREFIX_TO_VDI_TYPE, LvmCowUtil

35try:

36 from linstorcowutil import LinstorCowUtil

37 from linstorvolumemanager import get_controller_uri, LinstorVolumeManager

38 LINSTOR_AVAILABLE = True

39except ImportError:

40 LINSTOR_AVAILABLE = False

42TAPDEV_BACKPATH_PFX = "/dev/sm/backend"

43TAPDEV_PHYPATH_PFX = "/dev/sm/phy"

46def locking(excType, override=True):

47 def locking2(op):

48 def wrapper(self, *args):

49 if self.failfast: 49 ↛ 50line 49 didn't jump to line 50, because the condition on line 49 was never true

50 if not self.lock.acquireNoblock():

51 raise xs_errors.XenError(excType,

52 opterr='VDI already locked')

53 else:

54 self.lock.acquire()

55 try:

56 try:

57 ret = op(self, *args)

58 except (util.SMException, XenAPI.Failure) as e:

59 util.logException("TAP-PAUSE:%s" % op)

60 msg = str(e)

61 if isinstance(e, util.CommandException):

62 msg = "Command %s failed (%s): %s" % \

63 (e.cmd, e.code, e.reason)

64 if override:

65 raise xs_errors.XenError(excType, opterr=msg)

66 else:

67 raise

68 except:

69 util.logException("TAP-PAUSE:%s" % op)

70 raise

71 finally:

72 self.lock.release() 72 ↛ exitline 72 didn't except from function 'wrapper', because the raise on line 65 wasn't executed or the raise on line 67 wasn't executed or the raise on line 70 wasn't executed

73 return ret

74 return wrapper

75 return locking2

77def _getDevMajor_minor(dev):

78 st = os.stat(dev)

79 return [os.major(st.st_rdev),os.minor(st.st_rdev)]

81def _mkphylink(sr_uuid, vdi_uuid, path):

82 sympath = "/dev/sm/phy/%s/%s" % (sr_uuid,vdi_uuid)

83 cmd = ['ln', '-sf', path, sympath]

84 util.pread2(cmd)

85 return path

87def tapPause(session, args):

88 tap = Tapdisk(session, args)

89 return tap.Pause()

91def tapUnpause(session, args):

92 tap = Tapdisk(session, args)

93 return tap.Unpause()

95def tapRefresh(session, args):

96 tap = Tapdisk(session, args)

97 if tap.Pause() != "True": 97 ↛ 98line 97 didn't jump to line 98, because the condition on line 97 was never true

98 return str(False)

99 return tap.Unpause()

100

101

102class Tapdisk:

103 def __init__(self, session, args):

104 self.sr_uuid = args["sr_uuid"]

105 self.vdi_uuid = args["vdi_uuid"]

106 # Tells whether the lock must be acquired in a non-blocking manner.

107 if 'failfast' in args: 107 ↛ 108line 107 didn't jump to line 108, because the condition on line 107 was never true

108 self.failfast = eval(args['failfast'])

109 else:

110 self.failfast = False

111 self.session = session

112 self.path = os.path.join(TAPDEV_BACKPATH_PFX,self.sr_uuid,self.vdi_uuid)

113 self.phypath = os.path.join(TAPDEV_PHYPATH_PFX,self.sr_uuid,self.vdi_uuid)

114 self.lock = Lock("vdi", self.vdi_uuid)

115 self.realpath = None

116 self.vdi_type = None

117 self.secondary = None

118 if "secondary" in args: 118 ↛ 119line 118 didn't jump to line 119, because the condition on line 118 was never true

119 self.secondary = args["secondary"]

120 self.activate_parents = False

121 if args.get("activate_parents") == "true": 121 ↛ 122line 121 didn't jump to line 122, because the condition on line 121 was never true

122 self.activate_parents = True

123

124 def _pathRefresh(self):

125 # LVM rename check

126 try:

127 realpath = os.readlink(self.phypath)

128 except OSError as e:

129 util.SMlog("Phypath %s does not exist" % self.phypath)

130 return

131 util.SMlog("Realpath: %s" % realpath)

132 if realpath.startswith("/dev/VG_XenStorage-") and \ 132 ↛ 134line 132 didn't jump to line 134, because the condition on line 132 was never true

133 not os.path.exists(realpath):

134 util.SMlog("Path inconsistent")

135 pfx = "/dev/VG_XenStorage-%s/" % self.sr_uuid

136 for ty in LV_PREFIX.values():

137 p = pfx + ty + self.vdi_uuid

138 util.SMlog("Testing path: %s" % p)

139 if os.path.exists(p):

140 _mkphylink(self.sr_uuid, self.vdi_uuid, p)

141 self.realpath = p

142 self.vdi_type = LV_PREFIX_TO_VDI_TYPE[ty]

143 elif realpath.startswith('/dev/drbd/by-res/xcp-volume-'): 143 ↛ 144line 143 didn't jump to line 144, because the condition on line 143 was never true

144 if not LINSTOR_AVAILABLE:

145 raise util.SMException(

146 'Can\'t refresh tapdisk: LINSTOR libraries are missing'

147 )

148

149 # We must always recreate the symlink to ensure we have

150 # the right info. Why? Because if the volume UUID is changed in

151 # LINSTOR the symlink is not directly updated. When live leaf

152 # coalesce is executed we have these steps:

153 # "A" -> "OLD_A"

154 # "B" -> "A"

155 # Without symlink update the previous "A" path is reused instead of