Fixed async responses.

This commit is contained in:
Paul Davis 2010-03-23 15:54:22 -04:00
parent e4b7263314
commit 1d326f88c4
2 changed files with 10 additions and 7 deletions

View File

@ -26,7 +26,7 @@ class KeepaliveResponse(http.Response):
return [ return [
"HTTP/1.1 %s\r\n" % self.status, "HTTP/1.1 %s\r\n" % self.status,
"Server: %s\r\n" % self.SERVER_VERSION, "Server: %s\r\n" % self.version,
"Date: %s\r\n" % util.http_date(), "Date: %s\r\n" % util.http_date(),
"Connection: %s\r\n" % connection_hdr "Connection: %s\r\n" % connection_hdr
] ]

View File

@ -24,15 +24,18 @@ class Response(object):
self.chunked = True self.chunked = True
self.headers.append((name.strip(), value.strip())) self.headers.append((name.strip(), value.strip()))
def default_headers(self):
return [
"HTTP/1.1 %s\r\n" % self.status,
"Server: %s\r\n" % self.SERVER_VERSION,
"Date: %s\r\n" % util.http_date(),
"Connection: close\r\n"
]
def send_headers(self): def send_headers(self):
if self.headers_sent: if self.headers_sent:
return return
tosend = [ tosend = self.default_headers()
"HTTP/1.1 %s\r\n" % self.status,
"Server: %s\r\n" % self.version,
"Date: %s\r\n" % http_date(),
"Connection: close\r\n"
]
tosend.extend(["%s: %s\r\n" % (n, v) for n, v in self.headers]) tosend.extend(["%s: %s\r\n" % (n, v) for n, v in self.headers])
write(self.req.socket, "%s\r\n" % "".join(tosend)) write(self.req.socket, "%s\r\n" % "".join(tosend))
self.headers_sent = True self.headers_sent = True