reef: rgw/kafka: set message timeout to 5 seconds
Reviewed-by: J. Eric Ivancich <ivancich@redhat.com>
auto& conn = conn_it->second;
// Checking the connection idlesness
- if(conn->timestamp.sec() + max_idle_time < ceph_clock_now()) {
+ if(conn->timestamp.sec() + conn->cct->_conf->rgw_kafka_connection_idle < ceph_clock_now()) {
ldout(conn->cct, 20) << "kafka run: deleting a connection due to idle behaviour: " << ceph_clock_now() << dendl;
std::lock_guard lock(connections_lock);
- conn->destroy(STATUS_CONNECTION_IDLE);
+ conn->status = STATUS_CONNECTION_IDLE;
conn_it = connections.erase(conn_it);
--connection_count; \
continue;