Файловый менеджер - Редактировать - /opt/support/venv/lib/python3.13/site-packages/cproc/__pycache__/process.cpython-313.pyc
Ðазад
� ��i�% � � � S r SSKrSSKrSSKJr SSKJr SSKrSSK r SSK J r " S S5 r " S S \R 5 rg) z&cproc module process execution objects� N)� cpu_count)�Callable� )� ProcMonitorc � � \ rS rSrSrSrSSS\R \R 4S\ \ - S- S\ \ \ 4 S- S\ S- S\ \R - S \ S- S S4 S jjrS rg) � ProcLimit� ai Contains load limits for cproc.Proc if used as the lim= arg Note: The grace argument could be useful for subprocesses which require a TCP session, such as rsync, to avoid a timeout caused by the process sleeping for too long. ex: ProcLimit(grace=(5, 1)) Args: value (int | float | None): maximum sever load. If set to None, it'll default to either the number of cores determined from multiprocessing.cpu_count(), or 1.0 if running on a VZ VPS grace (tuple[int, int] | None): If set, it should be a 2-item tuple of ints > 0. The first item is the number of seconds to sleep if the server is overloaded, and the second is how long to allow execution anyways once the sleep expires max_mem (int | None): If set, the process will be killed if it uses more than this amount of memory, in MiB mem_signal (Signal | int): kill signal to send the process if it goes over max_mem. Defaults to ``signal.SIGTERM`` mem_log_func (Callable | None): log function to call if a process is killed for being over memory. Defaults to ``logging.error`` �cprocN�value�grace�max_mem� mem_signal� mem_log_func�returnc � � U( a US- OS U l X@l XPl Uc/ [ R R 5 ( a SO [ 5 nXl X l g )Ni g �?) r r r �rads�vz�is_vpsr r r )�selfr r r r r s �?/opt/support/venv/lib/python3.13/site-packages/cproc/process.py�__init__�ProcLimit.__init__& sF � � +2�w���t�� �$�� (�� �=� �7�7�>�>�+�+�C���E�� �� � )r r r r r )�__name__� __module__� __qualname__�__firstlineno__�__doc__�signal�SIGTERM�logging�error�int�float�tuple�Signalsr r �__static_attributes__� r r r r s� � ��. �J� %)�(,� "�+1�>�>�(/� � � ��U�{�T�!�� �S�#�X���%�� �t�� � �&�.�.�(� � ��o� � �� r r c � ^ � \ rS rSrSrSr\R r\R r\R r\R r \R r \R r SS.S\ \ - \- S- S\S \S- S \ S- S \ S- 4 U 4S jjjr SS \\- S- S\ \ - S- S\4S jjr\SSSSSS.S\S \S- S \\- S- S\S\ \ - S- S\S\R 4S jj5 rSrU =r$ )�Proc�8 a Custom subprocess.Popen subclass which allows automatic pausing and resuming based on server load and has no defaults for encoding, stdout, and stderr. Warning: Using None for stdout or stderr can be dangerous if your program runs as a daemon under systemd. Systemd can kill the subprocess with SIGPIPE. It's better to set the outputs to Proc.DEVNULL if you don't need them. Args: args: A string, or a sequence of program arguments lim (int, float, ProcLimit | None): max load limit. This can be a static limit if you set it to a float or int, or for more flexibility, use a ``ProcLimit`` instance shell (bool): If true, the command will be executed through the shell (unsafe) encoding (str | None): text encoding for subprocess output and input, such as "UTF-8". Set this to None to use no encoding (as bytes) stdout (int | None): specifies the executed program's standard output. Set to Proc.DEVNULL to not capture output. or Proc.PIPE to capture. Use None to print to your shell, but see Warning above stderr (int | None): specifies the executed program's error output. Set to Proc.DEVNULL to not capture output. or Proc.PIPE to capture. Use None to print to your shell, but see Warning above r F)�shell�limNr, �encoding�stdout�stderrc �� >� Uc S U l O,[ U[ 5 ( a X l O[ U5 U l [ TU ] " U4UUUUS.UD6 U R b [ U 5 U l g g )N)r, r. r/ r0 )r- � isinstancer �superr r �mon) r �argsr- r, r. r/ r0 �kwargs� __class__s �r r � Proc.__init__^ sv �� � �;��D�H� ��Y� '� '��H� ��~�D�H� ��� � �� ��� � � � �8�8� �"�4�(�D�H� r �input�timeout�checkc �J � U R XS9u pEU( a: U R ( a) [ R U R U R XES9e[ R U R U R XE5 $ ! U R 5 U R 5 e = f)an Wait for a process to complete and return a CompletedProcess instance Args: input (bytes | str | None): text to send to stdin. stdin should have already been set to PIPE before sending anything to it timeout (int | float | None): raise Proc.TimeoutExpired if the process takes longer than this number of seconds to execute. Defaults to None check (bool): if True, raise Proc.CalledProcessError if the process exits with a non-zero exit code. The raised object will contain the .returncode attribute. Defaults to False Raises: Proc.CalledProcessError: program exited with a non-zero exit code and check=True was specified Proc.TimeoutExpired: program took too long to execute and timeout= was specified Returns: Proc.CompletedProcess: contains .args, .returncode, .stdout, and .stdin )r9 r: )�outputr0 )� communicate�kill�wait� returncoder* �CalledProcessErrorr5 �CompletedProcess)r r9 r: r; r/ r0 s r �complete� Proc.complete| s� � �: � !� -� -�E� -� K�N�F� �T�_�_��)�)�������6� *� � � �$�$�T�Y�Y�����P�P�� � �I�I�K� �I�I�K� �s �A? �?#B")r, r9 �capture_outputr: r; rF r c � � Ub$ SU; a [ S5 e[ R US' U( a8 SU; d SU; a [ S5 e[ R n [ R n O# UR S5 n UR S5 n [ U 4UUU U US.UD6R XFUS 9$ ! [ a n [ S5 U eSn A ff = f) aF Run command with arguments and return a CompletedProcess instance Args: args: A string, or a sequence of program arguments lim: max load limit. This can be a float, an int, an object with a .value property (such as a multiprocessing.Value or cproc.ProcLimit object), or an object with .__int__() defined to allow casting to an int shell (bool): If true, the command will be executed through the shell (unsafe) encoding (str | None): text encoding for subprocess output and input, such as "UTF-8". Set this to None to use no encoding (as bytes) input (bytes | str | None): text to send to stdin. Do not use the stdin= kwarg if you use input= capture_output (bool, optional): Sets stdout and stderr to Proc.PIPE if True. Do not also manually set stdout and stderr if this is set to True timeout (int | float | None): raise Proc.TimeoutExpired if the process takes longer than this number of seconds to execute. Defaults to None check (bool): if True, raise Proc.CalledProcessError if the process exits with a non-zero exit code. The raised object will contain the .returncode attribute. Defaults to False Raises: FileNotFoundError: requested program to execute does not exist Proc.CalledProcessError: program exited with a non-zero exit code and check=True was specified Proc.TimeoutExpired: program took too long to execute and timeout= was specified Returns: Proc.CompletedProcess: contains .args, .returncode, .stdout, and .stdin N�stdinz&stdin and input are mutually exclusiver/ r0 zEstdout and stderr cannot be manually specified if capture_output=Truez=stdout and stderr kwargs are required if capture_output=False)r- r, r/ r0 r. )r9 r: r; )� TypeErrorr* �PIPE�pop�KeyErrorrD ) r5 r- r, r. r9 rF r: r; r6 � stdout_num� stderr_num�key_excs r �run�Proc.run� s� � �b � ��&� � � H�I�I� "�i�i�F�7�O� ��6�!�X��%7� �7�� � ���J� ���J� � #�Z�Z�� 1� � #�Z�Z�� 1� � � � ��� � � � � � � �(��u�(� =� >�� � � �.�� � �� �s �("B* �* C�4 C � C)r- r4 )NNF)r r r r r �srJ �DEVNULL�STDOUT�TimeoutExpiredrB rC r# r$ r �bool�strr �bytesrD � staticmethodrP r' � __classcell__)r7 s @r r* r* 8 s~ �� ��4 �J� �6�6�D��i�i�G� �X�X�F��%�%�N��-�-���)�)�� � )� �5�[�9� $�t� +� )� � )� ��*� )� �d� �)� �d� �)� )�@ %)�&*�� (Q��s�{�T�!�(Q� �u��t�#�(Q� � (Q�T � �$(� $�&*��M>� � M>� ��*� M>� �s�{�T�!� M>� �M>� �u��t�#�M>� �M>� � � �M>� �M>r r* )r r r! �multiprocessingr �collections.abcr � subprocessrR �rads.vzr �monitorr r �Popenr* r( r r �<module>ra s: �� ,� � � %� $� � � �)� )�X|>�1�7�7� |>r
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка