ACIL FM

Nama	Ukuran	Aksi
asyncio	-	Open
collections	-	Open
concurrent	-	Open
config-3.10-x86_64-linux-gnu	-	Open
ctypes	-	Open
curses	-	Open
dbm	-	Open
distutils	-	Open
email	-	Open
encodings	-	Open
ensurepip	-	Open
html	-	Open
http	-	Open
importlib	-	Open
json	-	Open
lib-dynload	-	Open
lib2to3	-	Open
logging	-	Open
multiprocessing	-	Open
pydoc_data	-	Open
site-packages	-	Open
sqlite3	-	Open
unittest	-	Open
urllib	-	Open
venv	-	Open
wsgiref	-	Open
xml	-	Open
xmlrpc	-	Open
zoneinfo	-	Open
__pycache__	-	Open
abc.py	6.37 MB	View DL Edit
aifc.py	31.84 MB	View DL Edit
antigravity.py	500 B	View DL Edit
argparse.py	96.23 MB	View DL Edit
ast.py	58.5 MB	View DL Edit
asynchat.py	11.25 MB	View DL Edit
asyncore.py	19.79 MB	View DL Edit
base64.py	20.37 MB	View DL Edit
bdb.py	31.64 MB	View DL Edit
binhex.py	14.44 MB	View DL Edit
bisect.py	3.06 MB	View DL Edit
bz2.py	11.57 MB	View DL Edit
calendar.py	24 MB	View DL Edit
cgi.py	33.31 MB	View DL Edit
cgitb.py	11.81 MB	View DL Edit
chunk.py	5.31 MB	View DL Edit
cmd.py	14.51 MB	View DL Edit
code.py	10.37 MB	View DL Edit
codecs.py	35.85 MB	View DL Edit
codeop.py	5.48 MB	View DL Edit
colorsys.py	3.92 MB	View DL Edit
compileall.py	19.78 MB	View DL Edit
configparser.py	53.33 MB	View DL Edit
contextlib.py	25.28 MB	View DL Edit
contextvars.py	129 B	View DL Edit
copy.py	8.48 MB	View DL Edit
copyreg.py	7.25 MB	View DL Edit
cProfile.py	6.21 MB	View DL Edit
crypt.py	3.76 MB	View DL Edit
csv.py	15.65 MB	View DL Edit
dataclasses.py	55.07 MB	View DL Edit
datetime.py	86.02 MB	View DL Edit
decimal.py	320 B	View DL Edit
difflib.py	81.36 MB	View DL Edit
dis.py	19.55 MB	View DL Edit
doctest.py	102.68 MB	View DL Edit
enum.py	38.9 MB	View DL Edit
filecmp.py	9.94 MB	View DL Edit
fileinput.py	16.06 MB	View DL Edit
fnmatch.py	6.56 MB	View DL Edit
fractions.py	27.58 MB	View DL Edit
ftplib.py	34.66 MB	View DL Edit
functools.py	37.18 MB	View DL Edit
genericpath.py	5.12 MB	View DL Edit
getopt.py	7.31 MB	View DL Edit
getpass.py	5.85 MB	View DL Edit
gettext.py	26.63 MB	View DL Edit
glob.py	7.7 MB	View DL Edit
graphlib.py	9.35 MB	View DL Edit
gzip.py	21.34 MB	View DL Edit
hashlib.py	9.99 MB	View DL Edit
heapq.py	22.34 MB	View DL Edit
hmac.py	7.54 MB	View DL Edit
imaplib.py	53.92 MB	View DL Edit
imghdr.py	3.72 MB	View DL Edit
imp.py	10.34 MB	View DL Edit
inspect.py	121.46 MB	View DL Edit
io.py	4.1 MB	View DL Edit
ipaddress.py	78.94 MB	View DL Edit
keyword.py	1.04 MB	View DL Edit
LICENSE.txt	13.61 MB	View DL Edit
linecache.py	5.56 MB	View DL Edit
locale.py	76.29 MB	View DL Edit
lzma.py	12.97 MB	View DL Edit
mailbox.py	76.95 MB	View DL Edit
mailcap.py	8.9 MB	View DL Edit
mimetypes.py	22.01 MB	View DL Edit
modulefinder.py	23.83 MB	View DL Edit
netrc.py	5.61 MB	View DL Edit
nntplib.py	40.06 MB	View DL Edit
ntpath.py	29.24 MB	View DL Edit
nturl2path.py	2.82 MB	View DL Edit
numbers.py	10.11 MB	View DL Edit
opcode.py	5.76 MB	View DL Edit
operator.py	10.5 MB	View DL Edit
optparse.py	58.95 MB	View DL Edit
os.py	38.63 MB	View DL Edit
pathlib.py	48.41 MB	View DL Edit
pdb.py	61.76 MB	View DL Edit
pickle.py	63.43 MB	View DL Edit
pickletools.py	91.29 MB	View DL Edit
pipes.py	8.71 MB	View DL Edit
pkgutil.py	24 MB	View DL Edit
platform.py	41.05 MB	View DL Edit
plistlib.py	27.69 MB	View DL Edit
poplib.py	14.84 MB	View DL Edit
posixpath.py	16.05 MB	View DL Edit
pprint.py	23.87 MB	View DL Edit
profile.py	22.36 MB	View DL Edit
pstats.py	28.64 MB	View DL Edit
pty.py	5.09 MB	View DL Edit
pyclbr.py	11.13 MB	View DL Edit
pydoc.py	107.03 MB	View DL Edit
py_compile.py	7.71 MB	View DL Edit
queue.py	11.23 MB	View DL Edit
quopri.py	7.11 MB	View DL Edit
random.py	32.44 MB	View DL Edit
re.py	15.49 MB	View DL Edit
reprlib.py	5.14 MB	View DL Edit
rlcompleter.py	7.63 MB	View DL Edit
runpy.py	12.8 MB	View DL Edit
sched.py	6.2 MB	View DL Edit
secrets.py	1.99 MB	View DL Edit
selectors.py	19.08 MB	View DL Edit
shelve.py	8.36 MB	View DL Edit
shlex.py	13.18 MB	View DL Edit
shutil.py	53.29 MB	View DL Edit
signal.py	2.38 MB	View DL Edit
site.py	22.39 MB	View DL Edit
smtpd.py	34.35 MB	View DL Edit
smtplib.py	44.37 MB	View DL Edit
sndhdr.py	6.93 MB	View DL Edit
socket.py	36.14 MB	View DL Edit
socketserver.py	26.66 MB	View DL Edit
sre_compile.py	27.32 MB	View DL Edit
sre_constants.py	7.01 MB	View DL Edit
sre_parse.py	39.82 MB	View DL Edit
ssl.py	52.63 MB	View DL Edit
stat.py	5.36 MB	View DL Edit
statistics.py	42.19 MB	View DL Edit
string.py	10.32 MB	View DL Edit
stringprep.py	12.61 MB	View DL Edit
struct.py	257 B	View DL Edit
subprocess.py	82.93 MB	View DL Edit
sunau.py	17.73 MB	View DL Edit
symtable.py	9.98 MB	View DL Edit
sysconfig.py	26.96 MB	View DL Edit
tabnanny.py	11.05 MB	View DL Edit
tarfile.py	108.99 MB	View DL Edit
telnetlib.py	22.71 MB	View DL Edit
tempfile.py	28.78 MB	View DL Edit
textwrap.py	19.31 MB	View DL Edit
this.py	1003 B	View DL Edit
threading.py	55.41 MB	View DL Edit
timeit.py	13.19 MB	View DL Edit
token.py	2.33 MB	View DL Edit
tokenize.py	25.31 MB	View DL Edit
trace.py	28.54 MB	View DL Edit
traceback.py	25.61 MB	View DL Edit
tracemalloc.py	17.62 MB	View DL Edit
tty.py	879 B	View DL Edit
types.py	9.88 MB	View DL Edit
typing.py	90.39 MB	View DL Edit
uu.py	7.11 MB	View DL Edit
uuid.py	26.86 MB	View DL Edit
warnings.py	19.23 MB	View DL Edit
wave.py	17.58 MB	View DL Edit
weakref.py	21.05 MB	View DL Edit
webbrowser.py	23.69 MB	View DL Edit
xdrlib.py	5.77 MB	View DL Edit
zipapp.py	7.36 MB	View DL Edit
zipfile.py	88.09 MB	View DL Edit
zipimport.py	30.17 MB	View DL Edit
_aix_support.py	3.19 MB	View DL Edit
_bootsubprocess.py	2.61 MB	View DL Edit
_collections_abc.py	31.53 MB	View DL Edit
_compat_pickle.py	8.54 MB	View DL Edit
_compression.py	5.55 MB	View DL Edit
_markupbase.py	14.31 MB	View DL Edit
_osx_support.py	21.28 MB	View DL Edit
_pydecimal.py	223.32 MB	View DL Edit
_pyio.py	92.25 MB	View DL Edit
_py_abc.py	6.04 MB	View DL Edit
_sitebuiltins.py	3.05 MB	View DL Edit
_strptime.py	24.68 MB	View DL Edit
_sysconfigdata_d_linux_x86_64-linux-gnu.py	40.14 MB	View DL Edit
_sysconfigdata__linux_x86_64-linux-gnu.py	40.71 MB	View DL Edit
_threading_local.py	7.05 MB	View DL Edit
_weakrefset.py	5.78 MB	View DL Edit
__future__.py	5.03 MB	View DL Edit
__phello__.foo.py	64 B	View DL Edit

