Revert "remove cinder-rtstool because of rtslib dep"
This reverts commitb66c3361be. Dependencies of this code (rtslib-fb) are now Apache-licensed, which resolves the previous issue with this code being in-tree. This patch is a direct revert, other patches will follow to line up changes that have occurred betweenb66c336and now. Conflicts: setup.py Blueprint: lio-rtslib Change-Id: I14786bddf419d98ff7c468b185462f5387dbbba1
This commit is contained in:
Eric Harney
parent
caba8c0860
commit
2f197f33ed
|
|
@ -0,0 +1,238 @@
|
|||
#!/usr/bin/env python
|
||||
# vim: et tabstop=4 shiftwidth=4 softtabstop=4
|
||||
|
||||
# Copyright 2012 - 2013 Red Hat, Inc.
|
||||
# All Rights Reserved.
|
||||
#
|
||||
# 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.
|
||||
|
||||
import gettext
|
||||
import re
|
||||
import sys
|
||||
|
||||
import rtslib
|
||||
|
||||
gettext.install('cinder-rtstool', unicode=1)
|
||||
|
||||
|
||||
class RtstoolError(Exception):
|
||||
pass
|
||||
|
||||
|
||||
class RtstoolImportError(RtstoolError):
|
||||
pass
|
||||
|
||||
|
||||
def create(backing_device, name, userid, password, initiator_iqns=None):
|
||||
try:
|
||||
rtsroot = rtslib.root.RTSRoot()
|
||||
except rtslib.utils.RTSLibError:
|
||||
print _('Ensure that configfs is mounted at /sys/kernel/config.')
|
||||
raise
|
||||
|
||||
# Look to see if BlockStorageObject already exists
|
||||
for x in rtsroot.storage_objects:
|
||||
if x.dump()['name'] == name:
|
||||
# Already exists, use this one
|
||||
return
|
||||
|
||||
so_new = rtslib.BlockStorageObject(name=name,
|
||||
dev=backing_device)
|
||||
|
||||
target_new = rtslib.Target(rtslib.FabricModule('iscsi'), name, 'create')
|
||||
|
||||
tpg_new = rtslib.TPG(target_new, mode='create')
|
||||
tpg_new.set_attribute('authentication', '1')
|
||||
|
||||
lun_new = rtslib.LUN(tpg_new, storage_object=so_new)
|
||||
|
||||
initiator_name = None
|
||||
name_file = '/etc/iscsi/initiatorname.iscsi'
|
||||
|
||||
try:
|
||||
with open(name_file, 'r') as f:
|
||||
for line in f:
|
||||
m = re.match('InitiatorName=(.+)', line)
|
||||
if m != None:
|
||||
initiator_name = m.group(1)
|
||||
break
|
||||
except IOError:
|
||||
raise RtstoolError(_('Could not open %s') % name_file)
|
||||
|
||||
if initiator_name == None:
|
||||
raise RtstoolError(_('Could not read InitiatorName from %s') %
|
||||
name_file)
|
||||
|
||||
acl_new = rtslib.NodeACL(tpg_new, initiator_name, mode='create')
|
||||
|
||||
acl_new.chap_userid = userid
|
||||
acl_new.chap_password = password
|
||||
|
||||
rtslib.MappedLUN(acl_new, lun_new.lun, lun_new.lun)
|
||||
|
||||
if initiator_iqns:
|
||||
initiator_iqns = initiator_iqns.strip(' ')
|
||||
for i in initiator_iqns.split(','):
|
||||
acl_new = rtslib.NodeACL(tpg_new, i, mode='create')
|
||||
acl_new.chap_userid = userid
|
||||
acl_new.chap_password = password
|
||||
|
||||
rtslib.MappedLUN(acl_new, lun_new.lun, lun_new.lun)
|
||||
|
||||
tpg_new.enable = 1
|
||||
|
||||
try:
|
||||
rtslib.NetworkPortal(tpg_new, '0.0.0.0', 3260, mode='any')
|
||||
except rtslib.utils.RTSLibError:
|
||||
print _('Error creating NetworkPortal: ensure port 3260 '
|
||||
'is not in use by another service.')
|
||||
raise
|
||||
|
||||
try:
|
||||
rtslib.NetworkPortal(tpg_new, '::0', 3260, mode='any')
|
||||
except rtslib.utils.RTSLibError:
|
||||
# TODO(emh): Binding to IPv6 fails sometimes -- let pass for now.
|
||||
pass
|
||||
|
||||
|
||||
def add_initiator(target_iqn, initiator_iqn, userid, password):
|
||||
try:
|
||||
rtsroot = rtslib.root.RTSRoot()
|
||||
except rtslib.utils.RTSLibError:
|
||||
print _('Ensure that configfs is mounted at /sys/kernel/config.')
|
||||
raise
|
||||
|
||||
# Look for the target
|
||||
target = None
|
||||
for t in rtsroot.targets:
|
||||
if t.dump()['wwn'] == target_iqn:
|
||||
target = t
|
||||
break
|
||||
if target == None:
|
||||
raise RtstoolError(_('Could not find target %s') % target_iqn)
|
||||
|
||||
tpg = target.tpgs.next() # get the first one
|
||||
for acl in tpg.dump()['node_acls']:
|
||||
# See if this ACL configuration already exists
|
||||
if acl['node_wwn'] == initiator_iqn:
|
||||
# No further action required
|
||||
return
|
||||
|
||||
acl_new = rtslib.NodeACL(tpg, initiator_iqn, mode='create')
|
||||
acl_new.chap_userid = userid
|
||||
acl_new.chap_password = password
|
||||
|
||||
rtslib.MappedLUN(acl_new, 0, tpg_lun=0)
|
||||
|
||||
|
||||
def get_targets():
|
||||
rtsroot = rtslib.root.RTSRoot()
|
||||
for x in rtsroot.targets:
|
||||
print(x.dump()['wwn'])
|
||||
|
||||
|
||||
def delete(iqn):
|
||||
rtsroot = rtslib.root.RTSRoot()
|
||||
for x in rtsroot.targets:
|
||||
if x.dump()['wwn'] == iqn:
|
||||
x.delete()
|
||||
break
|
||||
|
||||
for x in rtsroot.storage_objects:
|
||||
if x.dump()['name'] == iqn:
|
||||
x.delete()
|
||||
break
|
||||
|
||||
|
||||
def verify_rtslib():
|
||||
for member in ['BlockStorageObject', 'FabricModule', 'LUN',
|
||||
'MappedLUN', 'NetworkPortal', 'NodeACL', 'root',
|
||||
'Target', 'TPG']:
|
||||
if not hasattr(rtslib, member):
|
||||
raise RtstoolImportError(_("rtslib is missing member %s: "
|
||||
"You may need a newer python-rtslib.") %
|
||||
member)
|
||||
|
||||
|
||||
def usage():
|
||||
print "Usage:"
|
||||
print sys.argv[0], \
|
||||
"create [device] [name] [userid] [password]", \
|
||||
"<initiator_iqn,iqn2,iqn3,...>"
|
||||
print sys.argv[0], \
|
||||
"add-initiator [target_iqn] [userid] [password] [initiator_iqn]"
|
||||
print sys.argv[0], "get-targets"
|
||||
print sys.argv[0], "delete [iqn]"
|
||||
print sys.argv[0], "verify"
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def main(argv=None):
|
||||
if argv is None:
|
||||
argv = sys.argv
|
||||
|
||||
if len(argv) < 2:
|
||||
usage()
|
||||
|
||||
if argv[1] == 'create':
|
||||
if len(argv) < 6:
|
||||
usage()
|
||||
|
||||
if len(argv) > 7:
|
||||
usage()
|
||||
|
||||
backing_device = argv[2]
|
||||
name = argv[3]
|
||||
userid = argv[4]
|
||||
password = argv[5]
|
||||
initiator_iqns = None
|
||||
|
||||
if len(argv) > 6:
|
||||
initiator_iqns = argv[6]
|
||||
|
||||
create(backing_device, name, userid, password, initiator_iqns)
|
||||
|
||||
elif argv[1] == 'add-initiator':
|
||||
if len(argv) < 6:
|
||||
usage()
|
||||
|
||||
target_iqn = argv[2]
|
||||
userid = argv[3]
|
||||
password = argv[4]
|
||||
initiator_iqn = argv[5]
|
||||
|
||||
add_initiator(target_iqn, initiator_iqn, userid, password)
|
||||
|
||||
elif argv[1] == 'get-targets':
|
||||
get_targets()
|
||||
|
||||
elif argv[1] == 'delete':
|
||||
if len(argv) < 3:
|
||||
usage()
|
||||
|
||||
iqn = argv[2]
|
||||
delete(iqn)
|
||||
|
||||
elif argv[1] == 'verify':
|
||||
# This is used to verify that this script can be called by cinder,
|
||||
# and that rtslib is new enough to work.
|
||||
verify_rtslib()
|
||||
return 0
|
||||
|
||||
else:
|
||||
usage()
|
||||
|
||||
return 0
|
||||
|
||||
if __name__ == '__main__':
|
||||
sys.exit(main())
|
||||
Loading…
Reference in New Issue