[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') |
---|
[331] | 13 | e, txt = pbs.error() |
---|
[324] | 14 | if e: |
---|
[331] | 15 | print "statnode erro: %s" %pbs.pbs_strerror(e) |
---|
| 16 | print "txt %s\n" %txt |
---|
[324] | 17 | |
---|
| 18 | for node in nodes: |
---|
| 19 | print node.name |
---|
| 20 | attrs = node.attribs |
---|
| 21 | for attr in attrs: |
---|
[327] | 22 | print '\t ', attr.name, ' = ', attr.value |
---|
[324] | 23 | |
---|
[327] | 24 | # try: |
---|
| 25 | # mom_port = socket.getservbyname('pbs_resmom', 'tcp') |
---|
| 26 | # mom_id = pbs.openrm(node.name, mom_port) |
---|
| 27 | # except socket.error, detail: |
---|
| 28 | # mom_id = pbs.openrm(node.name, pbs.PBS_MANAGER_SERVICE_PORT) |
---|
[324] | 29 | |
---|
[327] | 30 | err = 0 |
---|
[328] | 31 | #mom_id = pbs.openrm(node.name, pbs.PBS_MANAGER_SERVICE_PORT) |
---|
| 32 | mom_id = pbs.openrm("localhost", 15003) |
---|
[331] | 33 | print mom_id |
---|
[327] | 34 | e, e_txt = pbs.error() |
---|
| 35 | print "openrm", e, e_txt |
---|
| 36 | print node.name, mom_id, pbs.PBS_MANAGER_SERVICE_PORT |
---|
[331] | 37 | #pbs.flushreq() |
---|
[327] | 38 | #pbs.fullresp(1) |
---|
[331] | 39 | #e, e_txt = pbs.error() |
---|
| 40 | #print "flush", e, e_txt |
---|
[327] | 41 | |
---|
| 42 | #pbs.addreq_err(mom_id, err, "arch") |
---|
[331] | 43 | pbs.addreq(mom_id, "larch") |
---|
[327] | 44 | e, e_txt = pbs.error() |
---|
| 45 | print "addreq:", e, e_txt |
---|
| 46 | |
---|
[328] | 47 | #print pbs.activereq() |
---|
| 48 | #e, e_txt = pbs.error() |
---|
| 49 | #print "addreq:", e, e_txt |
---|
[327] | 50 | |
---|
| 51 | #resp = pbs.getreq_err(err, mom_id) |
---|
| 52 | resp = pbs.getreq(mom_id) |
---|
| 53 | e, e_txt = pbs.error() |
---|
| 54 | print e, e_txt |
---|
| 55 | print err, resp |
---|
| 56 | |
---|
| 57 | sys.exit(1) |
---|
| 58 | print 'rm interface' |
---|
| 59 | |
---|
[324] | 60 | mom_keys = pbs.get_mom_values(mom_id) |
---|
| 61 | for key in mom_keys.keys(): |
---|
[327] | 62 | print '\t mom %s = %s' %(key, mom_keys[key]) |
---|
[324] | 63 | |
---|
| 64 | print 'Testing list with user supplied keywords' |
---|
| 65 | |
---|
| 66 | l = [ 'ncpus', 'loadave' ] |
---|
| 67 | mom_keys = pbs.get_mom_values(mom_id, l) |
---|
| 68 | for key in mom_keys.keys(): |
---|
| 69 | print '\t %s = %s' %(key, mom_keys[key]) |
---|
| 70 | |
---|
| 71 | main() |
---|