File "__init__.pyo"

Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/lib64/python2.7/multiprocessing/__init__.pyo
File size: 8.27 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit


{fc@sdZd
dddddddd	d
ddd
ddddddddddddddgZ
dZddlZddlZddlmZmZmZ
dd l	m
Z
mZ
d!ef
d"YZ
de
f
d#YZde
f
d$YZd%e
f
d&YZddlZd'Zed(
Zd)Zd*Zd+Zdd,
Zd-Zd.Zd/Zdd0
Zd1d2
Zd1d3
Zd4Z d5d6
Z!d5d7
Z"ddd@dd8Z#d9Z$d:Z%d;Z&d<Z'ej(d=krd>Z)e
d?g
7Z
ndS(As0.70a1tProcesstcurrent_processtactive_childrentfreeze_supporttManagertPipet	cpu_countt
log_to_stderrt
get_loggertallow_connection_picklingtBufferTooShorttTimeoutErrortLocktRLockt	SemaphoretBoundedSemaphoret	ConditiontEventtQueuet
JoinableQueuetPooltValuetArraytRawValuetRawArraytSUBDEBUGt
SUBWARNINGs"R. Oudkerk (r.m.oudkerk@gmail.com)iN(RR
R(RRtProcessErrorc
BseZ
RS((t__name__t
__module__(((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRGs
c
BseZ
RS((RR(((s0/usr/lib64/python2.7/multiprocessing/__init__.pyR
Js
c
BseZ
RS((RR(((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRMs
tAuthenticationErrorc
BseZ
RS((RR(((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRPs
cCs'd
dlm
}
|}
|
j
|
S(s
    Returns a manager associated with a running server process

    The managers methods such as `Lock()`, `Condition()` and `Queue()`
    can be used to create shared objects.
    i(
tSyncManager(tmultiprocessing.managersRtstart(Rt
m((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRZs
	


c
Csd
dlm
}

|
|
S(s;
    Returns two connection object connected by a pipe
    i(
R(tmultiprocessing.connectionR(tduplexR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRfs
cCs*
tj
d
krIyttjd
}Wq

ttfk
rE


d}q

Xndtj
ksgtj
dkrd}
tj
dkrd|
}
ny.tj|

}t|j
}WdQXWq

tk
r


d}q

Xn6ytj	d	
}Wn tt
tfk
r	



d}n
X|d
kr
|Std

dS(s2
    Returns the number of CPUs in the system
    twin32tNUMBER_OF_PROCESSORSitbsdtdarwins/sbin/sysctl -n hw.ncpus/usrNtSC_NPROCESSORS_ONLNi
scannot determine number of cpus(
tsystplatformtinttostenviront
ValueErrortKeyErrortpopentreadtsysconftOSErrortAttributeErrortNotImplementedError(tnumtcommt
p((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRms*





















c
Cs?tj
d
kr;ttdtr;ddlm}
|
ndS(s
    Check whether this is a fake forked process in a frozen executable.
    If so then run code specified by commandline and exit.
    R%tfrozeni(
RN(R*R+tgetattrtFalsetmultiprocessing.forkingR(
R((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs!

c
Csd
dlm
}
|S(sR
    Return package logger -- if it does not already exist then it is created
    i(
R(tmultiprocessing.utilR(
R((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
c
Csd
dlm
}

|
|
S(sB
    Turn on logging and add a handler which prints to stderr
    i(
R(R>R(tlevelR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
c
Csd
dlm
}
dS(sO
    Install support for sending connections and sockets between processes
    i(
t	reductionN(tmultiprocessingR@(
R@((s0/usr/lib64/python2.7/multiprocessing/__init__.pyR	sc
Csd
dlm
}
|S(s-
    Returns a non-recursive lock object
    i(
R(tmultiprocessing.synchronizeR(
R((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
c
Csd
dlm
}
|S(s)
    Returns a recursive lock object
    i(
R
(RBR
(
R
((s0/usr/lib64/python2.7/multiprocessing/__init__.pyR
s
c
Csd
dlm
}

|
|
S(s$
    Returns a condition object
    i(
R(RBR(tlockR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
i
c
Csd
dlm
}

|
|
S(s$
    Returns a semaphore object
    i(
R(RBR(tvalueR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
c
Csd
dlm
}

|
|
S(s,
    Returns a bounded semaphore object
    i(
R(RBR(RDR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
c
Csd
dlm
}
|S(s!
    Returns an event object
    i(
R(RBR(
R((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
ic
Csd
dlm
}

|
|
S(s 
    Returns a queue object
    i(
R(tmultiprocessing.queuesR(tmaxsizeR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
c
Csd
dlm
}

|
|
S(s 
    Returns a queue object
    i(
R(RER(RFR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
cCs#d
dlm
}
|||
||S(s'
    Returns a process pool object
    i(
R(tmultiprocessing.poolR(t	processestinitializertinitargstmaxtasksperchildR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
c
Gsd
dlm
}
|||

S(s!
    Returns a shared object
    i(
R(tmultiprocessing.sharedctypesR(ttypecode_or_typetargsR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
cCsd
dlm
}
|||
S(s 
    Returns a shared array
    i(
R(RLR(RMtsize_or_initializerR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
c
Os d
dlm
}
|||
|
S(s.
    Returns a synchronized shared object
    i(
R(RLR(RMRNtkwdsR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
cKs d
dlm
}
|||
|S(s-
    Returns a synchronized shared array
    i(
R(RLR(RMRORPR((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRs
R%c
Csd
dlm
}

|
|

dS(s
        Sets the path to a python.exe or pythonw.exe binary used to run
        child processes on Windows instead of sys.executable.
        Useful for people embedding Python.
        i(
tset_executableN(R=RQ(t
executableRQ((s0/usr/lib64/python2.7/multiprocessing/__init__.pyRQ
s
RQ((*t__version__t__all__t
__author__R-R*tmultiprocessing.processRR
RR>RRt	ExceptionRR
RRt_multiprocessingRtTrueRRRRtNoneRR	RR
RRRRRRRRRRRR+RQ(((s0/usr/lib64/python2.7/multiprocessing/__init__.pyt<module>,sN