golden hour

/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules

File/Folder	Size	Actions
__init__.py	35 B
__pycache__	-
acme.py	12.74 KB
aix_group.py	4.12 KB
aix_shadow.py	1.93 KB
aixpkg.py	24.15 KB
aliases.py	5.07 KB
alternatives.py	5.71 KB
ansiblegate.py	19.51 KB
apache.py	12.47 KB
apcups.py	2.15 KB
apf.py	3.09 KB
apkpkg.py	16 KB
aptly.py	15.28 KB
aptpkg.py	116.64 KB
archive.py	48.63 KB
arista_pyeapi.py	22.06 KB
artifactory.py	24.78 KB
at.py	10.72 KB
at_solaris.py	8.51 KB
augeas_cfg.py	13.93 KB
aws_sqs.py	6.55 KB
azurearm_compute.py	20.8 KB
azurearm_dns.py	15.8 KB
azurearm_network.py	82.99 KB
azurearm_resource.py	35.75 KB
bamboohr.py	7.36 KB
baredoc.py	11.13 KB
bcache.py	28.97 KB
beacons.py	27.82 KB
bigip.py	69.11 KB
bluez_bluetooth.py	6.76 KB
boto3_elasticache.py	37.34 KB
boto3_elasticsearch.py	53.17 KB
boto3_route53.py	39.82 KB
boto3_sns.py	12.93 KB
boto_apigateway.py	61.86 KB
boto_asg.py	35.69 KB
boto_cfn.py	7.95 KB
boto_cloudfront.py	12.75 KB
boto_cloudtrail.py	14.45 KB
boto_cloudwatch.py	10.99 KB
boto_cloudwatch_event.py	9.48 KB
boto_cognitoidentity.py	14.63 KB
boto_datapipeline.py	6.94 KB
boto_dynamodb.py	14.98 KB
boto_ec2.py	79.27 KB
boto_efs.py	14.05 KB
boto_elasticache.py	23.69 KB
boto_elasticsearch_domain.py	15.85 KB
boto_elb.py	35.53 KB
boto_elbv2.py	10.78 KB
boto_iam.py	75.62 KB
boto_iot.py	26.2 KB
boto_kinesis.py	19.62 KB
boto_kms.py	17.29 KB
boto_lambda.py	35.05 KB
boto_rds.py	34.92 KB
boto_route53.py	32.55 KB
boto_s3.py	4.24 KB
boto_s3_bucket.py	31.8 KB
boto_secgroup.py	25.22 KB
boto_sns.py	7.22 KB
boto_sqs.py	6.43 KB
boto_ssm.py	3.63 KB
boto_vpc.py	113.08 KB
bower.py	5.85 KB
bridge.py	10.81 KB
bsd_shadow.py	6.25 KB
btrfs.py	33.66 KB
cabal.py	3.79 KB
capirca_acl.py	40.04 KB
cassandra_cql.py	54.16 KB
cassandra_mod.py	4.3 KB
celery.py	3.33 KB
ceph.py	15.82 KB
chassis.py	1.52 KB
chef.py	4.66 KB
chocolatey.py	41.55 KB
chronos.py	2.89 KB
chroot.py	11.73 KB
cimc.py	23.02 KB
ciscoconfparse_mod.py	14.79 KB
cisconso.py	3.83 KB
cloud.py	9.39 KB
cmdmod.py	163.73 KB
composer.py	10.31 KB
config.py	16.98 KB
consul.py	69.3 KB
container_resource.py	12.94 KB
cp.py	31.98 KB
cpan.py	5.54 KB
cron.py	28.09 KB
cryptdev.py	10.08 KB
csf.py	16.04 KB
cyg.py	8.32 KB
daemontools.py	5.41 KB
data.py	3.85 KB
datadog_api.py	7.76 KB
ddns.py	7.12 KB
deb_apache.py	7.41 KB
deb_postgres.py	4.18 KB
debconfmod.py	4.06 KB
debian_ip.py	64.91 KB
debian_service.py	6.55 KB
debuild_pkgbuild.py	34.68 KB
defaults.py	6.55 KB
devinfo.py	9.07 KB
devmap.py	627 B
dig.py	8.75 KB
disk.py	30.82 KB
djangomod.py	7.53 KB
dnsmasq.py	5.71 KB
dnsutil.py	11.51 KB
dockercompose.py	32.62 KB
dockermod.py	224.85 KB
dpkg_lowpkg.py	12.94 KB
drac.py	10.97 KB
dracr.py	38.53 KB
drbd.py	7.19 KB
dummyproxy_pkg.py	2.46 KB
dummyproxy_service.py	2.91 KB
ebuildpkg.py	38.74 KB
eix.py	1.58 KB
elasticsearch.py	51.44 KB
environ.py	8.96 KB
eselect.py	4.99 KB
esxcluster.py	1.66 KB
esxdatacenter.py	1.68 KB
esxi.py	2.79 KB
esxvm.py	1.63 KB
etcd_mod.py	8.56 KB
ethtool.py	11.12 KB
event.py	7.67 KB
extfs.py	8.78 KB
file.py	232.18 KB
firewalld.py	20.51 KB
freebsd_sysctl.py	4.99 KB
freebsd_update.py	6.19 KB
freebsdjail.py	7.16 KB
freebsdkmod.py	6.17 KB
freebsdpkg.py	17.04 KB
freebsdports.py	13.13 KB
freebsdservice.py	12.53 KB
freezer.py	10.2 KB
gcp_addon.py	4.07 KB
gem.py	10.6 KB
genesis.py	21.75 KB
gentoo_service.py	9.18 KB
gentoolkitmod.py	8.39 KB
git.py	172.01 KB
github.py	53.19 KB
glanceng.py	4.69 KB
glassfish.py	19.49 KB
glusterfs.py	19.55 KB
gnomedesktop.py	6.85 KB
google_chat.py	1.52 KB
gpg.py	39.09 KB
grafana4.py	30.27 KB
grains.py	21.81 KB
groupadd.py	11.87 KB
grub_legacy.py	3.08 KB
guestfs.py	2.37 KB
hadoop.py	3.76 KB
haproxyconn.py	10.17 KB
hashutil.py	6.77 KB
heat.py	25.25 KB
helm.py	39.27 KB
hg.py	7.16 KB
highstate_doc.py	22.76 KB
hosts.py	10.47 KB
http.py	3.76 KB
icinga2.py	4.46 KB
idem.py	1.75 KB
ifttt.py	2.28 KB
ilo.py	15.98 KB
incron.py	7.68 KB
influxdb08mod.py	15.07 KB
influxdbmod.py	16.13 KB
infoblox.py	17.53 KB
ini_manage.py	14.63 KB
inspectlib	-
inspector.py	8.19 KB
introspect.py	4.02 KB
iosconfig.py	14.78 KB
ipmi.py	25.47 KB
ipset.py	17.97 KB
iptables.py	57.44 KB
iwtools.py	3.99 KB
jboss7.py	20.51 KB
jboss7_cli.py	15.23 KB
jenkinsmod.py	11.9 KB
jinja.py	2.66 KB
jira_mod.py	7.07 KB
junos.py	73.96 KB
k8s.py	24.87 KB
kapacitor.py	5.37 KB
kerberos.py	5.42 KB
kernelpkg_linux_apt.py	6.71 KB
kernelpkg_linux_yum.py	7.26 KB
key.py	1007 B
keyboard.py	2.64 KB
keystone.py	43.14 KB
keystoneng.py	21.82 KB
keystore.py	7.18 KB
kmod.py	7.65 KB
kubeadm.py	34.64 KB
kubernetesmod.py	46.77 KB
launchctl_service.py	9.69 KB
layman.py	4.22 KB
ldap3.py	18.81 KB
ldapmod.py	5.9 KB
libcloud_compute.py	23.48 KB
libcloud_dns.py	9.73 KB
libcloud_loadbalancer.py	13.14 KB
libcloud_storage.py	12.16 KB
linux_acl.py	7.7 KB
linux_ip.py	5.55 KB
linux_lvm.py	17.86 KB
linux_service.py	4.64 KB
linux_shadow.py	12.96 KB
linux_sysctl.py	7.5 KB
localemod.py	11.84 KB
locate.py	2.58 KB
logadm.py	9.44 KB
logmod.py	1.25 KB
logrotate.py	7.72 KB
lvs.py	11.54 KB
lxc.py	147.27 KB
lxd.py	90.07 KB
mac_assistive.py	11.37 KB
mac_brew_pkg.py	19.91 KB
mac_desktop.py	2.77 KB
mac_group.py	6.62 KB
mac_keychain.py	6.39 KB
mac_pkgutil.py	2.84 KB
mac_portspkg.py	11.36 KB
mac_power.py	13.29 KB
mac_service.py	19.64 KB
mac_shadow.py	14.23 KB
mac_softwareupdate.py	14.52 KB
mac_sysctl.py	5.13 KB
mac_system.py	15.07 KB
mac_timezone.py	8.34 KB
mac_user.py	16.41 KB
mac_xattr.py	6.27 KB
macdefaults.py	2.33 KB
macpackage.py	6.66 KB
makeconf.py	17.31 KB
mandrill.py	6.31 KB
marathon.py	5.36 KB
match.py	13 KB
mattermost.py	3.4 KB
mdadm_raid.py	9.86 KB
mdata.py	3.38 KB
memcached.py	6.13 KB
mine.py	18.84 KB
minion.py	7.68 KB
mod_random.py	7.18 KB
modjk.py	12.48 KB
mongodb.py	29.75 KB
monit.py	5.51 KB
moosefs.py	3.87 KB
mount.py	58.44 KB
mssql.py	14.64 KB
msteams.py	2.11 KB
munin.py	2.4 KB
mysql.py	90.66 KB
nacl.py	9.72 KB
nagios.py	6.53 KB
nagios_rpc.py	5.09 KB
namecheap_domains.py	12.84 KB
namecheap_domains_dns.py	5.93 KB
namecheap_domains_ns.py	4.51 KB
namecheap_ssl.py	25.69 KB
namecheap_users.py	2.4 KB
napalm_bgp.py	9.72 KB
napalm_formula.py	11.33 KB
napalm_mod.py	61.37 KB
napalm_netacl.py	28.59 KB
napalm_network.py	93.22 KB
napalm_ntp.py	10.22 KB
napalm_probes.py	13.25 KB
napalm_route.py	5.09 KB
napalm_snmp.py	7.05 KB
napalm_users.py	6.49 KB
napalm_yang_mod.py	20.28 KB
netaddress.py	1.6 KB
netbox.py	32.22 KB
netbsd_sysctl.py	3.92 KB
netbsdservice.py	6.43 KB
netmiko_mod.py	19.61 KB
netscaler.py	27.02 KB
network.py	63.42 KB
neutron.py	44.92 KB
neutronng.py	15.02 KB
nexus.py	22.95 KB
nfs3.py	3.9 KB
nftables.py	33.58 KB
nginx.py	3.83 KB
nilrt_ip.py	36.18 KB
nix.py	8.03 KB
nova.py	19.6 KB
npm.py	10.4 KB
nspawn.py	41.35 KB
nxos.py	24.65 KB
nxos_api.py	14.72 KB
nxos_upgrade.py	14.74 KB
omapi.py	3.6 KB
openbsd_sysctl.py	3.74 KB
openbsdpkg.py	10.97 KB
openbsdrcctl_service.py	6.33 KB
openbsdservice.py	8.31 KB
openscap.py	2.81 KB
openstack_config.py	3.21 KB
openstack_mng.py	2.71 KB
openvswitch.py	17.19 KB
opkg.py	49.67 KB
opsgenie.py	3.29 KB
oracle.py	5.82 KB
osquery.py	24.93 KB
out.py	2.53 KB
pacmanpkg.py	31.92 KB
pagerduty.py	4.7 KB
pagerduty_util.py	13.48 KB
pam.py	2.01 KB
panos.py	61.05 KB
parallels.py	19.85 KB
parted_partition.py	21.53 KB
pcs.py	14.11 KB
pdbedit.py	10.79 KB
pecl.py	3.79 KB
peeringdb.py	8.39 KB
pf.py	9.51 KB
philips_hue.py	1.55 KB
pillar.py	21.37 KB
pip.py	53.42 KB
pkg_resource.py	12.3 KB
pkgin.py	17.29 KB
pkgng.py	61.07 KB
pkgutil.py	9.85 KB
portage_config.py	22.73 KB
postfix.py	16.24 KB
postgres.py	88.24 KB
poudriere.py	7.85 KB
powerpath.py	2.57 KB
proxy.py	11.49 KB
ps.py	20.89 KB
publish.py	10.25 KB
puppet.py	10.9 KB
purefa.py	33.59 KB
purefb.py	13.69 KB
pushbullet.py	1.88 KB
pushover_notify.py	3.48 KB
pw_group.py	4.62 KB
pw_user.py	12.47 KB
pyenv.py	6.93 KB
qemu_img.py	1.53 KB
qemu_nbd.py	3.28 KB
quota.py	6.43 KB
rabbitmq.py	38.4 KB
rallydev.py	6.09 KB
random_org.py	23.76 KB
rbac_solaris.py	16.05 KB
rbenv.py	10.75 KB
rdp.py	6.08 KB
rebootmgr.py	7.68 KB
redismod.py	16.36 KB
reg.py	16.36 KB
rest_pkg.py	2.26 KB
rest_sample_utils.py	558 B
rest_service.py	3.63 KB
restartcheck.py	24.1 KB
restconf.py	3.15 KB
ret.py	1.27 KB
rh_ip.py	38.55 KB
rh_service.py	16.61 KB
riak.py	5.19 KB
rpm_lowpkg.py	27.67 KB
rpmbuild_pkgbuild.py	24.53 KB
rsync.py	8.04 KB
runit.py	17.17 KB
rvm.py	11.1 KB
s3.py	9.93 KB
s6.py	3.62 KB
salt_proxy.py	4.48 KB
salt_version.py	4.58 KB
saltcheck.py	46.66 KB
saltcloudmod.py	954 B
saltutil.py	57.49 KB
schedule.py	50.81 KB
scp_mod.py	6.22 KB
scsi.py	2.66 KB
sdb.py	2.48 KB
seed.py	8.87 KB
selinux.py	24.2 KB
sensehat.py	7.79 KB
sensors.py	1.3 KB
serverdensity_device.py	8.1 KB
servicenow.py	4.36 KB
slack_notify.py	7.83 KB
slackware_service.py	6.84 KB
slsutil.py	19.04 KB
smartos_imgadm.py	12.04 KB
smartos_nictagadm.py	6.46 KB
smartos_virt.py	5.21 KB
smartos_vmadm.py	26.2 KB
smbios.py	10.05 KB
smf_service.py	8.52 KB
smtp.py	5.41 KB
snapper.py	27.14 KB
solaris_fmadm.py	11.2 KB
solaris_group.py	2.8 KB
solaris_shadow.py	7.98 KB
solaris_system.py	3.72 KB
solaris_user.py	11.06 KB
solarisipspkg.py	18.68 KB
solarispkg.py	15.4 KB
solr.py	45.54 KB
solrcloud.py	14.63 KB
splunk.py	8.14 KB
splunk_search.py	8.76 KB
sqlite3.py	2.54 KB
ssh.py	43.89 KB
ssh_pkg.py	1.08 KB
ssh_service.py	3.39 KB
state.py	82.34 KB
status.py	57.79 KB
statuspage.py	14.67 KB
supervisord.py	11.15 KB
suse_apache.py	2.45 KB
suse_ip.py	35.72 KB
svn.py	10.75 KB
swarm.py	13.5 KB
swift.py	5.53 KB
sysbench.py	6.62 KB
sysfs.py	6.61 KB
syslog_ng.py	31.52 KB
sysmod.py	22.59 KB
sysrc.py	3.38 KB
system.py	19.28 KB
system_profiler.py	3.54 KB
systemd_service.py	46.29 KB
telegram.py	3.28 KB
telemetry.py	12.87 KB
temp.py	831 B
test.py	15.4 KB
test_virtual.py	237 B
testinframod.py	9.92 KB
textfsm_mod.py	16.22 KB
timezone.py	19.98 KB
tls.py	58.63 KB
tomcat.py	18.59 KB
trafficserver.py	10.44 KB
transactional_update.py	35.83 KB
travisci.py	2.05 KB
tuned.py	2.34 KB
twilio_notify.py	2.95 KB
udev.py	3.72 KB
upstart_service.py	16.92 KB
uptime.py	3.23 KB
useradd.py	22.63 KB
uwsgi.py	996 B
vagrant.py	20.4 KB
varnish.py	3.08 KB
vault.py	15.61 KB
vbox_guest.py	10.55 KB
vboxmanage.py	14.71 KB
vcenter.py	1.61 KB
victorops.py	6.54 KB
virt.py	287.71 KB
virtualenv_mod.py	15.09 KB
vmctl.py	9.56 KB
vsphere.py	380.41 KB
webutil.py	3.66 KB
win_auditpol.py	4.74 KB
win_autoruns.py	2.29 KB
win_certutil.py	4.55 KB
win_dacl.py	32.27 KB
win_disk.py	1.8 KB
win_dism.py	20.7 KB
win_dns_client.py	4.19 KB
win_dsc.py	27.54 KB
win_event.py	22.32 KB
win_file.py	64.39 KB
win_firewall.py	20.15 KB
win_groupadd.py	11.27 KB
win_iis.py	68.78 KB
win_ip.py	11.43 KB
win_lgpo.py	491.76 KB
win_lgpo_reg.py	17.9 KB
win_license.py	2.72 KB
win_network.py	13.9 KB
win_ntp.py	1.8 KB
win_path.py	11.12 KB
win_pkg.py	86.43 KB
win_pki.py	15.8 KB
win_powercfg.py	9.85 KB
win_psget.py	8.97 KB
win_servermanager.py	14.21 KB
win_service.py	32.96 KB
win_shadow.py	3.03 KB
win_shortcut.py	16.49 KB
win_smtp_server.py	17.67 KB
win_snmp.py	13.38 KB
win_status.py	16.94 KB
win_system.py	40.61 KB
win_task.py	79.17 KB
win_timezone.py	13.3 KB
win_useradd.py	27.39 KB
win_wua.py	38.29 KB
win_wusa.py	5.88 KB
winrepo.py	6.09 KB
wordpress.py	4.71 KB
x509.py	63.1 KB
x509_v2.py	74.15 KB
xapi_virt.py	24.07 KB
xbpspkg.py	15.84 KB
xfs.py	15.35 KB
xml.py	2.14 KB
xmpp.py	5.28 KB
yaml.py	1.94 KB
yumpkg.py	116.5 KB
zabbix.py	97.55 KB
zcbuildout.py	28.16 KB
zenoss.py	5.64 KB
zfs.py	34.44 KB
zk_concurrency.py	11.16 KB
znc.py	2.26 KB
zoneadm.py	15.05 KB
zonecfg.py	21.85 KB
zookeeper.py	14.72 KB
zpool.py	44.02 KB
zypperpkg.py	94.87 KB

