Files
aitsc/.venv/Lib/site-packages/engineio/__pycache__/async_socket.cpython-312.pyc

52 lines
16 KiB
Plaintext
Raw Normal View History

2025-02-23 09:07:52 +08:00
<EFBFBD>
W0<57>g<EFBFBD>)<00><00>v<00>ddlZddlZddlZddlmZddlmZddlmZddlmZGd<07>dej<00>Z y) <09>N<>)<01> base_socket)<01>
exceptions)<01>packet)<01>payloadc<00>P<00>eZdZd<01>Zd<02>Zd<03>Zd<04>Zd<05>Zd<06>Zd d<08>Z d <09>Z
d
<EFBFBD>Z d <0B>Z d <0C>Z y)<0E> AsyncSocketc<00><00><>K<00> tj|jj<00>|jj
|jj z<00><00>d{<00><03><03>g}|jj<00>|dgk(rgS |jj<00>}|jj<00>|<02>|jjd<01> |S|j|<02><00>g7<00><>#tjtjf$rtj<00><00>wxYw#tj$rY|SwxYw<01>w)z'Wait for packets to send to the client.N)<0F>asyncio<69>wait_for<6F>queue<75>get<65>server<65> ping_interval<61> ping_timeout<75> task_done<6E> TimeoutError<6F>CancelledErrorr<00>
QueueEmpty<EFBFBD>
get_nowait<EFBFBD>
put_nowait<EFBFBD>append)<03>self<6C>packets<74>pkts <20>?D:\wxxcx\tsccc\.venv\Lib\site-packages\engineio/async_socket.py<70>pollzAsyncSocket.poll s'<00><00><><00> *<2A>$<24>-<2D>-<2D><14>
<EFBFBD>
<EFBFBD><0E><0E> <20><14> <0B> <0B>)<29>)<29>D<EFBFBD>K<EFBFBD>K<EFBFBD>,D<>,D<>D<>F<01>F<01>G<01>G<EFBFBD> <11>J<EFBFBD>J<EFBFBD> <20> <20> "<22> <13>t<EFBFBD>f<EFBFBD> <1C><15>I<EFBFBD><12> <16><1A>j<EFBFBD>j<EFBFBD>+<2B>+<2B>-<2D><03><14>
<EFBFBD>
<EFBFBD>$<24>$<24>&<26><16>;<3B><18>J<EFBFBD>J<EFBFBD>)<29>)<29>$<24>/<2F><19><17><0E><18><0E><0E>s<EFBFBD>#<23><13>F<01><><18>$<24>$<24>g<EFBFBD>&<<3C>&<<3C>=<3D> *<2A><1C>'<27>'<27>)<29> )<29> *<2A><><1B>%<25>%<25> <16><15><16><0E> <16>s`<00>E<01>AC2<00> C0<04>!C2<00> E<01>
AD-<00>E<01>D-<00>/E<01>0C2<00>28D*<03>*E<01>-E<03>E<01>E<03>Ec <00><00><>K<00>|jjjd|jtj
|j t|jt<00>s |jnd<02>|j tjk(r|j<00>y|j tjk(rP|jjd|j|j|jj<00><04><00>d{<00><02><03>y|j tjk(r;|j!t j"tj$<00><00><00>d{<00><02><03>y|j tj&k(r;|j)dd|jj*j,<00><08><00>d{<00><02><03>yt/j0<00><00>7<00><>7<00>s7<00><1D>w) zReceive packet from the client.z%s: Received packet %s data %s<><binary><3E>message<67><01> run_asyncNFT<46><03>wait<69>abort<72>reason)r<00>logger<65>info<66>sidr<00> packet_names<65> packet_type<70>
isinstance<EFBFBD>data<74>bytes<65>PONG<4E> schedule_ping<6E>MESSAGE<47>_trigger_event<6E>async_handlers<72>UPGRADE<44>send<6E>Packet<65>NOOP<4F>CLOSE<53>closer&<00>CLIENT_DISCONNECTr<00>UnknownPacketError<6F>rrs r<00>receivezAsyncSocket.receive#sT<00><00><><00> <0C> <0B> <0B><1A><1A><1F><1F> @<40> $<24><08><08>&<26>*=<3D>*=<3D>c<EFBFBD>o<EFBFBD>o<EFBFBD>*N<>0:<3A>3<EFBFBD>8<EFBFBD>8<EFBFBD>U<EFBFBD>0K<30><03><08><08>%/<2F> 1<> <0F>?<3F>?<3F>f<EFBFBD>k<EFBFBD>k<EFBFBD> )<29> <10> <1E> <1E> <20> <10>_<EFBFBD>_<EFBFBD><06><0E><0E> .<2E><16>+<2B>+<2B>,<2C>,<2C><19>4<EFBFBD>8<EFBFBD>8<EFBFBD>S<EFBFBD>X<EFBFBD>X<EFBFBD><1E>+<2B>+<2B>4<>4<>-<2D>6<> 6<> 6<><11>_<EFBFBD>_<EFBFBD><06><0E><0E> .<2E><16>)<29>)<29>F<EFBFBD>M<EFBFBD>M<EFBFBD>&<26>+<2B>+<2B>6<>7<> 7<> 7<> <10>_<EFBFBD>_<EFBFBD><06> <0C> <0C> ,<2C><16>*<2A>*<2A>%<25>t<EFBFBD>$(<28>K<EFBFBD>K<EFBFBD>$6<>$6<>$H<>$H<><1D>J<01> J<01> J<01><1D>/<2F>/<2F>1<> 1<> 6<><36> 8<><38> J<01>s8<00>D G<01> G<04> AG<01>#G<04>$AG<01>;G<04><G<01>G<01>Gc<00><00><>K<00>|jrtj<00><00>|jr<>t j<00>|jz
|j
j kDrk|j
jjd|j<00>|jdd|j
jj<00><03><00>d{<00><02><03>yy7<00><06>w)z,Make sure the client is still sending pings.z"%s: Client is gone, closing socketFr#NT) <0A>closedr<00>SocketIsClosedError<6F> last_ping<6E>timerrr'r(r)r9r&<00> PING_TIMEOUT<55>rs r<00>check_ping_timeoutzAsyncSocket.check_ping_timeout7s<><00><00><><00> <0F>;<3B>;<3B><1C>0<>0<>2<> 2<> <0F>><3E>><3E><14> <09> <09> <0B>d<EFBFBD>n<EFBFBD>n<EFBFBD>,<2C>t<EFBFBD>{<7B>{<7B>/G<>/G<>G<> <10>K<EFBFBD>K<EFBFBD> <1E> <1E> #<23> #<23>$H<>$(<28>H<EFBFBD>H<EFBFBD> .<2E>
<17>*<2A>*<2A>%<25>u<EFBFBD>$(<28>K<EFBFBD>K<EFBFBD>$6<>$6<>$C<>$C<><1D>E<01> E<01> E<01><18><13> E<01>s<00>C
C<01> C<04> Cc <00><00>|K<00>|j<00><00>d{<00><02><03>sy|jj|<01><00>d{<00><02><03>|jjj d|j tj|jt|jt<00>s|j<00>yd<03>y7<00><>7<00><EFBFBD>w)zSend a packet to the client.Nz%s: Sending packet %s data %sr) rEr <00>putrr'r(r)rr*r+r,r-r.r<s rr5zAsyncSocket.sendGs<><00><00><><00><19>,<2C>,<2C>.<2E>.<2E>.<2E> <12><16>*<2A>*<2A>.<2E>.<2E><13>%<25> %<25> %<25> <0C> <0B> <0B><1A><1A><1F><1F> ?<3F> $<24><08><08>&<26>*=<3D>*=<3D>c<EFBFBD>o<EFBFBD>o<EFBFBD>*N<>0:<3A>3<EFBFBD>8<EFBFBD>8<EFBFBD>U<EFBFBD>0K<30><03><08><08> 1<>&0<> 1<> /<2F><> &<26>s <00>B<<01>B8<04>#B<<01>B:<04>A>B<<01>:B<c<00><00>VK<00>|jdd<02>j<00>jd<03>D<00>cgc]}|j<00><00><02>}}|jdd<02>j<00>}d|vr\||jvrN|j
j jd|j|<04>t|d|z<00>|<01><00>d{<00><02><03>S|js |jr$tjtj<00>gS |j<00><00>d{<00><03><03>}|Scc}w7<00>`7<00> #t j"$rft%j&<00>}|j)d |j
j*j,<00>
<EFBFBD><00>d{<00><03><03>7|d j/|d <00><00>wxYw<01>w) z2Handle a long-polling GET request from the client.<2E>HTTP_CONNECTION<4F><00>,<2C> HTTP_UPGRADE<44>upgradez%%s: Received request to upgrade to %s<> _upgrade_NF)r$r&r<00>)r<00>lower<65>split<69>strip<69>upgrade_protocolsrr'r(r)<00>getattr<74> upgrading<6E>upgradedrr6r7rrr<00>sys<79>exc_infor9r&<00>TRANSPORT_ERROR<4F>with_traceback)r<00>environ<6F>s<> connections<6E> transportr<00>excs r<00>handle_get_requestzAsyncSocket.handle_get_requestRs|<00><00><><00><1D>[<5B>[<5B>!2<>B<EFBFBD>7<>=<3D>=<3D>?<3F>E<>E<>c<EFBFBD>J<>L<01>J<><01> <0E>G<EFBFBD>G<EFBFBD>I<EFBFBD>J<> <14>L<01><1C>K<EFBFBD>K<EFBFBD><0E><02>3<>9<>9<>;<3B> <09> <14> <0B> #<23> <09>T<EFBFBD>5K<35>5K<35>(K<> <10>K<EFBFBD>K<EFBFBD> <1E> <1E> #<23> #<23>$K<>$(<28>H<EFBFBD>H<EFBFBD>i<EFBFBD> 9<>?<3F><17><14>{<7B>Y<EFBFBD>'><3E>?<3F><07>H<>H<> H<> <0F>><3E>><3E>T<EFBFBD>]<5D>]<5D><1B>M<EFBFBD>M<EFBFBD>&<26>+<2B>+<2B>.<2E>/<2F> /<2F> 0<> <20>I<EFBFBD>I<EFBFBD>K<EFBFBD>'<27>G<EFBFBD> <17><0E><>'L<01>I<01><> (<28><><19>$<24>$<24> 0<><15>,<2C>,<2C>.<2E>C<EFBFBD><16>*<2A>*<2A>%<25>$(<28>K<EFBFBD>K<EFBFBD>$6<>$6<>$F<>$F<><1D>H<01> H<01> H<01><15>a<EFBFBD>&<26>'<27>'<27><03>A<EFBFBD><06>/<2F> /<2F>  0<>sU<00>2F)<01>D$<04> A=F)<01>D)<04> AF)<01>
D-<00>D+<04>D-<00>"F)<01>+D-<00>-AF&<03>F <06> F&<03>&F)c<00><00>zK<00>t|jdd<02><00>}||jjkDrt j
<00><00>|dj |<02><00>d{<00><02><03>jd<05>}tj|<03><06>}|jD]}|j|<05><00>d{<00><02><03><00>y7<00>T7<00> <09>w)z3Handle a long-polling POST request from the client.<2E>CONTENT_LENGTH<54>0z
wsgi.inputNzutf-8)<01>encoded_payload) <0C>intrr<00>max_http_buffer_sizer<00>ContentTooLongError<6F>read<61>decoder<00>Payloadrr=)rr[<00>length<74>body<64>prs r<00>handle_post_requestzAsyncSocket.handle_post_requestis<><00><00><><00><14>W<EFBFBD>[<5B>[<5B>!1<>3<EFBFBD>7<>8<><06> <11>D<EFBFBD>K<EFBFBD>K<EFBFBD>4<>4<> 4<><1C>0<>0<>2<> 2<>!<21>,<2C>/<2F>4<>4<>V<EFBFBD><<3C><<3C>D<>D<>W<EFBFBD>M<>D<EFBFBD><17><0F><0F><04>5<>A<EFBFBD><18>y<EFBFBD>y<EFBFBD><03><1A>l<EFBFBD>l<EFBFBD>3<EFBFBD>'<27>'<27>'<27>!<21>=<3D><>(<28>s%<00>A B;<01>"B7<04>#A B;<01>/B9<06>0B;<01>9B;Nc<00><00><>K<00>|js<>|js<>d|_|jjd|j|xs |jj
j d<03><04><00>d{<00><02><03>|s:|jtjtj<00><00><00>d{<00><02><03>d|_|r#|jj<00><00>d{<00><02><03>yyyy7<00>o7<00>57<00> <0C>w)zClose the socket connection.T<>
disconnectFr!N) r?<00>closingrr2r)r&<00>SERVER_DISCONNECTr5rr6r8r <00>join)rr$r%r&s rr9zAsyncSocket.closets<><00><00><><00><13>{<7B>{<7B>4<EFBFBD><<3C><<3C><1F>D<EFBFBD>L<EFBFBD><16>+<2B>+<2B>,<2C>,<2C><1C>d<EFBFBD>h<EFBFBD>h<EFBFBD><16>><3E>$<24>+<2B>+<2B>,<2C>,<2C>><3E>><3E><1F>-<2D>!<21> !<21> !<21><19><1A>i<EFBFBD>i<EFBFBD><06> <0A> <0A>f<EFBFBD>l<EFBFBD>l<EFBFBD> ;<3B><<3C><<3C><<3C><1E>D<EFBFBD>K<EFBFBD><13><1A>j<EFBFBD>j<EFBFBD>o<EFBFBD>o<EFBFBD>'<27>'<27>'<27><14>$0<>{<7B> !<21><>
=<3D><>(<28>s6<00>A.C&<01>0C <04>1;C&<01>,C"<04>-*C&<01>C$<04> C&<01>"C&<01>$C&c<00>N<00>|jj|j<00>y<00>N)r<00>start_background_task<73>
_send_pingrDs rr0zAsyncSocket.schedule_ping<6E>s<00><00> <0C> <0B> <0B>)<29>)<29>$<24>/<2F>/<2F>:<3A>c<00><00>^K<00>d|_tj|jj<00><00>d{<00><02><03>|j
sa|j sTtj<00>|_|jtjtj<00><00><00>d{<00><02><03>yyy7<00>r7<00> <09>wru) rAr <00>sleeprrrqr?rBr5rr6<00>PINGrDs rrwzAsyncSocket._send_ping<6E>st<00><00><><00><1D><04><0E><15>m<EFBFBD>m<EFBFBD>D<EFBFBD>K<EFBFBD>K<EFBFBD>5<>5<>6<>6<>6<><13>|<7C>|<7C>D<EFBFBD>K<EFBFBD>K<EFBFBD>!<21>Y<EFBFBD>Y<EFBFBD>[<5B>D<EFBFBD>N<EFBFBD><16>)<29>)<29>F<EFBFBD>M<EFBFBD>M<EFBFBD>&<26>+<2B>+<2B>6<>7<> 7<> 7<>%0<>|<7C> 7<><37> 8<>s"<00>4B-<01>B)<04>A*B-<01>!B+<04>"B-<01>+B-c<00><00>*K<00>|jr td<01><00>|jjd<00>|jj <00>S|jjd|j
|j<00>}||<01><00>d{<00><02><03>S7<00><04>w)z1Upgrade the connection from polling to websocket.z Socket has been upgraded already<64> websocketN)rV<00>OSErrorr<00>_async<6E> _bad_request<73>_websocket_handler)rr[<00>wss r<00>_upgrade_websocketzAsyncSocket._upgrade_websocket<65>s{<00><00><><00> <0F>=<3D>=<3D><19><<3C>=<3D> =<3D> <0F>;<3B>;<3B> <1D> <1D>k<EFBFBD> *<2A> 2<><17>;<3B>;<3B>+<2B>+<2B>-<2D> -<2D> ,<2C>T<EFBFBD>[<5B>[<5B> <1F> <1F> <0B> ,<2C> <10> #<23> #<23>T<EFBFBD>[<5B>[<5B>2<><02><17><07>[<5B> <20> <20> <20>s<00>B
B<01> B<04> Bc<00><00>Z<00><00>K<00><00><00>fd<01>}<02>j<00>r<>d<02>_ |<02><00>d{<00><03><03>}tj|<03><04>}|j
tj k7s|jdk7r8<72>jjjd<06>j<00>d<07>_y<03>jtjtjd<05><08>j<00><00><00>d{<00><02><03><00>jj!tjtj"<00><00><00>d{<00><02><03> |<02><00>d{<00><03><03>}tj|<03><04>}|j
tj$k7r@d<07>_<00>jjjd <09>j|<03>d<07>_yd<02>_d<07>_nd<02>_d<02>_<00><00>fd
<EFBFBD>}t)j*|<05><00>}<06>jjjd <0B>j<00> d}t)j*|<02><00>} t)j,|<08>jj.<00>jj0z<00><00>d{<00><03><03>}|<07>n1tj|<07><04>} <00>j7|<03><00>d{<00><03><03><00><><EFBFBD>jj!d<03><00>d{<00><02><03>t)j,|d<03><0E><00>d{<00><02><03><00>j?dd<02>jj@jB<00><0F><00>d{<00><02><03>y7<00><03>#t$rYywxYw7<00><02>c7<00><02>"7<00><02>#t$r
d<07>_YywxYw7<00><>#t(j2$r |j5<00>n#YnxYwY<00><>Y<00><>xYw7<00><>#t8j:$rY<00><>t8j<$r)<00>jjjd <0C>Y<00><01>5<00>jjj5d <0A>Y<00><01>_xYw7<00><01>C7<00><01>'7<00><><EFBFBD>w)z*Engine.IO handler for websocket transport.c<00><00><><00>K<00><00>j<00><00>d{<00><02><03>}|r-t|<00><00>jjkDr t d<01><00>|S7<00>5<EFBFBD>w)Nzpacket is too large)r$<00>lenrrf<00>
ValueError)r-rr<>s <20><>r<00>websocket_waitz6AsyncSocket._websocket_handler.<locals>.websocket_wait<69>sB<00><><00><><00><1B><17><17><19>?<3F>D<EFBFBD><13><03>D<EFBFBD> <09>D<EFBFBD>K<EFBFBD>K<EFBFBD>$D<>$D<>D<> <20>!6<>7<>7<><17>K<EFBFBD>#<23>s<00>A<01>A <04>6ATN)<01>encoded_packet<65>probez,%s: Failed websocket upgrade, no PING packetF)r-zK%s: Failed websocket upgrade, expected UPGRADE packet, received %s instead.c<00><00>*<00>K<00> d} <00>j<00><00>d{<00><03><03>}|sn1 |D])}<01>j|j <00><00><00>d{<00><03><03><00>+ <00>O<EFBFBD>j <00><00>d{<00><02><03>y7<00>Q#tj$rY<00>0wxYw7<00><#Y<00>:xYw7<00>)<29>wru)rrrr5<00>encoder9)rrrr<>s <20><>r<00>writerz.AsyncSocket._websocket_handler.<locals>.writer<65>s<><00><><00><><00><16><1E><07><1A>$(<28>I<EFBFBD>I<EFBFBD>K<EFBFBD>/<2F>G<EFBFBD><1F><19><1A>&<26><03> <20>g<EFBFBD>g<EFBFBD>c<EFBFBD>j<EFBFBD>j<EFBFBD>l<EFBFBD>3<>3<>3<> '<27><17><15>(<28>(<28>*<2A> <1C> <1C>0<><30>!<21>,<2C>,<2C><1A><19><1A><>4<><34><1A><19><> <1C>sl<00>B<01>A/<00>A-<04>A/<00>B<01>'B
<00> B<06> B
<00>B<01>'B<04>(B<01>-A/<00>/B<03>B<01>B<03>B<01>B
<00>
B<03> Bz#%s: Upgrade to websocket successfulz!Receive error -- socket is closedzUnknown receive error)<01>timeoutr#)"<22> connectedrUr~rr6r+r{r-rr'r(r)r5r/r<>r rGr7r4rVr <00> ensure_futurer rrr<00> exceptionr=rr;r@r9r&<00>TRANSPORT_CLOSE) rr<>r<>r<00> decoded_pktr<74><00> writer_taskrm<00> wait_tasks `` rr<>zAsyncSocket._websocket_handler<65>sx<00><><00><><00> <18> <10>><3E>><3E>!<21>D<EFBFBD>N<EFBFBD> <17>*<2A>,<2C>,<2C><03>!<21>-<2D>-<2D>s<EFBFBD>;<3B>K<EFBFBD><1A>&<26>&<26>&<26>+<2B>+<2B>5<><1F>$<24>$<24><07>/<2F><14> <0B> <0B>"<22>"<22>'<27>'<27>B<>D<EFBFBD>H<EFBFBD>H<EFBFBD>N<01>!&<26><04><0E><16><14>'<27>'<27>&<26>-<2D>-<2D><06> <0B> <0B>'<27>B<>I<>I<>K<>L<> L<> L<><16>*<2A>*<2A>.<2E>.<2E><16><1D><1D>v<EFBFBD>{<7B>{<7B>!;<3B><<3C> <<3C> <<3C> <17>*<2A>,<2C>,<2C><03>!<21>-<2D>-<2D>s<EFBFBD>;<3B>K<EFBFBD><1A>&<26>&<26>&<26>.<2E>.<2E>8<> %<25><04> <0A><14> <0B> <0B>"<22>"<22>'<27>'<27>,<2C><18>H<EFBFBD>H<EFBFBD>c<EFBFBD>#<23>"'<27><04><0E><16> <20>D<EFBFBD>M<EFBFBD>"<22>D<EFBFBD>N<EFBFBD>!<21>D<EFBFBD>N<EFBFBD> <20>D<EFBFBD>M<EFBFBD> <1D>"<1E>+<2B>+<2B>F<EFBFBD>H<EFBFBD>5<> <0B> <0C> <0B> <0B><1A><1A><1F><1F> 1<>4<EFBFBD>8<EFBFBD>8<EFBFBD> =<3D><13><14>A<EFBFBD><1F>-<2D>-<2D>n<EFBFBD>.><3E>?<3F>I<EFBFBD> <16>!<21>*<2A>*<2A><1D><18>K<EFBFBD>K<EFBFBD>-<2D>-<2D><04> <0B> <0B>0H<30>0H<30>H<>J<01>J<01><01>$<11>y<EFBFBD><15><18>-<2D>-<2D>q<EFBFBD>1<>C<EFBFBD>
F<01><1A>l<EFBFBD>l<EFBFBD>3<EFBFBD>'<27>'<27>'<27>7<13>L<13>j<EFBFBD>j<EFBFBD>n<EFBFBD>n<EFBFBD>T<EFBFBD>"<22>"<22>"<22><15><1E><1E>{<7B>D<EFBFBD>9<>9<>9<><12>j<EFBFBD>j<EFBFBD>e<EFBFBD>4<EFBFBD> $<24> <0B> <0B> 2<> 2<> B<> B<><19>D<01> D<01> D<01>A-<2D><><1A> <17><16> <17><> M<01><> <<3C><>-<2D><><1A> <17>!&<26><04><0E><16> <17><>ZJ<01><><1B>)<29>)<29> <16><19><1D>'<27>'<27>)<29><><19><18><><15> <16><15><> (<28><><1D>0<>0<> <15><14><1D>1<>1<> <16><14> <0B> <0B>"<22>"<22>'<27>'<27>(K<>L<><15> F<01><15> <0B> <0B>"<22>"<22>,<2C>,<2C>-D<>E<><45>"<22><>9<><39> D<01>sO<00>P+<01>
M<00>L?<04>M<00>B?P+<01>.M<04>/AP+<01>2M<04>3P+<01>8
M<00>M<04>M<00>C=P+<01>AM2<00> M0<04>
M2<00>P+<01>(N(<00><N&<04>=N(<00>P+<01> P#<04>!P+<01>?P&<04>9P+<01>9P)<04>:P+<01>?M<00> M<03> P+<01> M<03>P+<01>P+<01>M<00>M-<03>*P+<01>,M-<03>-P+<01>0M2<00>2N#<03>N<02>N#<03>N<05>N#<03>P+<01> N#<03>!P+<01>&N(<00>(P <03>;P+<01>=7P <03>4P+<01>7&P <03>P+<01>&P+<01>)P+)TFN)<0E>__name__<5F>
__module__<EFBFBD> __qualname__rr=rEr5r`rnr9r0rwr<>r<><00>rxrr r s;<00><00><17>.2<>(<14> 1<><17>. (<28> (<28>;<3B>8<> !<21>nDrxr )
r rWrBrJrrrr<00>
BaseSocketr r<>rxr<00><module>r<>s0<00><01><0E>
<EFBFBD> <0B><19><18><14><15>zD<01>+<2B>(<28>(<28>zDrx