changed RPC recording to MPSC setup (#638)

fixes rare race condition when using RPC recording for long periods of time

1 files changed, 3 insertions, 6 deletions

diff --git a/src/zenutil/include/zenutil/cache/rpcrecording.h b/src/zenutil/include/zenutil/cache/rpcrecording.h
index ab9b92dd3..f1ad35413 100644
--- a/src/zenutil/include/zenutil/cache/rpcrecording.h
+++ b/src/zenutil/include/zenutil/cache/rpcrecording.h
@@ -24,18 +24,15 @@ class IRpcRequestRecorder
 {
 public:
 	virtual ~IRpcRequestRecorder() {}
-	virtual uint64_t RecordRequest(const RecordedRequestInfo& RequestInfo, const IoBuffer& RequestBuffer)							= 0;
-	virtual void	 RecordResponse(uint64_t RequestIndex, const ZenContentType ContentType, const IoBuffer& ResponseBuffer)		= 0;
-	virtual void	 RecordResponse(uint64_t RequestIndex, const ZenContentType ContentType, const CompositeBuffer& ResponseBuffer) = 0;
+	virtual void RecordRequest(const RecordedRequestInfo& RequestInfo, const IoBuffer& RequestBuffer) = 0;
 };
 
 class IRpcRequestReplayer
 {
 public:
 	virtual ~IRpcRequestReplayer() {}
-	virtual uint64_t			GetRequestCount() const									= 0;
-	virtual RecordedRequestInfo GetRequest(uint64_t RequestIndex, IoBuffer& OutBuffer)	= 0;
-	virtual ZenContentType		GetResponse(uint64_t RequestIndex, IoBuffer& OutBuffer) = 0;
+	virtual uint64_t			GetRequestCount() const								   = 0;
+	virtual RecordedRequestInfo GetRequest(uint64_t RequestIndex, IoBuffer& OutBuffer) = 0;
 };
 
 std::unique_ptr<cache::IRpcRequestRecorder> MakeDiskRequestRecorder(const std::filesystem::path& BasePath);