ݲk^c@`s5ddlmZmZmZmZddlmZddlmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZmZddlmZmZdd lZejdd krdd lmZndd lmZdd l Z dd l!Z!dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'dd l(Z(ddl)m*Z*m+Z+m,Z,m-Z-dd l.Z.ddl/m0Z0m1Z1m2Z2ddl3m4Z4m3Z3ddl5m6Z6m7Z7m8Z8m9Z9ddl:m;Z;ddl<m=Z=d dl>m?Z?d dl@mAZAd dlBmCZCd dlDmEZEe'eFZGde#fdYZHeCe(jIjJdr{eHdZKn e#dZKd dZLdeMfd YZNd!eNfd"YZOeOZPd#efd$YZQed d d d%ZSed d d&ZTed d'ZUeeQjVeQjVd(ZWed)ZXed*ZYed+ZZed d,Z[e&d e\d d-Z]d.Z^d/eMfd0YZ_d1eMfd2YZ`d3e fd4YZad5e fd6YZbe Z d7Zcd8eNfd9YZdd:ZeeFd;kr1eend S(<i(tabsolute_importtdivisiontprint_functiontunicode_literals(t defaultdict(tProcessPoolExecutortThreadPoolExecutortExecutortFuturet_baset as_completed(t _WorkItem(tcontextmanager(tEnum(tEPIPEt ESHUTDOWN(tpartialtwrapsNi(tBytesIO(tcycle(tCRITICALt FormattertNOTSETt StreamHandlertWARNt getLogger(tdirnametisdirtisfiletjoin(tEventtThreadtLock(tsleepttimei(tStringIOt iteritemston_wintencode_environment(tNULL(texpand(t memoizemethod(t NullHandler(tboolify(ttqdmtDeltaSecondsFormattercB`s&eZdZdddZdZRS(uw Logging formatter with additional attributes for run time logging. Attributes: `delta_secs`: Elapsed seconds since last log/format call (or creation of logger). `relative_created_secs`: Like `relativeCreated`, time relative to the initialization of the `logging` module but conveniently scaled to seconds as a `float` value. cC`s/t|_tt|jd|d|dS(Ntfmttdatefmt(R"t prev_timetsuperR-t__init__(tselfR.R/((s.lib/python2.7/site-packages/conda/common/io.pyR21s cC`sZt}|j}t|j||_|||_|jd|_tt|j|S(Ni( R"R0tmaxt delta_secstrelativeCreatedtrelative_created_secsR1R-tformat(R3trecordtnowR0((s.lib/python2.7/site-packages/conda/common/io.pyR85s    N(t__name__t __module__t__doc__tNoneR2R8(((s.lib/python2.7/site-packages/conda/common/io.pyR-&s uCONDA_TIMED_LOGGINGum%(relative_created_secs) 7.2f %(delta_secs) 7.2f %(levelname)s %(name)s:%(funcName)s(%(lineno)d): %(message)su<%(levelname)s %(name)s:%(funcName)s(%(lineno)d): %(message)sc`sdjfd|DS(Nuc3`s+|]!}dddt|VqdS(u u u- N(tstr(t.0tx(tindent(s.lib/python2.7/site-packages/conda/common/io.pys Js(R(titerableRB((RBs.lib/python2.7/site-packages/conda/common/io.pytdashlistIstContextDecoratorcB`seZdZdZRS(uyBase class for a context manager class (implementing __enter__() and __exit__()) that also makes it a decorator. c`s"tfd}|S(Nc`s||SWdQXdS(N((targstkwds(tfR3(s.lib/python2.7/site-packages/conda/common/io.pyt decoratedUs(R(R3RHRI((RHR3s.lib/python2.7/site-packages/conda/common/io.pyt__call__Ts(R;R<R=RJ(((s.lib/python2.7/site-packages/conda/common/io.pyREMstSwallowBrokenPipecB`seZdZdZRS(cC`sdS(N((R3((s.lib/python2.7/site-packages/conda/common/io.pyt __enter__`scC`sD|r@t|tr@t|ddr@|jttfkr@tSdS(Nuerrno(t isinstancetEnvironmentErrortgetattrR>terrnoRRtTrue(R3texc_typetexc_valtexc_tb((s.lib/python2.7/site-packages/conda/common/io.pyt__exit__cs (R;R<RLRU(((s.lib/python2.7/site-packages/conda/common/io.pyRK\s t CaptureTargetcB`seZdZdZdZRS(uConstants used for contextmanager captured. Used similarly like the constants PIPE, STDOUT for stdlib's subprocess.Popen. ii(R;R<R=tSTRINGtSTDOUT(((s.lib/python2.7/site-packages/conda/common/io.pyRVnscc`s|dkri}nt|}i}x@t|D]2\}}tjj|t||<|tj|R&R$tostenvirontgetR'RQtFalse(tvar_maptcallbacktstack_callbackt new_var_mapt saved_varstnametvalue((s.lib/python2.7/site-packages/conda/common/io.pytenv_varsws*         cc`s7i||6}t|d|d| }|VWdQXdS(NR^R_(Rd(RbRcR^R_tdtes((s.lib/python2.7/site-packages/conda/common/io.pytenv_vars cc`s!td| }|VWdQXdS(NR^(Rd(R^Rf((s.lib/python2.7/site-packages/conda/common/io.pytenv_unmodifiedsc c`sd}dtfdY}tjtj}}|tjkrtt}|j|_t |||_|t_n|}|dk r|t_n|tjkrt}|j|_t |||_|t_n=|tj kr|t_}n|}|dk r|t_n|}t j dz |VWd|tjkrT|j|_n ||_|tjkr~|j|_n$|tj krd|_n ||_||t_t_t j dXdS(uCapture outputs of sys.stdout and sys.stderr. If stdout is STRING, capture sys.stdout as a string, if stdout is None, do not capture sys.stdout, leaving it untouched, otherwise redirect sys.stdout to the file-like object given by stdout. Behave correspondingly for stderr with the exception that if stderr is STDOUT, redirect sys.stderr to stdout target and set stderr attribute of yielded object to None. Args: stdout: capture target for sys.stdout, one of STRING, None, or file-like object stderr: capture target for sys.stderr, one of STRING, STDOUT, None, or file-like object Yields: CapturedText: has attributes stdout, stderr which are either strings, None or the corresponding file-like function argument. cS`st|dr'd|jkr't}nMtjddkrRt|trRt}n"tjddkrnt}nt}t||st|dr|j d}|j |qt|dr|j d}|j |qn |j |dS( Numodeubiiiudecodeuutf-8uencode( thasattrtmodetbytestsyst version_infoRMRtunicodeR?tdecodet old_writetencode(R3tto_writetwantedtdecodedtb((s.lib/python2.7/site-packages/conda/common/io.pyt write_wrappers "  t CapturedTextcB`seZRS((R;R<(((s.lib/python2.7/site-packages/conda/common/io.pyRwsuovertaking stderr and stdoutNustderr and stdout yielding back(tobjectRltstdouttstderrRVRWR#twriteRpRR>RXtlogtinfotgetvalue( RyRzRvRwt saved_stdoutt saved_stderrtoutfileterrfiletc((s.lib/python2.7/site-packages/conda/common/io.pytcapturedsF"                 cc`s,tj}|t_z dVWd|t_XdS(N(Rltargv(t args_listt saved_args((s.lib/python2.7/site-packages/conda/common/io.pyRs    cc`s%tjz dVWdtjXdS(N(tloggingt _acquireLockt _releaseLock(((s.lib/python2.7/site-packages/conda/common/io.pyt _logger_locks  c c`st|}|j|j|j}}}t}t6|j||jtdt t |_|_WdQXz dVWdt.|j ||||_|_||_WdQXXdS(Ni( Rtleveltdisabledt propagateR*Rt addHandlertsetLevelRRQR\t removeHandler(t logger_nametlogrt_lvlt_dsbldt_prpgtt null_handler((s.lib/python2.7/site-packages/conda/common/io.pytdisable_loggers       c c`st|}|j|j|j|jf\}}}}ttj}d|_|j ||j t t I|j |gt t |_|_|_|j||j |WdQXz dVWdt +||||_|_|_||_WdQXXdS(Nustderr(RthandlersRRRRRlRzRbRt setFormattert _FORMATTERRR\R(RRRt_hndlrsRRRthandler((s.lib/python2.7/site-packages/conda/common/io.pytstderr_log_level-s  *        cC`st|}td|jDd}ttj}d|_|jt |j |p\t t >|r|j |n|j||j|||_WdQXdS(Ncs`s$|]}|jdkr|VqdS(ustderrN(Rb(R@R((s.lib/python2.7/site-packages/conda/common/io.pys Esustderr(RtnextRR>RRlRzRbRRRRRRRR(RRRt formatterRtold_stderr_handlertnew_stderr_handler((s.lib/python2.7/site-packages/conda/common/io.pytattach_stderr_handlerBs       c`s|jdd}trAy|||SWqtk r=|SXndtfdYfd}tjtj|tj|y$|||}tjd|SWntfk r|SXdS(u[Enforce a maximum time for a callable to complete. Not yet implemented on Windows. udefault_returntTimeoutExceptioncB`seZRS((R;R<(((s.lib/python2.7/site-packages/conda/common/io.pyRdsc`s dS(N((tsignumtframe(R(s.lib/python2.7/site-packages/conda/common/io.pyt interruptgsiN(tpopR>R%tKeyboardInterruptt ExceptiontsignaltSIGALRMtalarm(t timeout_secstfuncRFtkwargstdefault_returnRtret((Rs.lib/python2.7/site-packages/conda/common/io.pyttimeoutWs    tSpinnercB`s_eZdZedZeeddZdZdZ dZ e dZ dZ RS( u Args: message (str): A message to prefix the spinner with. The string ': ' is automatically appended. enabled (bool): If False, usage is a no-op. json (bool): If True, will not output non-json to stdout. u/-\|ufailed cC`s||_||_||_t|_td|j|_tt |j d|_ t j |_|o| ot|jdo|jj|_||_dS(Nttargetiuisatty(tmessagetenabledtjsonRt _stop_runningRt_start_spinningt_spinner_threadtlenRt spinner_cyclet_indicator_lengthRlRytfhRitisattyt show_spint fail_message(R3RRRR((s.lib/python2.7/site-packages/conda/common/io.pyR2s     1cC`sF|jr|jjn)|jsB|jjd|jjndS(Nu...working... (RRtstartRRR{tflush(R3((s.lib/python2.7/site-packages/conda/common/io.pyRs   cC`s3|jr/|jj|jjt|_ndS(N(RRtsetRRR\(R3((s.lib/python2.7/site-packages/conda/common/io.pytstops   cC`syex^|jjsc|jjt|jd|jjtd|jjd|jqWWn8t k r}|j t t fkr|j qnXdS(Nu g?u(Rtis_setRR{RRRR!RRNRPRRR(R3te((s.lib/python2.7/site-packages/conda/common/io.pyRs   cC`s>|js0tjjd|jtjjn|jdS(Nu%s: (RRlRyR{RRR(R3((s.lib/python2.7/site-packages/conda/common/io.pyRLs cC`sf|j|jsbtD|s&|r<tjj|jntjjdtjjWdQXndS(Nudone (RRtswallow_broken_pipeRlRyR{RR(R3RRRSRT((s.lib/python2.7/site-packages/conda/common/io.pyRUs   (R;R<R=RRRQR\R2RRRRRLRU(((s.lib/python2.7/site-packages/conda/common/io.pyRus     t ProgressBarcB`s8eZeedZdZdZedZRS(c C`s||_||_||_|r$nz|rd}y1td|d|dtdddtj|_Wqtk r}|j t t fkrt |_qqXndS( u Args: description (str): The name of the progress bar, shown on left side of output. enabled (bool): If False, usage is a no-op. json (bool): If true, outputs json progress to stdout rather than a progress bar. Currently, the json format assumes this is only used for "fetch", which maintains backward compatibility with conda 4.3 and earlier behavior. u!{desc}{bar} | {percentage:3.0f}% tdesct bar_formattasciittotalitfileN( t descriptionRRR,RQRlRytpbarRNRPRRR\(R3RRRRR((s.lib/python2.7/site-packages/conda/common/io.pyR2s    cC`sy\|jr5|jr5tjjd|j|fn&|jr[|jj||jjnWn7t k r}|j t t fkrt |_qnXdS(Nu:{"fetch":"%s","finished":false,"maxval":1,"progress":%f} (RRRlRyR{RRtupdatetnRNRPRRR\(R3tfractionR((s.lib/python2.7/site-packages/conda/common/io.pyt update_tos  ! cC`s|jddS(Ni(R(R3((s.lib/python2.7/site-packages/conda/common/io.pytfinishscC`sV|jr9|jr9tjjd|jtjjn|jrR|jjndS(Nu8{"fetch":"%s","finished":true,"maxval":1,"progress":1} ( RRRlRyR{RRRtclose(R3((s.lib/python2.7/site-packages/conda/common/io.pyRs    ( R;R<RQR\R2RRRR(((s.lib/python2.7/site-packages/conda/common/io.pyRs t DummyExecutorcB`s/eZdZdZdZedZRS(cC`st|_t|_dS(N(R\t _shutdownR t _shutdownLock(R3((s.lib/python2.7/site-packages/conda/common/io.pyR2s c O`s||jm|jr"tdnt}y|||}Wn tk r`}|j|nX|j||SWdQXdS(Nu*cannot schedule new futures after shutdown(RRt RuntimeErrorRt BaseExceptiont set_exceptiont set_result(R3tfnRFRRHtresultR((s.lib/python2.7/site-packages/conda/common/io.pytsubmits    cg`s1x*|D]"}x|D]}||VqWqWdS(N((R3Rt iterablesRCtthing((s.lib/python2.7/site-packages/conda/common/io.pytmap s  cC`s|jt|_WdQXdS(N(RRQR(R3twait((s.lib/python2.7/site-packages/conda/common/io.pytshutdowns (R;R<R2RRRQR(((s.lib/python2.7/site-packages/conda/common/io.pyRs   tThreadLimitedThreadPoolExecutorcB`seZddZdZRS(i cC`stt|j|dS(N(R1RR2(R3t max_workers((s.lib/python2.7/site-packages/conda/common/io.pyR2sc O`s|j|jr"tdntj}t||||}|jj|y|jWn,tk rt |j dkrqnX|SWdQXdS(u This is an exact reimplementation of the `submit()` method on the parent class, except with an added `try/except` around `self._adjust_thread_count()`. So long as there is at least one living thread, this thread pool will not throw an exception if threads cannot be expanded to `max_workers`. In the implementation, we use "protected" attributes from concurrent.futures (`_base` and `_WorkItem`). Consider vendoring the whole concurrent.futures library as an alternative to these protected imports. https://github.com/agronholm/pythonfutures/blob/3.2.0/concurrent/futures/thread.py#L121-L131 # NOQA https://github.com/python/cpython/blob/v3.6.4/Lib/concurrent/futures/thread.py#L114-L124 u*cannot schedule new futures after shutdowniN( t_shutdown_lockRRR RR t _work_queuetputt_adjust_thread_countRt_threads(R3RRFRRHtw((s.lib/python2.7/site-packages/conda/common/io.pyRs    (R;R<R2R(((s.lib/python2.7/site-packages/conda/common/io.pyRs cC`s+tddd}ttjjd|S(Nu~u.condauinstrumentation-record.csvu!CONDA_INSTRUMENTATION_RECORD_FILE(RR(RYRZR[(tdefault_record_file((s.lib/python2.7/site-packages/conda/common/io.pytget_instrumentation_record_file?st time_recordercB`seZeZdZeeZee Z dddZ dZ dZ dZdZedZedZRS(cC`s||_||_dS(N(t entry_namet module_name(R3RR((s.lib/python2.7/site-packages/conda/common/io.pyR2Js cC`sk|jdkrgt|dr*|j}n d|j}|jr[dj|j|f}n||_ndS(Nu __qualname__u:u.(RR>Rit __qualname__R;RR(R3RHR((s.lib/python2.7/site-packages/conda/common/io.pyt_set_entry_nameNs   cC`s#|j|tt|j|S(N(RR1RRJ(R3RH((s.lib/python2.7/site-packages/conda/common/io.pyRJXs cC`s7tjjd}|r3t|r3t|_n|S(NuCONDA_INSTRUMENTATION_ENABLED(RYRZR[R+R"t start_time(R3R((s.lib/python2.7/site-packages/conda/common/io.pyRL\scC`s|jr|j}t}||j}|j|cd7<|j|c|7<|jt|jd}|jd||fWdQXndS(Niuau%s,%f ( RRR"ttotal_call_numttotal_run_timet _ensure_dirtopent record_fileR{(R3RRRSRTRtend_timetrun_timeR((s.lib/python2.7/site-packages/conda/common/io.pyRUbs     cC`s}tjjd}|o!t|s(dStjdxAt|jjD]*}tjd|j||j ||qKWdS(NuCONDA_INSTRUMENTATION_ENABLEDu*=== time_recorder total time and calls ===uTOTAL %9.3f % 9d %s( RYRZR[R+R|R}tsortedRtkeysR(tclsRR((s.lib/python2.7/site-packages/conda/common/io.pyt log_totalsps   cC`s2tt|js.tjt|jndS(N(RRRRYtmakedirs(R3((s.lib/python2.7/site-packages/conda/common/io.pyR~sN(R;R<RRR>RRtintRtfloatRR2RRJRLRUt classmethodRR)R(((s.lib/python2.7/site-packages/conda/common/io.pyRDs      c C`st}tt}i}t|s+dSt|J}x@|D]8}|jjd\}}||jt|qAWWdQXx_t |D]Q}||}t |}t |}||} i|d6|d6| d6||RdRgRhRWRRRRRR\RRRRRRRRR(((s.lib/python2.7/site-packages/conda/common/io.pyts~".   . " "       d   G:) @