Sha256: b5682fac986d57f873e87906cb9950a4e010d83f69e3ab4db1fb74c27a497b06

Contents?: true

Size: 1.97 KB

Versions: 14

Compression:

Stored size: 1.97 KB

Contents

import os, time

def file_exist(filename):
	try:
		os.stat(filename)
		return True
	except OSError:
		return False

def application(env, start_response):
	status = '200 OK'
	body   = None
	
	method = env.get('REQUEST_METHOD')
	if method == 'OOBW':
		time.sleep(1)
		start_response(status, [('Content-Type', 'text/html')])
		return [str('oobw ok')]
	
	filename = env.get('HTTP_X_WAIT_FOR_FILE')
	if filename is not None:
		while not file_exist(filename):
			time.sleep(0.01)
	
	path = env['PATH_INFO']
	if path == '/pid':
		body = os.getpid()
	elif path == '/env':
		body = ''
		for pair in env.iteritems():
			body += pair[0] + ' = ' + str(pair[1]) + "\n"
		body = body
	elif path == '/upload':
		sleep_time = float(env.get('HTTP_X_SLEEP', 0))
		f = open(env['HTTP_X_OUTPUT'], 'w')
		try:
			line = env['wsgi.input'].readline()
			while line != "":
				f.write(line)
				f.flush()
				line = env['wsgi.input'].readline()
				if sleep_time > 0:
					time.sleep(sleep_time)
		finally:
			f.close()
		body = 'ok'
	elif path == '/custom_status':
		status = env['HTTP_X_CUSTOM_STATUS']
		body = 'ok'
	elif path == '/stream':
		sleep_time = float(env.get('HTTP_X_SLEEP', 0.1))
		def body():
			i = 0
			while True:
				data = ' ' * 32 + str(i) + "\n"
				yield("%x\r\n" % len(data))
				yield(data)
				yield("\r\n")
				time.sleep(sleep_time)
				i += 1
		start_response(status, [('Content-Type', 'text/html'), ('Transfer-Encoding', 'chunked')])
		return body()
	elif path == '/blob':
		size = int(env.get('HTTP_X_SIZE', 1024 * 1024 * 10))
		def body():
			written = 0
			while written < size:
				data = 'x' * min(1024 * 8, size - written)
				yield(data)
				written += len(data)
		start_response(status, [('Content-Type', 'text/plain')])
		return body()
	elif path == '/oobw':
		start_response(status, [('Content-Type', 'text/plain'), ('X-Passenger-Request-OOB-Work', 'true')])
		return [str(os.getpid())]
	else:
		body = 'hello <b>world</b>'
	
	start_response(status, [('Content-Type', 'text/html')])
	return [str(body)]

Version data entries

14 entries across 14 versions & 1 rubygems

Version Path
passenger-4.0.14 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.13 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.10 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.8 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.7 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.6 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.5 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.4 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.3 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.2 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.1 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.0.rc6 test/stub/wsgi/passenger_wsgi.py
passenger-4.0.0.rc4 test/stub/wsgi/passenger_wsgi.py
passenger-3.9.2.beta test/stub/wsgi/passenger_wsgi.py