HTTPInput::HTTPInput(const string &url, Input::Encoding encoding)
: state(NOT_CONNECTED),
url(url),
- encoding(encoding),
- has_metacube_header(false),
- sock(-1),
- num_connection_attempts(0),
- suppress_logging(false)
+ encoding(encoding)
{
pthread_mutex_init(&stats_mutex, nullptr);
stats.url = url;
stats.metadata_bytes_received = 0;
stats.connect_time = -1;
stats.latency_sec = HUGE_VAL;
-
- last_verbose_connection.tv_sec = -3600;
- last_verbose_connection.tv_nsec = 0;
}
HTTPInput::HTTPInput(const InputProto &serialized)
http_header(serialized.http_header()),
stream_header(serialized.stream_header()),
has_metacube_header(serialized.has_metacube_header()),
- sock(serialized.sock()),
- num_connection_attempts(0),
- suppress_logging(false)
+ sock(serialized.sock())
{
pending_data.resize(serialized.pending_data().size());
memcpy(&pending_data[0], serialized.pending_data().data(), serialized.pending_data().size());