X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=futatabi%2Fframe_on_disk.h;h=c8a74a758ffdc19e6fad72c34a9246408893971f;hb=refs%2Fheads%2Fmaster;hp=184385792528130df7e3ba16637385c0c14a35db;hpb=eeda8995329601f9f4e35047358400833eeae68e;p=nageru

diff --git a/futatabi/frame_on_disk.h b/futatabi/frame_on_disk.h
index 1843857..c8a74a7 100644
--- a/futatabi/frame_on_disk.h
+++ b/futatabi/frame_on_disk.h
@@ -1,37 +1,85 @@
 #ifndef _FRAME_ON_DISK_H
 #define _FRAME_ON_DISK_H 1
 
+#include "defs.h"
+
+#include <algorithm>
 #include <mutex>
+#include <stdint.h>
 #include <string>
 #include <vector>
 
-#include <stdint.h>
-
-#include "defs.h"
-
 extern std::mutex frame_mu;
 struct FrameOnDisk {
-        int64_t pts = -1;  // -1 means empty.
-        off_t offset;
-        unsigned filename_idx;
-        uint32_t size;  // Not using size_t saves a few bytes; we can have so many frames.
+	int64_t pts = -1;  // -1 means empty.
+	off_t offset;
+	unsigned filename_idx;
+	uint32_t size;  // Not using size_t saves a few bytes; we can have so many frames. TODO: Not anymore due to audio_size.
+	uint32_t audio_size;
+	// Unfortunately, 32 bits wasted in padding here.
 };
 extern std::vector<FrameOnDisk> frames[MAX_STREAMS];  // Under frame_mu.
 extern std::vector<std::string> frame_filenames;  // Under frame_mu.
 
+static bool inline operator==(const FrameOnDisk &a, const FrameOnDisk &b)
+{
+	return a.pts == b.pts &&
+		a.offset == b.offset &&
+		a.filename_idx == b.filename_idx &&
+		a.size == b.size &&
+		a.audio_size == b.audio_size;
+}
+
 // A helper class to read frames from disk. It caches the file descriptor
 // so that the kernel has a better chance of doing readahead when it sees
 // the sequential reads. (For this reason, each display has a private
 // FrameReader. Thus, we can easily keep multiple open file descriptors around
 // for a single .frames file.)
+//
+// Thread-compatible, but not thread-safe.
 class FrameReader {
 public:
+	FrameReader();
 	~FrameReader();
-	std::string read_frame(FrameOnDisk frame);
+
+	struct Frame {
+		std::string video;
+		std::string audio;
+	};
+	Frame read_frame(FrameOnDisk frame, bool read_video, bool read_audio);
 
 private:
 	int fd = -1;
 	int last_filename_idx = -1;
 };
 
+// Utility functions for dealing with binary search.
+inline std::vector<FrameOnDisk>::iterator
+find_last_frame_before(std::vector<FrameOnDisk> &frames, int64_t pts_origin)
+{
+	return std::lower_bound(frames.begin(), frames.end(), pts_origin,
+	                        [](const FrameOnDisk &frame, int64_t pts) { return frame.pts < pts; });
+}
+
+inline std::vector<FrameOnDisk>::const_iterator
+find_last_frame_before(const std::vector<FrameOnDisk> &frames, int64_t pts_origin)
+{
+	return std::lower_bound(frames.begin(), frames.end(), pts_origin,
+	                        [](const FrameOnDisk &frame, int64_t pts) { return frame.pts < pts; });
+}
+
+inline std::vector<FrameOnDisk>::iterator
+find_first_frame_at_or_after(std::vector<FrameOnDisk> &frames, int64_t pts_origin)
+{
+	return std::upper_bound(frames.begin(), frames.end(), pts_origin - 1,
+	                        [](int64_t pts, const FrameOnDisk &frame) { return pts < frame.pts; });
+}
+
+inline std::vector<FrameOnDisk>::const_iterator
+find_first_frame_at_or_after(const std::vector<FrameOnDisk> &frames, int64_t pts_origin)
+{
+	return std::upper_bound(frames.begin(), frames.end(), pts_origin - 1,
+	                        [](int64_t pts, const FrameOnDisk &frame) { return pts < frame.pts; });
+}
+
 #endif  // !defined(_FRAME_ON_DISK_H)