"""

class HStack:

"""

def __init__(self, req):

self.req = req

def pop(self):

handlers = self.req.hstack.split()

if not handlers:

return None

else:

self.req.hstack = " ".join(handlers[1:])

return handlers[0]

def ConnectionDispatch(self, conn):

# config

config, debug = conn.base_server.get_config(), False

if "PythonDebug" in config:

debug = config["PythonDebug"] == "1"

try:

handler = conn.hlist.handler

# split module::handler

l = handler.split('::', 1)

module_name = l[0]

if len(l) == 1:

# no oject, provide default

obj_str = "connectionhandler"

else:

obj_str = l[1]

# evaluate pythonpath and set sys.path to

# resulting value if not already done

if "PythonPath" in config:

_path_cache_lock.acquire()

try:

pathstring = config["PythonPath"]

if pathstring not in _path_cache:

newpath = eval(pathstring)

_path_cache[pathstring] = None

sys.path[:] = newpath

finally:

_path_cache_lock.release()

# import module

autoreload = True

if "PythonAutoReload" in config:

autoreload = config["PythonAutoReload"] == "1"

module = import_module(module_name,

autoreload=autoreload,

log=debug)

# find the object

obj = resolve_object(module, obj_str,

arg=conn, silent=0)

# Only permit debugging using pdb if Apache has

# actually been started in single process mode.

pdb_debug = False

if "PythonEnablePdb" in config:

pdb_debug = config["PythonEnablePdb"] == "1"

if pdb_debug and exists_config_define("ONE_PROCESS"):

# Don't use pdb.runcall() as it results in

# a bogus 'None' response when pdb session

# is quit. With this code the exception

# marking that the session has been quit is

# propogated back up and it is obvious in

# the error message what actually occurred.

debugger = pdb.Pdb()

debugger.reset()

sys.settrace(debugger.trace_dispatch)

try:

result = obj(conn)

finally:

debugger.quitting = 1

sys.settrace(None)

else:

result = obj(conn)

assert (result.__class__ is int), \

"ConnectionHandler '%s' returned invalid return code." % handler

except:

# Error (usually parsing)

try:

exc_type, exc_value, exc_traceback = sys.exc_info()

result = self.ReportError(exc_type, exc_value, exc_traceback, srv=conn.base_server,

phase="ConnectionHandler",

hname=handler, debug=debug)

finally:

exc_traceback = None

return result

def FilterDispatch(self, fltr):

req = fltr.req

# config

config, debug = req.get_config(), False

if "PythonDebug" in config:

debug = config["PythonDebug"] == "1"

try:

# split module::handler

l = fltr.handler.split('::', 1)

module_name = l[0]

if len(l) == 1:

# no oject, provide default

if fltr.is_input:

obj_str = "inputfilter"

else:

obj_str = "outputfilter"

else:

obj_str = l[1]

# add the directory to pythonpath if

# not there yet, or evaluate pythonpath

# and set sys.path to resulting value

# if not already done

if "PythonPath" in config:

_path_cache_lock.acquire()

try:

pathstring = config["PythonPath"]

if pathstring not in _path_cache:

newpath = eval(pathstring)

_path_cache[pathstring] = None

sys.path[:] = newpath

finally:

_path_cache_lock.release()

else:

if fltr.dir:

_path_cache_lock.acquire()

try:

if fltr.dir not in sys.path:

sys.path[:0] = [fltr.dir]

finally:

_path_cache_lock.release()

# import module

autoreload = True

if "PythonAutoReload" in config:

autoreload = config["PythonAutoReload"] == "1"

module = import_module(module_name,

autoreload=autoreload,

log=debug)

# find the object

obj = resolve_object(module, obj_str,

arg=fltr, silent=0)

# Only permit debugging using pdb if Apache has

# actually been started in single process mode.

pdb_debug = False

if "PythonEnablePdb" in config:

pdb_debug = config["PythonEnablePdb"] == "1"

if pdb_debug and exists_config_define("ONE_PROCESS"):

# Don't use pdb.runcall() as it results in

# a bogus 'None' response when pdb session

# is quit. With this code the exception

# marking that the session has been quit is

# propogated back up and it is obvious in

# the error message what actually occurred.

debugger = pdb.Pdb()

debugger.reset()

sys.settrace(debugger.trace_dispatch)

try:

result = obj(fltr)

finally:

debugger.quitting = 1

sys.settrace(None)

else:

result = obj(fltr)

# always flush the filter. without a FLUSH or EOS bucket,

# the content is never written to the network.

# XXX an alternative is to tell the user to flush() always

if not fltr.closed:

fltr.flush()

except SERVER_RETURN as value:

# SERVER_RETURN indicates a non-local abort from below

# with value as (result, status) or (result, None) or result

try:

