} // namespace
-void QueueLengthPolicy::register_metrics(const string &card_name)
+void QueueLengthPolicy::register_metrics(const vector<pair<string, string>> &labels)
{
- global_metrics.add("input_queue_length_frames{" + card_name + "}", &metric_input_queue_length_frames, Metrics::TYPE_GAUGE);
- global_metrics.add("input_queue_safe_length_frames{" + card_name + "}", &metric_input_queue_safe_length_frames, Metrics::TYPE_GAUGE);
- global_metrics.add("input_queue_duped_frames{" + card_name + "}", &metric_input_duped_frames);
+ global_metrics.add("input_queue_length_frames", labels, &metric_input_queue_length_frames, Metrics::TYPE_GAUGE);
+ global_metrics.add("input_queue_safe_length_frames", labels, &metric_input_queue_safe_length_frames, Metrics::TYPE_GAUGE);
+ global_metrics.add("input_queue_duped_frames", labels, &metric_input_duped_frames);
}
void QueueLengthPolicy::update_policy(unsigned queue_length)
{
- metric_input_queue_length_frames = queue_length;
-
if (queue_length == 0) { // Starvation.
if (been_at_safe_point_since_last_starvation && safe_queue_length < unsigned(global_flags.max_input_queue_frames)) {
++safe_queue_length;
been_at_safe_point_since_last_starvation = false;
++metric_input_duped_frames;
metric_input_queue_safe_length_frames = safe_queue_length;
+ metric_input_queue_length_frames = 0;
return;
}
if (queue_length >= safe_queue_length) {
card_index, safe_queue_length);
frames_with_at_least_one = 0;
}
+ metric_input_queue_length_frames = min(queue_length, safe_queue_length); // The caller will drop frames for us if needed.
}
Mixer::Mixer(const QSurfaceFormat &format, unsigned num_cards)
mixer_surface(create_surface(format)),
h264_encoder_surface(create_surface(format)),
decklink_output_surface(create_surface(format)),
- ycbcr_interpretation(global_flags.ycbcr_interpretation),
audio_mixer(num_cards)
{
+ memcpy(ycbcr_interpretation, global_flags.ycbcr_interpretation, sizeof(ycbcr_interpretation));
CHECK(init_movit(MOVIT_SHADER_DIR, MOVIT_DEBUG_OFF));
check_error();
set_output_card_internal(global_flags.output_card);
}
+ metric_start_time_seconds = get_timestamp_for_metrics();
+
global_metrics.add("frames_output_total", &metric_frames_output_total);
global_metrics.add("frames_output_dropped", &metric_frames_output_dropped);
- global_metrics.add("uptime_seconds", &metric_uptime_seconds);
+ global_metrics.add("start_time_seconds", &metric_start_time_seconds, Metrics::TYPE_GAUGE);
+ global_metrics.add("memory_used_bytes", &metrics_memory_used_bytes);
+ global_metrics.add("metrics_memory_locked_limit_bytes", &metrics_memory_locked_limit_bytes);
}
Mixer::~Mixer()
audio_mixer.trigger_state_changed_callback();
// Register metrics.
+ vector<pair<string, string>> labels;
char card_name[64];
+ snprintf(card_name, sizeof(card_name), "%d", card_index);
+ labels.emplace_back("card", card_name);
+
switch (card_type) {
case CardType::LIVE_CARD:
- snprintf(card_name, sizeof(card_name), "card=\"%d\",cardtype=\"live\"", card_index);
+ labels.emplace_back("cardtype", "live");
break;
case CardType::FAKE_CAPTURE:
- snprintf(card_name, sizeof(card_name), "card=\"%d\",cardtype=\"fake\"", card_index);
+ labels.emplace_back("cardtype", "fake");
break;
case CardType::FFMPEG_INPUT:
- snprintf(card_name, sizeof(card_name), "card=\"%d\",cardtype=\"ffmpeg\"", card_index);
+ labels.emplace_back("cardtype", "ffmpeg");
break;
default:
assert(false);
}
- card->queue_length_policy.register_metrics(card_name);
- global_metrics.add(string("input_dropped_frames_jitter{") + card_name + "}", &card->metric_input_dropped_frames_jitter);
- global_metrics.add(string("input_dropped_frames_error{") + card_name + "}", &card->metric_input_dropped_frames_error);
- global_metrics.add(string("input_dropped_frames_resets{") + card_name + "}", &card->metric_input_resets);
-
- global_metrics.add(string("input_has_signal_bool{") + card_name + "}", &card->metric_input_has_signal_bool, Metrics::TYPE_GAUGE);
- global_metrics.add(string("input_is_connected_bool{") + card_name + "}", &card->metric_input_is_connected_bool, Metrics::TYPE_GAUGE);
- global_metrics.add(string("input_interlaced_bool{") + card_name + "}", &card->metric_input_interlaced_bool, Metrics::TYPE_GAUGE);
- global_metrics.add(string("input_width_pixels{") + card_name + "}", &card->metric_input_width_pixels, Metrics::TYPE_GAUGE);
- global_metrics.add(string("input_height_pixels{") + card_name + "}", &card->metric_input_height_pixels, Metrics::TYPE_GAUGE);
- global_metrics.add(string("input_frame_rate_nom{") + card_name + "}", &card->metric_input_frame_rate_nom, Metrics::TYPE_GAUGE);
- global_metrics.add(string("input_frame_rate_den{") + card_name + "}", &card->metric_input_frame_rate_den, Metrics::TYPE_GAUGE);
- global_metrics.add(string("input_sample_rate_hz{") + card_name + "}", &card->metric_input_sample_rate_hz, Metrics::TYPE_GAUGE);
+ card->queue_length_policy.register_metrics(labels);
+ global_metrics.add("input_dropped_frames_jitter", labels, &card->metric_input_dropped_frames_jitter);
+ global_metrics.add("input_dropped_frames_error", labels, &card->metric_input_dropped_frames_error);
+ global_metrics.add("input_dropped_frames_resets", labels, &card->metric_input_resets);
+
+ global_metrics.add("input_has_signal_bool", labels, &card->metric_input_has_signal_bool, Metrics::TYPE_GAUGE);
+ global_metrics.add("input_is_connected_bool", labels, &card->metric_input_is_connected_bool, Metrics::TYPE_GAUGE);
+ global_metrics.add("input_interlaced_bool", labels, &card->metric_input_interlaced_bool, Metrics::TYPE_GAUGE);
+ global_metrics.add("input_width_pixels", labels, &card->metric_input_width_pixels, Metrics::TYPE_GAUGE);
+ global_metrics.add("input_height_pixels", labels, &card->metric_input_height_pixels, Metrics::TYPE_GAUGE);
+ global_metrics.add("input_frame_rate_nom", labels, &card->metric_input_frame_rate_nom, Metrics::TYPE_GAUGE);
+ global_metrics.add("input_frame_rate_den", labels, &card->metric_input_frame_rate_den, Metrics::TYPE_GAUGE);
+ global_metrics.add("input_sample_rate_hz", labels, &card->metric_input_sample_rate_hz, Metrics::TYPE_GAUGE);
}
void Mixer::set_output_card_internal(int card_index)
metric_frames_output_total = frame_num;
metric_frames_output_dropped = stats_dropped_frames;
- metric_uptime_seconds = elapsed;
if (frame_num % 100 == 0) {
printf("%d frames (%d dropped) in %.3f seconds = %.1f fps (%.1f ms/frame)",
long(limit.rlim_cur / 1048576),
float(100.0 * (used.ru_maxrss * 1024.0) / limit.rlim_cur));
}
+ metrics_memory_locked_limit_bytes = limit.rlim_cur;
} else {
printf(", using %ld MB memory (not locked)",
long(used.ru_maxrss / 1024));
+ metrics_memory_locked_limit_bytes = 0.0 / 0.0;
}
printf("\n");
+
+ metrics_memory_used_bytes = used.ru_maxrss * 1024;
}