Tatsumi Crew - File Manager

Current Directory

/lib64/python2.7

Type	Name	Operations
	Demo Open
	Doc Open
	Tools Open
	bsddb Open
	compiler Open
	config Open
	ctypes Open
	curses Open
	distutils Open
	email Open
	encodings Open
	ensurepip Open
	hotshot Open
	idlelib Open
	importlib Open
	json Open
	lib-dynload Open
	lib-tk Open
	lib2to3 Open
	logging Open
	multiprocessing Open
	plat-linux2 Open
	pydoc_data Open
	site-packages Open
	sqlite3 Open
	test Open
	unittest Open
	wsgiref Open
	xml Open
	BaseHTTPServer.py	Edit Get
	BaseHTTPServer.pyc	Edit Get
	BaseHTTPServer.pyo	Edit Get
	Bastion.py	Edit Get
	Bastion.pyc	Edit Get
	Bastion.pyo	Edit Get
	CGIHTTPServer.py	Edit Get
	CGIHTTPServer.pyc	Edit Get
	CGIHTTPServer.pyo	Edit Get
	ConfigParser.py	Edit Get
	ConfigParser.pyc	Edit Get
	ConfigParser.pyo	Edit Get
	Cookie.py	Edit Get
	Cookie.pyc	Edit Get
	Cookie.pyo	Edit Get
	DocXMLRPCServer.py	Edit Get
	DocXMLRPCServer.pyc	Edit Get
	DocXMLRPCServer.pyo	Edit Get
	HTMLParser.py	Edit Get
	HTMLParser.pyc	Edit Get
	HTMLParser.pyo	Edit Get
	MimeWriter.py	Edit Get
	MimeWriter.pyc	Edit Get
	MimeWriter.pyo	Edit Get
	Queue.py	Edit Get
	Queue.pyc	Edit Get
	Queue.pyo	Edit Get
	SimpleHTTPServer.py	Edit Get
	SimpleHTTPServer.pyc	Edit Get
	SimpleHTTPServer.pyo	Edit Get
	SimpleXMLRPCServer.py	Edit Get
	SimpleXMLRPCServer.pyc	Edit Get
	SimpleXMLRPCServer.pyo	Edit Get
	SocketServer.py	Edit Get
	SocketServer.pyc	Edit Get
	SocketServer.pyo	Edit Get
	StringIO.py	Edit Get
	StringIO.pyc	Edit Get
	StringIO.pyo	Edit Get
	UserDict.py	Edit Get
	UserDict.pyc	Edit Get
	UserDict.pyo	Edit Get
	UserList.py	Edit Get
	UserList.pyc	Edit Get
	UserList.pyo	Edit Get
	UserString.py	Edit Get
	UserString.pyc	Edit Get
	UserString.pyo	Edit Get
	_LWPCookieJar.py	Edit Get
	_LWPCookieJar.pyc	Edit Get
	_LWPCookieJar.pyo	Edit Get
	_MozillaCookieJar.py	Edit Get
	_MozillaCookieJar.pyc	Edit Get
	_MozillaCookieJar.pyo	Edit Get
	__future__.py	Edit Get
	__future__.pyc	Edit Get
	__future__.pyo	Edit Get
	__phello__.foo.py	Edit Get
	__phello__.foo.pyc	Edit Get
	__phello__.foo.pyo	Edit Get
	_abcoll.py	Edit Get
	_abcoll.pyc	Edit Get
	_abcoll.pyo	Edit Get
	_osx_support.py	Edit Get
	_osx_support.pyc	Edit Get
	_osx_support.pyo	Edit Get
	_pyio.py	Edit Get
	_pyio.pyc	Edit Get
	_pyio.pyo	Edit Get
	_strptime.py	Edit Get
	_strptime.pyc	Edit Get
	_strptime.pyo	Edit Get
	_sysconfigdata.py	Edit Get
	_sysconfigdata.pyc	Edit Get
	_sysconfigdata.pyo	Edit Get
	_threading_local.py	Edit Get
	_threading_local.pyc	Edit Get
	_threading_local.pyo	Edit Get
	_weakrefset.py	Edit Get
	_weakrefset.pyc	Edit Get
	_weakrefset.pyo	Edit Get
	abc.py	Edit Get
	abc.pyc	Edit Get
	abc.pyo	Edit Get
	aifc.py	Edit Get
	aifc.pyc	Edit Get
	aifc.pyo	Edit Get
	antigravity.py	Edit Get
	antigravity.pyc	Edit Get
	antigravity.pyo	Edit Get
	anydbm.py	Edit Get
	anydbm.pyc	Edit Get
	anydbm.pyo	Edit Get
	argparse.py	Edit Get
	argparse.pyc	Edit Get
	argparse.pyo	Edit Get
	ast.py	Edit Get
	ast.pyc	Edit Get
	ast.pyo	Edit Get
	asynchat.py	Edit Get
	asynchat.pyc	Edit Get
	asynchat.pyo	Edit Get
	asyncore.py	Edit Get
	asyncore.pyc	Edit Get
	asyncore.pyo	Edit Get
	atexit.py	Edit Get
	atexit.pyc	Edit Get
	atexit.pyo	Edit Get
	audiodev.py	Edit Get
	audiodev.pyc	Edit Get
	audiodev.pyo	Edit Get
	base64.py	Edit Get
	base64.pyc	Edit Get
	base64.pyo	Edit Get
	bdb.py	Edit Get
	bdb.pyc	Edit Get
	bdb.pyo	Edit Get
	binhex.py	Edit Get
	binhex.pyc	Edit Get
	binhex.pyo	Edit Get
	bisect.py	Edit Get
	bisect.pyc	Edit Get
	bisect.pyo	Edit Get
	cProfile.py	Edit Get
	cProfile.pyc	Edit Get
	cProfile.pyo	Edit Get
	calendar.py	Edit Get
	calendar.pyc	Edit Get
	calendar.pyo	Edit Get
	cgi.py	Edit Get
	cgi.pyc	Edit Get
	cgi.pyo	Edit Get
	cgitb.py	Edit Get
	cgitb.pyc	Edit Get
	cgitb.pyo	Edit Get
	chunk.py	Edit Get
	chunk.pyc	Edit Get
	chunk.pyo	Edit Get
	cmd.py	Edit Get
	cmd.pyc	Edit Get
	cmd.pyo	Edit Get
	code.py	Edit Get
	code.pyc	Edit Get
	code.pyo	Edit Get
	codecs.py	Edit Get
	codecs.pyc	Edit Get
	codecs.pyo	Edit Get
	codeop.py	Edit Get
	codeop.pyc	Edit Get
	codeop.pyo	Edit Get
	collections.py	Edit Get
	collections.pyc	Edit Get
	collections.pyo	Edit Get
	colorsys.py	Edit Get
	colorsys.pyc	Edit Get
	colorsys.pyo	Edit Get
	commands.py	Edit Get
	commands.pyc	Edit Get
	commands.pyo	Edit Get
	compileall.py	Edit Get
	compileall.pyc	Edit Get
	compileall.pyo	Edit Get
	contextlib.py	Edit Get
	contextlib.pyc	Edit Get
	contextlib.pyo	Edit Get
	cookielib.py	Edit Get
	cookielib.pyc	Edit Get
	cookielib.pyo	Edit Get
	copy.py	Edit Get
	copy.pyc	Edit Get
	copy.pyo	Edit Get
	copy_reg.py	Edit Get
	copy_reg.pyc	Edit Get
	copy_reg.pyo	Edit Get
	crypt.py	Edit Get
	crypt.pyc	Edit Get
	crypt.pyo	Edit Get
	csv.py	Edit Get
	csv.pyc	Edit Get
	csv.pyo	Edit Get
	dbhash.py	Edit Get
	dbhash.pyc	Edit Get
	dbhash.pyo	Edit Get
	decimal.py	Edit Get
	decimal.pyc	Edit Get
	decimal.pyo	Edit Get
	difflib.py	Edit Get
	difflib.pyc	Edit Get
	difflib.pyo	Edit Get
	dircache.py	Edit Get
	dircache.pyc	Edit Get
	dircache.pyo	Edit Get
	dis.py	Edit Get
	dis.pyc	Edit Get
	dis.pyo	Edit Get
	doctest.py	Edit Get
	doctest.pyc	Edit Get
	doctest.pyo	Edit Get
	dumbdbm.py	Edit Get
	dumbdbm.pyc	Edit Get
	dumbdbm.pyo	Edit Get
	dummy_thread.py	Edit Get
	dummy_thread.pyc	Edit Get
	dummy_thread.pyo	Edit Get
	dummy_threading.py	Edit Get
	dummy_threading.pyc	Edit Get
	dummy_threading.pyo	Edit Get
	filecmp.py	Edit Get
	filecmp.pyc	Edit Get
	filecmp.pyo	Edit Get
	fileinput.py	Edit Get
	fileinput.pyc	Edit Get
	fileinput.pyo	Edit Get
	fnmatch.py	Edit Get
	fnmatch.pyc	Edit Get
	fnmatch.pyo	Edit Get
	formatter.py	Edit Get
	formatter.pyc	Edit Get
	formatter.pyo	Edit Get
	fpformat.py	Edit Get
	fpformat.pyc	Edit Get
	fpformat.pyo	Edit Get
	fractions.py	Edit Get
	fractions.pyc	Edit Get
	fractions.pyo	Edit Get
	ftplib.py	Edit Get
	ftplib.pyc	Edit Get
	ftplib.pyo	Edit Get
	functools.py	Edit Get
	functools.pyc	Edit Get
	functools.pyo	Edit Get
	genericpath.py	Edit Get
	genericpath.pyc	Edit Get
	genericpath.pyo	Edit Get
	getopt.py	Edit Get
	getopt.pyc	Edit Get
	getopt.pyo	Edit Get
	getpass.py	Edit Get
	getpass.pyc	Edit Get
	getpass.pyo	Edit Get
	gettext.py	Edit Get
	gettext.pyc	Edit Get
	gettext.pyo	Edit Get
	glob.py	Edit Get
	glob.pyc	Edit Get
	glob.pyo	Edit Get
	gzip.py	Edit Get
	gzip.pyc	Edit Get
	gzip.pyo	Edit Get
	hashlib.py	Edit Get
	hashlib.pyc	Edit Get
	hashlib.pyo	Edit Get
	heapq.py	Edit Get
	heapq.pyc	Edit Get
	heapq.pyo	Edit Get
	hmac.py	Edit Get
	hmac.pyc	Edit Get
	hmac.pyo	Edit Get
	htmlentitydefs.py	Edit Get
	htmlentitydefs.pyc	Edit Get
	htmlentitydefs.pyo	Edit Get
	htmllib.py	Edit Get
	htmllib.pyc	Edit Get
	htmllib.pyo	Edit Get
	httplib.py	Edit Get
	httplib.pyc	Edit Get
	httplib.pyo	Edit Get
	ihooks.py	Edit Get
	ihooks.pyc	Edit Get
	ihooks.pyo	Edit Get
	imaplib.py	Edit Get
	imaplib.pyc	Edit Get
	imaplib.pyo	Edit Get
	imghdr.py	Edit Get
	imghdr.pyc	Edit Get
	imghdr.pyo	Edit Get
	imputil.py	Edit Get
	imputil.pyc	Edit Get
	imputil.pyo	Edit Get
	inspect.py	Edit Get
	inspect.pyc	Edit Get
	inspect.pyo	Edit Get
	io.py	Edit Get
	io.pyc	Edit Get
	io.pyo	Edit Get
	keyword.py	Edit Get
	keyword.pyc	Edit Get
	keyword.pyo	Edit Get
	linecache.py	Edit Get
	linecache.pyc	Edit Get
	linecache.pyo	Edit Get
	locale.py	Edit Get
	locale.pyc	Edit Get
	locale.pyo	Edit Get
	macpath.py	Edit Get
	macpath.pyc	Edit Get
	macpath.pyo	Edit Get
	macurl2path.py	Edit Get
	macurl2path.pyc	Edit Get
	macurl2path.pyo	Edit Get
	mailbox.py	Edit Get
	mailbox.pyc	Edit Get
	mailbox.pyo	Edit Get
	mailcap.py	Edit Get
	mailcap.pyc	Edit Get
	mailcap.pyo	Edit Get
	markupbase.py	Edit Get
	markupbase.pyc	Edit Get
	markupbase.pyo	Edit Get
	md5.py	Edit Get
	md5.pyc	Edit Get
	md5.pyo	Edit Get
	mhlib.py	Edit Get
	mhlib.pyc	Edit Get
	mhlib.pyo	Edit Get
	mimetools.py	Edit Get
	mimetools.pyc	Edit Get
	mimetools.pyo	Edit Get
	mimetypes.py	Edit Get
	mimetypes.pyc	Edit Get
	mimetypes.pyo	Edit Get
	mimify.py	Edit Get
	mimify.pyc	Edit Get
	mimify.pyo	Edit Get
	modulefinder.py	Edit Get
	modulefinder.pyc	Edit Get
	modulefinder.pyo	Edit Get
	multifile.py	Edit Get
	multifile.pyc	Edit Get
	multifile.pyo	Edit Get
	mutex.py	Edit Get
	mutex.pyc	Edit Get
	mutex.pyo	Edit Get
	netrc.py	Edit Get
	netrc.pyc	Edit Get
	netrc.pyo	Edit Get
	new.py	Edit Get
	new.pyc	Edit Get
	new.pyo	Edit Get
	nntplib.py	Edit Get
	nntplib.pyc	Edit Get
	nntplib.pyo	Edit Get
	ntpath.py	Edit Get
	ntpath.pyc	Edit Get
	ntpath.pyo	Edit Get
	nturl2path.py	Edit Get
	nturl2path.pyc	Edit Get
	nturl2path.pyo	Edit Get
	numbers.py	Edit Get
	numbers.pyc	Edit Get
	numbers.pyo	Edit Get
	opcode.py	Edit Get
	opcode.pyc	Edit Get
	opcode.pyo	Edit Get
	optparse.py	Edit Get
	optparse.pyc	Edit Get
	optparse.pyo	Edit Get
	os.py	Edit Get
	os.pyc	Edit Get
	os.pyo	Edit Get
	os2emxpath.py	Edit Get
	os2emxpath.pyc	Edit Get
	os2emxpath.pyo	Edit Get
	pdb.doc	Edit Get
	pdb.py	Edit Get
	pdb.pyc	Edit Get
	pdb.pyo	Edit Get
	pickle.py	Edit Get
	pickle.pyc	Edit Get
	pickle.pyo	Edit Get
	pickletools.py	Edit Get
	pickletools.pyc	Edit Get
	pickletools.pyo	Edit Get
	pipes.py	Edit Get
	pipes.pyc	Edit Get
	pipes.pyo	Edit Get
	pkgutil.py	Edit Get
	pkgutil.pyc	Edit Get
	pkgutil.pyo	Edit Get
	platform.py	Edit Get
	platform.pyc	Edit Get
	platform.pyo	Edit Get
	plistlib.py	Edit Get
	plistlib.pyc	Edit Get
	plistlib.pyo	Edit Get
	popen2.py	Edit Get
	popen2.pyc	Edit Get
	popen2.pyo	Edit Get
	poplib.py	Edit Get
	poplib.pyc	Edit Get
	poplib.pyo	Edit Get
	posixfile.py	Edit Get
	posixfile.pyc	Edit Get
	posixfile.pyo	Edit Get
	posixpath.py	Edit Get
	posixpath.pyc	Edit Get
	posixpath.pyo	Edit Get
	pprint.py	Edit Get
	pprint.pyc	Edit Get
	pprint.pyo	Edit Get
	profile.py	Edit Get
	profile.pyc	Edit Get
	profile.pyo	Edit Get
	pstats.py	Edit Get
	pstats.pyc	Edit Get
	pstats.pyo	Edit Get
	pty.py	Edit Get
	pty.pyc	Edit Get
	pty.pyo	Edit Get
	py_compile.py	Edit Get
	py_compile.pyc	Edit Get
	py_compile.pyo	Edit Get
	pyclbr.py	Edit Get
	pyclbr.pyc	Edit Get
	pyclbr.pyo	Edit Get
	pydoc.py	Edit Get
	pydoc.pyc	Edit Get
	pydoc.pyo	Edit Get
	quopri.py	Edit Get
	quopri.pyc	Edit Get
	quopri.pyo	Edit Get
	random.py	Edit Get
	random.pyc	Edit Get
	random.pyo	Edit Get
	re.py	Edit Get
	re.pyc	Edit Get
	re.pyo	Edit Get
	repr.py	Edit Get
	repr.pyc	Edit Get
	repr.pyo	Edit Get
	rexec.py	Edit Get
	rexec.pyc	Edit Get
	rexec.pyo	Edit Get
	rfc822.py	Edit Get
	rfc822.pyc	Edit Get
	rfc822.pyo	Edit Get
	rlcompleter.py	Edit Get
	rlcompleter.pyc	Edit Get
	rlcompleter.pyo	Edit Get
	robotparser.py	Edit Get
	robotparser.pyc	Edit Get
	robotparser.pyo	Edit Get
	runpy.py	Edit Get
	runpy.pyc	Edit Get
	runpy.pyo	Edit Get
	sched.py	Edit Get
	sched.pyc	Edit Get
	sched.pyo	Edit Get
	sets.py	Edit Get
	sets.pyc	Edit Get
	sets.pyo	Edit Get
	sgmllib.py	Edit Get
	sgmllib.pyc	Edit Get
	sgmllib.pyo	Edit Get
	sha.py	Edit Get
	sha.pyc	Edit Get
	sha.pyo	Edit Get
	shelve.py	Edit Get
	shelve.pyc	Edit Get
	shelve.pyo	Edit Get
	shlex.py	Edit Get
	shlex.pyc	Edit Get
	shlex.pyo	Edit Get
	shutil.py	Edit Get
	shutil.pyc	Edit Get
	shutil.pyo	Edit Get
	site.py	Edit Get
	site.pyc	Edit Get
	site.pyo	Edit Get
	smtpd.py	Edit Get
	smtpd.pyc	Edit Get
	smtpd.pyo	Edit Get
	smtplib.py	Edit Get
	smtplib.pyc	Edit Get
	smtplib.pyo	Edit Get
	sndhdr.py	Edit Get
	sndhdr.pyc	Edit Get
	sndhdr.pyo	Edit Get
	socket.py	Edit Get
	socket.pyc	Edit Get
	socket.pyo	Edit Get
	sre.py	Edit Get
	sre.pyc	Edit Get
	sre.pyo	Edit Get
	sre_compile.py	Edit Get
	sre_compile.pyc	Edit Get
	sre_compile.pyo	Edit Get
	sre_constants.py	Edit Get
	sre_constants.pyc	Edit Get
	sre_constants.pyo	Edit Get
	sre_parse.py	Edit Get
	sre_parse.pyc	Edit Get
	sre_parse.pyo	Edit Get
	ssl.py	Edit Get
	ssl.pyc	Edit Get
	ssl.pyo	Edit Get
	stat.py	Edit Get
	stat.pyc	Edit Get
	stat.pyo	Edit Get
	statvfs.py	Edit Get
	statvfs.pyc	Edit Get
	statvfs.pyo	Edit Get
	string.py	Edit Get
	string.pyc	Edit Get
	string.pyo	Edit Get
	stringold.py	Edit Get
	stringold.pyc	Edit Get
	stringold.pyo	Edit Get
	stringprep.py	Edit Get
	stringprep.pyc	Edit Get
	stringprep.pyo	Edit Get
	struct.py	Edit Get
	struct.pyc	Edit Get
	struct.pyo	Edit Get
	subprocess.py	Edit Get
	subprocess.pyc	Edit Get
	subprocess.pyo	Edit Get
	sunau.py	Edit Get
	sunau.pyc	Edit Get
	sunau.pyo	Edit Get
	sunaudio.py	Edit Get
	sunaudio.pyc	Edit Get
	sunaudio.pyo	Edit Get
	symbol.py	Edit Get
	symbol.pyc	Edit Get
	symbol.pyo	Edit Get
	symtable.py	Edit Get
	symtable.pyc	Edit Get
	symtable.pyo	Edit Get
	sysconfig.py	Edit Get
	sysconfig.pyc	Edit Get
	sysconfig.pyo	Edit Get
	tabnanny.py	Edit Get
	tabnanny.pyc	Edit Get
	tabnanny.pyo	Edit Get
	tarfile.py	Edit Get
	tarfile.pyc	Edit Get
	tarfile.pyo	Edit Get
	telnetlib.py	Edit Get
	telnetlib.pyc	Edit Get
	telnetlib.pyo	Edit Get
	tempfile.py	Edit Get
	tempfile.pyc	Edit Get
	tempfile.pyo	Edit Get
	textwrap.py	Edit Get
	textwrap.pyc	Edit Get
	textwrap.pyo	Edit Get
	this.py	Edit Get
	this.pyc	Edit Get
	this.pyo	Edit Get
	threading.py	Edit Get
	threading.pyc	Edit Get
	threading.pyo	Edit Get
	timeit.py	Edit Get
	timeit.pyc	Edit Get
	timeit.pyo	Edit Get
	toaiff.py	Edit Get
	toaiff.pyc	Edit Get
	toaiff.pyo	Edit Get
	token.py	Edit Get
	token.pyc	Edit Get
	token.pyo	Edit Get
	tokenize.py	Edit Get
	tokenize.pyc	Edit Get
	tokenize.pyo	Edit Get
	trace.py	Edit Get
	trace.pyc	Edit Get
	trace.pyo	Edit Get
	traceback.py	Edit Get
	traceback.pyc	Edit Get
	traceback.pyo	Edit Get
	tty.py	Edit Get
	tty.pyc	Edit Get
	tty.pyo	Edit Get
	types.py	Edit Get
	types.pyc	Edit Get
	types.pyo	Edit Get
	urllib.py	Edit Get
	urllib.pyc	Edit Get
	urllib.pyo	Edit Get
	urllib2.py	Edit Get
	urllib2.pyc	Edit Get
	urllib2.pyo	Edit Get
	urlparse.py	Edit Get
	urlparse.pyc	Edit Get
	urlparse.pyo	Edit Get
	user.py	Edit Get
	user.pyc	Edit Get
	user.pyo	Edit Get
	uu.py	Edit Get
	uu.pyc	Edit Get
	uu.pyo	Edit Get
	uuid.py	Edit Get
	uuid.pyc	Edit Get
	uuid.pyo	Edit Get
	warnings.py	Edit Get
	warnings.pyc	Edit Get
	warnings.pyo	Edit Get
	wave.py	Edit Get
	wave.pyc	Edit Get
	wave.pyo	Edit Get
	weakref.py	Edit Get
	weakref.pyc	Edit Get
	weakref.pyo	Edit Get
	webbrowser.py	Edit Get
	webbrowser.pyc	Edit Get
	webbrowser.pyo	Edit Get
	whichdb.py	Edit Get
	whichdb.pyc	Edit Get
	whichdb.pyo	Edit Get
	wsgiref.egg-info	Edit Get
	xdrlib.py	Edit Get
	xdrlib.pyc	Edit Get
	xdrlib.pyo	Edit Get
	xmllib.py	Edit Get
	xmllib.pyc	Edit Get
	xmllib.pyo	Edit Get
	xmlrpclib.py	Edit Get
	xmlrpclib.pyc	Edit Get
	xmlrpclib.pyo	Edit Get
	zipfile.py	Edit Get
	zipfile.pyc	Edit Get
	zipfile.pyo	Edit Get