Edit: disk.py

"""
Module for managing disks and blockdevices
"""

import collections
import decimal
import logging
import os
import re
import subprocess

import salt.utils.decorators
import salt.utils.decorators.path
import salt.utils.path
import salt.utils.platform
from salt.exceptions import CommandExecutionError

__func_alias__ = {"format_": "format"}

log = logging.getLogger(__name__)

def __virtual__():
    """
    Only work on POSIX-like systems
    """
    if salt.utils.platform.is_windows():
        return False, "This module doesn't work on Windows."
    return True

def _parse_numbers(text):
    """
    Convert a string to a number, allowing for a K|M|G|T postfix, 32.8K.
    Returns a decimal number if the string is a real number,
    or the string unchanged otherwise.
    """
    if text.isdigit():
        return decimal.Decimal(text)

try:
        postPrefixes = {
            "K": "10E3",
            "M": "10E6",
            "G": "10E9",
            "T": "10E12",
            "P": "10E15",
            "E": "10E18",
            "Z": "10E21",
            "Y": "10E24",
        }
        if text[-1] in postPrefixes.keys():
            v = decimal.Decimal(text[:-1])
            v = v * decimal.Decimal(postPrefixes[text[-1]])
            return v
        else:
            return decimal.Decimal(text)
    except ValueError:
        return text