Edit file: /opt/alt/python310/lib64/python3.10/asynchat.py

# -*- Mode: Python; tab-width: 4 -*-
#       Id: asynchat.py,v 2.26 2000/09/07 22:29:26 rushing Exp
#       Author: Sam Rushing <rushing@nightmare.com>

# ======================================================================
# Copyright 1996 by Sam Rushing
#
#                         All Rights Reserved
#
# Permission to use, copy, modify, and distribute this software and
# its documentation for any purpose and without fee is hereby
# granted, provided that the above copyright notice appear in all
# copies and that both that copyright notice and this permission
# notice appear in supporting documentation, and that the name of Sam
# Rushing not be used in advertising or publicity pertaining to
# distribution of the software without specific, written prior
# permission.
#
# SAM RUSHING DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE,
# INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN
# NO EVENT SHALL SAM RUSHING BE LIABLE FOR ANY SPECIAL, INDIRECT OR
# CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
# OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT,
# NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN
# CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
# ======================================================================

r"""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.
"""
import asyncore
from collections import deque

from warnings import warn
warn(
    'The asynchat module is deprecated and will be removed in Python 3.12. '
    'The recommended replacement is asyncio',
    DeprecationWarning,
    stacklevel=2)

class async_chat(asyncore.dispatcher):
    """This is an abstract class.  You must derive from this class, and add
    the two methods collect_incoming_data() and found_terminator()"""

