← Back
Editing: singleserver.cpython-311.pyc
� #H\a� � � � d Z dZddlZddlZddlZddlZddlZ ddlZd� Zn# e $ r d� ZY nw xY wdgZ G d� de � � Z e dk r� G d � d e � � Z ej � � Ze� ej ej d � � e� d � � e� ej � � e e� � � � e� � dS dS )z Allan Saddi <allan@saddi.com>z $Revision$� Nc �~ � t j | � � � t j t j � � d S �N)�fcntl�fileno�F_SETFD� FD_CLOEXEC��socks �:/usr/lib/python3/dist-packages/flup/server/singleserver.py�setCloseOnExecr * s) � � � �D�K�K�M�M�5�=�%�2B�C�C�C�C�C� c � � d S r � r s r r r ' s � � �r � SingleServerc �J � e Zd Zdd�Zdd�Zd� Zdd�Zd � Zd � Zd � Z d � Z d � Z dS )r Nr c �" � || _ || _ d S r )� _jobClass�_jobArgs)�self�jobClass�jobArgs�kws r �__init__zSingleServer.__init__0 s � �!��� �� � � r � �?c �0 � d| _ d| _ t j � d� � s| � � � t |� � | j �r$ t j |gg g |� � \ }}}n2# t j $ r }|j t j k rY d}~�O� d}~ww xY w|r� |� � � \ }}n<# t j $ r*}|j t j t j fv rY d}~��� d}~ww xY wt |� � | � |� � s|� � � �� | j ||g| j �R � }|� � � | � � � | j ��$| � � � | j S )z� The main loop. Pass a socket that is ready to accept() client connections. Return value will be True or False indiciating whether or not the loop was exited due to SIGHUP. TF�winN)� _keepGoing� _hupReceived�sys�platform� startswith�_installSignalHandlersr �select�error�errno�EINTR�accept�socket�EAGAIN�_isClientAllowed�closer r �run�_mainloopPeriodic�_restoreSignalHandlers) r r �timeout�r�w�e� clientSock�addr�conns r r, zSingleServer.run4 s� � � ��� !��� �|�&�&�u�-�-� *� � '� '� )� )� )� �t� � � � �o� %� � �-����B��@�@���1�a�a���<� � � ��7�e�k�)�)� �H�H�H�H������ ���� � ��'+�{�{�}�}�$�J���� �|� � � ��w�5�;�� �"=�=�=� �������������� �z�*�*�*��,�,�T�2�2� � �$�$�&�&�&� � &�t�~�j�$�G�� �G�G�G����� � � � � "� "� $� $� $�5 �o� %�: �#�#�%�%�%� � � s< � A7 �7B&�B!� B!�!B&�,C �C=� C8�7C8�8C=c � � dS )zi Called with just about each iteration of the main loop. Meant to be overridden. Nr �r s r r- z SingleServer._mainloopPeriodich s � � �r Fc �4 � | j rd| _ || _ dS dS )z� Protected convenience method for subclasses to force an exit. Not really thread-safe, which is why it isn't public. FN)r r )r �reloads r �_exitzSingleServer._exito s- � � �?� '� #�D�O� &�D� � � � '� 'r c � � dS )z#Override to provide access control.Tr )r r4 s r r* z SingleServer._isClientAllowedx s � ��tr c �" � d| _ d| _ d S )NTF)r r �r �signum�frames r � _hupHandlerzSingleServer._hupHandler~ s � � ��� ����r c � � d| _ d S )NF)r r= s r � _intHandlerzSingleServer._intHandler� s � � ����r c �~ � t j t j g}t t d� � r |� t j � � d� |D � � | _ |D ]\}t t d� � r+|t j k rt j || j � � �Bt j || j � � �]d S )N�SIGHUPc �: � g | ]}|t j |� � f��S r )�signal� getsignal)�.0�xs r � <listcomp>z7SingleServer._installSignalHandlers.<locals>.<listcomp>� s( � �K�K�K�Q�!�F� ,�Q� /� /�0�K�K�Kr ) rF �SIGINT�SIGTERM�hasattr�appendrD �_oldSIGsr@ rB )r �supportedSignals�sigs r r" z#SingleServer._installSignalHandlers� s� � � "�M�6�>�:�� �6�8� $� $� 3� � #� #�F�M� 2� 2� 2�K�K�:J�K�K�K�� �#� 5� 5�C��v�x�(�(� 5�S�F�M�-A�-A�� �c�4�#3�4�4�4�4�� �c�4�#3�4�4�4�4� 5� 5r c �J � | j D ]\ }}t j ||� � �d S r )rO rF )r r> �handlers r r. z#SingleServer._restoreSignalHandlers� s6 � � "�m� +� +�N�F�7� �M�&�'� *� *� *� *� +� +r )Nr )r )F) �__name__� __module__� __qualname__r r, r- r: r* r@ rB r" r. r r r r r / s� � � � � � � � � � �2!� 2!� 2!� 2!�h � � �'� '� '� '�� � � � � � � � � 5� 5� 5�+� +� +� +� +r �__main__c � � e Zd Zd� Zd� ZdS )�TestJobc �" � || _ || _ d S r )�_sock�_addr)r r r4 s r r zTestJob.__init__� s � � �D�J� �D�J�J�Jr c �0 � t d| j z � � | j � d� � | j � d� � | j � d� � | j � � � t d| j z � � d S )Nz#Client connection opened from %s:%dz Hello World! � z#Client connection closed from %s:%d)�printr\ r[ �send� setblocking�recvr+ r7 s r r, z TestJob.run� s� � � �7�$�*�D� E� E� E� �J�O�O� ,� -� -� -� �J� "� "�1� %� %� %� �J�O�O�A� � � � �J� � � � � � �7�$�*�D� E� E� E� E� Er N)rT rU rV r r, r r r rY rY � s7 � � � � � � � � � F� F� F� F� Fr rY r^ )� i� )r )� __author__� __version__r r( r# rF r% r r � ImportError�__all__�objectr rT rY r � setsockopt� SOL_SOCKET� SO_REUSEADDR�bind�listen� SOMAXCONNr, r r r �<module>ro s� ��6 -� �� � � � � � � � � � � � � � � � � � � � � �D��L�L�L� D� D� D� D�� � � � � � � � � � ���� � ��e+� e+� e+� e+� e+�6� e+� e+� e+�N �z��� F� F� F� F� F�&� F� F� F� �6�=�?�?�D��O�O�F�%�v�':�A�>�>�>��I�I�j�����K�K�� �!�!�!��L�'�"�"�"�&�&�t�,�,�,�,�,�! �s �" �-�-
Save File
Cancel