assert(!hosts.empty() && "Tried to set on an non-existent host");

switch (response->opcode()) {

case CQL_OPCODE_RESULT:

future_->set_result(hosts.front(), response->response_body().release());

break;

case CQL_OPCODE_ERROR: {

ErrorResponse* error =

static_cast<ErrorResponse*>(response->response_body().get());

future_->set_error_with_host(hosts.front(),

static_cast<CassError>(CASS_ERROR(

CASS_ERROR_SOURCE_SERVER, error->code())),

error->message());

} break;

default:

// TODO(mpenick): Get the host for errors

future_->set_error_with_host(hosts.front(),

CASS_ERROR_LIB_UNEXPECTED_RESPONSE,

"Unexpected response");

break;

}

notify_finished();

if (hosts.empty()) {

future_->set_error(code, message);

} else {

future_->set_error_with_host(hosts.front(), code, message);

}

notify_finished();

assert(!hosts.empty() && "Tried to timeout on an non-existent host");

future_->set_error_with_host(hosts.front(), CASS_ERROR_LIB_REQUEST_TIMED_OUT, "Request timed out");

notify_finished();