for (unsigned i = 0; i < config.streams.size(); ++i) {
const StreamConfig &stream_config = config.streams[i];
if (deserialized_stream_ids.count(stream_config.stream_id) == 0) {
- servers->add_stream(stream_config.stream_id);
+ servers->add_stream(stream_config.stream_id, stream_config.backlog_size);
}
expecting_stream_ids.erase(stream_config.stream_id);
if (state_fd != -1) {
fprintf(stderr, "Deserializing state from previous process... ");
string serialized;
- if (!read_tempfile(atoi(argv[3]), &serialized)) {
+ if (!read_tempfile(state_fd, &serialized)) {
exit(1);
}
if (!loaded_state.ParseFromString(serialized)) {
if (!config.stats_file.empty()) {
stats_thread = new StatsThread(config.stats_file, config.stats_interval);
stats_thread->run();
- } else if (config.stats_interval != -1) {
- fprintf(stderr, "WARNING: 'stats_interval' given, but no 'stats_file'. No statistics will be written.\n");
}
signal(SIGHUP, hup);