File Transfer

Upload files to current directory

File Editor: `asyncore.py`

# -*- Mode: Python -*-
#   Id: asyncore.py,v 2.51 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.
# ======================================================================

"""Basic infrastructure for asynchronous socket service clients and servers.

There are only two ways to have a program on a single processor do "more
than one thing at a time".  Multi-threaded programming is the simplest and
most popular way to do it, but there is another very different technique,
that lets you have nearly all the advantages of multi-threading, without
actually using multiple threads. it's really only practical if your program
is largely I/O bound. If your program is CPU bound, then pre-emptive
scheduled threads are probably what you really need. Network servers are
rarely CPU-bound, however.

If your operating system supports the select() system call in its I/O
library (and nearly all do), then you can use it to juggle multiple
communication channels at once; doing other work while your I/O is taking
place in the "background."  Although this strategy can seem strange and
complex, especially at first, it is in many ways easier to understand and
control than multi-threaded programming. The module documented here solves
many of the difficult problems for you, making the task of building
sophisticated high-performance network servers and clients a snap.
"""

import select
import socket
import sys
import time
import warnings

import os
from errno import EALREADY, EINPROGRESS, EWOULDBLOCK, ECONNRESET, EINVAL, \
     ENOTCONN, ESHUTDOWN, EINTR, EISCONN, EBADF, ECONNABORTED, EPIPE, EAGAIN, \
     errorcode

