This commit is contained in:
Kovid Goyal 2015-05-19 15:22:23 +05:30
parent 0f6e191bf8
commit be2c8a35ee
3 changed files with 7 additions and 3 deletions

View File

@ -489,7 +489,7 @@ class HTTPPair(object):
def generate_static_output(self, name, generator):
return generate_static_output(self.server_loop.gso_cache, self.server_loop.gso_lock, name, generator)
def response(self):
def respond(self):
if self.chunked_read:
self.input_reader = ChunkedReader(self.conn.socket_file, self.max_request_body_size)
else:

View File

@ -395,6 +395,7 @@ class WorkerThread(Thread): # {{{
self.ready = False
self.serving = False
self.server_loop = server_loop
self.conn = None
Thread.__init__(self, name='ServerWorker')
def run(self):
@ -402,7 +403,7 @@ class WorkerThread(Thread): # {{{
self.ready = True
while True:
self.serving = False
conn = self.server_loop.requests.get()
self.conn = conn = self.server_loop.requests.get()
if conn is None:
return # Clean exit
with conn, self:

View File

@ -65,7 +65,10 @@ class MultiDict(dict): # {{{
return dict.__getitem__(self, key)
except KeyError:
return []
return self.__getitem__(key)
try:
return self.__getitem__(key)
except KeyError:
return default
def pop(self, key, default=None, all=False):
ans = dict.pop(self, key, default)