X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=futatabi%2Fframe_on_disk.cpp;h=c3e3b4db496e4902e7239f61b2d53c98b57e7825;hb=13c7a8f2386ca7fbe9f6e04d24bd584993dc76c6;hp=b496b3d4188ebda04e401089cd7c03e9b59c22c3;hpb=eeda8995329601f9f4e35047358400833eeae68e;p=nageru diff --git a/futatabi/frame_on_disk.cpp b/futatabi/frame_on_disk.cpp index b496b3d..c3e3b4d 100644 --- a/futatabi/frame_on_disk.cpp +++ b/futatabi/frame_on_disk.cpp @@ -1,22 +1,60 @@ +#include "frame_on_disk.h" + +#include "shared/metrics.h" + +#include +#include #include +#include #include -#include "frame_on_disk.h" - using namespace std; +using namespace std::chrono; + +namespace { + +// There can be multiple FrameReader classes, so make all the metrics static. +once_flag frame_metrics_inited; + +atomic metric_frame_opened_files{ 0 }; +atomic metric_frame_closed_files{ 0 }; +atomic metric_frame_read_bytes{ 0 }; +atomic metric_frame_read_frames{ 0 }; + +Summary metric_frame_read_time_seconds; + +} // namespace + +FrameReader::FrameReader() +{ + call_once(frame_metrics_inited, [] { + 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 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); + }); +} FrameReader::~FrameReader() { if (fd != -1) { close(fd); + ++metric_frame_closed_files; } } string FrameReader::read_frame(FrameOnDisk frame) { + steady_clock::time_point start = steady_clock::now(); + if (int(frame.filename_idx) != last_filename_idx) { if (fd != -1) { close(fd); // Ignore errors. + ++metric_frame_closed_files; } string filename; @@ -35,6 +73,7 @@ string FrameReader::read_frame(FrameOnDisk frame) posix_fadvise(fd, 0, 0, POSIX_FADV_SEQUENTIAL); last_filename_idx = frame.filename_idx; + ++metric_frame_opened_files; } string str; @@ -49,5 +88,12 @@ string FrameReader::read_frame(FrameOnDisk frame) offset += ret; } + + steady_clock::time_point stop = steady_clock::now(); + metric_frame_read_time_seconds.count_event(duration(stop - start).count()); + + metric_frame_read_bytes += frame.size; + ++metric_frame_read_frames; + return str; }