MR K IS HERE

MRKShell
Server IP : 172.67.193.120 / Your IP : 104.23.243.235
Web Server : nginx/1.14.1
System : Linux comtuc2-s-2vcpu-8gb-160gb-intel-nyc3 4.18.0-348.7.1.el8_5.x86_64 #1 SMP Wed Dec 22 13:25:12 UTC 2021 x86_64
User : nginx ( 991)
PHP Version : 7.2.34
Disable Function : NONE
MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON
Directory : /usr/lib/python3.6/site-packages/sos/report/plugins/
Upload File :
[ HOME SHELL ]
Current File : /usr/lib/python3.6/site-packages/sos/report/plugins/ovn_central.py
# Copyright (C) 2018 Mark Michelson <mmichels@redhat.com>

# This file is part of the sos project: https://github.com/sosreport/sos
#
# This copyrighted material is made available to anyone wishing to use,
# modify, copy, or redistribute it subject to the terms and conditions of
# version 2 of the GNU General Public License.
#
# See the LICENSE file in the source distribution for further information.

from sos.report.plugins import (
    Plugin,
    RedHatPlugin,
    DebianPlugin,
    UbuntuPlugin,
    SoSPredicate,
)
import json
import os


class OVNCentral(Plugin):

    short_desc = 'OVN Northd'
    plugin_name = "ovn_central"
    profiles = ('network', 'virt')

    def get_tables_from_schema(self, filename, skip=[]):
        if self._container_name:
            cmd = "cat %s" % filename
            res = self.exec_cmd(cmd, timeout=None, foreground=True,
                                container=self._container_name)
            if res['status'] != 0:
                self._log_error("Could not retrieve DB schema file from "
                                "container %s" % self._container_name)
                return
            try:
                db = json.loads(res['output'])
            except Exception:
                self._log_error("Cannot parse JSON file %s" % filename)
                return
        else:
            try:
                with open(filename, 'r') as f:
                    try:
                        db = json.load(f)
                    except Exception:
                        self._log_error(
                            "Cannot parse JSON file %s" % filename)
                        return
            except IOError as ex:
                self._log_error(
                    "Could not open DB schema file %s: %s" % (filename, ex))
                return
        try:
            return [table for table in dict.keys(
                db['tables']) if table not in skip]
        except AttributeError:
            self._log_error("DB schema %s has no 'tables' key" % filename)

    def add_database_output(self, tables, cmds, ovn_cmd):
        if not tables:
            return
        for table in tables:
            cmds.append('%s list %s' % (ovn_cmd, table))

    def check_enabled(self):
        return (self.container_exists('ovs-dbs-bundle.*') or
                super(OVNCentral, self).check_enabled())

    def setup(self):
        self._container_name = self.get_container_by_name('ovs-dbs-bundle.*')

        ovs_rundir = os.environ.get('OVS_RUNDIR')
        for pidfile in ['ovnnb_db.pid', 'ovnsb_db.pid', 'ovn-northd.pid']:
            self.add_copy_spec([
                os.path.join('/var/lib/openvswitch/ovn', pidfile),
                os.path.join('/usr/local/var/run/openvswitch', pidfile),
                os.path.join('/run/openvswitch/', pidfile),
            ])

            if ovs_rundir:
                self.add_copy_spec(os.path.join(ovs_rundir, pidfile))

        if self.get_option("all_logs"):
            self.add_copy_spec("/var/log/ovn/")
        else:
            self.add_copy_spec("/var/log/ovn/*.log")

        # Some user-friendly versions of DB output
        nbctl_cmds = [
            'ovn-nbctl show',
            'ovn-nbctl get-ssl',
            'ovn-nbctl get-connection',
            'ovn-nbctl list loadbalancer',
            'ovn-nbctl list Load_Balancer',
            'ovn-nbctl list ACL',
            'ovn-nbctl list Logical_Switch_Port',
        ]

        sbctl_cmds = [
            'ovn-sbctl show',
            'ovn-sbctl lflow-list',
            'ovn-sbctl get-ssl',
            'ovn-sbctl get-connection',
        ]

        schema_dir = '/usr/share/openvswitch'

        nb_tables = self.get_tables_from_schema(os.path.join(
            schema_dir, 'ovn-nb.ovsschema'))

        self.add_database_output(nb_tables, nbctl_cmds, 'ovn-nbctl')

        cmds = nbctl_cmds

        # Can only run sbdb commands if we are the leader
        co = {'cmd': "ovs-appctl -t {} cluster/status OVN_Southbound".
              format(self.ovn_sbdb_sock_path),
              "output": "Leader: self"}
        if self.test_predicate(self, pred=SoSPredicate(self, cmd_outputs=co)):
            sb_tables = self.get_tables_from_schema(os.path.join(
                schema_dir, 'ovn-sb.ovsschema'), ['Logical_Flow'])
            self.add_database_output(sb_tables, sbctl_cmds, 'ovn-sbctl')
            cmds += sbctl_cmds

        # If OVN is containerized, we need to run the above commands inside
        # the container.
        cmds = [
            self.fmt_container_cmd(self._container_name, cmd) for cmd in cmds
        ]

        self.add_cmd_output(cmds, foreground=True)

        self.add_copy_spec("/etc/sysconfig/ovn-northd")

        ovs_dbdir = os.environ.get('OVS_DBDIR')
        for dbfile in ['ovnnb_db.db', 'ovnsb_db.db']:
            self.add_copy_spec([
                os.path.join('/var/lib/openvswitch/ovn', dbfile),
                os.path.join('/usr/local/etc/openvswitch', dbfile),
                os.path.join('/etc/openvswitch', dbfile),
                os.path.join('/var/lib/openvswitch', dbfile),
            ])
            if ovs_dbdir:
                self.add_copy_spec(os.path.join(ovs_dbdir, dbfile))

        self.add_journal(units="ovn-northd")


class RedHatOVNCentral(OVNCentral, RedHatPlugin):

    packages = ('openvswitch-ovn-central', 'ovn2.*-central', )
    ovn_sbdb_sock_path = '/var/run/openvswitch/ovnsb_db.ctl'


class DebianOVNCentral(OVNCentral, DebianPlugin, UbuntuPlugin):

    packages = ('ovn-central', )
    ovn_sbdb_sock_path = '/var/run/ovn/ovnsb_db.ctl'
Anon7 - 2022
AnonSec Team