if len(value.args) == 2:

(result, status) = value.args

if status:

req.status = status

else:

result = value.args[0]

if result.__class__ is not int:

s = "Value raised with SERVER_RETURN is invalid. It is a "

s = s + "%s, but it must be a tuple or an int." % result.__class__

_apache.log_error(s, APLOG_ERR, req.server)

return

except:

pass

except:

# Error (usually parsing)

try:

exc_type, exc_value, exc_traceback = sys.exc_info()

fltr.disable()

result = self.ReportError(exc_type, exc_value, exc_traceback, req=req, filter=fltr,

phase=fltr.name, hname=fltr.handler,

debug=debug)

finally:

exc_traceback = None

return OK

def HandlerDispatch(self, req):

"""

# be cautious

result = HTTP_INTERNAL_SERVER_ERROR

# config

config, debug = req.get_config(), False

if "PythonDebug" in config:

debug = config["PythonDebug"] == "1"

default_obj_str = _phase_handler_names[req.phase]

# Lookup expected status values that allow us to

# continue when multiple handlers exist.

expected = _status_values[default_obj_str]

try:

hlist = req.hlist

while hlist.handler is not None:

# split module::handler

l = hlist.handler.split('::', 1)

module_name = l[0]

if len(l) == 1:

# no object, provide default

obj_str = default_obj_str

else:

obj_str = l[1]

# add the directory to pythonpath if

# not there yet, or evaluate pythonpath

# and set sys.path to resulting value

# if not already done

if "PythonPath" in config:

_path_cache_lock.acquire()

try:

pathstring = config["PythonPath"]

if pathstring not in _path_cache:

newpath = eval(pathstring)

_path_cache[pathstring] = None

sys.path[:] = newpath

finally:

_path_cache_lock.release()

else:

if not hlist.is_location:

directory = hlist.directory

if directory:

_path_cache_lock.acquire()

try:

if directory not in sys.path:

sys.path[:0] = [directory]

finally:

_path_cache_lock.release()

# import module

autoreload = True

if "PythonAutoReload" in config:

autoreload = config["PythonAutoReload"] == "1"

module = import_module(module_name,

autoreload=autoreload,

log=debug)

# find the object

if '.' not in obj_str: # this is an optimization

try:

obj = module.__dict__[obj_str]

except:

if not hlist.silent:

s = "module '%s' contains no '%s'" % (module.__file__, obj_str)

raise AttributeError(s)

else:

obj = resolve_object(module, obj_str,

arg=req, silent=hlist.silent)

if not hlist.silent or obj is not None:

try:

# Only permit debugging using pdb if Apache has

# actually been started in single process mode.

pdb_debug = False

if "PythonEnablePdb" in config:

pdb_debug = config["PythonEnablePdb"] == "1"

if pdb_debug and exists_config_define("ONE_PROCESS"):

# Don't use pdb.runcall() as it results in

# a bogus 'None' response when pdb session

# is quit. With this code the exception

# marking that the session has been quit is

# propogated back up and it is obvious in

# the error message what actually occurred.

debugger = pdb.Pdb()

debugger.reset()

sys.settrace(debugger.trace_dispatch)

try:

result = obj(req)

finally:

debugger.quitting = 1

sys.settrace(None)

else:

result = obj(req)

except SERVER_RETURN as value:

# The SERVER_RETURN exception type when raised

# otherwise indicates an abort from below with

# value as (result, status) or (result, None) or

# result.

if len(value.args) == 2:

(result, status) = value.args

if status:

req.status = status

else:

result = value.args[0]

assert (result.__class__ is int), \

_result_warning % result.__class__

# stop cycling through handlers

if result not in expected:

break

elif hlist.silent:

# A missing handler when in silent mode will

# only propagate DECLINED if it is the first

# and only handler.

if result == HTTP_INTERNAL_SERVER_ERROR:

result = DECLINED

hlist.next()

except:

# Error (usually parsing)

try:

exc_type, exc_value, exc_traceback = sys.exc_info()

result = self.ReportError(exc_type, exc_value, exc_traceback, req=req,

phase=req.phase, hname=hlist.handler, debug=debug)

finally:

exc_traceback = None

return result

def IncludeDispatch(self, fltr, tag, code):

try:

# config

config, debug = fltr.req.get_config(), False

if "PythonDebug" in config:

debug = config["PythonDebug"] == "1"

if not hasattr(fltr.req,"ssi_globals"):

fltr.req.ssi_globals = {}

fltr.req.ssi_globals["filter"] = fltr

fltr.req.ssi_globals["__file__"] = fltr.req.filename

code = code.replace('\r\n', '\n').rstrip()

if tag == 'eval':

result = eval(code, fltr.req.ssi_globals)

if result is not None:

fltr.write(str(result))

elif tag == 'exec':

exec(code, fltr.req.ssi_globals)

fltr.flush()

except:

try:

exc_type, exc_value, exc_traceback = sys.exc_info()

fltr.disable()

result = self.ReportError(exc_type, exc_value, exc_traceback,

req=fltr.req, filter=fltr,

phase=fltr.name,

hname=fltr.req.filename,

debug=debug)

finally:

exc_traceback = None

raise

fltr.req.ssi_globals["filter"] = None

return OK

def ImportDispatch(self, name):

# config

config, debug = main_server.get_config(), False

if "PythonDebug" in config:

debug = config["PythonDebug"] == "1"

# evaluate pythonpath and set sys.path to

# resulting value if not already done

if "PythonPath" in config:

_path_cache_lock.acquire()

try:

pathstring = config["PythonPath"]

if pathstring not in _path_cache:

newpath = eval(pathstring)

_path_cache[pathstring] = None

sys.path[:] = newpath

finally:

_path_cache_lock.release()

# split module::function

l = name.split('::', 1)

module_name = l[0]

func_name = None

if len(l) != 1:

func_name = l[1]

module = import_module(module_name, log=debug)

if func_name:

getattr(module, func_name)()

def ReportError(self, etype, evalue, etb, req=None, filter=None, srv=None,

phase="N/A", hname="N/A", debug=0):

"""