def _clean_flags(args, caller):
    """
    Sanitize flags passed into df
    """
    flags = ""
    if args is None:
        return flags
    allowed = ("a", "B", "h", "H", "i", "k", "l", "P", "t", "T", "x", "v")
    for flag in args:
        if flag in allowed:
            flags += flag
        else:
            raise CommandExecutionError("Invalid flag passed to {}".format(caller))
    return flags

def usage(args=None):
    """
    Return usage information for volumes mounted on this minion

.. versionchanged:: 2019.2.0

Default for SunOS changed to 1 kilobyte blocks

CLI Example:

.. code-block:: bash

salt '*' disk.usage
    """
    flags = _clean_flags(args, "disk.usage")
    if not os.path.isfile("/etc/mtab") and __grains__["kernel"] == "Linux":
        log.error("df cannot run without /etc/mtab")
        if __grains__.get("virtual_subtype") == "LXC":
            log.error(
                "df command failed and LXC detected. If you are running "
                "a Docker container, consider linking /proc/mounts to "
                "/etc/mtab or consider running Docker with -privileged"
            )
        return {}
    if __grains__["kernel"] == "Linux":
        cmd = "df -P"
    elif __grains__["kernel"] == "OpenBSD" or __grains__["kernel"] == "AIX":
        cmd = "df -kP"
    elif __grains__["kernel"] == "SunOS":
        cmd = "df -k"
    else:
        cmd = "df"
    if flags:
        cmd += " -{}".format(flags)
    ret = {}
    out = __salt__["cmd.run"](cmd, python_shell=False).splitlines()
    oldline = None
    for line in out:
        if not line:
            continue
        if line.startswith("Filesystem"):
            continue
        if oldline:
            line = oldline + " " + line
        comps = line.split()
        if len(comps) == 1:
            oldline = line
            continue
        else:
            oldline = None
        while len(comps) >= 2 and not comps[1].isdigit():
            comps[0] = "{} {}".format(comps[0], comps[1])
            comps.pop(1)
        if len(comps) < 2:
            continue
        try:
            if __grains__["kernel"] == "Darwin":
                ret[comps[8]] = {
                    "filesystem": comps[0],
                    "512-blocks": comps[1],
                    "used": comps[2],
                    "available": comps[3],
                    "capacity": comps[4],
                    "iused": comps[5],
                    "ifree": comps[6],
                    "%iused": comps[7],
                }
            else:
                ret[comps[5]] = {
                    "filesystem": comps[0],
                    "1K-blocks": comps[1],
                    "used": comps[2],
                    "available": comps[3],
                    "capacity": comps[4],
                }
        except IndexError:
            log.error("Problem parsing disk usage information")
            ret = {}
    return ret

