http_header(serialized.http_header()),
stream_header(serialized.stream_header()),
has_metacube_header(serialized.has_metacube_header()),
- sock(serialized.sock())
+ sock(serialized.sock()),
+ num_connection_attempts(0),
+ suppress_logging(false)
{
pending_data.resize(serialized.pending_data().size());
memcpy(&pending_data[0], serialized.pending_data().data(), serialized.pending_data().size());
} else {
stats.connect_time = time(NULL);
}
+
+ last_verbose_connection.tv_sec = -3600;
+ last_verbose_connection.tv_nsec = 0;
}
void HTTPInput::close_socket()
return new HTTPInput(url, encoding);
}
if (protocol == "udp") {
- if (encoding == Input::INPUT_ENCODING_METACUBE) {
- return NULL;
- }
+ // encoding is ignored; it's never Metacube.
return new UDPInput(url);
}
return NULL;