_DISCONNECTED = frozenset((ECONNRESET, ENOTCONN, ESHUTDOWN, ECONNABORTED, EPIPE,
                           EBADF))

try:
    socket_map
except NameError:
    socket_map = {}

def _strerror(err):
    try:
        return os.strerror(err)
    except (ValueError, OverflowError, NameError):
        if err in errorcode:
            return errorcode[err]
        return "Unknown error %s" %err

class ExitNow(Exception):
    pass

_reraised_exceptions = (ExitNow, KeyboardInterrupt, SystemExit)

def read(obj):
    try:
        obj.handle_read_event()
    except _reraised_exceptions:
        raise
    except:
        obj.handle_error()

def write(obj):
    try:
        obj.handle_write_event()
    except _reraised_exceptions:
        raise
    except:
        obj.handle_error()

def _exception(obj):
    try:
        obj.handle_expt_event()
    except _reraised_exceptions:
        raise
    except:
        obj.handle_error()

def readwrite(obj, flags):
    try:
        if flags & select.POLLIN:
            obj.handle_read_event()
        if flags & select.POLLOUT:
            obj.handle_write_event()
        if flags & select.POLLPRI:
            obj.handle_expt_event()
        if flags & (select.POLLHUP | select.POLLERR | select.POLLNVAL):
            obj.handle_close()
    except socket.error, e:
        if e.args[0] not in _DISCONNECTED:
            obj.handle_error()
        else:
            obj.handle_close()
    except _reraised_exceptions:
        raise
    except:
        obj.handle_error()