def inodeusage(args=None):
    """
    Return inode usage information for volumes mounted on this minion

CLI Example:

.. code-block:: bash

salt '*' disk.inodeusage
    """
    flags = _clean_flags(args, "disk.inodeusage")
    if __grains__["kernel"] == "AIX":
        cmd = "df -i"
    else:
        cmd = "df -iP"
    if flags:
        cmd += " -{}".format(flags)
    ret = {}
    out = __salt__["cmd.run"](cmd, python_shell=False).splitlines()
    for line in out:
        if line.startswith("Filesystem"):
            continue
        comps = line.split()
        # Don't choke on empty lines
        if not comps:
            continue

try:
            if __grains__["kernel"] == "OpenBSD":
                ret[comps[8]] = {
                    "inodes": int(comps[5]) + int(comps[6]),
                    "used": comps[5],
                    "free": comps[6],
                    "use": comps[7],
                    "filesystem": comps[0],
                }
            elif __grains__["kernel"] == "AIX":
                ret[comps[6]] = {
                    "inodes": comps[4],
                    "used": comps[5],
                    "free": comps[2],
                    "use": comps[5],
                    "filesystem": comps[0],
                }
            else:
                ret[comps[5]] = {
                    "inodes": comps[1],
                    "used": comps[2],
                    "free": comps[3],
                    "use": comps[4],
                    "filesystem": comps[0],
                }
        except (IndexError, ValueError):
            log.error("Problem parsing inode usage information")
            ret = {}
    return ret

