ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / lib / python2.7 / site-packages / azurelinuxagent / common / osutil

# Microsoft Azure Linux Agent
#
# Copyright 2018 Microsoft Corporation
# Copyright 2018 Sonus Networks, Inc. (d.b.a. Ribbon Communications Operating Company)
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# Requires Python 2.6+ and Openssl 1.0+
#
import os
import re
import azurelinuxagent.common.logger as logger
import azurelinuxagent.common.utils.shellutil as shellutil
import azurelinuxagent.common.utils.fileutil as fileutil
from azurelinuxagent.common.osutil.default import DefaultOSUtil
from azurelinuxagent.common.utils.networkutil import NetworkInterfaceCard

class OpenWRTOSUtil(DefaultOSUtil):

def __init__(self):
        super(OpenWRTOSUtil, self).__init__()
        self.agent_conf_file_path = '/etc/waagent.conf'
        self.dhclient_name = 'udhcpc'
        self.ip_command_output = re.compile('^\d+:\s+(\w+):\s+(.*)$')  # pylint: disable=W1401
        self.jit_enabled = True
        
    def eject_dvd(self, chk_err=True):
        logger.warn('eject is not supported on OpenWRT')

def useradd(self, username, expiration=None, comment=None):
        """
        Create user account with 'username'
        """
        userentry = self.get_userentry(username)
        if userentry is not None:
            logger.info("User {0} already exists, skip useradd", username)
            return

if expiration is not None:
            cmd = ["useradd", "-m", username, "-s", "/bin/ash", "-e", expiration]
        else:
            cmd = ["useradd", "-m", username, "-s", "/bin/ash"]
        
        if not os.path.exists("/home"):
            os.mkdir("/home")

if comment is not None:
            cmd.extend(["-c", comment])
        self._run_command_raising_OSUtilError(cmd, err_msg="Failed to create user account:{0}".format(username))

def get_dhcp_pid(self):
        return self._get_dhcp_pid(["pidof", self.dhclient_name])

def get_nic_state(self, as_string=False):
        """
        Capture NIC state (IPv4 and IPv6 addresses plus link state).

:return: Dictionary of NIC state objects, with the NIC name as key
        :rtype: dict(str,NetworkInformationCard)
        """
        if as_string:  # as_string not supported on open wrt
            return ''

state = {}
        status, output = shellutil.run_get_output("ip -o link", chk_err=False, log_cmd=False)

if status != 0:
            logger.verbose("Could not fetch NIC link info; status {0}, {1}".format(status, output))
            return {}

for entry in output.splitlines():
            result = self.ip_command_output.match(entry)
            if result:
                name = result.group(1)
                state[name] = NetworkInterfaceCard(name, result.group(2))

self._update_nic_state(state, "ip -o -f inet address", NetworkInterfaceCard.add_ipv4, "an IPv4 address")
        self._update_nic_state(state, "ip -o -f inet6 address", NetworkInterfaceCard.add_ipv6, "an IPv6 address")

return state

def _update_nic_state(self, state, ip_command, handler, description):
        """
        Update the state of NICs based on the output of a specified ip subcommand.

:param dict(str, NetworkInterfaceCard) state: Dictionary of NIC state objects
        :param str ip_command: The ip command to run
        :param handler: A method on the NetworkInterfaceCard class
        :param str description: Description of the particular information being added to the state
        """
        status, output = shellutil.run_get_output(ip_command, chk_err=True)
        if status != 0:
            return

for entry in output.splitlines():
            result = self.ip_command_output.match(entry)
            if result:
                interface_name = result.group(1)
                if interface_name in state:
                    handler(state[interface_name], result.group(2))
                else:
                    logger.error("Interface {0} has {1} but no link state".format(interface_name, description))

def is_dhcp_enabled(self):
        pass

def start_dhcp_service(self):
        pass

def stop_dhcp_service(self):
        pass

def start_network(self) :
        return shellutil.run("/etc/init.d/network start", chk_err=True)

def restart_ssh_service(self):  # pylint: disable=R1710
        # Since Dropbear is the default ssh server on OpenWRt, lets do a sanity check
        if os.path.exists("/etc/init.d/sshd"):
            return shellutil.run("/etc/init.d/sshd restart", chk_err=True)
        else:
            logger.warn("sshd service does not exists")

def stop_agent_service(self):
        return shellutil.run("/etc/init.d/{0} stop".format(self.service_name), chk_err=True)

def start_agent_service(self):
        return shellutil.run("/etc/init.d/{0} start".format(self.service_name), chk_err=True)

def register_agent_service(self):
        return shellutil.run("/etc/init.d/{0} enable".format(self.service_name), chk_err=True)

def unregister_agent_service(self):
        return shellutil.run("/etc/init.d/{0} disable".format(self.service_name), chk_err=True)

def set_hostname(self, hostname):
        fileutil.write_file('/etc/hostname', hostname)
        commands = [['uci', 'set', 'system.@system[0].hostname={0}'.format(hostname)], ['uci', 'commit', 'system'],
                    ['/etc/init.d/system', 'reload']]
        self._run_multiple_commands_without_raising(commands, log_error=False, continue_on_error=False)

def remove_rules_files(self, rules_files=""):
        pass

[+] ..
[-] __init__.py [edit]
[-] alpine.py [edit]
[-] arch.py [edit]
[-] bigip.py [edit]
[-] clearlinux.py [edit]
[-] coreos.py [edit]
[-] debian.py [edit]
[-] default.py [edit]
[-] factory.py [edit]
[-] freebsd.py [edit]
[-] gaia.py [edit]
[-] openbsd.py [edit]
[-] redhat.py [edit]
[-] suse.py [edit]
[-] ubuntu.py [edit]
[-] __init__.pyc [edit]
[-] __init__.pyo [edit]
[-] alpine.pyc [edit]
[-] alpine.pyo [edit]
[-] photonos.pyc [edit]
[-] arch.pyc [edit]
[-] arch.pyo [edit]
[-] photonos.pyo [edit]
[-] bigip.pyc [edit]
[-] bigip.pyo [edit]
[-] photonos.py [edit]
[-] clearlinux.pyc [edit]
[-] clearlinux.pyo [edit]
[-] coreos.pyc [edit]
[-] coreos.pyo [edit]
[-] debian.pyc [edit]
[-] debian.pyo [edit]
[-] default.pyc [edit]
[-] default.pyo [edit]
[-] factory.pyc [edit]
[-] factory.pyo [edit]
[-] freebsd.pyc [edit]
[-] freebsd.pyo [edit]
[-] gaia.pyc [edit]
[-] gaia.pyo [edit]
[-] openbsd.pyc [edit]
[-] openbsd.pyo [edit]
[-] redhat.pyc [edit]
[-] redhat.pyo [edit]
[-] suse.pyc [edit]
[-] suse.pyo [edit]
[-] ubuntu.pyc [edit]
[-] ubuntu.pyo [edit]
[-] iosxe.py [edit]
[-] nsbsd.py [edit]
[-] openwrt.py [edit]
[-] iosxe.pyc [edit]
[-] iosxe.pyo [edit]
[-] nsbsd.pyc [edit]
[-] nsbsd.pyo [edit]
[-] openwrt.pyc [edit]
[-] openwrt.pyo [edit]
[-] mariner.py [edit]
[-] systemd.py [edit]
[-] mariner.pyc [edit]
[-] mariner.pyo [edit]
[-] systemd.pyc [edit]
[-] systemd.pyo [edit]