File manager

�
e f�)�@s[dd
lZdd
l
Z
dd
lZddlmZ
gZGdd�de�ZGdd�de�ZGdd	�d	e�Z	Gd
d�de�Z
Gdd
�d
e�ZGdd�dej
�ZGdd�de�Zedd�ee�
D�
�
e_e
jdkr�
Gdd�dej
�ZGdd�dej
�ZGdd�dej
�ZGdd�de�ZGdd�de�ZGdd �d e�Zie�d!6e�d"6e�d#6Zeed!�
ZnOGd$d�dej
�ZGd%d�de�Zi
e�d"6Zeed"�
Zd&d'�Zej�Zd(d)�Zd*d+�Zd,d-�Z d
S).�N�
)
�processc
@seZ
dZd
S)�ProcessErrorN)�__name__�
__module__�__qualname__�rr�</opt/alt/python34/lib64/python3.4/multiprocessing/context.pyr
s
rc
@seZ
dZd
S)�BufferTooShortN)rrrrrrr	r
s
r
c
@seZ
dZd
S)�TimeoutErrorN)rrrrrrr	rs
rc
@seZ
dZd
S)�AuthenticationErrorN)rrrrrrr	rs
rc@s�
eZ
dZeZeZeZeZeej	�
Z	eej
�
Z
d
d�Zdd�Zddd�
Z
dd	�Zd
d�Zdd
d�
Zddd�
Zddd�
Zdd�Zdddd�Zddd�
Zddd�
Zdd�Zddfddd �Zd!d"�Zd#d$�Zd%dd&d'�
Zd%dd(d)�
Zd*d+�Zd,d-�Zdd.d/�
Zd0d1�Z d2d3�Z!d4d5�Z"dd6d7�
Z#d8d9d:�
Z$dd;d<�
Z%d=d>�Z&dS)?�BaseContextc
Cs/tj
�}
|
d
kr'td�
�
n|
Sd
S)z(Returns the number of CPUs in the systemNzcannot determine number of cpus)�os�	cpu_count�NotImplementedError)�selfZnumrrr	r's

zBaseContext.cpu_countc
Cs3d
dlm
}

|
d|j��
}|j�
|S)z�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.
        r)
�SyncManager�ctx)Zmanagersr�get_context�start)rr�
mrrr	�Manager/s



zBaseContext.ManagerTcCsd
dlm
}
||
�
S)z1Returns two connection object connected by a piper)
�Pipe)�
connectionr)rZduplexrrrr	r:s
zBaseContext.Pipec
Cs#d
dlm
}

|
d|j��
S)z#Returns a non-recursive lock objectr)
�Lockr)�synchronizerr)rrrrr	r?s
zBaseContext.Lockc
Cs#d
dlm
}

|
d|j��
S)zReturns a recursive lock objectr)
�RLockr)rrr)rrrrr	rDs
zBaseContext.RLockNcCs&d
dlm
}
||
d|j��

S)zReturns a condition objectr)
�	Conditionr)rrr)r�lockrrrr	rIs
zBaseContext.ConditionrcCs&d
dlm
}
||
d|j��

S)zReturns a semaphore objectr)
�	Semaphorer)rrr)r�valuerrrr	rNs
zBaseContext.SemaphorecCs&d
dlm
}
||
d|j��

S)z"Returns a bounded semaphore objectr)
�BoundedSemaphorer)rr!r)rr r!rrr	r!Ss
zBaseContext.BoundedSemaphorec
Cs#d
dlm
}

|
d|j��
S)zReturns an event objectr)
�Eventr)rr"r)rr"rrr	r"Xs
zBaseContext.EventcCs,d
dlm
}
||
||d|j��
S)zReturns a barrier objectr)
�Barrierr)rr#r)rZparties�actionZtimeoutr#rrr	r#]s
zBaseContext.Barrierr
cCs&d
dlm
}
||
d|j��

S)zReturns a queue objectr)
�Queuer)�queuesr%r)r�maxsizer%rrr	r%bs
zBaseContext.QueuecCs&d
dlm
}
||
d|j��

