// Generated by the protocol buffer compiler. DO NOT EDIT! // source: GeneralRPC.proto #ifndef PROTOBUF_GeneralRPC_2eproto__INCLUDED #define PROTOBUF_GeneralRPC_2eproto__INCLUDED #include #include #if GOOGLE_PROTOBUF_VERSION < 2005000 #error This file was generated by a newer version of protoc which is #error incompatible with your Protocol Buffer headers. Please update #error your headers. #endif #if 2005000 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION #error This file was generated by an older version of protoc which is #error incompatible with your Protocol Buffer headers. Please #error regenerate this file with a newer version of protoc. #endif #include #include #include #include #include #include #include "Coordination.pb.h" // @@protoc_insertion_point(includes) namespace exec { namespace rpc { // Internal implementation detail -- do not call these. void protobuf_AddDesc_GeneralRPC_2eproto(); void protobuf_AssignDesc_GeneralRPC_2eproto(); void protobuf_ShutdownFile_GeneralRPC_2eproto(); class Ack; class RpcHeader; class CompleteRpcMessage; enum RpcMode { REQUEST = 0, RESPONSE = 1, RESPONSE_FAILURE = 2, PING = 3, PONG = 4 }; bool RpcMode_IsValid(int value); const RpcMode RpcMode_MIN = REQUEST; const RpcMode RpcMode_MAX = PONG; const int RpcMode_ARRAYSIZE = RpcMode_MAX + 1; const ::google::protobuf::EnumDescriptor* RpcMode_descriptor(); inline const ::std::string& RpcMode_Name(RpcMode value) { return ::google::protobuf::internal::NameOfEnum( RpcMode_descriptor(), value); } inline bool RpcMode_Parse( const ::std::string& name, RpcMode* value) { return ::google::protobuf::internal::ParseNamedEnum( RpcMode_descriptor(), name, value); } // =================================================================== class Ack : public ::google::protobuf::Message { public: Ack(); virtual ~Ack(); Ack(const Ack& from); inline Ack& operator=(const Ack& from) { CopyFrom(from); return *this; } inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { return _unknown_fields_; } inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { return &_unknown_fields_; } static const ::google::protobuf::Descriptor* descriptor(); static const Ack& default_instance(); void Swap(Ack* other); // implements Message ---------------------------------------------- Ack* New() const; void CopyFrom(const ::google::protobuf::Message& from); void MergeFrom(const ::google::protobuf::Message& from); void CopyFrom(const Ack& from); void MergeFrom(const Ack& from); void Clear(); bool IsInitialized() const; int ByteSize() const; bool MergePartialFromCodedStream( ::google::protobuf::io::CodedInputStream* input); void SerializeWithCachedSizes( ::google::protobuf::io::CodedOutputStream* output) const; ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const; int GetCachedSize() const { return _cached_size_; } private: void SharedCtor(); void SharedDtor(); void SetCachedSize(int size) const; public: ::google::protobuf::Metadata GetMetadata() const; // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- // optional bool ok = 1; inline bool has_ok() const; inline void clear_ok(); static const int kOkFieldNumber = 1; inline bool ok() const; inline void set_ok(bool value); // @@protoc_insertion_point(class_scope:exec.rpc.Ack) private: inline void set_has_ok(); inline void clear_has_ok(); ::google::protobuf::UnknownFieldSet _unknown_fields_; bool ok_; mutable int _cached_size_; ::google::protobuf::uint32 _has_bits_[(1 + 31) / 32]; friend void protobuf_AddDesc_GeneralRPC_2eproto(); friend void protobuf_AssignDesc_GeneralRPC_2eproto(); friend void protobuf_ShutdownFile_GeneralRPC_2eproto(); void InitAsDefaultInstance(); static Ack* default_instance_; }; // ------------------------------------------------------------------- class RpcHeader : public ::google::protobuf::Message { public: RpcHeader(); virtual ~RpcHeader(); RpcHeader(const RpcHeader& from); inline RpcHeader& operator=(const RpcHeader& from) { CopyFrom(from); return *this; } inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { return _unknown_fields_; } inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { return &_unknown_fields_; } static const ::google::protobuf::Descriptor* descriptor(); static const RpcHeader& default_instance(); void Swap(RpcHeader* other); // implements Message ---------------------------------------------- RpcHeader* New() const; void CopyFrom(const ::google::protobuf::Message& from); void MergeFrom(const ::google::protobuf::Message& from); void CopyFrom(const RpcHeader& from); void MergeFrom(const RpcHeader& from); void Clear(); bool IsInitialized() const; int ByteSize() const; bool MergePartialFromCodedStream( ::google::protobuf::io::CodedInputStream* input); void SerializeWithCachedSizes( ::google::protobuf::io::CodedOutputStream* output) const; ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const; int GetCachedSize() const { return _cached_size_; } private: void SharedCtor(); void SharedDtor(); void SetCachedSize(int size) const; public: ::google::protobuf::Metadata GetMetadata() const; // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- // optional .exec.rpc.RpcMode mode = 1; inline bool has_mode() const; inline void clear_mode(); static const int kModeFieldNumber = 1; inline ::exec::rpc::RpcMode mode() const; inline void set_mode(::exec::rpc::RpcMode value); // optional int32 coordination_id = 2; inline bool has_coordination_id() const; inline void clear_coordination_id(); static const int kCoordinationIdFieldNumber = 2; inline ::google::protobuf::int32 coordination_id() const; inline void set_coordination_id(::google::protobuf::int32 value); // optional int32 rpc_type = 3; inline bool has_rpc_type() const; inline void clear_rpc_type(); static const int kRpcTypeFieldNumber = 3; inline ::google::protobuf::int32 rpc_type() const; inline void set_rpc_type(::google::protobuf::int32 value); // @@protoc_insertion_point(class_scope:exec.rpc.RpcHeader) private: inline void set_has_mode(); inline void clear_has_mode(); inline void set_has_coordination_id(); inline void clear_has_coordination_id(); inline void set_has_rpc_type(); inline void clear_has_rpc_type(); ::google::protobuf::UnknownFieldSet _unknown_fields_; int mode_; ::google::protobuf::int32 coordination_id_; ::google::protobuf::int32 rpc_type_; mutable int _cached_size_; ::google::protobuf::uint32 _has_bits_[(3 + 31) / 32]; friend void protobuf_AddDesc_GeneralRPC_2eproto(); friend void protobuf_AssignDesc_GeneralRPC_2eproto(); friend void protobuf_ShutdownFile_GeneralRPC_2eproto(); void InitAsDefaultInstance(); static RpcHeader* default_instance_; }; // ------------------------------------------------------------------- class CompleteRpcMessage : public ::google::protobuf::Message { public: CompleteRpcMessage(); virtual ~CompleteRpcMessage(); CompleteRpcMessage(const CompleteRpcMessage& from); inline CompleteRpcMessage& operator=(const CompleteRpcMessage& from) { CopyFrom(from); return *this; } inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { return _unknown_fields_; } inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { return &_unknown_fields_; } static const ::google::protobuf::Descriptor* descriptor(); static const CompleteRpcMessage& default_instance(); void Swap(CompleteRpcMessage* other); // implements Message ---------------------------------------------- CompleteRpcMessage* New() const; void CopyFrom(const ::google::protobuf::Message& from); void MergeFrom(const ::google::protobuf::Message& from); void CopyFrom(const CompleteRpcMessage& from); void MergeFrom(const CompleteRpcMessage& from); void Clear(); bool IsInitialized() const; int ByteSize() const; bool MergePartialFromCodedStream( ::google::protobuf::io::CodedInputStream* input); void SerializeWithCachedSizes( ::google::protobuf::io::CodedOutputStream* output) const; ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const; int GetCachedSize() const { return _cached_size_; } private: void SharedCtor(); void SharedDtor(); void SetCachedSize(int size) const; public: ::google::protobuf::Metadata GetMetadata() const; // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- // optional .exec.rpc.RpcHeader header = 1; inline bool has_header() const; inline void clear_header(); static const int kHeaderFieldNumber = 1; inline const ::exec::rpc::RpcHeader& header() const; inline ::exec::rpc::RpcHeader* mutable_header(); inline ::exec::rpc::RpcHeader* release_header(); inline void set_allocated_header(::exec::rpc::RpcHeader* header); // optional bytes protobuf_body = 2; inline bool has_protobuf_body() const; inline void clear_protobuf_body(); static const int kProtobufBodyFieldNumber = 2; inline const ::std::string& protobuf_body() const; inline void set_protobuf_body(const ::std::string& value); inline void set_protobuf_body(const char* value); inline void set_protobuf_body(const void* value, size_t size); inline ::std::string* mutable_protobuf_body(); inline ::std::string* release_protobuf_body(); inline void set_allocated_protobuf_body(::std::string* protobuf_body); // optional bytes raw_body = 3; inline bool has_raw_body() const; inline void clear_raw_body(); static const int kRawBodyFieldNumber = 3; inline const ::std::string& raw_body() const; inline void set_raw_body(const ::std::string& value); inline void set_raw_body(const char* value); inline void set_raw_body(const void* value, size_t size); inline ::std::string* mutable_raw_body(); inline ::std::string* release_raw_body(); inline void set_allocated_raw_body(::std::string* raw_body); // @@protoc_insertion_point(class_scope:exec.rpc.CompleteRpcMessage) private: inline void set_has_header(); inline void clear_has_header(); inline void set_has_protobuf_body(); inline void clear_has_protobuf_body(); inline void set_has_raw_body(); inline void clear_has_raw_body(); ::google::protobuf::UnknownFieldSet _unknown_fields_; ::exec::rpc::RpcHeader* header_; ::std::string* protobuf_body_; ::std::string* raw_body_; mutable int _cached_size_; ::google::protobuf::uint32 _has_bits_[(3 + 31) / 32]; friend void protobuf_AddDesc_GeneralRPC_2eproto(); friend void protobuf_AssignDesc_GeneralRPC_2eproto(); friend void protobuf_ShutdownFile_GeneralRPC_2eproto(); void InitAsDefaultInstance(); static CompleteRpcMessage* default_instance_; }; // =================================================================== // =================================================================== // Ack // optional bool ok = 1; inline bool Ack::has_ok() const { return (_has_bits_[0] & 0x00000001u) != 0; } inline void Ack::set_has_ok() { _has_bits_[0] |= 0x00000001u; } inline void Ack::clear_has_ok() { _has_bits_[0] &= ~0x00000001u; } inline void Ack::clear_ok() { ok_ = false; clear_has_ok(); } inline bool Ack::ok() const { return ok_; } inline void Ack::set_ok(bool value) { set_has_ok(); ok_ = value; } // ------------------------------------------------------------------- // RpcHeader // optional .exec.rpc.RpcMode mode = 1; inline bool RpcHeader::has_mode() const { return (_has_bits_[0] & 0x00000001u) != 0; } inline void RpcHeader::set_has_mode() { _has_bits_[0] |= 0x00000001u; } inline void RpcHeader::clear_has_mode() { _has_bits_[0] &= ~0x00000001u; } inline void RpcHeader::clear_mode() { mode_ = 0; clear_has_mode(); } inline ::exec::rpc::RpcMode RpcHeader::mode() const { return static_cast< ::exec::rpc::RpcMode >(mode_); } inline void RpcHeader::set_mode(::exec::rpc::RpcMode value) { assert(::exec::rpc::RpcMode_IsValid(value)); set_has_mode(); mode_ = value; } // optional int32 coordination_id = 2; inline bool RpcHeader::has_coordination_id() const { return (_has_bits_[0] & 0x00000002u) != 0; } inline void RpcHeader::set_has_coordination_id() { _has_bits_[0] |= 0x00000002u; } inline void RpcHeader::clear_has_coordination_id() { _has_bits_[0] &= ~0x00000002u; } inline void RpcHeader::clear_coordination_id() { coordination_id_ = 0; clear_has_coordination_id(); } inline ::google::protobuf::int32 RpcHeader::coordination_id() const { return coordination_id_; } inline void RpcHeader::set_coordination_id(::google::protobuf::int32 value) { set_has_coordination_id(); coordination_id_ = value; } // optional int32 rpc_type = 3; inline bool RpcHeader::has_rpc_type() const { return (_has_bits_[0] & 0x00000004u) != 0; } inline void RpcHeader::set_has_rpc_type() { _has_bits_[0] |= 0x00000004u; } inline void RpcHeader::clear_has_rpc_type() { _has_bits_[0] &= ~0x00000004u; } inline void RpcHeader::clear_rpc_type() { rpc_type_ = 0; clear_has_rpc_type(); } inline ::google::protobuf::int32 RpcHeader::rpc_type() const { return rpc_type_; } inline void RpcHeader::set_rpc_type(::google::protobuf::int32 value) { set_has_rpc_type(); rpc_type_ = value; } // ------------------------------------------------------------------- // CompleteRpcMessage // optional .exec.rpc.RpcHeader header = 1; inline bool CompleteRpcMessage::has_header() const { return (_has_bits_[0] & 0x00000001u) != 0; } inline void CompleteRpcMessage::set_has_header() { _has_bits_[0] |= 0x00000001u; } inline void CompleteRpcMessage::clear_has_header() { _has_bits_[0] &= ~0x00000001u; } inline void CompleteRpcMessage::clear_header() { if (header_ != NULL) header_->::exec::rpc::RpcHeader::Clear(); clear_has_header(); } inline const ::exec::rpc::RpcHeader& CompleteRpcMessage::header() const { return header_ != NULL ? *header_ : *default_instance_->header_; } inline ::exec::rpc::RpcHeader* CompleteRpcMessage::mutable_header() { set_has_header(); if (header_ == NULL) header_ = new ::exec::rpc::RpcHeader; return header_; } inline ::exec::rpc::RpcHeader* CompleteRpcMessage::release_header() { clear_has_header(); ::exec::rpc::RpcHeader* temp = header_; header_ = NULL; return temp; } inline void CompleteRpcMessage::set_allocated_header(::exec::rpc::RpcHeader* header) { delete header_; header_ = header; if (header) { set_has_header(); } else { clear_has_header(); } } // optional bytes protobuf_body = 2; inline bool CompleteRpcMessage::has_protobuf_body() const { return (_has_bits_[0] & 0x00000002u) != 0; } inline void CompleteRpcMessage::set_has_protobuf_body() { _has_bits_[0] |= 0x00000002u; } inline void CompleteRpcMessage::clear_has_protobuf_body() { _has_bits_[0] &= ~0x00000002u; } inline void CompleteRpcMessage::clear_protobuf_body() { if (protobuf_body_ != &::google::protobuf::internal::kEmptyString) { protobuf_body_->clear(); } clear_has_protobuf_body(); } inline const ::std::string& CompleteRpcMessage::protobuf_body() const { return *protobuf_body_; } inline void CompleteRpcMessage::set_protobuf_body(const ::std::string& value) { set_has_protobuf_body(); if (protobuf_body_ == &::google::protobuf::internal::kEmptyString) { protobuf_body_ = new ::std::string; } protobuf_body_->assign(value); } inline void CompleteRpcMessage::set_protobuf_body(const char* value) { set_has_protobuf_body(); if (protobuf_body_ == &::google::protobuf::internal::kEmptyString) { protobuf_body_ = new ::std::string; } protobuf_body_->assign(value); } inline void CompleteRpcMessage::set_protobuf_body(const void* value, size_t size) { set_has_protobuf_body(); if (protobuf_body_ == &::google::protobuf::internal::kEmptyString) { protobuf_body_ = new ::std::string; } protobuf_body_->assign(reinterpret_cast(value), size); } inline ::std::string* CompleteRpcMessage::mutable_protobuf_body() { set_has_protobuf_body(); if (protobuf_body_ == &::google::protobuf::internal::kEmptyString) { protobuf_body_ = new ::std::string; } return protobuf_body_; } inline ::std::string* CompleteRpcMessage::release_protobuf_body() { clear_has_protobuf_body(); if (protobuf_body_ == &::google::protobuf::internal::kEmptyString) { return NULL; } else { ::std::string* temp = protobuf_body_; protobuf_body_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); return temp; } } inline void CompleteRpcMessage::set_allocated_protobuf_body(::std::string* protobuf_body) { if (protobuf_body_ != &::google::protobuf::internal::kEmptyString) { delete protobuf_body_; } if (protobuf_body) { set_has_protobuf_body(); protobuf_body_ = protobuf_body; } else { clear_has_protobuf_body(); protobuf_body_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); } } // optional bytes raw_body = 3; inline bool CompleteRpcMessage::has_raw_body() const { return (_has_bits_[0] & 0x00000004u) != 0; } inline void CompleteRpcMessage::set_has_raw_body() { _has_bits_[0] |= 0x00000004u; } inline void CompleteRpcMessage::clear_has_raw_body() { _has_bits_[0] &= ~0x00000004u; } inline void CompleteRpcMessage::clear_raw_body() { if (raw_body_ != &::google::protobuf::internal::kEmptyString) { raw_body_->clear(); } clear_has_raw_body(); } inline const ::std::string& CompleteRpcMessage::raw_body() const { return *raw_body_; } inline void CompleteRpcMessage::set_raw_body(const ::std::string& value) { set_has_raw_body(); if (raw_body_ == &::google::protobuf::internal::kEmptyString) { raw_body_ = new ::std::string; } raw_body_->assign(value); } inline void CompleteRpcMessage::set_raw_body(const char* value) { set_has_raw_body(); if (raw_body_ == &::google::protobuf::internal::kEmptyString) { raw_body_ = new ::std::string; } raw_body_->assign(value); } inline void CompleteRpcMessage::set_raw_body(const void* value, size_t size) { set_has_raw_body(); if (raw_body_ == &::google::protobuf::internal::kEmptyString) { raw_body_ = new ::std::string; } raw_body_->assign(reinterpret_cast(value), size); } inline ::std::string* CompleteRpcMessage::mutable_raw_body() { set_has_raw_body(); if (raw_body_ == &::google::protobuf::internal::kEmptyString) { raw_body_ = new ::std::string; } return raw_body_; } inline ::std::string* CompleteRpcMessage::release_raw_body() { clear_has_raw_body(); if (raw_body_ == &::google::protobuf::internal::kEmptyString) { return NULL; } else { ::std::string* temp = raw_body_; raw_body_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); return temp; } } inline void CompleteRpcMessage::set_allocated_raw_body(::std::string* raw_body) { if (raw_body_ != &::google::protobuf::internal::kEmptyString) { delete raw_body_; } if (raw_body) { set_has_raw_body(); raw_body_ = raw_body; } else { clear_has_raw_body(); raw_body_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); } } // @@protoc_insertion_point(namespace_scope) } // namespace rpc } // namespace exec #ifndef SWIG namespace google { namespace protobuf { template <> inline const EnumDescriptor* GetEnumDescriptor< ::exec::rpc::RpcMode>() { return ::exec::rpc::RpcMode_descriptor(); } } // namespace google } // namespace protobuf #endif // SWIG // @@protoc_insertion_point(global_scope) #endif // PROTOBUF_GeneralRPC_2eproto__INCLUDED