[7089] | 1 | #!/usr/bin/env python
|
---|
[10051] | 2 | #
|
---|
| 3 | # Zoek de eerste vrije (== niet in een wleiden.conf gedefinieerde) interlink
|
---|
| 4 | # range.
|
---|
| 5 | #
|
---|
| 6 | # Maybe this should use the py-iplib module?
|
---|
| 7 | #
|
---|
| 8 | # Orignal: lodewijk@wirelessleiden.nl
|
---|
| 9 | # 07/March/2012 - Rick van der Zwet <info@rickvanderzwet.nl>
|
---|
| 10 | #
|
---|
[3130] | 11 | import re
|
---|
[4150] | 12 | import sys
|
---|
[7936] | 13 | import glob
|
---|
[10051] | 14 | import gformat
|
---|
[3130] | 15 |
|
---|
| 16 | def parseaddr(s):
|
---|
[10051] | 17 | f = s.split('.')
|
---|
| 18 | return (long(f[0]) << 24L) + \
|
---|
| 19 | (long(f[1]) << 16L) + \
|
---|
| 20 | (long(f[2]) << 8L) + \
|
---|
| 21 | long(f[3])
|
---|
[3130] | 22 |
|
---|
[10051] | 23 |
|
---|
[3130] | 24 | def showaddr(a):
|
---|
[10051] | 25 | return "%d.%d.%d.%d" % ((a >> 24) & 0xff, (a >> 16) & 0xff, (a >> 8) & 0xff, a & 0xff)
|
---|
[3130] | 26 |
|
---|
[10051] | 27 |
|
---|
[11514] | 28 | bezet_cache = None
|
---|
[13321] | 29 | def make_cache():
|
---|
| 30 | global bezet_cache
|
---|
| 31 | bezet = {}
|
---|
| 32 | substs = {}
|
---|
| 33 | def add_ip(address):
|
---|
| 34 | if '/' not in address:
|
---|
| 35 | address += "/32"
|
---|
| 36 |
|
---|
| 37 | addr, mask = address.split('/')
|
---|
| 38 | if addr in substs:
|
---|
| 39 | addr = substs[addr]
|
---|
| 40 | try:
|
---|
| 41 | addr = parseaddr(addr)
|
---|
| 42 | mask = int(mask)
|
---|
| 43 | addr = addr & ~((1 << (32 - mask)) - 1)
|
---|
| 44 | for i in range(0, (1 << (32 - mask))):
|
---|
| 45 | bezet[addr + i] = 1
|
---|
| 46 | except ValueError, e:
|
---|
| 47 | print "[FOUT] in address %s node %s" % (address, node)
|
---|
| 48 |
|
---|
| 49 | for node in gformat.get_hostlist():
|
---|
| 50 | datadump = gformat.get_yaml(node)
|
---|
| 51 |
|
---|
| 52 | add_ip(datadump['masterip'])
|
---|
| 53 | for key in datadump['autogen_iface_keys']:
|
---|
[13641] | 54 | if 'ip' in datadump[key]:
|
---|
| 55 | add_ip(datadump[key]['ip'])
|
---|
[13321] | 56 |
|
---|
| 57 | # Fetching smallest in use IP
|
---|
| 58 | # XXX: Currently not used for anything
|
---|
| 59 | i = parseaddr("255.255.255.255")
|
---|
| 60 | for k in bezet.keys():
|
---|
| 61 | if k < i:
|
---|
| 62 | i = k
|
---|
| 63 | bezet_cache = bezet
|
---|
| 64 | return bezet
|
---|
| 65 |
|
---|
| 66 |
|
---|
[11514] | 67 | def get_ranges(interlink, size, aantal, use_history=False):
|
---|
| 68 | global bezet_cache
|
---|
[10051] | 69 | numaddrs = 1 << (32 - size)
|
---|
| 70 |
|
---|
[11514] | 71 | if not use_history or (use_history and not bezet_cache):
|
---|
[13321] | 72 | bezet = make_cache()
|
---|
[11514] | 73 | else:
|
---|
| 74 | bezet = bezet_cache
|
---|
[10051] | 75 |
|
---|
[11514] | 76 |
|
---|
[10051] | 77 | # Interlinks are living in special ranges usually
|
---|
| 78 | if interlink:
|
---|
| 79 | i = parseaddr("172.16.3.0")
|
---|
| 80 | else:
|
---|
| 81 | i = parseaddr("172.17.0.0")
|
---|
| 82 |
|
---|
| 83 | ranges = []
|
---|
| 84 | for n in xrange(aantal):
|
---|
| 85 | okay = False
|
---|
| 86 | while not okay:
|
---|
| 87 | while bezet.has_key(i):
|
---|
| 88 | i = i + numaddrs
|
---|
| 89 |
|
---|
| 90 | # Assume Ok, till we find a already used IP
|
---|
| 91 | okay = True
|
---|
| 92 | for j in range(numaddrs):
|
---|
| 93 | if bezet.has_key(i + j):
|
---|
| 94 | i = i + numaddrs
|
---|
| 95 | okay = False
|
---|
| 96 | break
|
---|
| 97 | ranges.append(i)
|
---|
| 98 | bezet[i] = 1
|
---|
| 99 |
|
---|
[11514] | 100 | bezet_cache = bezet
|
---|
[10051] | 101 | return ranges
|
---|
| 102 |
|
---|
| 103 |
|
---|
| 104 |
|
---|
[8228] | 105 | def main():
|
---|
[10051] | 106 | if len(sys.argv) < 2:
|
---|
| 107 | print "Gebruik: %s <interlink|subnet> <grootte> [aantal]" % sys.argv[0]
|
---|
| 108 | print "Voorbeelden:"
|
---|
| 109 | print "\tVoor drie /29 interlinks - '%s interlink 29 3'" % sys.argv[0]
|
---|
| 110 | print "\tVoor een (1) /24 subnet - '%s subnet 24'" % sys.argv[0]
|
---|
| 111 | exit(1)
|
---|
| 112 |
|
---|
| 113 | # Argument parsing
|
---|
| 114 | interlink = sys.argv[1] == 'interlink'
|
---|
| 115 | size = int(sys.argv[2])
|
---|
| 116 | try:
|
---|
| 117 | aantal = int(sys.argv[3])
|
---|
| 118 | except (KeyError,IndexError):
|
---|
| 119 | aantal = 1
|
---|
| 120 |
|
---|
| 121 | ranges = get_ranges(interlink, size, aantal)
|
---|
| 122 | numaddrs = 1 << (32 - size)
|
---|
[8227] | 123 |
|
---|
[10051] | 124 | for i in ranges:
|
---|
| 125 | print "%s/%d:" % (showaddr(i), size),
|
---|
| 126 | if size > 28:
|
---|
| 127 | print " en ".join([showaddr(i) for i in range(i + 1, i + numaddrs - 1)])
|
---|
| 128 | else:
|
---|
| 129 | print " en ".join([showaddr(i) for i in range(i + 1, i + 4)]),
|
---|
| 130 | print "...",
|
---|
| 131 | print " en ".join([showaddr(i) for i in range(i + numaddrs - 7, i + numaddrs - 4)])
|
---|
[3130] | 132 |
|
---|
[8228] | 133 | if __name__ == "__main__":
|
---|
| 134 | main()
|
---|