iBSSKrSSKJr SSKJr SSKJr SSKr\"\S5r"SS\R5r "SS 5r \ \R\R\\(a\ OS\RS .rg) N)queue)Event) selectorswebsocket_handshakec:^\rSrSrSr/04U4SjjrSrSrU=r$)Thread zt This wrapper class provides gevent Greenlet interface that is compatible with the standard library's Thread class. c.>[TU]"U/UQ70UD6 gN)super__init__)selftargetargskwargs __class__s `/home/admin/cozy_coffee/venv/lib/python3.13/site-packages/engineio/async_drivers/gevent_uwsgi.pyr Thread.__init__s 1$1&1c"UR5$r )runrs r_run Thread._runsxxzr) __name__ __module__ __qualname____firstlineno____doc__r r__static_attributes__ __classcell__)rs@rrr s%'r2rrcB\rSrSrSrSrSrSrSrSr Sr S r S r g ) uWSGIWebSocketzl This wrapper class provides a uWSGI WebSocket interface that is compatible with eventlet's implementation. c,XlSUl/Ulgr )app_sockreceived_messages)rhandlerservers rr uWSGIWebSocket.__init__s !#rc[R"5UlXl[R"5 SUl[ [S5(a"5UlO][5Ul [R"5Ul Sn[R"UURUR5UlUR!U5 [R""5 g)Nrequest_contextc [R"5nURU[R5 UR 5 UR 5 M"![ Ra URU5 gf=f)z5Sets event when data becomes available to read on fd.N) rDefaultSelectorregister EVENT_READselectsetgevent GreenletExit unregister)fdeventsels rselect_greenlet_runner7uWSGIWebSocket.__call__..select_greenlet_runner/sf//1 R!5!56'  **'NN2&'s#A%BB)uwsgi connection_fdr(environr_req_ctxhasattrr.r_eventrQueue _send_queuer5spawn_select_greenletr' disconnect)rr@start_responser;s r__call__uWSGIWebSocket.__call__s((*   !!# 5+ , ,!113DM 'DK${{}D  '%+LL&  %D !  rcURc5URR5 URR 5 gg)z"Disconnects uWSGI from the client.N)rArGkillrCr4rs rcloseuWSGIWebSocket.closeBs1 ==  ! ! & & ( KKOO  !rc[U[5(a[RnO[RnUR bU"XR S9 gU"U5 g)zMTransmits message either in binary or UTF-8 text mode, depending on its type.Nr.) isinstancebytesr>websocket_send_binarywebsocket_sendrA)rmsgmethods r_senduWSGIWebSocket._sendIsD c5 ! !00F))F == $ 3 6 3Krc~[U[5(dU$[USS5nUS:aURS5$U$)z7Returns either bytes or str, depending on message type.r0zutf-8)rRrSorddecode)rrVtypes r_decode_receiveduWSGIWebSocket._decode_receivedUs>#u%%J3q8} 2:::g& & rcURbURU5 gURRU5 URR 5 g)zvQueues a message for sending. Real transmission is done in wait method. Sends directly if uWSGI version is new enough.N)rArXrEputrCr4)rrVs rsenduWSGIWebSocket.sendas; == $ JJsO     % KKOO rcURb0[R"URS9nUR U5$UR (aUR RS5$URRSS9nU(aHURR5 /nURURRSS95 M+[R$"5nU(a+UR RUR U55 OOMKUR (aUR RS5$GML![a UR 5 gf=f![RR a Of=fUH6nUR#U5 M![a UR 5  gf=f N![a UR 5 gf=f)a,Waits and returns received messages. If running in compatibility mode for older uWSGI versions, it also sends messages that have been queued by send(). A return value of None means that connection was closed. This must be called repeatedly. For uWSGI < 2.1.x it must be called from the main greenlet.NrQr)timeoutF)block)rAr>websocket_recvOSErrorrNr`r)poprCwaitclearappendrEgetr5rEmptyrXwebsocket_recv_nb)rrV event_setmsgss rrmuWSGIWebSocket.waitks}}( ..t}}MC,,S11))1155a88!KK,,Q,7 KK%%'D" KK(8(8(<(<5(<(IJ$#557..55 11#68))1155a88Y JJL $ &||11"!"#( JJsO&( JJL#'( $#$ #$sGE)(E.GE+*E+.FFF++G G G,+G,)rCrArGrEr(r'r@r)N) rrrrr r rJrNrXr`rdrmr!rrrr$r$s+$ !F  39rr$)threadr queue_emptyr9 websocketsleep)r5r gevent.eventrrr>rB_websocket_availableGreenletrr$ JoinableQueuerqry_asyncrrrrsl  u&;< V__ I9I9Z  ;; #7T \\  r