i'ddlZddlZddlZddlZddlZddlZddlmZmZm Z ddl m Z ddl m Z ddlmZmZddl mZdd l mZer Gd d eZnd.d ZGd deZej,ej.dej.dej.dej0dZej,ej4dej.dej.dej6dej4dej4dej4dej0dZej,ej.dej0dej:ddej0dej<deZej,ej@dejBdej4dej4dej4d ej6d!ej6d"ej6d#ej6d$ej6d%ej6d&ej4d'ej.d(ej.d)ej.d*ej:d+dej<d+eZ"Gd,d-ejFZ$y)/N)PY3byte2int indexbytes)error)ge)lockconnect)rqeventc eZdZddZdZdZy) bytesviewNc|t||z }t|tr t|}n@t|tr |j }n#t djt|||||z|_yNzunsupported type: {}) len isinstancebytes memoryviewrview TypeErrorformattype)selfdataoffsetsizers _/home/obispo/Crisostomo_bridge/mision_env/lib/python3.12/site-packages/Xlib/protocol/display.py__init__zbytesview.__init__1si|4y'$&!$'D),yy 6 = =d4j IJJVF4K0DIc,t|jSN)rrrs r__len__zbytesview.__len__<styy> !r!cpt|trt|j|S|j|Sr#)rslicerr)rkeys r __getitem__zbytesview.__getitem__?s-#u%TYYs^,,99S> !r!rN)__name__ __module__ __qualname__r r%r)r!rrr/s 1 " "r!rct|ttfs#tdj t ||t ||z }t|||Sr)rrbufferrrrr)rrrs rrrFsM$0299$t*EF F <t9V#DdFD))r!c(eZdZiZej j Zejj Z ddZ dZ dZ dZdZdZdZd Zd Zd Zd Zdd ZdZdZddZdZdZdZdZddZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&y) DisplayNc tj|\}}}}}||_||_tj|||||_tj |j ||||\}}tj|_ d|_ tj|_ tj|_ g|_ tj|_d|_g|_tj|_d|_d|_d|_tj|_d|_tj|_|j j1t j2t j4} t7j8dt7j:t7j<| d} t?| |_ g|_!d|_"d|_#d|_$d|_%tj|_&i|_'d|_(d|_)tUjVdtUjXddd|_-|jZrd} nd } t]|| d d|| } | j^dk7r*tajb|j| jd| |_3ti|jtk|jfjldz |_y) Nr rrr!BBHBl ) byte_orderprotocol_majorprotocol_minorauth_prot_nameauth_prot_data)7r get_display display_namedefault_screen get_socketsocketget_authr allocate_locksocket_error_lock socket_errorevent_queue_read_lockevent_queue_write_lock event_queuerequest_queue_lockrequest_serial request_queuesend_recv_lock send_active recv_active event_waitingevent_wait_lockrequest_waitingrequest_wait_lock getsockopt SOL_SOCKET SO_RCVBUFmathpowfloorlogintrecv_buffer_size sent_requestsrecv_packet_len data_send data_recvdata_sent_bytesresource_id_lock resource_idslast_resource_id error_handlerstructunpackpack big_endianConnectionSetupRequeststatusrDisplayConnectionErrorreasoninfominrroots) rdisplaynameprotocolhost displaynoscreenno auth_name auth_data buffer_sizeorderrs rr zDisplay.__init__Ss4;4G4G4P1hi &((xyI &// T08$  K 9"&!3!3!5 &*%7%7%9"&*&8&8&:##'"4"4"6#002#113 !%!3!3!5kk,,V->->-3-=-=? hhq$**TXXk1-E"FG #K 0   !% 2 2 4 !"!--fkk#v.FGJ ??EE #40546454=4=  ? 88q=..t/@/@!((K K !$"5"5s499??7Ka7OPr!c|jSr#)r@r$s rget_display_namezDisplay.get_display_names   r!c|jSr#)rAr$s rget_default_screenzDisplay.get_default_screens"""r!cV|j|jjSr#)check_for_errorrCfilenor$s rrzDisplay.filenos! {{!!##r!c |j|jj|jj|jsm|j j|jj |jd|jj|jsm|jd}|jd=|jj |jj |S)NTr r)rrHacquirerIrJrNrelease send_and_recv)rrs r next_eventzDisplay.next_events  ""**, ##++- ""    ' ' )  ' ' / / 1   t  ,  ' ' / / 1#"",  #   Q  ##++- ""**, r!c|j|jj|jd|jjt |j }|jj|S)NT)recv)rrNrrrIrrJr)rcounts rpending_eventszDisplay.pending_eventssn  ##% $' ##++-D$$% ##++- r!c||j|jj|jdy)NT)flush)rrNrrr$s rrz Display.flushs1  ##% 4(r!cF|j|jdy)Nclient)rclose_internalr$s rclosez Display.closes  H%r!c||_yr#)rf)rhandlers rset_error_handlerzDisplay.set_error_handlers $r!c|jj |j}||jvrS|dz}||jj kDrd}||jk(rt jd||jvrSd|j|<||_|jj|z|jjS#|jjwxYw)zid = d.allocate_resource_id() Allocate a new X resource id number ID. Raises ResourceIDError if there are no free resource ids. r rzout of resource idsN) rcrrerdroresource_id_maskrResourceIDErrorresource_id_baser)ris rallocate_resource_idzDisplay.allocate_resource_id s %%' ,%%At(((Etyy111A---//0EFF t((($(D  a $%D !99--1  ! ! ) ) +D ! ! ) ) +sA,C .CC.c|jj ||jjz}||z |jjk7r |jj y |j |=|jj y#t$rY&wxYw#|jj wxYw)zd.free_resource_id(rid) Free resource id RID. Attempts to free a resource id which isn't allocated by us are ignored. N)rcrrorrrrdKeyError)rridrs rfree_resource_idzDisplay.free_resource_id!s %%' ,dii000AQw$))444  ! ! ) ) +  %%a(  ! ! ) ) +    ! ! ) ) +s)5B%. B B"B%!B""B%%Cc:|jj||S)zclass = d.get_resource_class(class_name, default = None) Return the class to be used for X resource objects of type CLASS_NAME, or DEFAULT if no such class is set. )resource_classesget)r class_namedefaults rget_resource_classzDisplay.get_resource_class9s$$((W==r!c"||j|<yr#extension_major_opcodes)rextnamemajors rset_extension_majorzDisplay.set_extension_majorBs05$$W-r!c |j|Sr#r)rrs rget_extension_majorzDisplay.get_extension_majorEs++G44r!c|dk(r||j|<y||jvr||i|j|<y||j||<yr#) event_classes)rcodeevtsubcodes radd_extension_eventzDisplay.add_extension_eventHsP T/&)4  d #$,,,+2C.t!!$'36t!!$'0r!c"||j|<yr#) error_classes)rrerrs radd_extension_errorzDisplay.add_extension_errorQs#&4 r!c|jj|j}|jj|r|yr#)rFrrGrrrs rrzDisplay.check_for_errorYs> &&( &&( I r!cP|jr |j|jj|j|_|jdzdz|_|j j ||ft|j }|jjy)Nr ) rGrKrrL_serialrMappendrr)rrequestwait_for_responseqlens r send_requestzDisplay.send_requestas   ## # '')--#22Q6%? !!7,=">?4%%& '')r!cd|_d|_d|_d|_d|_|j j |jjtj||_ |jjyr#) rMr^rJr`rarCrrFrrConnectionClosedErrorrGr)rwhoms rrzDisplay.close_internalrss!!  &&(!77= &&(r!cV |s| |js|s|r|jr|r0|j}|jsId|_|j n1|/|j }|j sd|_|j |jj|s|ryj |jy|js d}d|_nd}d}d} |s |js|jj |jD]A\} } |j| jz|_ | s'|jj| C|jdd=|jj|jr d|_d}n d|_d}|jj|s|sn|r$|"|jt!|jz} |r|j"g} ng} |s|rd} nd} t%j$|j"g| g| \} }}|rN |j"j1|j}|j|d|_ |j|z|_d}| r|r |j6t!|j8z }t;|j<|}|j"j?|}|s|j3d|j4tA|j8|z|_|jC|}n<|jj d|_|jjy|r||jk\rn3|r |jDrn$||rn|rn|jj |jj |rd|_|rd|_|jr!d|_|jj|j r!d|_|j j|jjy#t$j&$r[}t)|t*r |j,}n|d}|t,j.k7r|jj Yd}~d}~wwxYw#t"j&$r%}|j3d|z|j4d}~wwxYw#t"j&$r%}|j3d|z|j4d}~wwxYw)asend_and_recv(flush = None, event = None, request = None, recv = None) Perform I/O, or wait for some other thread to do it for us. send_recv_lock MUST be LOCKED when send_and_recv is called. It will be UNLOCKED at return. Exactly or one of the parameters flush, event, request and recv must be set to control the return condition. To attempt to send all requests in the queue, flush should be true. Will return immediately if another thread is already doing send_and_recv. To wait for an event to be received, event should be true. To wait for a response to a certain request (either an error or a response), request should be set to that request's serial number. To just read any pending data from the server, recv should be true. It is not guaranteed that the return condition has been fulfilled when the function returns, so the caller has to loop until it is finished. Nr rz server: %sserver)#rOrPrRrQrrTrSrNrrKrMr`_binaryr^rrbrrCselectrrOSErrorerrnoEINTRsendrrGr_ramaxr]rrparse_responserJ)rrrrr wait_lock receiving flush_bytessendingreqwaitwritesettimeoutrswsesrrrgotreqr bytes_recvs rrzDisplay.send_and_recvsTw*0@0@$D$4$4 00 )))*D&%%'$ 22 +++,D(%%'    ' ' )          I D I d.. ''//1!%!3!37IC%)^^ckk%ADN**11#67 &&q)''//1>>'(D$G'(D$G    ' ' )y ,"22S5HH $  $ }H!H 5G"G#]]DKK=(BP B(, ((8A "&!3'+';';a'?$F0 $ 4 4s4>>7J J #D$9$95 A%)[[%5%5e%< &++H5"///%*4>>%:Z%GDN!009F''//1'(D$''//1(<(<<))"v    ' ' )q~ ##%  D   D    !"D   ( ( *   #$D  " " * * , ##%[<< c7+99Dq6D5;;& ##++- &||,'' s(:;+++,$"<<0++L3,>?"///0sK(AQ-%R5AS0R2AR--R25S- S((S-0T( T##T(c|dk(r|jSd} |jrt|j}|jrrt |j|jkr|Sdk(r|j |xs|}m|dzt jk(r|j|t|t |jdkr|Sdk(r|j|xs|}ni|dk(s|dzt jk(r=ttjd|jdd d}d|dzz|_n|j|?) a%Internal method. Parse data received from server. If REQUEST is not None true is returned if the request with that serial number was received, otherwise false is returned. If REQUEST is -1, we're parsing the server connection setup response. Fr  rz=L)parse_connection_setuprarr_rparse_request_responserGenericEventCodeparse_event_responseAssertionErrorparse_error_responser\rgrh)rrrrtyperlens rrzDisplay.parse_responsesJ b=..0 0~~ 0##t~~&)=)==!MA:!88AKVFT\R%8%88--e4(//4>>"R' z227;Ev!ut|r/B/BB6==t~~a/BCAFG')D1H}$))%0Kr!ct|jd}|jj|tj }|||jdd}t |jd|_|j|j}|r|j|rt|tjra|jj|jr!d|_|j j#|jj#||jk(S|j$r"tj&|j$|dy|j)|y)Nr rrF)rrarrrXErrorrget_waiting_requestsequence_number _set_errorrr ReplyRequestrNrrSrTrrfcall_error_handlerdefault_error_handler)rrrestructers rrzDisplay.parse_error_responses$$..!,$$((u||< D$.."- ."4>>26&&q'8'89 3>>!$ #r/##++-''+,D(**224##++-a/// /!!%%d&8&8!TB**1-r!cHtjjd|zy)NzX protocol error: %s )sysstderrwriters rrzDisplay.default_error_handler s 2S89r!cL|j}tjd|jddd}||jk7rt d|jd|d|j |jd|jt|j|j|_d|_|jj|jr!d|_ |jj|jj|j|k(S)Nz=HrrrzExpected reply for request z , but got z. Can't happen!)get_waiting_replyrequestrgrhrar RuntimeError_parse_responser_rrNrrSrTrr)rrrsnos rrzDisplay.parse_request_responses++-mmD$..1"56q9 #++ "%++s 45 5 DNN+@D,@,@AB#4>>43G3GH  ##%   #$D  " " * * , ##%""g--r!c~|dz}|tjk(r |j}nd}|jj |t j }t|tk(r1|jd}t|tk(r t|}||}|||jd|}|tjk(rd|_t|j||_ t|dr!|j|jdz dz|j j#|j$j'||j j)|j*j#|j,r!d|_|j.j)|j*j)y)Nrrr )rr binarydatarrr)rrr_rrrAnyEventrdictrastrordrhasattrrrrIrrJrrrNrQrR)retypelengthrrrs rrzDisplay.parse_event_response-so  B'' '))FF$$((? =D nnQ'GG}#g,g&G d1H I B'' '#$D "4>>6: 1' (  $ $a&7&7!&;u%D E ##++- " ##++- ##%   !"D   ( ( * ##%r!cj|jsy|jdj|jkDr$|jdz}||jkr&|dz}n |j}||jkDr|dz }||jdjkryd}t|j}d}d}t dt|jD]R}|j|j|z}||krd}||z}|}||k(r|j|}|dz}n ||ksNd}|}n|jd|=|S)Nrrr )r^rrLrrange) rr last_serialrreqposadjlastrrnos rrzDisplay.get_waiting_requestdsa!!   a ( (4+>+> >--5KT(((Ek--KT(((Ek ##A&.. .T''(q#d0012 A$$Q'//#5CTzCiDcz((+Qs# (   ww ' r!ctdt|jD]@}t|j|ds|j|}|jd|dz=|cSt d)Nr_replyr z0Request reply to unknown request. Can't happen!)rrr^rr)rrrs rrz Display.get_waiting_replyrequestssq#d0012 SAt))!,h7((+&&vAv.  SQR Rr!c|jd} |jr|jddz}t|j|kry|jddk7r*|jd|jd |jd <nI|jj |jd||d \}}|jj ||jd=|j|d|_yt|jd kry|jj |jdd |d \|_}|jd d|_@) zCInternal function used to parse connection setup response. rTadditional_lengthrFrlr N reason_lengthrn)rawdictr)r^_datarra_success_reply parse_binaryupdater)rr|alenxds rrzDisplay.parse_connection_setupsG   q !wwww23a7t~~&- 778$)(,7P8P(QAGGH%++889N9=9ODAqGGNN1%&&q)!%!6t~~&* XX224>>"13E3743I !%!3Gr!r#)FFNF)'r+r,r-rr xerror_classcopyrr event_classrr r~rrrrrrrrrrrrrrrrrrrrrrrrrrr.r!rr2r2Ns &&++-M%%**,MWQ|!#$1f ) &%,0,0>657' *")"_&D 51p*Z:.>4&n4l S*4r!r2depthbits_per_pixel scanline_pad visual_id visual_classbits_per_rgb_valuecolormap_entriesred_mask green_mask blue_maskrvisualsrootdefault_colormap white_pixel black_pixelcurrent_input_maskwidth_in_pixelsheight_in_pixels width_in_mms height_in_mmsmin_installed_mapsmax_installed_maps root_visual backing_store save_unders root_depthallowed_depthsceZdZejej dddej dejdejdejddejddej dejdejd Z ejejd ejd ejdejdejd Z ejejd ejd ejdejdejddejdejddejddejdejdejdejdejdejdej dejdejdeejdeZdZy)rkr:r )r7r8r;r<r=rr>rlrrrelease_numberrrmotion_buffer_sizevendormax_request_lengthrqpixmap_formatsimage_byte_orderbitmap_format_bit_orderbitmap_format_scanline_unitbitmap_format_scanline_pad min_keycode max_keycoderc|jj|i||_d|_|jj |df|j j|jdy)NTr)r) _request to_binaryrrrMrrNrr)rrrargskeyss rr zConnectionSetupRequest.__init__&se.t}}..==  $$dD\2 &&(+r!N)r+r,r-r StructSetPadCard16LengthOfString8rFCard8rCard32List PixmapFormatScreenrr r.r!rrkrksryy&"&&q,? "&&)#"))$45#"))$45%"++&6:%"++&6: "&&)$"**%56$"**%569HRYY(+!/2"#34"#34"#67 :F RYY  *: ; ) *< = ) *< = ) *> ? + Ha 8 ) *> ? + GQ 7 + ,r_s2 *)#"F".*A4fA4Nryy("((7+""((#34""((>2 "&&) RYY;/!.1!"67"#56":."<0";/   8288G$266!92;;y!,266!92779j1   IBIIf%BKK 23BIIm,BIIm,BII23BII/0BII01BIIn-BIIo.BII23BII23BIIm,BHH_-BHH]+BHH\*BKK 0!4BGG,e4! (3,R^^3,r!