S)zReturns a queue objectr)
�
JoinableQueuer)r&r(r)rr'r(rrr	r(gs
zBaseContext.JoinableQueuec
Cs#d
dlm
}

|
d|j��
S)zReturns a queue objectr)
�SimpleQueuer)r&r)r)rr)rrr	r)ls
zBaseContext.SimpleQueuecCs/d
dlm
}
||
|||d|j��
S)zReturns a process pool objectr)
�Pool�context)Zpoolr*r)rZ	processesZinitializerZinitargsZmaxtasksperchildr*rrr	r*qs

zBaseContext.PoolcGsd
dlm
}
||
|�
S)zReturns a shared objectr)
�RawValue)�sharedctypesr,)r�typecode_or_type�argsr,rrr	r,xs
zBaseContext.RawValuecCsd
dlm
}
||
|�S)zReturns a shared arrayr)
�RawArray)r-r0)rr.�size_or_initializerr0rrr	r0}s
zBaseContext.RawArrayrc
Gs/d
dlm
}
||
d|d|j�|�
S)z$Returns a synchronized shared objectr)
�Valuerr)r-r2r)rr.rr/r2rrr	r2�s

zBaseContext.Valuec
Cs/d
dlm
}
||
|d|d|j��S)z#Returns a synchronized shared arrayr)
�Arrayrr)r-r3r)rr.r1rr3rrr	r3�s

zBaseContext.Arrayc
Cs?tj
d
kr;ttdd�r;ddlm}

|
�
ndS)z�Check whether this is a fake forked process in a frozen executable.
        If so then run code specified by commandline and exit.
        �win32�frozenFr)
�freeze_supportN)�sys�platform�getattr�spawnr6)rr6rrr	r6�s!

zBaseContext.freeze_supportc
Csd
dlm
}

|
�S)zZReturn package logger -- if it does not already exist then
        it is created.
        r)
�
get_logger)�utilr;)rr;rrr	r;�s
zBaseContext.get_loggercCsd
dlm
}
||
�
S)z8Turn on logging and add a handler which prints to stderrr)
�
log_to_stderr)r<r=)r�levelr=rrr	r=�s
zBaseContext.log_to_stderrc
Csd
dlm
}

dS)zVInstall support for sending connections and sockets
        between processes
        r)
rN)�r)rrrrr	�allow_connection_pickling�sz%BaseContext.allow_connection_picklingcCsd
dlm
}
||
�

dS)z�Sets the path to a python.exe or pythonw.exe binary used to run
        child processes instead of sys.executable when using the 'spawn'
        start method.  Useful for people embedding Python.
        r)
�set_executableN)r:rA)r�
executablerArrr	rA�s
zBaseContext.set_executablecCsd
dlm
}
||
�

dS)zkSet list of module names to try to load in forkserver process.
        This is really just a hint.
        r)
�set_forkserver_preloadN)�
forkserverrC)rZmodule_namesrCrrr	rC�s
z"BaseContext.set_forkserver_preloadcCsQ|
dkr|Syt|
}Wn"t
k
rB


td
|
�
�
Yn
X|j�
|S)Nzcannot find context for %r)�_concrete_contexts�KeyError�
ValueError�_check_available)r�methodrrrr	r�s









zBaseContext.get_contextFc
Cs|jS)
N)
�_name)r�
allow_nonerrr	�get_start_method�s
zBaseContext.get_start_methodcCstd
�
�
dS)Nz+cannot set start method of concrete context)
rG)rrIrrr	�set_start_method�s
zBaseContext.set_start_methodc


CsdS)
Nr)
rrrr	rH�s
zBaseContext._check_available)'rrrrr
rr�staticmethodrZcurrent_processZactive_childrenrrrrrrrr!r"r#r%r(r)r*r,r0r2r3r6r;r=r@rArCrrLrMrHrrrr	r
sF



	

r
c@s(eZ
dZd
Zedd��
Zd
S)�ProcessNc

Cstj
�jj|�
S)
N)�_default_contextrrO�_Popen)
�process_objrrr	rQ�szProcess._Popen)rrr�
_start_methodrNrQrrrr	rO�s