# these are overridable defaults

ac_in_buffer_size = 65536
    ac_out_buffer_size = 65536

# we don't want to enable the use of encoding by default, because that is a
    # sign of an application bug that we don't want to pass silently

use_encoding = 0
    encoding = 'latin-1'

def __init__(self, sock=None, map=None):
        # for string terminator matching
        self.ac_in_buffer = b''

# we use a list here rather than io.BytesIO for a few reasons...
        # del lst[:] is faster than bio.truncate(0)
        # lst = [] is faster than bio.truncate(0)
        self.incoming = []

# we toss the use of the "simple producer" and replace it with
        # a pure deque, which the original fifo was a wrapping of
        self.producer_fifo = deque()
        asyncore.dispatcher.__init__(self, sock, map)

def collect_incoming_data(self, data):
        raise NotImplementedError("must be implemented in subclass")

def _collect_incoming_data(self, data):
        self.incoming.append(data)

def _get_data(self):
        d = b''.join(self.incoming)
        del self.incoming[:]
        return d

def found_terminator(self):
        raise NotImplementedError("must be implemented in subclass")

def set_terminator(self, term):
        """Set the input delimiter.

Can be a fixed string of any length, an integer, or None.
        """
        if isinstance(term, str) and self.use_encoding:
            term = bytes(term, self.encoding)
        elif isinstance(term, int) and term < 0:
            raise ValueError('the number of received bytes must be positive')
        self.terminator = term

def get_terminator(self):
        return self.terminator

# grab some more data from the socket,
    # throw it to the collector method,
    # check for the terminator,
    # if found, transition to the next state.

def handle_read(self):

try:
            data = self.recv(self.ac_in_buffer_size)
        except BlockingIOError:
            return
        except OSError:
            self.handle_error()
            return

if isinstance(data, str) and self.use_encoding:
            data = bytes(str, self.encoding)
        self.ac_in_buffer = self.ac_in_buffer + data

# Continue to search for self.terminator in self.ac_in_buffer,
        # while calling self.collect_incoming_data.  The while loop
        # is necessary because we might read several data+terminator
        # combos with a single recv(4096).

