| 1400 | |
| 1401 | @defunct_on_error |
| 1402 | def _send_startup_message(self, compression=None, no_compact=False): |
| 1403 | log.debug("Sending StartupMessage on %s", self) |
| 1404 | opts = {'DRIVER_NAME': DRIVER_NAME, |
| 1405 | 'DRIVER_VERSION': DRIVER_VERSION} |
| 1406 | if compression: |
| 1407 | opts['COMPRESSION'] = compression |
| 1408 | if no_compact: |
| 1409 | opts['NO_COMPACT'] = 'true' |
| 1410 | sm = StartupMessage(cqlversion=self.cql_version, options=opts) |
| 1411 | self.send_msg(sm, self.get_request_id(), cb=self._handle_startup_response) |
| 1412 | log.debug("Sent StartupMessage on %s", self) |
| 1413 | |
| 1414 | @defunct_on_error |
| 1415 | def _handle_startup_response(self, startup_response, did_authenticate=False): |