<commit_before>#include "connection.hpp"
#include "constants.hpp"
#include "response.hpp"
#include "ssl_context.hpp"
#include "ssl_session.hpp"
#include "connecter.hpp"
#include "timer.hpp"
#include "config.hpp"
#include "result_response.hpp"
#include "supported_response.hpp"
#include "startup_request.hpp"
#include "query_request.hpp"
#include "options_request.hpp"
#include "error_response.hpp"
#include "logger.hpp"
#include "cassandra.h"

#include <sstream>
#include <iomanip>

#define INVALID_PROTOCOL_MSG

namespace cass {

Connection::StartupHandler::StartupHandler(Connection* connection,
                                           Request* request)
    : connection_(connection)
    , request_(request) {
}

const Request* Connection::StartupHandler::request() const {
  return request_.get();
}

void Connection::StartupHandler::on_set(ResponseMessage* response) {
  switch (response->opcode()) {
    case CQL_OPCODE_SUPPORTED:
      connection_->on_supported(response);
      break;
    case CQL_OPCODE_ERROR: {
      ErrorResponse* error
          = static_cast<ErrorResponse*>(response->response_body().get());
      if (error->code() == CQL_ERROR_PROTOCOL_ERROR &&<commit_msg>Removed unused #define<commit_after>#include "connection.hpp"
#include "constants.hpp"
#include "response.hpp"
#include "ssl_context.hpp"
#include "ssl_session.hpp"
#include "connecter.hpp"
#include "timer.hpp"
#include "config.hpp"
#include "result_response.hpp"
#include "supported_response.hpp"
#include "startup_request.hpp"
#include "query_request.hpp"
#include "options_request.hpp"
#include "error_response.hpp"
#include "logger.hpp"
#include "cassandra.h"

#include <sstream>
#include <iomanip>

namespace cass {

Connection::StartupHandler::StartupHandler(Connection* connection,
                                           Request* request)
    : connection_(connection)
    , request_(request) {
}

const Request* Connection::StartupHandler::request() const {
  return request_.get();
}

void Connection::StartupHandler::on_set(ResponseMessage* response) {
  switch (response->opcode()) {
    case CQL_OPCODE_SUPPORTED:
      connection_->on_supported(response);
      break;
    case CQL_OPCODE_ERROR: {
      ErrorResponse* error
          = static_cast<ErrorResponse*>(response->response_body().get());
      if (error->code() == CQL_ERROR_PROTOCOL_ERROR &&
{'fraction_non_alphanumeric': 0.12960609911054638, 'fraction_numerical': 0.0, 'mean_word_length': 4.733009708737864, 'pattern_counts': {'":': 0, '<': 9, '<?xml version=': 0, '>': 17, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 4, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '4358016', 'n_tokens_mistral': 712, 'n_tokens_neox': 716, 'n_words': 138}