plocate/access_rx_cache.h

#ifndef _ACCESS_RX_CACHE_H
#define _ACCESS_RX_CACHE_H 1

#include <functional>
#include <map>
#include <mutex>
#include <string>
#include <unordered_map>
#include <vector>

class IOUringEngine;

class AccessRXCache {
public:
	AccessRXCache(IOUringEngine *engine, bool check_visibility)
		: engine(engine), check_visibility(check_visibility) {}
	void check_access(const char *filename, bool allow_async, std::function<void(bool)> cb);

private:
	std::unordered_map<std::string, bool> cache;
	struct PendingStat {
		std::string filename;
		std::function<void(bool)> cb;
	};
	std::map<std::string, std::vector<PendingStat>> pending_stats;
	IOUringEngine *engine;
	std::mutex mu;
	bool check_visibility;
};

#endif  // !defined(_ACCESS_RX_CACHE_H)