def poll(timeout=0.0, map=None):
    if map is None:
        map = socket_map
    if map:
        r = []; w = []; e = []
        for fd, obj in map.items():
            is_r = obj.readable()
            is_w = obj.writable()
            if is_r:
                r.append(fd)
            # accepting sockets should not be writable
            if is_w and not obj.accepting:
                w.append(fd)
            if is_r or is_w:
                e.append(fd)
        if [] == r == w == e:
            time.sleep(timeout)
            return

        try:
            r, w, e = select.select(r, w, e, timeout)
        except select.error, err:
            if err.args[0] != EINTR:
                raise
            else:
                return

        for fd in r:
            obj = map.get(fd)
            if obj is None:
                continue
            read(obj)

        for fd in w:
            obj = map.get(fd)
            if obj is None:
                continue
            write(obj)

        for fd in e:
            obj = map.get(fd)
            if obj is None:
                continue
            _exception(obj)

def poll2(timeout=0.0, map=None):
    # Use the poll() support added to the select module in Python 2.0
    if map is None:
        map = socket_map
    if timeout is not None:
        # timeout is in milliseconds
        timeout = int(timeout*1000)
    pollster = select.poll()
    if map:
        for fd, obj in map.items():
            flags = 0
            if obj.readable():
                flags |= select.POLLIN | select.POLLPRI
            # accepting sockets should not be writable
            if obj.writable() and not obj.accepting:
                flags |= select.POLLOUT
            if flags:
                # Only check for exceptions if object was either readable
                # or writable.
                flags |= select.POLLERR | select.POLLHUP | select.POLLNVAL
                pollster.register(fd, flags)
        try:
            r = pollster.poll(timeout)
        except select.error, err:
            if err.args[0] != EINTR:
                raise
            r = []
        for fd, flags in r:
            obj = map.get(fd)
            if obj is None:
                continue
            readwrite(obj, flags)

