def pause_writing(self): logging.warn("PEER PROTOCOL IS OVER THE HIGH-WATER MARK") self._throttle = True