aboutsummaryrefslogtreecommitdiff
path: root/src/zenstore/cache/cachedisklayer.cpp
diff options
context:
space:
mode:
authorzousar <[email protected]>2025-09-23 09:26:11 -0600
committerzousar <[email protected]>2025-09-23 09:26:11 -0600
commitc7eebb0c8fc5d046d630b462bbfdab1f46bb2d42 (patch)
treee833c531de232503db4e006afeadb6563d71dcc9 /src/zenstore/cache/cachedisklayer.cpp
parentMerge branch 'main' into zs/put-overwrite-policy-response (diff)
downloadzen-c7eebb0c8fc5d046d630b462bbfdab1f46bb2d42.tar.xz
zen-c7eebb0c8fc5d046d630b462bbfdab1f46bb2d42.zip
Adjust the responses from PUT commands
- Ensure that text responses are in a field named "Message" - Change the record response to be named "Record" instead of "Object"
Diffstat (limited to 'src/zenstore/cache/cachedisklayer.cpp')
-rw-r--r--src/zenstore/cache/cachedisklayer.cpp15
1 files changed, 5 insertions, 10 deletions
diff --git a/src/zenstore/cache/cachedisklayer.cpp b/src/zenstore/cache/cachedisklayer.cpp
index 9a56844fe..ba82dd942 100644
--- a/src/zenstore/cache/cachedisklayer.cpp
+++ b/src/zenstore/cache/cachedisklayer.cpp
@@ -1969,7 +1969,7 @@ ZenCacheDiskLayer::CacheBucket::ShouldRejectPut(const IoHash& HashKey,
if (!cache::impl::UpdateValueWithRawSizeAndHash(InOutValue))
{
CbObjectWriter DetailWriter;
- DetailWriter.AddString("Value provided is of bad format");
+ DetailWriter.AddString("Message", "Value provided is of bad format");
OutPutResult = PutResult{zen::PutStatus::Fail, DetailWriter.Save()};
return true;
}
@@ -2011,7 +2011,7 @@ ZenCacheDiskLayer::CacheBucket::ShouldRejectPut(const IoHash& HashKey,
if (!cache::impl::UpdateValueWithRawSizeAndHash(InOutValue))
{
CbObjectWriter DetailWriter;
- DetailWriter.AddString("Value provided is of bad format");
+ DetailWriter.AddString("Message", "Value provided is of bad format");
OutPutResult = PutResult{zen::PutStatus::Fail, DetailWriter.Save()};
return true;
}
@@ -2019,16 +2019,11 @@ ZenCacheDiskLayer::CacheBucket::ShouldRejectPut(const IoHash& HashKey,
if (ExistingValue.RawSize != InOutValue.RawSize || ExistingValue.RawHash != InOutValue.RawHash)
{
CbObjectWriter DetailWriter;
+ DetailWriter.AddInteger("RawSize", ExistingValue.RawSize);
+ DetailWriter.AddHash("RawHash", ExistingValue.RawHash);
if (Location.IsFlagSet(DiskLocation::kStructured))
{
- DetailWriter.AddInteger("RawSize", ExistingValue.RawSize);
- DetailWriter.AddHash("RawHash", ExistingValue.RawHash);
- DetailWriter.AddObject("Object", CbObjectView(ExistingValue.Value.GetData()));
- }
- else
- {
- DetailWriter.AddInteger("RawSize", ExistingValue.RawSize);
- DetailWriter.AddHash("RawHash", ExistingValue.RawHash);
+ DetailWriter.AddObject("Record", CbObject(SharedBuffer(ExistingValue.Value)));
}
OutPutResult = PutResult{zen::PutStatus::Conflict, DetailWriter.Save()};
return true;