interrupt the file sending if the file size over the quota...some errors here...

Levi Nie levinie001 at gmail.com
Tue Jan 15 04:46:08 EST 2013


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()
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://mail.python.org/pipermail/python-list/attachments/20130115/771a786d/attachment.html>


More information about the Python-list mailing list