while self.ac_in_buffer:
            lb = len(self.ac_in_buffer)
            terminator = self.get_terminator()
            if not terminator:
                # no terminator, collect it all
                self.collect_incoming_data(self.ac_in_buffer)
                self.ac_in_buffer = b''
            elif isinstance(terminator, int):
                # numeric terminator
                n = terminator
                if lb < n:
                    self.collect_incoming_data(self.ac_in_buffer)
                    self.ac_in_buffer = b''
                    self.terminator = self.terminator - lb
                else:
                    self.collect_incoming_data(self.ac_in_buffer[:n])
                    self.ac_in_buffer = self.ac_in_buffer[n:]
                    self.terminator = 0
                    self.found_terminator()
            else:
                # 3 cases:
                # 1) end of buffer matches terminator exactly:
                #    collect data, transition
                # 2) end of buffer matches some prefix:
                #    collect data to the prefix
                # 3) end of buffer does not match any prefix:
                #    collect data
                terminator_len = len(terminator)
                index = self.ac_in_buffer.find(terminator)
                if index != -1:
                    # we found the terminator
                    if index > 0:
                        # don't bother reporting the empty string
                        # (source of subtle bugs)
                        self.collect_incoming_data(self.ac_in_buffer[:index])
                    self.ac_in_buffer = self.ac_in_buffer[index+terminator_len:]
                    # This does the Right Thing if the terminator
                    # is changed here.
                    self.found_terminator()
                else:
                    # check for a prefix of the terminator
                    index = find_prefix_at_end(self.ac_in_buffer, terminator)
                    if index:
                        if index != lb:
                            # we found a prefix, collect up to the prefix
                            self.collect_incoming_data(self.ac_in_buffer[:-index])
                            self.ac_in_buffer = self.ac_in_buffer[-index:]
                        break
                    else:
                        # no prefix, collect it all
                        self.collect_incoming_data(self.ac_in_buffer)
                        self.ac_in_buffer = b''

def handle_write(self):
        self.initiate_send()

def handle_close(self):
        self.close()

def push(self, data):
        if not isinstance(data, (bytes, bytearray, memoryview)):
            raise TypeError('data argument must be byte-ish (%r)',
                            type(data))
        sabs = self.ac_out_buffer_size
        if len(data) > sabs:
            for i in range(0, len(data), sabs):
                self.producer_fifo.append(data[i:i+sabs])
        else:
            self.producer_fifo.append(data)
        self.initiate_send()

def push_with_producer(self, producer):
        self.producer_fifo.append(producer)
        self.initiate_send()

def readable(self):
        "predicate for inclusion in the readable for select()"
        # cannot use the old predicate, it violates the claim of the
        # set_terminator method.

# return (len(self.ac_in_buffer) <= self.ac_in_buffer_size)
        return 1

def writable(self):
        "predicate for inclusion in the writable for select()"
        return self.producer_fifo or (not self.connected)

def close_when_done(self):
        "automatically close this channel once the outgoing queue is empty"
        self.producer_fifo.append(None)

def initiate_send(self):
        while self.producer_fifo and self.connected:
            first = self.producer_fifo[0]
            # handle empty string/buffer or None entry
            if not first:
                del self.producer_fifo[0]
                if first is None:
                    self.handle_close()
                    return

# handle classic producer behavior
            obs = self.ac_out_buffer_size
            try:
                data = first[:obs]
            except TypeError:
                data = first.more()
                if data:
                    self.producer_fifo.appendleft(data)
                else:
                    del self.producer_fifo[0]
                continue

if isinstance(data, str) and self.use_encoding:
                data = bytes(data, self.encoding)

# send the data
            try:
                num_sent = self.send(data)
            except OSError:
                self.handle_error()
                return

if num_sent:
                if num_sent < len(data) or obs < len(first):
                    self.producer_fifo[0] = first[num_sent:]
                else:
                    del self.producer_fifo[0]
            # we tried to send some actual data
            return

def discard_buffers(self):
        # Emergencies only!
        self.ac_in_buffer = b''
        del self.incoming[:]
        self.producer_fifo.clear()

class simple_producer:

def __init__(self, data, buffer_size=512):
        self.data = data
        self.buffer_size = buffer_size

def more(self):
        if len(self.data) > self.buffer_size:
            result = self.data[:self.buffer_size]
            self.data = self.data[self.buffer_size:]
            return result
        else:
            result = self.data
            self.data = b''
            return result

# Given 'haystack', see if any prefix of 'needle' is at its end.  This
# assumes an exact match has already been checked.  Return the number of
# characters matched.
# for example:
# f_p_a_e("qwerty\r", "\r\n") => 1
# f_p_a_e("qwertydkjf", "\r\n") => 0
# f_p_a_e("qwerty\r\n", "\r\n") => <undefined>

# this could maybe be made faster with a computed regex?
# [answer: no; circa Python-2.0, Jan 2001]
# new python:   28961/s
# old python:   18307/s
# re:        12820/s
# regex:     14035/s

def find_prefix_at_end(haystack, needle):
    l = len(needle) - 1
    while l and not haystack.endswith(needle[:l]):
        l -= 1
    return l

Batal