// There can be multiple FrameReader classes, so make all the metrics static.
once_flag frame_metrics_inited;
// There can be multiple FrameReader classes, so make all the metrics static.
once_flag frame_metrics_inited;
-atomic<int64_t> metric_frame_opened_files{0};
-atomic<int64_t> metric_frame_closed_files{0};
-atomic<int64_t> metric_frame_read_bytes{0};
-atomic<int64_t> metric_frame_read_frames{0};
+atomic<int64_t> metric_frame_opened_files{ 0 };
+atomic<int64_t> metric_frame_closed_files{ 0 };
+atomic<int64_t> metric_frame_read_bytes{ 0 };
+atomic<int64_t> metric_frame_read_frames{ 0 };
global_metrics.add("frame_opened_files", &metric_frame_opened_files);
global_metrics.add("frame_closed_files", &metric_frame_closed_files);
global_metrics.add("frame_read_bytes", &metric_frame_read_bytes);
global_metrics.add("frame_read_frames", &metric_frame_read_frames);
global_metrics.add("frame_opened_files", &metric_frame_opened_files);
global_metrics.add("frame_closed_files", &metric_frame_closed_files);
global_metrics.add("frame_read_bytes", &metric_frame_read_bytes);
global_metrics.add("frame_read_frames", &metric_frame_read_frames);
- vector<double> quantiles{0.01, 0.1, 0.25, 0.5, 0.75, 0.9, 0.99};
+ vector<double> quantiles{ 0.01, 0.1, 0.25, 0.5, 0.75, 0.9, 0.99 };
metric_frame_read_time_seconds.init(quantiles, 60.0);
global_metrics.add("frame_read_time_seconds", &metric_frame_read_time_seconds);
});
metric_frame_read_time_seconds.init(quantiles, 60.0);
global_metrics.add("frame_read_time_seconds", &metric_frame_read_time_seconds);
});
fd = open(filename.c_str(), O_RDONLY);
if (fd == -1) {
perror(filename.c_str());
fd = open(filename.c_str(), O_RDONLY);
if (fd == -1) {
perror(filename.c_str());
string str;
str.resize(frame.size);
off_t offset = 0;
while (offset < frame.size) {
int ret = pread(fd, &str[offset], frame.size - offset, frame.offset + offset);
if (ret <= 0) {
string str;
str.resize(frame.size);
off_t offset = 0;
while (offset < frame.size) {
int ret = pread(fd, &str[offset], frame.size - offset, frame.offset + offset);
if (ret <= 0) {