poll3 = poll2                           # Alias for backward compatibility

def loop(timeout=30.0, use_poll=False, map=None, count=None):
    if map is None:
        map = socket_map

    if use_poll and hasattr(select, 'poll'):
        poll_fun = poll2
    else:
        poll_fun = poll

    if count is None:
        while map:
            poll_fun(timeout, map)

    else:
        while map and count > 0:
            poll_fun(timeout, map)
            count = count - 1

class dispatcher:

    debug = False
    connected = False
    accepting = False
    connecting = False
    closing = False
    addr = None
    ignore_log_types = frozenset(['warning'])

    def __init__(self, sock=None, map=None):
        if map is None:
            self._map = socket_map
        else:
            self._map = map

        self._fileno = None

        if sock:
            # Set to nonblocking just to make sure for cases where we
            # get a socket from a blocking source.
            sock.setblocking(0)
            self.set_socket(sock, map)
            self.connected = True
            # The constructor no longer requires that the socket
            # passed be connected.
            try:
                self.addr = sock.getpeername()
            except socket.error, err:
                if err.args[0] in (ENOTCONN, EINVAL):
                    # To handle the case where we got an unconnected
                    # socket.
                    self.connected = False
                else:
                    # The socket is broken in some unknown way, alert
                    # the user and remove it from the map (to prevent
                    # polling of broken sockets).
                    self.del_channel(map)
                    raise
        else:
            self.socket = None

    def __repr__(self):
        status = [self.__class__.__module__+"."+self.__class__.__name__]
        if self.accepting and self.addr:
            status.append('listening')
        elif self.connected:
            status.append('connected')
        if self.addr is not None:
            try:
                status.append('%s:%d' % self.addr)
            except TypeError:
                status.append(repr(self.addr))
        return '<%s at %#x>' % (' '.join(status), id(self))

    __str__ = __repr__

    def add_channel(self, map=None):
        #self.log_info('adding channel %s' % self)
        if map is None:
            map = self._map
        map[self._fileno] = self

    def del_channel(self, map=None):
        fd = self._fileno
        if map is None:
            map = self._map
        if fd in map:
            #self.log_info('closing channel %d:%s' % (fd, self))
            del map[fd]
        self._fileno = None

    def create_socket(self, family, type):
        self.family_and_type = family, type
        sock = socket.socket(family, type)
        sock.setblocking(0)
        self.set_socket(sock)

    def set_socket(self, sock, map=None):
        self.socket = sock
