HEX

Warning: set_time_limit() [function.set-time-limit]: Cannot set time limit - prohibited by configuration in /home/u547966/brikov.ru/www/wp-content/plugins/admin-menu-editor/menu-editor.php on line 745
Server: Apache
System: Linux 4.19.0-0.bpo.9-amd64 x86_64 at red40
User: u547966 (5490)
PHP: 5.3.29-mh2
Disabled: syslog, dl, popen, proc_open, proc_nice, proc_get_status, proc_close, proc_terminate, posix_mkfifo, chown, chgrp, accelerator_reset, opcache_reset, accelerator_get_status, opcache_get_status, pcntl_alarm, pcntl_fork, pcntl_waitpid, pcntl_wait, pcntl_wifexited, pcntl_wifstopped, pcntl_wifsignaled, pcntl_wifcontinued, pcntl_wexitstatus, pcntl_wtermsig, pcntl_wstopsig, pcntl_signal, pcntl_signal_dispatch, pcntl_get_last_error, pcntl_strerror, pcntl_sigprocmask, pcntl_sigwaitinfo, pcntl_sigtimedwait, pcntl_exec, pcntl_getpriority, pcntl_setpriority
Upload Files
File: //usr/lib/python3.5/multiprocessing/__pycache__/queues.cpython-35.pyc


Fa+@s,dddgZddlZddlZddlZddlZddlZddlZddlZddlm	Z	m
Z
ddlZddlm
Z
ddlmZdd	lmZmZmZmZmZdd
lmZGdddeZeZGdddeZGd
ddeZdS)QueueSimpleQueue
JoinableQueueN)EmptyFull)
connection)context)debuginfoFinalizeregister_after_fork
is_exiting)ForkingPicklerc@s	eZdZdddZddZddZdd	Zd
ddd
Zd
dddZddZ	ddZ
ddZddZddZ
ddZddZddZd d!Zed"d#Zed$d%Zed&d'ZdS)(rrcCs|dkrddlm}||_tjdd\|_|_|j|_t	j
|_tj
dkr|d|_n|j|_|j||_d|_|jtj
dkrt|tjdS)Nrr)
SEM_VALUE_MAXduplexFwin32)Zsynchronizer_maxsizerPipe_reader_writerLock_rlockosgetpid_opidsysplatform_wlockZBoundedSemaphore_sem
_ignore_epipe_after_forkr
r)selfmaxsizectxr%,/usr/lib/python3.5/multiprocessing/queues.py__init__$s		
zQueue.__init__cCsAtj||j|j|j|j|j|j|j|j	fS)N)
r	assert_spawningr rrrrrrr)r"r%r%r&__getstate__9s
zQueue.__getstate__c	CsD|\|_|_|_|_|_|_|_|_|jdS)N)	r rrrrrrrr!)r"stater%r%r&__setstate__>s6zQueue.__setstate__cCstdtjtj|_tj|_d|_d|_	d|_
d|_d|_|j
j|_|jj|_|jj|_dS)NzQueue._after_fork()F)r
	threading	Conditionr	_notemptycollectionsdeque_buffer_thread_jointhread_joincancelled_closed_closer
send_bytes_send_bytesr
recv_bytes_recv_bytespoll_poll)r"r%r%r&r!Cs
					zQueue._after_forkTNc	Csv|jst|jj||s+t|j;|jdkrN|j|jj	||jj
WdQRXdS)N)r5AssertionErrorracquirerr.r2
_start_threadr1appendnotify)r"objblocktimeoutr%r%r&putPs

z	Queue.putc
Cs|r?|dkr?|j|j}WdQRX|jjn|rUtj|}|jj||sptzj|r|tj}|dks|j|rtn|jst|j}|jjWd|jjXtj	|S)Nr)
rr:rreleasetimer>rr<rloads)r"rCrDresZdeadliner%r%r&get[s&
	z	Queue.getcCs|j|jjjS)N)rr_semlockZ
_get_value)r"r%r%r&qsizesszQueue.qsizecCs|jS)N)r<)r"r%r%r&emptywszQueue.emptycCs|jjjS)N)rrK_is_zero)r"r%r%r&fullzsz
Queue.fullcCs
|jdS)NF)rJ)r"r%r%r&
get_nowait}szQueue.get_nowaitcCs|j|dS)NF)rE)r"rBr%r%r&
put_nowaitszQueue.put_nowaitcCsAd|_z|jjWd|j}|r<d|_|XdS)NT)r5rcloser6)r"rRr%r%r&rRs			zQueue.closecCs0td|jst|jr,|jdS)NzQueue.join_thread())r
r5r=r3)r"r%r%r&join_threads
	zQueue.join_threadcCs=tdd|_y|jjWntk
