blob: 340f043bc833c2f81c0ddf0821b4ba108d91a13a [file]
// automatically generated by the FlatBuffers compiler, do not modify
#ifndef FLATBUFFERS_GENERATED_PLASMA_PLASMA_FLATBUF_H_
#define FLATBUFFERS_GENERATED_PLASMA_PLASMA_FLATBUF_H_
#include "flatbuffers/flatbuffers.h"
#include "common_generated.h"
namespace plasma {
namespace flatbuf {
struct PlasmaObjectSpec;
struct PlasmaSetOptionsRequest;
struct PlasmaSetOptionsRequestBuilder;
struct PlasmaSetOptionsRequestT;
struct PlasmaSetOptionsReply;
struct PlasmaSetOptionsReplyBuilder;
struct PlasmaSetOptionsReplyT;
struct PlasmaGetDebugStringRequest;
struct PlasmaGetDebugStringRequestBuilder;
struct PlasmaGetDebugStringRequestT;
struct PlasmaGetDebugStringReply;
struct PlasmaGetDebugStringReplyBuilder;
struct PlasmaGetDebugStringReplyT;
struct PlasmaCreateRequest;
struct PlasmaCreateRequestBuilder;
struct PlasmaCreateRequestT;
struct CudaHandle;
struct CudaHandleBuilder;
struct CudaHandleT;
struct PlasmaCreateReply;
struct PlasmaCreateReplyBuilder;
struct PlasmaCreateReplyT;
struct PlasmaCreateAndSealRequest;
struct PlasmaCreateAndSealRequestBuilder;
struct PlasmaCreateAndSealRequestT;
struct PlasmaCreateAndSealReply;
struct PlasmaCreateAndSealReplyBuilder;
struct PlasmaCreateAndSealReplyT;
struct PlasmaCreateAndSealBatchRequest;
struct PlasmaCreateAndSealBatchRequestBuilder;
struct PlasmaCreateAndSealBatchRequestT;
struct PlasmaCreateAndSealBatchReply;
struct PlasmaCreateAndSealBatchReplyBuilder;
struct PlasmaCreateAndSealBatchReplyT;
struct PlasmaAbortRequest;
struct PlasmaAbortRequestBuilder;
struct PlasmaAbortRequestT;
struct PlasmaAbortReply;
struct PlasmaAbortReplyBuilder;
struct PlasmaAbortReplyT;
struct PlasmaSealRequest;
struct PlasmaSealRequestBuilder;
struct PlasmaSealRequestT;
struct PlasmaSealReply;
struct PlasmaSealReplyBuilder;
struct PlasmaSealReplyT;
struct PlasmaGetRequest;
struct PlasmaGetRequestBuilder;
struct PlasmaGetRequestT;
struct PlasmaGetReply;
struct PlasmaGetReplyBuilder;
struct PlasmaGetReplyT;
struct PlasmaReleaseRequest;
struct PlasmaReleaseRequestBuilder;
struct PlasmaReleaseRequestT;
struct PlasmaReleaseReply;
struct PlasmaReleaseReplyBuilder;
struct PlasmaReleaseReplyT;
struct PlasmaDeleteRequest;
struct PlasmaDeleteRequestBuilder;
struct PlasmaDeleteRequestT;
struct PlasmaDeleteReply;
struct PlasmaDeleteReplyBuilder;
struct PlasmaDeleteReplyT;
struct PlasmaContainsRequest;
struct PlasmaContainsRequestBuilder;
struct PlasmaContainsRequestT;
struct PlasmaContainsReply;
struct PlasmaContainsReplyBuilder;
struct PlasmaContainsReplyT;
struct PlasmaListRequest;
struct PlasmaListRequestBuilder;
struct PlasmaListRequestT;
struct PlasmaListReply;
struct PlasmaListReplyBuilder;
struct PlasmaListReplyT;
struct PlasmaConnectRequest;
struct PlasmaConnectRequestBuilder;
struct PlasmaConnectRequestT;
struct PlasmaConnectReply;
struct PlasmaConnectReplyBuilder;
struct PlasmaConnectReplyT;
struct PlasmaEvictRequest;
struct PlasmaEvictRequestBuilder;
struct PlasmaEvictRequestT;
struct PlasmaEvictReply;
struct PlasmaEvictReplyBuilder;
struct PlasmaEvictReplyT;
struct PlasmaSubscribeRequest;
struct PlasmaSubscribeRequestBuilder;
struct PlasmaSubscribeRequestT;
struct PlasmaNotification;
struct PlasmaNotificationBuilder;
struct PlasmaNotificationT;
struct PlasmaDataRequest;
struct PlasmaDataRequestBuilder;
struct PlasmaDataRequestT;
struct PlasmaDataReply;
struct PlasmaDataReplyBuilder;
struct PlasmaDataReplyT;
struct PlasmaRefreshLRURequest;
struct PlasmaRefreshLRURequestBuilder;
struct PlasmaRefreshLRURequestT;
struct PlasmaRefreshLRUReply;
struct PlasmaRefreshLRUReplyBuilder;
struct PlasmaRefreshLRUReplyT;
enum class MessageType : int64_t {
PlasmaDisconnectClient = 0,
PlasmaCreateRequest = 1LL,
PlasmaCreateReply = 2LL,
PlasmaCreateAndSealRequest = 3LL,
PlasmaCreateAndSealReply = 4LL,
PlasmaAbortRequest = 5LL,
PlasmaAbortReply = 6LL,
PlasmaSealRequest = 7LL,
PlasmaSealReply = 8LL,
PlasmaGetRequest = 9LL,
PlasmaGetReply = 10LL,
PlasmaReleaseRequest = 11LL,
PlasmaReleaseReply = 12LL,
PlasmaDeleteRequest = 13LL,
PlasmaDeleteReply = 14LL,
PlasmaContainsRequest = 15LL,
PlasmaContainsReply = 16LL,
PlasmaListRequest = 17LL,
PlasmaListReply = 18LL,
PlasmaConnectRequest = 19LL,
PlasmaConnectReply = 20LL,
PlasmaEvictRequest = 21LL,
PlasmaEvictReply = 22LL,
PlasmaSubscribeRequest = 23LL,
PlasmaUnsubscribeRequest = 24LL,
PlasmaDataRequest = 25LL,
PlasmaDataReply = 26LL,
PlasmaNotification = 27LL,
PlasmaSetOptionsRequest = 28LL,
PlasmaSetOptionsReply = 29LL,
PlasmaGetDebugStringRequest = 30LL,
PlasmaGetDebugStringReply = 31LL,
PlasmaCreateAndSealBatchRequest = 32LL,
PlasmaCreateAndSealBatchReply = 33LL,
PlasmaRefreshLRURequest = 34LL,
PlasmaRefreshLRUReply = 35LL,
MIN = PlasmaDisconnectClient,
MAX = PlasmaRefreshLRUReply
};
inline const MessageType (&EnumValuesMessageType())[36] {
static const MessageType values[] = {
MessageType::PlasmaDisconnectClient,
MessageType::PlasmaCreateRequest,
MessageType::PlasmaCreateReply,
MessageType::PlasmaCreateAndSealRequest,
MessageType::PlasmaCreateAndSealReply,
MessageType::PlasmaAbortRequest,
MessageType::PlasmaAbortReply,
MessageType::PlasmaSealRequest,
MessageType::PlasmaSealReply,
MessageType::PlasmaGetRequest,
MessageType::PlasmaGetReply,
MessageType::PlasmaReleaseRequest,
MessageType::PlasmaReleaseReply,
MessageType::PlasmaDeleteRequest,
MessageType::PlasmaDeleteReply,
MessageType::PlasmaContainsRequest,
MessageType::PlasmaContainsReply,
MessageType::PlasmaListRequest,
MessageType::PlasmaListReply,
MessageType::PlasmaConnectRequest,
MessageType::PlasmaConnectReply,
MessageType::PlasmaEvictRequest,
MessageType::PlasmaEvictReply,
MessageType::PlasmaSubscribeRequest,
MessageType::PlasmaUnsubscribeRequest,
MessageType::PlasmaDataRequest,
MessageType::PlasmaDataReply,
MessageType::PlasmaNotification,
MessageType::PlasmaSetOptionsRequest,
MessageType::PlasmaSetOptionsReply,
MessageType::PlasmaGetDebugStringRequest,
MessageType::PlasmaGetDebugStringReply,
MessageType::PlasmaCreateAndSealBatchRequest,
MessageType::PlasmaCreateAndSealBatchReply,
MessageType::PlasmaRefreshLRURequest,
MessageType::PlasmaRefreshLRUReply
};
return values;
}
inline const char * const *EnumNamesMessageType() {
static const char * const names[37] = {
"PlasmaDisconnectClient",
"PlasmaCreateRequest",
"PlasmaCreateReply",
"PlasmaCreateAndSealRequest",
"PlasmaCreateAndSealReply",
"PlasmaAbortRequest",
"PlasmaAbortReply",
"PlasmaSealRequest",
"PlasmaSealReply",
"PlasmaGetRequest",
"PlasmaGetReply",
"PlasmaReleaseRequest",
"PlasmaReleaseReply",
"PlasmaDeleteRequest",
"PlasmaDeleteReply",
"PlasmaContainsRequest",
"PlasmaContainsReply",
"PlasmaListRequest",
"PlasmaListReply",
"PlasmaConnectRequest",
"PlasmaConnectReply",
"PlasmaEvictRequest",
"PlasmaEvictReply",
"PlasmaSubscribeRequest",
"PlasmaUnsubscribeRequest",
"PlasmaDataRequest",
"PlasmaDataReply",
"PlasmaNotification",
"PlasmaSetOptionsRequest",
"PlasmaSetOptionsReply",
"PlasmaGetDebugStringRequest",
"PlasmaGetDebugStringReply",
"PlasmaCreateAndSealBatchRequest",
"PlasmaCreateAndSealBatchReply",
"PlasmaRefreshLRURequest",
"PlasmaRefreshLRUReply",
nullptr
};
return names;
}
inline const char *EnumNameMessageType(MessageType e) {
if (flatbuffers::IsOutRange(e, MessageType::PlasmaDisconnectClient, MessageType::PlasmaRefreshLRUReply)) return "";
const size_t index = static_cast<size_t>(e);
return EnumNamesMessageType()[index];
}
enum class PlasmaError : int32_t {
OK = 0,
ObjectExists = 1,
ObjectNotFound = 2,
OutOfMemory = 3,
ObjectNotSealed = 4,
ObjectInUse = 5,
MIN = OK,
MAX = ObjectInUse
};
inline const PlasmaError (&EnumValuesPlasmaError())[6] {
static const PlasmaError values[] = {
PlasmaError::OK,
PlasmaError::ObjectExists,
PlasmaError::ObjectNotFound,
PlasmaError::OutOfMemory,
PlasmaError::ObjectNotSealed,
PlasmaError::ObjectInUse
};
return values;
}
inline const char * const *EnumNamesPlasmaError() {
static const char * const names[7] = {
"OK",
"ObjectExists",
"ObjectNotFound",
"OutOfMemory",
"ObjectNotSealed",
"ObjectInUse",
nullptr
};
return names;
}
inline const char *EnumNamePlasmaError(PlasmaError e) {
if (flatbuffers::IsOutRange(e, PlasmaError::OK, PlasmaError::ObjectInUse)) return "";
const size_t index = static_cast<size_t>(e);
return EnumNamesPlasmaError()[index];
}
FLATBUFFERS_MANUALLY_ALIGNED_STRUCT(8) PlasmaObjectSpec FLATBUFFERS_FINAL_CLASS {
private:
int32_t segment_index_;
int32_t padding0__;
uint64_t data_offset_;
uint64_t data_size_;
uint64_t metadata_offset_;
uint64_t metadata_size_;
int32_t device_num_;
int32_t padding1__;
public:
PlasmaObjectSpec() {
memset(static_cast<void *>(this), 0, sizeof(PlasmaObjectSpec));
}
PlasmaObjectSpec(int32_t _segment_index, uint64_t _data_offset, uint64_t _data_size, uint64_t _metadata_offset, uint64_t _metadata_size, int32_t _device_num)
: segment_index_(flatbuffers::EndianScalar(_segment_index)),
padding0__(0),
data_offset_(flatbuffers::EndianScalar(_data_offset)),
data_size_(flatbuffers::EndianScalar(_data_size)),
metadata_offset_(flatbuffers::EndianScalar(_metadata_offset)),
metadata_size_(flatbuffers::EndianScalar(_metadata_size)),
device_num_(flatbuffers::EndianScalar(_device_num)),
padding1__(0) {
(void)padding0__;
(void)padding1__;
}
int32_t segment_index() const {
return flatbuffers::EndianScalar(segment_index_);
}
uint64_t data_offset() const {
return flatbuffers::EndianScalar(data_offset_);
}
uint64_t data_size() const {
return flatbuffers::EndianScalar(data_size_);
}
uint64_t metadata_offset() const {
return flatbuffers::EndianScalar(metadata_offset_);
}
uint64_t metadata_size() const {
return flatbuffers::EndianScalar(metadata_size_);
}
int32_t device_num() const {
return flatbuffers::EndianScalar(device_num_);
}
};
FLATBUFFERS_STRUCT_END(PlasmaObjectSpec, 48);
struct PlasmaSetOptionsRequestT : public flatbuffers::NativeTable {
typedef PlasmaSetOptionsRequest TableType;
std::string client_name;
int64_t output_memory_quota;
PlasmaSetOptionsRequestT()
: output_memory_quota(0) {
}
};
struct PlasmaSetOptionsRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaSetOptionsRequestT NativeTableType;
typedef PlasmaSetOptionsRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_CLIENT_NAME = 4,
VT_OUTPUT_MEMORY_QUOTA = 6
};
const flatbuffers::String *client_name() const {
return GetPointer<const flatbuffers::String *>(VT_CLIENT_NAME);
}
int64_t output_memory_quota() const {
return GetField<int64_t>(VT_OUTPUT_MEMORY_QUOTA, 0);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_CLIENT_NAME) &&
verifier.VerifyString(client_name()) &&
VerifyField<int64_t>(verifier, VT_OUTPUT_MEMORY_QUOTA) &&
verifier.EndTable();
}
PlasmaSetOptionsRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaSetOptionsRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaSetOptionsRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSetOptionsRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaSetOptionsRequestBuilder {
typedef PlasmaSetOptionsRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_client_name(flatbuffers::Offset<flatbuffers::String> client_name) {
fbb_.AddOffset(PlasmaSetOptionsRequest::VT_CLIENT_NAME, client_name);
}
void add_output_memory_quota(int64_t output_memory_quota) {
fbb_.AddElement<int64_t>(PlasmaSetOptionsRequest::VT_OUTPUT_MEMORY_QUOTA, output_memory_quota, 0);
}
explicit PlasmaSetOptionsRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaSetOptionsRequestBuilder &operator=(const PlasmaSetOptionsRequestBuilder &);
flatbuffers::Offset<PlasmaSetOptionsRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaSetOptionsRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaSetOptionsRequest> CreatePlasmaSetOptionsRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> client_name = 0,
int64_t output_memory_quota = 0) {
PlasmaSetOptionsRequestBuilder builder_(_fbb);
builder_.add_output_memory_quota(output_memory_quota);
builder_.add_client_name(client_name);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaSetOptionsRequest> CreatePlasmaSetOptionsRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *client_name = nullptr,
int64_t output_memory_quota = 0) {
auto client_name__ = client_name ? _fbb.CreateString(client_name) : 0;
return plasma::flatbuf::CreatePlasmaSetOptionsRequest(
_fbb,
client_name__,
output_memory_quota);
}
flatbuffers::Offset<PlasmaSetOptionsRequest> CreatePlasmaSetOptionsRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSetOptionsRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaSetOptionsReplyT : public flatbuffers::NativeTable {
typedef PlasmaSetOptionsReply TableType;
plasma::flatbuf::PlasmaError error;
PlasmaSetOptionsReplyT()
: error(plasma::flatbuf::PlasmaError::OK) {
}
};
struct PlasmaSetOptionsReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaSetOptionsReplyT NativeTableType;
typedef PlasmaSetOptionsReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_ERROR = 4
};
plasma::flatbuf::PlasmaError error() const {
return static_cast<plasma::flatbuf::PlasmaError>(GetField<int32_t>(VT_ERROR, 0));
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<int32_t>(verifier, VT_ERROR) &&
verifier.EndTable();
}
PlasmaSetOptionsReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaSetOptionsReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaSetOptionsReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSetOptionsReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaSetOptionsReplyBuilder {
typedef PlasmaSetOptionsReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_error(plasma::flatbuf::PlasmaError error) {
fbb_.AddElement<int32_t>(PlasmaSetOptionsReply::VT_ERROR, static_cast<int32_t>(error), 0);
}
explicit PlasmaSetOptionsReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaSetOptionsReplyBuilder &operator=(const PlasmaSetOptionsReplyBuilder &);
flatbuffers::Offset<PlasmaSetOptionsReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaSetOptionsReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaSetOptionsReply> CreatePlasmaSetOptionsReply(
flatbuffers::FlatBufferBuilder &_fbb,
plasma::flatbuf::PlasmaError error = plasma::flatbuf::PlasmaError::OK) {
PlasmaSetOptionsReplyBuilder builder_(_fbb);
builder_.add_error(error);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaSetOptionsReply> CreatePlasmaSetOptionsReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSetOptionsReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaGetDebugStringRequestT : public flatbuffers::NativeTable {
typedef PlasmaGetDebugStringRequest TableType;
PlasmaGetDebugStringRequestT() {
}
};
struct PlasmaGetDebugStringRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaGetDebugStringRequestT NativeTableType;
typedef PlasmaGetDebugStringRequestBuilder Builder;
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
verifier.EndTable();
}
PlasmaGetDebugStringRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaGetDebugStringRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaGetDebugStringRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetDebugStringRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaGetDebugStringRequestBuilder {
typedef PlasmaGetDebugStringRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
explicit PlasmaGetDebugStringRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaGetDebugStringRequestBuilder &operator=(const PlasmaGetDebugStringRequestBuilder &);
flatbuffers::Offset<PlasmaGetDebugStringRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaGetDebugStringRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaGetDebugStringRequest> CreatePlasmaGetDebugStringRequest(
flatbuffers::FlatBufferBuilder &_fbb) {
PlasmaGetDebugStringRequestBuilder builder_(_fbb);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaGetDebugStringRequest> CreatePlasmaGetDebugStringRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetDebugStringRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaGetDebugStringReplyT : public flatbuffers::NativeTable {
typedef PlasmaGetDebugStringReply TableType;
std::string debug_string;
PlasmaGetDebugStringReplyT() {
}
};
struct PlasmaGetDebugStringReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaGetDebugStringReplyT NativeTableType;
typedef PlasmaGetDebugStringReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_DEBUG_STRING = 4
};
const flatbuffers::String *debug_string() const {
return GetPointer<const flatbuffers::String *>(VT_DEBUG_STRING);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_DEBUG_STRING) &&
verifier.VerifyString(debug_string()) &&
verifier.EndTable();
}
PlasmaGetDebugStringReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaGetDebugStringReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaGetDebugStringReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetDebugStringReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaGetDebugStringReplyBuilder {
typedef PlasmaGetDebugStringReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_debug_string(flatbuffers::Offset<flatbuffers::String> debug_string) {
fbb_.AddOffset(PlasmaGetDebugStringReply::VT_DEBUG_STRING, debug_string);
}
explicit PlasmaGetDebugStringReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaGetDebugStringReplyBuilder &operator=(const PlasmaGetDebugStringReplyBuilder &);
flatbuffers::Offset<PlasmaGetDebugStringReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaGetDebugStringReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaGetDebugStringReply> CreatePlasmaGetDebugStringReply(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> debug_string = 0) {
PlasmaGetDebugStringReplyBuilder builder_(_fbb);
builder_.add_debug_string(debug_string);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaGetDebugStringReply> CreatePlasmaGetDebugStringReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *debug_string = nullptr) {
auto debug_string__ = debug_string ? _fbb.CreateString(debug_string) : 0;
return plasma::flatbuf::CreatePlasmaGetDebugStringReply(
_fbb,
debug_string__);
}
flatbuffers::Offset<PlasmaGetDebugStringReply> CreatePlasmaGetDebugStringReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetDebugStringReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaCreateRequestT : public flatbuffers::NativeTable {
typedef PlasmaCreateRequest TableType;
std::string object_id;
bool evict_if_full;
uint64_t data_size;
uint64_t metadata_size;
int32_t device_num;
PlasmaCreateRequestT()
: evict_if_full(false),
data_size(0),
metadata_size(0),
device_num(0) {
}
};
struct PlasmaCreateRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaCreateRequestT NativeTableType;
typedef PlasmaCreateRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4,
VT_EVICT_IF_FULL = 6,
VT_DATA_SIZE = 8,
VT_METADATA_SIZE = 10,
VT_DEVICE_NUM = 12
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
bool evict_if_full() const {
return GetField<uint8_t>(VT_EVICT_IF_FULL, 0) != 0;
}
uint64_t data_size() const {
return GetField<uint64_t>(VT_DATA_SIZE, 0);
}
uint64_t metadata_size() const {
return GetField<uint64_t>(VT_METADATA_SIZE, 0);
}
int32_t device_num() const {
return GetField<int32_t>(VT_DEVICE_NUM, 0);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
VerifyField<uint8_t>(verifier, VT_EVICT_IF_FULL) &&
VerifyField<uint64_t>(verifier, VT_DATA_SIZE) &&
VerifyField<uint64_t>(verifier, VT_METADATA_SIZE) &&
VerifyField<int32_t>(verifier, VT_DEVICE_NUM) &&
verifier.EndTable();
}
PlasmaCreateRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaCreateRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaCreateRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaCreateRequestBuilder {
typedef PlasmaCreateRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaCreateRequest::VT_OBJECT_ID, object_id);
}
void add_evict_if_full(bool evict_if_full) {
fbb_.AddElement<uint8_t>(PlasmaCreateRequest::VT_EVICT_IF_FULL, static_cast<uint8_t>(evict_if_full), 0);
}
void add_data_size(uint64_t data_size) {
fbb_.AddElement<uint64_t>(PlasmaCreateRequest::VT_DATA_SIZE, data_size, 0);
}
void add_metadata_size(uint64_t metadata_size) {
fbb_.AddElement<uint64_t>(PlasmaCreateRequest::VT_METADATA_SIZE, metadata_size, 0);
}
void add_device_num(int32_t device_num) {
fbb_.AddElement<int32_t>(PlasmaCreateRequest::VT_DEVICE_NUM, device_num, 0);
}
explicit PlasmaCreateRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaCreateRequestBuilder &operator=(const PlasmaCreateRequestBuilder &);
flatbuffers::Offset<PlasmaCreateRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaCreateRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaCreateRequest> CreatePlasmaCreateRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0,
bool evict_if_full = false,
uint64_t data_size = 0,
uint64_t metadata_size = 0,
int32_t device_num = 0) {
PlasmaCreateRequestBuilder builder_(_fbb);
builder_.add_metadata_size(metadata_size);
builder_.add_data_size(data_size);
builder_.add_device_num(device_num);
builder_.add_object_id(object_id);
builder_.add_evict_if_full(evict_if_full);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaCreateRequest> CreatePlasmaCreateRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr,
bool evict_if_full = false,
uint64_t data_size = 0,
uint64_t metadata_size = 0,
int32_t device_num = 0) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaCreateRequest(
_fbb,
object_id__,
evict_if_full,
data_size,
metadata_size,
device_num);
}
flatbuffers::Offset<PlasmaCreateRequest> CreatePlasmaCreateRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct CudaHandleT : public flatbuffers::NativeTable {
typedef CudaHandle TableType;
std::vector<uint8_t> handle;
CudaHandleT() {
}
};
struct CudaHandle FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef CudaHandleT NativeTableType;
typedef CudaHandleBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_HANDLE = 4
};
const flatbuffers::Vector<uint8_t> *handle() const {
return GetPointer<const flatbuffers::Vector<uint8_t> *>(VT_HANDLE);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_HANDLE) &&
verifier.VerifyVector(handle()) &&
verifier.EndTable();
}
CudaHandleT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(CudaHandleT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<CudaHandle> Pack(flatbuffers::FlatBufferBuilder &_fbb, const CudaHandleT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct CudaHandleBuilder {
typedef CudaHandle Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_handle(flatbuffers::Offset<flatbuffers::Vector<uint8_t>> handle) {
fbb_.AddOffset(CudaHandle::VT_HANDLE, handle);
}
explicit CudaHandleBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
CudaHandleBuilder &operator=(const CudaHandleBuilder &);
flatbuffers::Offset<CudaHandle> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<CudaHandle>(end);
return o;
}
};
inline flatbuffers::Offset<CudaHandle> CreateCudaHandle(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::Vector<uint8_t>> handle = 0) {
CudaHandleBuilder builder_(_fbb);
builder_.add_handle(handle);
return builder_.Finish();
}
inline flatbuffers::Offset<CudaHandle> CreateCudaHandleDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const std::vector<uint8_t> *handle = nullptr) {
auto handle__ = handle ? _fbb.CreateVector<uint8_t>(*handle) : 0;
return plasma::flatbuf::CreateCudaHandle(
_fbb,
handle__);
}
flatbuffers::Offset<CudaHandle> CreateCudaHandle(flatbuffers::FlatBufferBuilder &_fbb, const CudaHandleT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaCreateReplyT : public flatbuffers::NativeTable {
typedef PlasmaCreateReply TableType;
std::string object_id;
std::unique_ptr<plasma::flatbuf::PlasmaObjectSpec> plasma_object;
plasma::flatbuf::PlasmaError error;
int32_t store_fd;
int64_t mmap_size;
std::unique_ptr<plasma::flatbuf::CudaHandleT> ipc_handle;
PlasmaCreateReplyT()
: error(plasma::flatbuf::PlasmaError::OK),
store_fd(0),
mmap_size(0) {
}
};
struct PlasmaCreateReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaCreateReplyT NativeTableType;
typedef PlasmaCreateReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4,
VT_PLASMA_OBJECT = 6,
VT_ERROR = 8,
VT_STORE_FD = 10,
VT_MMAP_SIZE = 12,
VT_IPC_HANDLE = 14
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
const plasma::flatbuf::PlasmaObjectSpec *plasma_object() const {
return GetStruct<const plasma::flatbuf::PlasmaObjectSpec *>(VT_PLASMA_OBJECT);
}
plasma::flatbuf::PlasmaError error() const {
return static_cast<plasma::flatbuf::PlasmaError>(GetField<int32_t>(VT_ERROR, 0));
}
int32_t store_fd() const {
return GetField<int32_t>(VT_STORE_FD, 0);
}
int64_t mmap_size() const {
return GetField<int64_t>(VT_MMAP_SIZE, 0);
}
const plasma::flatbuf::CudaHandle *ipc_handle() const {
return GetPointer<const plasma::flatbuf::CudaHandle *>(VT_IPC_HANDLE);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
VerifyField<plasma::flatbuf::PlasmaObjectSpec>(verifier, VT_PLASMA_OBJECT) &&
VerifyField<int32_t>(verifier, VT_ERROR) &&
VerifyField<int32_t>(verifier, VT_STORE_FD) &&
VerifyField<int64_t>(verifier, VT_MMAP_SIZE) &&
VerifyOffset(verifier, VT_IPC_HANDLE) &&
verifier.VerifyTable(ipc_handle()) &&
verifier.EndTable();
}
PlasmaCreateReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaCreateReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaCreateReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaCreateReplyBuilder {
typedef PlasmaCreateReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaCreateReply::VT_OBJECT_ID, object_id);
}
void add_plasma_object(const plasma::flatbuf::PlasmaObjectSpec *plasma_object) {
fbb_.AddStruct(PlasmaCreateReply::VT_PLASMA_OBJECT, plasma_object);
}
void add_error(plasma::flatbuf::PlasmaError error) {
fbb_.AddElement<int32_t>(PlasmaCreateReply::VT_ERROR, static_cast<int32_t>(error), 0);
}
void add_store_fd(int32_t store_fd) {
fbb_.AddElement<int32_t>(PlasmaCreateReply::VT_STORE_FD, store_fd, 0);
}
void add_mmap_size(int64_t mmap_size) {
fbb_.AddElement<int64_t>(PlasmaCreateReply::VT_MMAP_SIZE, mmap_size, 0);
}
void add_ipc_handle(flatbuffers::Offset<plasma::flatbuf::CudaHandle> ipc_handle) {
fbb_.AddOffset(PlasmaCreateReply::VT_IPC_HANDLE, ipc_handle);
}
explicit PlasmaCreateReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaCreateReplyBuilder &operator=(const PlasmaCreateReplyBuilder &);
flatbuffers::Offset<PlasmaCreateReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaCreateReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaCreateReply> CreatePlasmaCreateReply(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0,
const plasma::flatbuf::PlasmaObjectSpec *plasma_object = 0,
plasma::flatbuf::PlasmaError error = plasma::flatbuf::PlasmaError::OK,
int32_t store_fd = 0,
int64_t mmap_size = 0,
flatbuffers::Offset<plasma::flatbuf::CudaHandle> ipc_handle = 0) {
PlasmaCreateReplyBuilder builder_(_fbb);
builder_.add_mmap_size(mmap_size);
builder_.add_ipc_handle(ipc_handle);
builder_.add_store_fd(store_fd);
builder_.add_error(error);
builder_.add_plasma_object(plasma_object);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaCreateReply> CreatePlasmaCreateReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr,
const plasma::flatbuf::PlasmaObjectSpec *plasma_object = 0,
plasma::flatbuf::PlasmaError error = plasma::flatbuf::PlasmaError::OK,
int32_t store_fd = 0,
int64_t mmap_size = 0,
flatbuffers::Offset<plasma::flatbuf::CudaHandle> ipc_handle = 0) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaCreateReply(
_fbb,
object_id__,
plasma_object,
error,
store_fd,
mmap_size,
ipc_handle);
}
flatbuffers::Offset<PlasmaCreateReply> CreatePlasmaCreateReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaCreateAndSealRequestT : public flatbuffers::NativeTable {
typedef PlasmaCreateAndSealRequest TableType;
std::string object_id;
bool evict_if_full;
std::string data;
std::string metadata;
std::string digest;
PlasmaCreateAndSealRequestT()
: evict_if_full(false) {
}
};
struct PlasmaCreateAndSealRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaCreateAndSealRequestT NativeTableType;
typedef PlasmaCreateAndSealRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4,
VT_EVICT_IF_FULL = 6,
VT_DATA = 8,
VT_METADATA = 10,
VT_DIGEST = 12
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
bool evict_if_full() const {
return GetField<uint8_t>(VT_EVICT_IF_FULL, 0) != 0;
}
const flatbuffers::String *data() const {
return GetPointer<const flatbuffers::String *>(VT_DATA);
}
const flatbuffers::String *metadata() const {
return GetPointer<const flatbuffers::String *>(VT_METADATA);
}
const flatbuffers::String *digest() const {
return GetPointer<const flatbuffers::String *>(VT_DIGEST);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
VerifyField<uint8_t>(verifier, VT_EVICT_IF_FULL) &&
VerifyOffset(verifier, VT_DATA) &&
verifier.VerifyString(data()) &&
VerifyOffset(verifier, VT_METADATA) &&
verifier.VerifyString(metadata()) &&
VerifyOffset(verifier, VT_DIGEST) &&
verifier.VerifyString(digest()) &&
verifier.EndTable();
}
PlasmaCreateAndSealRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaCreateAndSealRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaCreateAndSealRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaCreateAndSealRequestBuilder {
typedef PlasmaCreateAndSealRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaCreateAndSealRequest::VT_OBJECT_ID, object_id);
}
void add_evict_if_full(bool evict_if_full) {
fbb_.AddElement<uint8_t>(PlasmaCreateAndSealRequest::VT_EVICT_IF_FULL, static_cast<uint8_t>(evict_if_full), 0);
}
void add_data(flatbuffers::Offset<flatbuffers::String> data) {
fbb_.AddOffset(PlasmaCreateAndSealRequest::VT_DATA, data);
}
void add_metadata(flatbuffers::Offset<flatbuffers::String> metadata) {
fbb_.AddOffset(PlasmaCreateAndSealRequest::VT_METADATA, metadata);
}
void add_digest(flatbuffers::Offset<flatbuffers::String> digest) {
fbb_.AddOffset(PlasmaCreateAndSealRequest::VT_DIGEST, digest);
}
explicit PlasmaCreateAndSealRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaCreateAndSealRequestBuilder &operator=(const PlasmaCreateAndSealRequestBuilder &);
flatbuffers::Offset<PlasmaCreateAndSealRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaCreateAndSealRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaCreateAndSealRequest> CreatePlasmaCreateAndSealRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0,
bool evict_if_full = false,
flatbuffers::Offset<flatbuffers::String> data = 0,
flatbuffers::Offset<flatbuffers::String> metadata = 0,
flatbuffers::Offset<flatbuffers::String> digest = 0) {
PlasmaCreateAndSealRequestBuilder builder_(_fbb);
builder_.add_digest(digest);
builder_.add_metadata(metadata);
builder_.add_data(data);
builder_.add_object_id(object_id);
builder_.add_evict_if_full(evict_if_full);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaCreateAndSealRequest> CreatePlasmaCreateAndSealRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr,
bool evict_if_full = false,
const char *data = nullptr,
const char *metadata = nullptr,
const char *digest = nullptr) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
auto data__ = data ? _fbb.CreateString(data) : 0;
auto metadata__ = metadata ? _fbb.CreateString(metadata) : 0;
auto digest__ = digest ? _fbb.CreateString(digest) : 0;
return plasma::flatbuf::CreatePlasmaCreateAndSealRequest(
_fbb,
object_id__,
evict_if_full,
data__,
metadata__,
digest__);
}
flatbuffers::Offset<PlasmaCreateAndSealRequest> CreatePlasmaCreateAndSealRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaCreateAndSealReplyT : public flatbuffers::NativeTable {
typedef PlasmaCreateAndSealReply TableType;
plasma::flatbuf::PlasmaError error;
PlasmaCreateAndSealReplyT()
: error(plasma::flatbuf::PlasmaError::OK) {
}
};
struct PlasmaCreateAndSealReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaCreateAndSealReplyT NativeTableType;
typedef PlasmaCreateAndSealReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_ERROR = 4
};
plasma::flatbuf::PlasmaError error() const {
return static_cast<plasma::flatbuf::PlasmaError>(GetField<int32_t>(VT_ERROR, 0));
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<int32_t>(verifier, VT_ERROR) &&
verifier.EndTable();
}
PlasmaCreateAndSealReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaCreateAndSealReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaCreateAndSealReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaCreateAndSealReplyBuilder {
typedef PlasmaCreateAndSealReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_error(plasma::flatbuf::PlasmaError error) {
fbb_.AddElement<int32_t>(PlasmaCreateAndSealReply::VT_ERROR, static_cast<int32_t>(error), 0);
}
explicit PlasmaCreateAndSealReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaCreateAndSealReplyBuilder &operator=(const PlasmaCreateAndSealReplyBuilder &);
flatbuffers::Offset<PlasmaCreateAndSealReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaCreateAndSealReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaCreateAndSealReply> CreatePlasmaCreateAndSealReply(
flatbuffers::FlatBufferBuilder &_fbb,
plasma::flatbuf::PlasmaError error = plasma::flatbuf::PlasmaError::OK) {
PlasmaCreateAndSealReplyBuilder builder_(_fbb);
builder_.add_error(error);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaCreateAndSealReply> CreatePlasmaCreateAndSealReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaCreateAndSealBatchRequestT : public flatbuffers::NativeTable {
typedef PlasmaCreateAndSealBatchRequest TableType;
std::vector<std::string> object_ids;
bool evict_if_full;
std::vector<std::string> data;
std::vector<std::string> metadata;
std::vector<std::string> digest;
PlasmaCreateAndSealBatchRequestT()
: evict_if_full(false) {
}
};
struct PlasmaCreateAndSealBatchRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaCreateAndSealBatchRequestT NativeTableType;
typedef PlasmaCreateAndSealBatchRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_IDS = 4,
VT_EVICT_IF_FULL = 6,
VT_DATA = 8,
VT_METADATA = 10,
VT_DIGEST = 12
};
const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *object_ids() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *>(VT_OBJECT_IDS);
}
bool evict_if_full() const {
return GetField<uint8_t>(VT_EVICT_IF_FULL, 0) != 0;
}
const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *data() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *>(VT_DATA);
}
const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *metadata() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *>(VT_METADATA);
}
const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *digest() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *>(VT_DIGEST);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_IDS) &&
verifier.VerifyVector(object_ids()) &&
verifier.VerifyVectorOfStrings(object_ids()) &&
VerifyField<uint8_t>(verifier, VT_EVICT_IF_FULL) &&
VerifyOffset(verifier, VT_DATA) &&
verifier.VerifyVector(data()) &&
verifier.VerifyVectorOfStrings(data()) &&
VerifyOffset(verifier, VT_METADATA) &&
verifier.VerifyVector(metadata()) &&
verifier.VerifyVectorOfStrings(metadata()) &&
VerifyOffset(verifier, VT_DIGEST) &&
verifier.VerifyVector(digest()) &&
verifier.VerifyVectorOfStrings(digest()) &&
verifier.EndTable();
}
PlasmaCreateAndSealBatchRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaCreateAndSealBatchRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaCreateAndSealBatchRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealBatchRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaCreateAndSealBatchRequestBuilder {
typedef PlasmaCreateAndSealBatchRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_ids(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids) {
fbb_.AddOffset(PlasmaCreateAndSealBatchRequest::VT_OBJECT_IDS, object_ids);
}
void add_evict_if_full(bool evict_if_full) {
fbb_.AddElement<uint8_t>(PlasmaCreateAndSealBatchRequest::VT_EVICT_IF_FULL, static_cast<uint8_t>(evict_if_full), 0);
}
void add_data(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> data) {
fbb_.AddOffset(PlasmaCreateAndSealBatchRequest::VT_DATA, data);
}
void add_metadata(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> metadata) {
fbb_.AddOffset(PlasmaCreateAndSealBatchRequest::VT_METADATA, metadata);
}
void add_digest(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> digest) {
fbb_.AddOffset(PlasmaCreateAndSealBatchRequest::VT_DIGEST, digest);
}
explicit PlasmaCreateAndSealBatchRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaCreateAndSealBatchRequestBuilder &operator=(const PlasmaCreateAndSealBatchRequestBuilder &);
flatbuffers::Offset<PlasmaCreateAndSealBatchRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaCreateAndSealBatchRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaCreateAndSealBatchRequest> CreatePlasmaCreateAndSealBatchRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids = 0,
bool evict_if_full = false,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> data = 0,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> metadata = 0,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> digest = 0) {
PlasmaCreateAndSealBatchRequestBuilder builder_(_fbb);
builder_.add_digest(digest);
builder_.add_metadata(metadata);
builder_.add_data(data);
builder_.add_object_ids(object_ids);
builder_.add_evict_if_full(evict_if_full);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaCreateAndSealBatchRequest> CreatePlasmaCreateAndSealBatchRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const std::vector<flatbuffers::Offset<flatbuffers::String>> *object_ids = nullptr,
bool evict_if_full = false,
const std::vector<flatbuffers::Offset<flatbuffers::String>> *data = nullptr,
const std::vector<flatbuffers::Offset<flatbuffers::String>> *metadata = nullptr,
const std::vector<flatbuffers::Offset<flatbuffers::String>> *digest = nullptr) {
auto object_ids__ = object_ids ? _fbb.CreateVector<flatbuffers::Offset<flatbuffers::String>>(*object_ids) : 0;
auto data__ = data ? _fbb.CreateVector<flatbuffers::Offset<flatbuffers::String>>(*data) : 0;
auto metadata__ = metadata ? _fbb.CreateVector<flatbuffers::Offset<flatbuffers::String>>(*metadata) : 0;
auto digest__ = digest ? _fbb.CreateVector<flatbuffers::Offset<flatbuffers::String>>(*digest) : 0;
return plasma::flatbuf::CreatePlasmaCreateAndSealBatchRequest(
_fbb,
object_ids__,
evict_if_full,
data__,
metadata__,
digest__);
}
flatbuffers::Offset<PlasmaCreateAndSealBatchRequest> CreatePlasmaCreateAndSealBatchRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealBatchRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaCreateAndSealBatchReplyT : public flatbuffers::NativeTable {
typedef PlasmaCreateAndSealBatchReply TableType;
plasma::flatbuf::PlasmaError error;
PlasmaCreateAndSealBatchReplyT()
: error(plasma::flatbuf::PlasmaError::OK) {
}
};
struct PlasmaCreateAndSealBatchReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaCreateAndSealBatchReplyT NativeTableType;
typedef PlasmaCreateAndSealBatchReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_ERROR = 4
};
plasma::flatbuf::PlasmaError error() const {
return static_cast<plasma::flatbuf::PlasmaError>(GetField<int32_t>(VT_ERROR, 0));
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<int32_t>(verifier, VT_ERROR) &&
verifier.EndTable();
}
PlasmaCreateAndSealBatchReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaCreateAndSealBatchReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaCreateAndSealBatchReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealBatchReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaCreateAndSealBatchReplyBuilder {
typedef PlasmaCreateAndSealBatchReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_error(plasma::flatbuf::PlasmaError error) {
fbb_.AddElement<int32_t>(PlasmaCreateAndSealBatchReply::VT_ERROR, static_cast<int32_t>(error), 0);
}
explicit PlasmaCreateAndSealBatchReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaCreateAndSealBatchReplyBuilder &operator=(const PlasmaCreateAndSealBatchReplyBuilder &);
flatbuffers::Offset<PlasmaCreateAndSealBatchReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaCreateAndSealBatchReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaCreateAndSealBatchReply> CreatePlasmaCreateAndSealBatchReply(
flatbuffers::FlatBufferBuilder &_fbb,
plasma::flatbuf::PlasmaError error = plasma::flatbuf::PlasmaError::OK) {
PlasmaCreateAndSealBatchReplyBuilder builder_(_fbb);
builder_.add_error(error);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaCreateAndSealBatchReply> CreatePlasmaCreateAndSealBatchReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealBatchReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaAbortRequestT : public flatbuffers::NativeTable {
typedef PlasmaAbortRequest TableType;
std::string object_id;
PlasmaAbortRequestT() {
}
};
struct PlasmaAbortRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaAbortRequestT NativeTableType;
typedef PlasmaAbortRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
verifier.EndTable();
}
PlasmaAbortRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaAbortRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaAbortRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaAbortRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaAbortRequestBuilder {
typedef PlasmaAbortRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaAbortRequest::VT_OBJECT_ID, object_id);
}
explicit PlasmaAbortRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaAbortRequestBuilder &operator=(const PlasmaAbortRequestBuilder &);
flatbuffers::Offset<PlasmaAbortRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaAbortRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaAbortRequest> CreatePlasmaAbortRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0) {
PlasmaAbortRequestBuilder builder_(_fbb);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaAbortRequest> CreatePlasmaAbortRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaAbortRequest(
_fbb,
object_id__);
}
flatbuffers::Offset<PlasmaAbortRequest> CreatePlasmaAbortRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaAbortRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaAbortReplyT : public flatbuffers::NativeTable {
typedef PlasmaAbortReply TableType;
std::string object_id;
PlasmaAbortReplyT() {
}
};
struct PlasmaAbortReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaAbortReplyT NativeTableType;
typedef PlasmaAbortReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
verifier.EndTable();
}
PlasmaAbortReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaAbortReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaAbortReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaAbortReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaAbortReplyBuilder {
typedef PlasmaAbortReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaAbortReply::VT_OBJECT_ID, object_id);
}
explicit PlasmaAbortReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaAbortReplyBuilder &operator=(const PlasmaAbortReplyBuilder &);
flatbuffers::Offset<PlasmaAbortReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaAbortReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaAbortReply> CreatePlasmaAbortReply(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0) {
PlasmaAbortReplyBuilder builder_(_fbb);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaAbortReply> CreatePlasmaAbortReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaAbortReply(
_fbb,
object_id__);
}
flatbuffers::Offset<PlasmaAbortReply> CreatePlasmaAbortReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaAbortReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaSealRequestT : public flatbuffers::NativeTable {
typedef PlasmaSealRequest TableType;
std::string object_id;
std::string digest;
PlasmaSealRequestT() {
}
};
struct PlasmaSealRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaSealRequestT NativeTableType;
typedef PlasmaSealRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4,
VT_DIGEST = 6
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
const flatbuffers::String *digest() const {
return GetPointer<const flatbuffers::String *>(VT_DIGEST);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
VerifyOffset(verifier, VT_DIGEST) &&
verifier.VerifyString(digest()) &&
verifier.EndTable();
}
PlasmaSealRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaSealRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaSealRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSealRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaSealRequestBuilder {
typedef PlasmaSealRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaSealRequest::VT_OBJECT_ID, object_id);
}
void add_digest(flatbuffers::Offset<flatbuffers::String> digest) {
fbb_.AddOffset(PlasmaSealRequest::VT_DIGEST, digest);
}
explicit PlasmaSealRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaSealRequestBuilder &operator=(const PlasmaSealRequestBuilder &);
flatbuffers::Offset<PlasmaSealRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaSealRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaSealRequest> CreatePlasmaSealRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0,
flatbuffers::Offset<flatbuffers::String> digest = 0) {
PlasmaSealRequestBuilder builder_(_fbb);
builder_.add_digest(digest);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaSealRequest> CreatePlasmaSealRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr,
const char *digest = nullptr) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
auto digest__ = digest ? _fbb.CreateString(digest) : 0;
return plasma::flatbuf::CreatePlasmaSealRequest(
_fbb,
object_id__,
digest__);
}
flatbuffers::Offset<PlasmaSealRequest> CreatePlasmaSealRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSealRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaSealReplyT : public flatbuffers::NativeTable {
typedef PlasmaSealReply TableType;
std::string object_id;
plasma::flatbuf::PlasmaError error;
PlasmaSealReplyT()
: error(plasma::flatbuf::PlasmaError::OK) {
}
};
struct PlasmaSealReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaSealReplyT NativeTableType;
typedef PlasmaSealReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4,
VT_ERROR = 6
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
plasma::flatbuf::PlasmaError error() const {
return static_cast<plasma::flatbuf::PlasmaError>(GetField<int32_t>(VT_ERROR, 0));
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
VerifyField<int32_t>(verifier, VT_ERROR) &&
verifier.EndTable();
}
PlasmaSealReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaSealReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaSealReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSealReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaSealReplyBuilder {
typedef PlasmaSealReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaSealReply::VT_OBJECT_ID, object_id);
}
void add_error(plasma::flatbuf::PlasmaError error) {
fbb_.AddElement<int32_t>(PlasmaSealReply::VT_ERROR, static_cast<int32_t>(error), 0);
}
explicit PlasmaSealReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaSealReplyBuilder &operator=(const PlasmaSealReplyBuilder &);
flatbuffers::Offset<PlasmaSealReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaSealReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaSealReply> CreatePlasmaSealReply(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0,
plasma::flatbuf::PlasmaError error = plasma::flatbuf::PlasmaError::OK) {
PlasmaSealReplyBuilder builder_(_fbb);
builder_.add_error(error);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaSealReply> CreatePlasmaSealReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr,
plasma::flatbuf::PlasmaError error = plasma::flatbuf::PlasmaError::OK) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaSealReply(
_fbb,
object_id__,
error);
}
flatbuffers::Offset<PlasmaSealReply> CreatePlasmaSealReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSealReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaGetRequestT : public flatbuffers::NativeTable {
typedef PlasmaGetRequest TableType;
std::vector<std::string> object_ids;
int64_t timeout_ms;
PlasmaGetRequestT()
: timeout_ms(0) {
}
};
struct PlasmaGetRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaGetRequestT NativeTableType;
typedef PlasmaGetRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_IDS = 4,
VT_TIMEOUT_MS = 6
};
const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *object_ids() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *>(VT_OBJECT_IDS);
}
int64_t timeout_ms() const {
return GetField<int64_t>(VT_TIMEOUT_MS, 0);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_IDS) &&
verifier.VerifyVector(object_ids()) &&
verifier.VerifyVectorOfStrings(object_ids()) &&
VerifyField<int64_t>(verifier, VT_TIMEOUT_MS) &&
verifier.EndTable();
}
PlasmaGetRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaGetRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaGetRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaGetRequestBuilder {
typedef PlasmaGetRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_ids(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids) {
fbb_.AddOffset(PlasmaGetRequest::VT_OBJECT_IDS, object_ids);
}
void add_timeout_ms(int64_t timeout_ms) {
fbb_.AddElement<int64_t>(PlasmaGetRequest::VT_TIMEOUT_MS, timeout_ms, 0);
}
explicit PlasmaGetRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaGetRequestBuilder &operator=(const PlasmaGetRequestBuilder &);
flatbuffers::Offset<PlasmaGetRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaGetRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaGetRequest> CreatePlasmaGetRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids = 0,
int64_t timeout_ms = 0) {
PlasmaGetRequestBuilder builder_(_fbb);
builder_.add_timeout_ms(timeout_ms);
builder_.add_object_ids(object_ids);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaGetRequest> CreatePlasmaGetRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const std::vector<flatbuffers::Offset<flatbuffers::String>> *object_ids = nullptr,
int64_t timeout_ms = 0) {
auto object_ids__ = object_ids ? _fbb.CreateVector<flatbuffers::Offset<flatbuffers::String>>(*object_ids) : 0;
return plasma::flatbuf::CreatePlasmaGetRequest(
_fbb,
object_ids__,
timeout_ms);
}
flatbuffers::Offset<PlasmaGetRequest> CreatePlasmaGetRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaGetReplyT : public flatbuffers::NativeTable {
typedef PlasmaGetReply TableType;
std::vector<std::string> object_ids;
std::vector<plasma::flatbuf::PlasmaObjectSpec> plasma_objects;
std::vector<int32_t> store_fds;
std::vector<int64_t> mmap_sizes;
std::vector<std::unique_ptr<plasma::flatbuf::CudaHandleT>> handles;
PlasmaGetReplyT() {
}
};
struct PlasmaGetReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaGetReplyT NativeTableType;
typedef PlasmaGetReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_IDS = 4,
VT_PLASMA_OBJECTS = 6,
VT_STORE_FDS = 8,
VT_MMAP_SIZES = 10,
VT_HANDLES = 12
};
const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *object_ids() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *>(VT_OBJECT_IDS);
}
const flatbuffers::Vector<const plasma::flatbuf::PlasmaObjectSpec *> *plasma_objects() const {
return GetPointer<const flatbuffers::Vector<const plasma::flatbuf::PlasmaObjectSpec *> *>(VT_PLASMA_OBJECTS);
}
const flatbuffers::Vector<int32_t> *store_fds() const {
return GetPointer<const flatbuffers::Vector<int32_t> *>(VT_STORE_FDS);
}
const flatbuffers::Vector<int64_t> *mmap_sizes() const {
return GetPointer<const flatbuffers::Vector<int64_t> *>(VT_MMAP_SIZES);
}
const flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::CudaHandle>> *handles() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::CudaHandle>> *>(VT_HANDLES);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_IDS) &&
verifier.VerifyVector(object_ids()) &&
verifier.VerifyVectorOfStrings(object_ids()) &&
VerifyOffset(verifier, VT_PLASMA_OBJECTS) &&
verifier.VerifyVector(plasma_objects()) &&
VerifyOffset(verifier, VT_STORE_FDS) &&
verifier.VerifyVector(store_fds()) &&
VerifyOffset(verifier, VT_MMAP_SIZES) &&
verifier.VerifyVector(mmap_sizes()) &&
VerifyOffset(verifier, VT_HANDLES) &&
verifier.VerifyVector(handles()) &&
verifier.VerifyVectorOfTables(handles()) &&
verifier.EndTable();
}
PlasmaGetReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaGetReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaGetReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaGetReplyBuilder {
typedef PlasmaGetReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_ids(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids) {
fbb_.AddOffset(PlasmaGetReply::VT_OBJECT_IDS, object_ids);
}
void add_plasma_objects(flatbuffers::Offset<flatbuffers::Vector<const plasma::flatbuf::PlasmaObjectSpec *>> plasma_objects) {
fbb_.AddOffset(PlasmaGetReply::VT_PLASMA_OBJECTS, plasma_objects);
}
void add_store_fds(flatbuffers::Offset<flatbuffers::Vector<int32_t>> store_fds) {
fbb_.AddOffset(PlasmaGetReply::VT_STORE_FDS, store_fds);
}
void add_mmap_sizes(flatbuffers::Offset<flatbuffers::Vector<int64_t>> mmap_sizes) {
fbb_.AddOffset(PlasmaGetReply::VT_MMAP_SIZES, mmap_sizes);
}
void add_handles(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::CudaHandle>>> handles) {
fbb_.AddOffset(PlasmaGetReply::VT_HANDLES, handles);
}
explicit PlasmaGetReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaGetReplyBuilder &operator=(const PlasmaGetReplyBuilder &);
flatbuffers::Offset<PlasmaGetReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaGetReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaGetReply> CreatePlasmaGetReply(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids = 0,
flatbuffers::Offset<flatbuffers::Vector<const plasma::flatbuf::PlasmaObjectSpec *>> plasma_objects = 0,
flatbuffers::Offset<flatbuffers::Vector<int32_t>> store_fds = 0,
flatbuffers::Offset<flatbuffers::Vector<int64_t>> mmap_sizes = 0,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::CudaHandle>>> handles = 0) {
PlasmaGetReplyBuilder builder_(_fbb);
builder_.add_handles(handles);
builder_.add_mmap_sizes(mmap_sizes);
builder_.add_store_fds(store_fds);
builder_.add_plasma_objects(plasma_objects);
builder_.add_object_ids(object_ids);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaGetReply> CreatePlasmaGetReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const std::vector<flatbuffers::Offset<flatbuffers::String>> *object_ids = nullptr,
const std::vector<plasma::flatbuf::PlasmaObjectSpec> *plasma_objects = nullptr,
const std::vector<int32_t> *store_fds = nullptr,
const std::vector<int64_t> *mmap_sizes = nullptr,
const std::vector<flatbuffers::Offset<plasma::flatbuf::CudaHandle>> *handles = nullptr) {
auto object_ids__ = object_ids ? _fbb.CreateVector<flatbuffers::Offset<flatbuffers::String>>(*object_ids) : 0;
auto plasma_objects__ = plasma_objects ? _fbb.CreateVectorOfStructs<plasma::flatbuf::PlasmaObjectSpec>(*plasma_objects) : 0;
auto store_fds__ = store_fds ? _fbb.CreateVector<int32_t>(*store_fds) : 0;
auto mmap_sizes__ = mmap_sizes ? _fbb.CreateVector<int64_t>(*mmap_sizes) : 0;
auto handles__ = handles ? _fbb.CreateVector<flatbuffers::Offset<plasma::flatbuf::CudaHandle>>(*handles) : 0;
return plasma::flatbuf::CreatePlasmaGetReply(
_fbb,
object_ids__,
plasma_objects__,
store_fds__,
mmap_sizes__,
handles__);
}
flatbuffers::Offset<PlasmaGetReply> CreatePlasmaGetReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaReleaseRequestT : public flatbuffers::NativeTable {
typedef PlasmaReleaseRequest TableType;
std::string object_id;
PlasmaReleaseRequestT() {
}
};
struct PlasmaReleaseRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaReleaseRequestT NativeTableType;
typedef PlasmaReleaseRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
verifier.EndTable();
}
PlasmaReleaseRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaReleaseRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaReleaseRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaReleaseRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaReleaseRequestBuilder {
typedef PlasmaReleaseRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaReleaseRequest::VT_OBJECT_ID, object_id);
}
explicit PlasmaReleaseRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaReleaseRequestBuilder &operator=(const PlasmaReleaseRequestBuilder &);
flatbuffers::Offset<PlasmaReleaseRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaReleaseRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaReleaseRequest> CreatePlasmaReleaseRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0) {
PlasmaReleaseRequestBuilder builder_(_fbb);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaReleaseRequest> CreatePlasmaReleaseRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaReleaseRequest(
_fbb,
object_id__);
}
flatbuffers::Offset<PlasmaReleaseRequest> CreatePlasmaReleaseRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaReleaseRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaReleaseReplyT : public flatbuffers::NativeTable {
typedef PlasmaReleaseReply TableType;
std::string object_id;
plasma::flatbuf::PlasmaError error;
PlasmaReleaseReplyT()
: error(plasma::flatbuf::PlasmaError::OK) {
}
};
struct PlasmaReleaseReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaReleaseReplyT NativeTableType;
typedef PlasmaReleaseReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4,
VT_ERROR = 6
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
plasma::flatbuf::PlasmaError error() const {
return static_cast<plasma::flatbuf::PlasmaError>(GetField<int32_t>(VT_ERROR, 0));
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
VerifyField<int32_t>(verifier, VT_ERROR) &&
verifier.EndTable();
}
PlasmaReleaseReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaReleaseReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaReleaseReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaReleaseReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaReleaseReplyBuilder {
typedef PlasmaReleaseReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaReleaseReply::VT_OBJECT_ID, object_id);
}
void add_error(plasma::flatbuf::PlasmaError error) {
fbb_.AddElement<int32_t>(PlasmaReleaseReply::VT_ERROR, static_cast<int32_t>(error), 0);
}
explicit PlasmaReleaseReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaReleaseReplyBuilder &operator=(const PlasmaReleaseReplyBuilder &);
flatbuffers::Offset<PlasmaReleaseReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaReleaseReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaReleaseReply> CreatePlasmaReleaseReply(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0,
plasma::flatbuf::PlasmaError error = plasma::flatbuf::PlasmaError::OK) {
PlasmaReleaseReplyBuilder builder_(_fbb);
builder_.add_error(error);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaReleaseReply> CreatePlasmaReleaseReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr,
plasma::flatbuf::PlasmaError error = plasma::flatbuf::PlasmaError::OK) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaReleaseReply(
_fbb,
object_id__,
error);
}
flatbuffers::Offset<PlasmaReleaseReply> CreatePlasmaReleaseReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaReleaseReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaDeleteRequestT : public flatbuffers::NativeTable {
typedef PlasmaDeleteRequest TableType;
int32_t count;
std::vector<std::string> object_ids;
PlasmaDeleteRequestT()
: count(0) {
}
};
struct PlasmaDeleteRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaDeleteRequestT NativeTableType;
typedef PlasmaDeleteRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_COUNT = 4,
VT_OBJECT_IDS = 6
};
int32_t count() const {
return GetField<int32_t>(VT_COUNT, 0);
}
const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *object_ids() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *>(VT_OBJECT_IDS);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<int32_t>(verifier, VT_COUNT) &&
VerifyOffset(verifier, VT_OBJECT_IDS) &&
verifier.VerifyVector(object_ids()) &&
verifier.VerifyVectorOfStrings(object_ids()) &&
verifier.EndTable();
}
PlasmaDeleteRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaDeleteRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaDeleteRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDeleteRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaDeleteRequestBuilder {
typedef PlasmaDeleteRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_count(int32_t count) {
fbb_.AddElement<int32_t>(PlasmaDeleteRequest::VT_COUNT, count, 0);
}
void add_object_ids(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids) {
fbb_.AddOffset(PlasmaDeleteRequest::VT_OBJECT_IDS, object_ids);
}
explicit PlasmaDeleteRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaDeleteRequestBuilder &operator=(const PlasmaDeleteRequestBuilder &);
flatbuffers::Offset<PlasmaDeleteRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaDeleteRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaDeleteRequest> CreatePlasmaDeleteRequest(
flatbuffers::FlatBufferBuilder &_fbb,
int32_t count = 0,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids = 0) {
PlasmaDeleteRequestBuilder builder_(_fbb);
builder_.add_object_ids(object_ids);
builder_.add_count(count);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaDeleteRequest> CreatePlasmaDeleteRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
int32_t count = 0,
const std::vector<flatbuffers::Offset<flatbuffers::String>> *object_ids = nullptr) {
auto object_ids__ = object_ids ? _fbb.CreateVector<flatbuffers::Offset<flatbuffers::String>>(*object_ids) : 0;
return plasma::flatbuf::CreatePlasmaDeleteRequest(
_fbb,
count,
object_ids__);
}
flatbuffers::Offset<PlasmaDeleteRequest> CreatePlasmaDeleteRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDeleteRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaDeleteReplyT : public flatbuffers::NativeTable {
typedef PlasmaDeleteReply TableType;
int32_t count;
std::vector<std::string> object_ids;
std::vector<plasma::flatbuf::PlasmaError> errors;
PlasmaDeleteReplyT()
: count(0) {
}
};
struct PlasmaDeleteReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaDeleteReplyT NativeTableType;
typedef PlasmaDeleteReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_COUNT = 4,
VT_OBJECT_IDS = 6,
VT_ERRORS = 8
};
int32_t count() const {
return GetField<int32_t>(VT_COUNT, 0);
}
const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *object_ids() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *>(VT_OBJECT_IDS);
}
const flatbuffers::Vector<int32_t> *errors() const {
return GetPointer<const flatbuffers::Vector<int32_t> *>(VT_ERRORS);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<int32_t>(verifier, VT_COUNT) &&
VerifyOffset(verifier, VT_OBJECT_IDS) &&
verifier.VerifyVector(object_ids()) &&
verifier.VerifyVectorOfStrings(object_ids()) &&
VerifyOffset(verifier, VT_ERRORS) &&
verifier.VerifyVector(errors()) &&
verifier.EndTable();
}
PlasmaDeleteReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaDeleteReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaDeleteReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDeleteReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaDeleteReplyBuilder {
typedef PlasmaDeleteReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_count(int32_t count) {
fbb_.AddElement<int32_t>(PlasmaDeleteReply::VT_COUNT, count, 0);
}
void add_object_ids(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids) {
fbb_.AddOffset(PlasmaDeleteReply::VT_OBJECT_IDS, object_ids);
}
void add_errors(flatbuffers::Offset<flatbuffers::Vector<int32_t>> errors) {
fbb_.AddOffset(PlasmaDeleteReply::VT_ERRORS, errors);
}
explicit PlasmaDeleteReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaDeleteReplyBuilder &operator=(const PlasmaDeleteReplyBuilder &);
flatbuffers::Offset<PlasmaDeleteReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaDeleteReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaDeleteReply> CreatePlasmaDeleteReply(
flatbuffers::FlatBufferBuilder &_fbb,
int32_t count = 0,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids = 0,
flatbuffers::Offset<flatbuffers::Vector<int32_t>> errors = 0) {
PlasmaDeleteReplyBuilder builder_(_fbb);
builder_.add_errors(errors);
builder_.add_object_ids(object_ids);
builder_.add_count(count);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaDeleteReply> CreatePlasmaDeleteReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
int32_t count = 0,
const std::vector<flatbuffers::Offset<flatbuffers::String>> *object_ids = nullptr,
const std::vector<int32_t> *errors = nullptr) {
auto object_ids__ = object_ids ? _fbb.CreateVector<flatbuffers::Offset<flatbuffers::String>>(*object_ids) : 0;
auto errors__ = errors ? _fbb.CreateVector<int32_t>(*errors) : 0;
return plasma::flatbuf::CreatePlasmaDeleteReply(
_fbb,
count,
object_ids__,
errors__);
}
flatbuffers::Offset<PlasmaDeleteReply> CreatePlasmaDeleteReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDeleteReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaContainsRequestT : public flatbuffers::NativeTable {
typedef PlasmaContainsRequest TableType;
std::string object_id;
PlasmaContainsRequestT() {
}
};
struct PlasmaContainsRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaContainsRequestT NativeTableType;
typedef PlasmaContainsRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
verifier.EndTable();
}
PlasmaContainsRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaContainsRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaContainsRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaContainsRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaContainsRequestBuilder {
typedef PlasmaContainsRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaContainsRequest::VT_OBJECT_ID, object_id);
}
explicit PlasmaContainsRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaContainsRequestBuilder &operator=(const PlasmaContainsRequestBuilder &);
flatbuffers::Offset<PlasmaContainsRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaContainsRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaContainsRequest> CreatePlasmaContainsRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0) {
PlasmaContainsRequestBuilder builder_(_fbb);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaContainsRequest> CreatePlasmaContainsRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaContainsRequest(
_fbb,
object_id__);
}
flatbuffers::Offset<PlasmaContainsRequest> CreatePlasmaContainsRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaContainsRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaContainsReplyT : public flatbuffers::NativeTable {
typedef PlasmaContainsReply TableType;
std::string object_id;
int32_t has_object;
PlasmaContainsReplyT()
: has_object(0) {
}
};
struct PlasmaContainsReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaContainsReplyT NativeTableType;
typedef PlasmaContainsReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4,
VT_HAS_OBJECT = 6
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
int32_t has_object() const {
return GetField<int32_t>(VT_HAS_OBJECT, 0);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
VerifyField<int32_t>(verifier, VT_HAS_OBJECT) &&
verifier.EndTable();
}
PlasmaContainsReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaContainsReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaContainsReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaContainsReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaContainsReplyBuilder {
typedef PlasmaContainsReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaContainsReply::VT_OBJECT_ID, object_id);
}
void add_has_object(int32_t has_object) {
fbb_.AddElement<int32_t>(PlasmaContainsReply::VT_HAS_OBJECT, has_object, 0);
}
explicit PlasmaContainsReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaContainsReplyBuilder &operator=(const PlasmaContainsReplyBuilder &);
flatbuffers::Offset<PlasmaContainsReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaContainsReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaContainsReply> CreatePlasmaContainsReply(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0,
int32_t has_object = 0) {
PlasmaContainsReplyBuilder builder_(_fbb);
builder_.add_has_object(has_object);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaContainsReply> CreatePlasmaContainsReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr,
int32_t has_object = 0) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaContainsReply(
_fbb,
object_id__,
has_object);
}
flatbuffers::Offset<PlasmaContainsReply> CreatePlasmaContainsReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaContainsReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaListRequestT : public flatbuffers::NativeTable {
typedef PlasmaListRequest TableType;
PlasmaListRequestT() {
}
};
struct PlasmaListRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaListRequestT NativeTableType;
typedef PlasmaListRequestBuilder Builder;
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
verifier.EndTable();
}
PlasmaListRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaListRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaListRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaListRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaListRequestBuilder {
typedef PlasmaListRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
explicit PlasmaListRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaListRequestBuilder &operator=(const PlasmaListRequestBuilder &);
flatbuffers::Offset<PlasmaListRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaListRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaListRequest> CreatePlasmaListRequest(
flatbuffers::FlatBufferBuilder &_fbb) {
PlasmaListRequestBuilder builder_(_fbb);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaListRequest> CreatePlasmaListRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaListRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaListReplyT : public flatbuffers::NativeTable {
typedef PlasmaListReply TableType;
std::vector<std::unique_ptr<plasma::flatbuf::ObjectInfoT>> objects;
PlasmaListReplyT() {
}
};
struct PlasmaListReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaListReplyT NativeTableType;
typedef PlasmaListReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECTS = 4
};
const flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>> *objects() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>> *>(VT_OBJECTS);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECTS) &&
verifier.VerifyVector(objects()) &&
verifier.VerifyVectorOfTables(objects()) &&
verifier.EndTable();
}
PlasmaListReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaListReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaListReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaListReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaListReplyBuilder {
typedef PlasmaListReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_objects(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>>> objects) {
fbb_.AddOffset(PlasmaListReply::VT_OBJECTS, objects);
}
explicit PlasmaListReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaListReplyBuilder &operator=(const PlasmaListReplyBuilder &);
flatbuffers::Offset<PlasmaListReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaListReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaListReply> CreatePlasmaListReply(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>>> objects = 0) {
PlasmaListReplyBuilder builder_(_fbb);
builder_.add_objects(objects);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaListReply> CreatePlasmaListReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const std::vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>> *objects = nullptr) {
auto objects__ = objects ? _fbb.CreateVector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>>(*objects) : 0;
return plasma::flatbuf::CreatePlasmaListReply(
_fbb,
objects__);
}
flatbuffers::Offset<PlasmaListReply> CreatePlasmaListReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaListReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaConnectRequestT : public flatbuffers::NativeTable {
typedef PlasmaConnectRequest TableType;
PlasmaConnectRequestT() {
}
};
struct PlasmaConnectRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaConnectRequestT NativeTableType;
typedef PlasmaConnectRequestBuilder Builder;
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
verifier.EndTable();
}
PlasmaConnectRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaConnectRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaConnectRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaConnectRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaConnectRequestBuilder {
typedef PlasmaConnectRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
explicit PlasmaConnectRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaConnectRequestBuilder &operator=(const PlasmaConnectRequestBuilder &);
flatbuffers::Offset<PlasmaConnectRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaConnectRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaConnectRequest> CreatePlasmaConnectRequest(
flatbuffers::FlatBufferBuilder &_fbb) {
PlasmaConnectRequestBuilder builder_(_fbb);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaConnectRequest> CreatePlasmaConnectRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaConnectRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaConnectReplyT : public flatbuffers::NativeTable {
typedef PlasmaConnectReply TableType;
int64_t memory_capacity;
PlasmaConnectReplyT()
: memory_capacity(0) {
}
};
struct PlasmaConnectReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaConnectReplyT NativeTableType;
typedef PlasmaConnectReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_MEMORY_CAPACITY = 4
};
int64_t memory_capacity() const {
return GetField<int64_t>(VT_MEMORY_CAPACITY, 0);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<int64_t>(verifier, VT_MEMORY_CAPACITY) &&
verifier.EndTable();
}
PlasmaConnectReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaConnectReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaConnectReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaConnectReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaConnectReplyBuilder {
typedef PlasmaConnectReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_memory_capacity(int64_t memory_capacity) {
fbb_.AddElement<int64_t>(PlasmaConnectReply::VT_MEMORY_CAPACITY, memory_capacity, 0);
}
explicit PlasmaConnectReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaConnectReplyBuilder &operator=(const PlasmaConnectReplyBuilder &);
flatbuffers::Offset<PlasmaConnectReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaConnectReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaConnectReply> CreatePlasmaConnectReply(
flatbuffers::FlatBufferBuilder &_fbb,
int64_t memory_capacity = 0) {
PlasmaConnectReplyBuilder builder_(_fbb);
builder_.add_memory_capacity(memory_capacity);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaConnectReply> CreatePlasmaConnectReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaConnectReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaEvictRequestT : public flatbuffers::NativeTable {
typedef PlasmaEvictRequest TableType;
uint64_t num_bytes;
PlasmaEvictRequestT()
: num_bytes(0) {
}
};
struct PlasmaEvictRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaEvictRequestT NativeTableType;
typedef PlasmaEvictRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_NUM_BYTES = 4
};
uint64_t num_bytes() const {
return GetField<uint64_t>(VT_NUM_BYTES, 0);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<uint64_t>(verifier, VT_NUM_BYTES) &&
verifier.EndTable();
}
PlasmaEvictRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaEvictRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaEvictRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaEvictRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaEvictRequestBuilder {
typedef PlasmaEvictRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_num_bytes(uint64_t num_bytes) {
fbb_.AddElement<uint64_t>(PlasmaEvictRequest::VT_NUM_BYTES, num_bytes, 0);
}
explicit PlasmaEvictRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaEvictRequestBuilder &operator=(const PlasmaEvictRequestBuilder &);
flatbuffers::Offset<PlasmaEvictRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaEvictRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaEvictRequest> CreatePlasmaEvictRequest(
flatbuffers::FlatBufferBuilder &_fbb,
uint64_t num_bytes = 0) {
PlasmaEvictRequestBuilder builder_(_fbb);
builder_.add_num_bytes(num_bytes);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaEvictRequest> CreatePlasmaEvictRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaEvictRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaEvictReplyT : public flatbuffers::NativeTable {
typedef PlasmaEvictReply TableType;
uint64_t num_bytes;
PlasmaEvictReplyT()
: num_bytes(0) {
}
};
struct PlasmaEvictReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaEvictReplyT NativeTableType;
typedef PlasmaEvictReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_NUM_BYTES = 4
};
uint64_t num_bytes() const {
return GetField<uint64_t>(VT_NUM_BYTES, 0);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<uint64_t>(verifier, VT_NUM_BYTES) &&
verifier.EndTable();
}
PlasmaEvictReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaEvictReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaEvictReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaEvictReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaEvictReplyBuilder {
typedef PlasmaEvictReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_num_bytes(uint64_t num_bytes) {
fbb_.AddElement<uint64_t>(PlasmaEvictReply::VT_NUM_BYTES, num_bytes, 0);
}
explicit PlasmaEvictReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaEvictReplyBuilder &operator=(const PlasmaEvictReplyBuilder &);
flatbuffers::Offset<PlasmaEvictReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaEvictReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaEvictReply> CreatePlasmaEvictReply(
flatbuffers::FlatBufferBuilder &_fbb,
uint64_t num_bytes = 0) {
PlasmaEvictReplyBuilder builder_(_fbb);
builder_.add_num_bytes(num_bytes);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaEvictReply> CreatePlasmaEvictReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaEvictReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaSubscribeRequestT : public flatbuffers::NativeTable {
typedef PlasmaSubscribeRequest TableType;
PlasmaSubscribeRequestT() {
}
};
struct PlasmaSubscribeRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaSubscribeRequestT NativeTableType;
typedef PlasmaSubscribeRequestBuilder Builder;
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
verifier.EndTable();
}
PlasmaSubscribeRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaSubscribeRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaSubscribeRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSubscribeRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaSubscribeRequestBuilder {
typedef PlasmaSubscribeRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
explicit PlasmaSubscribeRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaSubscribeRequestBuilder &operator=(const PlasmaSubscribeRequestBuilder &);
flatbuffers::Offset<PlasmaSubscribeRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaSubscribeRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaSubscribeRequest> CreatePlasmaSubscribeRequest(
flatbuffers::FlatBufferBuilder &_fbb) {
PlasmaSubscribeRequestBuilder builder_(_fbb);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaSubscribeRequest> CreatePlasmaSubscribeRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSubscribeRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaNotificationT : public flatbuffers::NativeTable {
typedef PlasmaNotification TableType;
std::vector<std::unique_ptr<plasma::flatbuf::ObjectInfoT>> object_info;
PlasmaNotificationT() {
}
};
struct PlasmaNotification FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaNotificationT NativeTableType;
typedef PlasmaNotificationBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_INFO = 4
};
const flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>> *object_info() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>> *>(VT_OBJECT_INFO);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_INFO) &&
verifier.VerifyVector(object_info()) &&
verifier.VerifyVectorOfTables(object_info()) &&
verifier.EndTable();
}
PlasmaNotificationT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaNotificationT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaNotification> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaNotificationT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaNotificationBuilder {
typedef PlasmaNotification Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_info(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>>> object_info) {
fbb_.AddOffset(PlasmaNotification::VT_OBJECT_INFO, object_info);
}
explicit PlasmaNotificationBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaNotificationBuilder &operator=(const PlasmaNotificationBuilder &);
flatbuffers::Offset<PlasmaNotification> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaNotification>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaNotification> CreatePlasmaNotification(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>>> object_info = 0) {
PlasmaNotificationBuilder builder_(_fbb);
builder_.add_object_info(object_info);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaNotification> CreatePlasmaNotificationDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const std::vector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>> *object_info = nullptr) {
auto object_info__ = object_info ? _fbb.CreateVector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>>(*object_info) : 0;
return plasma::flatbuf::CreatePlasmaNotification(
_fbb,
object_info__);
}
flatbuffers::Offset<PlasmaNotification> CreatePlasmaNotification(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaNotificationT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaDataRequestT : public flatbuffers::NativeTable {
typedef PlasmaDataRequest TableType;
std::string object_id;
std::string address;
int32_t port;
PlasmaDataRequestT()
: port(0) {
}
};
struct PlasmaDataRequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaDataRequestT NativeTableType;
typedef PlasmaDataRequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4,
VT_ADDRESS = 6,
VT_PORT = 8
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
const flatbuffers::String *address() const {
return GetPointer<const flatbuffers::String *>(VT_ADDRESS);
}
int32_t port() const {
return GetField<int32_t>(VT_PORT, 0);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
VerifyOffset(verifier, VT_ADDRESS) &&
verifier.VerifyString(address()) &&
VerifyField<int32_t>(verifier, VT_PORT) &&
verifier.EndTable();
}
PlasmaDataRequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaDataRequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaDataRequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDataRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaDataRequestBuilder {
typedef PlasmaDataRequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaDataRequest::VT_OBJECT_ID, object_id);
}
void add_address(flatbuffers::Offset<flatbuffers::String> address) {
fbb_.AddOffset(PlasmaDataRequest::VT_ADDRESS, address);
}
void add_port(int32_t port) {
fbb_.AddElement<int32_t>(PlasmaDataRequest::VT_PORT, port, 0);
}
explicit PlasmaDataRequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaDataRequestBuilder &operator=(const PlasmaDataRequestBuilder &);
flatbuffers::Offset<PlasmaDataRequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaDataRequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaDataRequest> CreatePlasmaDataRequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0,
flatbuffers::Offset<flatbuffers::String> address = 0,
int32_t port = 0) {
PlasmaDataRequestBuilder builder_(_fbb);
builder_.add_port(port);
builder_.add_address(address);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaDataRequest> CreatePlasmaDataRequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr,
const char *address = nullptr,
int32_t port = 0) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
auto address__ = address ? _fbb.CreateString(address) : 0;
return plasma::flatbuf::CreatePlasmaDataRequest(
_fbb,
object_id__,
address__,
port);
}
flatbuffers::Offset<PlasmaDataRequest> CreatePlasmaDataRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDataRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaDataReplyT : public flatbuffers::NativeTable {
typedef PlasmaDataReply TableType;
std::string object_id;
uint64_t object_size;
uint64_t metadata_size;
PlasmaDataReplyT()
: object_size(0),
metadata_size(0) {
}
};
struct PlasmaDataReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaDataReplyT NativeTableType;
typedef PlasmaDataReplyBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_ID = 4,
VT_OBJECT_SIZE = 6,
VT_METADATA_SIZE = 8
};
const flatbuffers::String *object_id() const {
return GetPointer<const flatbuffers::String *>(VT_OBJECT_ID);
}
uint64_t object_size() const {
return GetField<uint64_t>(VT_OBJECT_SIZE, 0);
}
uint64_t metadata_size() const {
return GetField<uint64_t>(VT_METADATA_SIZE, 0);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_ID) &&
verifier.VerifyString(object_id()) &&
VerifyField<uint64_t>(verifier, VT_OBJECT_SIZE) &&
VerifyField<uint64_t>(verifier, VT_METADATA_SIZE) &&
verifier.EndTable();
}
PlasmaDataReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaDataReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaDataReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDataReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaDataReplyBuilder {
typedef PlasmaDataReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_id(flatbuffers::Offset<flatbuffers::String> object_id) {
fbb_.AddOffset(PlasmaDataReply::VT_OBJECT_ID, object_id);
}
void add_object_size(uint64_t object_size) {
fbb_.AddElement<uint64_t>(PlasmaDataReply::VT_OBJECT_SIZE, object_size, 0);
}
void add_metadata_size(uint64_t metadata_size) {
fbb_.AddElement<uint64_t>(PlasmaDataReply::VT_METADATA_SIZE, metadata_size, 0);
}
explicit PlasmaDataReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaDataReplyBuilder &operator=(const PlasmaDataReplyBuilder &);
flatbuffers::Offset<PlasmaDataReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaDataReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaDataReply> CreatePlasmaDataReply(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::String> object_id = 0,
uint64_t object_size = 0,
uint64_t metadata_size = 0) {
PlasmaDataReplyBuilder builder_(_fbb);
builder_.add_metadata_size(metadata_size);
builder_.add_object_size(object_size);
builder_.add_object_id(object_id);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaDataReply> CreatePlasmaDataReplyDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const char *object_id = nullptr,
uint64_t object_size = 0,
uint64_t metadata_size = 0) {
auto object_id__ = object_id ? _fbb.CreateString(object_id) : 0;
return plasma::flatbuf::CreatePlasmaDataReply(
_fbb,
object_id__,
object_size,
metadata_size);
}
flatbuffers::Offset<PlasmaDataReply> CreatePlasmaDataReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDataReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaRefreshLRURequestT : public flatbuffers::NativeTable {
typedef PlasmaRefreshLRURequest TableType;
std::vector<std::string> object_ids;
PlasmaRefreshLRURequestT() {
}
};
struct PlasmaRefreshLRURequest FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaRefreshLRURequestT NativeTableType;
typedef PlasmaRefreshLRURequestBuilder Builder;
enum FlatBuffersVTableOffset FLATBUFFERS_VTABLE_UNDERLYING_TYPE {
VT_OBJECT_IDS = 4
};
const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *object_ids() const {
return GetPointer<const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *>(VT_OBJECT_IDS);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyOffset(verifier, VT_OBJECT_IDS) &&
verifier.VerifyVector(object_ids()) &&
verifier.VerifyVectorOfStrings(object_ids()) &&
verifier.EndTable();
}
PlasmaRefreshLRURequestT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaRefreshLRURequestT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaRefreshLRURequest> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaRefreshLRURequestT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaRefreshLRURequestBuilder {
typedef PlasmaRefreshLRURequest Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_object_ids(flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids) {
fbb_.AddOffset(PlasmaRefreshLRURequest::VT_OBJECT_IDS, object_ids);
}
explicit PlasmaRefreshLRURequestBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaRefreshLRURequestBuilder &operator=(const PlasmaRefreshLRURequestBuilder &);
flatbuffers::Offset<PlasmaRefreshLRURequest> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaRefreshLRURequest>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaRefreshLRURequest> CreatePlasmaRefreshLRURequest(
flatbuffers::FlatBufferBuilder &_fbb,
flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> object_ids = 0) {
PlasmaRefreshLRURequestBuilder builder_(_fbb);
builder_.add_object_ids(object_ids);
return builder_.Finish();
}
inline flatbuffers::Offset<PlasmaRefreshLRURequest> CreatePlasmaRefreshLRURequestDirect(
flatbuffers::FlatBufferBuilder &_fbb,
const std::vector<flatbuffers::Offset<flatbuffers::String>> *object_ids = nullptr) {
auto object_ids__ = object_ids ? _fbb.CreateVector<flatbuffers::Offset<flatbuffers::String>>(*object_ids) : 0;
return plasma::flatbuf::CreatePlasmaRefreshLRURequest(
_fbb,
object_ids__);
}
flatbuffers::Offset<PlasmaRefreshLRURequest> CreatePlasmaRefreshLRURequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaRefreshLRURequestT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
struct PlasmaRefreshLRUReplyT : public flatbuffers::NativeTable {
typedef PlasmaRefreshLRUReply TableType;
PlasmaRefreshLRUReplyT() {
}
};
struct PlasmaRefreshLRUReply FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
typedef PlasmaRefreshLRUReplyT NativeTableType;
typedef PlasmaRefreshLRUReplyBuilder Builder;
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
verifier.EndTable();
}
PlasmaRefreshLRUReplyT *UnPack(const flatbuffers::resolver_function_t *_resolver = nullptr) const;
void UnPackTo(PlasmaRefreshLRUReplyT *_o, const flatbuffers::resolver_function_t *_resolver = nullptr) const;
static flatbuffers::Offset<PlasmaRefreshLRUReply> Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaRefreshLRUReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
};
struct PlasmaRefreshLRUReplyBuilder {
typedef PlasmaRefreshLRUReply Table;
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
explicit PlasmaRefreshLRUReplyBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
PlasmaRefreshLRUReplyBuilder &operator=(const PlasmaRefreshLRUReplyBuilder &);
flatbuffers::Offset<PlasmaRefreshLRUReply> Finish() {
const auto end = fbb_.EndTable(start_);
auto o = flatbuffers::Offset<PlasmaRefreshLRUReply>(end);
return o;
}
};
inline flatbuffers::Offset<PlasmaRefreshLRUReply> CreatePlasmaRefreshLRUReply(
flatbuffers::FlatBufferBuilder &_fbb) {
PlasmaRefreshLRUReplyBuilder builder_(_fbb);
return builder_.Finish();
}
flatbuffers::Offset<PlasmaRefreshLRUReply> CreatePlasmaRefreshLRUReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaRefreshLRUReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher = nullptr);
inline PlasmaSetOptionsRequestT *PlasmaSetOptionsRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaSetOptionsRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaSetOptionsRequestT>(new PlasmaSetOptionsRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaSetOptionsRequest::UnPackTo(PlasmaSetOptionsRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = client_name(); if (_e) _o->client_name = _e->str(); }
{ auto _e = output_memory_quota(); _o->output_memory_quota = _e; }
}
inline flatbuffers::Offset<PlasmaSetOptionsRequest> PlasmaSetOptionsRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSetOptionsRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaSetOptionsRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaSetOptionsRequest> CreatePlasmaSetOptionsRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSetOptionsRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaSetOptionsRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _client_name = _o->client_name.empty() ? 0 : _fbb.CreateString(_o->client_name);
auto _output_memory_quota = _o->output_memory_quota;
return plasma::flatbuf::CreatePlasmaSetOptionsRequest(
_fbb,
_client_name,
_output_memory_quota);
}
inline PlasmaSetOptionsReplyT *PlasmaSetOptionsReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaSetOptionsReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaSetOptionsReplyT>(new PlasmaSetOptionsReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaSetOptionsReply::UnPackTo(PlasmaSetOptionsReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = error(); _o->error = _e; }
}
inline flatbuffers::Offset<PlasmaSetOptionsReply> PlasmaSetOptionsReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSetOptionsReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaSetOptionsReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaSetOptionsReply> CreatePlasmaSetOptionsReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSetOptionsReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaSetOptionsReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _error = _o->error;
return plasma::flatbuf::CreatePlasmaSetOptionsReply(
_fbb,
_error);
}
inline PlasmaGetDebugStringRequestT *PlasmaGetDebugStringRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaGetDebugStringRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaGetDebugStringRequestT>(new PlasmaGetDebugStringRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaGetDebugStringRequest::UnPackTo(PlasmaGetDebugStringRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
}
inline flatbuffers::Offset<PlasmaGetDebugStringRequest> PlasmaGetDebugStringRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetDebugStringRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaGetDebugStringRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaGetDebugStringRequest> CreatePlasmaGetDebugStringRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetDebugStringRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaGetDebugStringRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
return plasma::flatbuf::CreatePlasmaGetDebugStringRequest(
_fbb);
}
inline PlasmaGetDebugStringReplyT *PlasmaGetDebugStringReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaGetDebugStringReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaGetDebugStringReplyT>(new PlasmaGetDebugStringReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaGetDebugStringReply::UnPackTo(PlasmaGetDebugStringReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = debug_string(); if (_e) _o->debug_string = _e->str(); }
}
inline flatbuffers::Offset<PlasmaGetDebugStringReply> PlasmaGetDebugStringReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetDebugStringReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaGetDebugStringReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaGetDebugStringReply> CreatePlasmaGetDebugStringReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetDebugStringReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaGetDebugStringReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _debug_string = _o->debug_string.empty() ? 0 : _fbb.CreateString(_o->debug_string);
return plasma::flatbuf::CreatePlasmaGetDebugStringReply(
_fbb,
_debug_string);
}
inline PlasmaCreateRequestT *PlasmaCreateRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaCreateRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaCreateRequestT>(new PlasmaCreateRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaCreateRequest::UnPackTo(PlasmaCreateRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
{ auto _e = evict_if_full(); _o->evict_if_full = _e; }
{ auto _e = data_size(); _o->data_size = _e; }
{ auto _e = metadata_size(); _o->metadata_size = _e; }
{ auto _e = device_num(); _o->device_num = _e; }
}
inline flatbuffers::Offset<PlasmaCreateRequest> PlasmaCreateRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaCreateRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaCreateRequest> CreatePlasmaCreateRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaCreateRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
auto _evict_if_full = _o->evict_if_full;
auto _data_size = _o->data_size;
auto _metadata_size = _o->metadata_size;
auto _device_num = _o->device_num;
return plasma::flatbuf::CreatePlasmaCreateRequest(
_fbb,
_object_id,
_evict_if_full,
_data_size,
_metadata_size,
_device_num);
}
inline CudaHandleT *CudaHandle::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::CudaHandleT> _o = std::unique_ptr<plasma::flatbuf::CudaHandleT>(new CudaHandleT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void CudaHandle::UnPackTo(CudaHandleT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = handle(); if (_e) { _o->handle.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->handle[_i] = _e->Get(_i); } } }
}
inline flatbuffers::Offset<CudaHandle> CudaHandle::Pack(flatbuffers::FlatBufferBuilder &_fbb, const CudaHandleT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreateCudaHandle(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<CudaHandle> CreateCudaHandle(flatbuffers::FlatBufferBuilder &_fbb, const CudaHandleT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const CudaHandleT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _handle = _o->handle.size() ? _fbb.CreateVector(_o->handle) : 0;
return plasma::flatbuf::CreateCudaHandle(
_fbb,
_handle);
}
inline PlasmaCreateReplyT *PlasmaCreateReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaCreateReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaCreateReplyT>(new PlasmaCreateReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaCreateReply::UnPackTo(PlasmaCreateReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
{ auto _e = plasma_object(); if (_e) _o->plasma_object = std::unique_ptr<plasma::flatbuf::PlasmaObjectSpec>(new plasma::flatbuf::PlasmaObjectSpec(*_e)); }
{ auto _e = error(); _o->error = _e; }
{ auto _e = store_fd(); _o->store_fd = _e; }
{ auto _e = mmap_size(); _o->mmap_size = _e; }
{ auto _e = ipc_handle(); if (_e) _o->ipc_handle = std::unique_ptr<plasma::flatbuf::CudaHandleT>(_e->UnPack(_resolver)); }
}
inline flatbuffers::Offset<PlasmaCreateReply> PlasmaCreateReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaCreateReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaCreateReply> CreatePlasmaCreateReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaCreateReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
auto _plasma_object = _o->plasma_object ? _o->plasma_object.get() : 0;
auto _error = _o->error;
auto _store_fd = _o->store_fd;
auto _mmap_size = _o->mmap_size;
auto _ipc_handle = _o->ipc_handle ? CreateCudaHandle(_fbb, _o->ipc_handle.get(), _rehasher) : 0;
return plasma::flatbuf::CreatePlasmaCreateReply(
_fbb,
_object_id,
_plasma_object,
_error,
_store_fd,
_mmap_size,
_ipc_handle);
}
inline PlasmaCreateAndSealRequestT *PlasmaCreateAndSealRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaCreateAndSealRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaCreateAndSealRequestT>(new PlasmaCreateAndSealRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaCreateAndSealRequest::UnPackTo(PlasmaCreateAndSealRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
{ auto _e = evict_if_full(); _o->evict_if_full = _e; }
{ auto _e = data(); if (_e) _o->data = _e->str(); }
{ auto _e = metadata(); if (_e) _o->metadata = _e->str(); }
{ auto _e = digest(); if (_e) _o->digest = _e->str(); }
}
inline flatbuffers::Offset<PlasmaCreateAndSealRequest> PlasmaCreateAndSealRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaCreateAndSealRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaCreateAndSealRequest> CreatePlasmaCreateAndSealRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaCreateAndSealRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
auto _evict_if_full = _o->evict_if_full;
auto _data = _o->data.empty() ? 0 : _fbb.CreateString(_o->data);
auto _metadata = _o->metadata.empty() ? 0 : _fbb.CreateString(_o->metadata);
auto _digest = _o->digest.empty() ? 0 : _fbb.CreateString(_o->digest);
return plasma::flatbuf::CreatePlasmaCreateAndSealRequest(
_fbb,
_object_id,
_evict_if_full,
_data,
_metadata,
_digest);
}
inline PlasmaCreateAndSealReplyT *PlasmaCreateAndSealReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaCreateAndSealReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaCreateAndSealReplyT>(new PlasmaCreateAndSealReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaCreateAndSealReply::UnPackTo(PlasmaCreateAndSealReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = error(); _o->error = _e; }
}
inline flatbuffers::Offset<PlasmaCreateAndSealReply> PlasmaCreateAndSealReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaCreateAndSealReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaCreateAndSealReply> CreatePlasmaCreateAndSealReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaCreateAndSealReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _error = _o->error;
return plasma::flatbuf::CreatePlasmaCreateAndSealReply(
_fbb,
_error);
}
inline PlasmaCreateAndSealBatchRequestT *PlasmaCreateAndSealBatchRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaCreateAndSealBatchRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaCreateAndSealBatchRequestT>(new PlasmaCreateAndSealBatchRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaCreateAndSealBatchRequest::UnPackTo(PlasmaCreateAndSealBatchRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_ids(); if (_e) { _o->object_ids.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->object_ids[_i] = _e->Get(_i)->str(); } } }
{ auto _e = evict_if_full(); _o->evict_if_full = _e; }
{ auto _e = data(); if (_e) { _o->data.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->data[_i] = _e->Get(_i)->str(); } } }
{ auto _e = metadata(); if (_e) { _o->metadata.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->metadata[_i] = _e->Get(_i)->str(); } } }
{ auto _e = digest(); if (_e) { _o->digest.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->digest[_i] = _e->Get(_i)->str(); } } }
}
inline flatbuffers::Offset<PlasmaCreateAndSealBatchRequest> PlasmaCreateAndSealBatchRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealBatchRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaCreateAndSealBatchRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaCreateAndSealBatchRequest> CreatePlasmaCreateAndSealBatchRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealBatchRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaCreateAndSealBatchRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_ids = _o->object_ids.size() ? _fbb.CreateVectorOfStrings(_o->object_ids) : 0;
auto _evict_if_full = _o->evict_if_full;
auto _data = _o->data.size() ? _fbb.CreateVectorOfStrings(_o->data) : 0;
auto _metadata = _o->metadata.size() ? _fbb.CreateVectorOfStrings(_o->metadata) : 0;
auto _digest = _o->digest.size() ? _fbb.CreateVectorOfStrings(_o->digest) : 0;
return plasma::flatbuf::CreatePlasmaCreateAndSealBatchRequest(
_fbb,
_object_ids,
_evict_if_full,
_data,
_metadata,
_digest);
}
inline PlasmaCreateAndSealBatchReplyT *PlasmaCreateAndSealBatchReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaCreateAndSealBatchReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaCreateAndSealBatchReplyT>(new PlasmaCreateAndSealBatchReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaCreateAndSealBatchReply::UnPackTo(PlasmaCreateAndSealBatchReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = error(); _o->error = _e; }
}
inline flatbuffers::Offset<PlasmaCreateAndSealBatchReply> PlasmaCreateAndSealBatchReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealBatchReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaCreateAndSealBatchReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaCreateAndSealBatchReply> CreatePlasmaCreateAndSealBatchReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaCreateAndSealBatchReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaCreateAndSealBatchReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _error = _o->error;
return plasma::flatbuf::CreatePlasmaCreateAndSealBatchReply(
_fbb,
_error);
}
inline PlasmaAbortRequestT *PlasmaAbortRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaAbortRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaAbortRequestT>(new PlasmaAbortRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaAbortRequest::UnPackTo(PlasmaAbortRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
}
inline flatbuffers::Offset<PlasmaAbortRequest> PlasmaAbortRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaAbortRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaAbortRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaAbortRequest> CreatePlasmaAbortRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaAbortRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaAbortRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
return plasma::flatbuf::CreatePlasmaAbortRequest(
_fbb,
_object_id);
}
inline PlasmaAbortReplyT *PlasmaAbortReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaAbortReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaAbortReplyT>(new PlasmaAbortReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaAbortReply::UnPackTo(PlasmaAbortReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
}
inline flatbuffers::Offset<PlasmaAbortReply> PlasmaAbortReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaAbortReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaAbortReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaAbortReply> CreatePlasmaAbortReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaAbortReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaAbortReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
return plasma::flatbuf::CreatePlasmaAbortReply(
_fbb,
_object_id);
}
inline PlasmaSealRequestT *PlasmaSealRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaSealRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaSealRequestT>(new PlasmaSealRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaSealRequest::UnPackTo(PlasmaSealRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
{ auto _e = digest(); if (_e) _o->digest = _e->str(); }
}
inline flatbuffers::Offset<PlasmaSealRequest> PlasmaSealRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSealRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaSealRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaSealRequest> CreatePlasmaSealRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSealRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaSealRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
auto _digest = _o->digest.empty() ? 0 : _fbb.CreateString(_o->digest);
return plasma::flatbuf::CreatePlasmaSealRequest(
_fbb,
_object_id,
_digest);
}
inline PlasmaSealReplyT *PlasmaSealReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaSealReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaSealReplyT>(new PlasmaSealReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaSealReply::UnPackTo(PlasmaSealReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
{ auto _e = error(); _o->error = _e; }
}
inline flatbuffers::Offset<PlasmaSealReply> PlasmaSealReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSealReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaSealReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaSealReply> CreatePlasmaSealReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSealReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaSealReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
auto _error = _o->error;
return plasma::flatbuf::CreatePlasmaSealReply(
_fbb,
_object_id,
_error);
}
inline PlasmaGetRequestT *PlasmaGetRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaGetRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaGetRequestT>(new PlasmaGetRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaGetRequest::UnPackTo(PlasmaGetRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_ids(); if (_e) { _o->object_ids.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->object_ids[_i] = _e->Get(_i)->str(); } } }
{ auto _e = timeout_ms(); _o->timeout_ms = _e; }
}
inline flatbuffers::Offset<PlasmaGetRequest> PlasmaGetRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaGetRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaGetRequest> CreatePlasmaGetRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaGetRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_ids = _o->object_ids.size() ? _fbb.CreateVectorOfStrings(_o->object_ids) : 0;
auto _timeout_ms = _o->timeout_ms;
return plasma::flatbuf::CreatePlasmaGetRequest(
_fbb,
_object_ids,
_timeout_ms);
}
inline PlasmaGetReplyT *PlasmaGetReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaGetReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaGetReplyT>(new PlasmaGetReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaGetReply::UnPackTo(PlasmaGetReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_ids(); if (_e) { _o->object_ids.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->object_ids[_i] = _e->Get(_i)->str(); } } }
{ auto _e = plasma_objects(); if (_e) { _o->plasma_objects.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->plasma_objects[_i] = *_e->Get(_i); } } }
{ auto _e = store_fds(); if (_e) { _o->store_fds.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->store_fds[_i] = _e->Get(_i); } } }
{ auto _e = mmap_sizes(); if (_e) { _o->mmap_sizes.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->mmap_sizes[_i] = _e->Get(_i); } } }
{ auto _e = handles(); if (_e) { _o->handles.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->handles[_i] = std::unique_ptr<plasma::flatbuf::CudaHandleT>(_e->Get(_i)->UnPack(_resolver)); } } }
}
inline flatbuffers::Offset<PlasmaGetReply> PlasmaGetReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaGetReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaGetReply> CreatePlasmaGetReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaGetReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaGetReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_ids = _o->object_ids.size() ? _fbb.CreateVectorOfStrings(_o->object_ids) : 0;
auto _plasma_objects = _o->plasma_objects.size() ? _fbb.CreateVectorOfStructs(_o->plasma_objects) : 0;
auto _store_fds = _o->store_fds.size() ? _fbb.CreateVector(_o->store_fds) : 0;
auto _mmap_sizes = _o->mmap_sizes.size() ? _fbb.CreateVector(_o->mmap_sizes) : 0;
auto _handles = _o->handles.size() ? _fbb.CreateVector<flatbuffers::Offset<plasma::flatbuf::CudaHandle>> (_o->handles.size(), [](size_t i, _VectorArgs *__va) { return CreateCudaHandle(*__va->__fbb, __va->__o->handles[i].get(), __va->__rehasher); }, &_va ) : 0;
return plasma::flatbuf::CreatePlasmaGetReply(
_fbb,
_object_ids,
_plasma_objects,
_store_fds,
_mmap_sizes,
_handles);
}
inline PlasmaReleaseRequestT *PlasmaReleaseRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaReleaseRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaReleaseRequestT>(new PlasmaReleaseRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaReleaseRequest::UnPackTo(PlasmaReleaseRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
}
inline flatbuffers::Offset<PlasmaReleaseRequest> PlasmaReleaseRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaReleaseRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaReleaseRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaReleaseRequest> CreatePlasmaReleaseRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaReleaseRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaReleaseRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
return plasma::flatbuf::CreatePlasmaReleaseRequest(
_fbb,
_object_id);
}
inline PlasmaReleaseReplyT *PlasmaReleaseReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaReleaseReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaReleaseReplyT>(new PlasmaReleaseReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaReleaseReply::UnPackTo(PlasmaReleaseReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
{ auto _e = error(); _o->error = _e; }
}
inline flatbuffers::Offset<PlasmaReleaseReply> PlasmaReleaseReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaReleaseReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaReleaseReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaReleaseReply> CreatePlasmaReleaseReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaReleaseReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaReleaseReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
auto _error = _o->error;
return plasma::flatbuf::CreatePlasmaReleaseReply(
_fbb,
_object_id,
_error);
}
inline PlasmaDeleteRequestT *PlasmaDeleteRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaDeleteRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaDeleteRequestT>(new PlasmaDeleteRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaDeleteRequest::UnPackTo(PlasmaDeleteRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = count(); _o->count = _e; }
{ auto _e = object_ids(); if (_e) { _o->object_ids.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->object_ids[_i] = _e->Get(_i)->str(); } } }
}
inline flatbuffers::Offset<PlasmaDeleteRequest> PlasmaDeleteRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDeleteRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaDeleteRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaDeleteRequest> CreatePlasmaDeleteRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDeleteRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaDeleteRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _count = _o->count;
auto _object_ids = _o->object_ids.size() ? _fbb.CreateVectorOfStrings(_o->object_ids) : 0;
return plasma::flatbuf::CreatePlasmaDeleteRequest(
_fbb,
_count,
_object_ids);
}
inline PlasmaDeleteReplyT *PlasmaDeleteReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaDeleteReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaDeleteReplyT>(new PlasmaDeleteReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaDeleteReply::UnPackTo(PlasmaDeleteReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = count(); _o->count = _e; }
{ auto _e = object_ids(); if (_e) { _o->object_ids.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->object_ids[_i] = _e->Get(_i)->str(); } } }
{ auto _e = errors(); if (_e) { _o->errors.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->errors[_i] = static_cast<plasma::flatbuf::PlasmaError>(_e->Get(_i)); } } }
}
inline flatbuffers::Offset<PlasmaDeleteReply> PlasmaDeleteReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDeleteReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaDeleteReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaDeleteReply> CreatePlasmaDeleteReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDeleteReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaDeleteReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _count = _o->count;
auto _object_ids = _o->object_ids.size() ? _fbb.CreateVectorOfStrings(_o->object_ids) : 0;
auto _errors = _o->errors.size() ? _fbb.CreateVectorScalarCast<int32_t>(flatbuffers::data(_o->errors), _o->errors.size()) : 0;
return plasma::flatbuf::CreatePlasmaDeleteReply(
_fbb,
_count,
_object_ids,
_errors);
}
inline PlasmaContainsRequestT *PlasmaContainsRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaContainsRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaContainsRequestT>(new PlasmaContainsRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaContainsRequest::UnPackTo(PlasmaContainsRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
}
inline flatbuffers::Offset<PlasmaContainsRequest> PlasmaContainsRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaContainsRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaContainsRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaContainsRequest> CreatePlasmaContainsRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaContainsRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaContainsRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
return plasma::flatbuf::CreatePlasmaContainsRequest(
_fbb,
_object_id);
}
inline PlasmaContainsReplyT *PlasmaContainsReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaContainsReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaContainsReplyT>(new PlasmaContainsReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaContainsReply::UnPackTo(PlasmaContainsReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
{ auto _e = has_object(); _o->has_object = _e; }
}
inline flatbuffers::Offset<PlasmaContainsReply> PlasmaContainsReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaContainsReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaContainsReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaContainsReply> CreatePlasmaContainsReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaContainsReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaContainsReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
auto _has_object = _o->has_object;
return plasma::flatbuf::CreatePlasmaContainsReply(
_fbb,
_object_id,
_has_object);
}
inline PlasmaListRequestT *PlasmaListRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaListRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaListRequestT>(new PlasmaListRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaListRequest::UnPackTo(PlasmaListRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
}
inline flatbuffers::Offset<PlasmaListRequest> PlasmaListRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaListRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaListRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaListRequest> CreatePlasmaListRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaListRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaListRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
return plasma::flatbuf::CreatePlasmaListRequest(
_fbb);
}
inline PlasmaListReplyT *PlasmaListReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaListReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaListReplyT>(new PlasmaListReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaListReply::UnPackTo(PlasmaListReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = objects(); if (_e) { _o->objects.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->objects[_i] = std::unique_ptr<plasma::flatbuf::ObjectInfoT>(_e->Get(_i)->UnPack(_resolver)); } } }
}
inline flatbuffers::Offset<PlasmaListReply> PlasmaListReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaListReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaListReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaListReply> CreatePlasmaListReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaListReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaListReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _objects = _o->objects.size() ? _fbb.CreateVector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>> (_o->objects.size(), [](size_t i, _VectorArgs *__va) { return CreateObjectInfo(*__va->__fbb, __va->__o->objects[i].get(), __va->__rehasher); }, &_va ) : 0;
return plasma::flatbuf::CreatePlasmaListReply(
_fbb,
_objects);
}
inline PlasmaConnectRequestT *PlasmaConnectRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaConnectRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaConnectRequestT>(new PlasmaConnectRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaConnectRequest::UnPackTo(PlasmaConnectRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
}
inline flatbuffers::Offset<PlasmaConnectRequest> PlasmaConnectRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaConnectRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaConnectRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaConnectRequest> CreatePlasmaConnectRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaConnectRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaConnectRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
return plasma::flatbuf::CreatePlasmaConnectRequest(
_fbb);
}
inline PlasmaConnectReplyT *PlasmaConnectReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaConnectReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaConnectReplyT>(new PlasmaConnectReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaConnectReply::UnPackTo(PlasmaConnectReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = memory_capacity(); _o->memory_capacity = _e; }
}
inline flatbuffers::Offset<PlasmaConnectReply> PlasmaConnectReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaConnectReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaConnectReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaConnectReply> CreatePlasmaConnectReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaConnectReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaConnectReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _memory_capacity = _o->memory_capacity;
return plasma::flatbuf::CreatePlasmaConnectReply(
_fbb,
_memory_capacity);
}
inline PlasmaEvictRequestT *PlasmaEvictRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaEvictRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaEvictRequestT>(new PlasmaEvictRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaEvictRequest::UnPackTo(PlasmaEvictRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = num_bytes(); _o->num_bytes = _e; }
}
inline flatbuffers::Offset<PlasmaEvictRequest> PlasmaEvictRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaEvictRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaEvictRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaEvictRequest> CreatePlasmaEvictRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaEvictRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaEvictRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _num_bytes = _o->num_bytes;
return plasma::flatbuf::CreatePlasmaEvictRequest(
_fbb,
_num_bytes);
}
inline PlasmaEvictReplyT *PlasmaEvictReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaEvictReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaEvictReplyT>(new PlasmaEvictReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaEvictReply::UnPackTo(PlasmaEvictReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = num_bytes(); _o->num_bytes = _e; }
}
inline flatbuffers::Offset<PlasmaEvictReply> PlasmaEvictReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaEvictReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaEvictReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaEvictReply> CreatePlasmaEvictReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaEvictReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaEvictReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _num_bytes = _o->num_bytes;
return plasma::flatbuf::CreatePlasmaEvictReply(
_fbb,
_num_bytes);
}
inline PlasmaSubscribeRequestT *PlasmaSubscribeRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaSubscribeRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaSubscribeRequestT>(new PlasmaSubscribeRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaSubscribeRequest::UnPackTo(PlasmaSubscribeRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
}
inline flatbuffers::Offset<PlasmaSubscribeRequest> PlasmaSubscribeRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSubscribeRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaSubscribeRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaSubscribeRequest> CreatePlasmaSubscribeRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaSubscribeRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaSubscribeRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
return plasma::flatbuf::CreatePlasmaSubscribeRequest(
_fbb);
}
inline PlasmaNotificationT *PlasmaNotification::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaNotificationT> _o = std::unique_ptr<plasma::flatbuf::PlasmaNotificationT>(new PlasmaNotificationT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaNotification::UnPackTo(PlasmaNotificationT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_info(); if (_e) { _o->object_info.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->object_info[_i] = std::unique_ptr<plasma::flatbuf::ObjectInfoT>(_e->Get(_i)->UnPack(_resolver)); } } }
}
inline flatbuffers::Offset<PlasmaNotification> PlasmaNotification::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaNotificationT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaNotification(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaNotification> CreatePlasmaNotification(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaNotificationT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaNotificationT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_info = _o->object_info.size() ? _fbb.CreateVector<flatbuffers::Offset<plasma::flatbuf::ObjectInfo>> (_o->object_info.size(), [](size_t i, _VectorArgs *__va) { return CreateObjectInfo(*__va->__fbb, __va->__o->object_info[i].get(), __va->__rehasher); }, &_va ) : 0;
return plasma::flatbuf::CreatePlasmaNotification(
_fbb,
_object_info);
}
inline PlasmaDataRequestT *PlasmaDataRequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaDataRequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaDataRequestT>(new PlasmaDataRequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaDataRequest::UnPackTo(PlasmaDataRequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
{ auto _e = address(); if (_e) _o->address = _e->str(); }
{ auto _e = port(); _o->port = _e; }
}
inline flatbuffers::Offset<PlasmaDataRequest> PlasmaDataRequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDataRequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaDataRequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaDataRequest> CreatePlasmaDataRequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDataRequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaDataRequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
auto _address = _o->address.empty() ? 0 : _fbb.CreateString(_o->address);
auto _port = _o->port;
return plasma::flatbuf::CreatePlasmaDataRequest(
_fbb,
_object_id,
_address,
_port);
}
inline PlasmaDataReplyT *PlasmaDataReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaDataReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaDataReplyT>(new PlasmaDataReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaDataReply::UnPackTo(PlasmaDataReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_id(); if (_e) _o->object_id = _e->str(); }
{ auto _e = object_size(); _o->object_size = _e; }
{ auto _e = metadata_size(); _o->metadata_size = _e; }
}
inline flatbuffers::Offset<PlasmaDataReply> PlasmaDataReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDataReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaDataReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaDataReply> CreatePlasmaDataReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaDataReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaDataReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_id = _o->object_id.empty() ? 0 : _fbb.CreateString(_o->object_id);
auto _object_size = _o->object_size;
auto _metadata_size = _o->metadata_size;
return plasma::flatbuf::CreatePlasmaDataReply(
_fbb,
_object_id,
_object_size,
_metadata_size);
}
inline PlasmaRefreshLRURequestT *PlasmaRefreshLRURequest::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaRefreshLRURequestT> _o = std::unique_ptr<plasma::flatbuf::PlasmaRefreshLRURequestT>(new PlasmaRefreshLRURequestT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaRefreshLRURequest::UnPackTo(PlasmaRefreshLRURequestT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
{ auto _e = object_ids(); if (_e) { _o->object_ids.resize(_e->size()); for (flatbuffers::uoffset_t _i = 0; _i < _e->size(); _i++) { _o->object_ids[_i] = _e->Get(_i)->str(); } } }
}
inline flatbuffers::Offset<PlasmaRefreshLRURequest> PlasmaRefreshLRURequest::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaRefreshLRURequestT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaRefreshLRURequest(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaRefreshLRURequest> CreatePlasmaRefreshLRURequest(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaRefreshLRURequestT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaRefreshLRURequestT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
auto _object_ids = _o->object_ids.size() ? _fbb.CreateVectorOfStrings(_o->object_ids) : 0;
return plasma::flatbuf::CreatePlasmaRefreshLRURequest(
_fbb,
_object_ids);
}
inline PlasmaRefreshLRUReplyT *PlasmaRefreshLRUReply::UnPack(const flatbuffers::resolver_function_t *_resolver) const {
std::unique_ptr<plasma::flatbuf::PlasmaRefreshLRUReplyT> _o = std::unique_ptr<plasma::flatbuf::PlasmaRefreshLRUReplyT>(new PlasmaRefreshLRUReplyT());
UnPackTo(_o.get(), _resolver);
return _o.release();
}
inline void PlasmaRefreshLRUReply::UnPackTo(PlasmaRefreshLRUReplyT *_o, const flatbuffers::resolver_function_t *_resolver) const {
(void)_o;
(void)_resolver;
}
inline flatbuffers::Offset<PlasmaRefreshLRUReply> PlasmaRefreshLRUReply::Pack(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaRefreshLRUReplyT* _o, const flatbuffers::rehasher_function_t *_rehasher) {
return CreatePlasmaRefreshLRUReply(_fbb, _o, _rehasher);
}
inline flatbuffers::Offset<PlasmaRefreshLRUReply> CreatePlasmaRefreshLRUReply(flatbuffers::FlatBufferBuilder &_fbb, const PlasmaRefreshLRUReplyT *_o, const flatbuffers::rehasher_function_t *_rehasher) {
(void)_rehasher;
(void)_o;
struct _VectorArgs { flatbuffers::FlatBufferBuilder *__fbb; const PlasmaRefreshLRUReplyT* __o; const flatbuffers::rehasher_function_t *__rehasher; } _va = { &_fbb, _o, _rehasher}; (void)_va;
return plasma::flatbuf::CreatePlasmaRefreshLRUReply(
_fbb);
}
} // namespace flatbuf
} // namespace plasma
#endif // FLATBUFFERS_GENERATED_PLASMA_PLASMA_FLATBUF_H_