##        self.__dict__['socket'] = sock
        self._fileno = sock.fileno()
        self.add_channel(map)

    def set_reuse_addr(self):
        # try to re-use a server port if possible
        try:
            self.socket.setsockopt(
                socket.SOL_SOCKET, socket.SO_REUSEADDR,
                self.socket.getsockopt(socket.SOL_SOCKET,
                                       socket.SO_REUSEADDR) | 1
                )
        except socket.error:
            pass

    # ==================================================
    # predicates for select()
    # these are used as filters for the lists of sockets
    # to pass to select().
    # ==================================================

    def readable(self):
        return True

    def writable(self):
        return True

    # ==================================================
    # socket object methods.
    # ==================================================

    def listen(self, num):
        self.accepting = True
        if os.name == 'nt' and num > 5:
            num = 5
        return self.socket.listen(num)

    def bind(self, addr):
        self.addr = addr
        return self.socket.bind(addr)

    def connect(self, address):
        self.connected = False
        self.connecting = True
        err = self.socket.connect_ex(address)
        if err in (EINPROGRESS, EALREADY, EWOULDBLOCK) \
        or err == EINVAL and os.name in ('nt', 'ce'):
            self.addr = address
            return
        if err in (0, EISCONN):
            self.addr = address
            self.handle_connect_event()
        else:
            raise socket.error(err, errorcode[err])

    def accept(self):
        # XXX can return either an address pair or None
        try:
            conn, addr = self.socket.accept()
        except TypeError:
            return None
        except socket.error as why:
            if why.args[0] in (EWOULDBLOCK, ECONNABORTED, EAGAIN):
                return None
            else:
                raise
        else:
            return conn, addr

    def send(self, data):
        try:
            result = self.socket.send(data)
            return result
        except socket.error, why:
            if why.args[0] == EWOULDBLOCK:
                return 0
            elif why.args[0] in _DISCONNECTED:
                self.handle_close()
                return 0
            else:
                raise

    def recv(self, buffer_size):
        try:
            data = self.socket.recv(buffer_size)
            if not data:
                # a closed connection is indicated by signaling
                # a read condition, and having recv() return 0.
                self.handle_close()
                return ''
            else:
                return data
        except socket.error, why:
            # winsock sometimes raises ENOTCONN
            if why.args[0] in _DISCONNECTED:
                self.handle_close()
                return ''
            else:
                raise

    def close(self):
        self.connected = False
        self.accepting = False
        self.connecting = False
        self.del_channel()
        try:
            self.socket.close()
        except socket.error, why:
            if why.args[0] not in (ENOTCONN, EBADF):
                raise

    # cheap inheritance, used to pass all other attribute
    # references to the underlying socket object.
    def __getattr__(self, attr):
        try:
            retattr = getattr(self.socket, attr)
        except AttributeError:
            raise AttributeError("%s instance has no attribute '%s'"
                                 %(self.__class__.__name__, attr))
        else:
            msg = "%(me)s.%(attr)s is deprecated. Use %(me)s.socket.%(attr)s " \
                  "instead." % {'me': self.__class__.__name__, 'attr':attr}
            warnings.warn(msg, DeprecationWarning, stacklevel=2)
            return retattr

    # log and log_info may be overridden to provide more sophisticated
    # logging and warning methods. In general, log is for 'hit' logging
    # and 'log_info' is for informational, warning and error logging.

    def log(self, message):
        sys.stderr.write('log: %s\n' % str(message))

    def log_info(self, message, type='info'):
        if type not in self.ignore_log_types:
            print '%s: %s' % (type, message)

    def handle_read_event(self):
        if self.accepting:
            # accepting sockets are never connected, they "spawn" new
            # sockets that are connected
            self.handle_accept()
        elif not self.connected:
            if self.connecting:
                self.handle_connect_event()
            self.handle_read()
        else:
            self.handle_read()

    def handle_connect_event(self):
        err = self.socket.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR)
        if err != 0:
            raise socket.error(err, _strerror(err))
        self.handle_connect()
        self.connected = True
        self.connecting = False

    def handle_write_event(self):
        if self.accepting:
            # Accepting sockets shouldn't get a write event.
            # We will pretend it didn't happen.
            return

        if not self.connected:
            if self.connecting:
                self.handle_connect_event()
        self.handle_write()

    def handle_expt_event(self):
        # handle_expt_event() is called if there might be an error on the
        # socket, or if there is OOB data
        # check for the error condition first
        err = self.socket.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR)
        if err != 0:
            # we can get here when select.select() says that there is an
            # exceptional condition on the socket
            # since there is an error, we'll go ahead and close the socket
            # like we would in a subclassed handle_read() that received no
            # data
            self.handle_close()
        else:
            self.handle_expt()

    def handle_error(self):
        nil, t, v, tbinfo = compact_traceback()

        # sometimes a user repr method will crash.
        try:
            self_repr = repr(self)
        except:
            self_repr = '<__repr__(self) failed for object at %0x>' % id(self)

        self.log_info(
            'uncaptured python exception, closing channel %s (%s:%s %s)' % (
                self_repr,
                t,
                v,
                tbinfo
                ),
            'error'
            )
        self.handle_close()

    def handle_expt(self):
        self.log_info('unhandled incoming priority event', 'warning')

    def handle_read(self):
        self.log_info('unhandled read event', 'warning')

    def handle_write(self):
        self.log_info('unhandled write event', 'warning')

    def handle_connect(self):
        self.log_info('unhandled connect event', 'warning')

    def handle_accept(self):
        self.log_info('unhandled accept event', 'warning')

    def handle_close(self):
        self.log_info('unhandled close event', 'warning')
        self.close()

