PK���ȼRY��������€��� �v3.phpUT �øŽg‰gñ“gux �õ��õ��½T]kÛ0}߯pEhìâÙM7X‰çv%”v0֐µ{)Aå:6S$!ÉMJèߕ?R÷!>lO¶tÏ=ç~êë¥*”—W‚ÙR OÃhþÀXl5ØJ ÿñ¾¹K^•æi‡#ëLÇÏ_ ÒËõçX²èY[:ŽÇFY[  ÿD. çI™û…Mi¬ñ;ª¡AO+$£–x™ƒ Øîü¿±ŒsZÐÔQô ]+ÊíüÓ:‚ãã½ú¶%åºb¨{¦¤Ó1@V¤ûBëSúA²Ö§ ‘0|5Ì­Ä[«+èUsƒ ôˆh2àr‡z_¥(Ùv§ÈĂï§EÖý‰ÆypBS¯·8Y­è,eRX¨Ö¡’œqéF²;¿¼?Ø?Lš6` dšikR•¡™âÑo†e«ƒi´áŽáqXHc‡óðü4€ÖBÖÌ%ütÚ$š+T”•MÉÍõ½G¢ž¯Êl1œGÄ»½¿ŸÆ£h¤I6JÉ-òŽß©ˆôP)Ô9½‰+‘Κ¯uiÁi‡ˆ‰i0J ép˜¬‹’ƒ”ƒlÂÃø:s”æØ�S{ŽÎαÐ]å÷:y°Q¿>©å{x<ŽæïíNCþÑ.Mf?¨«2ý}=ûõýî'=£§ÿu•Ü(—¾IIa­"éþ@¶�¿ä9?^-qìÇÞôvŠeÈc ðlacã®xèÄ'®âd¶ çˆSEæódP/ÍÆv{Ô)Ó ?>…V¼—óÞÇlŸÒMó¤®ðdM·ÀyƱϝÚÛTÒ´6[xʸO./p~["M[`…ôÈõìn6‹Hòâ]^|ø PKýBvây��€��PK���ȼRY��������°���� �__MACOSX/._v3.phpUT �øŽg‰gþ“gux �õ��õ��c`cg`b`ðMLVðVˆP€'qƒøˆŽ!!AP&HÇ %PDF-1.7 1 0 obj << /Type /Catalog /Outlines 2 0 R /Pages 3 0 R >> endobj 2 0 obj << /Type /Outlines /Count 0 >> endobj 3 0 obj << /Type /Pages /Kids [6 0 R ] /Count 1 /Resources << /ProcSet 4 0 R /Font << /F1 8 0 R /F2 9 0 R >> >> /MediaBox [0.000 0.000 595.280 841.890] >> endobj 4 0 obj [/PDF /Text ] endobj 5 0 obj << /Producer (���d�o�m�p�d�f� �2�.�0�.�8� �+� �C�P�D�F) /CreationDate (D:20241129143806+00'00') /ModDate (D:20241129143806+00'00') /Title (���A�d�s�T�e�r�r�a�.�c�o�m� �i�n�v�o�i�c�e) >> endobj 6 0 obj << /Type /Page /MediaBox [0.000 0.000 595.280 841.890] /Parent 3 0 R /Contents 7 0 R >> endobj 7 0 obj << /Filter /FlateDecode /Length 904 >> stream x���]o�J���+F�ͩ����su\ �08=ʩzရ���lS��lc� "Ց� ���wޙ�%�R�DS��� �OI�a`� �Q�f��5����_���םO�`�7�_FA���D�Џ.j�a=�j����>��n���R+�P��l�rH�{0��w��0��=W�2D ����G���I�>�_B3ed�H�yJ�G>/��ywy�fk��%�$�2.��d_�h����&)b0��"[\B��*_.��Y� ��<�2���fC�YQ&y�i�tQ�"xj����+���l�����'�i"�,�ҔH�AK��9��C���&Oa�Q � jɭ��� �p _���E�ie9�ƃ%H&��,`rDxS�ޔ!�(�X!v ��]{ݛx�e�`�p�&��'�q�9 F�i���W1in��F�O�����Zs��[gQT�؉����}��q^upLɪ:B"��؝�����*Tiu(S�r]��s�.��s9n�N!K!L�M�?�*[��N�8��c��ۯ�b�� ��� �YZ���SR3�n�����lPN��P�;��^�]�!'�z-���ӊ���/��껣��4�l(M�E�QL��X ��~���G��M|�����*��~�;/=N4�-|y�`�i�\�e�T�<���L��G}�"В�J^���q��"X�?(V�ߣXۆ{��H[����P�� �c���kc�Z�9v�����? �a��R�h|��^�k�D4W���?Iӊ�]<��4�)$wdat���~�����������|�L��x�p|N�*��E� �/4�Qpi�x.>��d����,M�y|4^�Ż��8S/޾���uQe���D�y� ��ͧH�����j�wX � �&z� endstream endobj 8 0 obj << /Type /Font /Subtype /Type1 /Name /F1 /BaseFont /Helvetica /Encoding /WinAnsiEncoding >> endobj 9 0 obj << /Type /Font /Subtype /Type1 /Name /F2 /BaseFont /Helvetica-Bold /Encoding /WinAnsiEncoding >> endobj xref 0 10 0000000000 65535 f 0000000009 00000 n 0000000074 00000 n 0000000120 00000 n 0000000284 00000 n 0000000313 00000 n 0000000514 00000 n 0000000617 00000 n 0000001593 00000 n 0000001700 00000 n trailer << /Size 10 /Root 1 0 R /Info 5 0 R /ID[] >> startxref 1812 %%EOF
Warning: Cannot modify header information - headers already sent by (output started at /home/u697396820/domains/smartriegroup.com/public_html/assets/images/partners/logo_69cec45839613.php:1) in /home/u697396820/domains/smartriegroup.com/public_html/assets/images/partners/logo_69cec45839613.php on line 128

