NAME
mpdlib
FILE
/Users/goodell/svn/mpich2-1.2.1p1-tmp/src/pm/mpd/mpdlib.py
DESCRIPTION
- #
-
(C) 2001 by Argonne National Laboratory.
- #
-
See COPYRIGHT in top-level directory. #
CLASSES
__builtin__.dict(__builtin__.object) MPDParmDB __builtin__.object MPDRing MPDSock MPDConClientSock MPDListenSock MPDConListenSock MPDStreamHandler MPDTest
class MPDConClientSock(MPDSock)
- |
-
Method resolution order:
- |
-
MPDConClientSock
- |
-
MPDSock
- |
-
__builtin__.object
- |
- |
-
Methods defined here:
- |
- |
-
__init__(self, name='console_to_mpd', mpdroot='', secretword='', **kargs)
- |
- |
-
----------------------------------------------------------------------
- |
-
Methods inherited from MPDSock:
- |
- |
-
accept(self, name='accepter')
- |
- |
-
close(self)
- |
- |
-
connect(self, *args)
- |
- |
-
fileno(self)
- |
- |
-
getsockname(self)
- |
- |
-
recv(self, nbytes)
- |
- |
-
recv_char_msg(self)
- |
- |
-
recv_dict_msg(self, timeout=None)
- |
- |
-
recv_one_line(self)
- |
- |
-
send_char_msg(self, msg, errprint=1)
- |
- |
-
send_dict_msg(self, msg, errprint=1)
- |
-
# The default behavior on an error needs to be to handle and/or report
- |
-
# it. Otherwise, we all waste time trying to figure out why
- |
-
# the code is silently failing. I've set the default for errprint
- |
-
# to YES rather than NO.
- |
- |
-
sendall(self, data)
- |
- |
-
----------------------------------------------------------------------
- |
-
Data descriptors inherited from MPDSock:
- |
- |
-
__dict__
- |
-
dictionary for instance variables (if defined)
- |
- |
-
__weakref__
- |
-
list of weak references to the object (if defined)
class MPDConListenSock(MPDListenSock)
- |
-
Method resolution order:
- |
-
MPDConListenSock
- |
-
MPDListenSock
- |
-
MPDSock
- |
-
__builtin__.object
- |
- |
-
Methods defined here:
- |
- |
-
__init__(self, name='console_listen', secretword='', **kargs)
- |
- |
-
----------------------------------------------------------------------
- |
-
Methods inherited from MPDSock:
- |
- |
-
accept(self, name='accepter')
- |
- |
-
close(self)
- |
- |
-
connect(self, *args)
- |
- |
-
fileno(self)
- |
- |
-
getsockname(self)
- |
- |
-
recv(self, nbytes)
- |
- |
-
recv_char_msg(self)
- |
- |
-
recv_dict_msg(self, timeout=None)
- |
- |
-
recv_one_line(self)
- |
- |
-
send_char_msg(self, msg, errprint=1)
- |
- |
-
send_dict_msg(self, msg, errprint=1)
- |
-
# The default behavior on an error needs to be to handle and/or report
- |
-
# it. Otherwise, we all waste time trying to figure out why
- |
-
# the code is silently failing. I've set the default for errprint
- |
-
# to YES rather than NO.
- |
- |
-
sendall(self, data)
- |
- |
-
----------------------------------------------------------------------
- |
-
Data descriptors inherited from MPDSock:
- |
- |
-
__dict__
- |
-
dictionary for instance variables (if defined)
- |
- |
-
__weakref__
- |
-
list of weak references to the object (if defined)
class MPDListenSock(MPDSock)
- |
-
Method resolution order:
- |
-
MPDListenSock
- |
-
MPDSock
- |
-
__builtin__.object
- |
- |
-
Methods defined here:
- |
- |
-
__init__(self, host='', port=0, filename='', listen=5, name='listener', **kargs)
- |
- |
-
----------------------------------------------------------------------
- |
-
Methods inherited from MPDSock:
- |
- |
-
accept(self, name='accepter')
- |
- |
-
close(self)
- |
- |
-
connect(self, *args)
- |
- |
-
fileno(self)
- |
- |
-
getsockname(self)
- |
- |
-
recv(self, nbytes)
- |
- |
-
recv_char_msg(self)
- |
- |
-
recv_dict_msg(self, timeout=None)
- |
- |
-
recv_one_line(self)
- |
- |
-
send_char_msg(self, msg, errprint=1)
- |
- |
-
send_dict_msg(self, msg, errprint=1)
- |
-
# The default behavior on an error needs to be to handle and/or report
- |
-
# it. Otherwise, we all waste time trying to figure out why
- |
-
# the code is silently failing. I've set the default for errprint
- |
-
# to YES rather than NO.
- |
- |
-
sendall(self, data)
- |
- |
-
----------------------------------------------------------------------
- |
-
Data descriptors inherited from MPDSock:
- |
- |
-
__dict__
- |
-
dictionary for instance variables (if defined)
- |
- |
-
__weakref__
- |
-
list of weak references to the object (if defined)
class MPDParmDB(__builtin__.dict)
- |
-
Method resolution order:
- |
-
MPDParmDB
- |
-
__builtin__.dict
- |
-
__builtin__.object
- |
- |
-
Methods defined here:
- |
- |
-
__getitem__(self, key)
- |
- |
-
__init__(self, orderedSources=[])
- |
- |
-
__setitem__(self, sk_tup, val)
- |
- |
-
get_parms_from_env(self, parmsToOverride)
- |
- |
-
get_parms_from_rcfile(self, parmsToOverride, errIfMissingFile=0)
- |
- |
-
has_key(self, key)
- |
- |
-
printall(self)
- |
- |
-
printdef(self)
- |
- |
-
----------------------------------------------------------------------
- |
-
Data descriptors defined here:
- |
- |
-
__dict__
- |
-
dictionary for instance variables (if defined)
- |
- |
-
__weakref__
- |
-
list of weak references to the object (if defined)
- |
- |
-
----------------------------------------------------------------------
- |
-
Methods inherited from __builtin__.dict:
- |
- |
-
__cmp__(...)
- |
-
x.__cmp__(y) <==> cmp(x,y)
- |
- |
-
__contains__(...)
- |
-
D.__contains__(k) -> True if D has a key k, else False
- |
- |
-
__delitem__(...)
- |
-
x.__delitem__(y) <==> del x[y]
- |
- |
-
__eq__(...)
- |
-
x.__eq__(y) <==> x==y
- |
- |
-
__ge__(...)
- |
-
x.__ge__(y) <==> x>=y
- |
- |
-
__getattribute__(...)
- |
-
x.__getattribute__('name') <==> x.name
- |
- |
-
__gt__(...)
- |
-
x.__gt__(y) <==> x>y
- |
- |
-
__hash__(...)
- |
-
x.__hash__() <==> hash(x)
- |
- |
-
__iter__(...)
- |
-
x.__iter__() <==> iter(x)
- |
- |
-
__le__(...)
- |
-
x.__le__(y) <==> x<=y
- |
- |
-
__len__(...)
- |
-
x.__len__() <==> len(x)
- |
- |
-
__lt__(...)
- |
-
x.__lt__(y) <==> x<y
- |
- |
-
__ne__(...)
- |
-
x.__ne__(y) <==> x!=y
- |
- |
-
__repr__(...)
- |
-
x.__repr__() <==> repr(x)
- |
- |
-
clear(...)
- |
-
D.clear() -> None. Remove all items from D.
- |
- |
-
copy(...)
- |
-
D.copy() -> a shallow copy of D
- |
- |
-
get(...)
- |
-
D.get(k[,d]) -> D[k] if k in D, else d. d defaults to None.
- |
- |
-
items(...)
- |
-
D.items() -> list of D's (key, value) pairs, as 2-tuples
- |
- |
-
iteritems(...)
- |
-
D.iteritems() -> an iterator over the (key, value) items of D
- |
- |
-
iterkeys(...)
- |
-
D.iterkeys() -> an iterator over the keys of D
- |
- |
-
itervalues(...)
- |
-
D.itervalues() -> an iterator over the values of D
- |
- |
-
keys(...)
- |
-
D.keys() -> list of D's keys
- |
- |
-
pop(...)
- |
-
D.pop(k[,d]) -> v, remove specified key and return the corresponding value
- |
-
If key is not found, d is returned if given, otherwise KeyError is raised
- |
- |
-
popitem(...)
- |
-
D.popitem() -> (k, v), remove and return some (key, value) pair as a
- |
-
2-tuple; but raise KeyError if D is empty
- |
- |
-
setdefault(...)
- |
-
D.setdefault(k[,d]) -> D.get(k,d), also set D[k]=d if k not in D
- |
- |
-
update(...)
- |
-
D.update(E, **F) -> None. Update D from E and F: for k in E: D[k] = E[k]
- |
-
(if E has keys else: for (k, v) in E: D[k] = v) then: for k in F: D[k] = F[k]
- |
- |
-
values(...)
- |
-
D.values() -> list of D's values
- |
- |
-
----------------------------------------------------------------------
- |
-
Data and other attributes inherited from __builtin__.dict:
- |
- |
-
__new__ = <built-in method __new__ of type object at 0x1eeec0>
- |
-
T.__new__(S, ...) -> a new object with type S, a subtype of T
- |
- |
-
fromkeys = <built-in method fromkeys of type object at 0x339390>
- |
-
dict.fromkeys(S[,v]) -> New dict with keys from S and values equal to v.
- |
-
v defaults to None.
class MPDRing(__builtin__.object)
- |
-
Methods defined here:
- |
- |
-
__init__(self, listenSock=None, streamHandler=None, secretword='', myIfhn='', entryIfhn='', entryPort=0, zcMyLevel=0)
- |
- |
-
accept_lhs(self, lhsHandler=None)
- |
- |
-
accept_rhs(self, rhsHandler=None)
- |
- |
-
connect_lhs(self, lhsIfhn='', lhsPort=0, lhsHandler=None, numTries=1)
- |
- |
-
connect_rhs(self, rhsIfhn='', rhsPort=0, rhsHandler=None, numTries=1)
- |
- |
-
create_single_mem_ring(self, ifhn='', port=0, lhsHandler=None, rhsHandler=None)
- |
- |
-
enter_ring(self, entryIfhn='', entryPort=0, lhsHandler='', rhsHandler='', ntries=1)
- |
- |
-
handle_lhs_challenge_response(self, sock)
- |
- |
-
handle_rhs_challenge_response(self, sock)
- |
- |
-
handle_ring_listener_connection(self, sock)
- |
- |
-
reenter_ring(self, entryIfhn='', entryPort=0, lhsHandler='', rhsHandler='', ntries=5)
- |
- |
-
----------------------------------------------------------------------
- |
-
Data descriptors defined here:
- |
- |
-
__dict__
- |
-
dictionary for instance variables (if defined)
- |
- |
-
__weakref__
- |
-
list of weak references to the object (if defined)
class MPDSock(__builtin__.object)
- |
-
Methods defined here:
- |
- |
-
__init__(self, family=2, socktype=1, proto=0, sock=None, name='')
- |
- |
-
accept(self, name='accepter')
- |
- |
-
close(self)
- |
- |
-
connect(self, *args)
- |
- |
-
fileno(self)
- |
- |
-
getsockname(self)
- |
- |
-
recv(self, nbytes)
- |
- |
-
recv_char_msg(self)
- |
- |
-
recv_dict_msg(self, timeout=None)
- |
- |
-
recv_one_line(self)
- |
- |
-
send_char_msg(self, msg, errprint=1)
- |
- |
-
send_dict_msg(self, msg, errprint=1)
- |
-
# The default behavior on an error needs to be to handle and/or report
- |
-
# it. Otherwise, we all waste time trying to figure out why
- |
-
# the code is silently failing. I've set the default for errprint
- |
-
# to YES rather than NO.
- |
- |
-
sendall(self, data)
- |
- |
-
----------------------------------------------------------------------
- |
-
Data descriptors defined here:
- |
- |
-
__dict__
- |
-
dictionary for instance variables (if defined)
- |
- |
-
__weakref__
- |
-
list of weak references to the object (if defined)
class MPDStreamHandler(__builtin__.object)
- |
-
Methods defined here:
- |
- |
-
__init__(self)
- |
- |
-
close_all_active_streams(self)
- |
- |
-
del_handler(self, stream)
- |
- |
-
handle_active_streams(self, streams=None, timeout=0.10000000000000001)
- |
- |
-
set_handler(self, stream, handler, args=())
- |
- |
-
----------------------------------------------------------------------
- |
-
Data descriptors defined here:
- |
- |
-
__dict__
- |
-
dictionary for instance variables (if defined)
- |
- |
-
__weakref__
- |
-
list of weak references to the object (if defined)
class MPDTest(__builtin__.object)
- |
-
Methods defined here:
- |
- |
-
__init__(self)
- |
- |
-
run(self, cmd='', expIn='', chkEC=0, expEC=0, chkOut=0, expOut='', ordOut=0, grepOut=0, exitOnFail=1)
- |
- |
-
----------------------------------------------------------------------
- |
-
Data descriptors defined here:
- |
- |
-
__dict__
- |
-
dictionary for instance variables (if defined)
- |
- |
-
__weakref__
- |
-
list of weak references to the object (if defined)
FUNCTIONS
dumps(...) dumps(obj, protocol=0) -- Return a string containing an object in pickle format.
See the Pickler docstring for the meaning of optional argument proto.
loads(...) loads(string) -- Load a pickle from the given string
md5new = openssl_md5(...) Returns a md5 hash object; optionally initialized with a string
mpd_check_python_version()
mpd_close_zc()
mpd_find_zc_peer(peer_level)
mpd_get_groups_for_username(username)
mpd_get_my_id()
mpd_get_my_username()
mpd_get_ranks_in_binary_tree(myRank, nprocs)
mpd_handle_signal(signum, frame)
mpd_init_zc(ifhn, my_level) #### experimental code for zeroconf
mpd_print(*args)
mpd_print_tb(*args)
mpd_read_nbytes(fd, nbytes)
mpd_register_zc(ifhn, level)
mpd_same_ips(host1, host2)
mpd_set_cli_app(app)
mpd_set_dbg_level(flag)
mpd_set_my_id(myid='')
mpd_set_procedures_to_trace(procs)
mpd_set_tmpdir(tmpdir)
mpd_sockpair()
mpd_trace_calls(frame, event, args)
mpd_trace_returns(frame, event, args)
mpd_uncaught_except_tb(arg1, arg2, arg3)
mpd_version()
mpd_which(execName, user_path=None)
random(...) random() -> x in the interval [0, 1).
sleep(...) sleep(seconds)
- Delay execution for a given number of seconds.
-
The argument may be a floating point number for subsecond precision.
DATA
ECONNREFUSED = 61 ECONNRESET = 54 EINTR = 4 EISCONN = 56 EPIPE = 32 grp_module_available = 1 mpd_cli_app = '' mpd_dbg_level = 0 mpd_my_hostname = '' mpd_my_id = '' mpd_procedures_to_trace = [] mpd_signum = 0 mpd_tmpdir = '/tmp' mpd_zc = 0 pwd_module_available = 1 subprocess_module_available = 1 syslog_module_available = 1