[309] | 1 | # This file was automatically generated by SWIG (http://www.swig.org). |
---|
| 2 | # Version 1.3.40 |
---|
| 3 | # |
---|
| 4 | # Do not make changes to this file unless you know what you are doing--modify |
---|
| 5 | # the SWIG interface file instead. |
---|
| 6 | # This file is compatible with both classic and new-style classes. |
---|
| 7 | |
---|
| 8 | from sys import version_info |
---|
| 9 | if version_info >= (2,6,0): |
---|
| 10 | def swig_import_helper(): |
---|
| 11 | from os.path import dirname |
---|
| 12 | import imp |
---|
| 13 | fp = None |
---|
| 14 | try: |
---|
| 15 | fp, pathname, description = imp.find_module('_pbs', [dirname(__file__)]) |
---|
| 16 | except ImportError: |
---|
| 17 | import _pbs |
---|
| 18 | return _pbs |
---|
| 19 | if fp is not None: |
---|
| 20 | try: |
---|
| 21 | _mod = imp.load_module('_pbs', fp, pathname, description) |
---|
| 22 | finally: |
---|
| 23 | fp.close() |
---|
| 24 | return _mod |
---|
| 25 | _pbs = swig_import_helper() |
---|
| 26 | del swig_import_helper |
---|
| 27 | else: |
---|
| 28 | import _pbs |
---|
| 29 | del version_info |
---|
| 30 | try: |
---|
| 31 | _swig_property = property |
---|
| 32 | except NameError: |
---|
| 33 | pass # Python < 2.2 doesn't have 'property'. |
---|
| 34 | def _swig_setattr_nondynamic(self,class_type,name,value,static=1): |
---|
| 35 | if (name == "thisown"): return self.this.own(value) |
---|
| 36 | if (name == "this"): |
---|
| 37 | if type(value).__name__ == 'SwigPyObject': |
---|
| 38 | self.__dict__[name] = value |
---|
| 39 | return |
---|
| 40 | method = class_type.__swig_setmethods__.get(name,None) |
---|
| 41 | if method: return method(self,value) |
---|
| 42 | if (not static) or hasattr(self,name): |
---|
| 43 | self.__dict__[name] = value |
---|
| 44 | else: |
---|
| 45 | raise AttributeError("You cannot add attributes to %s" % self) |
---|
| 46 | |
---|
| 47 | def _swig_setattr(self,class_type,name,value): |
---|
| 48 | return _swig_setattr_nondynamic(self,class_type,name,value,0) |
---|
| 49 | |
---|
| 50 | def _swig_getattr(self,class_type,name): |
---|
| 51 | if (name == "thisown"): return self.this.own() |
---|
| 52 | method = class_type.__swig_getmethods__.get(name,None) |
---|
| 53 | if method: return method(self) |
---|
| 54 | raise AttributeError(name) |
---|
| 55 | |
---|
| 56 | def _swig_repr(self): |
---|
| 57 | try: strthis = "proxy of " + self.this.__repr__() |
---|
| 58 | except: strthis = "" |
---|
| 59 | return "<%s.%s; %s >" % (self.__class__.__module__, self.__class__.__name__, strthis,) |
---|
| 60 | |
---|
| 61 | try: |
---|
| 62 | _object = object |
---|
| 63 | _newclass = 1 |
---|
| 64 | except AttributeError: |
---|
| 65 | class _object : pass |
---|
| 66 | _newclass = 0 |
---|
| 67 | |
---|
| 68 | |
---|
| 69 | |
---|
| 70 | def new_attrl(*args): |
---|
| 71 | return _pbs.new_attrl(*args) |
---|
| 72 | new_attrl = _pbs.new_attrl |
---|
| 73 | |
---|
| 74 | def new_attropl(*args): |
---|
| 75 | return _pbs.new_attropl(*args) |
---|
| 76 | new_attropl = _pbs.new_attropl |
---|
| 77 | |
---|
| 78 | def new_batch_status(): |
---|
| 79 | return _pbs.new_batch_status() |
---|
| 80 | new_batch_status = _pbs.new_batch_status |
---|
| 81 | |
---|
| 82 | def get_error(): |
---|
| 83 | return _pbs.get_error() |
---|
| 84 | get_error = _pbs.get_error |
---|
| 85 | ATTR_a = _pbs.ATTR_a |
---|
| 86 | ATTR_c = _pbs.ATTR_c |
---|
| 87 | ATTR_e = _pbs.ATTR_e |
---|
| 88 | ATTR_f = _pbs.ATTR_f |
---|
| 89 | ATTR_g = _pbs.ATTR_g |
---|
| 90 | ATTR_h = _pbs.ATTR_h |
---|
| 91 | ATTR_j = _pbs.ATTR_j |
---|
| 92 | ATTR_k = _pbs.ATTR_k |
---|
| 93 | ATTR_l = _pbs.ATTR_l |
---|
| 94 | ATTR_m = _pbs.ATTR_m |
---|
| 95 | ATTR_o = _pbs.ATTR_o |
---|
| 96 | ATTR_p = _pbs.ATTR_p |
---|
| 97 | ATTR_q = _pbs.ATTR_q |
---|
| 98 | ATTR_r = _pbs.ATTR_r |
---|
| 99 | ATTR_t = _pbs.ATTR_t |
---|
| 100 | ATTR_array_id = _pbs.ATTR_array_id |
---|
| 101 | ATTR_u = _pbs.ATTR_u |
---|
| 102 | ATTR_v = _pbs.ATTR_v |
---|
| 103 | ATTR_A = _pbs.ATTR_A |
---|
| 104 | ATTR_M = _pbs.ATTR_M |
---|
| 105 | ATTR_N = _pbs.ATTR_N |
---|
| 106 | ATTR_S = _pbs.ATTR_S |
---|
| 107 | ATTR_depend = _pbs.ATTR_depend |
---|
| 108 | ATTR_inter = _pbs.ATTR_inter |
---|
| 109 | ATTR_stagein = _pbs.ATTR_stagein |
---|
| 110 | ATTR_stageout = _pbs.ATTR_stageout |
---|
| 111 | ATTR_jobtype = _pbs.ATTR_jobtype |
---|
| 112 | ATTR_ctime = _pbs.ATTR_ctime |
---|
| 113 | ATTR_exechost = _pbs.ATTR_exechost |
---|
| 114 | ATTR_mtime = _pbs.ATTR_mtime |
---|
| 115 | ATTR_qtime = _pbs.ATTR_qtime |
---|
| 116 | ATTR_session = _pbs.ATTR_session |
---|
| 117 | ATTR_euser = _pbs.ATTR_euser |
---|
| 118 | ATTR_egroup = _pbs.ATTR_egroup |
---|
| 119 | ATTR_hashname = _pbs.ATTR_hashname |
---|
| 120 | ATTR_hopcount = _pbs.ATTR_hopcount |
---|
| 121 | ATTR_security = _pbs.ATTR_security |
---|
| 122 | ATTR_sched_hint = _pbs.ATTR_sched_hint |
---|
| 123 | ATTR_substate = _pbs.ATTR_substate |
---|
| 124 | ATTR_name = _pbs.ATTR_name |
---|
| 125 | ATTR_owner = _pbs.ATTR_owner |
---|
| 126 | ATTR_used = _pbs.ATTR_used |
---|
| 127 | ATTR_state = _pbs.ATTR_state |
---|
| 128 | ATTR_queue = _pbs.ATTR_queue |
---|
| 129 | ATTR_server = _pbs.ATTR_server |
---|
| 130 | ATTR_maxrun = _pbs.ATTR_maxrun |
---|
| 131 | ATTR_maxreport = _pbs.ATTR_maxreport |
---|
| 132 | ATTR_total = _pbs.ATTR_total |
---|
| 133 | ATTR_comment = _pbs.ATTR_comment |
---|
| 134 | ATTR_cookie = _pbs.ATTR_cookie |
---|
| 135 | ATTR_qrank = _pbs.ATTR_qrank |
---|
| 136 | ATTR_altid = _pbs.ATTR_altid |
---|
| 137 | ATTR_etime = _pbs.ATTR_etime |
---|
| 138 | ATTR_exitstat = _pbs.ATTR_exitstat |
---|
| 139 | ATTR_forwardx11 = _pbs.ATTR_forwardx11 |
---|
| 140 | ATTR_submit_args = _pbs.ATTR_submit_args |
---|
| 141 | ATTR_tokens = _pbs.ATTR_tokens |
---|
| 142 | ATTR_netcounter = _pbs.ATTR_netcounter |
---|
| 143 | ATTR_umask = _pbs.ATTR_umask |
---|
| 144 | ATTR_start_time = _pbs.ATTR_start_time |
---|
| 145 | ATTR_start_count = _pbs.ATTR_start_count |
---|
| 146 | ATTR_checkpoint_dir = _pbs.ATTR_checkpoint_dir |
---|
| 147 | ATTR_checkpoint_name = _pbs.ATTR_checkpoint_name |
---|
| 148 | ATTR_checkpoint_time = _pbs.ATTR_checkpoint_time |
---|
| 149 | ATTR_checkpoint_restart_status = _pbs.ATTR_checkpoint_restart_status |
---|
| 150 | ATTR_restart_name = _pbs.ATTR_restart_name |
---|
| 151 | ATTR_comp_time = _pbs.ATTR_comp_time |
---|
| 152 | ATTR_reported = _pbs.ATTR_reported |
---|
| 153 | ATTR_intcmd = _pbs.ATTR_intcmd |
---|
| 154 | ATTR_aclgren = _pbs.ATTR_aclgren |
---|
| 155 | ATTR_aclgroup = _pbs.ATTR_aclgroup |
---|
| 156 | ATTR_aclhten = _pbs.ATTR_aclhten |
---|
| 157 | ATTR_aclhost = _pbs.ATTR_aclhost |
---|
| 158 | ATTR_acluren = _pbs.ATTR_acluren |
---|
| 159 | ATTR_acluser = _pbs.ATTR_acluser |
---|
| 160 | ATTR_altrouter = _pbs.ATTR_altrouter |
---|
| 161 | ATTR_checkpoint_min = _pbs.ATTR_checkpoint_min |
---|
| 162 | ATTR_enable = _pbs.ATTR_enable |
---|
| 163 | ATTR_fromroute = _pbs.ATTR_fromroute |
---|
| 164 | ATTR_hostlist = _pbs.ATTR_hostlist |
---|
| 165 | ATTR_killdelay = _pbs.ATTR_killdelay |
---|
| 166 | ATTR_maxgrprun = _pbs.ATTR_maxgrprun |
---|
| 167 | ATTR_maxque = _pbs.ATTR_maxque |
---|
| 168 | ATTR_maxuserque = _pbs.ATTR_maxuserque |
---|
| 169 | ATTR_maxuserrun = _pbs.ATTR_maxuserrun |
---|
| 170 | ATTR_qtype = _pbs.ATTR_qtype |
---|
| 171 | ATTR_rescassn = _pbs.ATTR_rescassn |
---|
| 172 | ATTR_rescdflt = _pbs.ATTR_rescdflt |
---|
| 173 | ATTR_rescmax = _pbs.ATTR_rescmax |
---|
| 174 | ATTR_rescmin = _pbs.ATTR_rescmin |
---|
| 175 | ATTR_rerunnable = _pbs.ATTR_rerunnable |
---|
| 176 | ATTR_rndzretry = _pbs.ATTR_rndzretry |
---|
| 177 | ATTR_routedest = _pbs.ATTR_routedest |
---|
| 178 | ATTR_routeheld = _pbs.ATTR_routeheld |
---|
| 179 | ATTR_routewait = _pbs.ATTR_routewait |
---|
| 180 | ATTR_routeretry = _pbs.ATTR_routeretry |
---|
| 181 | ATTR_routelife = _pbs.ATTR_routelife |
---|
| 182 | ATTR_rsvexpdt = _pbs.ATTR_rsvexpdt |
---|
| 183 | ATTR_rsvsync = _pbs.ATTR_rsvsync |
---|
| 184 | ATTR_start = _pbs.ATTR_start |
---|
| 185 | ATTR_count = _pbs.ATTR_count |
---|
| 186 | ATTR_number = _pbs.ATTR_number |
---|
| 187 | ATTR_acllogic = _pbs.ATTR_acllogic |
---|
| 188 | ATTR_aclgrpslpy = _pbs.ATTR_aclgrpslpy |
---|
| 189 | ATTR_keepcompleted = _pbs.ATTR_keepcompleted |
---|
| 190 | ATTR_disallowedtypes = _pbs.ATTR_disallowedtypes |
---|
| 191 | ATTR_is_transit = _pbs.ATTR_is_transit |
---|
| 192 | ATTR_aclroot = _pbs.ATTR_aclroot |
---|
| 193 | ATTR_managers = _pbs.ATTR_managers |
---|
| 194 | ATTR_dfltque = _pbs.ATTR_dfltque |
---|
| 195 | ATTR_dispsvrsuffix = _pbs.ATTR_dispsvrsuffix |
---|
| 196 | ATTR_jobsuffixalias = _pbs.ATTR_jobsuffixalias |
---|
| 197 | ATTR_defnode = _pbs.ATTR_defnode |
---|
| 198 | ATTR_locsvrs = _pbs.ATTR_locsvrs |
---|
| 199 | ATTR_logevents = _pbs.ATTR_logevents |
---|
| 200 | ATTR_logfile = _pbs.ATTR_logfile |
---|
| 201 | ATTR_loglevel = _pbs.ATTR_loglevel |
---|
| 202 | ATTR_mailfrom = _pbs.ATTR_mailfrom |
---|
| 203 | ATTR_nodepack = _pbs.ATTR_nodepack |
---|
| 204 | ATTR_nodesuffix = _pbs.ATTR_nodesuffix |
---|
| 205 | ATTR_operators = _pbs.ATTR_operators |
---|
| 206 | ATTR_queryother = _pbs.ATTR_queryother |
---|
| 207 | ATTR_resccost = _pbs.ATTR_resccost |
---|
| 208 | ATTR_rescavail = _pbs.ATTR_rescavail |
---|
| 209 | ATTR_schedit = _pbs.ATTR_schedit |
---|
| 210 | ATTR_scheduling = _pbs.ATTR_scheduling |
---|
| 211 | ATTR_status = _pbs.ATTR_status |
---|
| 212 | ATTR_syscost = _pbs.ATTR_syscost |
---|
| 213 | ATTR_pingrate = _pbs.ATTR_pingrate |
---|
| 214 | ATTR_ndchkrate = _pbs.ATTR_ndchkrate |
---|
| 215 | ATTR_tcptimeout = _pbs.ATTR_tcptimeout |
---|
| 216 | ATTR_jobstatrate = _pbs.ATTR_jobstatrate |
---|
| 217 | ATTR_polljobs = _pbs.ATTR_polljobs |
---|
| 218 | ATTR_downonerror = _pbs.ATTR_downonerror |
---|
| 219 | ATTR_disableserveridcheck = _pbs.ATTR_disableserveridcheck |
---|
| 220 | ATTR_jobnanny = _pbs.ATTR_jobnanny |
---|
| 221 | ATTR_ownerpurge = _pbs.ATTR_ownerpurge |
---|
| 222 | ATTR_qcqlimits = _pbs.ATTR_qcqlimits |
---|
| 223 | ATTR_momjobsync = _pbs.ATTR_momjobsync |
---|
| 224 | ATTR_maildomain = _pbs.ATTR_maildomain |
---|
| 225 | ATTR_pbsversion = _pbs.ATTR_pbsversion |
---|
| 226 | ATTR_submithosts = _pbs.ATTR_submithosts |
---|
| 227 | ATTR_allownodesubmit = _pbs.ATTR_allownodesubmit |
---|
| 228 | ATTR_allowproxyuser = _pbs.ATTR_allowproxyuser |
---|
| 229 | ATTR_autonodenp = _pbs.ATTR_autonodenp |
---|
| 230 | ATTR_servername = _pbs.ATTR_servername |
---|
| 231 | ATTR_logfilemaxsize = _pbs.ATTR_logfilemaxsize |
---|
| 232 | ATTR_logfilerolldepth = _pbs.ATTR_logfilerolldepth |
---|
| 233 | ATTR_logkeepdays = _pbs.ATTR_logkeepdays |
---|
| 234 | ATTR_nextjobnum = _pbs.ATTR_nextjobnum |
---|
| 235 | ATTR_extraresc = _pbs.ATTR_extraresc |
---|
| 236 | ATTR_schedversion = _pbs.ATTR_schedversion |
---|
| 237 | ATTR_acctkeepdays = _pbs.ATTR_acctkeepdays |
---|
| 238 | ATTR_lockfile = _pbs.ATTR_lockfile |
---|
| 239 | ATTR_credentiallifetime = _pbs.ATTR_credentiallifetime |
---|
| 240 | ATTR_jobmustreport = _pbs.ATTR_jobmustreport |
---|
| 241 | ATTR_LockfileUpdateTime = _pbs.ATTR_LockfileUpdateTime |
---|
| 242 | ATTR_LockfileCheckTime = _pbs.ATTR_LockfileCheckTime |
---|
| 243 | ATTR_npdefault = _pbs.ATTR_npdefault |
---|
| 244 | ATTR_jobstarttimeout = _pbs.ATTR_jobstarttimeout |
---|
| 245 | ATTR_NODE_state = _pbs.ATTR_NODE_state |
---|
| 246 | ATTR_NODE_np = _pbs.ATTR_NODE_np |
---|
| 247 | ATTR_NODE_properties = _pbs.ATTR_NODE_properties |
---|
| 248 | ATTR_NODE_ntype = _pbs.ATTR_NODE_ntype |
---|
| 249 | ATTR_NODE_jobs = _pbs.ATTR_NODE_jobs |
---|
| 250 | ATTR_NODE_status = _pbs.ATTR_NODE_status |
---|
| 251 | ATTR_NODE_note = _pbs.ATTR_NODE_note |
---|
| 252 | ATTR_mailsubjectfmt = _pbs.ATTR_mailsubjectfmt |
---|
| 253 | ATTR_mailbodyfmt = _pbs.ATTR_mailbodyfmt |
---|
| 254 | CHECKPOINT_UNSPECIFIED = _pbs.CHECKPOINT_UNSPECIFIED |
---|
| 255 | NO_HOLD = _pbs.NO_HOLD |
---|
| 256 | NO_JOIN = _pbs.NO_JOIN |
---|
| 257 | NO_KEEP = _pbs.NO_KEEP |
---|
| 258 | MAIL_AT_ABORT = _pbs.MAIL_AT_ABORT |
---|
| 259 | DELDELAY = _pbs.DELDELAY |
---|
| 260 | DELPURGE = _pbs.DELPURGE |
---|
| 261 | PURGECOMP = _pbs.PURGECOMP |
---|
| 262 | EXECQUEONLY = _pbs.EXECQUEONLY |
---|
| 263 | RERUNFORCE = _pbs.RERUNFORCE |
---|
| 264 | USER_HOLD = _pbs.USER_HOLD |
---|
| 265 | OTHER_HOLD = _pbs.OTHER_HOLD |
---|
| 266 | SYSTEM_HOLD = _pbs.SYSTEM_HOLD |
---|
| 267 | ND_free = _pbs.ND_free |
---|
| 268 | ND_offline = _pbs.ND_offline |
---|
| 269 | ND_down = _pbs.ND_down |
---|
| 270 | ND_reserve = _pbs.ND_reserve |
---|
| 271 | ND_job_exclusive = _pbs.ND_job_exclusive |
---|
| 272 | ND_job_sharing = _pbs.ND_job_sharing |
---|
| 273 | ND_busy = _pbs.ND_busy |
---|
| 274 | ND_state_unknown = _pbs.ND_state_unknown |
---|
| 275 | ND_timeshared = _pbs.ND_timeshared |
---|
| 276 | ND_cluster = _pbs.ND_cluster |
---|
| 277 | Q_DT_batch = _pbs.Q_DT_batch |
---|
| 278 | Q_DT_interactive = _pbs.Q_DT_interactive |
---|
| 279 | Q_DT_rerunable = _pbs.Q_DT_rerunable |
---|
| 280 | Q_DT_nonrerunable = _pbs.Q_DT_nonrerunable |
---|
| 281 | Q_DT_fault_tolerant = _pbs.Q_DT_fault_tolerant |
---|
| 282 | Q_DT_fault_intolerant = _pbs.Q_DT_fault_intolerant |
---|
| 283 | Q_DT_job_array = _pbs.Q_DT_job_array |
---|
| 284 | MAX_ENCODE_BFR = _pbs.MAX_ENCODE_BFR |
---|
| 285 | MGR_CMD_CREATE = _pbs.MGR_CMD_CREATE |
---|
| 286 | MGR_CMD_DELETE = _pbs.MGR_CMD_DELETE |
---|
| 287 | MGR_CMD_SET = _pbs.MGR_CMD_SET |
---|
| 288 | MGR_CMD_UNSET = _pbs.MGR_CMD_UNSET |
---|
| 289 | MGR_CMD_LIST = _pbs.MGR_CMD_LIST |
---|
| 290 | MGR_CMD_PRINT = _pbs.MGR_CMD_PRINT |
---|
| 291 | MGR_CMD_ACTIVE = _pbs.MGR_CMD_ACTIVE |
---|
| 292 | MGR_OBJ_NONE = _pbs.MGR_OBJ_NONE |
---|
| 293 | MGR_OBJ_SERVER = _pbs.MGR_OBJ_SERVER |
---|
| 294 | MGR_OBJ_QUEUE = _pbs.MGR_OBJ_QUEUE |
---|
| 295 | MGR_OBJ_JOB = _pbs.MGR_OBJ_JOB |
---|
| 296 | MGR_OBJ_NODE = _pbs.MGR_OBJ_NODE |
---|
| 297 | MSG_OUT = _pbs.MSG_OUT |
---|
| 298 | MSG_ERR = _pbs.MSG_ERR |
---|
| 299 | SHUT_SIG = _pbs.SHUT_SIG |
---|
| 300 | SHUT_IMMEDIATE = _pbs.SHUT_IMMEDIATE |
---|
| 301 | SHUT_DELAY = _pbs.SHUT_DELAY |
---|
| 302 | SHUT_QUICK = _pbs.SHUT_QUICK |
---|
| 303 | SIG_RESUME = _pbs.SIG_RESUME |
---|
| 304 | SIG_SUSPEND = _pbs.SIG_SUSPEND |
---|
| 305 | PBS_MAXHOSTNAME = _pbs.PBS_MAXHOSTNAME |
---|
| 306 | MAXPATHLEN = _pbs.MAXPATHLEN |
---|
| 307 | MAXNAMLEN = _pbs.MAXNAMLEN |
---|
| 308 | MAX_NOTE = _pbs.MAX_NOTE |
---|
| 309 | MAX_NOTE_STR = _pbs.MAX_NOTE_STR |
---|
| 310 | PBS_MAXUSER = _pbs.PBS_MAXUSER |
---|
| 311 | PBS_MAXGRPN = _pbs.PBS_MAXGRPN |
---|
| 312 | PBS_MAXQUEUENAME = _pbs.PBS_MAXQUEUENAME |
---|
| 313 | PBS_MAXSERVERNAME = _pbs.PBS_MAXSERVERNAME |
---|
| 314 | PBS_MAXJOBARRAYLEN = _pbs.PBS_MAXJOBARRAYLEN |
---|
| 315 | PBS_MAXSEQNUM = _pbs.PBS_MAXSEQNUM |
---|
| 316 | PBS_MAXPORTNUM = _pbs.PBS_MAXPORTNUM |
---|
| 317 | PBS_MAXJOBARRAY = _pbs.PBS_MAXJOBARRAY |
---|
| 318 | PBS_MAXSVRJOBID = _pbs.PBS_MAXSVRJOBID |
---|
| 319 | PBS_MAXCLTJOBID = _pbs.PBS_MAXCLTJOBID |
---|
| 320 | PBS_MAXDEST = _pbs.PBS_MAXDEST |
---|
| 321 | PBS_MAXROUTEDEST = _pbs.PBS_MAXROUTEDEST |
---|
| 322 | PBS_USE_IFF = _pbs.PBS_USE_IFF |
---|
| 323 | PBS_INTERACTIVE = _pbs.PBS_INTERACTIVE |
---|
| 324 | PBS_TERM_BUF_SZ = _pbs.PBS_TERM_BUF_SZ |
---|
| 325 | PBS_TERM_CCA = _pbs.PBS_TERM_CCA |
---|
| 326 | PBS_QS_VERSION_BASE = _pbs.PBS_QS_VERSION_BASE |
---|
| 327 | PBS_QS_VERSION_INT = _pbs.PBS_QS_VERSION_INT |
---|
| 328 | PBS_QS_VERSION = _pbs.PBS_QS_VERSION |
---|
| 329 | PBS_BATCH_SERVICE_NAME = _pbs.PBS_BATCH_SERVICE_NAME |
---|
| 330 | PBS_BATCH_SERVICE_PORT = _pbs.PBS_BATCH_SERVICE_PORT |
---|
| 331 | PBS_BATCH_SERVICE_NAME_DIS = _pbs.PBS_BATCH_SERVICE_NAME_DIS |
---|
| 332 | PBS_BATCH_SERVICE_PORT_DIS = _pbs.PBS_BATCH_SERVICE_PORT_DIS |
---|
| 333 | PBS_MOM_SERVICE_NAME = _pbs.PBS_MOM_SERVICE_NAME |
---|
| 334 | PBS_MOM_SERVICE_PORT = _pbs.PBS_MOM_SERVICE_PORT |
---|
| 335 | PBS_MANAGER_SERVICE_NAME = _pbs.PBS_MANAGER_SERVICE_NAME |
---|
| 336 | PBS_MANAGER_SERVICE_PORT = _pbs.PBS_MANAGER_SERVICE_PORT |
---|
| 337 | PBS_SCHEDULER_SERVICE_NAME = _pbs.PBS_SCHEDULER_SERVICE_NAME |
---|
| 338 | PBS_SCHEDULER_SERVICE_PORT = _pbs.PBS_SCHEDULER_SERVICE_PORT |
---|
| 339 | CHECKPOINTHOLD = _pbs.CHECKPOINTHOLD |
---|
| 340 | CHECKPOINTCONT = _pbs.CHECKPOINTCONT |
---|
| 341 | MOM_DEFAULT_CHECKPOINT_DIR = _pbs.MOM_DEFAULT_CHECKPOINT_DIR |
---|
| 342 | SET = _pbs.SET |
---|
| 343 | UNSET = _pbs.UNSET |
---|
| 344 | INCR = _pbs.INCR |
---|
| 345 | DECR = _pbs.DECR |
---|
| 346 | EQ = _pbs.EQ |
---|
| 347 | NE = _pbs.NE |
---|
| 348 | GE = _pbs.GE |
---|
| 349 | GT = _pbs.GT |
---|
| 350 | LE = _pbs.LE |
---|
| 351 | LT = _pbs.LT |
---|
| 352 | DFLT = _pbs.DFLT |
---|
| 353 | MERGE = _pbs.MERGE |
---|
| 354 | class attrl(_object): |
---|
| 355 | __swig_setmethods__ = {} |
---|
| 356 | __setattr__ = lambda self, name, value: _swig_setattr(self, attrl, name, value) |
---|
| 357 | __swig_getmethods__ = {} |
---|
| 358 | __getattr__ = lambda self, name: _swig_getattr(self, attrl, name) |
---|
| 359 | def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined") |
---|
| 360 | __repr__ = _swig_repr |
---|
| 361 | __swig_setmethods__["next"] = _pbs.attrl_next_set |
---|
| 362 | __swig_getmethods__["next"] = _pbs.attrl_next_get |
---|
| 363 | if _newclass:next = _swig_property(_pbs.attrl_next_get, _pbs.attrl_next_set) |
---|
| 364 | __swig_setmethods__["name"] = _pbs.attrl_name_set |
---|
| 365 | __swig_getmethods__["name"] = _pbs.attrl_name_get |
---|
| 366 | if _newclass:name = _swig_property(_pbs.attrl_name_get, _pbs.attrl_name_set) |
---|
| 367 | __swig_setmethods__["resource"] = _pbs.attrl_resource_set |
---|
| 368 | __swig_getmethods__["resource"] = _pbs.attrl_resource_get |
---|
| 369 | if _newclass:resource = _swig_property(_pbs.attrl_resource_get, _pbs.attrl_resource_set) |
---|
| 370 | __swig_setmethods__["value"] = _pbs.attrl_value_set |
---|
| 371 | __swig_getmethods__["value"] = _pbs.attrl_value_get |
---|
| 372 | if _newclass:value = _swig_property(_pbs.attrl_value_get, _pbs.attrl_value_set) |
---|
| 373 | __swig_setmethods__["op"] = _pbs.attrl_op_set |
---|
| 374 | __swig_getmethods__["op"] = _pbs.attrl_op_get |
---|
| 375 | if _newclass:op = _swig_property(_pbs.attrl_op_get, _pbs.attrl_op_set) |
---|
| 376 | def __str__(self): return _pbs.attrl___str__(self) |
---|
| 377 | __swig_destroy__ = _pbs.delete_attrl |
---|
| 378 | __del__ = lambda self : None; |
---|
| 379 | attrl_swigregister = _pbs.attrl_swigregister |
---|
| 380 | attrl_swigregister(attrl) |
---|
| 381 | |
---|
| 382 | class attropl(_object): |
---|
| 383 | __swig_setmethods__ = {} |
---|
| 384 | __setattr__ = lambda self, name, value: _swig_setattr(self, attropl, name, value) |
---|
| 385 | __swig_getmethods__ = {} |
---|
| 386 | __getattr__ = lambda self, name: _swig_getattr(self, attropl, name) |
---|
| 387 | def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined") |
---|
| 388 | __repr__ = _swig_repr |
---|
| 389 | __swig_setmethods__["next"] = _pbs.attropl_next_set |
---|
| 390 | __swig_getmethods__["next"] = _pbs.attropl_next_get |
---|
| 391 | if _newclass:next = _swig_property(_pbs.attropl_next_get, _pbs.attropl_next_set) |
---|
| 392 | __swig_setmethods__["name"] = _pbs.attropl_name_set |
---|
| 393 | __swig_getmethods__["name"] = _pbs.attropl_name_get |
---|
| 394 | if _newclass:name = _swig_property(_pbs.attropl_name_get, _pbs.attropl_name_set) |
---|
| 395 | __swig_setmethods__["resource"] = _pbs.attropl_resource_set |
---|
| 396 | __swig_getmethods__["resource"] = _pbs.attropl_resource_get |
---|
| 397 | if _newclass:resource = _swig_property(_pbs.attropl_resource_get, _pbs.attropl_resource_set) |
---|
| 398 | __swig_setmethods__["value"] = _pbs.attropl_value_set |
---|
| 399 | __swig_getmethods__["value"] = _pbs.attropl_value_get |
---|
| 400 | if _newclass:value = _swig_property(_pbs.attropl_value_get, _pbs.attropl_value_set) |
---|
| 401 | __swig_setmethods__["op"] = _pbs.attropl_op_set |
---|
| 402 | __swig_getmethods__["op"] = _pbs.attropl_op_get |
---|
| 403 | if _newclass:op = _swig_property(_pbs.attropl_op_get, _pbs.attropl_op_set) |
---|
| 404 | def __str__(self): return _pbs.attropl___str__(self) |
---|
| 405 | __swig_destroy__ = _pbs.delete_attropl |
---|
| 406 | __del__ = lambda self : None; |
---|
| 407 | attropl_swigregister = _pbs.attropl_swigregister |
---|
| 408 | attropl_swigregister(attropl) |
---|
| 409 | |
---|
| 410 | class batch_status(_object): |
---|
| 411 | __swig_setmethods__ = {} |
---|
| 412 | __setattr__ = lambda self, name, value: _swig_setattr(self, batch_status, name, value) |
---|
| 413 | __swig_getmethods__ = {} |
---|
| 414 | __getattr__ = lambda self, name: _swig_getattr(self, batch_status, name) |
---|
| 415 | def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined") |
---|
| 416 | __repr__ = _swig_repr |
---|
| 417 | __swig_setmethods__["next"] = _pbs.batch_status_next_set |
---|
| 418 | __swig_getmethods__["next"] = _pbs.batch_status_next_get |
---|
| 419 | if _newclass:next = _swig_property(_pbs.batch_status_next_get, _pbs.batch_status_next_set) |
---|
| 420 | __swig_setmethods__["name"] = _pbs.batch_status_name_set |
---|
| 421 | __swig_getmethods__["name"] = _pbs.batch_status_name_get |
---|
| 422 | if _newclass:name = _swig_property(_pbs.batch_status_name_get, _pbs.batch_status_name_set) |
---|
| 423 | __swig_setmethods__["attribs"] = _pbs.batch_status_attribs_set |
---|
| 424 | __swig_getmethods__["attribs"] = _pbs.batch_status_attribs_get |
---|
| 425 | if _newclass:attribs = _swig_property(_pbs.batch_status_attribs_get, _pbs.batch_status_attribs_set) |
---|
| 426 | __swig_setmethods__["text"] = _pbs.batch_status_text_set |
---|
| 427 | __swig_getmethods__["text"] = _pbs.batch_status_text_get |
---|
| 428 | if _newclass:text = _swig_property(_pbs.batch_status_text_get, _pbs.batch_status_text_set) |
---|
| 429 | batch_status_swigregister = _pbs.batch_status_swigregister |
---|
| 430 | batch_status_swigregister(batch_status) |
---|
| 431 | |
---|
| 432 | |
---|
| 433 | def avail(*args): |
---|
| 434 | return _pbs.avail(*args) |
---|
| 435 | avail = _pbs.avail |
---|
| 436 | |
---|
| 437 | def pbs_asyrunjob(*args): |
---|
| 438 | return _pbs.pbs_asyrunjob(*args) |
---|
| 439 | pbs_asyrunjob = _pbs.pbs_asyrunjob |
---|
| 440 | |
---|
| 441 | def pbs_alterjob(*args): |
---|
| 442 | return _pbs.pbs_alterjob(*args) |
---|
| 443 | pbs_alterjob = _pbs.pbs_alterjob |
---|
| 444 | |
---|
| 445 | def pbs_connect(*args): |
---|
| 446 | return _pbs.pbs_connect(*args) |
---|
| 447 | pbs_connect = _pbs.pbs_connect |
---|
| 448 | |
---|
| 449 | def pbs_query_max_connections(): |
---|
| 450 | return _pbs.pbs_query_max_connections() |
---|
| 451 | pbs_query_max_connections = _pbs.pbs_query_max_connections |
---|
| 452 | |
---|
| 453 | def pbs_default(): |
---|
| 454 | return _pbs.pbs_default() |
---|
| 455 | pbs_default = _pbs.pbs_default |
---|
| 456 | |
---|
| 457 | def pbs_deljob(*args): |
---|
| 458 | return _pbs.pbs_deljob(*args) |
---|
| 459 | pbs_deljob = _pbs.pbs_deljob |
---|
| 460 | |
---|
| 461 | def pbs_disconnect(*args): |
---|
| 462 | return _pbs.pbs_disconnect(*args) |
---|
| 463 | pbs_disconnect = _pbs.pbs_disconnect |
---|
| 464 | |
---|
| 465 | def pbs_geterrmsg(*args): |
---|
| 466 | return _pbs.pbs_geterrmsg(*args) |
---|
| 467 | pbs_geterrmsg = _pbs.pbs_geterrmsg |
---|
| 468 | |
---|
| 469 | def pbs_holdjob(*args): |
---|
| 470 | return _pbs.pbs_holdjob(*args) |
---|
| 471 | pbs_holdjob = _pbs.pbs_holdjob |
---|
| 472 | |
---|
| 473 | def pbs_locjob(*args): |
---|
| 474 | return _pbs.pbs_locjob(*args) |
---|
| 475 | pbs_locjob = _pbs.pbs_locjob |
---|
| 476 | |
---|
| 477 | def pbs_manager(*args): |
---|
| 478 | return _pbs.pbs_manager(*args) |
---|
| 479 | pbs_manager = _pbs.pbs_manager |
---|
| 480 | |
---|
| 481 | def pbs_movejob(*args): |
---|
| 482 | return _pbs.pbs_movejob(*args) |
---|
| 483 | pbs_movejob = _pbs.pbs_movejob |
---|
| 484 | |
---|
| 485 | def pbs_msgjob(*args): |
---|
| 486 | return _pbs.pbs_msgjob(*args) |
---|
| 487 | pbs_msgjob = _pbs.pbs_msgjob |
---|
| 488 | |
---|
| 489 | def pbs_orderjob(*args): |
---|
| 490 | return _pbs.pbs_orderjob(*args) |
---|
| 491 | pbs_orderjob = _pbs.pbs_orderjob |
---|
| 492 | |
---|
| 493 | def pbs_rescquery(*args): |
---|
| 494 | return _pbs.pbs_rescquery(*args) |
---|
| 495 | pbs_rescquery = _pbs.pbs_rescquery |
---|
| 496 | |
---|
| 497 | def pbs_rescreserve(*args): |
---|
| 498 | return _pbs.pbs_rescreserve(*args) |
---|
| 499 | pbs_rescreserve = _pbs.pbs_rescreserve |
---|
| 500 | |
---|
| 501 | def pbs_rescrelease(*args): |
---|
| 502 | return _pbs.pbs_rescrelease(*args) |
---|
| 503 | pbs_rescrelease = _pbs.pbs_rescrelease |
---|
| 504 | |
---|
| 505 | def pbs_rerunjob(*args): |
---|
| 506 | return _pbs.pbs_rerunjob(*args) |
---|
| 507 | pbs_rerunjob = _pbs.pbs_rerunjob |
---|
| 508 | |
---|
| 509 | def pbs_rlsjob(*args): |
---|
| 510 | return _pbs.pbs_rlsjob(*args) |
---|
| 511 | pbs_rlsjob = _pbs.pbs_rlsjob |
---|
| 512 | |
---|
| 513 | def pbs_runjob(*args): |
---|
| 514 | return _pbs.pbs_runjob(*args) |
---|
| 515 | pbs_runjob = _pbs.pbs_runjob |
---|
| 516 | |
---|
| 517 | def pbs_selectjob(*args): |
---|
| 518 | return _pbs.pbs_selectjob(*args) |
---|
| 519 | pbs_selectjob = _pbs.pbs_selectjob |
---|
| 520 | |
---|
| 521 | def pbs_sigjob(*args): |
---|
| 522 | return _pbs.pbs_sigjob(*args) |
---|
| 523 | pbs_sigjob = _pbs.pbs_sigjob |
---|
| 524 | |
---|
| 525 | def pbs_statfree(*args): |
---|
| 526 | return _pbs.pbs_statfree(*args) |
---|
| 527 | pbs_statfree = _pbs.pbs_statfree |
---|
| 528 | |
---|
| 529 | def pbs_statjob(*args): |
---|
| 530 | return _pbs.pbs_statjob(*args) |
---|
| 531 | pbs_statjob = _pbs.pbs_statjob |
---|
| 532 | |
---|
| 533 | def pbs_selstat(*args): |
---|
| 534 | return _pbs.pbs_selstat(*args) |
---|
| 535 | pbs_selstat = _pbs.pbs_selstat |
---|
| 536 | |
---|
| 537 | def pbs_statque(*args): |
---|
| 538 | return _pbs.pbs_statque(*args) |
---|
| 539 | pbs_statque = _pbs.pbs_statque |
---|
| 540 | |
---|
| 541 | def pbs_statserver(*args): |
---|
| 542 | return _pbs.pbs_statserver(*args) |
---|
| 543 | pbs_statserver = _pbs.pbs_statserver |
---|
| 544 | |
---|
| 545 | def pbs_statnode(*args): |
---|
| 546 | return _pbs.pbs_statnode(*args) |
---|
| 547 | pbs_statnode = _pbs.pbs_statnode |
---|
| 548 | |
---|
| 549 | def pbs_submit(*args): |
---|
| 550 | return _pbs.pbs_submit(*args) |
---|
| 551 | pbs_submit = _pbs.pbs_submit |
---|
| 552 | |
---|
| 553 | def pbs_terminate(*args): |
---|
| 554 | return _pbs.pbs_terminate(*args) |
---|
| 555 | pbs_terminate = _pbs.pbs_terminate |
---|
| 556 | |
---|
| 557 | def totpool(*args): |
---|
| 558 | return _pbs.totpool(*args) |
---|
| 559 | totpool = _pbs.totpool |
---|
| 560 | |
---|
| 561 | def usepool(*args): |
---|
| 562 | return _pbs.usepool(*args) |
---|
| 563 | usepool = _pbs.usepool |
---|
| 564 | |
---|
| 565 | def pbs_fbserver(): |
---|
| 566 | return _pbs.pbs_fbserver() |
---|
| 567 | pbs_fbserver = _pbs.pbs_fbserver |
---|
| 568 | |
---|
| 569 | def pbs_get_server_list(): |
---|
| 570 | return _pbs.pbs_get_server_list() |
---|
| 571 | pbs_get_server_list = _pbs.pbs_get_server_list |
---|
| 572 | |
---|
| 573 | def pbs_sigjobasync(*args): |
---|
| 574 | return _pbs.pbs_sigjobasync(*args) |
---|
| 575 | pbs_sigjobasync = _pbs.pbs_sigjobasync |
---|
| 576 | |
---|
| 577 | def pbs_alterjob_async(*args): |
---|
| 578 | return _pbs.pbs_alterjob_async(*args) |
---|
| 579 | pbs_alterjob_async = _pbs.pbs_alterjob_async |
---|
| 580 | |
---|
| 581 | def pbs_checkpointjob(*args): |
---|
| 582 | return _pbs.pbs_checkpointjob(*args) |
---|
| 583 | pbs_checkpointjob = _pbs.pbs_checkpointjob |
---|
| 584 | |
---|
| 585 | def openrm(*args): |
---|
| 586 | return _pbs.openrm(*args) |
---|
| 587 | openrm = _pbs.openrm |
---|
| 588 | |
---|
| 589 | def closerm(*args): |
---|
| 590 | return _pbs.closerm(*args) |
---|
| 591 | closerm = _pbs.closerm |
---|
| 592 | |
---|
| 593 | def downrm(*args): |
---|
| 594 | return _pbs.downrm(*args) |
---|
| 595 | downrm = _pbs.downrm |
---|
| 596 | |
---|
| 597 | def configrm(*args): |
---|
| 598 | return _pbs.configrm(*args) |
---|
| 599 | configrm = _pbs.configrm |
---|
| 600 | |
---|
| 601 | def addreq(*args): |
---|
| 602 | return _pbs.addreq(*args) |
---|
| 603 | addreq = _pbs.addreq |
---|
| 604 | |
---|
| 605 | def allreq(*args): |
---|
| 606 | return _pbs.allreq(*args) |
---|
| 607 | allreq = _pbs.allreq |
---|
| 608 | |
---|
| 609 | def getreq(*args): |
---|
| 610 | return _pbs.getreq(*args) |
---|
| 611 | getreq = _pbs.getreq |
---|
| 612 | |
---|
| 613 | def flushreq(): |
---|
| 614 | return _pbs.flushreq() |
---|
| 615 | flushreq = _pbs.flushreq |
---|
| 616 | |
---|
| 617 | def activereq(): |
---|
| 618 | return _pbs.activereq() |
---|
| 619 | activereq = _pbs.activereq |
---|
| 620 | |
---|
| 621 | def fullresp(*args): |
---|
| 622 | return _pbs.fullresp(*args) |
---|
| 623 | fullresp = _pbs.fullresp |
---|
| 624 | LOG_BUF_SIZE = _pbs.LOG_BUF_SIZE |
---|
| 625 | LOG_EMERG = _pbs.LOG_EMERG |
---|
| 626 | LOG_ALERT = _pbs.LOG_ALERT |
---|
| 627 | LOG_CRIT = _pbs.LOG_CRIT |
---|
| 628 | LOG_ERR = _pbs.LOG_ERR |
---|
| 629 | LOG_WARNING = _pbs.LOG_WARNING |
---|
| 630 | LOG_NOTICE = _pbs.LOG_NOTICE |
---|
| 631 | LOG_INFO = _pbs.LOG_INFO |
---|
| 632 | LOG_DEBUG = _pbs.LOG_DEBUG |
---|
| 633 | |
---|
| 634 | def log_close(*args): |
---|
| 635 | return _pbs.log_close(*args) |
---|
| 636 | log_close = _pbs.log_close |
---|
| 637 | |
---|
| 638 | def log_err(*args): |
---|
| 639 | return _pbs.log_err(*args) |
---|
| 640 | log_err = _pbs.log_err |
---|
| 641 | |
---|
| 642 | def log_event(*args): |
---|
| 643 | return _pbs.log_event(*args) |
---|
| 644 | log_event = _pbs.log_event |
---|
| 645 | |
---|
| 646 | def log_open(*args): |
---|
| 647 | return _pbs.log_open(*args) |
---|
| 648 | log_open = _pbs.log_open |
---|
| 649 | |
---|
| 650 | def log_record(*args): |
---|
| 651 | return _pbs.log_record(*args) |
---|
| 652 | log_record = _pbs.log_record |
---|
| 653 | |
---|
| 654 | def log_roll(*args): |
---|
| 655 | return _pbs.log_roll(*args) |
---|
| 656 | log_roll = _pbs.log_roll |
---|
| 657 | |
---|
| 658 | def log_size(): |
---|
| 659 | return _pbs.log_size() |
---|
| 660 | log_size = _pbs.log_size |
---|
| 661 | |
---|
| 662 | def chk_file_sec(*args): |
---|
| 663 | return _pbs.chk_file_sec(*args) |
---|
| 664 | chk_file_sec = _pbs.chk_file_sec |
---|
| 665 | |
---|
| 666 | def setup_env(*args): |
---|
| 667 | return _pbs.setup_env(*args) |
---|
| 668 | setup_env = _pbs.setup_env |
---|
| 669 | |
---|
| 670 | def log_ext(*args): |
---|
| 671 | return _pbs.log_ext(*args) |
---|
| 672 | log_ext = _pbs.log_ext |
---|
| 673 | |
---|
| 674 | def log_init(*args): |
---|
| 675 | return _pbs.log_init(*args) |
---|
| 676 | log_init = _pbs.log_init |
---|
| 677 | |
---|
| 678 | def log_remove_old(*args): |
---|
| 679 | return _pbs.log_remove_old(*args) |
---|
| 680 | log_remove_old = _pbs.log_remove_old |
---|
| 681 | PBSEVENT_ERROR = _pbs.PBSEVENT_ERROR |
---|
| 682 | PBSEVENT_SYSTEM = _pbs.PBSEVENT_SYSTEM |
---|
| 683 | PBSEVENT_ADMIN = _pbs.PBSEVENT_ADMIN |
---|
| 684 | PBSEVENT_JOB = _pbs.PBSEVENT_JOB |
---|
| 685 | PBSEVENT_JOB_USAGE = _pbs.PBSEVENT_JOB_USAGE |
---|
| 686 | PBSEVENT_SECURITY = _pbs.PBSEVENT_SECURITY |
---|
| 687 | PBSEVENT_SCHED = _pbs.PBSEVENT_SCHED |
---|
| 688 | PBSEVENT_DEBUG = _pbs.PBSEVENT_DEBUG |
---|
| 689 | PBSEVENT_DEBUG2 = _pbs.PBSEVENT_DEBUG2 |
---|
| 690 | PBSEVENT_FORCE = _pbs.PBSEVENT_FORCE |
---|
| 691 | PBS_EVENTCLASS_SERVER = _pbs.PBS_EVENTCLASS_SERVER |
---|
| 692 | PBS_EVENTCLASS_QUEUE = _pbs.PBS_EVENTCLASS_QUEUE |
---|
| 693 | PBS_EVENTCLASS_JOB = _pbs.PBS_EVENTCLASS_JOB |
---|
| 694 | PBS_EVENTCLASS_REQUEST = _pbs.PBS_EVENTCLASS_REQUEST |
---|
| 695 | PBS_EVENTCLASS_FILE = _pbs.PBS_EVENTCLASS_FILE |
---|
| 696 | PBS_EVENTCLASS_ACCT = _pbs.PBS_EVENTCLASS_ACCT |
---|
| 697 | PBS_EVENTCLASS_NODE = _pbs.PBS_EVENTCLASS_NODE |
---|
| 698 | PBSEVENT_MASK = _pbs.PBSEVENT_MASK |
---|
| 699 | MAX_PATH_LEN = _pbs.MAX_PATH_LEN |
---|
| 700 | SECS_PER_DAY = _pbs.SECS_PER_DAY |
---|
| 701 | TRUE = _pbs.TRUE |
---|
| 702 | FALSE = _pbs.FALSE |
---|
| 703 | # PBS python interface |
---|
| 704 | # Author: Bas van der Vlies <basv@sara.nl> |
---|
| 705 | # Date : 27 Feb 2002 |
---|
| 706 | # Desc. : This is python wrapper class for getting the resource |
---|
| 707 | # mom values. |
---|
| 708 | # |
---|
| 709 | # CVS info |
---|
| 710 | # $Id: resmom.py,v 1.6 2002/10/21 14:14:47 sscpbas Exp $ |
---|
| 711 | # $Date: 2002/10/21 14:14:47 $ |
---|
| 712 | # $Revision: 1.6 $ |
---|
| 713 | # |
---|
| 714 | import string |
---|
| 715 | import types |
---|
| 716 | |
---|
| 717 | # Default linux resources to get from the mom |
---|
| 718 | # |
---|
| 719 | default_linux_res = [ |
---|
| 720 | "availmem", # available memory size in KB |
---|
| 721 | "ideal_load", # static ideal_load value |
---|
| 722 | "loadave", # the current load average |
---|
| 723 | "max_load", # static max_load value |
---|
| 724 | "ncpus", # number of cpus |
---|
| 725 | "physmem", # physical memory size in KB |
---|
| 726 | "resi", # resident memory size for a pid or session in KB |
---|
| 727 | "totmem", # total memory size in KB |
---|
| 728 | "walltime", # wall clock time for a pid |
---|
| 729 | ] |
---|
| 730 | |
---|
| 731 | # Default irix6 resources to get from the mom |
---|
| 732 | # |
---|
| 733 | default_irix6_res = [ |
---|
| 734 | "availmem", # available memory size in KB |
---|
| 735 | "loadave", # the current load average |
---|
| 736 | "ncpus", # number of cpus |
---|
| 737 | "physmem", # physical memory size in KB |
---|
| 738 | "resi", # resident memory size for a pid or session in KB |
---|
| 739 | "walltime", # wall clock time for a pid |
---|
| 740 | "quota", # quota information (sizes in KB) |
---|
| 741 | ] |
---|
| 742 | |
---|
| 743 | default_mom_res = [ |
---|
| 744 | "arch", # the architecture of the machine |
---|
| 745 | "uname", # the architecture of the machine |
---|
| 746 | "cput", # cpu time for a pid or session |
---|
| 747 | "idletime", # seconds of idle time |
---|
| 748 | "mem", # memory size for a pid or session in KB |
---|
| 749 | "sessions", # list of sessions in the system |
---|
| 750 | "pids", # list of pids in a session |
---|
| 751 | "nsessions", # number of sessions in the system |
---|
| 752 | "nusers", # number of users in the system |
---|
| 753 | "size", # size of a file or filesystem |
---|
| 754 | "host", # Name of host on which job should be run |
---|
| 755 | "nodes", # Number and/or type of nodes to be reserved for exclusive use by the job |
---|
| 756 | "other", # Allows a user to specify site specific information |
---|
| 757 | "software", # Allows a user to specify software required by the job |
---|
| 758 | ] |
---|
| 759 | |
---|
| 760 | def check_resp(dict, str): |
---|
| 761 | """ |
---|
| 762 | Check the daemon response. If we have no permission to |
---|
| 763 | query the values then we got a 'None' response. Else |
---|
| 764 | if we supplied a keyword that does not exits we get a |
---|
| 765 | '?' response |
---|
| 766 | """ |
---|
| 767 | if not str: |
---|
| 768 | return |
---|
| 769 | |
---|
| 770 | ## Value can contain the '=' char :-( |
---|
| 771 | # |
---|
| 772 | l = string.split(str, '=') |
---|
| 773 | key = string.strip(l[0]) |
---|
| 774 | if len(l) > 2: |
---|
| 775 | val = string.strip( '='.join(l[1:]) ) |
---|
| 776 | else: |
---|
| 777 | val = string.strip(l[1]) |
---|
| 778 | |
---|
| 779 | key = string.strip(key) |
---|
| 780 | val = string.strip(val) |
---|
| 781 | |
---|
| 782 | # Did we got a valid response |
---|
| 783 | # |
---|
| 784 | if not val[0] == '?': |
---|
| 785 | dict[key] = val |
---|
| 786 | |
---|
| 787 | def use_default_keywords(id, d): |
---|
| 788 | """ |
---|
| 789 | Get the default values from the mom daemon |
---|
| 790 | """ |
---|
| 791 | for res in default_mom_res: |
---|
| 792 | addreq(id, res) |
---|
| 793 | resp = getreq(id) |
---|
| 794 | check_resp(d, resp) |
---|
| 795 | |
---|
| 796 | # Do not proceed if we have an empty dictionary |
---|
| 797 | # |
---|
| 798 | if not d: |
---|
| 799 | return |
---|
| 800 | |
---|
| 801 | if d['arch' ] == 'linux': |
---|
| 802 | for res in default_linux_res: |
---|
| 803 | addreq(id, res) |
---|
| 804 | resp = getreq(id) |
---|
| 805 | check_resp(d, resp) |
---|
| 806 | |
---|
| 807 | def use_user_keywords(id, d, l): |
---|
| 808 | for res in l: |
---|
| 809 | if type(res) is types.StringType: |
---|
| 810 | addreq(id, res) |
---|
| 811 | resp = getreq(id) |
---|
| 812 | check_resp(d, resp) |
---|
| 813 | else: |
---|
| 814 | raise TypeError, 'Expected a string got %s :%s' %(type(res), res) |
---|
| 815 | |
---|
| 816 | def get_mom_values(id, list = None): |
---|
| 817 | """ |
---|
| 818 | This function will query the mom with a default resmon keywords |
---|
| 819 | and 'arch' depended keywords. Supported archs are: |
---|
| 820 | linux |
---|
| 821 | irix6 |
---|
| 822 | User can also supply their own list of keywords as second parameter. |
---|
| 823 | arguments: |
---|
| 824 | id : connection number with mom daemon on a node |
---|
| 825 | list : optional parameter. If supplied then use this. A list |
---|
| 826 | of mom keywords. |
---|
| 827 | """ |
---|
| 828 | |
---|
| 829 | d = {} |
---|
| 830 | if not list: |
---|
| 831 | use_default_keywords(id, d) |
---|
| 832 | else: |
---|
| 833 | use_user_keywords(id, d , list) |
---|
| 834 | |
---|
| 835 | return d |
---|
| 836 | |
---|
| 837 | version_info = ( 4, 4, 0 ) |
---|
| 838 | version = 'SARA pbs_python version 4.4.0' |
---|
| 839 | |
---|
| 840 | # A useful dict with error codes to text |
---|
| 841 | # |
---|
| 842 | # SVN Info: |
---|
| 843 | # $Id: errors.py 429 2005-11-04 13:59:06Z bas $ |
---|
| 844 | # |
---|
| 845 | errors_txt = { |
---|
| 846 | 0 : 'no error', |
---|
| 847 | 15001 : 'Unknown Job Identifier', |
---|
| 848 | 15002 : 'Undefined Attribute', |
---|
| 849 | 15003 : 'attempt to set READ ONLY attribute', |
---|
| 850 | 15004 : 'Invalid request', |
---|
| 851 | 15005 : 'Unknown batch request', |
---|
| 852 | 15006 : 'Too many submit retries', |
---|
| 853 | 15007 : 'No permission', |
---|
| 854 | 15008 : 'access from host not allowed', |
---|
| 855 | 15009 : 'job already exists', |
---|
| 856 | 15010 : 'system error occurred', |
---|
| 857 | 15011 : 'internal server error occurred', |
---|
| 858 | 15012 : 'parent job of dependent in rte que', |
---|
| 859 | 15013 : 'unknown signal name', |
---|
| 860 | 15014 : 'bad attribute value', |
---|
| 861 | 15015 : 'Cannot modify attrib in run state', |
---|
| 862 | 15016 : 'request invalid for job state', |
---|
| 863 | 15018 : 'Unknown queue name', |
---|
| 864 | 15019 : 'Invalid Credential in request', |
---|
| 865 | 15020 : 'Expired Credential in request', |
---|
| 866 | 15021 : 'Queue not enabled', |
---|
| 867 | 15022 : 'No access permission for queue', |
---|
| 868 | 15023 : 'Bad user - no password entry', |
---|
| 869 | 15024 : 'Max hop count exceeded', |
---|
| 870 | 15025 : 'Queue already exists', |
---|
| 871 | 15026 : 'incompatable queue attribute type', |
---|
| 872 | 15027 : 'Queue Busy (not empty)', |
---|
| 873 | 15028 : 'Queue name too long', |
---|
| 874 | 15029 : 'Feature', |
---|
| 875 | 15030 : 'Cannot enable queue,needs add def', |
---|
| 876 | 15031 : 'Protocol (ASN.1) error', |
---|
| 877 | 15032 : 'Bad attribute list structure', |
---|
| 878 | 15033 : 'No free connections', |
---|
| 879 | 15034 : 'No server to connect to', |
---|
| 880 | 15035 : 'Unknown resource', |
---|
| 881 | 15036 : 'Job exceeds Queue resource limits', |
---|
| 882 | 15037 : 'No Default Queue Defined', |
---|
| 883 | 15038 : 'Job Not Rerunnable', |
---|
| 884 | 15039 : 'Route rejected by all destinations', |
---|
| 885 | 15040 : 'Time in Route Queue Expired', |
---|
| 886 | 15041 : 'Request to MOM failed', |
---|
| 887 | 15042 : '(qsub) cannot access script file', |
---|
| 888 | 15043 : 'Stage In of files failed', |
---|
| 889 | 15044 : 'Resources temporarily unavailable', |
---|
| 890 | 15045 : 'Bad Group specified', |
---|
| 891 | 15046 : 'Max number of jobs in queue', |
---|
| 892 | 15047 : 'Checkpoint Busy, may be retries', |
---|
| 893 | 15048 : 'Limit exceeds allowable', |
---|
| 894 | 15049 : 'Bad Account attribute value', |
---|
| 895 | 15050 : 'Job already in exit state', |
---|
| 896 | 15051 : 'Job files not copied', |
---|
| 897 | 15052 : 'unknown job id after clean init', |
---|
| 898 | 15053 : 'No Master in Sync Set', |
---|
| 899 | 15054 : 'Invalid dependency', |
---|
| 900 | 15055 : 'Duplicate entry in List', |
---|
| 901 | 15056 : 'Bad DIS based Request Protocol', |
---|
| 902 | 15057 : 'cannot execute there', |
---|
| 903 | 15058 : 'sister rejected', |
---|
| 904 | 15059 : 'sister could not communicate', |
---|
| 905 | 15060 : 'req rejected -server shutting down', |
---|
| 906 | 15061 : 'not all tasks could checkpoint', |
---|
| 907 | 15062 : 'Named node is not in the list', |
---|
| 908 | 15063 : 'node-attribute not recognized', |
---|
| 909 | 15064 : 'Server has no node list', |
---|
| 910 | 15065 : 'Node name is too big', |
---|
| 911 | 15066 : 'Node name already exists', |
---|
| 912 | 15067 : 'Bad node-attribute value', |
---|
| 913 | 15068 : 'State values are mutually exclusive', |
---|
| 914 | 15069 : 'Error(s) during global modification of nodes', |
---|
| 915 | 15070 : 'could not contact Mom', |
---|
| 916 | 15071 : 'no time-shared nodes', |
---|
| 917 | 15201 : 'resource unknown', |
---|
| 918 | 15202 : 'parameter could not be used', |
---|
| 919 | 15203 : 'a parameter needed did not exist', |
---|
| 920 | 15204 : "something specified didn't exist", |
---|
| 921 | 15205 : 'a system error occured', |
---|
| 922 | 15206 : 'only part of reservation made' |
---|
| 923 | } |
---|
| 924 | |
---|
| 925 | def error(): |
---|
| 926 | """ |
---|
| 927 | Check if there is an error, if so fetch the error message string. |
---|
| 928 | It says more then a number! |
---|
| 929 | """ |
---|
| 930 | e = get_error() |
---|
| 931 | if errors_txt.has_key(e): |
---|
| 932 | return (e, errors_txt[e]) |
---|
| 933 | else: |
---|
| 934 | return (e, "Could not find a text for this error, uhhh") |
---|
| 935 | |
---|
| 936 | |
---|
| 937 | cvar = _pbs.cvar |
---|
| 938 | |
---|