⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.67
Server IP:
50.6.168.112
Server:
Linux server-617809.webnetzimbabwe.com 5.14.0-570.25.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 9 04:57:09 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.4.10
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib64
/
python3.9
/
multiprocessing
/
__pycache__
/
View File Name :
queues.cpython-39.pyc
a DOg. @ s g d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl Z ddl mZ ddl mZ ejjZddlmZmZmZmZmZ G dd d eZe ZG d d d eZ G d d d eZ dS ))Queue SimpleQueue JoinableQueue N)EmptyFull ) connection)context)debuginfoFinalizeregister_after_fork is_exitingc @ s e Zd Zd-ddZdd Zdd Zdd Zd.d d Zd/ddZd0ddZ dd Z dd Z dd Z dd Z dd Zd d Zd d Zd!d" Zd#d$ Zed%d& Zed'd( Zed)d* Zed+d, ZdS )1r r c C s |dkrddl m} || _tjdd\| _| _| | _t | _ t j dkrTd | _n | | _||| _d| _| t j dkrt| tj d S )Nr r ) SEM_VALUE_MAXFduplexwin32) synchronizer _maxsizer Pipe_reader_writerLock_rlockosgetpid_opidsysplatform_wlockBoundedSemaphore_sem _ignore_epipe_resetr r _after_forkselfmaxsizectx r) ./usr/lib64/python3.9/multiprocessing/queues.py__init__% s zQueue.__init__c C s. t | | j| j| j| j| j| j| j| j fS N) r assert_spawningr" r r r r r r! r r& r) r) r* __getstate__9 s zQueue.__getstate__c C s0 |\| _ | _| _| _| _| _| _| _| d S r, ) r" r r r r r r! r r# r& stater) r) r* __setstate__> s zQueue.__setstate__c C s t d | jdd d S )NzQueue._after_fork()T) after_fork)r r# r. r) r) r* r$ C s zQueue._after_forkFc C sj |r| j ntt | _ t | _d | _d | _ d| _ d| _ d | _ | j j| _| jj| _| jj| _d S NF) _notempty_at_fork_reinit threading Conditionr collectionsdeque_buffer_thread _jointhread_joincancelled_closed_closer send_bytes _send_bytesr recv_bytes _recv_bytespoll_poll)r& r3 r) r) r* r# G s z Queue._resetTNc C sz | j rtd| d| j||s(t| j8 | jd u rB| | j | | j W d n1 sl0 Y d S NzQueue z is closed) r? ValueErrorr! acquirer r5 r< _start_threadr; appendnotifyr& objblocktimeoutr) r) r* putV s z Queue.putc C s | j rtd| d|r\|d u r\| j | }W d n1 sF0 Y | j n||rlt | }| j||s~t zL|r|t }| |st n | st | }| j W | j n | j 0 t |S rG ) r? rH r rD r! releasetime monotonicrI r rF _ForkingPicklerloads)r& rO rP resdeadliner) r) r* getb s* & z Queue.getc C s | j | jj S r, )r r! _semlock _get_valuer. r) r) r* qsize| s z Queue.qsizec C s | S r, rF r. r) r) r* empty s z Queue.emptyc C s | j j S r, )r! rZ _is_zeror. r) r) r* full s z Queue.fullc C s | dS r4 )rY r. r) r) r* get_nowait s zQueue.get_nowaitc C s | |dS r4 )rQ r& rN r) r) r* put_nowait s zQueue.put_nowaitc C s d| _ | j}|r d | _| d S )NT)r? r@ )r& closer) r) r* rd s z Queue.closec C s. t d | js J d| | jr*| d S )NzQueue.join_thread()zQueue {0!r} not closed)r r? formatr= r. r) r) r* join_thread s zQueue.join_threadc C s4 t d d| _z| j W n ty. Y n0 d S )NzQueue.cancel_join_thread()T)r r> r= cancelAttributeErrorr. r) r) r* cancel_join_thread s zQueue.cancel_join_threadc C s t d | j tjtj| j| j| j| j | j j | j j | j | j| jf dd| _d| j_t d | j t d | jst| jtjt| jgdd| _t| tj| j| jgd d| _d S ) NzQueue._start_thread()QueueFeederThread)targetargsnameTzdoing self._thread.start()z ... done self._thread.start()) exitpriority )r r; clearr7 Threadr _feedr5 rB r r rd r r" _on_queue_feeder_errorr! r< daemonstartr> r _finalize_joinweakrefrefr= _finalize_closer@ r. r) r) r* rJ s4 zQueue._start_threadc C s4 t d | }|d ur(| t d nt d d S )Nzjoining queue threadz... queue thread joinedz ... queue thread already dead)r join)twrthreadr) r) r* rw s zQueue._finalize_joinc C sB t d |" | t | W d n1 s40 Y d S )Nz telling queue thread to quit)r rK _sentinelrL )buffernotemptyr) r) r* rz s zQueue._finalize_closec C sr t d |j} |j} |j} | j} t} tjdkr<|j}|j}nd }z| z| sT| W | n| 0 zn| }|| u rt d | | W W d S t |}|d u r|| qh| z|| W | qh| 0 qhW n t y Y n0 W q@ t yj } zf|r$t |ddt jkr$W Y d }~d S t rDtd| W Y d }~d S | ||| W Y d }~q@d }~0 0 q@d S )Nz$starting thread to feed data to piper z%feeder thread got sentinel -- exitingerrnor zerror in queue thread: %s)r rI rR waitpopleftr~ r r rU dumps IndexError Exceptiongetattrr EPIPEr r )r r rA writelock reader_close writer_close ignore_epipeonerror queue_semnacquirenreleasenwaitbpopleftsentinelwacquirewreleaserN er) r) r* rs sP z Queue._feedc C s ddl }| dS )z Private API hook called when feeding data in the background thread raises an exception. For overriding by concurrent.futures. r N) traceback print_exc)r rN r r) r) r* rt s z Queue._on_queue_feeder_error)r )F)TN)TN)__name__ __module__ __qualname__r+ r/ r2 r$ r# rQ rY r\ r^ r` ra rc rd rf ri rJ staticmethodrw rz rs rt r) r) r) r* r # s0 ! >r c @ s@ e Zd ZdddZdd Zdd Zdd d Zd d Zdd Zd S )r r c C s* t j| ||d |d| _| | _d S )N)r( r )r r+ Semaphore_unfinished_tasksr8 _condr% r) r) r* r+ ( s zJoinableQueue.__init__c C s t | | j| jf S r, )r r/ r r r. r) r) r* r/ - s zJoinableQueue.__getstate__c C s, t | |d d |dd \| _| _d S )N)r r2 r r r0 r) r) r* r2 0 s zJoinableQueue.__setstate__TNc C s | j rtd| d| j||s(t| jh | jB | jd u rJ| | j | | j | j W d n1 s~0 Y W d n1 s0 Y d S rG )r? rH r! rI r r5 r r< rJ r; rK r rR rL rM r) r) r* rQ 4 s zJoinableQueue.putc C sT | j : | jds td| jj r2| j W d n1 sF0 Y d S )NFz!task_done() called too many times)r r rI rH rZ r_ notify_allr. r) r) r* task_doneA s zJoinableQueue.task_donec C s@ | j & | jj s | j W d n1 s20 Y d S r, )r r rZ r_ r r. r) r) r* r{ H s zJoinableQueue.join)r )TN) r r r r+ r/ r2 rQ r r{ r) r) r) r* r & s r c @ sN e Zd Zdd Zdd Zdd Zdd Zd d Zd d Zd d Z e e j Z dS )r c C sH t jdd\| _| _| | _| jj| _tj dkr:d | _ n | | _ d S )NFr r ) r r r r r r rE rF r r r )r& r( r) r) r* r+ S s zSimpleQueue.__init__c C s | j | j d S r, )r rd r r. r) r) r* rd \ s zSimpleQueue.closec C s | S r, r] r. r) r) r* r^ ` s zSimpleQueue.emptyc C s t | | j| j| j| jfS r, )r r- r r r r r. r) r) r* r/ c s zSimpleQueue.__getstate__c C s" |\| _ | _| _| _| j j| _d S r, )r r r r rE rF r0 r) r) r* r2 g s zSimpleQueue.__setstate__c C s: | j | j }W d n1 s&0 Y t|S r, )r r rC rU rV )r& rW r) r) r* rY k s (zSimpleQueue.getc C sX t |}| jd u r"| j| n2| j | j| W d n1 sJ0 Y d S r, )rU r r r rA rb r) r) r* rQ q s zSimpleQueue.putN)r r r r+ rd r^ r/ r2 rY rQ classmethodtypes GenericAlias__class_getitem__r) r) r) r* r Q s r ) __all__r r r7 r9 rS r rx r queuer r _multiprocessing r r reductionForkingPicklerrU utilr r r r r objectr r~ r r r) r) r) r* <module> s& z +