pool/tgt
SHA256
2
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
088f2f069b
tgt/tgt-0.9.0-update

1910 lines
58 KiB
Plaintext
Raw Blame History

diff --git a/README b/README
index dd99e74..22785fc 100644
--- a/README
+++ b/README
@@ -3,46 +3,53 @@ Introduction
Linux target framework (tgt) aims to simplify various SCSI target
driver (iSCSI, Fibre Channel, SRP, etc) creation and maintenance.
-Tgt consists of kernel modules, user-space daemon, and user-space
-tools. Some target drivers uses all of them and some use only
-user-space daemon and tools (i.e. they completely runs in user space).
+Currently, tgt supports the following target drivers:
-Currently, tgt supports three target drivers:
+- iSCSI software target driver for Ethernet NICs
-- IBM VIO server (ibmvstgt)
-- iSCSI
-- Xen vscsifront/back
+- iSER software target driver for Infiniband and RDMA NICs
-Note that tgt is under active development. Don't play with important
-data.
+- IBM System p VIO server
-The code is under the GNU General Public License version 2.
+- FCoE software target driver for Ethernet NICs (in progress)
+- Qlogic qla2xxx FC target driver (in progress)
-Preparation
--------------
-The iSCSI target driver can works with the 2.6.X kernels. It requires
-OpenSSL library (libssl-dev for debian, openssl-devel for Fedora).
+Tgt consists of kernel modules, user-space daemon, and user-space
+tools. iSCSI, iSER, and FCoE target drivers use only user-space daemon
+and tools (i.e. they are just user-space applications. They don't need
+any kernel support).
+
+tgt can emulate the following device types:
-host:~/tgt/usr$ make ISCSI=1
+- SBC: a virtual disk drive that can use a file to store the content.
-If you want IBM VIO target driver, get kernel version 2.6.20, rebuild
-the kernel, and reboot with the new kernel. Note you need to enable
-SCSI_TGT, SCSI_SRP, and SCSI_IBMVSCSIS kernel options.
+- SMC: a virtual media jukebox that can be controlled by the "mtx"
+tool (partially functional).
-host:~/tgt/usr$ make KERNELSRC=<kernel-src-directory> IBMVIO=1
+- MMC: a virtual DVD drive that can read DVD-ROM iso files and create
+burnable DVD+R. It can be combined with SMC to provide a fully
+operational DVD jukebox.
-Make sure that everything is built successfully.
+- SSC: a virtual tape device (aka VTL) that can use a file to store
+the content (in progress).
-Now you can run tgt. Target drivers have their own ways for
-configuration. So find an appropriate documentation in the doc
-directory.
+- OSD: a virtual object-based storage device that can use a file to
+store the content (in progress).
+
+The code is under the GNU General Public License version 2.
+
+
+Preparation
+-------------
+Target drivers have their own ways to build, configure, etc. So find
+an appropriate documentation in the doc directory.
Developer Notes
-------------
The central resource for tgt development is the mailing list
-(stgt-devel@lists.berlios.de).
+(stgt@vger.kernel.org).
First, please read the following documents (in short, follow Linux
kernel development rules):
diff --git a/doc/README.ibmvstgt b/doc/README.ibmvstgt
index 9a9dbd8..d77f932 100644
--- a/doc/README.ibmvstgt
+++ b/doc/README.ibmvstgt
@@ -1,5 +1,13 @@
Starting
-------------
+If you want IBM VIO target driver, get kernel version 2.6.20, rebuild
+the kernel, and reboot with the new kernel. Note you need to enable
+SCSI_TGT, SCSI_SRP, and SCSI_IBMVSCSIS kernel options.
+
+host:~/tgt/usr$ make KERNELSRC=<kernel-src-directory> IBMVIO=1
+
+Make sure that everything is built successfully.
+
Try the following commands:
host:~/tgt$ su
diff --git a/doc/README.iscsi b/doc/README.iscsi
index 5aec190..e6b4d09 100644
--- a/doc/README.iscsi
+++ b/doc/README.iscsi
@@ -5,6 +5,13 @@ This show a simple example to set up some targets.
Starting the daemon
-------------
+The iSCSI target driver works with the 2.6.X kernels. It requires
+OpenSSL library (libssl-dev for debian, openssl-devel for Fedora).
+
+First, you need to compile the source code:
+
+host:~/tgt/usr$ make ISCSI=1
+
Try the following commands:
host:~/tgt$ su
diff --git a/doc/targets.conf.example b/doc/targets.conf.example
new file mode 100644
index 0000000..46be8fe
--- /dev/null
+++ b/doc/targets.conf.example
@@ -0,0 +1,168 @@
+# This is a sample config file for tgt-admin.
+# By default, tgt-admin looks for its config file in /etc/tgt/targets.conf
+
+# This one includes other config files:
+
+include /etc/tgt/temp/*.conf
+
+
+# Set the driver. If not specified, defaults to "iscsi".
+
+default-driver iscsi
+
+
+# Sample target with one LUN only. Defaults to allow access for all initiators:
+
+<target iqn.2008-09.com.example:server.target1>
+ backing-store /dev/LVM/somedevice
+</target>
+
+
+# Similar, but we use "direct-store" instead of "backing-store".
+# "direct-store" reads drive parameters with sg_inq command and sets them to
+# the target.
+# Parameters fatched with sg_inq are:
+# - Vendor identification
+# - Product identification
+# - Product revision level
+# - Unit serial number (if present)
+# We also specify "incominguser".
+
+<target iqn.2008-09.com.example:server.target2>
+ direct-store /dev/sdd
+ incominguser someuser secretpass12
+</target>
+
+
+# An example with multiple LUNs, disabled write-cache (tgtd enables write-cache
+# by default) and vendor identification set to "MyVendor"
+
+<target iqn.2008-09.com.example:server.target3>
+ backing-store /dev/LVM/somedevice1 # Becomes LUN 1
+ backing-store /dev/LVM/somedevice2 # Becomes LUN 2
+ backing-store /dev/LVM/somedevice3 # Becomes LUN 3
+ write-cache off
+ vendor_id MyCompany Inc.
+</target>
+
+
+# Similar to the one above, but we fetch vendor_id, product_id, product_rev and
+# scsi_sn from the disks.
+# Vendor identification (vendor_id) is replaced in all disks by "MyVendor"
+
+<target iqn.2008-09.com.example:server.target4>
+ direct-store /dev/sdb # Becomes LUN 1
+ direct-store /dev/sdc # Becomes LUN 2
+ direct-store /dev/sdd # Becomes LUN 3
+ write-cache off
+ vendor_id MyCompany Inc.
+</target>
+
+
+# Note that "first-device-first-lun numbering" will work only for simple
+# scenarios above, where _only_ direct-store _or_ backing-store is used.
+# If you mix backing-store and direct-store, then all backing-store entries
+# are processed before direct-store-entries.
+
+<target iqn.2008-09.com.example:server.target4>
+ direct-store /dev/sdb # Becomes LUN 3
+ backing-store /dev/sdc # Becomes LUN 1
+ direct-store /dev/sdd # Becomes LUN 4
+ backing-store /dev/sde # Becomes LUN 2
+</target>
+
+
+# Even more complicated example - each device has different parameters.
+# You can use indentation to make the config file more readable.
+# Note that LUNs will be assigned more or less randomly here (and still
+# backing-store get LUNs assigned before drect-store).
+# You can specify multiple mode_page parameters (they are commented out
+# in this example).
+# Note that some parameters (write-cache, scsi_sn) were specified "globally".
+# "Global" parameters will be applied to all LUNs; they can be overwritten
+# "locally", per LUN.
+
+<target iqn.2008-09.com.example:server.target5>
+
+ <direct-store /dev/sdd>
+ vendor_id VENDOR1
+ removable 1
+ device-type cd
+ # lun 1 # Not yet supported
+ </direct-store>
+
+ <direct-store /dev/sda>
+ vendor_id VENDOR2
+ # lun 2 # Not yet supported
+ </direct-store>
+
+ <backing-store /dev/sdb1>
+ vendor_id back1
+ scsi_sn SERIAL
+ write-cache on
+ # lun 3 # Not yet supported
+ </backing-store>
+
+ <backing-store /dev/sdd1>
+ vendor_id back2
+ #mode_page 8:0:18:0x10:0:0xff....
+ #mode_page 8:0:18:0x10:0:0xff....
+ # lun 4 # Not yet supported
+ </backing-store>
+
+ # Some more parameters which can be specified locally or globally:
+ #scsi_id ...
+ #scsi_sn ...
+ #vendor_id ...
+ #product_id ...
+ #product_rev ...
+ #sense_format ...
+ #removable ...
+ #online ...
+ #path ...
+ #mode_page 8:0:18:0x10:0:0xff....
+ #mode_page 8:0:18:0x10:0:0xff....
+ #device-type
+
+ write-cache off
+ scsi_sn multipath-10
+
+ # Parameters below are global. They can't be configured per LUN.
+ # Only allow connections from 192.168.100.1 and 192.168.200.5
+ initiator-address 192.168.100.1
+ initiator-address 192.168.200.5
+
+ # Allowed incoming users
+ incominguser user1 secretpass12
+ incominguser user2 secretpass23
+
+ # Outgoing user
+ outgoinguser userA secretpassA
+
+</target>
+
+
+
+# Not supported configurations, and therefore, commented out:
+
+#<target iqn.2008-09.com.example:server.target6>
+# <direct-store /dev/sdd>
+# vendor_id VENDOR1
+# </direct-store>
+#
+# direct-store /dev/sdc
+#</target>
+
+# This one will break the parser:
+
+#<target iqn.2008-09.com.example:server.target7>
+# <direct-store /dev/sdd>
+# vendor_id VENDOR1
+# </direct-store>
+#
+# direct-store /dev/sdc
+#
+# <direct-store /dev/sdd>
+# vendor_id VENDOR1
+# </direct-store>
+#</target>
diff --git a/scripts/tgt-admin b/scripts/tgt-admin
index fe95723..e4be373 100755
--- a/scripts/tgt-admin
+++ b/scripts/tgt-admin
@@ -11,7 +11,6 @@
use strict;
use Config::General qw(ParseConfig);
-use Data::Dumper;
use Getopt::Long;
# Our config file
@@ -30,12 +29,15 @@ This tool configures tgt targets.
(see "--offline help" for more info)
--ready <value> put all or selected targets in ready state
(see "--ready help" for more info)
+ --update <value> update configuration for all or selected targets
+ (see "--update help" for more info)
-s, --show show all the targets
-c, --conf <conf file> specify an alternative configuration file
--ignore-errors continue even if tgtadm exits with non-zero code
-f, --force force some operations even if the target is in use
-p, --pretend only print tgtadm options
- --dump dump current tgtd configuration
+ --dump dump current tgtd configuration (note: does not
+ include detailed parameters, like write caching)
-v, --verbose increase verbosity (show tgtadm commands)
-h, --help show this help
@@ -49,6 +51,7 @@ my $execute = 0;
my $delete = 0;
my $offline = 0;
my $ready = 0;
+my $update = 0;
my $show = 0;
my $alternate_conf="0";
my $ignore_errors = 0;
@@ -62,6 +65,7 @@ my $result = GetOptions (
"delete=s" => \$delete,
"offline=s" => \$offline,
"ready=s" => \$ready,
+ "update=s" => \$update,
"s|show" => \$show,
"c|conf=s" => \$alternate_conf,
"ignore-errors" => \$ignore_errors,
@@ -73,7 +77,7 @@ my $result = GetOptions (
);
if (($help == 1) || ($param eq undef)) {
- &usage
+ usage;
}
# Show all the targets and exit
@@ -99,7 +103,6 @@ sub process_targets {
my @show_target = `tgtadm --op show --mode target`;
my $tid;
my $targetname;
-
# Here, we create hashes of target names (all target data) and target tids
foreach my $show_target_line (@show_target) {
if ( $show_target_line =~ m/^Target (\d*): (.+)/ ) {
@@ -128,7 +131,7 @@ sub parse_configs {
%conf = ParseConfig(-ConfigFile => "$alternate_conf", -UseApacheInclude => 1, -IncludeGlob => 1,);
}
else {
- die("file $alternate_conf not found. Exiting...\n");
+ die("Config file $alternate_conf not found. Exiting...\n");
}
} else {
# Parse the config file with Config::General
@@ -145,13 +148,17 @@ my $default_driver;
my $target;
my $option;
my $value;
+my $lun;
sub add_targets {
-
+ my $single_target = $_[0];
+ my $configured = $_[1];
+ my $connected = $_[2];
+ my $in_configfile = $_[3];
foreach my $k (sort keys %conf) {
- if ( $k eq "default-driver" ) {
- if ( not length ref($conf{$k}) ) {
+ if ($k eq "default-driver") {
+ if (not length ref($conf{$k})) {
$default_driver = $conf{$k};
} else {
print "Multiple default-driver definitions are not allowed!\n";
@@ -162,134 +169,344 @@ sub add_targets {
}
# If $default_driver is empty, default to iscsi
- if ( not defined $default_driver ) {
+ if (not defined $default_driver) {
execute("# default-driver not defined, defaulting to iscsi.\n");
$default_driver = "iscsi";
}
foreach my $k (sort keys %conf) {
- if ( $k eq "target" ) {
+ if ($k eq "target") {
foreach my $k2 (sort keys %{$conf{$k}}) {
- $target = $k2;
- my $allowall = 1;
- if ( not defined $tgtadm_output{$k2} ) {
- # We have to find available tid
- $next_tid = $next_tid + 1;
+ # Do we run update or execute?
+ if (length $single_target) {
+ if ($single_target ne $k2) {
+ next;
+ } else {
+ $target = $single_target;
+ }
+ } else {
+ $target = $k2;
}
- else {
- execute("# Target $target already exist!");
- execute("# Updating Target $target");
- execute("tgtadm --op update --mode target --tid=$next_tid -n state -v offline");
- execute("tgtadm --mode target --op delete --tid=$next_tid");
+
+ my $in_use = 0;
+ if (length $single_target) {
+ $in_use = main_delete($target);
}
+ my $allowall = 1;
+ if ((not defined $tgtadm_output{$k2}) ||
+ ($update ne 0 && $in_use == 0) ||
+ ($update ne 0 && $in_use == 1 && $pretend == 1 && $force == 1))
+ {
+ # We have to find available tid
+ if ($in_configfile == 1 && $configured == 0 && $pretend == 0) {
+ my $maxtid = find_max_tid();
+ $next_tid = $maxtid + 1;
+ } elsif (length $single_target && $configured == 1) {
+ $next_tid = $tgtadm_output_tid{$target};
+ } else {
+ $next_tid = $next_tid + 1;
+ }
+
+ # Before we add a target, we need to know its type
+ # and other parameters which can be specified globally
+ my %target_options;
+ my $target_options_ref;
+ foreach my $k3 (sort keys %{$conf{$k}{$k2}}) {
+ $lun = 1;
+ $option = $k3;
+ $value = $conf{$k}{$k2}{$k3};
+ check_value($value);
+ $target_options{$option} = $value;
+ $target_options_ref = \%target_options;
+ }
- # Before we add a target, we need to know its type
- my $driver;
- foreach my $k3 (sort keys %{$conf{$k}{$k2}}) {
- $option = $k3;
- $value = $conf{$k}{$k2}{$k3};
- &check($value);
- if ( $option eq "driver" ) {
- if (ref($value) eq "ARRAY") {
- print "Multiple driver definitions not allowed!\n";
- print "Check your config file for errors (target: $target).\n";
- exit 1;
+ if (not defined $target_options{"driver"}) {
+ $target_options{"driver"} = $default_driver;
+ }
+ my $driver = $target_options{"driver"};
+ execute("# Adding target: $target");
+ execute("tgtadm --lld $driver --op new --mode target --tid $next_tid -T $target");
+ foreach my $k3 (sort keys %{$conf{$k}{$k2}}) {
+ $option = $k3;
+ $value = $conf{$k}{$k2}{$k3};
+ check_value($value);
+ process_options($target_options_ref);
+ # If there was no option called "initiator-address", it means
+ # we want to allow ALL initiators for this target
+ if ($option eq "initiator-address") {
+ $allowall = 0;
}
- $driver = $value;
+ }
+
+ if ($allowall == 1) {
+ execute("tgtadm --lld $driver --op bind --mode target --tid $next_tid -I ALL");
+ }
+
+ } else {
+ if (not length $configured || $in_use eq 1) {
+ execute("# Target $target already exists!");
}
}
+ }
+ if (length $single_target && $in_configfile == 0 && $configured == 0) {
+ print "Target $single_target is currently not configured\n";
+ print "and does not exist in the config file - can't continue!\n";
+ exit 1;
+ }
+ execute();
+ }
+ }
+}
- if ( not defined $driver ) {
- $driver = $default_driver;
+# Some options can be specified only once
+sub check_if_hash_array {
+ my $check = $_[0];
+ my $definition = $_[1];
+ if (ref($check) eq 'ARRAY' || ref($check) eq "HASH") {
+ print "Multiple '$definition' definitions in '$option' not allowed!\n";
+ print "Check your config file for errors (target: $target).\n";
+ exit 1;
+ }
+}
+
+# Force an array if we just have one command
+sub force_array {
+ unless (ref($value) eq 'ARRAY') {
+ $value = [ $value ];
+ }
+}
+
+# If we start any external command, we want to know if it exists
+sub check_exe {
+ my $command = $_[0];
+ my $option = $_[1];
+ my @path = split(":", $ENV{PATH});
+ my $exists = 0;
+ foreach my $path (@path) {
+ if ( -x "$path/$command" && -f "$path/$command" ) { $exists = 1 }
+ }
+ if ( $exists == 0 ) {
+ print "Command $command (needed by $option option in your config file) is not in your path - can't continue!\n";
+ exit 1;
+ }
+}
+
+# Apply additional parameters
+sub add_params {
+ my $param = shift;
+ my $param_value = shift;
+ my $lun = shift;
+ my $driver = shift;
+
+ if ($param eq "write-cache") {
+ if ($param_value eq "off") {
+ return("tgtadm --lld $driver --op update --mode logicalunit --tid $next_tid --lun=$lun --params mode_page=8:0:18:0x10:0:0xff:0xff:0:0:0xff:0xff:0xff:0xff:0x80:0x14:0:0:0:0:0:0");
+ } elsif ($param_value eq "on" || not length $param_value) {
+ return("# Write cache is enabled (default) for lun $lun.");
+ } else {
+ return("# WARNING! Unknown value ($param_value) to write-cache! Accepted values are \"on\" and \"off\".");
+ }
+ }
+
+ if ($param eq "scsi_id" || $param eq "scsi_sn" || $param eq "vendor_id" || $param eq "product_id" ||
+ $param eq "product_rev" || $param eq "sense_format" || $param eq "removable" || $param eq "online" ||
+ $param eq "path" || $param eq "mode_page") {
+ return("tgtadm --lld $driver --op update --mode logicalunit --tid $next_tid --lun=$lun --params $param=\"$param_value\"");
+ }
+}
+
+# Add backing or direct store
+sub add_backing_direct {
+ my $backing_store = $_[0];
+ my $target_options_ref = $_[1];
+ my $lun = $_[2];
+ my $direct_store = $_[3];
+ my $driver = $$target_options_ref{"driver"};
+
+ # Is the device in use?
+ (my $can_alloc, my $dev) = check_device($backing_store);
+
+ # Needed if the config file has mixed definitions
+ if (ref($backing_store) eq "HASH") {
+ foreach my $backing_store (sort keys %$value) {
+ add_backing_direct($backing_store,$target_options_ref,$lun,$direct_store);
+ $lun += 1;
+ }
+ return $lun;
+ } elsif (-e $backing_store && $can_alloc == 1) {
+ my @exec_commands;
+ my $device_type;
+ # Process parameters for each lun / backing store
+ if (ref $value eq "HASH") {
+ my %params_added;
+ my @mode_page;
+ foreach my $store (keys %$value) {
+ if (ref $$value{$store} eq "HASH" && $store eq $backing_store) {
+ foreach my $store_option (keys %{$$value{$store}}) {
+ my $result = $$value{$store}{$store_option};
+ check_value($result);
+ if ($store_option ne "mode_page") { check_if_hash_array($result,$store_option) }
+ # write-cache can be set globally per target and overridden per lun,
+ # so we treat it differently
+ if ($store_option ne "mode_page" && $store_option ne "write-cache") {
+ my $exec_command = add_params($store_option, $result, $lun, $driver);
+ push(@exec_commands, $exec_command);
+ $params_added{$store_option} = 1;
+ }
+ if ($store_option eq "write-cache") {
+ my $exec_command = add_params($store_option, $result, $lun, $driver);
+ $params_added{write_cache} = 1;
+ push(@exec_commands, $exec_command);
+ }
+ if ($store_option eq "device-type") {
+ $device_type = $result;
+ $params_added{$store_option} = 1;
+ }
+ if ($store_option eq "mode_page") {
+ @mode_page = @$result;
+ foreach my $mode_page (@mode_page) {
+ my $exec_command = add_params("mode_page", $mode_page, $lun, $driver);
+ push(@exec_commands, $exec_command);
+ }
+ }
+ }
}
- execute("# Adding target: $target");
- execute("tgtadm --lld $driver --op new --mode target --tid $next_tid -T $target");
- foreach my $k3 (sort keys %{$conf{$k}{$k2}}) {
- $option = $k3;
- $value = $conf{$k}{$k2}{$k3};
- &check($value);
- &process_options($driver);
- # If there was no option called "initiator-address", it means
- # we want to allow ALL initiators for this target
- if ( $option eq "initiator-address" ) {
- $allowall = 0;
+ }
+ # Used only if lun is a direct-store
+ my $sg_inq;
+ my %direct_params;
+ if ($direct_store == 1) {
+ $sg_inq=`sg_inq $backing_store`;
+ if ($sg_inq=~m {
+ Vendor\ identification:\s+?(.*?)\n
+ \s+Product\ identification:\s+(.*?)\n
+ \s+Product\ revision\ level:\s+(.*?)\n
+ (?:\s+Unit\ serial\ number:\s+(.*?)\n)?
+ }xs ) {
+ # If they were not defined globally for a target,
+ # add them now
+ if (not length $$target_options_ref{vendor_id}) {
+ $direct_params{vendor_id} = $1;
+ }
+ if (not length $$target_options_ref{product_id}) {
+ $direct_params{product_id} = $2;
+ }
+ if (not length $$target_options_ref{product_rev}) {
+ $direct_params{product_rev} = $3;
+ }
+ if (not length $$target_options_ref{scsi_sn}) {
+ $direct_params{scsi_sn} = $4;
}
}
+ }
- if ( $allowall == 1 ) {
- execute("tgtadm --lld $driver --op bind --mode target --tid $next_tid -I ALL");
+ # Add these parameters if they were not overwritten in the config file
+ my @opts = ("scsi_id", "sense_format", "removable", "online", "path");
+ foreach my $single_opt (@opts) {
+ check_if_hash_array($$target_options_ref{$single_opt},$single_opt);
+ if ($params_added{$single_opt} ne 1 && length $$target_options_ref{$single_opt}) {
+ my $exec_command = add_params($single_opt, $$target_options_ref{$single_opt}, $lun, $driver);
+ push(@exec_commands, $exec_command);
+ $params_added{$single_opt} = 1;
}
- execute();
}
+ # These options can be fetched by sg_inq for direct-store
+ my @opts = ("vendor_id", "product_id", "product_rev", "scsi_sn");
+ foreach my $single_opt (@opts) {
+ check_if_hash_array($$target_options_ref{$single_opt},$single_opt);
+ my $this_opt;
+ if (length $$target_options_ref{$single_opt}) {
+ $this_opt = $$target_options_ref{$single_opt};
+ } elsif (length $direct_params{$single_opt}) {
+ $this_opt = $direct_params{$single_opt};
+ }
+ if ($params_added{$single_opt} ne 1 && length $this_opt) {
+ my $exec_command = add_params($single_opt, $this_opt, $lun, $driver);
+ push(@exec_commands, $exec_command);
+ $params_added{$single_opt} = 1;
+ }
+ }
+ # write-cache
+ if ($params_added{write_cache} ne 1) {
+ my $exec_command = add_params("write-cache", $$target_options_ref{"write-cache"}, $lun, $driver);
+ push(@exec_commands, $exec_command);
+ $params_added{write_cache} = 1;
+ }
+ # mode_page
+ unless (ref($$target_options_ref{mode_page}) eq 'ARRAY') {
+ $$target_options_ref{mode_page} = [ $$target_options_ref{mode_page} ];
+ }
+ foreach my $mode_page (@{$$target_options_ref{"mode_page"}}) {
+ if (length $mode_page) {
+ my $exec_command = add_params("mode_page", $mode_page, $lun, $driver);
+ push(@exec_commands, $exec_command);
+ }
+ }
+ # device-type
+ if ($params_added{"device-type"} ne 1) {
+ check_if_hash_array($$target_options_ref{"device-type"}, "device-type");
+ $device_type = $$target_options_ref{"device-type"};
+ }
+ } else {
+ print "If you got here, this means your config file is not supported.\n";
+ print "Please report it to stgt mailing list and attach your config files.\n";
+ exit 1;
+ }
+ # Execute commands for a given LUN
+ if (length $device_type) { $device_type = "--device-type $device_type" };
+ execute("tgtadm --lld $driver --op new --mode logicalunit --tid $next_tid --lun $lun -b $backing_store $device_type");
+ foreach my $exec_command (@exec_commands) {
+ if (length $exec_command) { execute($exec_command) }
}
+ $lun += 1;
+ return $lun;
+ } elsif ($can_alloc == 0) {
+ execute("# Skipping device $backing_store ($dev is mounted / in use)");
+ } else {
+ execute("# Skipping device: $backing_store");
+ execute("# $backing_store does not exist - please check the configuration file");
}
}
# Process options from the config file
sub process_options {
- my $driver = $_[0];
- if ( $option eq "backing-store" ) {
- # if we have one command, force it to be an array anyway
- unless (ref($value) eq 'ARRAY') {
- $value = [ $value ];
+ my $target_options_ref = $_[0];
+ my $driver = $$target_options_ref{"driver"};
+ if ($option eq "backing-store" || $option eq "direct-store") {
+ my $direct_store = 0;
+ if ($option eq "direct-store") {
+ check_exe("sg_inq", "direct-store");
+ $direct_store = 1;
}
- my @value_arr = @$value;
- my $i = 1;
- foreach my $backing_store (@value_arr) {
- # Check if device exists
- if ( -e $backing_store) {
- execute("tgtadm --lld $driver --op new --mode logicalunit --tid $next_tid --lun $i -b $backing_store");
- $i += 1;
- }
- else {
- print("skipping device $backing_store\n");
- print("$backing_store does not exist - please check the configuration file\n");
- }
+ # We want to make everything a hash to use it
+ # in the same way later on
+ unless (ref($value)) {
+ $value = { $value }
}
- }
- if ( $option eq "direct-store" ) {
- my $inq;
- my $vendor_id="";
- my $prod_id="";
- my $prod_rev="";
- my $scsi_serial="";
- # if we have one command, force it to be an array anyway
- unless (ref($value) eq 'ARRAY') {
- $value = [ $value ];
- }
- my @value_arr = @$value;
- my $i = 1;
- foreach my $direct_store (@value_arr) {
- $inq=`sg_inq $direct_store`;
- if ($inq=~/Vendor identification:\s*(\w+)\s*\n*Product identification:\s*([\w\s\/\-]+)\n\s*\n*Product revision level:\s*(\w*)\s*\n*Unit serial number:\s*(\w+)/)
- {
- $vendor_id="$1";
- $prod_id="$2";
- $prod_rev="$3";
- $scsi_serial="$4";
+ my %arrvalue;
+ if (ref($value) eq "ARRAY") {
+ foreach my $backing_store (@$value) {
+ $arrvalue{$backing_store} = 1;
}
- $vendor_id =~ s/\s+$//;
- $prod_id =~ s/\s+$//;
- $prod_rev =~ s/\s+$//;
- $scsi_serial =~ s/\s+$//;
+ $value = \%arrvalue;
+ }
- execute("tgtadm --lld $driver --op new --mode logicalunit --tid $next_tid --lun 1 -b $direct_store");
- execute("tgtadm --lld $driver --op update --mode logicalunit --tid $next_tid --lun 1 --params vendor_id=\"$vendor_id\",product_id=\"$prod_id\",product_rev=\"$prod_rev\",scsi_sn=\"$scsi_serial\"");
- $i += 1;
+ if (ref($value) eq "HASH") {
+ foreach my $backing_store (sort keys %$value) {
+ $lun = add_backing_direct($backing_store,$target_options_ref,$lun,$direct_store);
+ }
}
}
if ( $option eq "incominguser" ) {
# if we have one command, force it to be an array anyway
- unless (ref($value) eq 'ARRAY') {
- $value = [ $value ];
- }
+ force_array();
my @value_arr = @$value;
foreach my $incominguser (@value_arr) {
my @userpass = split(/ /, $incominguser);
- &check($userpass[1]);
+ check_value($userpass[1]);
execute("tgtadm --lld $driver --mode account --op delete --user=$userpass[0]");
execute("tgtadm --lld $driver --mode account --op new --user=$userpass[0] --password=$userpass[1]");
execute("tgtadm --lld $driver --mode account --op bind --tid=$next_tid --user=$userpass[0]");
@@ -298,12 +515,10 @@ sub process_options {
if ( $option eq "outgoinguser" ) {
# if we have one command, force it to be an array anyway
- unless (ref($value) eq 'ARRAY') {
- $value = [ $value ];
- }
+ force_array();
execute("# Warning: only one outgoinguser is allowed. Will only use the first one.");
my @userpass = split(/ /, @$value[0]);
- &check($userpass[1]);
+ check_value($userpass[1]);
execute("tgtadm --lld $driver --mode account --op delete --user=$userpass[0]");
execute("tgtadm --lld $driver --mode account --op new --user=$userpass[0] --password=$userpass[1]");
execute("tgtadm --lld $driver --mode account --op bind --tid=$next_tid --user=$userpass[0] --outgoing");
@@ -311,21 +526,20 @@ sub process_options {
if ( $option eq "initiator-address" ) {
# if we have one command, force it to be an array anyway
- unless (ref($value) eq 'ARRAY') {
- $value = [ $value ];
- }
+ force_array();
my @value_arr = @$value;
foreach my $initiator_address (@value_arr) {
+ check_value($initiator_address);
execute("tgtadm --lld $driver --op bind --mode target --tid $next_tid -I $initiator_address");
}
}
}
# If the target is configured, but not present in the config file,
-# offline it and try to remove it
+# try to remove it
sub remove_targets {
- &process_targets;
+ process_targets;
my @all_targets = keys %tgtadm_output_tid;
foreach my $existing_target (@all_targets) {
@@ -340,13 +554,8 @@ sub remove_targets {
}
if ( $dontremove == 0 ) {
- # Right now, it is not possible to remove a target if any initiators
- # are connected to it. We'll do our best - offline the target first
- # (so it won't accept any new connections), and remove.
- # Note that remove will only work if no initiator is connected.
- execute("# Removing target: $existing_target");
- execute("tgtadm --op update --mode target --tid=$tgtadm_output_tid{$existing_target} -n state -v offline");
- execute("tgtadm --mode target --op delete --tid=$tgtadm_output_tid{$existing_target}");
+ # Remove the target
+ main_delete($existing_target);
}
}
}
@@ -356,61 +565,54 @@ sub remove_targets {
# Dump current tgtd configuration
sub dump_config {
- &process_targets;
+ process_targets;
my @all_targets = keys %tgtadm_output_tid;
- foreach my $target (@all_targets) {
- foreach my $show_target_line ($tgtadm_output{$target}) {
- if ( $show_target_line =~ m/^Target (\d*): (.+)/ ) {
- print "<target $2>\n";
- }
+ # If all targets use the same driver, us it only once in the config
+ my $skip_driver = 0;
+ my @drivers_combined;
+ foreach my $current_target (@all_targets) {
+ my $driver = show_target_info($current_target, "driver");
+ push (@drivers_combined, $driver);
+ }
- if ( $show_target_line =~ m/\s+Driver: (.+)/ ) {
- print "\tdriver $1\n";
- }
+ my %drivers_uniq;
+ @drivers_uniq{@drivers_combined} = ();
+ my @drivers_combined_uniq = sort keys %drivers_uniq;
- if ( $show_target_line =~ m/\s+Backing store: (?!No backing store)(.+)/ ) {
- print "\tbacking-store $1\n";
- }
- }
+ if (scalar @drivers_combined_uniq == 1) {
+ print "default-driver $drivers_combined_uniq[0]\n\n";
+ }
- # Process account and ACL information
- my $account_acl;
+ # Print everything else in the config
+ foreach my $current_target (@all_targets) {
+ my $target_name = show_target_info($current_target, "target_name");
+ print "<target $target_name>\n";
- foreach my $show_target_line ($tgtadm_output{$target}) {
- $account_acl .= $show_target_line
+ if (scalar @drivers_combined_uniq gt 1) {
+ my $driver = show_target_info($current_target, "driver");
+ print "\tdriver $driver\n";
}
- # start with account information...
- while ($account_acl =~ m{
- \s+Account\ information:\n(.*)ACL\ information:
- }xmgs
- ) {
-
- my @account = split(/\n/, $1);
-
- foreach my $user (@account) {
- my @var = split(/^\s+/, $user);
- @var = split(/\s/, $var[1]);
+ my @backing_stores = show_target_info($current_target, "backing_stores");
+ foreach my $backing_store (@backing_stores) {
+ print "\tbacking-store $backing_store\n";
+ }
- if ( $var[1] eq "(outgoing)" ) {
- print "\toutgoinguser $var[0] PLEASE_CORRECT_THE_PASSWORD\n";
- } elsif ( ($var[0] ne "") && ($var[1] eq "") ) {
- print "\tincominguser $var[0] PLEASE_CORRECT_THE_PASSWORD\n";
- }
+ my @account_information = show_target_info($current_target, "account_information");
+ foreach my $account (@account_information) {
+ if ($account =~ /(.+)\ \(outgoing\)/) {
+ print "\toutgoinguser $1 PLEASE_CORRECT_THE_PASSWORD\n";
+ } elsif (length $account) {
+ print "\tincominguser $account PLEASE_CORRECT_THE_PASSWORD\n";
}
}
- #...and finish with ACL information
- while ($account_acl =~ m{
- \s+ACL\ information:\n(.*)
- }xmgs
- ) {
- my @ini_addresses = split(/\n/, $1);
- foreach my $ini_address (@ini_addresses) {
- my @var = split(/^\s+/, $ini_address);
- print "\tinitiator-address $var[1]\n";
+ my @acl_information = show_target_info($current_target, "acl_information");
+ if (scalar(@acl_information) != 1 || $acl_information[0] ne "ALL") {
+ foreach my $ini_address (@acl_information) {
+ print "\tinitiator-address $ini_address\n";
}
}
print "</target>\n\n";
@@ -441,17 +643,17 @@ Example usage:
EOF
} elsif ($off_ready eq "ALL") {
- &process_targets;
+ process_targets;
# Run over all targets and offline/ready them
my @all_targets = keys %tgtadm_output_tid;
foreach my $existing_target (@all_targets) {
execute("tgtadm --op update --mode target --tid=$tgtadm_output_tid{$existing_target} -n state -v $var");
}
} elsif ($off_ready =~ m/tid=(.+)/) {
- &process_targets;
+ process_targets;
execute("tgtadm --op update --mode target --tid=$1 -n state -v $var");
} else {
- &process_targets;
+ process_targets;
if (length $tgtadm_output_tid{$off_ready}) {
execute("tgtadm --op update --mode target --tid=$tgtadm_output_tid{$off_ready} --name=\"$off_ready\" -n state -v $var");
} else {
@@ -465,17 +667,42 @@ EOF
sub show_target_info {
my $existing_target = $_[0];
my $task = $_[1];
+ # Returns target information
+ if ($task eq "target_name") {
+ if ($tgtadm_output{$existing_target} =~ m/^Target (\d*): (.+)/ ) {
+ return $2;
+ }
# Returns driver information
- if ($task eq "driver") {
- if ( $tgtadm_output{$existing_target} =~ m/\s+Driver: (.+)/ ) {
- print $1;
+ } elsif ($task eq "driver") {
+ if ($tgtadm_output{$existing_target} =~ m/\s+Driver: (.+)/ ) {
return $1;
}
+ # Returns backing store
+ } elsif ($task eq "backing_stores") {
+ if ($tgtadm_output{$existing_target} =~ m/\s+Backing store: (?!No backing store)(.+)/ ) {
+ my @backing_stores = $tgtadm_output{$existing_target} =~ m{\s+Backing store: (?!No backing store\n)(.+)}g;
+ return @backing_stores;
+ }
+ return;
+ # Returns account information:
+ } elsif ($task eq "account_information") {
+ if ($tgtadm_output{$existing_target} =~ m{
+ \s+Account\ information:\n(.*)\n\s+ACL\ information:
+ }xs
+ ) {
+ my @accounts = split(/\n/, $1);
+ my @account_information;
+ foreach my $user (@accounts) {
+ my @var = split(/^\s+/, $user);
+ push(@account_information, $var[1]);
+ }
+ return @account_information;
+ }
# Returns ACL information
} elsif ($task eq "acl_information") {
- while ($tgtadm_output{$existing_target} =~ m{
+ if ($tgtadm_output{$existing_target} =~ m{
\s+ACL\ information:\n(.*)
- }xmgs
+ }xs
) {
my @ini_addresses = split(/\n/, $1);
my @acls;
@@ -487,51 +714,80 @@ sub show_target_info {
}
# Returns sessions
} elsif ($task eq "sessions") {
- my @var = split(/\n/, $tgtadm_output{$existing_target});
- my @sids;
- foreach my $sid (@var) {
- if ( $sid =~ m/\s+I_T nexus: (.+)/ ) {
- push(@sids, $1);
+ my %sessions;
+ if ($tgtadm_output{$existing_target} =~ m{
+ \s+I_T\ nexus\ information:\n(.*)LUN\ information:
+ }xs
+ ) {
+ my @var = split(/\n/, $1);
+ my $sid;
+ my $cid;
+
+ foreach my $line (@var) {
+ if ($line =~ m/\s+I_T nexus:\ (.+)/) {
+ $sid = $1;
+ } else {
+ if ($line =~ m/\s+Connection:\ (.+)/) {
+ $cid = $1;
+ $sessions{$sid} = $cid;
+ }
+ }
}
}
- return @sids;
+ return %sessions;
}
}
-# Delete the targets which are not in use
-sub delete_targets {
-
- # Check if the target is used by an initiator
- sub check_in_use {
- my $existing_target = $_[0];
- my $cur_option = $_[1];
- my $cur_tid = $_[2];
- if ($tgtadm_output{$existing_target} =~ m/\s+Connection:/) {
- if ($force == 1) {
- # Remove ACLs first
- my @acl_info = &show_target_info($existing_target, "acl_information");
- foreach my $acl (@acl_info) {
- execute("tgtadm --op unbind --mode target --tid $tgtadm_output_tid{$existing_target} -I $acl");
- }
- # Now, remove all sessions / connections from that tid
- my @sessions = &show_target_info($existing_target, "sessions");
- foreach my $session (@sessions) {
- execute("tgtadm --op delete --mode conn --tid $tgtadm_output_tid{$existing_target} --sid $session --cid 0");
+# Main subroutine for deleting targets
+sub main_delete {
+ my $current_target = $_[0];
+ my $current_tid = $_[1];
+ my $configured = check_configured($current_target);
+ my $del_upd_text;
+ # Check if the target has initiators connected
+ if ($tgtadm_output{$current_target} =~ m/\s+Connection:/) {
+ if ($force == 1) {
+ execute("# Removing target: $current_target");
+ # Remove ACLs first
+ my @acl_info = show_target_info($current_target, "acl_information");
+ foreach my $acl (@acl_info) {
+ execute("tgtadm --op unbind --mode target --tid $tgtadm_output_tid{$current_target} -I $acl");
+ }
+ # Now, remove all sessions / connections from that tid
+ my %sessions = show_target_info($current_target, "sessions");
+ foreach my $sid (keys %sessions) {
+ foreach my $cid ($sessions{$sid}) {
+ execute("tgtadm --op delete --mode conn --tid $tgtadm_output_tid{$current_target} --sid $sid --cid $cid");
}
- execute("tgtadm --mode target --op delete --tid=$tgtadm_output_tid{$existing_target}");
- } else {
- execute("# Target with tid $tgtadm_output_tid{$existing_target} ($existing_target) is in use, it won't be deleted.");
}
- } elsif (length $tgtadm_output_tid{$existing_target}) {
- execute("tgtadm --mode target --op delete --tid=$tgtadm_output_tid{$existing_target}");
+ execute("tgtadm --mode target --op delete --tid=$tgtadm_output_tid{$current_target}");
} else {
- if ($cur_option eq "tid") {
- execute("# Target with tid $cur_tid does not exist!");
+ if ($update ne 0) {
+ $del_upd_text = "updated";
} else {
- execute("# Target $existing_target does not exist!");
+ $del_upd_text = "deleted";
}
+ execute("# Target with tid $tgtadm_output_tid{$current_target} ($current_target) is in use, it won't be $del_upd_text.");
+ return 1;
+ }
+ } elsif (length $tgtadm_output_tid{$current_target}) {
+ execute("# Removing target: $current_target");
+ execute("tgtadm --mode target --op delete --tid=$tgtadm_output_tid{$current_target}");
+ } else {
+ if (length $current_tid) {
+ execute("# Target with tid $current_tid does not exist!");
+ } else {
+ execute("# Target with name $current_target does not exist!");
}
}
+ if ($configured ne 0) {
+ execute();
+ }
+ return 0;
+}
+
+# Delete the targets
+sub delete_targets {
if ($delete eq "help") {
print <<EOF;
@@ -539,7 +795,7 @@ sub delete_targets {
The target will be deleted only if it's not used
(no initiator is connected to it).
If you want to delete targets which are in use,
- you have to add "--force" flag
+ you have to add "--force" flag.
Example usage:
--delete help - display this help
@@ -550,27 +806,131 @@ Example usage:
EOF
exit;
} elsif ($delete eq "ALL") {
- &process_targets;
- # Run over all targets and delete them if they are not in use
+ process_targets;
+ # Run over all targets and delete them
my @all_targets = keys %tgtadm_output_tid;
- foreach my $existing_target (@all_targets) {
- &check_in_use($existing_target);
+ foreach my $current_target (@all_targets) {
+ main_delete($current_target);
}
- } elsif ($delete =~ m/tid=(.+)/) {
+ } elsif ($delete =~ m/^tid=(.+)/) {
# Delete by tid
- &process_targets;
- my $existing_target = $1;
- &check_in_use($tgtadm_output_name{$existing_target}, "tid", $existing_target);
+ process_targets;
+ my $current_target = $tgtadm_output_name{$1};
+ main_delete($current_target, $1);
} else {
# Delete by name
- &process_targets;
- my $existing_target = $delete;
- &check_in_use($existing_target);
+ process_targets;
+ my $current_target = $delete;
+ main_delete($current_target);
}
}
-# Some checks
-sub check {
+# Update targets
+sub update_targets {
+ if ($update eq "help") {
+ print <<EOF;
+ --update <value> update all or selected targets
+ The target will be updated only if it's not used
+ (no initiator is connected to it).
+ If you want to update targets which are in use,
+ you have to add "--force" flag.
+
+Example usage:
+ --update help - display this help
+ --update ALL - update all targets
+ --update tid=4 - update target 4 (target with tid 4)
+ --update iqn.2008-08.com.example:some.target - update this target
+
+EOF
+ exit;
+ } elsif ($update eq "ALL") {
+ # Run over all targets and delete them if they are not in use
+ parse_configs;
+ process_targets;
+ my @targets_combined = combine_targets();
+ foreach my $current_target (@targets_combined) {
+ my $configured = check_configured($current_target);
+ my $connected = check_connected($current_target);
+ my $in_configfile = check_in_configfile($current_target);
+ combine_targets();
+ if (($in_configfile == 0) && ($configured == 1)) {
+ # Delete the target if it's not in the config file
+ main_delete($current_target);
+ } else {
+ add_targets($current_target, $configured, $connected, $in_configfile);
+ }
+
+ }
+ } elsif ($update =~ m/^tid=(.+)/) {
+ # Update by tid
+ parse_configs;
+ process_targets;
+ my $current_target = $tgtadm_output_name{$1};
+ my $configured = check_configured($current_target);
+ my $connected = check_connected($current_target);
+ my $in_configfile = check_in_configfile($current_target);
+ if (($in_configfile == 0) && ($configured == 1)) {
+ # Delete the target if it's not in the config file
+ main_delete($current_target);
+ } elsif ($configured == 1) {
+ add_targets($current_target, $configured, $connected, $in_configfile);
+ } else {
+ print "There is no target with tid $1, can't continue!\n";
+ exit 1;
+ }
+ } else {
+ # Update by name
+ parse_configs;
+ process_targets;
+ my $current_target = $update;
+ my $configured = check_configured($current_target);
+ my $connected = check_connected($current_target);
+ my $in_configfile = check_in_configfile($current_target);
+ if ($in_configfile == 0 && $configured == 1) {
+ # Delete the target if it's not in the config file
+ main_delete($current_target);
+ } else {
+ add_targets($current_target, $configured, $connected, $in_configfile);
+ }
+ }
+}
+
+# Find the biggest tid
+sub find_max_tid {
+ process_targets;
+ my @all_targets = keys %tgtadm_output_tid;
+ my $maxtid = 0;
+ foreach my $var (@all_targets) {
+ if ($tgtadm_output_tid{$var} > $maxtid) {
+ $maxtid = $tgtadm_output_tid{$var};
+ }
+ }
+ return $maxtid;
+}
+
+# Combine targets from the config file and currently configured targets
+sub combine_targets {
+ my @targets_in_configfile;
+ my @all_targets = keys %tgtadm_output_tid;
+ my @targets_combined;
+ # Make an array of targets in the config file
+ foreach my $k (sort keys %conf) {
+ if ( $k eq "target" ) {
+ foreach my $k2 (sort keys %{$conf{$k}}) {
+ push(@targets_in_configfile, $k2)
+ }
+ }
+ }
+ # Use only unique elements from both arrays
+ foreach my $current_target (@all_targets) {
+ push (@targets_combined, $current_target) unless grep { $_ eq $current_target } @targets_in_configfile;
+ }
+ @targets_combined = (@targets_combined, @targets_in_configfile);
+ return @targets_combined;
+}
+
+# Check if a value is correct
+sub check_value {
if ( not defined $_[0] or not length $_[0] ) {
print "\nOption $option has a missing value!\n";
print "Check your config file for errors (target: $target)\n";
@@ -578,6 +938,102 @@ sub check {
}
}
+# Check if the target is in the config file
+sub check_in_configfile {
+ my $current_target = $_[0];
+ my $result;
+ foreach my $k (sort keys %conf) {
+ if ( $k eq "target" ) {
+ foreach my $k2 (sort keys %{$conf{$k}}) {
+ if ($k2 eq $current_target) {
+ return 1;
+ }
+ }
+ # If we're here, we didn't find a match
+ return 0;
+ }
+ }
+}
+
+# Check if the target is configured in tgtd
+sub check_configured {
+ my $current_target = $_[0];
+ if (length $tgtadm_output_tid{$current_target}) {
+ return 1;
+ } else {
+ return 0;
+ }
+}
+
+# Check if any initiators are connected to the target
+sub check_connected {
+ my $current_target = $_[0];
+ if ($tgtadm_output{$current_target} =~ m/\s+Connection:/) {
+ return 1;
+ } else {
+ return 0;
+ }
+}
+
+# Check if a device can be allocated
+my @rootfs_dev;
+sub check_device {
+ my $tmp_dev = $_[0];
+
+ # Check if force flag is set
+ if ( $force == 0) {
+ # Check for rootfs devices
+ &find_rootfs_device();
+ $tmp_dev =~ s/\d//g;
+ # Check if device is on the same disk as rootfs
+ if (grep {$_ eq $tmp_dev} @rootfs_dev) {
+ return (0,$tmp_dev);
+ }
+ }
+ return 1;
+}
+
+# finds all the devices that rootfs is mounted on
+sub find_rootfs_device {
+ my @files=("/etc/mtab","/proc/mounts");
+ my @lines;
+ # read files
+ foreach my $file (@files){
+ if (open(FH,"$file")) {
+ @lines=(@lines,<FH>);
+ close (FH);
+ }
+ }
+
+ # parse files and finds all the device which mounted on /
+ foreach my $line (@lines){
+ chomp $line;
+ if (($line=~/^\/dev\//) && ($line=~/ \/ /)){
+ my @ln=split(' ',$line);
+ $ln[0]=~s/\d//g;
+ push(@rootfs_dev,$ln[0]);
+ }
+ }
+
+ # read swap file
+ my $swap_file="/proc/swap";
+ if (open(FH,"$swap_file")) {
+ @lines=<FH>;
+ close (FH);
+ }
+ # parse swap file and finds all the swap devices
+ foreach my $line (@lines){
+ chomp $line;
+ if ($line=~/^\/dev\//) {
+ my @ln=split(' ',$line);
+ $ln[0]=~s/\d//g;
+ push(@rootfs_dev,$ln[0]);
+ }
+ }
+ # remove duplicate entries from @rootfs_dev
+ my %seen = ();
+ @rootfs_dev = grep { ! $seen{ $_ }++ } @rootfs_dev;
+}
# Execute or just print (or both) everything we start or would start
sub execute {
@@ -589,7 +1045,7 @@ sub execute {
}
# Don't try to execute if it's a comment
my @execargs = split(/#/, $args);
- if ( $execargs[0] ne undef ) {
+ if ($execargs[0] ne undef) {
system($args);
# If non-zero exit code was return, exit
@@ -600,24 +1056,26 @@ sub execute {
}
}
- } elsif ( $pretend == 1 ) {
+ } elsif ($pretend == 1) {
print "@_\n";
}
}
if ($execute == 1) {
- &process_targets;
- &parse_configs;
- &add_targets;
- &remove_targets;
+ process_targets;
+ parse_configs;
+ add_targets;
+ remove_targets;
} elsif ($delete ne 0) {
- &delete_targets;
+ delete_targets;
+} elsif ($update ne 0) {
+ update_targets;
} elsif ($dump == 1) {
- &dump_config;
+ dump_config;
} elsif ($offline ne 0) {
- &ready_offline_targets("offline");
+ ready_offline_targets("offline");
} elsif ($ready ne 0) {
- &ready_offline_targets("ready");
+ ready_offline_targets("ready");
} else {
print "No action specified.\n";
}
diff --git a/usr/Makefile b/usr/Makefile
index 4245709..82ddf07 100644
--- a/usr/Makefile
+++ b/usr/Makefile
@@ -55,10 +55,12 @@ CFLAGS += -g -O2 -Wall -Wstrict-prototypes -fPIC
LIBS += -lpthread
PROGRAMS += tgtd tgtadm
-SCRIPTS += ../scripts/tgt-setup-lun
+SCRIPTS += ../scripts/tgt-setup-lun ../scripts/tgt-admin
TGTD_OBJS += tgtd.o mgmt.o target.o scsi.o log.o driver.o util.o work.o \
- parser.o spc.o sbc.o mmc.o osd.o scc.o smc.o ssc.o bs_ssc.o bs.o
-MANPAGES = ../doc/manpages/tgtadm.8 ../doc/manpages/tgt-setup-lun.8
+ parser.o spc.o sbc.o mmc.o osd.o scc.o smc.o ssc.o bs_ssc.o \
+ bs.o
+MANPAGES = ../doc/manpages/tgtadm.8 ../doc/manpages/tgt-admin.8 \
+ ../doc/manpages/tgt-setup-lun.8
TGTD_DEP = $(TGTD_OBJS:.o=.d)
diff --git a/usr/be_byteshift.h b/usr/be_byteshift.h
new file mode 100644
index 0000000..5c6a619
--- /dev/null
+++ b/usr/be_byteshift.h
@@ -0,0 +1,68 @@
+#ifndef _LINUX_UNALIGNED_BE_BYTESHIFT_H
+#define _LINUX_UNALIGNED_BE_BYTESHIFT_H
+
+static inline uint16_t __get_unaligned_be16(const uint8_t *p)
+{
+ return p[0] << 8 | p[1];
+}
+
+static inline uint32_t __get_unaligned_be32(const uint8_t *p)
+{
+ return p[0] << 24 | p[1] << 16 | p[2] << 8 | p[3];
+}
+
+static inline uint64_t __get_unaligned_be64(const uint8_t *p)
+{
+ return (uint64_t)__get_unaligned_be32(p) << 32 |
+ __get_unaligned_be32(p + 4);
+}
+
+static inline void __put_unaligned_be16(uint16_t val, uint8_t *p)
+{
+ *p++ = val >> 8;
+ *p++ = val;
+}
+
+static inline void __put_unaligned_be32(uint32_t val, uint8_t *p)
+{
+ __put_unaligned_be16(val >> 16, p);
+ __put_unaligned_be16(val, p + 2);
+}
+
+static inline void __put_unaligned_be64(uint64_t val, uint8_t *p)
+{
+ __put_unaligned_be32(val >> 32, p);
+ __put_unaligned_be32(val, p + 4);
+}
+
+static inline uint16_t get_unaligned_be16(const void *p)
+{
+ return __get_unaligned_be16((const uint8_t *)p);
+}
+
+static inline uint32_t get_unaligned_be32(const void *p)
+{
+ return __get_unaligned_be32((const uint8_t *)p);
+}
+
+static inline uint64_t get_unaligned_be64(const void *p)
+{
+ return __get_unaligned_be64((const uint8_t *)p);
+}
+
+static inline void put_unaligned_be16(uint16_t val, void *p)
+{
+ __put_unaligned_be16(val, p);
+}
+
+static inline void put_unaligned_be32(uint32_t val, void *p)
+{
+ __put_unaligned_be32(val, p);
+}
+
+static inline void put_unaligned_be64(uint64_t val, void *p)
+{
+ __put_unaligned_be64(val, p);
+}
+
+#endif /* _LINUX_UNALIGNED_BE_BYTESHIFT_H */
diff --git a/usr/bs.c b/usr/bs.c
index f100e2c..cef7b19 100644
--- a/usr/bs.c
+++ b/usr/bs.c
@@ -125,7 +125,15 @@ static void bs_thread_request_done(int fd, int events, void *data)
cmd->scsi_cmd_done(cmd, scsi_get_result(cmd));
}
- write(info->command_fd[1], &nr_events, sizeof(nr_events));
+rewrite:
+ ret = write(info->command_fd[1], &nr_events, sizeof(nr_events));
+ if (ret < 0) {
+ eprintf("can't write done, %m\n");
+ if (errno == EAGAIN || errno == EINTR)
+ goto rewrite;
+
+ return;
+ }
}
static void *bs_thread_worker_fn(void *arg)
@@ -140,7 +148,7 @@ static void *bs_thread_worker_fn(void *arg)
pthread_cond_wait(&info->pending_cond, &info->pending_lock);
if (info->stop) {
pthread_mutex_unlock(&info->pending_lock);
- break;
+ pthread_exit(NULL);
}
goto retest;
}
@@ -200,11 +208,32 @@ int bs_thread_open(struct bs_thread_info *info, request_func_t *rfn)
for (i = 0; i < ARRAY_SIZE(info->worker_thread); i++) {
ret = pthread_create(&info->worker_thread[i], NULL,
bs_thread_worker_fn, info);
+ if (ret)
+ goto destroy_threads;
+ }
+rewrite:
+ ret = write(info->command_fd[1], &ret, sizeof(ret));
+ if (ret < 0) {
+ eprintf("can't write done, %m\n");
+ if (errno == EAGAIN || errno == EINTR)
+ goto rewrite;
}
+ return 0;
+destroy_threads:
write(info->command_fd[1], &ret, sizeof(ret));
+ pthread_cancel(info->ack_thread);
+ pthread_cond_signal(&info->finished_cond);
+ pthread_join(info->ack_thread, NULL);
- return 0;
+ info->stop = 1;
+ for (i = 0; info->worker_thread[i]; i++) {
+ pthread_cancel(info->worker_thread[i]);
+ pthread_cond_signal(&info->pending_cond);
+ }
+
+ for (i = 0; info->worker_thread[i]; i++)
+ pthread_join(info->worker_thread[i], NULL);
event_del:
tgt_event_del(info->done_fd[0]);
close_done_fd:
diff --git a/usr/bs_aio.h b/usr/bs_aio.h
index ad1cc3a..f62e99c 100644
--- a/usr/bs_aio.h
+++ b/usr/bs_aio.h
@@ -44,6 +44,10 @@ enum {
#define __NR_eventfd 284
#elif defined(__i386__)
#define __NR_eventfd 323
+#elif defined(__powerpc__)
+#define __NR_eventfd 307
+#elif defined(__powerpc64__)
+#define __NR_eventfd 307
#elif defined(__ia64__)
#define __NR_eventfd 1309
#elif defined(__sparc__) || defined(__sparc64__)
diff --git a/usr/log.c b/usr/log.c
index 4b71216..076c770 100644
--- a/usr/log.c
+++ b/usr/log.c
@@ -108,9 +108,6 @@ static int logarea_init (int size)
return 1;
}
- la->ops[0].sem_num = 0;
- la->ops[0].sem_flg = 0;
-
return 0;
}
@@ -237,21 +234,24 @@ static void log_syslog (void * buff)
static void dolog(int prio, const char *fmt, va_list ap)
{
struct timespec ts;
+ struct sembuf ops;
if (la) {
ts.tv_sec = 0;
ts.tv_nsec = 10000;
- la->ops[0].sem_op = -1;
- if (semtimedop(la->semid, la->ops, 1, &ts) < 0) {
+ ops.sem_num = 0;
+ ops.sem_flg = 0;
+ ops.sem_op = -1;
+ if (semtimedop(la->semid, &ops, 1, &ts) < 0) {
syslog(LOG_ERR, "semop up failed");
return;
}
log_enqueue(prio, fmt, ap);
- la->ops[0].sem_op = 1;
- if (semop(la->semid, la->ops, 1) < 0) {
+ ops.sem_op = 1;
+ if (semop(la->semid, &ops, 1) < 0) {
syslog(LOG_ERR, "semop down failed");
return;
}
@@ -291,15 +291,21 @@ void log_debug(const char *fmt, ...)
static void log_flush(void)
{
+ struct sembuf ops;
+
while (!la->empty) {
- la->ops[0].sem_op = -1;
- if (semop(la->semid, la->ops, 1) < 0) {
+ ops.sem_num = 0;
+ ops.sem_flg = 0;
+ ops.sem_op = -1;
+ if (semop(la->semid, &ops, 1) < 0) {
syslog(LOG_ERR, "semop up failed");
exit(1);
}
+
log_dequeue(la->buff);
- la->ops[0].sem_op = 1;
- if (semop(la->semid, la->ops, 1) < 0) {
+
+ ops.sem_op = 1;
+ if (semop(la->semid, &ops, 1) < 0) {
syslog(LOG_ERR, "semop down failed");
exit(1);
}
diff --git a/usr/log.h b/usr/log.h
index 6993235..b84f6d6 100644
--- a/usr/log.h
+++ b/usr/log.h
@@ -55,7 +55,6 @@ struct logarea {
void *start;
void *end;
char *buff;
- struct sembuf ops[1];
int semid;
union semun semarg;
};
diff --git a/usr/parser.c b/usr/parser.c
index 7b892a5..0b244e4 100644
--- a/usr/parser.c
+++ b/usr/parser.c
@@ -30,6 +30,7 @@ static int match_one(char *s, char *p, substring_t args[])
{
char *meta;
int argc = 0;
+ unsigned long long ret;
if (!p)
return 1;
@@ -68,16 +69,16 @@ static int match_one(char *s, char *p, substring_t args[])
args[argc].to = s + len;
break;
case 'd':
- strtol(s, &args[argc].to, 0);
+ ret = strtol(s, &args[argc].to, 0);
goto num;
case 'u':
- strtoul(s, &args[argc].to, 0);
+ ret = strtoul(s, &args[argc].to, 0);
goto num;
case 'o':
- strtoul(s, &args[argc].to, 8);
+ ret = strtoul(s, &args[argc].to, 8);
goto num;
case 'x':
- strtoul(s, &args[argc].to, 16);
+ ret = strtoul(s, &args[argc].to, 16);
num:
if (args[argc].to == args[argc].from)
return 0;
diff --git a/usr/smc.c b/usr/smc.c
index 9d7f681..ab36e9c 100644
--- a/usr/smc.c
+++ b/usr/smc.c
@@ -225,6 +225,41 @@ static int build_element_descriptors(uint8_t *data, struct list_head *head,
}
/**
+ * smc_initialize_element_status with range
+ * - INITIALIZE ELEMENT STATUS WITH RANGE op code
+ *
+ * Support the SCSI op code INITIALIZE_ELEMENT_STATUS_WITH_RANGE
+ * Ref: smc3r11, 6.5
+ */
+static int smc_initialize_element_status_range(int host_no, struct scsi_cmd *cmd)
+{
+ scsi_set_in_resid_by_actual(cmd, 0);
+
+ if (device_reserved(cmd))
+ return SAM_STAT_RESERVATION_CONFLICT;
+ else
+ return SAM_STAT_GOOD;
+}
+
+/**
+ * smc_initialize_element_status - INITIALIZE ELEMENT STATUS op code
+ *
+ * Some backup libraries seem to require this.
+ *
+ * Support the SCSI op code INITIALIZE_ELEMENT_STATUS
+ * Ref: smc3r10a, 6.2
+ */
+static int smc_initialize_element_status(int host_no, struct scsi_cmd *cmd)
+{
+ scsi_set_in_resid_by_actual(cmd, 0);
+
+ if (device_reserved(cmd))
+ return SAM_STAT_RESERVATION_CONFLICT;
+ else
+ return SAM_STAT_GOOD;
+}
+
+/**
* smc_read_element_status - READ ELEMENT STATUS op code
*
* Support the SCSI op code READ ELEMENT STATUS
@@ -748,7 +783,7 @@ struct device_type_template smc_template = {
{spc_illegal_op,},
{spc_illegal_op,},
{spc_illegal_op,},
- {spc_illegal_op,},
+ {smc_initialize_element_status,},
{spc_illegal_op,},
{spc_illegal_op,},
@@ -778,7 +813,28 @@ struct device_type_template smc_template = {
{spc_illegal_op,},
{spc_illegal_op,},
- [0x20 ... 0x4f] = {spc_illegal_op,},
+ [0x20 ... 0x2f] = {spc_illegal_op,},
+
+ /* 0x30 */
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {smc_initialize_element_status_range,},
+
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+ {spc_illegal_op,},
+
+ [0x40 ... 0x4f] = {spc_illegal_op,},
/* 0x50 */
{spc_illegal_op,},
diff --git a/usr/spc.c b/usr/spc.c
index bd2c975..60fd7d7 100644
--- a/usr/spc.c
+++ b/usr/spc.c
@@ -318,6 +318,16 @@ int spc_test_unit(int host_no, struct scsi_cmd *cmd)
return SAM_STAT_CHECK_CONDITION;
}
+int spc_prevent_allow_media_removal(int host_no, struct scsi_cmd *cmd)
+{
+ /* TODO: implement properly */
+
+ if (device_reserved(cmd))
+ return SAM_STAT_RESERVATION_CONFLICT;
+ else
+ return SAM_STAT_GOOD;
+}
+
int spc_mode_select(int host_no, struct scsi_cmd *cmd,
int (*update)(struct scsi_cmd *, uint8_t *, int *))
{
diff --git a/usr/spc.h b/usr/spc.h
index 8fe3e3c..cfc9cf3 100644
--- a/usr/spc.h
+++ b/usr/spc.h
@@ -8,6 +8,7 @@ extern int spc_report_luns(int host_no, struct scsi_cmd *cmd);
extern int spc_start_stop(int host_no, struct scsi_cmd *cmd);
extern int spc_test_unit(int host_no, struct scsi_cmd *cmd);
extern int spc_request_sense(int host_no, struct scsi_cmd *cmd);
+extern int spc_prevent_allow_media_removal(int host_no, struct scsi_cmd *cmd);
extern int spc_illegal_op(int host_no, struct scsi_cmd *cmd);
extern int spc_lu_init(struct scsi_lu *lu);
diff --git a/usr/ssc.c b/usr/ssc.c
index 2630a6a..96c3242 100644
--- a/usr/ssc.c
+++ b/usr/ssc.c
@@ -192,7 +192,7 @@ static struct device_type_template ssc_template = {
{spc_start_stop,},
{spc_illegal_op,},
{spc_illegal_op,},
- {spc_illegal_op,},
+ {spc_prevent_allow_media_removal,},
{spc_illegal_op,},
/* 0x20 */
@@ -298,7 +298,7 @@ static struct device_type_template ssc_template = {
{spc_report_luns,},
{spc_illegal_op,},
{spc_illegal_op,},
- {spc_illegal_op,},
+ {spc_maint_in, maint_in_service_actions,},
{spc_illegal_op,},
{spc_illegal_op,},
{spc_illegal_op,},
diff --git a/usr/target.c b/usr/target.c
index 70bf72a..32812d9 100644
--- a/usr/target.c
+++ b/usr/target.c
@@ -491,7 +491,7 @@ int tgt_device_create(int tid, int dev_type, uint64_t lun, char *params,
if (lu->bst->bs_init) {
ret = lu->bst->bs_init(lu);
if (ret)
- goto fail_bs_init;
+ goto fail_lu_init;
}
if (backing && !path && !lu->attrs.removable) {
diff --git a/usr/util.h b/usr/util.h
index ac4b380..794c70b 100644
--- a/usr/util.h
+++ b/usr/util.h
@@ -6,6 +6,7 @@
#include <unistd.h>
#include <errno.h>
#include <endian.h>
+#include "be_byteshift.h"
#define roundup(x, y) ((((x) + ((y) - 1)) / (y)) * (y))
#define ARRAY_SIZE(x) (sizeof(x) / sizeof((x)[0]))
Reference in New Issue View Git Blame Copy Permalink