h SSKrSSKrSSKrSSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS KJ r SS KJ r SS K Jr SS KJr /S Qr\R$SS:Hr\(aSrOSr\ R*"\R\5 SVs/sHn\"\"0U5"55PM snr\S\LaSr\Hr\ R*"\\5 M "SS5rS04SjrSr"SS\5r Sr!Sr""SS5r#"SS5r$\RJ\RL4\RN\RP4S .r)"S!S"5r*"S#S$\+5r,"S%S&5r-S'r.04S(jr/S_S)jr0"S*S+5r1"S,S-5r2S`S.jr3"S/S0\-5r4"S1S2\-5r5"S3S4\55r6"S5S6\-5r7"S7S8\-5r8"S9S:\-5r9"S;S<\-5r:S=r;\(d\;S>- r;\/"S?\;5r<"S@SA\<5r=\/"SBSC5r>SDr?\(d\?SE- r?\/"SF\?5r@\/"SGSH5rASISISISJSJSK.\AlB"SLSG\A5rC"SMSN\*5rD\DR+SO\5 \DR+SP\5 \DR+SQ\R\75 \DR+SR\R\55 \DR+SS\R\55 \DR+ST\R\55 \DR+SU\R\55 \DR+SV\R\65 \K"\SW5(a\DR+SW\R\85 \DR+SX\R\C5 \DR+SY\\=5 \DR+SZ\N\>5 \DR+S-\2\:5 \DR+S[\3\@5 \DR+S+\1\95 \DR+SJ\4S\S]9 \DR+SIS\S^9 gs snf)aN) format_exc) connection)context)pool)process) reduction)util) get_context)Queue) monotonic) BaseManager SyncManager BaseProxyTokencZ[RURUR544$N)arraytypecodetobytesas 9D:\TimeStamps\venv\Lib\site-packages\billiard/managers.py reduce_arrayr*s {{QZZ555cZ[RURUR544$r)rrtostringrs rrr-s {{QZZ666r)itemskeysvaluesc&[[U544$r)listobjs rrebuild_as_listr&5sd3i]""rc4\rSrSrSrSrSrSrSrSr Sr g ) r?z+ Type to uniquely identify a shared object typeidaddressidc.XUsUlUlUlgrr))selfr*r+r,s r__init__Token.__init__Es06,dlDGrcHURURUR4$rr)r.s r __getstate__Token.__getstate__Hs T\\47733rc.UuUlUlUlgrr))r.states r __setstate__Token.__setstate__Ks/4,dlDGrcURR<SUR<SUR<SUR<S3$)Nz(typeid=z , address=z, id=)) __class____name__r*r+r,r2s r__repr__Token.__repr__Ns- ^^ $ $dkk4<<J Jr)r+r,r*N) r< __module__ __qualname____firstlineno____doc__ __slots__r/r3r7r=__static_attributes__rrrr?s$,IE45JrrrEcrURXX445 UR5upVUS:XaU$[XV5e)zD Send a message to manager using connection `c` and return response #RETURN)sendrecvconvert_to_error)cr, methodnameargskwdskindresults rdispatchrQWs:FFBD '(668LD y 4 ((rcUS:XaU$US:Xa[U5[Lde[U5$US:Xa"[U5[Lde[SU-5$[S5$)N#ERROR #TRACEBACK#UNSERIALIZABLEzUnserializable message: %s zUnrecognized message type)typestr RemoteError ValueError)rOrPs rrJrJbsl x  F|s"""6"" " "F|s"""9FBCC566rc\rSrSrSrSrg)rXoc>S[URS5-S-$)NzM --------------------------------------------------------------------------- rzK---------------------------------------------------------------------------)rWrMr2s r__str__RemoteError.__str__qs&TYYq\)::XEFrrEN)r<r?r@rAr]rDrErrrXrXosGrrXc/n[U5H1n[X5n[U5(dM URU5 M3 U$)z, Return a list of names of methods of `obj` )dirgetattrcallableappend)r%tempnamefuncs r all_methodsrgys= DCs! D>> KK  KrcX[U5Vs/sHoSS:wdM UPM sn$s snf)zH Return a list of names of methods of `obj` which do not start with '_' r_)rg)r%res rpublic_methodsrjs+)- @-TaCD- @@ @s ''c\rSrSrSr/SQrSrSrSrSr Sr S r S r S r \ \ \ S .rS rSrSrSrSrSrSrSrSrSrg)ServerzE Server class which runs in a process controlled by a manager object ) shutdowncreateaccept_connection get_methods debug_infonumber_of_objectsdummyincrefdecrefc,[U[5(deXl[R"U5Ul[ UupVU"USS9UlURRUlSS0Ul 0Ul [R"5Ul g)N)r+backlog0NrE) isinstancebytesregistryrAuthenticationStringauthkeylistener_clientlistenerr+ id_to_objid_to_refcount threadingRLockmutex)r.r~r+r serializerListenerClients rr/Server.__init__s|'5)))) 33G< *:6!"= }},, z* __& rc[R"5UlU[R"5l[R "URS9nSUlUR5 URR5(d<URRS5 URR5(dM<[R[R :waH["R$"S5 [R [l[R&[l[R*"S5 g![[4a Nf=f![R[R :waH["R$"S5 [R [l[R&[l[R*"S5 f=f)z Run the server forever )targetTrzresetting stdout, stderrrN)rEvent stop_eventrcurrent_process_manager_serverThreadaccepterdaemonstartis_setwaitKeyboardInterrupt SystemExitsysstdout __stdout__r debug __stderr__stderrexit)r.rs r serve_foreverServer.serve_forevers&$//+48!1  ''t}}=H"HO NN  //0022OO((+//0022 zzS^^+ 56 ^^  ^^ HHQK&z2  zzS^^+ 56 ^^  ^^ HHQKs+5E,AEEEEEBG cURR5n[R"UR U4S9nSUlUR5 MT![a Mbf=f)NTrrM)racceptOSErrorrrhandle_requestrr)r.rKts rrServer.acceptersa MM((*  (;(;1%HAAH GGI  sA A$#A$cS=n=p4[R"XR5 [R"XR5 UR 5nUupRpgX R ;d SU-5e[ X5nU"U/UQ70UD6nSU4n URU 5 UR5 g![a S[54n N;f=f![a S[54n NWf=f![a|n URS[545 O![a Of=f[R"SU 5 [R"SU5 [R"SU 5 Sn A NSn A ff=f)z Handle a new connection Nz%r unrecognizedrGrTzFailure to send message: %rz ... request was %r ... exception was %r) rdeliver_challengeranswer_challengerIpublicra ExceptionrrHr infoclose) r.rKfuncnamerPrequestignorerMrNrfmsgexcs rrServer.handle_requestsX'+**6 *  ( (LL 9  ' '<< 8ffhG+2 (Fd{{* H,=,H H*4*D *a/$/$/!&) 4 FF3K   3#Z\2 3  /.C / 4  jl34   II3S 9 II+W 5 II-s 3 3 4s[A9C B4C,4C  C C)(C), E27DE- D E-D  AE--E2c[R"S[R"5R5 UR nUR nURnURR5(dS=pVU"5nUuppXHupkn X[;a [SU<S[U5<SU <35e[Xe5n U "U 0U D6nU =(a U RUS5nU(a2URXU5unn[XR U5nSUU44nOSU4nU"W5 URR5(dMgg!["anSU4nSnAN@SnAff=f![aS WcS [%54nNcUR&UnU"XWW/W Q70W D6nSU4nN!["a S [%54nNf=f[(aM [R"S [R"5R5 [*R,"S 5 N["a S [%54nGNf=f!["a U"S [/W545 GN+f=f!["an[R0"S [R"5R5 [R0"SW5 [R0"SU5 UR35 [*R,"S5 SnAGNSnAff=f)zA Handle requests from the proxies in a particular process/thread z$starting server thread to service %rNzmethod z of z object is not in exposed=#PROXYrGrSrTz$got EOF -- exiting thread serving %rrrUzexception in thread serving %rz ... message was %rrr)r rrcurrent_threadrerIrHrrrAttributeErrorrVragetrorr+rrfallback_mappingEOFErrorrrreprrr)r.connrIrHrrLr%ridentrMrNexposed gettypeidfunctionresr*ridentrexposedtokenrr fallback_funcrPs r serve_clientServer.serve_clients 9++-22 4yyyyNN //((**. 3#'' &07-4*3*:'i,(&S 7< #33 /"D1D1C'J9==T+JF+/;;tS+I( %fllF C'(E):;(#.. 9Ii//((**$!*#S/C*" ;%'6C;(,(=(=j(I !. s"59"=A" )&1$;+Z\:;  A$335::<  3#Z\2 3 !9+T#Y789  :#22499; /5 137   s9AE)EAE)E)#H6 E&E!E)!E&&E))H3!F((G>H3GAH3H32H36IIII K7$BK22K7cU$rrEr.rrr%s rfallback_getvalueServer.fallback_getvalue1s rc[U5$rrWrs r fallback_strServer.fallback_str4s 3xrc[U5$r)rrs r fallback_reprServer.fallback_repr7s Cyr)r]r= #GETVALUEcgrrEr.rKs rrt Server.dummy@s rc UR /n[URR55nUR 5 UHQnUS:wdM UR SU<SUR U<S[URUS5SS<35 MS SRU5sSSS5 $!,(df  g=f) z? Return some info --- useful to spot problems with refcounting rzz z: refcount=z rNK ) rr#rr sortrcrrWjoin)r.rKrPr rs rrrServer.debug_infoCsZZF++-.D IIKC<MM#($*=*=e*D#&t~~e'>"Q&&rc[R"S5 URS5 UR R 5 g! SSKnUR 5 N3=f!UR R 5 f=f)z Shutdown this process z!Manager received shutdown messagerGNrN)r rrH traceback print_excrset)r.rKrs rrnServer.shutdownXsZ " JJ: ; FF$ % OO   !  "     ! OO   !s'AAAA;c6UR URUupVpxUc[U5S:XaU(aeUSn OU"U0UD6n Uc [U 5nUb+[ U5[ Lde[ U5[ U5-nS[U 5-n [R"SX*5 U [U5U4URU 'XR;aSURU 'URX5 U [U54sSSS5 $!,(df  g=f)z. Create a new shared object and return its id Nrrz%xz&%r callable returned object with id %r)rr~rrjrVdictr#r,r rrrrrutuple) r.rKr*rMrNrbrmethod_to_typeid proxytyper%rs rro Server.createes ZZ f% ;H/4yA~d221g--(-+,-555w-$/?*@@2c7NE JJ? O%(#g,8H$IDNN5 !///-.##E* KK !%.(;ZZs C3D  DcL[URURS5$)z< Return the methods of the shared object indicated by token r)rrr,)r.rKrs rrqServer.get_methodss!T^^EHH-a011rc|U[R"5lURS5 UR U5 g)z- Spawn a new thread to serve this connection rN)rrrerHr)r.rKres rrpServer.accept_connections0+/   "'  ! !rc~UR URU==S- ss'SSS5 g!,(df  g=f)Nr)rrr.rKrs rru Server.increfs) ZZ    &! + &ZZs. <c0UR URUS:deURU==S-ss'URUS:Xa1URU URU [R"SU5 SSS5 g!,(df  g=f)Nrrzdisposing of obj with id %r)rrrr rrs rrv Server.decrefs} ZZ&&u-2 22    &! + &""5)Q.NN5)4+>+>u+E 8%@ ZZs A1B B)r+rrrrrr~rN)r<r?r@rArBrr/rrrrrrrrrtrrrsrnrorqrprurvrDrErrrlrls|NF ', DHT !&   %' "!)F2 ,Arrlc&\rSrSrS/rSrSrSrSrg)StateivaluerrrEN) r<r?r@rArCINITIALSTARTEDSHUTDOWNrDrErrrrs IGGHrr)pickle xmlrpclibc\rSrSrSr0r\rSSjrSr Sr Sr SSjr \ SS j5rS rSS jrS rS rSrSr\S5r\"S5r\ SSj5rSrg)riz Base class for managers NcNUc[R"5RnXl[R"U5Ul[ 5Ul[ RURl X0l [UuUl Ul U=(d [5Ulgr)rrr_addressr_authkeyr_staterr _serializerr _Listener_Clientr _ctx)r.r+rrctxs rr/BaseManager.__init__sr ?--/77G 44W= g !MM %'6z'B$ (;= rcr[U5RURURUR44$r)rV from_addressrrrr2s r __reduce__BaseManager.__reduce__s3T '' t/?/?@B BrcURR[R:Xde[ UR UR URUR5$)zH Return server object with serve_forever() method and address attribute ) rrrrrl _registryrrrr2s r get_serverBaseManager.get_serversH{{  EMM111dnndmmmmT%5%57 7rc[URupU"URURS9n[ USS5 [ R URlg)z. Connect manager object to the server process rNrt) rrrrrQrrrr)r.rrrs rconnectBaseManager.connectsG+4+;+;<dmmT]];tW%!MM rc URR[R:XdeUb[ U5(d [ S5e[ R"SS9up4URR[U5RURURURURXAU4S9UlSR#SUR R$55n[U5R&S-U-UR lUR R+5 UR-5 UR/5Ul UR-5 [R0URl[2R4"U[U5R6UR URURURUR84S S 9Ulg) z0 Spawn a server process for this manager object Nzinitializer must be a callableF)duplexr:c38# UHn[U5v M g7frr).0is r $BaseManager.start..sA)@AQ)@s-rrM exitpriority)rrrrrb TypeErrorrPiper ProcessrV _run_serverrrrr_processr _identityr<rerrrIrr Finalize_finalize_managerr rn)r. initializerinitargsreaderwriterrs rrBaseManager.startsh{{  EMM111  "8K+@+@<= =$6 )):))..$--""FC*  A)@)@AA!$Z0036>       "MM  $t*..-- ++t||-   rcUbU"U6 URXX45nURUR5 UR5 [R "SUR5 UR 5 g)z0 Create a server, report its address and run it Nzmanager serving at %r)_ServerrHr+rr rr) clsr~r+rrr/r,r-servers rr'BaseManager._run_servers`  "  "XD  FNN#  )6>>:rcNURR[R:XdS5eUR UR UR S9n[USSU4U-U5upVUR5 [XR U5U4$!UR5 f=f)z@ Create a new shared object; return the token and exposed tuple zserver not yet startedrNro) rrrrr rrrQrr)r.r*rMrNrr,rs r_createBaseManager._creates{{  EMM1K3KK1||DMM4==|A "4x$*9t#3T;KB JJLV]]B/88 JJLs BB$cURbCURRU5 URR5(dSUlggg)z3 Join the manager process (if it has been spawned) N)r(ris_aliver.timeouts rrBaseManager.join(sD == $ MM  w '==))++ $ , %rcURURURS9n[USS5UR 5 $!UR 5 f=f)zC Return some info about the servers shared objects and connections rNrrr rrrQrr.rs r _debug_infoBaseManager._debug_info1sB||DMM4==|A D$ 5 JJLDJJL AAcURURURS9n[USS5UR 5 $!UR 5 f=f)z% Return the number of shared objects rNrsr?r@s r_number_of_objectsBaseManager._number_of_objects;sC||DMM4==|A D$(;< JJLDJJLrCcURR[R:XaUR 5 URR[R :XdeU$r)rrrrrrr2s r __enter__BaseManager.__enter__EsB ;;   - JJL{{  EMM111 rc$UR5 gr)rnr.exc_typeexc_valexc_tbs r__exit__BaseManager.__exit__Ks  rcUR"5(a[R"S5 U"XS9n[USS5 UR 5 UR "SS9 UR"5(a[R"S5 [US5(ac[R"S 5 UR"5 UR "S S9 UR"5(a[R"S 5 [RUl [RU g!UR 5 f=f![ a Nf=f![a gf=f) zA Shutdown the manager process; will be registered as a finalizer z#sending shutdown message to managerrNrng?)r<zmanager still alive terminatez'trying to `terminate()` manager processg?z#manager still alive after terminate)r:r rrQrrrhasattrrRrrrr_address_to_localKeyError)rr+rr6r rs rr+BaseManager._finalize_managerNs      II; < w8!T44JJL LL %!! /07K00IIGH%%'LL-'')) "GHnn  ++G4!JJL      s:D? D*D?E*D<<D?? E  E  EEcUR$r)rr2s rBaseManager.nsDMMrc^^SUR;aURR5UlTc[mU=(d [ TSS5nU=(d [ TSS5nU(aQUR 5H=upx[ U5[Ld SU-5e[ U5[LaM5SU-5e X$UT4URT'U(aUU4Sjn TU l[UTU 5 gg)z) Register a typeid with the manager type rN _exposed__method_to_typeid_z%r is not a stringc>[R"ST5 UR"T/UQ70UD6up4T"X0RUURUS9nUR UR URS9n[USSUR45 U$)Nz)requesting creation of a shared %r objectmanagerrrrrv) r rr7rrr r+rQr,) r.rMrNrexpproxyrrr*s rrd"BaseManager.register..temps FO!\\&@4@4@ !++T MM3||EMM4==|ItX{; r) __dict__rcopy AutoProxyrarrVrWr<setattr) r3r*rbrrr create_methodkeyrrds ` ` rregisterBaseManager.registerps cll *MM..0CM  !IBWY TB  ; I3T :  .446 CyC'C)=)CC'E{c)G+?%+GG)7 /!  f  #DM C & r) r rrrr r(rrrn)NNrNr{r)NNNNT)r<r?r@rArBrrlr2r/rrrr classmethodr'r7rrArErHrO staticmethodr+propertyr+rirDrErrrrsIG>F )B7*" H/1& 9% >12GEI6:''''rrc \rSrSrSrSrSrg)ProcessLocalSetic4[R"US5 g)Nc"UR5$r)clearr$s rrX*ProcessLocalSet.__init__..s 399;r)r register_after_forkr2s rr/ProcessLocalSet.__init__s   '>?rc[U5S4$r{)rVr2s rrProcessLocalSet.__reduce__sDz2~rrEN)r<r?r@rAr/rrDrErrroros @rroc\rSrSrSr0r\R"5rSSjr Sr S04Sjr Sr S r \S 5rS rS rS rSrSrSrg)riz& A base for proxies of shared objects Nc [R [RRURS5nUc<[ R "5[54nU[RUR'SSS5 WSUlUSUl Xl URRUl X0l X l[USUlUb["R$"U5UlOMURbURR&UlO$["R("5R*UlU(aUR-5 [ R."U[R05 g!,(df  GN =f)Nrr)r_mutexrTrr+r ForkAwareLocalro_tls_idset_tokenr,_id_managerrrr rrrrr_increfrt _after_fork)r.rrr_rrru tls_idsets rr/BaseProxy.__init__s   !3377 tLI  //1?3DD =F ++EMM: aL  l  ;;>> %&z215  #88ADM ]] & MM22DM#335==DM  LLN   y'<'<=? s A*E>> F c[R"S5 [R"5Rn[ R "5RS:wa%US[ R "5R-- nURURRURS9n[USSU45 X Rl g)Nzmaking connection to manager MainThread|rrp)r rrrrerrr r~r+rrQr|r)r.rers r_connectBaseProxy._connects 12&&(--  # # % * *l : C)224999 9D||DKK//|Gt04':# rrEcURRnURURXU45 UR5upVUS:XaU$US:XaUupxURRURSn URR UlU "XR"URUR$US9n UR'UR UR$S9n[)USSUR*45 U $[-XV5e![a^ [R"S[ R "5R5 UR5 URRnGN[f=f) zG Try to call a method of the referrent and return a copy of the result z#thread %r does not own a connectionrGrr^rNrv)r|rrr rrrrerrHrrIrrr*r~r+rrr rQr,rJ) r.rLrMrNrrOrPrrrras r _callmethodBaseProxy._callmethods2 (99''D 488Zt45yy{  9 M X #NG // =bAI KK//EM'' wE<< t}}<ED T4EHH; 7Lt,,- ( JJ< //166 8 MMO99''D  (sD A$E43E4c$URS5$)z) Get a copy of the value of the referent rrr2s r _getvalueBaseProxy._getvalues ,,rc HURURRURS9n[ USSUR 45 [ R"SURR5 URRUR 5 UR=(a URRn[ R"U[RURURUUR URUR4SS9Ulg)Nrruz INCREF %r r")r r~r+rrQrr rr,r}addrrr*r_decrefr|_close)r.rr6s rrBaseProxy._increfs||DKK//|GtX{3 ; / ! 6$--"6"6mm )##++t}}e))T[[$,,8   rcURUR5 UbUR[R:XaM[ R "SUR5 U"URUS9n[USSUR45 O![ R "SUR5 U(dc[US5(aQ[ R "S[R"5R5 URR5 U?ggg![a!n[ R "SU5 SnANSnAff=f)Nz DECREF %rrrvz... decref failed %sz%DECREF %r -- manager already shutdownrz-thread %r has no more proxies so closing conn)discardr,rrrr rr+rQrrSrrrerr)rrr6tlsidsetr rrs rrBaseProxy._decrefs ehh =EKK5==8 8 ;1u}}g>tX{; JJ> Il33 JJF //166 8 NN " 4u 8 1377 8sA D E D<<EcSUlUR5 g![a!n[R"SU5 SnAgSnAff=f)Nzincref failed: %s)rrrr r)r.rs rrBaseProxy._after_fork,s9  0 LLN 0 II)3 / / 0s AAAc,0n[R"5bURUS'[USS5(a3URUS'[ [ URURU44$[ [U5URURU44$)Nr_isautoFr) rget_spawning_popenrrar[ RebuildProxyrer~rrVr.rNs rrBaseProxy.__reduce__4s  % % ' 3"mmDO 4E * *"nnDO  T-=-=tDF F!$Zd.>.>EG Grc"UR5$r)r)r.memos r __deepcopy__BaseProxy.__deepcopy__As~~rcrS[U5RURR[ U54-$)Nz<%s object, typeid %r at %#x>)rVr<r~r*r,r2s rr=BaseProxy.__repr__Ds3.T ##T[[%7%7DBC CrchURS5$![a [U5SSS-s$f=f)zF Return representation of the referent (or a fall-back if that fails) r=Nrz; '__str__()' failed>)rrrr2s rr]BaseProxy.__str__Hs= =##J/ / =:cr?%<< < =s 11) r rrrr}rrr|r~NNNT)r<r?r@rArBrTr ForkAwareThreadLockrzr/rrrrrlrrrrr=r]rDrErrrrss  % % 'F2648!>F$,.B-<-  00 G C=rrcN[[R"5SS5nU(a6URUR:XaURUR S$UR SS5=(a% [[R"5SS5(+nU"X4SU0UD6$)zv Function used for unpickling proxy objects. If possible the shared object is returned, or otherwise a proxy for it. rNrruT _inheritingF)rarrr+rr,pop)rfrrrNr4rus rrrVs W,,.0A4 HF &..EMM1)!,, HHXt $ I//1=%H H E=f===rc[U5nX U4$![a Of=f0nUHn[SU<SU<S3U5 M [U[4U5nXlXRX4'U$)z; Return an proxy type whose methods are given by `exposed` zdef z7(self, *args, **kwds): return self._callmethod(z , args, kwds))rrUexecrVrr[)rer_cachedicmeth ProxyTypes r MakeProxyTyperlsGnG Wo&&     C 6:DBCF HTI<-I!'D? s   ch[USnUc1U"URUS9n[USSU45nUR5 UcUb URnUc[ R "5Rn[SUR-U5nU"XX#US9n SU l U $!UR5 f=f)z" Return an auto-proxy for `token` rNrrqz AutoProxy[%s])r_rruT) rr+rQrrrrrrr*r) rrr_rrrur rrras rreres j)!,Gu}}g6 tT=5(CG JJL7.""))+33o >22DIIdODDrrEN)r<r?r@rAr/r=rDrErrrrs #ErrcB\rSrSrSSjrSrSrSr\"\\5r Sr g) ValueicXlX lgr _typecode_value)r.rrlocks rr/Value.__init__s ! rcUR$rrr2s rr Value.gets {{rcXlgrrr.rs rr Value.sets rcl[U5R<SUR<SUR<S3$)Nrrr:)rVr<rrr2s rr=Value.__repr__s&#Dz22#~~t{{< I5))CCEEBBrr"c*\rSrSrSrSrSrSrSrg)NamespaceProxyi;)r# __setattr__ __delattr__c~USS:Xa[RX5$[RUS5nU"SU45$)Nrrirr#)objectr#r.rh callmethods r __getattr__NamespaceProxy.__getattr__>s@ q6S=**45 5,,T=A ,sf55rcUSS:Xa[RXU5$[RUS5nU"SX45$)Nrrirr7)r:r7r#)r.rhrr<s rr7NamespaceProxy.__setattr__DsA q6S=%%d7 7,,T=A -#66rc~USS:Xa[RX5$[RUS5nU"SU45$)Nrrirr8)r:r8r#r;s rr8NamespaceProxy.__delattr__Js? q6S=%%d0 0,,T=A -#00rrEN) r<r?r@rAr[r=r7r8rDrErrr6r6;sBI6 7 1rr6c6\rSrSrSrSrSr\"\\5rSr g) ValueProxyiQ)rrc$URS5$)Nrrr2s rrValueProxy.getTrrc(URSU45$rrrs rrValueProxy.setWsx00rrEN) r<r?r@rAr[rrrmrrDrErrrDrDQsI'1 S# ErrD)__add__ __contains__ __delitem__ __getitem____len____mul__ __reversed____rmul__ __setitem__rccountextendindexinsertrremovereverser__imul__) __getslice__ __setslice__ __delslice__ BaseListProxyc \rSrSrSrSrSrg) ListProxyigc,URSU45 U$)NrSrrs r__iadd__ListProxy.__iadd__is E8, rc,URSU45 U$)NrXrrs rrXListProxy.__imul__ms eX. rrEN)r<r?r@rAr`rXrDrErrr^r^gs rr^ DictProxy)rJrKrLrMrQrrrdrhas_keyrr rpopitem setdefaultrr!)rMrLrQ)rYrZ ArrayProxy PoolProxy) apply apply_asyncrimapimap_unorderedrmap map_asyncstarmap starmap_asyncrR AsyncResultIterator)rkrorqrlrmc \rSrSrSrSrSrg)riicU$rrEr2s rrHPoolProxy.__enter__rrc$UR5 gr)rR)r.exc_infos rrOPoolProxy.__exit__s  rrEN)r<r?r@rArHrOrDrErrriris rc\rSrSrSrSrg)ria  Subclass of `BaseManager` which supports a number of shared object types. The types registered are those intended for the synchronization of threads, plus `dict`, `list` and `Namespace`. The `billiard.Manager()` function creates started instances of this class. rEN)r<r?r@rArBrDrErrrrsrrr JoinableQueuerLockr SemaphoreBoundedSemaphore ConditionBarrierPoolr#rrF)rrg)rgrr)Orrrrrrrrrr r r queuer timer __all__rPY3rrirVra view_typesr#r& view_typerrQrJrrXrgrjrlrrr XmlListener XmlClientrrrrorrrrerrrrrrrr"r6rD_ListProxy_Attributesr\r^rd_ArrayProxy_Attributesrh BasePoolProxyr\rirrr|rr}r~rrSrrr)res0rrs   > qQ67 5;; -675$72t$&'57  a=# 9o6 JJ0&(b) 7G)G APAPAn""J$5$56((**>*>?]']'Hcc=c=T>,)+,8<#'< E E$+/I/2+I+"]> 4 4 B9B21Y1,  MMo/DE   +(   >> <)? @ k, !"  $   +  We$ _e, Wiooz: VY^^]; Wioo}= [)"5"5}E ')C)C"$ [)"5"5~F 9i  I$5$5|D VTYY 2 VT9- VT9- WeZ0 WeZ0 [)^< Z=N ]%8S$7sO