# ---------------------------------------------------------------------------
# adds simple buffered output capability, useful for simple clients.
# [for more sophisticated usage use asynchat.async_chat]
# ---------------------------------------------------------------------------

class dispatcher_with_send(dispatcher):

    def __init__(self, sock=None, map=None):
        dispatcher.__init__(self, sock, map)
        self.out_buffer = ''

    def initiate_send(self):
        num_sent = 0
        num_sent = dispatcher.send(self, self.out_buffer[:512])
        self.out_buffer = self.out_buffer[num_sent:]

    def handle_write(self):
        self.initiate_send()

    def writable(self):
        return (not self.connected) or len(self.out_buffer)

    def send(self, data):
        if self.debug:
            self.log_info('sending %s' % repr(data))
        self.out_buffer = self.out_buffer + data
        self.initiate_send()

# ---------------------------------------------------------------------------
# used for debugging.
# ---------------------------------------------------------------------------

def compact_traceback():
    t, v, tb = sys.exc_info()
    tbinfo = []
    if not tb: # Must have a traceback
        raise AssertionError("traceback does not exist")
    while tb:
        tbinfo.append((
            tb.tb_frame.f_code.co_filename,
            tb.tb_frame.f_code.co_name,
            str(tb.tb_lineno)
            ))
        tb = tb.tb_next

    # just to be safe
    del tb

    file, function, line = tbinfo[-1]
    info = ' '.join(['[%s|%s|%s]' % x for x in tbinfo])
    return (file, function, line), t, v, info