try: # try/finally

try: # try/except

if str(etype) == "exceptions.IOError" \

and str(evalue)[:5] == "Write":

# if this is an IOError while writing to client,

# it is probably better not to try to write to the cleint

# even if debug is on.

debug = 0

# write to log

for e in traceback.format_exception(etype, evalue, etb):

s = "%s %s: %s" % (phase, hname, e[:-1])

if req:

req.log_error(s, APLOG_ERR)

else:

_apache.log_error(s, APLOG_ERR, srv)

if not debug or not req:

return HTTP_INTERNAL_SERVER_ERROR

else:

# write to client

req.status = HTTP_INTERNAL_SERVER_ERROR

req.content_type = 'text/html'

s = '\n<pre>\nMod_python error: "%s %s"\n\n' % (phase, hname)

for e in traceback.format_exception(etype, evalue, etb):

s = s + cgi.escape(e) + '\n'

s = s + "</pre>\n"

if filter:

filter.write(s)

filter.flush()

else:

req.write(s)

return DONE

except:

# last try

traceback.print_exc()

sys.stderr.flush()

finally:

# erase the traceback

etb = None

"""

# nlehuen: this is a big lock, we'll have to refine it later to get better performance.

# For now, we'll concentrate on thread-safety.

imp.acquire_lock()

try:

# (Re)import

if module_name in sys.modules:

# The module has been imported already

module = sys.modules[module_name]

oldmtime, mtime = 0, 0

if autoreload:

# but is it in the path?

try:

file = module.__dict__["__file__"]

except KeyError:

file = None

# the "and not" part of this condition is to prevent execution

# of arbitrary already imported modules, such as os. The

# reason we use startswith as opposed to exact match is that

# modules inside packages are actually in subdirectories.

if not file or (path and not list(filter(file.startswith, path))):

# there is a script by this name already imported, but it's in

# a different directory, therefore it's a different script

mtime, oldmtime = 0, -1 # trigger import

else:

try:

last_check = module.__dict__["__mtime_check__"]

except KeyError:

last_check = 0

if (time.time() - last_check) > 1:

oldmtime = module.__dict__.get("__mtime__", 0)

mtime = module_mtime(module)

else:

pass

else:

mtime, oldmtime = 0, -1

if mtime != oldmtime:

# Import the module

if log:

if path:

s = "mod_python: (Re)importing module '%s' with path set to '%s'" % (module_name, path)

else:

s = "mod_python: (Re)importing module '%s'" % module_name

_apache.log_error(s, APLOG_NOTICE)

parent = None

parts = module_name.split('.')

for i in range(len(parts)):

f, p, d = imp.find_module(parts[i], path)

try:

mname = ".".join(parts[:i+1])

module = imp.load_module(mname, f, p, d)

if parent:

setattr(parent,parts[i],module)

parent = module

finally:

if f: f.close()

if hasattr(module, "__path__"):

path = module.__path__

if mtime == 0:

mtime = module_mtime(module)

module.__mtime__ = mtime

return module

finally:

"""Get modification time of module"""

mtime = 0

if "__file__" in module.__dict__:

filepath = module.__file__

try:

# this try/except block is a workaround for a Python bug in

# 2.0, 2.1 and 2.1.1. See

# http://sourceforge.net/tracker/?group_id=5470&atid=105470&func=detail&aid=422004

if os.path.exists(filepath):

mtime = os.path.getmtime(filepath)

if os.path.exists(filepath[:-1]) :

mtime = max(mtime, os.path.getmtime(filepath[:-1]))

module.__dict__["__mtime_check__"] = time.time()

except OSError: pass

"""

