cengal.parallel_execution.asyncio.efficient_streams.versions.v_0.efficient_streams_base_internal
Module Docstring Docstrings: http://www.python.org/dev/peps/pep-0257/
1#!/usr/bin/env python 2# coding=utf-8 3 4# Copyright © 2012-2024 ButenkoMS. All rights reserved. Contacts: <gtalk@butenkoms.space> 5# 6# Licensed under the Apache License, Version 2.0 (the "License"); 7# you may not use this file except in compliance with the License. 8# You may obtain a copy of the License at 9# 10# http://www.apache.org/licenses/LICENSE-2.0 11# 12# Unless required by applicable law or agreed to in writing, software 13# distributed under the License is distributed on an "AS IS" BASIS, 14# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 15# See the License for the specific language governing permissions and 16# limitations under the License. 17 18 19""" 20Module Docstring 21Docstrings: http://www.python.org/dev/peps/pep-0257/ 22""" 23 24 25__author__ = "ButenkoMS <gtalk@butenkoms.space>" 26__copyright__ = "Copyright © 2012-2024 ButenkoMS. All rights reserved. Contacts: <gtalk@butenkoms.space>" 27__credits__ = ["ButenkoMS <gtalk@butenkoms.space>", ] 28__license__ = "Apache License, Version 2.0" 29__version__ = "4.4.1" 30__maintainer__ = "ButenkoMS <gtalk@butenkoms.space>" 31__email__ = "gtalk@butenkoms.space" 32# __status__ = "Prototype" 33__status__ = "Development" 34# __status__ = "Production" 35 36 37from typing import Optional 38 39 40DEFAULT_PROTOCOL_GREETING = b'<<MessageProtocol>>' 41MESSAGE_SIZE_MAX_POSSIBLE_LEN = 8 42MESSAGE_SIZE_LEN = MESSAGE_SIZE_MAX_POSSIBLE_LEN 43SERVER_ANSWER__KEYWORD_ACCEPTED = b'OK' 44 45 46# DEFAULT_LIMIT = 2 ** 24 # 64 KiB 47# DEFAULT_LIMIT = cpu_info().l2_cache_size_per_virtual_core 48# DEFAULT_LIMIT = cpu_info().l3_cache_size 49DEFAULT_LIMIT = 10 * 1024**2 50 51 52class MessageProtocolSettings: 53 def __init__(self, protocol_greeting: Optional[str], message_size_len: Optional[int], max_message_size_len: Optional[int]) -> None: 54 self.protocol_greeting = protocol_greeting or DEFAULT_PROTOCOL_GREETING 55 self.max_message_size_len = max_message_size_len or MESSAGE_SIZE_MAX_POSSIBLE_LEN 56 self.message_size_len = message_size_len or MESSAGE_SIZE_LEN
DEFAULT_PROTOCOL_GREETING =
b'<<MessageProtocol>>'
MESSAGE_SIZE_MAX_POSSIBLE_LEN =
8
MESSAGE_SIZE_LEN =
8
SERVER_ANSWER__KEYWORD_ACCEPTED =
b'OK'
DEFAULT_LIMIT =
10485760
class
MessageProtocolSettings:
53class MessageProtocolSettings: 54 def __init__(self, protocol_greeting: Optional[str], message_size_len: Optional[int], max_message_size_len: Optional[int]) -> None: 55 self.protocol_greeting = protocol_greeting or DEFAULT_PROTOCOL_GREETING 56 self.max_message_size_len = max_message_size_len or MESSAGE_SIZE_MAX_POSSIBLE_LEN 57 self.message_size_len = message_size_len or MESSAGE_SIZE_LEN
MessageProtocolSettings( protocol_greeting: Union[str, NoneType], message_size_len: Union[int, NoneType], max_message_size_len: Union[int, NoneType])
54 def __init__(self, protocol_greeting: Optional[str], message_size_len: Optional[int], max_message_size_len: Optional[int]) -> None: 55 self.protocol_greeting = protocol_greeting or DEFAULT_PROTOCOL_GREETING 56 self.max_message_size_len = max_message_size_len or MESSAGE_SIZE_MAX_POSSIBLE_LEN 57 self.message_size_len = message_size_len or MESSAGE_SIZE_LEN