def close_all(map=None, ignore_all=False):
    if map is None:
        map = socket_map
    for x in map.values():
        try:
            x.close()
        except OSError, x:
            if x.args[0] == EBADF:
                pass
            elif not ignore_all:
                raise
        except _reraised_exceptions:
            raise
        except:
            if not ignore_all:
                raise
    map.clear()

# Asynchronous File I/O:
#
# After a little research (reading man pages on various unixen, and
# digging through the linux kernel), I've determined that select()
# isn't meant for doing asynchronous file i/o.
# Heartening, though - reading linux/mm/filemap.c shows that linux
# supports asynchronous read-ahead.  So _MOST_ of the time, the data
# will be sitting in memory for us already when we go to read it.
#
# What other OS's (besides NT) support async file i/o?  [VMS?]
#
# Regardless, this is useful for pipes, and stdin/stdout...

if os.name == 'posix':
    import fcntl

    class file_wrapper:
        # Here we override just enough to make a file
        # look like a socket for the purposes of asyncore.
        # The passed fd is automatically os.dup()'d

        def __init__(self, fd):
            self.fd = os.dup(fd)

        def recv(self, *args):
            return os.read(self.fd, *args)

        def send(self, *args):
            return os.write(self.fd, *args)

        def getsockopt(self, level, optname, buflen=None):
            if (level == socket.SOL_SOCKET and
                optname == socket.SO_ERROR and
                not buflen):
                return 0
            raise NotImplementedError("Only asyncore specific behaviour "
                                      "implemented.")

        read = recv
        write = send

        def close(self):
            if self.fd < 0:
                return
            fd = self.fd
            self.fd = -1
            os.close(fd)

        def fileno(self):
            return self.fd

    class file_dispatcher(dispatcher):

        def __init__(self, fd, map=None):
            dispatcher.__init__(self, None, map)
            self.connected = True
            try:
                fd = fd.fileno()
            except AttributeError:
                pass
            self.set_file(fd)
            # set it to non-blocking mode
            flags = fcntl.fcntl(fd, fcntl.F_GETFL, 0)
            flags = flags | os.O_NONBLOCK
            fcntl.fcntl(fd, fcntl.F_SETFL, flags)

        def set_file(self, fd):
            self.socket = file_wrapper(fd)
            self._fileno = self.socket.fileno()
            self.add_channel()

Current Directory

File Transfer

File Editor: asyncore.py

File Editor: `asyncore.py`