obj = module

for obj_str in obj_str.split('.'):

parent = obj

# don't throw attribute errors when silent

if silent and not hasattr(obj, obj_str):

return None

# this adds a little clarity if we have an attriute error

if obj == module and not hasattr(module, obj_str):

if hasattr(module, "__file__"):

s = "module '%s' contains no '%s'" % (module.__file__, obj_str)

raise AttributeError(s)

obj = getattr(obj, obj_str)

if hasattr(obj, "im_self") and not obj.__self__:

# this is an unbound method, its class

# needs to be instantiated

instance = parent(arg)

obj = getattr(instance, obj_str)

"""

req.add_cgi_vars()

env = req.subprocess_env.copy()

if req.path_info and len(req.path_info) > 0:

env["SCRIPT_NAME"] = req.uri[:-len(req.path_info)]

else:

env["SCRIPT_NAME"] = req.uri

env["GATEWAY_INTERFACE"] = "Python-CGI/1.1"

# you may want to comment this out for better security

if "authorization" in req.headers_in:

env["HTTP_AUTHORIZATION"] = req.headers_in["authorization"]

""" Abstract IO

def tell(self): return 0

def read(self, n = -1): return ""

def readline(self, length = None): return ""

def readlines(self): return []

def write(self, s): pass

def writelines(self, list):

self.write("".join(list))

def isatty(self): return 0

def flush(self): pass

def close(self): pass

def detach(self): pass

def __init__(self, req):

self.pos = 0

self.req = req

self.BLOCK = 65536 # 64K

# note that self.buf sometimes contains leftovers

# that were read, but not used when readline was used

self.buf = ""

def read(self, n = -1):

if n == 0:

return ""

if n == -1:

s = self.req.read(self.BLOCK)

while s:

self.buf = self.buf + s

self.pos = self.pos + len(s)

s = self.req.read(self.BLOCK)

result = self.buf

self.buf = ""

return result

else:

if self.buf:

s = self.buf[:n]

n = n - len(s)

else:

s = ""

s = s + self.req.read(n)

self.pos = self.pos + len(s)

return s

def readlines(self):

s = (self.buf + self.read()).split('\n')

return [s + '\n' for s in s]

def readline(self, n = -1):

if n == 0:

return ""

# fill up the buffer

self.buf = self.buf + self.req.read(self.BLOCK)

# look for \n in the buffer

i = self.buf.find('\n')

while i == -1: # if \n not found - read more

if (n != -1) and (len(self.buf) >= n): # we're past n

i = n - 1

break

x = len(self.buf)

self.buf = self.buf + self.req.read(self.BLOCK)

if len(self.buf) == x: # nothing read, eof

i = x - 1

break

i = self.buf.find('\n', x)

# carve out the piece, then shorten the buffer

result = self.buf[:i+1]

self.buf = self.buf[i+1:]

self.pos = self.pos + len(result)

"""

def __init__(self, req):

self.pos = 0

self.req = req

self.headers_sent = 0

self.headers = ""

def write(self, s):

if not s: return

if not self.headers_sent:

self.headers = self.headers + s

# are headers over yet?

headers_over = 0

# first try RFC-compliant CRLF

ss = self.headers.split('\r\n\r\n', 1)

if len(ss) < 2:

# second try with \n\n

ss = self.headers.split('\n\n', 1)

if len(ss) >= 2:

headers_over = 1

else:

headers_over = 1

if headers_over:

# headers done, process them

ss[0] = ss[0].replace('\r\n', '\n')

lines = ss[0].split('\n')

for line in lines:

h, v = line.split(":", 1)

v = v.strip()

if h.lower() == "status":

status = int(v.split()[0])

self.req.status = status

elif h.lower() == "content-type":

self.req.content_type = v

self.req.headers_out[h] = v

else:

self.req.headers_out.add(h, v)

self.headers_sent = 1

# write the body if any at this point

self.req.write(ss[1])

else:

self.req.write(str(s))

self.pos = self.pos + len(s)

"""

# save env

save_env = os.environ.copy()

si = sys.stdin

so = sys.stdout

os.environ.update(build_cgi_env(req))

sys.stdout = CGIStdout(req)

sys.stdin = CGIStdin(req)

sys.argv = [] # keeps cgi.py happy

""" see setup_cgi() """

osenv = os.environ

# restore env

for k in list(osenv.keys()):

del osenv[k]

for k in sav_env:

osenv[k] = sav_env[k]

sys.stdout = si

"""

global interpreter

global main_server

interpreter = name

main_server = server

sys.argv = ["mod_python"]

global _callback

_callback = CallBack()