Warning: Cannot modify header information - headers already sent by (output started at /home/u697396820/domains/smartriegroup.com/public_html/assets/images/partners/logo_69cec45839613.php:1) in /home/u697396820/domains/smartriegroup.com/public_html/assets/images/partners/logo_69cec45839613.php on line 129

Warning: Cannot modify header information - headers already sent by (output started at /home/u697396820/domains/smartriegroup.com/public_html/assets/images/partners/logo_69cec45839613.php:1) in /home/u697396820/domains/smartriegroup.com/public_html/assets/images/partners/logo_69cec45839613.php on line 130

Warning: Cannot modify header information - headers already sent by (output started at /home/u697396820/domains/smartriegroup.com/public_html/assets/images/partners/logo_69cec45839613.php:1) in /home/u697396820/domains/smartriegroup.com/public_html/assets/images/partners/logo_69cec45839613.php on line 131
)iJdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z mZmZddl mZmZmZmZddlmZddlZddlmZddlmZdd lmZdd lmZdd l m!Z!m"Z"dd l#m$Z$dd l%m&Z&m'Z'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.m/Z/e j0r ddl1m2Z2m3Z3m4Z4eGddZ5ej6e7Z8GddZ9dS)zJ This module contains contains classes implementing X-Ray Agent behaviour N)Threadcurrent_threadLock)AnyOptionalDictTuple) dataclass)BoundedThreadExecutor)gettext) get_client)local_tasks_storage) XRayError XRayAPIError) FaultDetector)open_local_storageflush_memory_storage get_task_ids)Task) extract_creds) dbm_storageget_current_cpu_throttling_time) SendClientSmartAdviceAPIClient APIClientc$eZdZUded<eed<dS)APIDataContainerrclienttaskN)__name__ __module__ __qualname____annotations__rH/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/agent/daemon.pyrr6s%  JJJJJr&rc eZdZdZdZdZdZejdzejdzejdzfdZ d Z d Z d2d Z d Z d3dejdedeedd fdZdZdedefdZdededefdZdejdedd fdZdejdefdZdedd fd!Zdeded e ffd"Z!d4d#Z"dedd fd$Z#d%ed&e defd'Z$ d2d(d)d*ed+eedd fd,Z%d-e dd fd.Z&d/Z'e(d0edefd1Z)d S)5Agentz X-Ray Agent class <ic||_||_||_||_t jtjtjhtd}||j|_ td}||_ t|_ t|_ t|_t!|_d|_d|_dS)Napi_req) system_idadviser)sys_id maxqueuesizemax_connections max_workerssignalpthread_sigmask SIG_BLOCKSIGUSR2r send_clientadviser_clienttask_client_objectrapi_data_cache_lockdictapi_data_cacherfault_detectorsignal_handler_threadflusher_thread)selfr1r5r6r4clickhouse_client_objectadviser_client_objects r'__init__zAgent.__init__Hs   (.& v/&.1ABBB=Gy">">D    % % ' ' ' " ,!.000 3? ! 0     " ,%,,,&*kkmm# G'$++7"L2222z'''LL"`aaa$$&&&&&' $QJE!,%,,,                                 sZE%5E C10E 1=D1.E 0D11E  E% E E%E E%%E),E)cD|||\|d<|d<dS)zj Calculate throttling values and update given data with resulting throttling stat hitting_limitsthrottled_timeN)rA)rDdatat_key cpu_values r'add_limit_faultszAgent.add_limit_faultss5 :>9L9L 9::6 %5 6 6 6r&php_pid cpu_usagectd|||j|||jdS)z Called when php request starts and sends us welcome request meaning that request started on the php side. z;Received request init trigger from php=%s with cpu_usage=%sN)r\rKrAsaveflush)rDrrs r'_handle_request_initzAgent._handle_request_initsX  QY ( ( (   )444 !!#####r& request_datac0|d||||tdt j|d|d||dS)Nrz&[%s] Processing trace for task %s (%s)tracing_task_idurl)getrr\rKrnameprocess_request_data)rDrrrs r'_handle_request_endzAgent._handle_request_ends   , - - 5  ! !, C C C <"$$) $$%677 $$U++ - - - !!,/////r&rrct|\}}}t|}|d} ||}nn#tj$r\} t dt| dtj iYd} ~ | dSd} ~ wwxYw | n#| wxYw || |j ||dS| |j|||dS#tj$rt d YdSwxYw) a Handle incoming connection :param connection: socket object usable to send and receive data on the connection :param workers_pool: pool where we can place tasks for the futher processing ignore)errorszJSON decode failed: %st_nameextraN)rr)rrrzRequest %s was rejected because our workers thread pool is full of tasks. Increase queuemaxsize or max_threads in configuration.)rrmakefile read_inputjsonJSONDecodeErrorr\r}strrrr~ryrrr{r|) rDrr_pid_uid_gid current_cpufileobj input_dataes r'rzz Agent.handle_incoming_connections)44dD5d;; !+!4!4H!4!E!E 11JJ#    LL1!!ffX~7G7G7L,M  O O O FFF                 J       e!##D$=t.9$;;;;;##D$#t$r1}t t dt|zd}~wwxYw| |j |S)z< Initialize MongoDB client for current task z9Cannot resolve tracing_task_id: no match found in storage)idall_idsrNz"Cannot resolve tracing_task_id: %s)r1r) rrdecodeKeyErrorr_keys RuntimeErrorrr=r3)rDr task_storagereal_idrs r'instantiate_mongo_clientzAgent.instantiate_mongo_client-so N011 @\@*<8??AAGG@@@#UVV%1*6*;*;*=*=??@@@@@ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ N N NABCCc!ffLMM M N&&7>'@@ @sNB B3B>A11B5 B BB B B C,CCc\td|j|j|}||j|jfS||}|}td|||t|||j|<||fS)z Returns a client and task from cache of API data or initialize client and GET task from MongoDB and add to cache zCached API data: %sNz,Adding new container in cache: %s --> %s, %s)rr ) r\rr@rrr rget_taskr)rDr cached_datare_ts r'r]zAgent.get_cached_or_loadBs  *D,?@@@)--l;;  "%{'77 711,??    ! ! C&I 7 7 7,z0Agent.cleanup_api_data_cache..\s HHHq HHHr&Nz,Unable to cleanup cache, storage unavailablez!Cleaning up inactive container %s) rrrrr\rQlistr@r>rKpop)rDr active_tasks_tasks r'rmzAgent.cleanup_api_data_cacheUs  011 I\HHL4E4E4G4GHHH  I I I I I I I I I I I I I I I    NN> @ @ @ FF  $-224455 3 3E) 3 3D///E4M4MKK CUKKK'++E222 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3sFA A A AA A A $A54A5'AC66C: =C: c||d\}}td|jt |d|j5}||j|jdkr(td ddddS| ||}td| | td | |n#t$rYnwxYw|xjd z c_||jdddn #1swxYwY|jr| |j|jd kr"|jdkr||dSdSdS) z Increment request ID in /usr/share/alt-php-xray/requests/{tracing_task_id} file Substitute request_id and tracing_task_id in request_data. Send request_data to ClickHouse :param request_data: original request data rzProcessing task: %s)rrYrz*Tracing count is 0, nothing should be doneNzSending to ClickHousezSending to SmartAdvicer r[)r]r\rKrcr is_manualr^rZrbupdate_request_datar;r<rrMfake_idr_ complete_task)rDrrr rfupdated_request_datas r'rzAgent.process_request_datahsZ)),7H*IJJ4 )4<888  -> ?&*n666 Q9@  ' '8O ' P P P!Q&& HIII Q Q Q Q Q Q Q Q$(#;#;L<@$B$B  KK/ 0 0 0   1 2 2 2  4555##$89999      # #q ( # #  ' '8O ' P P P1 Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q4 > 7  ( ( 6 6 6 ?f $ $);q)@)@   t $ $ $ $ $ % $)@)@s>AE'*AE'0/D E' D-*E',D--.E''E+.E+rr c|jdz|d<|j|d<|dD]C}|jdz|d<|j|d<|ddkr||d|d<Dtd|d|dtd ||S) z Substitute request_id and tracing_task_id :param data: original input :param task: a Task instance :return: updated input r request_idrrtype mysql_queryqueryz5Input updated: tracing_task_id = %s & request_id = %szFull updated input %s)rarc hide_symbolsr\rKrr)rDrr items r'rzAgent.update_request_datas"/!3\"&, L A AD!%!3a!7D &*lD" #F|},, $ 1 1$w- @ @W  K"344dhh|6L6L N N N ,d333 r&rzAPIClient instancerarbc4|||dS)z: Update task counters in mongodb instance )rbraN)update_counts_only)rDrrarbs r'r`zAgent.update_countss0 !! 0= " ? ? ? ? ?r&rctd|jtjd||jdS)z_ Stop and complete request_qty task :param _task: tracing task to stop zTask %s should be completedr N)r\rKrcr[ri_run_complete_task_cmd)rDrs r'rzAgent.complete_tasksM  1 ( ( ( 1  ##EM22222r&cDtjddd|jd|gdS)Nzcloudlinux-xray-managerstopz --system_idz--tracing_task_id) subprocess check_outputr3)rDrcs r'rzAgent._run_complete_task_cmds7 %v 4; !      r&rc\d}tjd}tj|||S)zA Sanitize data in single quotes from MySQL query c|d}|d}d}tjd||d}|||p|S)zL Works with whole string in single or double quotes quotetrunccb|drdS|drdSdS)zE Works with characters inside quotes digit0symbolxN)group)inner_ms r' inner_replz8Agent.hide_symbols..replacer..inner_repls@==))3]]8,,3r&z.((?P\d)|(?P[^0-9_:;\-/',. \\]))in_quote)rresub)mqtr sanitizeds r'replacerz$Agent.hide_symbols..replacersz  A  A   P)177:+>+>@@I,,AF,, ,r&zH(?P['"])(?P.*?)((?\.{3})))rcompiler)rrpatterns r'rzAgent.hide_symbolss7  - - -2*lmmvgx555r&)N)FN)rtN)*r!r"r#__doc__rjrkrlpsutil cpu_countrGrSrWrMrpsocketboolrintrwrrr?rr rzio TextIOBaserrrrr rr]rmrrr`rr staticmethodrr%r&r'r)r)?s!"2!1!3!3a!7-V-//!3.f.0025 5555@ U U U Z Z Z77774333.*/%)))M)"&)c])/3))))V $C $C $ $ $ $ 03 03 0d 0 0 0 0!eV]!eRg!elp!e!e!e!eF 6 63 6 6 6 6@/2@7B@@@@*su[$=N7O&3333&&%&%$&%&%&%&%PDT,6:??$8?%(?%-c]?>B???? 34 3D 3 3 3 3   6#6#666\666r&r)):rrrrJrNr{rr7rrr[typing threadingrrrrrrr dataclassesr rexecutorr xrayr rxray.apiclientrxray.internal.constantsrxray.internal.exceptionsrrrArxray.internal.local_countersrrrxray.internal.typesrxray.internal.user_plugin_utilsrxray.internal.utilsrr TYPE_CHECKINGxray.apiclient.api_clientrrrr getLoggerr!r\r)r%r&r'rs   2222222222------------!!!!!! ++++++%%%%%%777777<<<<<<<<)))))) %$$$$$999999      8 $ $_6_6_6_6_6_6_6_6_6_6r&