aboutsummaryrefslogtreecommitdiffstats
path: root/storageapi
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@oath.com>2018-05-30 21:49:01 +0200
committerHenning Baldersheim <balder@oath.com>2018-05-31 13:48:59 +0200
commit51d9070a1184af82b85dafb6c8f2dd6d6b635c2e (patch)
tree015918e634d1ee112af117b09aeda2c87eacf7af /storageapi
parent4b97af420a3b0b6842e51e0ee1a8481e81050d66 (diff)
Though shall never produce old format again, except from tests.
Diffstat (limited to 'storageapi')
-rw-r--r--storageapi/src/vespa/storageapi/mbusprot/serializationhelper.h53
1 files changed, 6 insertions, 47 deletions
diff --git a/storageapi/src/vespa/storageapi/mbusprot/serializationhelper.h b/storageapi/src/vespa/storageapi/mbusprot/serializationhelper.h
index 02c4c0ce0b9..08cec601cce 100644
--- a/storageapi/src/vespa/storageapi/mbusprot/serializationhelper.h
+++ b/storageapi/src/vespa/storageapi/mbusprot/serializationhelper.h
@@ -4,13 +4,11 @@
#include <vespa/fastos/types.h>
#include <vespa/document/base/globalid.h>
#include <vespa/document/fieldvalue/document.h>
-#include <vespa/document/update/documentupdate.h>
#include <vespa/document/util/bytebuffer.h>
#include <vespa/vespalib/objects/nbostream.h>
#include <vespa/vespalib/util/growablebytebuffer.h>
-namespace storage {
-namespace mbusprot {
+namespace storage::mbusprot {
class SerializationHelper
{
@@ -60,8 +58,7 @@ public:
return api::ReturnCode(result, message);
}
- static void putReturnCode(const api::ReturnCode& code,
- vespalib::GrowableByteBuffer& buf)
+ static void putReturnCode(const api::ReturnCode& code, vespalib::GrowableByteBuffer& buf)
{
buf.putInt(code.getResult());
buf.putString(code.getMessage());
@@ -77,18 +74,14 @@ public:
return document::GlobalId(&buffer[0]);
}
- static void putGlobalId(const document::GlobalId& gid,
- vespalib::GrowableByteBuffer& buf)
+ static void putGlobalId(const document::GlobalId& gid, vespalib::GrowableByteBuffer& buf)
{
buf.putShort(document::GlobalId::LENGTH);
for (uint32_t i=0; i<document::GlobalId::LENGTH; ++i) {
buf.putByte(gid.get()[i]);
}
}
-
- static document::Document::UP getDocument(
- document::ByteBuffer& buf,
- const document::DocumentTypeRepo& repo)
+ static document::Document::UP getDocument(document::ByteBuffer& buf, const document::DocumentTypeRepo& repo)
{
uint32_t size = getInt(buf);
if (size == 0) {
@@ -100,26 +93,7 @@ public:
}
}
- static document::DocumentUpdate::UP getUpdate(
- document::ByteBuffer& buf,
- const document::DocumentTypeRepo& repo)
- {
- uint32_t size = getInt(buf);
- if (size == 0) {
- return document::DocumentUpdate::UP();
- } else {
- document::ByteBuffer bbuf(buf.getBufferAtPos(), size);
- buf.incPos(size);
- return document::DocumentUpdate::UP(
- new document::DocumentUpdate(repo, bbuf,
- document::DocumentUpdate::
- SerializeVersion::
- SERIALIZE_42));
- }
- }
-
- static void putDocument(document::Document* doc,
- vespalib::GrowableByteBuffer& buf)
+ static void putDocument(document::Document* doc, vespalib::GrowableByteBuffer& buf)
{
if (doc) {
vespalib::nbostream stream;
@@ -131,21 +105,6 @@ public:
}
}
- static void putUpdate(document::DocumentUpdate* update,
- vespalib::GrowableByteBuffer& buf)
- {
- if (update) {
- vespalib::nbostream stream;
- update->serialize42(stream);
- buf.putInt(stream.size());
- buf.putBytes(stream.peek(), stream.size());
- } else {
- buf.putInt(0);
- }
- }
-
};
-} // mbusprot
-} // storage
-
+}