"eydZddlZddlmZmZmZmZmZddlm Z m Z m Z ddl m Z ddlZddlmZmZmZddlmZddlZddlmZdd lmZmZmZdd lmZmZdd lm Z ddl!Z!dd l"m#Z#dd l$m%Z%ddlm&Z&gZ'Gdde(Z)dZ*dZ+edZ,dZ-dZ.dZ/dZ0e&ddZ1d+dZ2dZ3dZ4dZ5dZ6 ddl7m8Z8e8Z6dZ9d Z:Gd!d"e#Z;e5d#Zd&Z?d'Z@d(ZAd)ZBd*ZCy#Y3xYw),zE pydevd_vars deals with variables: resolution/conversion to XML. N) get_frameget_current_thread_id iter_charssilence_warnings_decoratorget_global_debugger)ExceptionOnEvaluateget_type var_to_xml) pydev_log)resume_threadsmark_thread_suspendedsuspend_all_threads) CMD_SET_BREAK) threading)pydevd_save_localspydevd_timeoutpydevd_constants)Execexecfile) to_string)PyDBDaemonThread)update_globals_and_locals) lru_cachec eZdZy) VariableErrorN)__name__ __module__ __qualname__EXECFILE__file__zN)rSrrstrr rV) rFr/rGrHrWstyle code_or_fileoperation_fn_nameexpressionValue namespaces r!custom_operationrjs"#y(E5IO !56 J $0Ij ! \9i 8$;Ij ! y) 4/9./@AAs AAA+cd}|j|}d}|D];}|jst|D]}|jr|dz }nn|rd}g}|D]A}|sn=t|d|D]}|jrd}n|j ||dC|r4t |t rdj|}|Sdj|}|S)NTrFr ) splitlinesstriprisspaceappend isinstancebytesjoin) expressionkeependslineschars_to_striplinecproceed new_liness r!_expression_to_evaluater~sH  ! !( +EN ::<% 99;"a'N     4D_n 56 yy{#G    T./2 3 4 *e, XXi0  !XXi0 r c(d} t|}tj|jztjk(}|r|t }| t dt ||||}|j|j|jr+|jdj|jd|j} |St|||} |S#ttf$rtj \}}} t#||| } d|vro|j%d} | d} ||}|| } | ddD]F} | j'dr't)| | sd| j*j,| } t/| | } H| }Y|S#YY|SxYwwxYw) Nz$Cannot evaluate async without py_db.rmz.__.r___)compile_as_evalinspect CO_COROUTINEco_flagsr RuntimeError_EvalAwaitInNewEventLoopstartruexcwith_tracebackevaluated_valueeval ExceptionKeyboardInterruptr)exc_inforr; startswithhasattr __class__rgetattr) rv global_vars local_varspy_dbresultcompiledis_asynctetypetbr;entrycurrs r!eval_in_contextrs F(":.''(*;*;;w?S?SS }+-=&'MNN(+zRA GGI FFHuueeAh--aeeAh77**2 M/(K>+B+BE J"4/D0  M   M-s+CC C4FA3FF  F Fcd}|j}tj}|dkDr*tj}t j d|| |||||S|j||5|||||cdddS#1swYyxYw)Nrz2Doing evaluate with interrupt threads timeout: %s.)timeout_trackerrPYDEVD_INTERRUPT_THREAD_TIMEOUTr%create_interrupt_this_thread_callbackr infocall_on_timeout) original_funcr curr_threadr&rvis_execon_interrupt_threadsrinterrupt_thread_timeouts r!_run_with_interrupt_threadr&s++O/OO!#-SSUKMef#UE:w??  , ,-EG[ \ D z7C D D Ds - BB c  dj}jrtj}nd}|dk\r0t j d|t   fdd_ xt||||fjrYttjjtjj tSSS|j|5t||||cdddfjrYttjjtjj tSSS#1swYnxYw fjrYttjjtjj tyyy#fjrYttjjtjj twwwxYw)Nrz0Doing evaluate with unblock threads timeout: %s.cd_tjdtdjj y)NTz(Resuming threads after evaluate timeout.* except_thread)calledr rr %threads_suspended_single_notificationon_thread_resume)ron_timeout_unblock_threadsrtidsr!rz=_run_with_unblock_threads..on_timeout_unblock_threadsDs904 & - NNE F 3k :  7 7 H Hk Zr Fr)r!multi_threads_single_notificationrPYDEVD_UNBLOCK_THREADS_TIMEOUTr rrrrr rrincrement_suspend_timeron_thread_suspendr) rrrr&rvrrunblock_threads_timeoutrrs `` @@r!_run_with_unblock_threadsr7s5!%++O .."2"Q"Q"$!#IKbc#K0 [ -2") k % --mUKQVXbdkl & 16P6W6W !+} =  7 7 N N P [ A  7 7 I I#{\i j 7X 1 !001HJde q1- UZ\fhop q q & 16P6W6W !+} =  7 7 N N P [ A  7 7 I I#{\i j 7X 1  q q q & 16P6W6W !+} =  7 7 N N P [ A  7 7 I I#{\i j 7X 1 % 16P6W6W !+} =  7 7 N N P [ A  7 7 I I#{\i j 7X 1s+(G,"G,4E6 G,6E?;G,,A*IcBtjfd}|S)z Provides a decorator that wraps the original evaluate to deal with slow evaluates. If some evaluation is too slow, we may show a message, resume threads or interrupt them as needed (based on the related configurations). c , tjd||Stj}t j fd}j }|j||5t||cdddS#1swYyxYw)Nz-_evaluate_with_timeouts called without py_db!crjjjjyr#)writer add_command cmd_factorymake_evaluation_timeout_msg)rrvrsr!on_warn_evaluation_timeoutzM_evaluate_with_timeouts..new_func..on_warn_evaluation_timeoutls/ LL $ $U%6%6%R%Rz;&0 1r ) r criticalrPYDEVD_WARN_EVALUATION_TIMEOUTrr,rrr) rr&rvrwarn_evaluation_timeoutrrrrs ` ` @r!new_funcz)_evaluate_with_timeouts..new_funccs =   N O z7C C"2"Q"Q..0  1 //  , ,-DF` a l,]E;PUWacjk l l ls 0B  B) functoolswraps)rrs` r!_evaluate_with_timeoutsr[s)__]#l$l Or )PyCF_ALLOW_TOP_LEVEL_AWAITcbt|}tt|ddtSt|ddS) :param expression: The expression to be _compiled. :return: code object :raises Exception if the expression cannot be evaluated. rr~_ASYNC_COMPILE_FLAGScompilervexpression_to_evaluates r!rr85Z@'-z6CWXX-z6BBr cbt|}tt|ddtSt|ddS)rrexecrrs r!_compile_as_execrrr ceZdZdZdZdZy)rcvtj||||_||_||_d|_d|_yr#)r__init__ _compiled_updated_globals_updated_localsrr)selfrrupdated_globalsupdated_localss r!rz!_EvalAwaitInNewEventLoop.__init__s:!!$.! /- $r ctKt|j|j|jd{S7wr#)rrrr)rs r! _async_funcz$_EvalAwaitInNewEventLoop._async_funcs+$..$*>*>@U@UVVVVs /868c ddl}|j}|j||j|j |_y#t j|_YyxYw)Nr) asyncionew_event_loopset_event_looprunrrr)rr)rrloops r!_on_runz _EvalAwaitInNewEventLoop._on_runsT & ))+D  " "4 (#*;;t/?/?/A#BD  &||~DHs A A A)N)rrrrrrrr r!rrsW&r rcyi}|jj|jjd|vrfd|d<|j}d} |j dd}|r t |}| t|}tj|jztjk(}|ret||||} | j| j| jr8| jdj| jdt!|||t#||ntj|jztjk(}|rrt||||} | j| j| jr+| jdj| jd| j$} n t'|||} | "t(j*j-| d ~~~yt/||||} | j0t2k(} | st#|| | ~~~S#t $rd}YwxYw#t#||wxYw#Y.xYw#~~~wxYw)aT :param str expression: The expression to be evaluated. Note that if the expression is indented it's automatically dedented (based on the indentation found on the first non-empty line). i.e.: something as: ` def method(): a = 1 ` becomes: ` def method(): a = 1 ` Also, it's possible to evaluate calls with a top-level await (currently this is done by creating a new event loop in a new thread and making the evaluate at that thread -- note that this is still done synchronously so the evaluation has to finish before this function returns). :param is_exec: determines if we should do an exec or an eval. There are some changes in this function depending on whether it's an exec or an eval. When it's an exec (i.e.: is_exec==True): This function returns None. Any exception that happens during the evaluation is reraised. If the expression could actually be evaluated, the variable is printed to the console if not None. When it's an eval (i.e.: is_exec==False): This function returns the result from the evaluation. If some exception happens in this case, the exception is caught and a ExceptionOnEvaluate is returned. Also, in this case we try to resolve name-mangling (i.e.: to be able to add a self.__my_var watch). :param py_db: The debugger. Only needed if some top-level await is detected (for creating a PyDBDaemonThread). NglobalscjSr#)rCr%sr!z%evaluate_expression..s U__r @LINE@r4rmr)rDrCrEcopyr?rrrrrrrrrurrrrrrr)r*r+rrr) rr&rvrrinitial_globalsrrrrrretis_exception_returneds ` r!rBrBsnZ }FO5??+5>>*'&= "%**,ON=''$7  +:6W/ ;H&33h6G6GG7K_K__H4UHoWef 55"#%%("9"9!%%("CCXG.oPUV"//(2C2CCwG[G[[0/SabAGGIFFHuueeAh55aeeAh??!"!2!2!(O^LF%JJ$$v%78     !"*o~uUC W(+ 9L(L%-.oPUV    k  $.oPUV,     shI72 I =I7B-I-C!I7I7#I06I7 II7II7I--I70I42I77I=c4|y |jdd}|jr)|tur!|jj|||}|r|S|dddk(r[|dd}||jvr|tur!t ||j|j }||j|<|j|Sd|vrptjr\|tur!t ||j|j }||j |<tj||j |S|tur!t ||j|j }|}t|d||j|j |Sy#t$rtjYywxYw) z-Changes some attribute in a given frame. Nrr4Globalsr=)r?pluginSENTINEL_VALUEchange_variablerCrrEris_save_locals_available save_localsrrr rV)r&rQrvrFvaluers r!change_attr_expressionrWsr } ''$7 ::%>1ZZ//tZHF 8y 8Du&N* U__ennME(-%t,,$%>>@. $Z%.. Q+0ENN4(&2259 >>$//&Z%..IF D*-u OM''* s'AE7 A"E7/A3E7#AE77FFdic t|\}}}|dk(r@t|||\}} } } } | } d| z}|dk(r |dk(r| }| }| t||||||z } d| zS|dk(rt|||||||} d| zSt d|z)Nndarray%r DataFramez+Do not know how to convert type %s to tablez %s)r array_to_meta_xml array_to_xmldataframe_to_xmlr)arraynameroffsetcoffsetrowscolsformatrrXmetaxmlrr{fxmls r!table_like_struct_to_xmlrsuoOAy!I"3E4"Hw1aq 2:$"*DD |E7GT4HH S  k !udGWdD&Q S  IYWXXr cNd}t|t}t|t}t|dk(r|dkDs|dkDr|d}|jt|kDrL||d|df}t|t|}t|t|d}t|dk(rg|d}na|jt|k(rI|dk(r |dk(r||d}t|t|}n$|dk(r|dk(r||d}t|t|}|d|d|dz }t |D]}|dt |zz }t |D]e}|} |dk(s|dk(r;|dk(r |dk(r|d} n3|dk(r|} n|} || } dt t| vr| d} n|||} || z} |t| dz }g|S) Nrnrmrzr) minMAXIMUM_ARRAY_SIZErAsizer@rrdr]r ) r r r rrrrrowcolrdims r!rrs C t' (D t' (D 5zQD1Hqa zzCJgh()4U$4U1X' u:?!HE s5z ! a2Dc%j "d+!DME a5;;r?N35;;r?N3 %++b/ !TEKKO%;(,d3Gafafn% >>' "  F w))+uyy{+ $fdF1Ivay BC #tT6 ))r ct|jdt}t|jdt}||f|jk7r|jd|d|f}d|d|d} nd} || z} d| d|d |d } ||fd k(r||}}t|t}tt|t|}d g|z} t |D]j} |j j|| zj} | d vr7|jd d || zf}|j|jf}nd}|| | <l|j|||z|||zf}|j\}}| d|d |dz } |jdd}g}d}t |D]} |j j| j} | dk(r|r|}n| dk(rd}n| dk(s| dk(rd}nd}|jd|z| | }| dt| d||jdj| d| d|d|dd|dd z } tt|jdD] \}}| d t|d!||d"z } "| d#z } | d$|d |d"z } t |D]K}| d%t|zz } t |D]*} |j || f}|| |z}| t#|dz } ,M| S)&z :type df: pandas.core.frame.DataFrame :type name: str :type coffset: int :type roffset: int :type rows: int :type cols: int :type format: str rrmz.iloc[0:r(r)rnr,r-rz&" format="" type="" max="0" min="0"/> )rrNr+r*z rcvt|ts t|Sdjt t|S)N/)rstuplerdrumap)labels r!rz"dataframe_to_xml../s* 5%0Hc%jchhWZ[^`eWfNgr rr!r"r#r$r%z z z rz )rr4r6ilocrr@dtypesr3r8r?rrrdaxesvalues enumerateiteriatr )dfr r r rrrnum_rowsnum_colsr9r col_boundsrr2cvaluesr= col_formats get_labelfmtrrCrs r!r r s"288A;/H288A;/H(rxx' WWQxZH, -'/: 5LE (H &C d|xxd t' (D s4+,h 7D$JT{! w}-22 G gga3./GkkmW[[]3FF 3! 'D.('7T>*AA BBJD$tT BBC ^^C $FKgIT{_ s#(( Cr`sJ@@PO#mm> 8OO61@G L 7IIX/,$*. 1""J+\D"!kH8 .5 C"C"&/&2YYx@N&R!$*Z;*|JM  s 6C--C1