Method _enable_checksumming

cassandra/connection.py:974–978

(self)

            self.compressor = self._compressor

    def _enable_checksumming(self):
        self._io_buffer.set_checksumming_buffer()
        self._is_checksumming_enabled = True
        self._segment_codec = segment_codec_lz4 if self.compressor else segment_codec_no_compression
        log.debug("Enabling protocol checksumming on connection (%s).", id(self))

    def close(self):
        raise NotImplementedError()