rOcsaeZ
dZeZd
d�Zd�f
dd�
Zddd�
Zdd	d
�
Zdd�Z�S)
�DefaultContextcCs|
|_d|_
dS)
N)rP�_actual_context)rr+rrr	�__init__�s
	
zDefaultContext.__init__NcsE|
dkr1|jdkr*|j
|_n|jSt�j|
�
SdS)
N)rUrP�superr)rrI)
�	__class__rr	r�s




zDefaultContext.get_contextFcCsZ|jdk	r%|r%t
d
�
�
n|
dkrD|rDd|_dS|j|
�
|_dS)Nzcontext has already been set)rU�RuntimeErrorr)rrIZforcerrr	rM�s



	

zDefaultContext.set_start_methodcCs2|jdkr(|
rdS|j
|_n|jjS)
N)rUrPrJ)rrKrrr	rL�s





zDefaultContext.get_start_methodc
CsJtj
d
krdg
Sddlm}

|
jr<dddgSddgSdS)Nr4r:r)
�	reduction�forkrD)r7r8r?rZ�HAVE_SEND_HANDLE)rrZrrr	�get_all_start_methods�s


	

z$DefaultContext.get_all_start_methods)	rrrrOrVrrMrLr]rr)
rXr	rT�s
rTc
cs%|]}
|
dd
kr|
V
qdS)r
�
_Nr)�.0�
xrrr	�	<genexpr>�srar4c@s(eZ
dZd
Zedd��
ZdS)�ForkProcessr[c
Csd
dlm
}

|
|�
S)Nr)
�Popen)Z
popen_forkrc)rRrcrrr	rQ
s
zForkProcess._PopenN)rrrrSrNrQrrrr	rb
s

rbc@s(eZ
dZd
Zedd��
ZdS)�SpawnProcessr:c
Csd
dlm
}

|
|�
S)Nr)
rc)Zpopen_spawn_posixrc)rRrcrrr	rQ
s
zSpawnProcess._PopenN)rrrrSrNrQrrrr	rd

s

rdc@s(eZ
dZd
Zedd��
ZdS)�ForkServerProcessrDc
Csd
dlm
}

|
|�
S)Nr)
rc)Zpopen_forkserverrc)rRrcrrr	rQ
s
zForkServerProcess._PopenN)rrrrSrNrQrrrr	re
s

rec
@seZ
dZd
ZeZdS)�ForkContextr[N)rrrrJrbrOrrrr	rf
s

rfc
@seZ
dZd
ZeZdS)�SpawnContextr:N)rrrrJrdrOrrrr	rg
s

rgc@s(eZ
dZd
ZeZdd�ZdS)�ForkServerContextrDc
Cs,d
dlm
}

|
js(td�
�
ndS)Nr)
rZz%forkserver start method not available)r?rZr\rG)rrZrrr	rH&
s

	
z"ForkServerContext._check_availableN)rrrrJrerOrHrrrr	rh#
s


rhr[r:rDc@s(eZ
dZd
Zedd��
ZdS)rdr:c
Csd
dlm
}

|
|�
S)Nr)
rc)Zpopen_spawn_win32rc)rRrcrrr	rQ6
s
zSpawnProcess._PopenN)rrrrSrNrQrrrr	rd4
s

c
@seZ
dZd
ZeZdS)rgr:N)rrrrJrdrOrrrr	rg;
s

c

Cst|t
_dS)
N)rErPrU)
rIrrr	�_force_start_methodH
s
ricCstt
d
d�S)N�spawning_popen)r9�_tlsrrrr	�get_spawning_popenQ
s
rlc

Cs
|t_
dS)
N)rkrj)
�popenrrr	�set_spawning_popenT
s
rnc

Cs/t�dkr+t
d
t|�
j�
�
ndS)NzF%s objects should only be shared between processes through inheritance)rlrY�typer)
�objrrr	�assert_spawningW
s



rq)!rr7Z	threadingr?r�__all__�	Exceptionrr
rr�objectr
ZBaseProcessrOrT�list�dirr8rbrdrerfrgrhrErPriZlocalrkrlrnrqrrrr	�<module>
sD

�("