def percent(args=None):
    """
    Return partition information for volumes mounted on this minion

CLI Example:

.. code-block:: bash

salt '*' disk.percent /var
    """
    if __grains__["kernel"] == "Linux":
        cmd = "df -P"
    elif __grains__["kernel"] == "OpenBSD" or __grains__["kernel"] == "AIX":
        cmd = "df -kP"
    else:
        cmd = "df"
    ret = {}
    out = __salt__["cmd.run"](cmd, python_shell=False).splitlines()
    for line in out:
        if not line:
            continue
        if line.startswith("Filesystem"):
            continue
        comps = line.split()
        while len(comps) >= 2 and not comps[1].isdigit():
            comps[0] = "{} {}".format(comps[0], comps[1])
            comps.pop(1)
        if len(comps) < 2:
            continue
        try:
            if __grains__["kernel"] == "Darwin":
                ret[comps[8]] = comps[4]
            else:
                ret[comps[5]] = comps[4]
        except IndexError:
            log.error("Problem parsing disk usage information")
            ret = {}
    if args and args not in ret:
        log.error(
            "Problem parsing disk usage information: Partition '%s' does not exist!",
            args,
        )
        ret = {}
    elif args:
        return ret[args]

return ret

@salt.utils.decorators.path.which("blkid")
def blkid(device=None, token=None):
    """
    Return block device attributes: UUID, LABEL, etc. This function only works
    on systems where blkid is available.

device
        Device name from the system

token
        Any valid token used for the search

CLI Example:

.. code-block:: bash

salt '*' disk.blkid
        salt '*' disk.blkid /dev/sda
        salt '*' disk.blkid token='UUID=6a38ee5-7235-44e7-8b22-816a403bad5d'
        salt '*' disk.blkid token='TYPE=ext4'
    """
    cmd = ["blkid"]
    if device:
        cmd.append(device)
    elif token:
        cmd.extend(["-t", token])

ret = {}
    blkid_result = __salt__["cmd.run_all"](cmd, python_shell=False)

if blkid_result["retcode"] > 0:
        return ret

for line in blkid_result["stdout"].splitlines():
        if not line:
            continue
        comps = line.split()
        device = comps[0][:-1]
        info = {}
        device_attributes = re.split('"*"', line.partition(" ")[2])
        for key, value in zip(*[iter(device_attributes)] * 2):
            key = key.strip("=").strip(" ")
            info[key] = value.strip('"')
        ret[device] = info

return ret

def tune(device, **kwargs):
    """
    Set attributes for the specified device

CLI Example:

.. code-block:: bash

salt '*' disk.tune /dev/sda1 read-ahead=1024 read-write=True

Valid options are: ``read-ahead``, ``filesystem-read-ahead``,
    ``read-only``, ``read-write``.

See the ``blockdev(8)`` manpage for a more complete description of these
    options.
    """

kwarg_map = {
        "read-ahead": "setra",
        "filesystem-read-ahead": "setfra",
        "read-only": "setro",
        "read-write": "setrw",
    }
    opts = ""
    args = []
    for key in kwargs:
        if key in kwarg_map:
            switch = kwarg_map[key]
            if key != "read-write":
                args.append(switch.replace("set", "get"))
            else:
                args.append("getro")
            if kwargs[key] == "True" or kwargs[key] is True:
                opts += "--{} ".format(key)
            else:
                opts += "--{} {} ".format(switch, kwargs[key])
    cmd = "blockdev {}{}".format(opts, device)
    out = __salt__["cmd.run"](cmd, python_shell=False).splitlines()
    return dump(device, args)

def wipe(device):
    """
    Remove the filesystem information

CLI Example:

.. code-block:: bash

salt '*' disk.wipe /dev/sda1
    """

cmd = "wipefs -a {}".format(device)
    try:
        out = __salt__["cmd.run_all"](cmd, python_shell=False)
    except subprocess.CalledProcessError as err:
        return False
    if out["retcode"] == 0:
        return True
    else:
        log.error("Error wiping device %s: %s", device, out["stderr"])
        return False

def dump(device, args=None):
    """
    Return all contents of dumpe2fs for a specified device

CLI Example:

.. code-block:: bash

salt '*' disk.dump /dev/sda1
    """
    cmd = (
        "blockdev --getro --getsz --getss --getpbsz --getiomin --getioopt --getalignoff"
        " --getmaxsect --getsize --getsize64 --getra --getfra {}".format(device)
    )
    ret = {}
    opts = [c[2:] for c in cmd.split() if c.startswith("--")]
    out = __salt__["cmd.run_all"](cmd, python_shell=False)
    if out["retcode"] == 0:
        lines = [line for line in out["stdout"].splitlines() if line]
        count = 0
        for line in lines:
            ret[opts[count]] = line
            count = count + 1
        if args:
            temp_ret = {}
            for arg in args:
                temp_ret[arg] = ret[arg]
            return temp_ret
        else:
            return ret
    else:
        return False

def resize2fs(device):
    """
    Resizes the filesystem.

CLI Example:

.. code-block:: bash

salt '*' disk.resize2fs /dev/sda1
    """
    cmd = "resize2fs {}".format(device)
    try:
        out = __salt__["cmd.run_all"](cmd, python_shell=False)
    except subprocess.CalledProcessError as err:
        return False
    if out["retcode"] == 0:
        return True

