OXIESEC PANEL
- Current Dir:
/
/
snap
/
core
/
17200
/
usr
/
lib
/
python3.5
Server IP: 139.59.38.164
Upload:
Create Dir:
Name
Size
Modified
Perms
📁
..
-
06/06/2024 02:31:58 PM
rwxr-xr-x
📄
LICENSE.txt
12.47 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
__future__.py
4.73 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
__phello__.foo.py
64 bytes
11/22/2023 03:35:00 PM
rw-r--r--
📁
__pycache__
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
_bootlocale.py
1.27 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_collections_abc.py
24.13 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_compat_pickle.py
8.36 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_compression.py
5.21 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_dummy_thread.py
5 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_markupbase.py
14.26 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_osx_support.py
18.66 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_pydecimal.py
222.46 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_pyio.py
85.91 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_sitebuiltins.py
3.04 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_strptime.py
21.67 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_sysconfigdata.py
126 bytes
11/23/2013 12:09:48 PM
rw-r--r--
📄
_threading_local.py
7.24 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
_weakrefset.py
5.57 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
abc.py
8.43 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
aifc.py
30.84 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
antigravity.py
475 bytes
11/22/2023 03:35:00 PM
rw-r--r--
📄
argparse.py
88.21 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
ast.py
11.72 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
asynchat.py
11.69 KB
11/22/2023 03:35:00 PM
rw-r--r--
📁
asyncio
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
asyncore.py
19.63 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
base64.py
19.96 KB
11/22/2023 03:35:15 PM
rwxr-xr-x
📄
bdb.py
22.81 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
binhex.py
13.63 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
bisect.py
2.53 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
bz2.py
12.13 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
cProfile.py
5.19 KB
11/22/2023 03:35:25 PM
rwxr-xr-x
📄
calendar.py
22.4 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
cgi.py
35.19 KB
11/22/2023 03:35:28 PM
rwxr-xr-x
📄
cgitb.py
11.74 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
chunk.py
5.3 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
cmd.py
14.51 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
code.py
9.88 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
codecs.py
35.38 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
codeop.py
5.85 KB
11/22/2023 03:35:00 PM
rw-r--r--
📁
collections
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
colorsys.py
3.97 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
compileall.py
11.42 KB
11/22/2023 03:35:00 PM
rw-r--r--
📁
concurrent
-
02/18/2024 07:58:20 PM
rwxr-xr-x
📄
configparser.py
52.2 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
contextlib.py
11.97 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
copy.py
8.74 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
copyreg.py
6.67 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
crypt.py
1.83 KB
11/22/2023 03:35:00 PM
rw-r--r--
📄
csv.py
15.75 KB
11/22/2023 03:35:00 PM
rw-r--r--
📁
ctypes
-
02/18/2024 07:58:20 PM
rwxr-xr-x
📁
curses
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
datetime.py
74.12 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
dbm
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
decimal.py
320 bytes
11/22/2023 03:35:01 PM
rw-r--r--
📄
difflib.py
82.23 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
dis.py
16.94 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
distutils
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
doctest.py
101.6 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
dummy_threading.py
2.75 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
email
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📁
encodings
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
enum.py
21.71 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
filecmp.py
9.6 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
fileinput.py
13.92 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
fnmatch.py
3.09 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
formatter.py
14.79 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
fractions.py
23.82 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
ftplib.py
34.36 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
functools.py
28.1 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
genericpath.py
4.26 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
getopt.py
7.31 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
getpass.py
5.91 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
gettext.py
18.18 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
glob.py
4.95 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
gzip.py
19.79 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
hashlib.py
7.79 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
heapq.py
22.39 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
hmac.py
4.94 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
html
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📁
http
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📁
idlelib
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
imaplib.py
50.75 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
imghdr.py
3.67 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
imp.py
10.38 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
importlib
-
02/18/2024 07:58:20 PM
rwxr-xr-x
📄
inspect.py
110.66 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
io.py
3.32 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
ipaddress.py
73.83 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
json
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
keyword.py
2.16 KB
11/22/2023 03:35:15 PM
rwxr-xr-x
📁
lib-dynload
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📁
lib2to3
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
linecache.py
5.19 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
locale.py
72.97 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
logging
-
02/18/2024 07:58:20 PM
rwxr-xr-x
📄
lzma.py
12.62 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
macpath.py
5.77 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
macurl2path.py
2.67 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
mailbox.py
76.58 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
mailcap.py
8.21 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
mimetypes.py
20.36 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
modulefinder.py
22.54 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
multiprocessing
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
netrc.py
5.61 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
nntplib.py
42.07 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
ntpath.py
22.26 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
nturl2path.py
2.39 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
numbers.py
10 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
opcode.py
5.75 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
operator.py
10.61 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
optparse.py
58.93 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
os.py
36.1 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
pathlib.py
45.89 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
pdb.py
59.56 KB
11/22/2023 03:35:24 PM
rwxr-xr-x
📄
pickle.py
54.54 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
pickletools.py
89.61 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
pipes.py
8.71 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
pkgutil.py
20.71 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
plat-x86_64-linux-gnu
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
platform.py
47.91 KB
11/22/2023 03:35:15 PM
rwxr-xr-x
📄
plistlib.py
32 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
poplib.py
14.17 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
posixpath.py
14.53 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
pprint.py
20.37 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
profile.py
21.5 KB
11/22/2023 03:35:24 PM
rwxr-xr-x
📄
pstats.py
25.7 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
pty.py
4.65 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
py_compile.py
7.01 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
pyclbr.py
13.25 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
pydoc.py
100.38 KB
11/22/2023 03:35:24 PM
rwxr-xr-x
📁
pydoc_data
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
queue.py
8.57 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
quopri.py
7.08 KB
11/22/2023 03:35:29 PM
rwxr-xr-x
📄
random.py
25.48 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
re.py
15.14 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
reprlib.py
5.21 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
rlcompleter.py
6.16 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
runpy.py
11.13 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
sched.py
6.07 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
selectors.py
18.72 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
shelve.py
8.33 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
shlex.py
11.15 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
shutil.py
38.93 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
signal.py
2.07 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
site.py
21.74 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
sitecustomize.py
0 bytes
01/01/1970 12:00:00 AM
---------
📄
smtpd.py
34.53 KB
11/22/2023 03:35:28 PM
rwxr-xr-x
📄
smtplib.py
42.57 KB
11/22/2023 03:35:26 PM
rwxr-xr-x
📄
sndhdr.py
6.27 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
socket.py
26.46 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
socketserver.py
24.09 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
sqlite3
-
02/18/2024 07:58:20 PM
rwxr-xr-x
📄
sre_compile.py
17.98 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
sre_constants.py
6.3 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
sre_parse.py
34.14 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
ssl.py
42.54 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
stat.py
4.92 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
statistics.py
19.08 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
string.py
11.58 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
stringprep.py
12.61 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
struct.py
257 bytes
11/22/2023 03:35:01 PM
rw-r--r--
📄
subprocess.py
66.8 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
sunau.py
17.67 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
symbol.py
2.04 KB
11/22/2023 03:35:24 PM
rwxr-xr-x
📄
symtable.py
7.02 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
sysconfig.py
24.07 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
tabnanny.py
11.13 KB
11/22/2023 03:35:29 PM
rwxr-xr-x
📄
tarfile.py
90.83 KB
11/22/2023 03:35:26 PM
rwxr-xr-x
📄
telnetlib.py
22.48 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
tempfile.py
30.98 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
test
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
textwrap.py
19.19 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
this.py
1003 bytes
11/22/2023 03:35:01 PM
rw-r--r--
📄
threading.py
47.77 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
timeit.py
12.1 KB
11/22/2023 03:35:25 PM
rwxr-xr-x
📁
tkinter
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
token.py
3 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
tokenize.py
27.14 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
trace.py
30.8 KB
11/22/2023 03:35:29 PM
rwxr-xr-x
📄
traceback.py
21.67 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
tracemalloc.py
15.27 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
tty.py
879 bytes
11/22/2023 03:35:01 PM
rw-r--r--
📄
turtle.py
140.14 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
types.py
8.59 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
typing.py
58.12 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
unittest
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📁
urllib
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
uu.py
6.59 KB
11/22/2023 03:35:24 PM
rwxr-xr-x
📄
uuid.py
22.72 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
venv
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
warnings.py
15.48 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
wave.py
17.27 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
weakref.py
18.95 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
webbrowser.py
20.92 KB
11/22/2023 03:35:26 PM
rwxr-xr-x
📁
wsgiref
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
xdrlib.py
5.77 KB
11/22/2023 03:35:01 PM
rw-r--r--
📁
xml
-
02/18/2024 07:58:20 PM
rwxr-xr-x
📁
xmlrpc
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
zipapp.py
6.99 KB
11/22/2023 03:35:01 PM
rw-r--r--
📄
zipfile.py
71.95 KB
11/22/2023 03:35:01 PM
rw-r--r--
Editing: asynchat.py
Close
# -*- 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 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 as why: 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 class fifo: def __init__(self, list=None): import warnings warnings.warn('fifo class will be removed in Python 3.6', DeprecationWarning, stacklevel=2) if not list: self.list = deque() else: self.list = deque(list) def __len__(self): return len(self.list) def is_empty(self): return not self.list def first(self): return self.list[0] def push(self, data): self.list.append(data) def pop(self): if self.list: return (1, self.list.popleft()) else: return (0, None) # 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