swift/proxy/controllers/obj.py
def send_commit_confirmation(self):
        """
        Call when there are > quorum 2XX responses received.  Send commit
        confirmations to all object nodes to finalize the PUT.
        """
        if not self.multiphase:
            raise ValueError(
                "called send_commit_confirmation but multiphase is False")
        if self.state == COMMIT_SENT:
            raise ValueError("called send_commit_confirmation twice")

        self.state = DATA_ACKED

        if self.mime_boundary:
            body = "put_commit_confirmation"
            tail_boundary = ("--%s--" % (self.mime_boundary,))
            message_parts = [
                "X-Document: put commit\r\n",
                "\r\n",
                body, "\r\n",
                tail_boundary,
            ]
            self.queue.put("".join(message_parts))

        self.queue.put('')
        self.state = COMMIT_SENT

        Call when there are > quorum 2XX responses received.  Send commit
        confirmations to all object nodes to finalize the PUT.
        
Call when there are > quorum 2XX responses received.  Send commit
confirmations to all object nodes to finalize the PUT.
Call when there are > quorum 2XX responses received . Send commit confirmations to all object nodes to finalize the PUT .
def send_commit_confirmation(self):
        if not self.multiphase:
            raise ValueError(
                "called send_commit_confirmation but multiphase is False")
        if self.state == COMMIT_SENT:
            raise ValueError("called send_commit_confirmation twice")
        self.state = DATA_ACKED
        if self.mime_boundary:
            body = "put_commit_confirmation"
            tail_boundary = ("--%s--" % (self.mime_boundary,))
            message_parts = [
                "X-Document: put commit\r\n",
                "\r\n",
                body, "\r\n",
                tail_boundary,
            ]
            self.queue.put("".join(message_parts))
        self.queue.put('')
        self.state = COMMIT_SENT
def send_commit_confirmation ( self ) : if not self . multiphase : raise ValueError ( "called send_commit_confirmation but multiphase is False" ) if self . state == COMMIT_SENT : raise ValueError ( "called send_commit_confirmation twice" ) self . state = DATA_ACKED if self . mime_boundary : body = "put_commit_confirmation" tail_boundary = ( "--%s--" % ( self . mime_boundary , ) ) message_parts = [ "X-Document: put commit\r\n" , "\r\n" , body , "\r\n" , tail_boundary , ] self . queue . put ( "" . join ( message_parts ) ) self . queue . put ( '' ) self . state = COMMIT_SENT
Call when there are > quorum 2XX responses received.
Call when there are > quorum 2XX responses received .
"""
        Call when there are > quorum 2XX responses received.  Send commit
        confirmations to all object nodes to finalize the PUT.
        """
self