@salt.utils.decorators.path.which("sync")
@salt.utils.decorators.path.which("mkfs")
def format_(
    device,
    fs_type="ext4",
    inode_size=None,
    lazy_itable_init=None,
    fat=None,
    force=False,
):
    """
    Format a filesystem onto a device

.. versionadded:: 2016.11.0

device
        The device in which to create the new filesystem

fs_type
        The type of filesystem to create

inode_size
        Size of the inodes

This option is only enabled for ext and xfs filesystems

lazy_itable_init
        If enabled and the uninit_bg feature is enabled, the inode table will
        not be fully initialized by mke2fs.  This speeds up filesystem
        initialization noticeably, but it requires the kernel to finish
        initializing the filesystem  in  the  background  when  the filesystem
        is first mounted.  If the option value is omitted, it defaults to 1 to
        enable lazy inode table zeroing.

This option is only enabled for ext filesystems

fat
        FAT size option. Can be 12, 16 or 32, and can only be used on
        fat or vfat filesystems.

force
        Force mke2fs to create a filesystem, even if the specified device is
        not a partition on a block special device. This option is only enabled
        for ext and xfs filesystems

This option is dangerous, use it with caution.

CLI Example:

.. code-block:: bash

salt '*' disk.format /dev/sdX1
    """
    cmd = ["mkfs", "-t", str(fs_type)]
    if inode_size is not None:
        if fs_type[:3] == "ext":
            cmd.extend(["-i", str(inode_size)])
        elif fs_type == "xfs":
            cmd.extend(["-i", "size={}".format(inode_size)])
    if lazy_itable_init is not None:
        if fs_type[:3] == "ext":
            cmd.extend(["-E", "lazy_itable_init={}".format(lazy_itable_init)])
    if fat is not None and fat in (12, 16, 32):
        if fs_type[-3:] == "fat":
            cmd.extend(["-F", fat])
    if force:
        if fs_type[:3] == "ext":
            cmd.append("-F")
        elif fs_type == "xfs":
            cmd.append("-f")
    cmd.append(str(device))

mkfs_success = __salt__["cmd.retcode"](cmd, ignore_retcode=True) == 0
    sync_success = __salt__["cmd.retcode"]("sync", ignore_retcode=True) == 0

return all([mkfs_success, sync_success])

@salt.utils.decorators.path.which_bin(["lsblk", "df"])
def fstype(device):
    """
    Return the filesystem name of the specified device

.. versionadded:: 2016.11.0

device
        The name of the device

CLI Example:

.. code-block:: bash

salt '*' disk.fstype /dev/sdX1
    """
    if salt.utils.path.which("lsblk"):
        lsblk_out = __salt__["cmd.run"](
            "lsblk -o fstype {}".format(device)
        ).splitlines()
        if len(lsblk_out) > 1:
            fs_type = lsblk_out[1].strip()
            if fs_type:
                return fs_type

if salt.utils.path.which("df"):
        # the fstype was not set on the block device, so inspect the filesystem
        # itself for its type
        if __grains__["kernel"] == "AIX" and os.path.isfile("/usr/sysv/bin/df"):
            df_out = __salt__["cmd.run"](
                "/usr/sysv/bin/df -n {}".format(device)
            ).split()
            if len(df_out) > 2:
                fs_type = df_out[2]
                if fs_type:
                    return fs_type
        else:
            df_out = __salt__["cmd.run"]("df -T {}".format(device)).splitlines()
            if len(df_out) > 1:
                fs_type = df_out[1]
                if fs_type:
                    return fs_type

return ""

@salt.utils.decorators.path.which("hdparm")
def _hdparm(args, failhard=True):
    """
    Execute hdparm
    Fail hard when required
    return output when possible
    """
    cmd = "hdparm {}".format(args)
    result = __salt__["cmd.run_all"](cmd)
    if result["retcode"] != 0:
        msg = "{}: {}".format(cmd, result["stderr"])
        if failhard:
            raise CommandExecutionError(msg)
        else:
            log.warning(msg)

return result["stdout"]

@salt.utils.decorators.path.which("hdparm")
def hdparms(disks, args=None):
    """
    Retrieve all info's for all disks
    parse 'em into a nice dict
    (which, considering hdparms output, is quite a hassle)

.. versionadded:: 2016.3.0

CLI Example:

.. code-block:: bash

salt '*' disk.hdparms /dev/sda
    """
    all_parms = "aAbBcCdgHiJkMmNnQrRuW"
    if args is None:
        args = all_parms
    elif isinstance(args, (list, tuple)):
        args = "".join(args)

if not isinstance(disks, (list, tuple)):
        disks = [disks]

out = {}
    for disk in disks:
        if not disk.startswith("/dev"):
            disk = "/dev/{}".format(disk)
        disk_data = {}
        for line in _hdparm("-{} {}".format(args, disk), False).splitlines():
            line = line.strip()
            if not line or line == disk + ":":
                continue

if ":" in line:
                key, vals = line.split(":", 1)
                key = re.sub(r" is$", "", key)
            elif "=" in line:
                key, vals = line.split("=", 1)
            else:
                continue
            key = key.strip().lower().replace(" ", "_")
            vals = vals.strip()

rvals = []
            if re.match(r"[0-9]+ $.*$", vals):
                vals = vals.split(" ")
                rvals.append(int(vals[0]))
                rvals.append(vals[1].strip("()"))
            else:
                valdict = {}
                for val in re.split(r"[/,]", vals.strip()):
                    val = val.strip()
                    try:
                        val = int(val)
                        rvals.append(val)
                    except Exception:  # pylint: disable=broad-except
                        if "=" in val:
                            deep_key, val = val.split("=", 1)
                            deep_key = deep_key.strip()
                            val = val.strip()
                            if val:
                                valdict[deep_key] = val
                        elif val:
                            rvals.append(val)
                if valdict:
                    rvals.append(valdict)
                if not rvals:
                    continue
                elif len(rvals) == 1:
                    rvals = rvals[0]
            disk_data[key] = rvals

out[disk] = disk_data

return out

