[1765] | 1 | #!/usr/bin/python |
---|
| 2 | |
---|
[1779] | 3 | from xen.xm.main import SERVER_LEGACY_XMLRPC, SERVER_XEN_API, parseServer, parseAuthentication |
---|
[1765] | 4 | from xen.xend import sxp |
---|
[1779] | 5 | import atexit |
---|
[1765] | 6 | |
---|
| 7 | serverType, serverURI = parseServer() |
---|
| 8 | |
---|
| 9 | if serverType == SERVER_XEN_API: |
---|
| 10 | from xen.xm import XenAPI |
---|
| 11 | server = XenAPI.Session(serverURI) |
---|
| 12 | username, password = parseAuthentication() |
---|
| 13 | server.login_with_password(username, password) |
---|
| 14 | def logout(): |
---|
| 15 | try: |
---|
| 16 | server.xenapi.session.logout() |
---|
| 17 | except: |
---|
| 18 | pass |
---|
| 19 | atexit.register(logout) |
---|
| 20 | else: |
---|
| 21 | from xen.util.xmlrpcclient import ServerProxy |
---|
| 22 | server = ServerProxy(serverURI) |
---|
| 23 | |
---|
| 24 | import sys |
---|
| 25 | |
---|
| 26 | if len(sys.argv) > 1: |
---|
| 27 | cmd = sys.argv[1] |
---|
| 28 | else: |
---|
| 29 | cmd = None |
---|
| 30 | |
---|
| 31 | def getDomains(): |
---|
| 32 | ret = {} |
---|
| 33 | if serverType == SERVER_XEN_API: |
---|
[1779] | 34 | domains = server.xenapi.VM.get_all_records() |
---|
[1765] | 35 | metrics = server.xenapi.VM_metrics.get_all_records() |
---|
| 36 | for d in domains.values(): |
---|
[1774] | 37 | ret[d['uuid'].replace('-', '_')] = {'name': d['name_label'], |
---|
| 38 | 'cpu_time': sum(metrics[d['metrics']]['VCPUs_utilisation'].values()), |
---|
| 39 | 'domid': d['domid'], |
---|
[1777] | 40 | 'uuid': d['uuid'], |
---|
[1779] | 41 | # No equivalent |
---|
[1774] | 42 | } |
---|
[1765] | 43 | return ret |
---|
| 44 | else: |
---|
| 45 | domains = server.xend.domains_with_state(True, 'all', True) |
---|
| 46 | for d in domains: |
---|
[1779] | 47 | data = {'name': sxp.child_value(d, 'name', 'UNKNOWN'), |
---|
| 48 | 'cpu_time': sxp.child_value(d, 'cpu_time', 0.0), |
---|
| 49 | 'domid': sxp.child_value(d, 'domid', -1), |
---|
| 50 | 'uuid': sxp.child_value(d, 'uuid', 'NONE'), |
---|
| 51 | } |
---|
| 52 | try: |
---|
| 53 | sched = server.xend.domain.sched_credit_get(data['name']) |
---|
| 54 | data['sched-credit'] = sched |
---|
| 55 | except: |
---|
| 56 | data['sched-credit'] = None |
---|
| 57 | ret[sxp.child_value(d, 'uuid', 'NONE').replace('-', '_')] = data |
---|
[1765] | 58 | return ret |
---|
| 59 | |
---|
| 60 | if cmd == 'config': |
---|
| 61 | print """ |
---|
| 62 | graph_title Xen domain CPU usage |
---|
| 63 | graph_args --base 1000 -r --lower-limit 0 --upper-limit 800 |
---|
| 64 | graph_vlabel % |
---|
| 65 | graph_scale no |
---|
| 66 | graph_info This graph shows how CPU time is spent by Xen domains. |
---|
| 67 | graph_category system |
---|
| 68 | graph_period second""" |
---|
| 69 | domains = getDomains() |
---|
| 70 | for d in sorted(domains): |
---|
| 71 | name = domains[d]['name'] |
---|
| 72 | if name[0:2] == 'd_': |
---|
[1779] | 73 | name = 'db domid %d' % domains[d]['domid'] |
---|
[1765] | 74 | print "%s.label %s" % (d, name) |
---|
| 75 | if domains[d]['domid'] == 0: |
---|
| 76 | print "%s.draw AREA" % d |
---|
| 77 | else: |
---|
| 78 | print "%s.draw STACK" % d |
---|
[1779] | 79 | print "%s.max 19200000000" % d # 64x 100% CPU usage |
---|
[1765] | 80 | print "%s.min 0" % d |
---|
| 81 | print "%s.type DERIVE" % d |
---|
[1779] | 82 | if domains[d].get('sched-credit'): |
---|
| 83 | print "%s.info uuid %s CPU weight %d cap %d%%" % (d, domains[d]['uuid'], domains[d]['sched-credit']['weight'], domains[d]['sched-credit']['cap']) |
---|
| 84 | else: |
---|
| 85 | print "%s.info uuid %s" % (d, domains[d]['uuid']) |
---|
[1777] | 86 | print "%s.cdef %s,10000,/" % (d, d) |
---|
[1765] | 87 | sys.exit(0) |
---|
| 88 | |
---|
| 89 | domains = getDomains() |
---|
| 90 | for d in sorted(domains): |
---|
[1777] | 91 | print "%s.value %s" % (d, long(domains[d]['cpu_time']*1000000)) |
---|