r8YnXdS)NzQueue.cancel_join_thread()T)r
r4r3ZcancelAttributeError)r"r%r%r&cancel_join_threads
	
zQueue.cancel_join_threadc
Cstd|jjtjdtjd|j|j|j|j	|j
j|jfdd|_
d|j
_td|j
jtd|jtjk}|jr|rt|j
tjtj|j
gd	d|_t|tj|j|jgd	d|_dS)
NzQueue._start_thread()targetargsnameZQueueFeederThreadTzdoing self._thread.start()z... done self._thread.start()Zexitpriority
)r
r1clearr,ZThreadr_feedr.r8rrrRr r2Zdaemonstartrrrr4r_finalize_joinweakrefrefr3_finalize_closer6)r"Zcreated_by_this_processr%r%r&r?s*

		


	zQueue._start_threadcCsDtd|}|dk	r6|jtdn
tddS)Nzjoining queue threadz... queue thread joinedz... queue thread already dead)r
join)ZtwrZthreadr%r%r&r_s
	

zQueue._finalize_joinc	Cs3td||jt|jWdQRXdS)Nztelling queue thread to quit)r
r@	_sentinelrA)buffernotemptyr%r%r&rbs

zQueue._finalize_closecCstd|j}|j}|j}|j}	t}
tjdkrX|j}|j}nd}yx|z|s{|Wd|Xy}xv|	}
|
|
krtd|dStj	|
}
|dkr||
q|z||
Wd|XqWWqdt
k
rYqdXqdWWntk
r}zr|rXt|ddt
jkrXdSy3trttd|nddl}|jWntk
rYnXWYdd}~XnXdS)Nz$starting thread to feed data to piperz%feeder thread got sentinel -- exitingerrnorzerror in queue thread: %s)r
r>rFwaitpopleftrdrrrdumps
IndexError	ExceptiongetattrrgZEPIPErr	traceback	print_exc)rerfr7Z	writelockrRZignore_epipeZnacquireZnreleaseZnwaitZbpopleftsentinelZwacquireZwreleaserBernr%r%r&r]sV
						



!	
zQueue._feed)__name__
__module____qualname__r'r)r+r!rErJrLrMrOrPrQrRrSrUr?staticmethodr_rbr]r%r%r%r&r"s$

&
c@saeZdZdddZddZddZdd	d
dZdd
ZddZd	S)rrcCs;tj||d||jd|_|j|_dS)Nr$r)rr'Z	Semaphore_unfinished_tasksr-_cond)r"r#r$r%r%r&r'szJoinableQueue.__init__cCstj||j|jfS)N)rr)rwrv)r"r%r%r&r)szJoinableQueue.__getstate__cCs:tj||dd|dd\|_|_dS)Nry)rr+rwrv)r"r*r%r%r&r+ szJoinableQueue.__setstate__TNcCs|jst|jj||s+t|jY|jH|jdkrX|j|j	j
||jj|jj
WdQRXWdQRXdS)N)r5r=rr>rr.rwr2r?r1r@rvrFrA)r"rBrCrDr%r%r&rE$s

zJoinableQueue.putc	CsR|jB|jjds(td|jjjrG|jjWdQRXdS)NFz!task_done() called too many times)rwrvr>
ValueErrorrKrNZ
notify_all)r"r%r%r&	task_done0s

zJoinableQueue.task_donec	Cs4|j$|jjjs)|jjWdQRXdS)N)rwrvrKrNrh)r"r%r%r&rc7s
zJoinableQueue.join)	rrrsrtr'r)r+rEr{rcr%r%r%r&rsc@sXeZdZddZddZddZddZd	d
ZddZd
S)rcCsjtjdd\|_|_|j|_|jj|_tj	dkrWd|_
n|j|_
dS)NrFr)rrrrrrr;r<rrr)r"r$r%r%r&r'BszSimpleQueue.__init__cCs|jS)N)r<)r"r%r%r&rMKszSimpleQueue.emptycCs)tj||j|j|j|jfS)N)r	r(rrrr)r"r%r%r&r)Ns
zSimpleQueue.__getstate__cCs"|\|_|_|_|_dS)N)rrrr)r"r*r%r%r&r+RszSimpleQueue.__setstate__c	Cs-|j|jj}WdQRXtj|S)N)rrr9rrH)r"rIr%r%r&rJUs
zSimpleQueue.getc	CsVtj|}|jdkr1|jj|n!|j|jj|WdQRXdS)N)rrjrrr7)r"rBr%r%r&rE[s

zSimpleQueue.putN)	rrrsrtr'rMr)r+rJrEr%r%r%r&r@s	)__all__rrr,r/rGr`rgZqueuerrZ_multiprocessingrr	utilr
rrr
rZ	reductionrobjectrrdrrr%r%r%r&<module>
s"(	
*