@salt.utils.decorators.path.which("hdparm")
def hpa(disks, size=None):
    """
    Get/set Host Protected Area settings

T13 INCITS 346-2001 (1367D) defines the BEER (Boot Engineering Extension Record)
    and PARTIES (Protected Area Run Time Interface Extension Services), allowing
    for a Host Protected Area on a disk.

It's often used by OEMS to hide parts of a disk, and for overprovisioning SSD's

.. warning::
        Setting the HPA might clobber your data, be very careful with this on active disks!

.. versionadded:: 2016.3.0

CLI Example:

.. code-block:: bash

salt '*' disk.hpa /dev/sda
        salt '*' disk.hpa /dev/sda 5%
        salt '*' disk.hpa /dev/sda 10543256
    """

hpa_data = {}
    for disk, data in hdparms(disks, "N").items():
        visible, total, status = next(iter(data.values()))
        if visible == total or "disabled" in status:
            hpa_data[disk] = {"total": total}
        else:
            hpa_data[disk] = {
                "total": total,
                "visible": visible,
                "hidden": total - visible,
            }

if size is None:
        return hpa_data

for disk, data in hpa_data.items():
        try:
            size = data["total"] - int(size)
        except Exception:  # pylint: disable=broad-except
            if "%" in size:
                size = int(size.strip("%"))
                size = (100 - size) * data["total"]
                size /= 100
        if size <= 0:
            size = data["total"]

_hdparm("--yes-i-know-what-i-am-doing -Np{} {}".format(size, disk))

def smart_attributes(dev, attributes=None, values=None):
    """
    Fetch SMART attributes
    Providing attributes will deliver only requested attributes
    Providing values will deliver only requested values for attributes

Default is the Backblaze recommended
    set (https://www.backblaze.com/blog/hard-drive-smart-stats/):
    (5,187,188,197,198)

.. versionadded:: 2016.3.0

CLI Example:

.. code-block:: bash

salt '*' disk.smart_attributes /dev/sda
        salt '*' disk.smart_attributes /dev/sda attributes=(5,187,188,197,198)
    """

if not dev.startswith("/dev/"):
        dev = "/dev/" + dev

cmd = "smartctl --attributes {}".format(dev)
    smart_result = __salt__["cmd.run_all"](cmd, output_loglevel="quiet")
    if smart_result["retcode"] != 0:
        raise CommandExecutionError(smart_result["stderr"])

smart_result = iter(smart_result["stdout"].splitlines())

fields = []
    for line in smart_result:
        if line.startswith("ID#"):
            fields = re.split(r"\s+", line.strip())
            fields = [key.lower() for key in fields[1:]]
            break

if values is not None:
        fields = [field if field in values else "_" for field in fields]

smart_attr = {}
    for line in smart_result:
        if not re.match(r"[\s]*\d", line):
            break

line = re.split(r"\s+", line.strip(), maxsplit=len(fields))
        attr = int(line[0])

if attributes is not None and attr not in attributes:
            continue

data = dict(zip(fields, line[1:]))
        try:
            del data["_"]
        except Exception:  # pylint: disable=broad-except
            pass

for field in data:
            val = data[field]
            try:
                val = int(val)
            except Exception:  # pylint: disable=broad-except
                try:
                    val = [int(value) for value in val.split(" ")]
                except Exception:  # pylint: disable=broad-except
                    pass
            data[field] = val

smart_attr[attr] = data

return smart_attr

@salt.utils.decorators.path.which("iostat")
def iostat(interval=1, count=5, disks=None):
    """
    Gather and return (averaged) IO stats.

.. versionadded:: 2016.3.0

.. versionchanged:: 2016.11.4
        Added support for AIX

CLI Example:

.. code-block:: bash

salt '*' disk.iostat 1 5 disks=sda
    """
    if salt.utils.platform.is_linux():
        return _iostat_linux(interval, count, disks)
    elif salt.utils.platform.is_freebsd():
        return _iostat_fbsd(interval, count, disks)
    elif salt.utils.platform.is_aix():
        return _iostat_aix(interval, count, disks)

def _iostats_dict(header, stats):
    """
    Transpose collected data, average it, stomp it in dict using header

Use Decimals so we can properly calc & round, convert to float 'caus' we can't transmit Decimals over 0mq
    """
    stats = [
        float((sum(stat) / len(stat)).quantize(decimal.Decimal(".01")))
        for stat in zip(*stats)
    ]
    stats = dict(zip(header, stats))
    return stats

def _iostat_fbsd(interval, count, disks):
    """
    Tested on FreeBSD, quite likely other BSD's only need small changes in cmd syntax
    """
    if disks is None:
        iostat_cmd = "iostat -xC -w {} -c {} ".format(interval, count)
    elif isinstance(disks, str):
        iostat_cmd = "iostat -x -w {} -c {} {}".format(interval, count, disks)
    else:
        iostat_cmd = "iostat -x -w {} -c {} {}".format(interval, count, " ".join(disks))

sys_stats = []
    dev_stats = collections.defaultdict(list)
    sys_header = []
    dev_header = []
    h_len = 1000  # randomly absurdly high

ret = iter(
        __salt__["cmd.run_stdout"](iostat_cmd, output_loglevel="quiet").splitlines()
    )
    for line in ret:
        if not line.startswith("device"):
            continue
        elif not dev_header:
            dev_header = line.split()[1:]
        while line is not False:
            line = next(ret, False)
            if not line or not line[0].isalnum():
                break
            line = line.split()
            disk = line[0]
            stats = [decimal.Decimal(x) for x in line[1:]]
            # h_len will become smallest number of fields in stat lines
            if len(stats) < h_len:
                h_len = len(stats)
            dev_stats[disk].append(stats)

iostats = {}

# The header was longer than the smallest number of fields
    # Therefore the sys stats are hidden in there
    if h_len < len(dev_header):
        sys_header = dev_header[h_len:]
        dev_header = dev_header[0:h_len]

for disk, stats in dev_stats.items():
            if len(stats[0]) > h_len:
                sys_stats = [stat[h_len:] for stat in stats]
                dev_stats[disk] = [stat[0:h_len] for stat in stats]

iostats["sys"] = _iostats_dict(sys_header, sys_stats)

for disk, stats in dev_stats.items():
        iostats[disk] = _iostats_dict(dev_header, stats)

return iostats

