41596d7062
This change also removes some methods that weren't needed. Change-Id: Iafa215d7c9418b0e3b82b7ff9a4919ee6c5ac6a7
66 lines
2.3 KiB
Python
66 lines
2.3 KiB
Python
# Copyright 2016 Mirantis, Inc.
|
|
#
|
|
# 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.
|
|
|
|
|
|
def get_all_bridged_interfaces_for_node(remote, excluded_criteria=None):
|
|
"""Return all network bridges for a node.
|
|
|
|
:param remote: SSH connection to the node.
|
|
:type remote: SSHClient
|
|
:param excluded_criteria: regular expression to filter out items
|
|
:type excluded_criteria: str
|
|
:returns: list of interfaces
|
|
:rtype: list
|
|
"""
|
|
# TODO(rpromyshlennikov): do filtration on python side
|
|
excluded_criteria_cmd = (
|
|
" | grep -v '%s'" % excluded_criteria
|
|
if excluded_criteria else "")
|
|
cmd = "brctl show | awk '/br-/{{print $1}}'{excluded}".format(
|
|
excluded=excluded_criteria_cmd)
|
|
interfaces = remote.check_call(cmd)["stdout"]
|
|
return [iface.strip() for iface in interfaces]
|
|
|
|
|
|
def switch_interface(remote, interface, up=True):
|
|
"""Turn a network interface up or down.
|
|
|
|
:param remote: SSH connection to the node.
|
|
:type remote: SSHClient
|
|
:param interface: interface name.
|
|
:type interface: str
|
|
:param up: whether the interface should be turned up (default: True).
|
|
:type up: boolean
|
|
"""
|
|
method = 'up' if up else 'down'
|
|
cmd = "if{method} {interface}".format(method=method,
|
|
interface=interface)
|
|
remote.check_call(cmd)
|
|
|
|
|
|
def simulate_network_interrupt_on_node(remote, interval=30):
|
|
"""Simulate a network outage on a node.
|
|
|
|
:param remote: SSH connection to the node.
|
|
:type remote: SSHClient
|
|
:param interval: outage duration in seconds (default: 30).
|
|
:type interval: int
|
|
"""
|
|
cmd = (
|
|
"(/sbin/iptables -I INPUT -j DROP && "
|
|
"sleep {interval} && "
|
|
"/sbin/iptables -D INPUT -j DROP) 2>&1>/dev/null &".format(
|
|
interval=interval))
|
|
remote.execute(cmd)
|