[324] | 1 | #!/usr/bin/python |
---|
| 2 | |
---|
| 3 | import pbs |
---|
| 4 | import sys |
---|
| 5 | import time |
---|
| 6 | import socket |
---|
| 7 | |
---|
| 8 | def main(): |
---|
| 9 | server = pbs.pbs_default() |
---|
| 10 | c = pbs.pbs_connect(server) |
---|
| 11 | |
---|
| 12 | nodes = pbs.pbs_statnode(c, '', 'NULL', 'NULL') |
---|
| 13 | e, txt= pbs.error() |
---|
| 14 | if e: |
---|
| 15 | print txt |
---|
| 16 | |
---|
| 17 | for node in nodes: |
---|
| 18 | print node.name |
---|
| 19 | attrs = node.attribs |
---|
| 20 | for attr in attrs: |
---|
[327] | 21 | print '\t ', attr.name, ' = ', attr.value |
---|
[324] | 22 | |
---|
[327] | 23 | # try: |
---|
| 24 | # mom_port = socket.getservbyname('pbs_resmom', 'tcp') |
---|
| 25 | # mom_id = pbs.openrm(node.name, mom_port) |
---|
| 26 | # except socket.error, detail: |
---|
| 27 | # mom_id = pbs.openrm(node.name, pbs.PBS_MANAGER_SERVICE_PORT) |
---|
[324] | 28 | |
---|
[327] | 29 | err = 0 |
---|
[328] | 30 | #mom_id = pbs.openrm(node.name, pbs.PBS_MANAGER_SERVICE_PORT) |
---|
| 31 | mom_id = pbs.openrm("localhost", 15003) |
---|
[327] | 32 | e, e_txt = pbs.error() |
---|
| 33 | print "openrm", e, e_txt |
---|
| 34 | print node.name, mom_id, pbs.PBS_MANAGER_SERVICE_PORT |
---|
| 35 | pbs.flushreq() |
---|
| 36 | #pbs.fullresp(1) |
---|
| 37 | e, e_txt = pbs.error() |
---|
| 38 | print "flush", e, e_txt |
---|
| 39 | |
---|
| 40 | #pbs.addreq_err(mom_id, err, "arch") |
---|
| 41 | pbs.addreq(mom_id, "arch") |
---|
| 42 | e, e_txt = pbs.error() |
---|
| 43 | print "addreq:", e, e_txt |
---|
| 44 | |
---|
[328] | 45 | #print pbs.activereq() |
---|
| 46 | #e, e_txt = pbs.error() |
---|
| 47 | #print "addreq:", e, e_txt |
---|
[327] | 48 | |
---|
| 49 | #resp = pbs.getreq_err(err, mom_id) |
---|
| 50 | resp = pbs.getreq(mom_id) |
---|
| 51 | e, e_txt = pbs.error() |
---|
| 52 | print e, e_txt |
---|
| 53 | print err, resp |
---|
| 54 | |
---|
| 55 | sys.exit(1) |
---|
| 56 | print 'rm interface' |
---|
| 57 | |
---|
[324] | 58 | mom_keys = pbs.get_mom_values(mom_id) |
---|
| 59 | for key in mom_keys.keys(): |
---|
[327] | 60 | print '\t mom %s = %s' %(key, mom_keys[key]) |
---|
[324] | 61 | |
---|
| 62 | print 'Testing list with user supplied keywords' |
---|
| 63 | |
---|
| 64 | l = [ 'ncpus', 'loadave' ] |
---|
| 65 | mom_keys = pbs.get_mom_values(mom_id, l) |
---|
| 66 | for key in mom_keys.keys(): |
---|
| 67 | print '\t %s = %s' %(key, mom_keys[key]) |
---|
| 68 | |
---|
| 69 | main() |
---|