aboutsummaryrefslogtreecommitdiffstats
path: root/app/monitoring/checks/check_instance_communictions.py
blob: d3a94b7c96f6c3f926c97c5b278fea824d91c546 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
#!/usr/bin/env python3
###############################################################################
# Copyright (c) 2017 Koren Lev (Cisco Systems), Yaron Yogev (Cisco Systems)   #
# and others                                                                  #
#                                                                             #
# All rights reserved. This program and the accompanying materials            #
# are made available under the terms of the Apache License, Version 2.0       #
# which accompanies this distribution, and is available at                    #
# http://www.apache.org/licenses/LICENSE-2.0                                  #
###############################################################################

# find status of instance network
# For each instance vNIC - take the MAC address
# For each vService in the same network as the instance,
# use local_service_id attribute in the following command in the network node:
# "ip netns exec <local_service_id> arp -n"
# look for the instance vNIC's mac_address to appear in the response
# for each mac_address:
# - if Flag 'C' = 'Complete' - mark result OK for that instance,
# - 'I' = 'Incomplete' - mark as 'warn',
# - no mac_address mark as 'error'

import sys
import subprocess

from binary_converter import binary2str


arp_headers = ['Address', 'HWtype', 'HWaddress', 'Flags', 'Mask', 'Iface']
arp_mac_pos = arp_headers.index('HWaddress')
arp_flags_pos = arp_headers.index('Flags')


def check_vnic_tuple(vnic_and_service: str):
    tuple_parts = vnic_and_service.split(',')
    local_service_id = tuple_parts[0]
    mac_address = tuple_parts[1]
    check_output = None
    try:
        netns_cmd = 'ip netns exec {} arp -n'.format(local_service_id)
        check_output = 'MAC={}, local_service_id={}\n'\
            .format(mac_address, local_service_id)
        netns_out = subprocess.check_output([netns_cmd],
                                            stderr=subprocess.STDOUT,
                                            shell=True)
        netns_out = binary2str(netns_out)
        check_output += '{}\n'.format(netns_out)
        netns_lines = netns_out.splitlines()
        if not netns_lines or \
                netns_lines[0].endswith('No such file or directory'):
            check_rc = 2
        else:
            mac_found = False
            flags = None
            for l in netns_lines:
                line_parts = l.split()
                line_mac = line_parts[arp_mac_pos]
                if len(line_parts) > arp_mac_pos and line_mac == mac_address:
                    mac_found = True
                    flags = line_parts[arp_flags_pos]
                    break
            if mac_found:
                check_rc = 1 if flags == 'I' else 0
            else:
                check_rc = 2
    except subprocess.CalledProcessError as e:
        check_output = str(e)
        check_rc = 2
    return check_rc, check_output


if len(sys.argv) < 2:
    print('usage: ' + sys.argv[0] +
          ' <vService local_service_id>,<MAC>[;<>,<>]...')
    exit(1)

rc = 0
output = ''
vnics = str(sys.argv[1]).split(';')
for vnic_tuple in vnics:
    tuple_ret, out = check_vnic_tuple(vnic_tuple)
    rc = min(rc, tuple_ret)
    output += out
print(output)
exit(rc)