def _iostat_linux(interval, count, disks):
    if disks is None:
        iostat_cmd = "iostat -x {} {} ".format(interval, count)
    elif isinstance(disks, str):
        iostat_cmd = "iostat -xd {} {} {}".format(interval, count, disks)
    else:
        iostat_cmd = "iostat -xd {} {} {}".format(interval, count, " ".join(disks))

sys_stats = []
    dev_stats = collections.defaultdict(list)
    sys_header = []
    dev_header = []

ret = iter(
        __salt__["cmd.run_stdout"](iostat_cmd, output_loglevel="quiet").splitlines()
    )
    for line in ret:
        if line.startswith("avg-cpu:"):
            if not sys_header:
                sys_header = tuple(line.split()[1:])
            line = [decimal.Decimal(x) for x in next(ret).split()]
            sys_stats.append(line)
        elif line.startswith("Device:"):
            if not dev_header:
                dev_header = tuple(line.split()[1:])
            while line is not False:
                line = next(ret, False)
                if not line or not line[0].isalnum():
                    break
                line = line.split()
                disk = line[0]
                stats = [decimal.Decimal(x) for x in line[1:]]
                dev_stats[disk].append(stats)

iostats = {}

if sys_header:
        iostats["sys"] = _iostats_dict(sys_header, sys_stats)

for disk, stats in dev_stats.items():
        iostats[disk] = _iostats_dict(dev_header, stats)

return iostats

def _iostat_aix(interval, count, disks):
    """
    AIX support to gather and return (averaged) IO stats.
    """
    log.debug("AIX disk iostat entry")

if disks is None:
        iostat_cmd = "iostat -dD {} {} ".format(interval, count)
    elif isinstance(disks, str):
        iostat_cmd = "iostat -dD {} {} {}".format(disks, interval, count)
    else:
        iostat_cmd = "iostat -dD {} {} {}".format(" ".join(disks), interval, count)

ret = {}
    procn = None
    fields = []
    disk_name = ""
    disk_mode = ""
    dev_stats = collections.defaultdict(list)
    for line in __salt__["cmd.run"](iostat_cmd).splitlines():
        # Note: iostat -dD is per-system
        #
        # root@l490vp031_pub:~/devtest# iostat -dD hdisk6 1 3
        #
        # System configuration: lcpu=8 drives=1 paths=2 vdisks=2
        #
        # hdisk6          xfer:  %tm_act      bps      tps      bread      bwrtn
        #                          0.0      0.0      0.0        0.0        0.0
        #                read:      rps  avgserv  minserv  maxserv   timeouts      fails
        #                          0.0      0.0      0.0      0.0           0          0
        #               write:      wps  avgserv  minserv  maxserv   timeouts      fails
        #                          0.0      0.0      0.0      0.0           0          0
        #               queue:  avgtime  mintime  maxtime  avgwqsz    avgsqsz     sqfull
        #                          0.0      0.0      0.0      0.0        0.0         0.0
        # --------------------------------------------------------------------------------
        #
        # hdisk6          xfer:  %tm_act      bps      tps      bread      bwrtn
        #                          9.6     16.4K     4.0       16.4K       0.0
        #                read:      rps  avgserv  minserv  maxserv   timeouts      fails
        #                          4.0      4.9      0.3      9.9           0          0
        #               write:      wps  avgserv  minserv  maxserv   timeouts      fails
        #                          0.0      0.0      0.0      0.0           0          0
        #               queue:  avgtime  mintime  maxtime  avgwqsz    avgsqsz     sqfull
        #                          0.0      0.0      0.0      0.0        0.0         0.0
        # --------------------------------------------------------------------------------
        #
        # hdisk6          xfer:  %tm_act      bps      tps      bread      bwrtn
        #                          0.0      0.0      0.0        0.0        0.0
        #                read:      rps  avgserv  minserv  maxserv   timeouts      fails
        #                          0.0      0.0      0.3      9.9           0          0
        #               write:      wps  avgserv  minserv  maxserv   timeouts      fails
        #                          0.0      0.0      0.0      0.0           0          0
        #               queue:  avgtime  mintime  maxtime  avgwqsz    avgsqsz     sqfull
        #                          0.0      0.0      0.0      0.0        0.0         0.0
        # --------------------------------------------------------------------------------
        if not line or line.startswith("System") or line.startswith("-----------"):
            continue

if not re.match(r"\s", line):
            # seen disk name
            dsk_comps = line.split(":")
            dsk_firsts = dsk_comps[0].split()
            disk_name = dsk_firsts[0]
            disk_mode = dsk_firsts[1]
            fields = dsk_comps[1].split()
            if disk_name not in dev_stats.keys():
                dev_stats[disk_name] = []
                procn = len(dev_stats[disk_name])
                dev_stats[disk_name].append({})
                dev_stats[disk_name][procn][disk_mode] = {}
                dev_stats[disk_name][procn][disk_mode]["fields"] = fields
                dev_stats[disk_name][procn][disk_mode]["stats"] = []
            continue

if ":" in line:
            comps = line.split(":")
            fields = comps[1].split()
            disk_mode = comps[0].lstrip()
            if disk_mode not in dev_stats[disk_name][0].keys():
                dev_stats[disk_name][0][disk_mode] = {}
                dev_stats[disk_name][0][disk_mode]["fields"] = fields
                dev_stats[disk_name][0][disk_mode]["stats"] = []
        else:
            line = line.split()
            stats = [_parse_numbers(x) for x in line[:]]
            dev_stats[disk_name][0][disk_mode]["stats"].append(stats)

iostats = {}

for disk, list_modes in dev_stats.items():
        iostats[disk] = {}
        for modes in list_modes:
            for disk_mode in modes.keys():
                fields = modes[disk_mode]["fields"]
                stats = modes[disk_mode]["stats"]
                iostats[disk][disk_mode] = _iostats_dict(fields, stats)

return iostats

def get_fstype_from_path(path):
    """
    Return the filesystem type of the underlying device for a specified path.

.. versionadded:: 3006.0

path
        The path for the function to evaluate.

CLI Example:

.. code-block:: bash

salt '*' disk.get_fstype_from_path /root
    """
    dev = __salt__["mount.get_device_from_path"](path)
    return fstype(dev)