Adding onos-gen-partitions
Change-Id: I6910e4e992231a7ffdb2c4bf43723529fa367172
Showing
1 changed file
with
52 additions
and
0 deletions
tools/test/bin/onos-gen-partitions
0 → 100755
| 1 | +#!/usr/bin/env python | ||
| 2 | +''' | ||
| 3 | + Generate the partitions json file from the $OC* environment variables | ||
| 4 | + | ||
| 5 | + Usage: onos-gen-partitions [output file] | ||
| 6 | + If output file is not provided, the json is written to stdout. | ||
| 7 | +''' | ||
| 8 | + | ||
| 9 | +from os import environ | ||
| 10 | +from collections import deque, OrderedDict | ||
| 11 | +import re | ||
| 12 | +import json | ||
| 13 | +import sys | ||
| 14 | + | ||
| 15 | +convert = lambda text: int(text) if text.isdigit() else text.lower() | ||
| 16 | +alphanum_key = lambda key: [convert(c) for c in re.split('([0-9]+)', key)] | ||
| 17 | + | ||
| 18 | +def get_OC_vars(): | ||
| 19 | + vars = [] | ||
| 20 | + for var in environ: | ||
| 21 | + if re.match(r"OC[0-9]+", var): | ||
| 22 | + vars.append(var) | ||
| 23 | + return sorted(vars, key=alphanum_key) | ||
| 24 | + | ||
| 25 | +def get_nodes(vars, port=7238): | ||
| 26 | + node = lambda k: { 'id': k, 'ip': k, 'tcpPort': port } | ||
| 27 | + return [ node(environ[v]) for v in vars ] | ||
| 28 | + | ||
| 29 | +def generate_permutations(nodes, k): | ||
| 30 | + l = deque(nodes) | ||
| 31 | + perms = {} | ||
| 32 | + for i in range(1, len(nodes)+1): | ||
| 33 | + perms['p%d' % i] = list(l)[:k] | ||
| 34 | + l.rotate(-1) | ||
| 35 | + return OrderedDict(sorted(perms.iteritems(), key=lambda (k, v): alphanum_key(k))) | ||
| 36 | + | ||
| 37 | +if __name__ == '__main__': | ||
| 38 | + vars = get_OC_vars() | ||
| 39 | + nodes = get_nodes(vars) | ||
| 40 | + partitions = generate_permutations(nodes, 3) | ||
| 41 | + data = { | ||
| 42 | + 'nodes': nodes, | ||
| 43 | + 'partitions': partitions | ||
| 44 | + } | ||
| 45 | + output = json.dumps(data, indent=4) | ||
| 46 | + | ||
| 47 | + if len(sys.argv) == 2: | ||
| 48 | + filename = sys.argv[1] | ||
| 49 | + with open(filename, 'w') as f: | ||
| 50 | + f.write(output) | ||
| 51 | + else: | ||
| 52 | + print output |
-
Please register or login to post a comment