diff options
| author | zousar <[email protected]> | 2025-09-23 09:26:11 -0600 |
|---|---|---|
| committer | zousar <[email protected]> | 2025-09-23 09:26:11 -0600 |
| commit | c7eebb0c8fc5d046d630b462bbfdab1f46bb2d42 (patch) | |
| tree | e833c531de232503db4e006afeadb6563d71dcc9 /src/zenstore/cache/cachedisklayer.cpp | |
| parent | Merge branch 'main' into zs/put-overwrite-policy-response (diff) | |
| download | zen-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.cpp | 15 |
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; |