i want to interrupt the file sending. but i can't change the client. so i
need change the server.
All things go well, but the message i wanna response seem not work.
is the self.transport.loseConnection() (the last line) blocking the
messages?
in fact, i work on Cumulus(nimbus project) which based on twisted. And i
use s3cmd as the client.
here is the my code:
def headerReceived(self,line):
pycb.log(logging.INFO, "===== def headerReceived of cumulus.py")
http.HTTPChannel.headerReceived(self,line)
pycb.log(logging.INFO, "===== self.length is %s"%self.length)
header, data = line.split(':', 1)
header = header.lower()
data = data.strip()
if header=='authorization':
self.authorization=data
if self.length and self.authorization:
user_id = self.authorization.split(':')[0].split()[1].strip()
user = pycb.config.auth.get_user(user_id)
pycb.log(logging.INFO, "===== user who put this object is
%s"%user)
remaining_quota = user.get_remaining_quota()
pycb.log(logging.INFO, "===== remaining_quota is
%s"%remaining_quota)
quota_check=self.length-remaining_quota
pycb.log(logging.INFO, "=====
quota_check=self.length-remaining_quota of cumulus.py")
if quota_check>0:
requestId = str(uuid.uuid1()).replace("-", "")
ex=cbException('AccountProblem')
m_msg = "HTTP/1.1 %s %s\r\n" % (ex.httpCode, ex.httpDesc)
self.transport.write(m_msg)
m_msg = "%s: %s\r\n" % (('x-amz-request-id', requestId))
self.transport.write(m_msg)
#req.setHeader('x-amz-request-id', requestId)
m_msg = "%s: %s\r\n" % (('x-amz-id-2', str(uuid.uuid1())))
self.transport.write(m_msg)
e_msg = ex.make_xml_string(self._path, str(uuid.uuid1()))
pycb.log(logging.INFO, "===== e_msg is %s"%e_msg)
#self.transport.write("\r\n")
self.transport.write(e_msg)
pycb.log(logging.INFO, "===== self.transport.write(e_msg)")
self.transport.loseConnection()
--
http://mail.python.org/mailman/listinfo/python-list
