Page MenuHomePhabricator
Files F2901546

D3238.diff
No OneTemporary
Actions

D3238.diff
View Options

diff --git a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.h b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.h
--- a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.h
+++ b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.h
@@ -92,6 +92,16 @@
std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::tunnelbroker::GetResponse>> PrepareAsyncGet(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest& request, ::grpc::CompletionQueue* cq) {
return std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::tunnelbroker::GetResponse>>(PrepareAsyncGetRaw(context, request, cq));
}
+ // Replacing Send and Get with a single bidirectional streaming RPC
+ std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>> OpenStream(::grpc::ClientContext* context) {
+ return std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>>(OpenStreamRaw(context));
+ }
+ std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>> AsyncOpenStream(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
+ return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>>(AsyncOpenStreamRaw(context, cq, tag));
+ }
+ std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>> PrepareAsyncOpenStream(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
+ return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>>(PrepareAsyncOpenStreamRaw(context, cq));
+ }
class async_interface {
public:
virtual ~async_interface() {}
@@ -114,6 +124,8 @@
virtual void Send(::grpc::ClientContext* context, const ::tunnelbroker::SendRequest* request, ::google::protobuf::Empty* response, std::function<void(::grpc::Status)>) = 0;
virtual void Send(::grpc::ClientContext* context, const ::tunnelbroker::SendRequest* request, ::google::protobuf::Empty* response, ::grpc::ClientUnaryReactor* reactor) = 0;
virtual void Get(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest* request, ::grpc::ClientReadReactor< ::tunnelbroker::GetResponse>* reactor) = 0;
+ // Replacing Send and Get with a single bidirectional streaming RPC
+ virtual void OpenStream(::grpc::ClientContext* context, ::grpc::ClientBidiReactor< ::tunnelbroker::OutboundMessage,::tunnelbroker::InboundMessage>* reactor) = 0;
};
typedef class async_interface experimental_async_interface;
virtual class async_interface* async() { return nullptr; }
@@ -134,6 +146,9 @@
virtual ::grpc::ClientReaderInterface< ::tunnelbroker::GetResponse>* GetRaw(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest& request) = 0;
virtual ::grpc::ClientAsyncReaderInterface< ::tunnelbroker::GetResponse>* AsyncGetRaw(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest& request, ::grpc::CompletionQueue* cq, void* tag) = 0;
virtual ::grpc::ClientAsyncReaderInterface< ::tunnelbroker::GetResponse>* PrepareAsyncGetRaw(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest& request, ::grpc::CompletionQueue* cq) = 0;
+ virtual ::grpc::ClientReaderWriterInterface< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* OpenStreamRaw(::grpc::ClientContext* context) = 0;
+ virtual ::grpc::ClientAsyncReaderWriterInterface< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* AsyncOpenStreamRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) = 0;
+ virtual ::grpc::ClientAsyncReaderWriterInterface< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* PrepareAsyncOpenStreamRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) = 0;
};
class Stub final : public StubInterface {
public:
@@ -189,6 +204,15 @@
std::unique_ptr< ::grpc::ClientAsyncReader< ::tunnelbroker::GetResponse>> PrepareAsyncGet(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest& request, ::grpc::CompletionQueue* cq) {
return std::unique_ptr< ::grpc::ClientAsyncReader< ::tunnelbroker::GetResponse>>(PrepareAsyncGetRaw(context, request, cq));
}
+ std::unique_ptr< ::grpc::ClientReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>> OpenStream(::grpc::ClientContext* context) {
+ return std::unique_ptr< ::grpc::ClientReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>>(OpenStreamRaw(context));
+ }
+ std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>> AsyncOpenStream(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
+ return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>>(AsyncOpenStreamRaw(context, cq, tag));
+ }
+ std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>> PrepareAsyncOpenStream(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
+ return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>>(PrepareAsyncOpenStreamRaw(context, cq));
+ }
class async final :
public StubInterface::async_interface {
public:
@@ -205,6 +229,7 @@
void Send(::grpc::ClientContext* context, const ::tunnelbroker::SendRequest* request, ::google::protobuf::Empty* response, std::function<void(::grpc::Status)>) override;
void Send(::grpc::ClientContext* context, const ::tunnelbroker::SendRequest* request, ::google::protobuf::Empty* response, ::grpc::ClientUnaryReactor* reactor) override;
void Get(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest* request, ::grpc::ClientReadReactor< ::tunnelbroker::GetResponse>* reactor) override;
+ void OpenStream(::grpc::ClientContext* context, ::grpc::ClientBidiReactor< ::tunnelbroker::OutboundMessage,::tunnelbroker::InboundMessage>* reactor) override;
private:
friend class Stub;
explicit async(Stub* stub): stub_(stub) { }
@@ -231,6 +256,9 @@
::grpc::ClientReader< ::tunnelbroker::GetResponse>* GetRaw(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest& request) override;
::grpc::ClientAsyncReader< ::tunnelbroker::GetResponse>* AsyncGetRaw(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest& request, ::grpc::CompletionQueue* cq, void* tag) override;
::grpc::ClientAsyncReader< ::tunnelbroker::GetResponse>* PrepareAsyncGetRaw(::grpc::ClientContext* context, const ::tunnelbroker::GetRequest& request, ::grpc::CompletionQueue* cq) override;
+ ::grpc::ClientReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* OpenStreamRaw(::grpc::ClientContext* context) override;
+ ::grpc::ClientAsyncReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* AsyncOpenStreamRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) override;
+ ::grpc::ClientAsyncReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* PrepareAsyncOpenStreamRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) override;
const ::grpc::internal::RpcMethod rpcmethod_CheckIfPrimaryDeviceOnline_;
const ::grpc::internal::RpcMethod rpcmethod_BecomeNewPrimaryDevice_;
const ::grpc::internal::RpcMethod rpcmethod_SendPong_;
@@ -238,6 +266,7 @@
const ::grpc::internal::RpcMethod rpcmethod_NewSession_;
const ::grpc::internal::RpcMethod rpcmethod_Send_;
const ::grpc::internal::RpcMethod rpcmethod_Get_;
+ const ::grpc::internal::RpcMethod rpcmethod_OpenStream_;
};
static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
@@ -258,6 +287,8 @@
virtual ::grpc::Status NewSession(::grpc::ServerContext* context, const ::tunnelbroker::NewSessionRequest* request, ::tunnelbroker::NewSessionResponse* response);
virtual ::grpc::Status Send(::grpc::ServerContext* context, const ::tunnelbroker::SendRequest* request, ::google::protobuf::Empty* response);
virtual ::grpc::Status Get(::grpc::ServerContext* context, const ::tunnelbroker::GetRequest* request, ::grpc::ServerWriter< ::tunnelbroker::GetResponse>* writer);
+ // Replacing Send and Get with a single bidirectional streaming RPC
+ virtual ::grpc::Status OpenStream(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::tunnelbroker::InboundMessage, ::tunnelbroker::OutboundMessage>* stream);
};
template <class BaseClass>
class WithAsyncMethod_CheckIfPrimaryDeviceOnline : public BaseClass {
@@ -399,7 +430,27 @@
::grpc::Service::RequestAsyncServerStreaming(6, context, request, writer, new_call_cq, notification_cq, tag);
}
};
- typedef WithAsyncMethod_CheckIfPrimaryDeviceOnline<WithAsyncMethod_BecomeNewPrimaryDevice<WithAsyncMethod_SendPong<WithAsyncMethod_SessionSignature<WithAsyncMethod_NewSession<WithAsyncMethod_Send<WithAsyncMethod_Get<Service > > > > > > > AsyncService;
+ template <class BaseClass>
+ class WithAsyncMethod_OpenStream : public BaseClass {
+ private:
+ void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
+ public:
+ WithAsyncMethod_OpenStream() {
+ ::grpc::Service::MarkMethodAsync(7);
+ }
+ ~WithAsyncMethod_OpenStream() override {
+ BaseClassMustBeDerivedFromService(this);
+ }
+ // disable synchronous version of this method
+ ::grpc::Status OpenStream(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::tunnelbroker::InboundMessage, ::tunnelbroker::OutboundMessage>* /*stream*/) override {
+ abort();
+ return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
+ }
+ void RequestOpenStream(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::tunnelbroker::InboundMessage, ::tunnelbroker::OutboundMessage>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
+ ::grpc::Service::RequestAsyncBidiStreaming(7, context, stream, new_call_cq, notification_cq, tag);
+ }
+ };
+ typedef WithAsyncMethod_CheckIfPrimaryDeviceOnline<WithAsyncMethod_BecomeNewPrimaryDevice<WithAsyncMethod_SendPong<WithAsyncMethod_SessionSignature<WithAsyncMethod_NewSession<WithAsyncMethod_Send<WithAsyncMethod_Get<WithAsyncMethod_OpenStream<Service > > > > > > > > AsyncService;
template <class BaseClass>
class WithCallbackMethod_CheckIfPrimaryDeviceOnline : public BaseClass {
private:
@@ -584,7 +635,30 @@
virtual ::grpc::ServerWriteReactor< ::tunnelbroker::GetResponse>* Get(
::grpc::CallbackServerContext* /*context*/, const ::tunnelbroker::GetRequest* /*request*/) { return nullptr; }
};
- typedef WithCallbackMethod_CheckIfPrimaryDeviceOnline<WithCallbackMethod_BecomeNewPrimaryDevice<WithCallbackMethod_SendPong<WithCallbackMethod_SessionSignature<WithCallbackMethod_NewSession<WithCallbackMethod_Send<WithCallbackMethod_Get<Service > > > > > > > CallbackService;
+ template <class BaseClass>
+ class WithCallbackMethod_OpenStream : public BaseClass {
+ private:
+ void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
+ public:
+ WithCallbackMethod_OpenStream() {
+ ::grpc::Service::MarkMethodCallback(7,
+ new ::grpc::internal::CallbackBidiHandler< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>(
+ [this](
+ ::grpc::CallbackServerContext* context) { return this->OpenStream(context); }));
+ }
+ ~WithCallbackMethod_OpenStream() override {
+ BaseClassMustBeDerivedFromService(this);
+ }
+ // disable synchronous version of this method
+ ::grpc::Status OpenStream(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::tunnelbroker::InboundMessage, ::tunnelbroker::OutboundMessage>* /*stream*/) override {
+ abort();
+ return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
+ }
+ virtual ::grpc::ServerBidiReactor< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* OpenStream(
+ ::grpc::CallbackServerContext* /*context*/)
+ { return nullptr; }
+ };
+ typedef WithCallbackMethod_CheckIfPrimaryDeviceOnline<WithCallbackMethod_BecomeNewPrimaryDevice<WithCallbackMethod_SendPong<WithCallbackMethod_SessionSignature<WithCallbackMethod_NewSession<WithCallbackMethod_Send<WithCallbackMethod_Get<WithCallbackMethod_OpenStream<Service > > > > > > > > CallbackService;
typedef CallbackService ExperimentalCallbackService;
template <class BaseClass>
class WithGenericMethod_CheckIfPrimaryDeviceOnline : public BaseClass {
@@ -706,6 +780,23 @@
}
};
template <class BaseClass>
+ class WithGenericMethod_OpenStream : public BaseClass {
+ private:
+ void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
+ public:
+ WithGenericMethod_OpenStream() {
+ ::grpc::Service::MarkMethodGeneric(7);
+ }
+ ~WithGenericMethod_OpenStream() override {
+ BaseClassMustBeDerivedFromService(this);
+ }
+ // disable synchronous version of this method
+ ::grpc::Status OpenStream(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::tunnelbroker::InboundMessage, ::tunnelbroker::OutboundMessage>* /*stream*/) override {
+ abort();
+ return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
+ }
+ };
+ template <class BaseClass>
class WithRawMethod_CheckIfPrimaryDeviceOnline : public BaseClass {
private:
void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
@@ -846,6 +937,26 @@
}
};
template <class BaseClass>
+ class WithRawMethod_OpenStream : public BaseClass {
+ private:
+ void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
+ public:
+ WithRawMethod_OpenStream() {
+ ::grpc::Service::MarkMethodRaw(7);
+ }
+ ~WithRawMethod_OpenStream() override {
+ BaseClassMustBeDerivedFromService(this);
+ }
+ // disable synchronous version of this method
+ ::grpc::Status OpenStream(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::tunnelbroker::InboundMessage, ::tunnelbroker::OutboundMessage>* /*stream*/) override {
+ abort();
+ return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
+ }
+ void RequestOpenStream(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
+ ::grpc::Service::RequestAsyncBidiStreaming(7, context, stream, new_call_cq, notification_cq, tag);
+ }
+ };
+ template <class BaseClass>
class WithRawCallbackMethod_CheckIfPrimaryDeviceOnline : public BaseClass {
private:
void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
@@ -1000,6 +1111,29 @@
::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/) { return nullptr; }
};
template <class BaseClass>
+ class WithRawCallbackMethod_OpenStream : public BaseClass {
+ private:
+ void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
+ public:
+ WithRawCallbackMethod_OpenStream() {
+ ::grpc::Service::MarkMethodRawCallback(7,
+ new ::grpc::internal::CallbackBidiHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
+ [this](
+ ::grpc::CallbackServerContext* context) { return this->OpenStream(context); }));
+ }
+ ~WithRawCallbackMethod_OpenStream() override {
+ BaseClassMustBeDerivedFromService(this);
+ }
+ // disable synchronous version of this method
+ ::grpc::Status OpenStream(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::tunnelbroker::InboundMessage, ::tunnelbroker::OutboundMessage>* /*stream*/) override {
+ abort();
+ return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
+ }
+ virtual ::grpc::ServerBidiReactor< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* OpenStream(
+ ::grpc::CallbackServerContext* /*context*/)
+ { return nullptr; }
+ };
+ template <class BaseClass>
class WithStreamedUnaryMethod_CheckIfPrimaryDeviceOnline : public BaseClass {
private:
void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
diff --git a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.cc b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.cc
--- a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.cc
+++ b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.cc
@@ -29,6 +29,7 @@
"/tunnelbroker.TunnelbrokerService/NewSession",
"/tunnelbroker.TunnelbrokerService/Send",
"/tunnelbroker.TunnelbrokerService/Get",
+ "/tunnelbroker.TunnelbrokerService/OpenStream",
};
std::unique_ptr< TunnelbrokerService::Stub> TunnelbrokerService::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) {
@@ -45,6 +46,7 @@
, rpcmethod_NewSession_(TunnelbrokerService_method_names[4], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_Send_(TunnelbrokerService_method_names[5], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_Get_(TunnelbrokerService_method_names[6], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
+ , rpcmethod_OpenStream_(TunnelbrokerService_method_names[7], options.suffix_for_stats(),::grpc::internal::RpcMethod::BIDI_STREAMING, channel)
{}
::grpc::Status TunnelbrokerService::Stub::CheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::tunnelbroker::CheckResponse* response) {
@@ -201,6 +203,22 @@
return ::grpc::internal::ClientAsyncReaderFactory< ::tunnelbroker::GetResponse>::Create(channel_.get(), cq, rpcmethod_Get_, context, request, false, nullptr);
}
+::grpc::ClientReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* TunnelbrokerService::Stub::OpenStreamRaw(::grpc::ClientContext* context) {
+ return ::grpc::internal::ClientReaderWriterFactory< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>::Create(channel_.get(), rpcmethod_OpenStream_, context);
+}
+
+void TunnelbrokerService::Stub::async::OpenStream(::grpc::ClientContext* context, ::grpc::ClientBidiReactor< ::tunnelbroker::OutboundMessage,::tunnelbroker::InboundMessage>* reactor) {
+ ::grpc::internal::ClientCallbackReaderWriterFactory< ::tunnelbroker::OutboundMessage,::tunnelbroker::InboundMessage>::Create(stub_->channel_.get(), stub_->rpcmethod_OpenStream_, context, reactor);
+}
+
+::grpc::ClientAsyncReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* TunnelbrokerService::Stub::AsyncOpenStreamRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
+ return ::grpc::internal::ClientAsyncReaderWriterFactory< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>::Create(channel_.get(), cq, rpcmethod_OpenStream_, context, true, tag);
+}
+
+::grpc::ClientAsyncReaderWriter< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>* TunnelbrokerService::Stub::PrepareAsyncOpenStreamRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
+ return ::grpc::internal::ClientAsyncReaderWriterFactory< ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>::Create(channel_.get(), cq, rpcmethod_OpenStream_, context, false, nullptr);
+}
+
TunnelbrokerService::Service::Service() {
AddMethod(new ::grpc::internal::RpcServiceMethod(
TunnelbrokerService_method_names[0],
@@ -272,6 +290,16 @@
::grpc::ServerWriter<::tunnelbroker::GetResponse>* writer) {
return service->Get(ctx, req, writer);
}, this)));
+ AddMethod(new ::grpc::internal::RpcServiceMethod(
+ TunnelbrokerService_method_names[7],
+ ::grpc::internal::RpcMethod::BIDI_STREAMING,
+ new ::grpc::internal::BidiStreamingHandler< TunnelbrokerService::Service, ::tunnelbroker::OutboundMessage, ::tunnelbroker::InboundMessage>(
+ [](TunnelbrokerService::Service* service,
+ ::grpc::ServerContext* ctx,
+ ::grpc::ServerReaderWriter<::tunnelbroker::InboundMessage,
+ ::tunnelbroker::OutboundMessage>* stream) {
+ return service->OpenStream(ctx, stream);
+ }, this)));
}
TunnelbrokerService::Service::~Service() {
@@ -326,6 +354,12 @@
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
}
+::grpc::Status TunnelbrokerService::Service::OpenStream(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::tunnelbroker::InboundMessage, ::tunnelbroker::OutboundMessage>* stream) {
+ (void) context;
+ (void) stream;
+ return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
+}
+
} // namespace tunnelbroker
diff --git a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.pb.h b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.pb.h
--- a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.pb.h
+++ b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.pb.h
@@ -48,7 +48,7 @@
PROTOBUF_SECTION_VARIABLE(protodesc_cold);
static const ::PROTOBUF_NAMESPACE_ID::internal::AuxiliaryParseTableField aux[]
PROTOBUF_SECTION_VARIABLE(protodesc_cold);
- static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[12]
+ static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[14]
PROTOBUF_SECTION_VARIABLE(protodesc_cold);
static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata field_metadata[];
static const ::PROTOBUF_NAMESPACE_ID::internal::SerializationTable serialization_table[];
@@ -69,6 +69,9 @@
class GetResponse;
struct GetResponseDefaultTypeInternal;
extern GetResponseDefaultTypeInternal _GetResponse_default_instance_;
+class InboundMessage;
+struct InboundMessageDefaultTypeInternal;
+extern InboundMessageDefaultTypeInternal _InboundMessage_default_instance_;
class NewPrimaryRequest;
struct NewPrimaryRequestDefaultTypeInternal;
extern NewPrimaryRequestDefaultTypeInternal _NewPrimaryRequest_default_instance_;
@@ -81,6 +84,9 @@
class NewSessionResponse;
struct NewSessionResponseDefaultTypeInternal;
extern NewSessionResponseDefaultTypeInternal _NewSessionResponse_default_instance_;
+class OutboundMessage;
+struct OutboundMessageDefaultTypeInternal;
+extern OutboundMessageDefaultTypeInternal _OutboundMessage_default_instance_;
class PongRequest;
struct PongRequestDefaultTypeInternal;
extern PongRequestDefaultTypeInternal _PongRequest_default_instance_;
@@ -99,10 +105,12 @@
template<> ::tunnelbroker::CheckResponse* Arena::CreateMaybeMessage<::tunnelbroker::CheckResponse>(Arena*);
template<> ::tunnelbroker::GetRequest* Arena::CreateMaybeMessage<::tunnelbroker::GetRequest>(Arena*);
template<> ::tunnelbroker::GetResponse* Arena::CreateMaybeMessage<::tunnelbroker::GetResponse>(Arena*);
+template<> ::tunnelbroker::InboundMessage* Arena::CreateMaybeMessage<::tunnelbroker::InboundMessage>(Arena*);
template<> ::tunnelbroker::NewPrimaryRequest* Arena::CreateMaybeMessage<::tunnelbroker::NewPrimaryRequest>(Arena*);
template<> ::tunnelbroker::NewPrimaryResponse* Arena::CreateMaybeMessage<::tunnelbroker::NewPrimaryResponse>(Arena*);
template<> ::tunnelbroker::NewSessionRequest* Arena::CreateMaybeMessage<::tunnelbroker::NewSessionRequest>(Arena*);
template<> ::tunnelbroker::NewSessionResponse* Arena::CreateMaybeMessage<::tunnelbroker::NewSessionResponse>(Arena*);
+template<> ::tunnelbroker::OutboundMessage* Arena::CreateMaybeMessage<::tunnelbroker::OutboundMessage>(Arena*);
template<> ::tunnelbroker::PongRequest* Arena::CreateMaybeMessage<::tunnelbroker::PongRequest>(Arena*);
template<> ::tunnelbroker::SendRequest* Arena::CreateMaybeMessage<::tunnelbroker::SendRequest>(Arena*);
template<> ::tunnelbroker::SessionSignatureRequest* Arena::CreateMaybeMessage<::tunnelbroker::SessionSignatureRequest>(Arena*);
@@ -622,13 +630,13 @@
std::string* _internal_mutable_deviceid();
public:
- // bytes publicKey = 2;
+ // string publicKey = 2;
void clear_publickey();
const std::string& publickey() const;
void set_publickey(const std::string& value);
void set_publickey(std::string&& value);
void set_publickey(const char* value);
- void set_publickey(const void* value, size_t size);
+ void set_publickey(const char* value, size_t size);
std::string* mutable_publickey();
std::string* release_publickey();
void set_allocated_publickey(std::string* publickey);
@@ -1417,24 +1425,24 @@
};
// -------------------------------------------------------------------
-class CheckRequest PROTOBUF_FINAL :
- public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.CheckRequest) */ {
+class OutboundMessage PROTOBUF_FINAL :
+ public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.OutboundMessage) */ {
public:
- inline CheckRequest() : CheckRequest(nullptr) {}
- virtual ~CheckRequest();
- explicit constexpr CheckRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+ inline OutboundMessage() : OutboundMessage(nullptr) {}
+ virtual ~OutboundMessage();
+ explicit constexpr OutboundMessage(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
- CheckRequest(const CheckRequest& from);
- CheckRequest(CheckRequest&& from) noexcept
- : CheckRequest() {
+ OutboundMessage(const OutboundMessage& from);
+ OutboundMessage(OutboundMessage&& from) noexcept
+ : OutboundMessage() {
*this = ::std::move(from);
}
- inline CheckRequest& operator=(const CheckRequest& from) {
+ inline OutboundMessage& operator=(const OutboundMessage& from) {
CopyFrom(from);
return *this;
}
- inline CheckRequest& operator=(CheckRequest&& from) noexcept {
+ inline OutboundMessage& operator=(OutboundMessage&& from) noexcept {
if (GetArena() == from.GetArena()) {
if (this != &from) InternalSwap(&from);
} else {
@@ -1452,20 +1460,20 @@
static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
return GetMetadataStatic().reflection;
}
- static const CheckRequest& default_instance() {
+ static const OutboundMessage& default_instance() {
return *internal_default_instance();
}
- static inline const CheckRequest* internal_default_instance() {
- return reinterpret_cast<const CheckRequest*>(
- &_CheckRequest_default_instance_);
+ static inline const OutboundMessage* internal_default_instance() {
+ return reinterpret_cast<const OutboundMessage*>(
+ &_OutboundMessage_default_instance_);
}
static constexpr int kIndexInFileMessages =
7;
- friend void swap(CheckRequest& a, CheckRequest& b) {
+ friend void swap(OutboundMessage& a, OutboundMessage& b) {
a.Swap(&b);
}
- inline void Swap(CheckRequest* other) {
+ inline void Swap(OutboundMessage* other) {
if (other == this) return;
if (GetArena() == other->GetArena()) {
InternalSwap(other);
@@ -1473,7 +1481,7 @@
::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
}
}
- void UnsafeArenaSwap(CheckRequest* other) {
+ void UnsafeArenaSwap(OutboundMessage* other) {
if (other == this) return;
GOOGLE_DCHECK(GetArena() == other->GetArena());
InternalSwap(other);
@@ -1481,17 +1489,17 @@
// implements Message ----------------------------------------------
- inline CheckRequest* New() const final {
- return CreateMaybeMessage<CheckRequest>(nullptr);
+ inline OutboundMessage* New() const final {
+ return CreateMaybeMessage<OutboundMessage>(nullptr);
}
- CheckRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
- return CreateMaybeMessage<CheckRequest>(arena);
+ OutboundMessage* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
+ return CreateMaybeMessage<OutboundMessage>(arena);
}
void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
- void CopyFrom(const CheckRequest& from);
- void MergeFrom(const CheckRequest& from);
+ void CopyFrom(const OutboundMessage& from);
+ void MergeFrom(const OutboundMessage& from);
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
bool IsInitialized() const final;
@@ -1505,13 +1513,13 @@
inline void SharedCtor();
inline void SharedDtor();
void SetCachedSize(int size) const final;
- void InternalSwap(CheckRequest* other);
+ void InternalSwap(OutboundMessage* other);
friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
- return "tunnelbroker.CheckRequest";
+ return "tunnelbroker.OutboundMessage";
}
protected:
- explicit CheckRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+ explicit OutboundMessage(::PROTOBUF_NAMESPACE_ID::Arena* arena);
private:
static void ArenaDtor(void* object);
inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
@@ -1530,73 +1538,99 @@
// accessors -------------------------------------------------------
enum : int {
- kUserIdFieldNumber = 1,
- kDeviceTokenFieldNumber = 2,
+ kBlobHashesFieldNumber = 3,
+ kToDeviceIDFieldNumber = 1,
+ kPayloadFieldNumber = 2,
};
- // string userId = 1;
- void clear_userid();
- const std::string& userid() const;
- void set_userid(const std::string& value);
- void set_userid(std::string&& value);
- void set_userid(const char* value);
- void set_userid(const char* value, size_t size);
- std::string* mutable_userid();
- std::string* release_userid();
- void set_allocated_userid(std::string* userid);
+ // repeated string blobHashes = 3;
+ int blobhashes_size() const;
private:
- const std::string& _internal_userid() const;
- void _internal_set_userid(const std::string& value);
- std::string* _internal_mutable_userid();
+ int _internal_blobhashes_size() const;
+ public:
+ void clear_blobhashes();
+ const std::string& blobhashes(int index) const;
+ std::string* mutable_blobhashes(int index);
+ void set_blobhashes(int index, const std::string& value);
+ void set_blobhashes(int index, std::string&& value);
+ void set_blobhashes(int index, const char* value);
+ void set_blobhashes(int index, const char* value, size_t size);
+ std::string* add_blobhashes();
+ void add_blobhashes(const std::string& value);
+ void add_blobhashes(std::string&& value);
+ void add_blobhashes(const char* value);
+ void add_blobhashes(const char* value, size_t size);
+ const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>& blobhashes() const;
+ ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>* mutable_blobhashes();
+ private:
+ const std::string& _internal_blobhashes(int index) const;
+ std::string* _internal_add_blobhashes();
public:
- // string deviceToken = 2;
- void clear_devicetoken();
- const std::string& devicetoken() const;
- void set_devicetoken(const std::string& value);
- void set_devicetoken(std::string&& value);
- void set_devicetoken(const char* value);
- void set_devicetoken(const char* value, size_t size);
- std::string* mutable_devicetoken();
- std::string* release_devicetoken();
- void set_allocated_devicetoken(std::string* devicetoken);
+ // string toDeviceID = 1;
+ void clear_todeviceid();
+ const std::string& todeviceid() const;
+ void set_todeviceid(const std::string& value);
+ void set_todeviceid(std::string&& value);
+ void set_todeviceid(const char* value);
+ void set_todeviceid(const char* value, size_t size);
+ std::string* mutable_todeviceid();
+ std::string* release_todeviceid();
+ void set_allocated_todeviceid(std::string* todeviceid);
private:
- const std::string& _internal_devicetoken() const;
- void _internal_set_devicetoken(const std::string& value);
- std::string* _internal_mutable_devicetoken();
+ const std::string& _internal_todeviceid() const;
+ void _internal_set_todeviceid(const std::string& value);
+ std::string* _internal_mutable_todeviceid();
public:
- // @@protoc_insertion_point(class_scope:tunnelbroker.CheckRequest)
+ // string payload = 2;
+ void clear_payload();
+ const std::string& payload() const;
+ void set_payload(const std::string& value);
+ void set_payload(std::string&& value);
+ void set_payload(const char* value);
+ void set_payload(const char* value, size_t size);
+ std::string* mutable_payload();
+ std::string* release_payload();
+ void set_allocated_payload(std::string* payload);
+ private:
+ const std::string& _internal_payload() const;
+ void _internal_set_payload(const std::string& value);
+ std::string* _internal_mutable_payload();
+ public:
+
+ // @@protoc_insertion_point(class_scope:tunnelbroker.OutboundMessage)
private:
class _Internal;
template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
typedef void InternalArenaConstructable_;
typedef void DestructorSkippable_;
- ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_;
- ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr devicetoken_;
+ ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string> blobhashes_;
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr todeviceid_;
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr payload_;
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
friend struct ::TableStruct_tunnelbroker_2eproto;
};
// -------------------------------------------------------------------
-class CheckResponse PROTOBUF_FINAL :
- public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.CheckResponse) */ {
+class InboundMessage PROTOBUF_FINAL :
+ public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.InboundMessage) */ {
public:
- inline CheckResponse() : CheckResponse(nullptr) {}
- virtual ~CheckResponse();
- explicit constexpr CheckResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+ inline InboundMessage() : InboundMessage(nullptr) {}
+ virtual ~InboundMessage();
+ explicit constexpr InboundMessage(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
- CheckResponse(const CheckResponse& from);
- CheckResponse(CheckResponse&& from) noexcept
- : CheckResponse() {
+ InboundMessage(const InboundMessage& from);
+ InboundMessage(InboundMessage&& from) noexcept
+ : InboundMessage() {
*this = ::std::move(from);
}
- inline CheckResponse& operator=(const CheckResponse& from) {
+ inline InboundMessage& operator=(const InboundMessage& from) {
CopyFrom(from);
return *this;
}
- inline CheckResponse& operator=(CheckResponse&& from) noexcept {
+ inline InboundMessage& operator=(InboundMessage&& from) noexcept {
if (GetArena() == from.GetArena()) {
if (this != &from) InternalSwap(&from);
} else {
@@ -1614,20 +1648,20 @@
static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
return GetMetadataStatic().reflection;
}
- static const CheckResponse& default_instance() {
+ static const InboundMessage& default_instance() {
return *internal_default_instance();
}
- static inline const CheckResponse* internal_default_instance() {
- return reinterpret_cast<const CheckResponse*>(
- &_CheckResponse_default_instance_);
+ static inline const InboundMessage* internal_default_instance() {
+ return reinterpret_cast<const InboundMessage*>(
+ &_InboundMessage_default_instance_);
}
static constexpr int kIndexInFileMessages =
8;
- friend void swap(CheckResponse& a, CheckResponse& b) {
+ friend void swap(InboundMessage& a, InboundMessage& b) {
a.Swap(&b);
}
- inline void Swap(CheckResponse* other) {
+ inline void Swap(InboundMessage* other) {
if (other == this) return;
if (GetArena() == other->GetArena()) {
InternalSwap(other);
@@ -1635,7 +1669,7 @@
::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
}
}
- void UnsafeArenaSwap(CheckResponse* other) {
+ void UnsafeArenaSwap(InboundMessage* other) {
if (other == this) return;
GOOGLE_DCHECK(GetArena() == other->GetArena());
InternalSwap(other);
@@ -1643,17 +1677,17 @@
// implements Message ----------------------------------------------
- inline CheckResponse* New() const final {
- return CreateMaybeMessage<CheckResponse>(nullptr);
+ inline InboundMessage* New() const final {
+ return CreateMaybeMessage<InboundMessage>(nullptr);
}
- CheckResponse* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
- return CreateMaybeMessage<CheckResponse>(arena);
+ InboundMessage* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
+ return CreateMaybeMessage<InboundMessage>(arena);
}
void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
- void CopyFrom(const CheckResponse& from);
- void MergeFrom(const CheckResponse& from);
+ void CopyFrom(const InboundMessage& from);
+ void MergeFrom(const InboundMessage& from);
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
bool IsInitialized() const final;
@@ -1667,13 +1701,13 @@
inline void SharedCtor();
inline void SharedDtor();
void SetCachedSize(int size) const final;
- void InternalSwap(CheckResponse* other);
+ void InternalSwap(InboundMessage* other);
friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
- return "tunnelbroker.CheckResponse";
+ return "tunnelbroker.InboundMessage";
}
protected:
- explicit CheckResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+ explicit InboundMessage(::PROTOBUF_NAMESPACE_ID::Arena* arena);
private:
static void ArenaDtor(void* object);
inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
@@ -1692,48 +1726,117 @@
// accessors -------------------------------------------------------
enum : int {
- kCheckResponseTypeFieldNumber = 1,
+ kBlobHashesFieldNumber = 4,
+ kFromDeviceIDFieldNumber = 1,
+ kFromConnectionIDFieldNumber = 2,
+ kPayloadFieldNumber = 3,
};
- // .tunnelbroker.CheckResponseType checkResponseType = 1;
- void clear_checkresponsetype();
- ::tunnelbroker::CheckResponseType checkresponsetype() const;
- void set_checkresponsetype(::tunnelbroker::CheckResponseType value);
+ // repeated string blobHashes = 4;
+ int blobhashes_size() const;
private:
- ::tunnelbroker::CheckResponseType _internal_checkresponsetype() const;
- void _internal_set_checkresponsetype(::tunnelbroker::CheckResponseType value);
+ int _internal_blobhashes_size() const;
+ public:
+ void clear_blobhashes();
+ const std::string& blobhashes(int index) const;
+ std::string* mutable_blobhashes(int index);
+ void set_blobhashes(int index, const std::string& value);
+ void set_blobhashes(int index, std::string&& value);
+ void set_blobhashes(int index, const char* value);
+ void set_blobhashes(int index, const char* value, size_t size);
+ std::string* add_blobhashes();
+ void add_blobhashes(const std::string& value);
+ void add_blobhashes(std::string&& value);
+ void add_blobhashes(const char* value);
+ void add_blobhashes(const char* value, size_t size);
+ const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>& blobhashes() const;
+ ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>* mutable_blobhashes();
+ private:
+ const std::string& _internal_blobhashes(int index) const;
+ std::string* _internal_add_blobhashes();
public:
- // @@protoc_insertion_point(class_scope:tunnelbroker.CheckResponse)
+ // string fromDeviceID = 1;
+ void clear_fromdeviceid();
+ const std::string& fromdeviceid() const;
+ void set_fromdeviceid(const std::string& value);
+ void set_fromdeviceid(std::string&& value);
+ void set_fromdeviceid(const char* value);
+ void set_fromdeviceid(const char* value, size_t size);
+ std::string* mutable_fromdeviceid();
+ std::string* release_fromdeviceid();
+ void set_allocated_fromdeviceid(std::string* fromdeviceid);
+ private:
+ const std::string& _internal_fromdeviceid() const;
+ void _internal_set_fromdeviceid(const std::string& value);
+ std::string* _internal_mutable_fromdeviceid();
+ public:
+
+ // string fromConnectionID = 2;
+ void clear_fromconnectionid();
+ const std::string& fromconnectionid() const;
+ void set_fromconnectionid(const std::string& value);
+ void set_fromconnectionid(std::string&& value);
+ void set_fromconnectionid(const char* value);
+ void set_fromconnectionid(const char* value, size_t size);
+ std::string* mutable_fromconnectionid();
+ std::string* release_fromconnectionid();
+ void set_allocated_fromconnectionid(std::string* fromconnectionid);
+ private:
+ const std::string& _internal_fromconnectionid() const;
+ void _internal_set_fromconnectionid(const std::string& value);
+ std::string* _internal_mutable_fromconnectionid();
+ public:
+
+ // string payload = 3;
+ void clear_payload();
+ const std::string& payload() const;
+ void set_payload(const std::string& value);
+ void set_payload(std::string&& value);
+ void set_payload(const char* value);
+ void set_payload(const char* value, size_t size);
+ std::string* mutable_payload();
+ std::string* release_payload();
+ void set_allocated_payload(std::string* payload);
+ private:
+ const std::string& _internal_payload() const;
+ void _internal_set_payload(const std::string& value);
+ std::string* _internal_mutable_payload();
+ public:
+
+ // @@protoc_insertion_point(class_scope:tunnelbroker.InboundMessage)
private:
class _Internal;
template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
typedef void InternalArenaConstructable_;
typedef void DestructorSkippable_;
- int checkresponsetype_;
+ ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string> blobhashes_;
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr fromdeviceid_;
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr fromconnectionid_;
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr payload_;
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
friend struct ::TableStruct_tunnelbroker_2eproto;
};
// -------------------------------------------------------------------
-class NewPrimaryRequest PROTOBUF_FINAL :
- public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.NewPrimaryRequest) */ {
+class CheckRequest PROTOBUF_FINAL :
+ public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.CheckRequest) */ {
public:
- inline NewPrimaryRequest() : NewPrimaryRequest(nullptr) {}
- virtual ~NewPrimaryRequest();
- explicit constexpr NewPrimaryRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+ inline CheckRequest() : CheckRequest(nullptr) {}
+ virtual ~CheckRequest();
+ explicit constexpr CheckRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
- NewPrimaryRequest(const NewPrimaryRequest& from);
- NewPrimaryRequest(NewPrimaryRequest&& from) noexcept
- : NewPrimaryRequest() {
+ CheckRequest(const CheckRequest& from);
+ CheckRequest(CheckRequest&& from) noexcept
+ : CheckRequest() {
*this = ::std::move(from);
}
- inline NewPrimaryRequest& operator=(const NewPrimaryRequest& from) {
+ inline CheckRequest& operator=(const CheckRequest& from) {
CopyFrom(from);
return *this;
}
- inline NewPrimaryRequest& operator=(NewPrimaryRequest&& from) noexcept {
+ inline CheckRequest& operator=(CheckRequest&& from) noexcept {
if (GetArena() == from.GetArena()) {
if (this != &from) InternalSwap(&from);
} else {
@@ -1751,20 +1854,20 @@
static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
return GetMetadataStatic().reflection;
}
- static const NewPrimaryRequest& default_instance() {
+ static const CheckRequest& default_instance() {
return *internal_default_instance();
}
- static inline const NewPrimaryRequest* internal_default_instance() {
- return reinterpret_cast<const NewPrimaryRequest*>(
- &_NewPrimaryRequest_default_instance_);
+ static inline const CheckRequest* internal_default_instance() {
+ return reinterpret_cast<const CheckRequest*>(
+ &_CheckRequest_default_instance_);
}
static constexpr int kIndexInFileMessages =
9;
- friend void swap(NewPrimaryRequest& a, NewPrimaryRequest& b) {
+ friend void swap(CheckRequest& a, CheckRequest& b) {
a.Swap(&b);
}
- inline void Swap(NewPrimaryRequest* other) {
+ inline void Swap(CheckRequest* other) {
if (other == this) return;
if (GetArena() == other->GetArena()) {
InternalSwap(other);
@@ -1772,7 +1875,7 @@
::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
}
}
- void UnsafeArenaSwap(NewPrimaryRequest* other) {
+ void UnsafeArenaSwap(CheckRequest* other) {
if (other == this) return;
GOOGLE_DCHECK(GetArena() == other->GetArena());
InternalSwap(other);
@@ -1780,17 +1883,17 @@
// implements Message ----------------------------------------------
- inline NewPrimaryRequest* New() const final {
- return CreateMaybeMessage<NewPrimaryRequest>(nullptr);
+ inline CheckRequest* New() const final {
+ return CreateMaybeMessage<CheckRequest>(nullptr);
}
- NewPrimaryRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
- return CreateMaybeMessage<NewPrimaryRequest>(arena);
+ CheckRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
+ return CreateMaybeMessage<CheckRequest>(arena);
}
void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
- void CopyFrom(const NewPrimaryRequest& from);
- void MergeFrom(const NewPrimaryRequest& from);
+ void CopyFrom(const CheckRequest& from);
+ void MergeFrom(const CheckRequest& from);
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
bool IsInitialized() const final;
@@ -1804,13 +1907,13 @@
inline void SharedCtor();
inline void SharedDtor();
void SetCachedSize(int size) const final;
- void InternalSwap(NewPrimaryRequest* other);
+ void InternalSwap(CheckRequest* other);
friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
- return "tunnelbroker.NewPrimaryRequest";
+ return "tunnelbroker.CheckRequest";
}
protected:
- explicit NewPrimaryRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+ explicit CheckRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena);
private:
static void ArenaDtor(void* object);
inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
@@ -1864,7 +1967,7 @@
std::string* _internal_mutable_devicetoken();
public:
- // @@protoc_insertion_point(class_scope:tunnelbroker.NewPrimaryRequest)
+ // @@protoc_insertion_point(class_scope:tunnelbroker.CheckRequest)
private:
class _Internal;
@@ -1878,24 +1981,24 @@
};
// -------------------------------------------------------------------
-class NewPrimaryResponse PROTOBUF_FINAL :
- public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.NewPrimaryResponse) */ {
+class CheckResponse PROTOBUF_FINAL :
+ public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.CheckResponse) */ {
public:
- inline NewPrimaryResponse() : NewPrimaryResponse(nullptr) {}
- virtual ~NewPrimaryResponse();
- explicit constexpr NewPrimaryResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+ inline CheckResponse() : CheckResponse(nullptr) {}
+ virtual ~CheckResponse();
+ explicit constexpr CheckResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
- NewPrimaryResponse(const NewPrimaryResponse& from);
- NewPrimaryResponse(NewPrimaryResponse&& from) noexcept
- : NewPrimaryResponse() {
+ CheckResponse(const CheckResponse& from);
+ CheckResponse(CheckResponse&& from) noexcept
+ : CheckResponse() {
*this = ::std::move(from);
}
- inline NewPrimaryResponse& operator=(const NewPrimaryResponse& from) {
+ inline CheckResponse& operator=(const CheckResponse& from) {
CopyFrom(from);
return *this;
}
- inline NewPrimaryResponse& operator=(NewPrimaryResponse&& from) noexcept {
+ inline CheckResponse& operator=(CheckResponse&& from) noexcept {
if (GetArena() == from.GetArena()) {
if (this != &from) InternalSwap(&from);
} else {
@@ -1913,20 +2016,20 @@
static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
return GetMetadataStatic().reflection;
}
- static const NewPrimaryResponse& default_instance() {
+ static const CheckResponse& default_instance() {
return *internal_default_instance();
}
- static inline const NewPrimaryResponse* internal_default_instance() {
- return reinterpret_cast<const NewPrimaryResponse*>(
- &_NewPrimaryResponse_default_instance_);
+ static inline const CheckResponse* internal_default_instance() {
+ return reinterpret_cast<const CheckResponse*>(
+ &_CheckResponse_default_instance_);
}
static constexpr int kIndexInFileMessages =
10;
- friend void swap(NewPrimaryResponse& a, NewPrimaryResponse& b) {
+ friend void swap(CheckResponse& a, CheckResponse& b) {
a.Swap(&b);
}
- inline void Swap(NewPrimaryResponse* other) {
+ inline void Swap(CheckResponse* other) {
if (other == this) return;
if (GetArena() == other->GetArena()) {
InternalSwap(other);
@@ -1934,7 +2037,7 @@
::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
}
}
- void UnsafeArenaSwap(NewPrimaryResponse* other) {
+ void UnsafeArenaSwap(CheckResponse* other) {
if (other == this) return;
GOOGLE_DCHECK(GetArena() == other->GetArena());
InternalSwap(other);
@@ -1942,17 +2045,17 @@
// implements Message ----------------------------------------------
- inline NewPrimaryResponse* New() const final {
- return CreateMaybeMessage<NewPrimaryResponse>(nullptr);
+ inline CheckResponse* New() const final {
+ return CreateMaybeMessage<CheckResponse>(nullptr);
}
- NewPrimaryResponse* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
- return CreateMaybeMessage<NewPrimaryResponse>(arena);
+ CheckResponse* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
+ return CreateMaybeMessage<CheckResponse>(arena);
}
void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
- void CopyFrom(const NewPrimaryResponse& from);
- void MergeFrom(const NewPrimaryResponse& from);
+ void CopyFrom(const CheckResponse& from);
+ void MergeFrom(const CheckResponse& from);
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
bool IsInitialized() const final;
@@ -1966,13 +2069,13 @@
inline void SharedCtor();
inline void SharedDtor();
void SetCachedSize(int size) const final;
- void InternalSwap(NewPrimaryResponse* other);
+ void InternalSwap(CheckResponse* other);
friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
- return "tunnelbroker.NewPrimaryResponse";
+ return "tunnelbroker.CheckResponse";
}
protected:
- explicit NewPrimaryResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+ explicit CheckResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
private:
static void ArenaDtor(void* object);
inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
@@ -1991,48 +2094,48 @@
// accessors -------------------------------------------------------
enum : int {
- kSuccessFieldNumber = 1,
+ kCheckResponseTypeFieldNumber = 1,
};
- // bool success = 1;
- void clear_success();
- bool success() const;
- void set_success(bool value);
+ // .tunnelbroker.CheckResponseType checkResponseType = 1;
+ void clear_checkresponsetype();
+ ::tunnelbroker::CheckResponseType checkresponsetype() const;
+ void set_checkresponsetype(::tunnelbroker::CheckResponseType value);
private:
- bool _internal_success() const;
- void _internal_set_success(bool value);
+ ::tunnelbroker::CheckResponseType _internal_checkresponsetype() const;
+ void _internal_set_checkresponsetype(::tunnelbroker::CheckResponseType value);
public:
- // @@protoc_insertion_point(class_scope:tunnelbroker.NewPrimaryResponse)
+ // @@protoc_insertion_point(class_scope:tunnelbroker.CheckResponse)
private:
class _Internal;
template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
typedef void InternalArenaConstructable_;
typedef void DestructorSkippable_;
- bool success_;
+ int checkresponsetype_;
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
friend struct ::TableStruct_tunnelbroker_2eproto;
};
// -------------------------------------------------------------------
-class PongRequest PROTOBUF_FINAL :
- public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.PongRequest) */ {
+class NewPrimaryRequest PROTOBUF_FINAL :
+ public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.NewPrimaryRequest) */ {
public:
- inline PongRequest() : PongRequest(nullptr) {}
- virtual ~PongRequest();
- explicit constexpr PongRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+ inline NewPrimaryRequest() : NewPrimaryRequest(nullptr) {}
+ virtual ~NewPrimaryRequest();
+ explicit constexpr NewPrimaryRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
- PongRequest(const PongRequest& from);
- PongRequest(PongRequest&& from) noexcept
- : PongRequest() {
+ NewPrimaryRequest(const NewPrimaryRequest& from);
+ NewPrimaryRequest(NewPrimaryRequest&& from) noexcept
+ : NewPrimaryRequest() {
*this = ::std::move(from);
}
- inline PongRequest& operator=(const PongRequest& from) {
+ inline NewPrimaryRequest& operator=(const NewPrimaryRequest& from) {
CopyFrom(from);
return *this;
}
- inline PongRequest& operator=(PongRequest&& from) noexcept {
+ inline NewPrimaryRequest& operator=(NewPrimaryRequest&& from) noexcept {
if (GetArena() == from.GetArena()) {
if (this != &from) InternalSwap(&from);
} else {
@@ -2050,20 +2153,20 @@
static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
return GetMetadataStatic().reflection;
}
- static const PongRequest& default_instance() {
+ static const NewPrimaryRequest& default_instance() {
return *internal_default_instance();
}
- static inline const PongRequest* internal_default_instance() {
- return reinterpret_cast<const PongRequest*>(
- &_PongRequest_default_instance_);
+ static inline const NewPrimaryRequest* internal_default_instance() {
+ return reinterpret_cast<const NewPrimaryRequest*>(
+ &_NewPrimaryRequest_default_instance_);
}
static constexpr int kIndexInFileMessages =
11;
- friend void swap(PongRequest& a, PongRequest& b) {
+ friend void swap(NewPrimaryRequest& a, NewPrimaryRequest& b) {
a.Swap(&b);
}
- inline void Swap(PongRequest* other) {
+ inline void Swap(NewPrimaryRequest* other) {
if (other == this) return;
if (GetArena() == other->GetArena()) {
InternalSwap(other);
@@ -2071,7 +2174,7 @@
::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
}
}
- void UnsafeArenaSwap(PongRequest* other) {
+ void UnsafeArenaSwap(NewPrimaryRequest* other) {
if (other == this) return;
GOOGLE_DCHECK(GetArena() == other->GetArena());
InternalSwap(other);
@@ -2079,17 +2182,17 @@
// implements Message ----------------------------------------------
- inline PongRequest* New() const final {
- return CreateMaybeMessage<PongRequest>(nullptr);
+ inline NewPrimaryRequest* New() const final {
+ return CreateMaybeMessage<NewPrimaryRequest>(nullptr);
}
- PongRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
- return CreateMaybeMessage<PongRequest>(arena);
+ NewPrimaryRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
+ return CreateMaybeMessage<NewPrimaryRequest>(arena);
}
void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
- void CopyFrom(const PongRequest& from);
- void MergeFrom(const PongRequest& from);
+ void CopyFrom(const NewPrimaryRequest& from);
+ void MergeFrom(const NewPrimaryRequest& from);
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
bool IsInitialized() const final;
@@ -2103,13 +2206,13 @@
inline void SharedCtor();
inline void SharedDtor();
void SetCachedSize(int size) const final;
- void InternalSwap(PongRequest* other);
+ void InternalSwap(NewPrimaryRequest* other);
friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
- return "tunnelbroker.PongRequest";
+ return "tunnelbroker.NewPrimaryRequest";
}
protected:
- explicit PongRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+ explicit NewPrimaryRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena);
private:
static void ArenaDtor(void* object);
inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
@@ -2163,7 +2266,7 @@
std::string* _internal_mutable_devicetoken();
public:
- // @@protoc_insertion_point(class_scope:tunnelbroker.PongRequest)
+ // @@protoc_insertion_point(class_scope:tunnelbroker.NewPrimaryRequest)
private:
class _Internal;
@@ -2175,726 +2278,1490 @@
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
friend struct ::TableStruct_tunnelbroker_2eproto;
};
-// ===================================================================
+// -------------------------------------------------------------------
+class NewPrimaryResponse PROTOBUF_FINAL :
+ public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.NewPrimaryResponse) */ {
+ public:
+ inline NewPrimaryResponse() : NewPrimaryResponse(nullptr) {}
+ virtual ~NewPrimaryResponse();
+ explicit constexpr NewPrimaryResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
-// ===================================================================
+ NewPrimaryResponse(const NewPrimaryResponse& from);
+ NewPrimaryResponse(NewPrimaryResponse&& from) noexcept
+ : NewPrimaryResponse() {
+ *this = ::std::move(from);
+ }
-#ifdef __GNUC__
- #pragma GCC diagnostic push
- #pragma GCC diagnostic ignored "-Wstrict-aliasing"
-#endif // __GNUC__
-// SessionSignatureRequest
+ inline NewPrimaryResponse& operator=(const NewPrimaryResponse& from) {
+ CopyFrom(from);
+ return *this;
+ }
+ inline NewPrimaryResponse& operator=(NewPrimaryResponse&& from) noexcept {
+ if (GetArena() == from.GetArena()) {
+ if (this != &from) InternalSwap(&from);
+ } else {
+ CopyFrom(from);
+ }
+ return *this;
+ }
-// string deviceID = 1;
-inline void SessionSignatureRequest::clear_deviceid() {
- deviceid_.ClearToEmpty();
-}
-inline const std::string& SessionSignatureRequest::deviceid() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.SessionSignatureRequest.deviceID)
- return _internal_deviceid();
-}
-inline void SessionSignatureRequest::set_deviceid(const std::string& value) {
- _internal_set_deviceid(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.SessionSignatureRequest.deviceID)
-}
-inline std::string* SessionSignatureRequest::mutable_deviceid() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.SessionSignatureRequest.deviceID)
- return _internal_mutable_deviceid();
-}
-inline const std::string& SessionSignatureRequest::_internal_deviceid() const {
- return deviceid_.Get();
-}
-inline void SessionSignatureRequest::_internal_set_deviceid(const std::string& value) {
-
- deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
-}
-inline void SessionSignatureRequest::set_deviceid(std::string&& value) {
-
- deviceid_.Set(
- ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SessionSignatureRequest.deviceID)
-}
-inline void SessionSignatureRequest::set_deviceid(const char* value) {
- GOOGLE_DCHECK(value != nullptr);
-
- deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.SessionSignatureRequest.deviceID)
-}
-inline void SessionSignatureRequest::set_deviceid(const char* value,
- size_t size) {
-
- deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
- reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SessionSignatureRequest.deviceID)
-}
-inline std::string* SessionSignatureRequest::_internal_mutable_deviceid() {
-
- return deviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
-}
-inline std::string* SessionSignatureRequest::release_deviceid() {
- // @@protoc_insertion_point(field_release:tunnelbroker.SessionSignatureRequest.deviceID)
- return deviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
-}
-inline void SessionSignatureRequest::set_allocated_deviceid(std::string* deviceid) {
- if (deviceid != nullptr) {
-
- } else {
-
+ static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
+ return GetDescriptor();
}
- deviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), deviceid,
- GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SessionSignatureRequest.deviceID)
-}
+ static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
+ return GetMetadataStatic().descriptor;
+ }
+ static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
+ return GetMetadataStatic().reflection;
+ }
+ static const NewPrimaryResponse& default_instance() {
+ return *internal_default_instance();
+ }
+ static inline const NewPrimaryResponse* internal_default_instance() {
+ return reinterpret_cast<const NewPrimaryResponse*>(
+ &_NewPrimaryResponse_default_instance_);
+ }
+ static constexpr int kIndexInFileMessages =
+ 12;
-// -------------------------------------------------------------------
+ friend void swap(NewPrimaryResponse& a, NewPrimaryResponse& b) {
+ a.Swap(&b);
+ }
+ inline void Swap(NewPrimaryResponse* other) {
+ if (other == this) return;
+ if (GetArena() == other->GetArena()) {
+ InternalSwap(other);
+ } else {
+ ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
+ }
+ }
+ void UnsafeArenaSwap(NewPrimaryResponse* other) {
+ if (other == this) return;
+ GOOGLE_DCHECK(GetArena() == other->GetArena());
+ InternalSwap(other);
+ }
-// SessionSignatureResponse
+ // implements Message ----------------------------------------------
-// string toSign = 1;
-inline void SessionSignatureResponse::clear_tosign() {
- tosign_.ClearToEmpty();
-}
-inline const std::string& SessionSignatureResponse::tosign() const {
+ inline NewPrimaryResponse* New() const final {
+ return CreateMaybeMessage<NewPrimaryResponse>(nullptr);
+ }
+
+ NewPrimaryResponse* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
+ return CreateMaybeMessage<NewPrimaryResponse>(arena);
+ }
+ void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
+ void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
+ void CopyFrom(const NewPrimaryResponse& from);
+ void MergeFrom(const NewPrimaryResponse& from);
+ PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
+ bool IsInitialized() const final;
+
+ size_t ByteSizeLong() const final;
+ const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
+ ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize(
+ ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
+ int GetCachedSize() const final { return _cached_size_.Get(); }
+
+ private:
+ inline void SharedCtor();
+ inline void SharedDtor();
+ void SetCachedSize(int size) const final;
+ void InternalSwap(NewPrimaryResponse* other);
+ friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
+ static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
+ return "tunnelbroker.NewPrimaryResponse";
+ }
+ protected:
+ explicit NewPrimaryResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+ private:
+ static void ArenaDtor(void* object);
+ inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+ public:
+
+ ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
+ private:
+ static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
+ return ::descriptor_table_tunnelbroker_2eproto_metadata_getter(kIndexInFileMessages);
+ }
+
+ public:
+
+ // nested types ----------------------------------------------------
+
+ // accessors -------------------------------------------------------
+
+ enum : int {
+ kSuccessFieldNumber = 1,
+ };
+ // bool success = 1;
+ void clear_success();
+ bool success() const;
+ void set_success(bool value);
+ private:
+ bool _internal_success() const;
+ void _internal_set_success(bool value);
+ public:
+
+ // @@protoc_insertion_point(class_scope:tunnelbroker.NewPrimaryResponse)
+ private:
+ class _Internal;
+
+ template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
+ typedef void InternalArenaConstructable_;
+ typedef void DestructorSkippable_;
+ bool success_;
+ mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
+ friend struct ::TableStruct_tunnelbroker_2eproto;
+};
+// -------------------------------------------------------------------
+
+class PongRequest PROTOBUF_FINAL :
+ public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.PongRequest) */ {
+ public:
+ inline PongRequest() : PongRequest(nullptr) {}
+ virtual ~PongRequest();
+ explicit constexpr PongRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+
+ PongRequest(const PongRequest& from);
+ PongRequest(PongRequest&& from) noexcept
+ : PongRequest() {
+ *this = ::std::move(from);
+ }
+
+ inline PongRequest& operator=(const PongRequest& from) {
+ CopyFrom(from);
+ return *this;
+ }
+ inline PongRequest& operator=(PongRequest&& from) noexcept {
+ if (GetArena() == from.GetArena()) {
+ if (this != &from) InternalSwap(&from);
+ } else {
+ CopyFrom(from);
+ }
+ return *this;
+ }
+
+ static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
+ return GetDescriptor();
+ }
+ static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
+ return GetMetadataStatic().descriptor;
+ }
+ static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
+ return GetMetadataStatic().reflection;
+ }
+ static const PongRequest& default_instance() {
+ return *internal_default_instance();
+ }
+ static inline const PongRequest* internal_default_instance() {
+ return reinterpret_cast<const PongRequest*>(
+ &_PongRequest_default_instance_);
+ }
+ static constexpr int kIndexInFileMessages =
+ 13;
+
+ friend void swap(PongRequest& a, PongRequest& b) {
+ a.Swap(&b);
+ }
+ inline void Swap(PongRequest* other) {
+ if (other == this) return;
+ if (GetArena() == other->GetArena()) {
+ InternalSwap(other);
+ } else {
+ ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
+ }
+ }
+ void UnsafeArenaSwap(PongRequest* other) {
+ if (other == this) return;
+ GOOGLE_DCHECK(GetArena() == other->GetArena());
+ InternalSwap(other);
+ }
+
+ // implements Message ----------------------------------------------
+
+ inline PongRequest* New() const final {
+ return CreateMaybeMessage<PongRequest>(nullptr);
+ }
+
+ PongRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
+ return CreateMaybeMessage<PongRequest>(arena);
+ }
+ void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
+ void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
+ void CopyFrom(const PongRequest& from);
+ void MergeFrom(const PongRequest& from);
+ PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
+ bool IsInitialized() const final;
+
+ size_t ByteSizeLong() const final;
+ const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
+ ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize(
+ ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
+ int GetCachedSize() const final { return _cached_size_.Get(); }
+
+ private:
+ inline void SharedCtor();
+ inline void SharedDtor();
+ void SetCachedSize(int size) const final;
+ void InternalSwap(PongRequest* other);
+ friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
+ static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
+ return "tunnelbroker.PongRequest";
+ }
+ protected:
+ explicit PongRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+ private:
+ static void ArenaDtor(void* object);
+ inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+ public:
+
+ ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
+ private:
+ static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
+ return ::descriptor_table_tunnelbroker_2eproto_metadata_getter(kIndexInFileMessages);
+ }
+
+ public:
+
+ // nested types ----------------------------------------------------
+
+ // accessors -------------------------------------------------------
+
+ enum : int {
+ kUserIdFieldNumber = 1,
+ kDeviceTokenFieldNumber = 2,
+ };
+ // string userId = 1;
+ void clear_userid();
+ const std::string& userid() const;
+ void set_userid(const std::string& value);
+ void set_userid(std::string&& value);
+ void set_userid(const char* value);
+ void set_userid(const char* value, size_t size);
+ std::string* mutable_userid();
+ std::string* release_userid();
+ void set_allocated_userid(std::string* userid);
+ private:
+ const std::string& _internal_userid() const;
+ void _internal_set_userid(const std::string& value);
+ std::string* _internal_mutable_userid();
+ public:
+
+ // string deviceToken = 2;
+ void clear_devicetoken();
+ const std::string& devicetoken() const;
+ void set_devicetoken(const std::string& value);
+ void set_devicetoken(std::string&& value);
+ void set_devicetoken(const char* value);
+ void set_devicetoken(const char* value, size_t size);
+ std::string* mutable_devicetoken();
+ std::string* release_devicetoken();
+ void set_allocated_devicetoken(std::string* devicetoken);
+ private:
+ const std::string& _internal_devicetoken() const;
+ void _internal_set_devicetoken(const std::string& value);
+ std::string* _internal_mutable_devicetoken();
+ public:
+
+ // @@protoc_insertion_point(class_scope:tunnelbroker.PongRequest)
+ private:
+ class _Internal;
+
+ template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
+ typedef void InternalArenaConstructable_;
+ typedef void DestructorSkippable_;
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_;
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr devicetoken_;
+ mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
+ friend struct ::TableStruct_tunnelbroker_2eproto;
+};
+// ===================================================================
+
+
+// ===================================================================
+
+#ifdef __GNUC__
+ #pragma GCC diagnostic push
+ #pragma GCC diagnostic ignored "-Wstrict-aliasing"
+#endif // __GNUC__
+// SessionSignatureRequest
+
+// string deviceID = 1;
+inline void SessionSignatureRequest::clear_deviceid() {
+ deviceid_.ClearToEmpty();
+}
+inline const std::string& SessionSignatureRequest::deviceid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.SessionSignatureRequest.deviceID)
+ return _internal_deviceid();
+}
+inline void SessionSignatureRequest::set_deviceid(const std::string& value) {
+ _internal_set_deviceid(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.SessionSignatureRequest.deviceID)
+}
+inline std::string* SessionSignatureRequest::mutable_deviceid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.SessionSignatureRequest.deviceID)
+ return _internal_mutable_deviceid();
+}
+inline const std::string& SessionSignatureRequest::_internal_deviceid() const {
+ return deviceid_.Get();
+}
+inline void SessionSignatureRequest::_internal_set_deviceid(const std::string& value) {
+
+ deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+}
+inline void SessionSignatureRequest::set_deviceid(std::string&& value) {
+
+ deviceid_.Set(
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SessionSignatureRequest.deviceID)
+}
+inline void SessionSignatureRequest::set_deviceid(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+
+ deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.SessionSignatureRequest.deviceID)
+}
+inline void SessionSignatureRequest::set_deviceid(const char* value,
+ size_t size) {
+
+ deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ reinterpret_cast<const char*>(value), size), GetArena());
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SessionSignatureRequest.deviceID)
+}
+inline std::string* SessionSignatureRequest::_internal_mutable_deviceid() {
+
+ return deviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+}
+inline std::string* SessionSignatureRequest::release_deviceid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.SessionSignatureRequest.deviceID)
+ return deviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+inline void SessionSignatureRequest::set_allocated_deviceid(std::string* deviceid) {
+ if (deviceid != nullptr) {
+
+ } else {
+
+ }
+ deviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), deviceid,
+ GetArena());
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SessionSignatureRequest.deviceID)
+}
+
+// -------------------------------------------------------------------
+
+// SessionSignatureResponse
+
+// string toSign = 1;
+inline void SessionSignatureResponse::clear_tosign() {
+ tosign_.ClearToEmpty();
+}
+inline const std::string& SessionSignatureResponse::tosign() const {
// @@protoc_insertion_point(field_get:tunnelbroker.SessionSignatureResponse.toSign)
return _internal_tosign();
}
-inline void SessionSignatureResponse::set_tosign(const std::string& value) {
- _internal_set_tosign(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.SessionSignatureResponse.toSign)
+inline void SessionSignatureResponse::set_tosign(const std::string& value) {
+ _internal_set_tosign(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.SessionSignatureResponse.toSign)
+}
+inline std::string* SessionSignatureResponse::mutable_tosign() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.SessionSignatureResponse.toSign)
+ return _internal_mutable_tosign();
+}
+inline const std::string& SessionSignatureResponse::_internal_tosign() const {
+ return tosign_.Get();
+}
+inline void SessionSignatureResponse::_internal_set_tosign(const std::string& value) {
+
+ tosign_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+}
+inline void SessionSignatureResponse::set_tosign(std::string&& value) {
+
+ tosign_.Set(
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SessionSignatureResponse.toSign)
+}
+inline void SessionSignatureResponse::set_tosign(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+
+ tosign_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.SessionSignatureResponse.toSign)
+}
+inline void SessionSignatureResponse::set_tosign(const char* value,
+ size_t size) {
+
+ tosign_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ reinterpret_cast<const char*>(value), size), GetArena());
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SessionSignatureResponse.toSign)
+}
+inline std::string* SessionSignatureResponse::_internal_mutable_tosign() {
+
+ return tosign_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+}
+inline std::string* SessionSignatureResponse::release_tosign() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.SessionSignatureResponse.toSign)
+ return tosign_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+inline void SessionSignatureResponse::set_allocated_tosign(std::string* tosign) {
+ if (tosign != nullptr) {
+
+ } else {
+
+ }
+ tosign_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), tosign,
+ GetArena());
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SessionSignatureResponse.toSign)
+}
+
+// -------------------------------------------------------------------
+
+// NewSessionRequest
+
+// string deviceID = 1;
+inline void NewSessionRequest::clear_deviceid() {
+ deviceid_.ClearToEmpty();
+}
+inline const std::string& NewSessionRequest::deviceid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.deviceID)
+ return _internal_deviceid();
+}
+inline void NewSessionRequest::set_deviceid(const std::string& value) {
+ _internal_set_deviceid(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.deviceID)
+}
+inline std::string* NewSessionRequest::mutable_deviceid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.deviceID)
+ return _internal_mutable_deviceid();
+}
+inline const std::string& NewSessionRequest::_internal_deviceid() const {
+ return deviceid_.Get();
+}
+inline void NewSessionRequest::_internal_set_deviceid(const std::string& value) {
+
+ deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+}
+inline void NewSessionRequest::set_deviceid(std::string&& value) {
+
+ deviceid_.Set(
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.deviceID)
+}
+inline void NewSessionRequest::set_deviceid(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+
+ deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.deviceID)
+}
+inline void NewSessionRequest::set_deviceid(const char* value,
+ size_t size) {
+
+ deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ reinterpret_cast<const char*>(value), size), GetArena());
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.deviceID)
+}
+inline std::string* NewSessionRequest::_internal_mutable_deviceid() {
+
+ return deviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+}
+inline std::string* NewSessionRequest::release_deviceid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.deviceID)
+ return deviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+inline void NewSessionRequest::set_allocated_deviceid(std::string* deviceid) {
+ if (deviceid != nullptr) {
+
+ } else {
+
+ }
+ deviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), deviceid,
+ GetArena());
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.deviceID)
+}
+
+// string publicKey = 2;
+inline void NewSessionRequest::clear_publickey() {
+ publickey_.ClearToEmpty();
+}
+inline const std::string& NewSessionRequest::publickey() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.publicKey)
+ return _internal_publickey();
+}
+inline void NewSessionRequest::set_publickey(const std::string& value) {
+ _internal_set_publickey(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.publicKey)
+}
+inline std::string* NewSessionRequest::mutable_publickey() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.publicKey)
+ return _internal_mutable_publickey();
+}
+inline const std::string& NewSessionRequest::_internal_publickey() const {
+ return publickey_.Get();
+}
+inline void NewSessionRequest::_internal_set_publickey(const std::string& value) {
+
+ publickey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+}
+inline void NewSessionRequest::set_publickey(std::string&& value) {
+
+ publickey_.Set(
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.publicKey)
+}
+inline void NewSessionRequest::set_publickey(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+
+ publickey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.publicKey)
+}
+inline void NewSessionRequest::set_publickey(const char* value,
+ size_t size) {
+
+ publickey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ reinterpret_cast<const char*>(value), size), GetArena());
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.publicKey)
+}
+inline std::string* NewSessionRequest::_internal_mutable_publickey() {
+
+ return publickey_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+}
+inline std::string* NewSessionRequest::release_publickey() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.publicKey)
+ return publickey_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+inline void NewSessionRequest::set_allocated_publickey(std::string* publickey) {
+ if (publickey != nullptr) {
+
+ } else {
+
+ }
+ publickey_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), publickey,
+ GetArena());
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.publicKey)
+}
+
+// string signature = 3;
+inline void NewSessionRequest::clear_signature() {
+ signature_.ClearToEmpty();
+}
+inline const std::string& NewSessionRequest::signature() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.signature)
+ return _internal_signature();
+}
+inline void NewSessionRequest::set_signature(const std::string& value) {
+ _internal_set_signature(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.signature)
+}
+inline std::string* NewSessionRequest::mutable_signature() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.signature)
+ return _internal_mutable_signature();
+}
+inline const std::string& NewSessionRequest::_internal_signature() const {
+ return signature_.Get();
+}
+inline void NewSessionRequest::_internal_set_signature(const std::string& value) {
+
+ signature_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+}
+inline void NewSessionRequest::set_signature(std::string&& value) {
+
+ signature_.Set(
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.signature)
+}
+inline void NewSessionRequest::set_signature(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+
+ signature_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.signature)
+}
+inline void NewSessionRequest::set_signature(const char* value,
+ size_t size) {
+
+ signature_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ reinterpret_cast<const char*>(value), size), GetArena());
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.signature)
+}
+inline std::string* NewSessionRequest::_internal_mutable_signature() {
+
+ return signature_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+}
+inline std::string* NewSessionRequest::release_signature() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.signature)
+ return signature_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+inline void NewSessionRequest::set_allocated_signature(std::string* signature) {
+ if (signature != nullptr) {
+
+ } else {
+
+ }
+ signature_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), signature,
+ GetArena());
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.signature)
+}
+
+// string notifyToken = 4;
+inline bool NewSessionRequest::_internal_has_notifytoken() const {
+ bool value = (_has_bits_[0] & 0x00000001u) != 0;
+ return value;
+}
+inline bool NewSessionRequest::has_notifytoken() const {
+ return _internal_has_notifytoken();
+}
+inline void NewSessionRequest::clear_notifytoken() {
+ notifytoken_.ClearToEmpty();
+ _has_bits_[0] &= ~0x00000001u;
+}
+inline const std::string& NewSessionRequest::notifytoken() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.notifyToken)
+ return _internal_notifytoken();
+}
+inline void NewSessionRequest::set_notifytoken(const std::string& value) {
+ _internal_set_notifytoken(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.notifyToken)
+}
+inline std::string* NewSessionRequest::mutable_notifytoken() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.notifyToken)
+ return _internal_mutable_notifytoken();
+}
+inline const std::string& NewSessionRequest::_internal_notifytoken() const {
+ return notifytoken_.Get();
+}
+inline void NewSessionRequest::_internal_set_notifytoken(const std::string& value) {
+ _has_bits_[0] |= 0x00000001u;
+ notifytoken_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+}
+inline void NewSessionRequest::set_notifytoken(std::string&& value) {
+ _has_bits_[0] |= 0x00000001u;
+ notifytoken_.Set(
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.notifyToken)
+}
+inline void NewSessionRequest::set_notifytoken(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+ _has_bits_[0] |= 0x00000001u;
+ notifytoken_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.notifyToken)
+}
+inline void NewSessionRequest::set_notifytoken(const char* value,
+ size_t size) {
+ _has_bits_[0] |= 0x00000001u;
+ notifytoken_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ reinterpret_cast<const char*>(value), size), GetArena());
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.notifyToken)
+}
+inline std::string* NewSessionRequest::_internal_mutable_notifytoken() {
+ _has_bits_[0] |= 0x00000001u;
+ return notifytoken_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+}
+inline std::string* NewSessionRequest::release_notifytoken() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.notifyToken)
+ if (!_internal_has_notifytoken()) {
+ return nullptr;
+ }
+ _has_bits_[0] &= ~0x00000001u;
+ return notifytoken_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+inline void NewSessionRequest::set_allocated_notifytoken(std::string* notifytoken) {
+ if (notifytoken != nullptr) {
+ _has_bits_[0] |= 0x00000001u;
+ } else {
+ _has_bits_[0] &= ~0x00000001u;
+ }
+ notifytoken_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), notifytoken,
+ GetArena());
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.notifyToken)
+}
+
+// .tunnelbroker.NewSessionRequest.DeviceTypes deviceType = 5;
+inline void NewSessionRequest::clear_devicetype() {
+ devicetype_ = 0;
+}
+inline ::tunnelbroker::NewSessionRequest_DeviceTypes NewSessionRequest::_internal_devicetype() const {
+ return static_cast< ::tunnelbroker::NewSessionRequest_DeviceTypes >(devicetype_);
+}
+inline ::tunnelbroker::NewSessionRequest_DeviceTypes NewSessionRequest::devicetype() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.deviceType)
+ return _internal_devicetype();
+}
+inline void NewSessionRequest::_internal_set_devicetype(::tunnelbroker::NewSessionRequest_DeviceTypes value) {
+
+ devicetype_ = value;
+}
+inline void NewSessionRequest::set_devicetype(::tunnelbroker::NewSessionRequest_DeviceTypes value) {
+ _internal_set_devicetype(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.deviceType)
+}
+
+// string deviceAppVersion = 6;
+inline void NewSessionRequest::clear_deviceappversion() {
+ deviceappversion_.ClearToEmpty();
+}
+inline const std::string& NewSessionRequest::deviceappversion() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.deviceAppVersion)
+ return _internal_deviceappversion();
+}
+inline void NewSessionRequest::set_deviceappversion(const std::string& value) {
+ _internal_set_deviceappversion(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.deviceAppVersion)
+}
+inline std::string* NewSessionRequest::mutable_deviceappversion() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.deviceAppVersion)
+ return _internal_mutable_deviceappversion();
+}
+inline const std::string& NewSessionRequest::_internal_deviceappversion() const {
+ return deviceappversion_.Get();
+}
+inline void NewSessionRequest::_internal_set_deviceappversion(const std::string& value) {
+
+ deviceappversion_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+}
+inline void NewSessionRequest::set_deviceappversion(std::string&& value) {
+
+ deviceappversion_.Set(
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.deviceAppVersion)
+}
+inline void NewSessionRequest::set_deviceappversion(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+
+ deviceappversion_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.deviceAppVersion)
+}
+inline void NewSessionRequest::set_deviceappversion(const char* value,
+ size_t size) {
+
+ deviceappversion_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ reinterpret_cast<const char*>(value), size), GetArena());
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.deviceAppVersion)
+}
+inline std::string* NewSessionRequest::_internal_mutable_deviceappversion() {
+
+ return deviceappversion_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+}
+inline std::string* NewSessionRequest::release_deviceappversion() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.deviceAppVersion)
+ return deviceappversion_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+inline void NewSessionRequest::set_allocated_deviceappversion(std::string* deviceappversion) {
+ if (deviceappversion != nullptr) {
+
+ } else {
+
+ }
+ deviceappversion_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), deviceappversion,
+ GetArena());
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.deviceAppVersion)
}
-inline std::string* SessionSignatureResponse::mutable_tosign() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.SessionSignatureResponse.toSign)
- return _internal_mutable_tosign();
+
+// string deviceOS = 7;
+inline void NewSessionRequest::clear_deviceos() {
+ deviceos_.ClearToEmpty();
}
-inline const std::string& SessionSignatureResponse::_internal_tosign() const {
- return tosign_.Get();
+inline const std::string& NewSessionRequest::deviceos() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.deviceOS)
+ return _internal_deviceos();
}
-inline void SessionSignatureResponse::_internal_set_tosign(const std::string& value) {
+inline void NewSessionRequest::set_deviceos(const std::string& value) {
+ _internal_set_deviceos(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.deviceOS)
+}
+inline std::string* NewSessionRequest::mutable_deviceos() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.deviceOS)
+ return _internal_mutable_deviceos();
+}
+inline const std::string& NewSessionRequest::_internal_deviceos() const {
+ return deviceos_.Get();
+}
+inline void NewSessionRequest::_internal_set_deviceos(const std::string& value) {
- tosign_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+ deviceos_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void SessionSignatureResponse::set_tosign(std::string&& value) {
+inline void NewSessionRequest::set_deviceos(std::string&& value) {
- tosign_.Set(
+ deviceos_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SessionSignatureResponse.toSign)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.deviceOS)
}
-inline void SessionSignatureResponse::set_tosign(const char* value) {
+inline void NewSessionRequest::set_deviceos(const char* value) {
GOOGLE_DCHECK(value != nullptr);
- tosign_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.SessionSignatureResponse.toSign)
+ deviceos_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.deviceOS)
}
-inline void SessionSignatureResponse::set_tosign(const char* value,
+inline void NewSessionRequest::set_deviceos(const char* value,
size_t size) {
- tosign_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ deviceos_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SessionSignatureResponse.toSign)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.deviceOS)
}
-inline std::string* SessionSignatureResponse::_internal_mutable_tosign() {
+inline std::string* NewSessionRequest::_internal_mutable_deviceos() {
- return tosign_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+ return deviceos_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* SessionSignatureResponse::release_tosign() {
- // @@protoc_insertion_point(field_release:tunnelbroker.SessionSignatureResponse.toSign)
- return tosign_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* NewSessionRequest::release_deviceos() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.deviceOS)
+ return deviceos_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void SessionSignatureResponse::set_allocated_tosign(std::string* tosign) {
- if (tosign != nullptr) {
+inline void NewSessionRequest::set_allocated_deviceos(std::string* deviceos) {
+ if (deviceos != nullptr) {
} else {
}
- tosign_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), tosign,
+ deviceos_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), deviceos,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SessionSignatureResponse.toSign)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.deviceOS)
}
// -------------------------------------------------------------------
-// NewSessionRequest
+// NewSessionResponse
-// string deviceID = 1;
-inline void NewSessionRequest::clear_deviceid() {
- deviceid_.ClearToEmpty();
+// string sessionID = 1;
+inline void NewSessionResponse::clear_sessionid() {
+ sessionid_.ClearToEmpty();
}
-inline const std::string& NewSessionRequest::deviceid() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.deviceID)
- return _internal_deviceid();
+inline const std::string& NewSessionResponse::sessionid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionResponse.sessionID)
+ return _internal_sessionid();
}
-inline void NewSessionRequest::set_deviceid(const std::string& value) {
- _internal_set_deviceid(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.deviceID)
+inline void NewSessionResponse::set_sessionid(const std::string& value) {
+ _internal_set_sessionid(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionResponse.sessionID)
}
-inline std::string* NewSessionRequest::mutable_deviceid() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.deviceID)
- return _internal_mutable_deviceid();
+inline std::string* NewSessionResponse::mutable_sessionid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionResponse.sessionID)
+ return _internal_mutable_sessionid();
}
-inline const std::string& NewSessionRequest::_internal_deviceid() const {
- return deviceid_.Get();
+inline const std::string& NewSessionResponse::_internal_sessionid() const {
+ return sessionid_.Get();
}
-inline void NewSessionRequest::_internal_set_deviceid(const std::string& value) {
+inline void NewSessionResponse::_internal_set_sessionid(const std::string& value) {
- deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+ sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void NewSessionRequest::set_deviceid(std::string&& value) {
+inline void NewSessionResponse::set_sessionid(std::string&& value) {
- deviceid_.Set(
+ sessionid_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.deviceID)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionResponse.sessionID)
}
-inline void NewSessionRequest::set_deviceid(const char* value) {
+inline void NewSessionResponse::set_sessionid(const char* value) {
GOOGLE_DCHECK(value != nullptr);
- deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.deviceID)
+ sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionResponse.sessionID)
}
-inline void NewSessionRequest::set_deviceid(const char* value,
+inline void NewSessionResponse::set_sessionid(const char* value,
size_t size) {
- deviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.deviceID)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionResponse.sessionID)
}
-inline std::string* NewSessionRequest::_internal_mutable_deviceid() {
+inline std::string* NewSessionResponse::_internal_mutable_sessionid() {
- return deviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+ return sessionid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* NewSessionRequest::release_deviceid() {
- // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.deviceID)
- return deviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* NewSessionResponse::release_sessionid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionResponse.sessionID)
+ return sessionid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void NewSessionRequest::set_allocated_deviceid(std::string* deviceid) {
- if (deviceid != nullptr) {
+inline void NewSessionResponse::set_allocated_sessionid(std::string* sessionid) {
+ if (sessionid != nullptr) {
} else {
}
- deviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), deviceid,
+ sessionid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), sessionid,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.deviceID)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionResponse.sessionID)
}
-// bytes publicKey = 2;
-inline void NewSessionRequest::clear_publickey() {
- publickey_.ClearToEmpty();
+// -------------------------------------------------------------------
+
+// SendRequest
+
+// string sessionID = 1;
+inline void SendRequest::clear_sessionid() {
+ sessionid_.ClearToEmpty();
}
-inline const std::string& NewSessionRequest::publickey() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.publicKey)
- return _internal_publickey();
+inline const std::string& SendRequest::sessionid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.SendRequest.sessionID)
+ return _internal_sessionid();
}
-inline void NewSessionRequest::set_publickey(const std::string& value) {
- _internal_set_publickey(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.publicKey)
+inline void SendRequest::set_sessionid(const std::string& value) {
+ _internal_set_sessionid(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.sessionID)
}
-inline std::string* NewSessionRequest::mutable_publickey() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.publicKey)
- return _internal_mutable_publickey();
+inline std::string* SendRequest::mutable_sessionid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.SendRequest.sessionID)
+ return _internal_mutable_sessionid();
}
-inline const std::string& NewSessionRequest::_internal_publickey() const {
- return publickey_.Get();
+inline const std::string& SendRequest::_internal_sessionid() const {
+ return sessionid_.Get();
}
-inline void NewSessionRequest::_internal_set_publickey(const std::string& value) {
+inline void SendRequest::_internal_set_sessionid(const std::string& value) {
- publickey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+ sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void NewSessionRequest::set_publickey(std::string&& value) {
+inline void SendRequest::set_sessionid(std::string&& value) {
- publickey_.Set(
+ sessionid_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.publicKey)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SendRequest.sessionID)
}
-inline void NewSessionRequest::set_publickey(const char* value) {
+inline void SendRequest::set_sessionid(const char* value) {
GOOGLE_DCHECK(value != nullptr);
- publickey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.publicKey)
+ sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.SendRequest.sessionID)
+}
+inline void SendRequest::set_sessionid(const char* value,
+ size_t size) {
+
+ sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ reinterpret_cast<const char*>(value), size), GetArena());
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SendRequest.sessionID)
+}
+inline std::string* SendRequest::_internal_mutable_sessionid() {
+
+ return sessionid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+}
+inline std::string* SendRequest::release_sessionid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.SendRequest.sessionID)
+ return sessionid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+inline void SendRequest::set_allocated_sessionid(std::string* sessionid) {
+ if (sessionid != nullptr) {
+
+ } else {
+
+ }
+ sessionid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), sessionid,
+ GetArena());
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SendRequest.sessionID)
+}
+
+// string toDeviceID = 2;
+inline void SendRequest::clear_todeviceid() {
+ todeviceid_.ClearToEmpty();
+}
+inline const std::string& SendRequest::todeviceid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.SendRequest.toDeviceID)
+ return _internal_todeviceid();
+}
+inline void SendRequest::set_todeviceid(const std::string& value) {
+ _internal_set_todeviceid(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.toDeviceID)
+}
+inline std::string* SendRequest::mutable_todeviceid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.SendRequest.toDeviceID)
+ return _internal_mutable_todeviceid();
+}
+inline const std::string& SendRequest::_internal_todeviceid() const {
+ return todeviceid_.Get();
+}
+inline void SendRequest::_internal_set_todeviceid(const std::string& value) {
+
+ todeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+}
+inline void SendRequest::set_todeviceid(std::string&& value) {
+
+ todeviceid_.Set(
+ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SendRequest.toDeviceID)
+}
+inline void SendRequest::set_todeviceid(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+
+ todeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.SendRequest.toDeviceID)
}
-inline void NewSessionRequest::set_publickey(const void* value,
+inline void SendRequest::set_todeviceid(const char* value,
size_t size) {
- publickey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ todeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.publicKey)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SendRequest.toDeviceID)
}
-inline std::string* NewSessionRequest::_internal_mutable_publickey() {
+inline std::string* SendRequest::_internal_mutable_todeviceid() {
- return publickey_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+ return todeviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* NewSessionRequest::release_publickey() {
- // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.publicKey)
- return publickey_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* SendRequest::release_todeviceid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.SendRequest.toDeviceID)
+ return todeviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void NewSessionRequest::set_allocated_publickey(std::string* publickey) {
- if (publickey != nullptr) {
+inline void SendRequest::set_allocated_todeviceid(std::string* todeviceid) {
+ if (todeviceid != nullptr) {
} else {
}
- publickey_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), publickey,
+ todeviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), todeviceid,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.publicKey)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SendRequest.toDeviceID)
}
-// string signature = 3;
-inline void NewSessionRequest::clear_signature() {
- signature_.ClearToEmpty();
+// bytes payload = 3;
+inline void SendRequest::clear_payload() {
+ payload_.ClearToEmpty();
}
-inline const std::string& NewSessionRequest::signature() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.signature)
- return _internal_signature();
+inline const std::string& SendRequest::payload() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.SendRequest.payload)
+ return _internal_payload();
}
-inline void NewSessionRequest::set_signature(const std::string& value) {
- _internal_set_signature(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.signature)
+inline void SendRequest::set_payload(const std::string& value) {
+ _internal_set_payload(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.payload)
}
-inline std::string* NewSessionRequest::mutable_signature() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.signature)
- return _internal_mutable_signature();
+inline std::string* SendRequest::mutable_payload() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.SendRequest.payload)
+ return _internal_mutable_payload();
}
-inline const std::string& NewSessionRequest::_internal_signature() const {
- return signature_.Get();
+inline const std::string& SendRequest::_internal_payload() const {
+ return payload_.Get();
}
-inline void NewSessionRequest::_internal_set_signature(const std::string& value) {
+inline void SendRequest::_internal_set_payload(const std::string& value) {
- signature_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+ payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void NewSessionRequest::set_signature(std::string&& value) {
+inline void SendRequest::set_payload(std::string&& value) {
- signature_.Set(
+ payload_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.signature)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SendRequest.payload)
}
-inline void NewSessionRequest::set_signature(const char* value) {
+inline void SendRequest::set_payload(const char* value) {
GOOGLE_DCHECK(value != nullptr);
- signature_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.signature)
+ payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.SendRequest.payload)
}
-inline void NewSessionRequest::set_signature(const char* value,
+inline void SendRequest::set_payload(const void* value,
size_t size) {
- signature_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.signature)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SendRequest.payload)
}
-inline std::string* NewSessionRequest::_internal_mutable_signature() {
+inline std::string* SendRequest::_internal_mutable_payload() {
- return signature_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+ return payload_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* NewSessionRequest::release_signature() {
- // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.signature)
- return signature_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* SendRequest::release_payload() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.SendRequest.payload)
+ return payload_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void NewSessionRequest::set_allocated_signature(std::string* signature) {
- if (signature != nullptr) {
+inline void SendRequest::set_allocated_payload(std::string* payload) {
+ if (payload != nullptr) {
} else {
}
- signature_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), signature,
+ payload_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), payload,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.signature)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SendRequest.payload)
}
-// string notifyToken = 4;
-inline bool NewSessionRequest::_internal_has_notifytoken() const {
- bool value = (_has_bits_[0] & 0x00000001u) != 0;
- return value;
+// repeated string blobHashes = 4;
+inline int SendRequest::_internal_blobhashes_size() const {
+ return blobhashes_.size();
}
-inline bool NewSessionRequest::has_notifytoken() const {
- return _internal_has_notifytoken();
+inline int SendRequest::blobhashes_size() const {
+ return _internal_blobhashes_size();
}
-inline void NewSessionRequest::clear_notifytoken() {
- notifytoken_.ClearToEmpty();
- _has_bits_[0] &= ~0x00000001u;
+inline void SendRequest::clear_blobhashes() {
+ blobhashes_.Clear();
}
-inline const std::string& NewSessionRequest::notifytoken() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.notifyToken)
- return _internal_notifytoken();
+inline std::string* SendRequest::add_blobhashes() {
+ // @@protoc_insertion_point(field_add_mutable:tunnelbroker.SendRequest.blobHashes)
+ return _internal_add_blobhashes();
}
-inline void NewSessionRequest::set_notifytoken(const std::string& value) {
- _internal_set_notifytoken(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.notifyToken)
+inline const std::string& SendRequest::_internal_blobhashes(int index) const {
+ return blobhashes_.Get(index);
}
-inline std::string* NewSessionRequest::mutable_notifytoken() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.notifyToken)
- return _internal_mutable_notifytoken();
+inline const std::string& SendRequest::blobhashes(int index) const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.SendRequest.blobHashes)
+ return _internal_blobhashes(index);
}
-inline const std::string& NewSessionRequest::_internal_notifytoken() const {
- return notifytoken_.Get();
+inline std::string* SendRequest::mutable_blobhashes(int index) {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.SendRequest.blobHashes)
+ return blobhashes_.Mutable(index);
}
-inline void NewSessionRequest::_internal_set_notifytoken(const std::string& value) {
- _has_bits_[0] |= 0x00000001u;
- notifytoken_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+inline void SendRequest::set_blobhashes(int index, const std::string& value) {
+ // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.blobHashes)
+ blobhashes_.Mutable(index)->assign(value);
}
-inline void NewSessionRequest::set_notifytoken(std::string&& value) {
- _has_bits_[0] |= 0x00000001u;
- notifytoken_.Set(
- ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.notifyToken)
+inline void SendRequest::set_blobhashes(int index, std::string&& value) {
+ // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.blobHashes)
+ blobhashes_.Mutable(index)->assign(std::move(value));
}
-inline void NewSessionRequest::set_notifytoken(const char* value) {
+inline void SendRequest::set_blobhashes(int index, const char* value) {
GOOGLE_DCHECK(value != nullptr);
- _has_bits_[0] |= 0x00000001u;
- notifytoken_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.notifyToken)
-}
-inline void NewSessionRequest::set_notifytoken(const char* value,
- size_t size) {
- _has_bits_[0] |= 0x00000001u;
- notifytoken_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
- reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.notifyToken)
+ blobhashes_.Mutable(index)->assign(value);
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.SendRequest.blobHashes)
}
-inline std::string* NewSessionRequest::_internal_mutable_notifytoken() {
- _has_bits_[0] |= 0x00000001u;
- return notifytoken_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+inline void SendRequest::set_blobhashes(int index, const char* value, size_t size) {
+ blobhashes_.Mutable(index)->assign(
+ reinterpret_cast<const char*>(value), size);
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SendRequest.blobHashes)
}
-inline std::string* NewSessionRequest::release_notifytoken() {
- // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.notifyToken)
- if (!_internal_has_notifytoken()) {
- return nullptr;
- }
- _has_bits_[0] &= ~0x00000001u;
- return notifytoken_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* SendRequest::_internal_add_blobhashes() {
+ return blobhashes_.Add();
}
-inline void NewSessionRequest::set_allocated_notifytoken(std::string* notifytoken) {
- if (notifytoken != nullptr) {
- _has_bits_[0] |= 0x00000001u;
- } else {
- _has_bits_[0] &= ~0x00000001u;
- }
- notifytoken_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), notifytoken,
- GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.notifyToken)
+inline void SendRequest::add_blobhashes(const std::string& value) {
+ blobhashes_.Add()->assign(value);
+ // @@protoc_insertion_point(field_add:tunnelbroker.SendRequest.blobHashes)
}
-
-// .tunnelbroker.NewSessionRequest.DeviceTypes deviceType = 5;
-inline void NewSessionRequest::clear_devicetype() {
- devicetype_ = 0;
+inline void SendRequest::add_blobhashes(std::string&& value) {
+ blobhashes_.Add(std::move(value));
+ // @@protoc_insertion_point(field_add:tunnelbroker.SendRequest.blobHashes)
}
-inline ::tunnelbroker::NewSessionRequest_DeviceTypes NewSessionRequest::_internal_devicetype() const {
- return static_cast< ::tunnelbroker::NewSessionRequest_DeviceTypes >(devicetype_);
+inline void SendRequest::add_blobhashes(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+ blobhashes_.Add()->assign(value);
+ // @@protoc_insertion_point(field_add_char:tunnelbroker.SendRequest.blobHashes)
}
-inline ::tunnelbroker::NewSessionRequest_DeviceTypes NewSessionRequest::devicetype() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.deviceType)
- return _internal_devicetype();
+inline void SendRequest::add_blobhashes(const char* value, size_t size) {
+ blobhashes_.Add()->assign(reinterpret_cast<const char*>(value), size);
+ // @@protoc_insertion_point(field_add_pointer:tunnelbroker.SendRequest.blobHashes)
}
-inline void NewSessionRequest::_internal_set_devicetype(::tunnelbroker::NewSessionRequest_DeviceTypes value) {
-
- devicetype_ = value;
+inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>&
+SendRequest::blobhashes() const {
+ // @@protoc_insertion_point(field_list:tunnelbroker.SendRequest.blobHashes)
+ return blobhashes_;
}
-inline void NewSessionRequest::set_devicetype(::tunnelbroker::NewSessionRequest_DeviceTypes value) {
- _internal_set_devicetype(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.deviceType)
+inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>*
+SendRequest::mutable_blobhashes() {
+ // @@protoc_insertion_point(field_mutable_list:tunnelbroker.SendRequest.blobHashes)
+ return &blobhashes_;
}
-// string deviceAppVersion = 6;
-inline void NewSessionRequest::clear_deviceappversion() {
- deviceappversion_.ClearToEmpty();
+// -------------------------------------------------------------------
+
+// GetRequest
+
+// string sessionID = 1;
+inline void GetRequest::clear_sessionid() {
+ sessionid_.ClearToEmpty();
}
-inline const std::string& NewSessionRequest::deviceappversion() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.deviceAppVersion)
- return _internal_deviceappversion();
+inline const std::string& GetRequest::sessionid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.GetRequest.sessionID)
+ return _internal_sessionid();
}
-inline void NewSessionRequest::set_deviceappversion(const std::string& value) {
- _internal_set_deviceappversion(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.deviceAppVersion)
+inline void GetRequest::set_sessionid(const std::string& value) {
+ _internal_set_sessionid(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.GetRequest.sessionID)
}
-inline std::string* NewSessionRequest::mutable_deviceappversion() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.deviceAppVersion)
- return _internal_mutable_deviceappversion();
+inline std::string* GetRequest::mutable_sessionid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.GetRequest.sessionID)
+ return _internal_mutable_sessionid();
}
-inline const std::string& NewSessionRequest::_internal_deviceappversion() const {
- return deviceappversion_.Get();
+inline const std::string& GetRequest::_internal_sessionid() const {
+ return sessionid_.Get();
}
-inline void NewSessionRequest::_internal_set_deviceappversion(const std::string& value) {
+inline void GetRequest::_internal_set_sessionid(const std::string& value) {
- deviceappversion_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+ sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void NewSessionRequest::set_deviceappversion(std::string&& value) {
+inline void GetRequest::set_sessionid(std::string&& value) {
- deviceappversion_.Set(
+ sessionid_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.deviceAppVersion)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetRequest.sessionID)
}
-inline void NewSessionRequest::set_deviceappversion(const char* value) {
+inline void GetRequest::set_sessionid(const char* value) {
GOOGLE_DCHECK(value != nullptr);
- deviceappversion_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.deviceAppVersion)
+ sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.GetRequest.sessionID)
}
-inline void NewSessionRequest::set_deviceappversion(const char* value,
+inline void GetRequest::set_sessionid(const char* value,
size_t size) {
- deviceappversion_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.deviceAppVersion)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetRequest.sessionID)
}
-inline std::string* NewSessionRequest::_internal_mutable_deviceappversion() {
+inline std::string* GetRequest::_internal_mutable_sessionid() {
- return deviceappversion_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+ return sessionid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* NewSessionRequest::release_deviceappversion() {
- // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.deviceAppVersion)
- return deviceappversion_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* GetRequest::release_sessionid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.GetRequest.sessionID)
+ return sessionid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void NewSessionRequest::set_allocated_deviceappversion(std::string* deviceappversion) {
- if (deviceappversion != nullptr) {
+inline void GetRequest::set_allocated_sessionid(std::string* sessionid) {
+ if (sessionid != nullptr) {
} else {
}
- deviceappversion_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), deviceappversion,
+ sessionid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), sessionid,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.deviceAppVersion)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetRequest.sessionID)
}
-// string deviceOS = 7;
-inline void NewSessionRequest::clear_deviceos() {
- deviceos_.ClearToEmpty();
+// -------------------------------------------------------------------
+
+// GetResponse
+
+// string fromDeviceID = 1;
+inline void GetResponse::clear_fromdeviceid() {
+ fromdeviceid_.ClearToEmpty();
}
-inline const std::string& NewSessionRequest::deviceos() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionRequest.deviceOS)
- return _internal_deviceos();
+inline const std::string& GetResponse::fromdeviceid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.fromDeviceID)
+ return _internal_fromdeviceid();
}
-inline void NewSessionRequest::set_deviceos(const std::string& value) {
- _internal_set_deviceos(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionRequest.deviceOS)
+inline void GetResponse::set_fromdeviceid(const std::string& value) {
+ _internal_set_fromdeviceid(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.fromDeviceID)
}
-inline std::string* NewSessionRequest::mutable_deviceos() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionRequest.deviceOS)
- return _internal_mutable_deviceos();
+inline std::string* GetResponse::mutable_fromdeviceid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.fromDeviceID)
+ return _internal_mutable_fromdeviceid();
}
-inline const std::string& NewSessionRequest::_internal_deviceos() const {
- return deviceos_.Get();
+inline const std::string& GetResponse::_internal_fromdeviceid() const {
+ return fromdeviceid_.Get();
}
-inline void NewSessionRequest::_internal_set_deviceos(const std::string& value) {
+inline void GetResponse::_internal_set_fromdeviceid(const std::string& value) {
- deviceos_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+ fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void NewSessionRequest::set_deviceos(std::string&& value) {
+inline void GetResponse::set_fromdeviceid(std::string&& value) {
- deviceos_.Set(
+ fromdeviceid_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionRequest.deviceOS)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetResponse.fromDeviceID)
}
-inline void NewSessionRequest::set_deviceos(const char* value) {
+inline void GetResponse::set_fromdeviceid(const char* value) {
GOOGLE_DCHECK(value != nullptr);
- deviceos_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionRequest.deviceOS)
+ fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponse.fromDeviceID)
}
-inline void NewSessionRequest::set_deviceos(const char* value,
+inline void GetResponse::set_fromdeviceid(const char* value,
size_t size) {
- deviceos_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionRequest.deviceOS)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponse.fromDeviceID)
}
-inline std::string* NewSessionRequest::_internal_mutable_deviceos() {
+inline std::string* GetResponse::_internal_mutable_fromdeviceid() {
- return deviceos_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+ return fromdeviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* NewSessionRequest::release_deviceos() {
- // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionRequest.deviceOS)
- return deviceos_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* GetResponse::release_fromdeviceid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.GetResponse.fromDeviceID)
+ return fromdeviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void NewSessionRequest::set_allocated_deviceos(std::string* deviceos) {
- if (deviceos != nullptr) {
+inline void GetResponse::set_allocated_fromdeviceid(std::string* fromdeviceid) {
+ if (fromdeviceid != nullptr) {
} else {
}
- deviceos_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), deviceos,
+ fromdeviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), fromdeviceid,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionRequest.deviceOS)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponse.fromDeviceID)
}
-// -------------------------------------------------------------------
-
-// NewSessionResponse
-
-// string sessionID = 1;
-inline void NewSessionResponse::clear_sessionid() {
- sessionid_.ClearToEmpty();
+// bytes payload = 2;
+inline void GetResponse::clear_payload() {
+ payload_.ClearToEmpty();
}
-inline const std::string& NewSessionResponse::sessionid() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.NewSessionResponse.sessionID)
- return _internal_sessionid();
+inline const std::string& GetResponse::payload() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.payload)
+ return _internal_payload();
}
-inline void NewSessionResponse::set_sessionid(const std::string& value) {
- _internal_set_sessionid(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.NewSessionResponse.sessionID)
+inline void GetResponse::set_payload(const std::string& value) {
+ _internal_set_payload(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.payload)
}
-inline std::string* NewSessionResponse::mutable_sessionid() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.NewSessionResponse.sessionID)
- return _internal_mutable_sessionid();
+inline std::string* GetResponse::mutable_payload() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.payload)
+ return _internal_mutable_payload();
}
-inline const std::string& NewSessionResponse::_internal_sessionid() const {
- return sessionid_.Get();
+inline const std::string& GetResponse::_internal_payload() const {
+ return payload_.Get();
}
-inline void NewSessionResponse::_internal_set_sessionid(const std::string& value) {
+inline void GetResponse::_internal_set_payload(const std::string& value) {
- sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+ payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void NewSessionResponse::set_sessionid(std::string&& value) {
+inline void GetResponse::set_payload(std::string&& value) {
- sessionid_.Set(
+ payload_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.NewSessionResponse.sessionID)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetResponse.payload)
}
-inline void NewSessionResponse::set_sessionid(const char* value) {
+inline void GetResponse::set_payload(const char* value) {
GOOGLE_DCHECK(value != nullptr);
- sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.NewSessionResponse.sessionID)
+ payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponse.payload)
}
-inline void NewSessionResponse::set_sessionid(const char* value,
+inline void GetResponse::set_payload(const void* value,
size_t size) {
- sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.NewSessionResponse.sessionID)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponse.payload)
}
-inline std::string* NewSessionResponse::_internal_mutable_sessionid() {
+inline std::string* GetResponse::_internal_mutable_payload() {
- return sessionid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+ return payload_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* NewSessionResponse::release_sessionid() {
- // @@protoc_insertion_point(field_release:tunnelbroker.NewSessionResponse.sessionID)
- return sessionid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* GetResponse::release_payload() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.GetResponse.payload)
+ return payload_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void NewSessionResponse::set_allocated_sessionid(std::string* sessionid) {
- if (sessionid != nullptr) {
+inline void GetResponse::set_allocated_payload(std::string* payload) {
+ if (payload != nullptr) {
} else {
}
- sessionid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), sessionid,
+ payload_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), payload,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.NewSessionResponse.sessionID)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponse.payload)
}
-// -------------------------------------------------------------------
-
-// SendRequest
-
-// string sessionID = 1;
-inline void SendRequest::clear_sessionid() {
- sessionid_.ClearToEmpty();
+// repeated string blobHashes = 3;
+inline int GetResponse::_internal_blobhashes_size() const {
+ return blobhashes_.size();
}
-inline const std::string& SendRequest::sessionid() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.SendRequest.sessionID)
- return _internal_sessionid();
+inline int GetResponse::blobhashes_size() const {
+ return _internal_blobhashes_size();
}
-inline void SendRequest::set_sessionid(const std::string& value) {
- _internal_set_sessionid(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.sessionID)
+inline void GetResponse::clear_blobhashes() {
+ blobhashes_.Clear();
}
-inline std::string* SendRequest::mutable_sessionid() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.SendRequest.sessionID)
- return _internal_mutable_sessionid();
+inline std::string* GetResponse::add_blobhashes() {
+ // @@protoc_insertion_point(field_add_mutable:tunnelbroker.GetResponse.blobHashes)
+ return _internal_add_blobhashes();
}
-inline const std::string& SendRequest::_internal_sessionid() const {
- return sessionid_.Get();
+inline const std::string& GetResponse::_internal_blobhashes(int index) const {
+ return blobhashes_.Get(index);
}
-inline void SendRequest::_internal_set_sessionid(const std::string& value) {
-
- sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+inline const std::string& GetResponse::blobhashes(int index) const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.blobHashes)
+ return _internal_blobhashes(index);
}
-inline void SendRequest::set_sessionid(std::string&& value) {
-
- sessionid_.Set(
- ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SendRequest.sessionID)
+inline std::string* GetResponse::mutable_blobhashes(int index) {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.blobHashes)
+ return blobhashes_.Mutable(index);
}
-inline void SendRequest::set_sessionid(const char* value) {
+inline void GetResponse::set_blobhashes(int index, const std::string& value) {
+ // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.blobHashes)
+ blobhashes_.Mutable(index)->assign(value);
+}
+inline void GetResponse::set_blobhashes(int index, std::string&& value) {
+ // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.blobHashes)
+ blobhashes_.Mutable(index)->assign(std::move(value));
+}
+inline void GetResponse::set_blobhashes(int index, const char* value) {
GOOGLE_DCHECK(value != nullptr);
-
- sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.SendRequest.sessionID)
+ blobhashes_.Mutable(index)->assign(value);
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponse.blobHashes)
}
-inline void SendRequest::set_sessionid(const char* value,
- size_t size) {
-
- sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
- reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SendRequest.sessionID)
+inline void GetResponse::set_blobhashes(int index, const char* value, size_t size) {
+ blobhashes_.Mutable(index)->assign(
+ reinterpret_cast<const char*>(value), size);
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponse.blobHashes)
+}
+inline std::string* GetResponse::_internal_add_blobhashes() {
+ return blobhashes_.Add();
+}
+inline void GetResponse::add_blobhashes(const std::string& value) {
+ blobhashes_.Add()->assign(value);
+ // @@protoc_insertion_point(field_add:tunnelbroker.GetResponse.blobHashes)
+}
+inline void GetResponse::add_blobhashes(std::string&& value) {
+ blobhashes_.Add(std::move(value));
+ // @@protoc_insertion_point(field_add:tunnelbroker.GetResponse.blobHashes)
}
-inline std::string* SendRequest::_internal_mutable_sessionid() {
-
- return sessionid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+inline void GetResponse::add_blobhashes(const char* value) {
+ GOOGLE_DCHECK(value != nullptr);
+ blobhashes_.Add()->assign(value);
+ // @@protoc_insertion_point(field_add_char:tunnelbroker.GetResponse.blobHashes)
}
-inline std::string* SendRequest::release_sessionid() {
- // @@protoc_insertion_point(field_release:tunnelbroker.SendRequest.sessionID)
- return sessionid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline void GetResponse::add_blobhashes(const char* value, size_t size) {
+ blobhashes_.Add()->assign(reinterpret_cast<const char*>(value), size);
+ // @@protoc_insertion_point(field_add_pointer:tunnelbroker.GetResponse.blobHashes)
}
-inline void SendRequest::set_allocated_sessionid(std::string* sessionid) {
- if (sessionid != nullptr) {
-
- } else {
-
- }
- sessionid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), sessionid,
- GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SendRequest.sessionID)
+inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>&
+GetResponse::blobhashes() const {
+ // @@protoc_insertion_point(field_list:tunnelbroker.GetResponse.blobHashes)
+ return blobhashes_;
+}
+inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>*
+GetResponse::mutable_blobhashes() {
+ // @@protoc_insertion_point(field_mutable_list:tunnelbroker.GetResponse.blobHashes)
+ return &blobhashes_;
}
-// string toDeviceID = 2;
-inline void SendRequest::clear_todeviceid() {
+// -------------------------------------------------------------------
+
+// OutboundMessage
+
+// string toDeviceID = 1;
+inline void OutboundMessage::clear_todeviceid() {
todeviceid_.ClearToEmpty();
}
-inline const std::string& SendRequest::todeviceid() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.SendRequest.toDeviceID)
+inline const std::string& OutboundMessage::todeviceid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.OutboundMessage.toDeviceID)
return _internal_todeviceid();
}
-inline void SendRequest::set_todeviceid(const std::string& value) {
+inline void OutboundMessage::set_todeviceid(const std::string& value) {
_internal_set_todeviceid(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.toDeviceID)
+ // @@protoc_insertion_point(field_set:tunnelbroker.OutboundMessage.toDeviceID)
}
-inline std::string* SendRequest::mutable_todeviceid() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.SendRequest.toDeviceID)
+inline std::string* OutboundMessage::mutable_todeviceid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.OutboundMessage.toDeviceID)
return _internal_mutable_todeviceid();
}
-inline const std::string& SendRequest::_internal_todeviceid() const {
+inline const std::string& OutboundMessage::_internal_todeviceid() const {
return todeviceid_.Get();
}
-inline void SendRequest::_internal_set_todeviceid(const std::string& value) {
+inline void OutboundMessage::_internal_set_todeviceid(const std::string& value) {
todeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void SendRequest::set_todeviceid(std::string&& value) {
+inline void OutboundMessage::set_todeviceid(std::string&& value) {
todeviceid_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SendRequest.toDeviceID)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.OutboundMessage.toDeviceID)
}
-inline void SendRequest::set_todeviceid(const char* value) {
+inline void OutboundMessage::set_todeviceid(const char* value) {
GOOGLE_DCHECK(value != nullptr);
todeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.SendRequest.toDeviceID)
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.OutboundMessage.toDeviceID)
}
-inline void SendRequest::set_todeviceid(const char* value,
+inline void OutboundMessage::set_todeviceid(const char* value,
size_t size) {
todeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SendRequest.toDeviceID)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.OutboundMessage.toDeviceID)
}
-inline std::string* SendRequest::_internal_mutable_todeviceid() {
+inline std::string* OutboundMessage::_internal_mutable_todeviceid() {
return todeviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* SendRequest::release_todeviceid() {
- // @@protoc_insertion_point(field_release:tunnelbroker.SendRequest.toDeviceID)
+inline std::string* OutboundMessage::release_todeviceid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.OutboundMessage.toDeviceID)
return todeviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void SendRequest::set_allocated_todeviceid(std::string* todeviceid) {
+inline void OutboundMessage::set_allocated_todeviceid(std::string* todeviceid) {
if (todeviceid != nullptr) {
} else {
@@ -2902,60 +3769,60 @@
}
todeviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), todeviceid,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SendRequest.toDeviceID)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.OutboundMessage.toDeviceID)
}
-// bytes payload = 3;
-inline void SendRequest::clear_payload() {
+// string payload = 2;
+inline void OutboundMessage::clear_payload() {
payload_.ClearToEmpty();
}
-inline const std::string& SendRequest::payload() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.SendRequest.payload)
+inline const std::string& OutboundMessage::payload() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.OutboundMessage.payload)
return _internal_payload();
}
-inline void SendRequest::set_payload(const std::string& value) {
+inline void OutboundMessage::set_payload(const std::string& value) {
_internal_set_payload(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.payload)
+ // @@protoc_insertion_point(field_set:tunnelbroker.OutboundMessage.payload)
}
-inline std::string* SendRequest::mutable_payload() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.SendRequest.payload)
+inline std::string* OutboundMessage::mutable_payload() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.OutboundMessage.payload)
return _internal_mutable_payload();
}
-inline const std::string& SendRequest::_internal_payload() const {
+inline const std::string& OutboundMessage::_internal_payload() const {
return payload_.Get();
}
-inline void SendRequest::_internal_set_payload(const std::string& value) {
+inline void OutboundMessage::_internal_set_payload(const std::string& value) {
payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void SendRequest::set_payload(std::string&& value) {
+inline void OutboundMessage::set_payload(std::string&& value) {
payload_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.SendRequest.payload)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.OutboundMessage.payload)
}
-inline void SendRequest::set_payload(const char* value) {
+inline void OutboundMessage::set_payload(const char* value) {
GOOGLE_DCHECK(value != nullptr);
payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.SendRequest.payload)
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.OutboundMessage.payload)
}
-inline void SendRequest::set_payload(const void* value,
+inline void OutboundMessage::set_payload(const char* value,
size_t size) {
payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SendRequest.payload)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.OutboundMessage.payload)
}
-inline std::string* SendRequest::_internal_mutable_payload() {
+inline std::string* OutboundMessage::_internal_mutable_payload() {
return payload_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* SendRequest::release_payload() {
- // @@protoc_insertion_point(field_release:tunnelbroker.SendRequest.payload)
+inline std::string* OutboundMessage::release_payload() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.OutboundMessage.payload)
return payload_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void SendRequest::set_allocated_payload(std::string* payload) {
+inline void OutboundMessage::set_allocated_payload(std::string* payload) {
if (payload != nullptr) {
} else {
@@ -2963,264 +3830,260 @@
}
payload_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), payload,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.SendRequest.payload)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.OutboundMessage.payload)
}
-// repeated string blobHashes = 4;
-inline int SendRequest::_internal_blobhashes_size() const {
+// repeated string blobHashes = 3;
+inline int OutboundMessage::_internal_blobhashes_size() const {
return blobhashes_.size();
}
-inline int SendRequest::blobhashes_size() const {
+inline int OutboundMessage::blobhashes_size() const {
return _internal_blobhashes_size();
}
-inline void SendRequest::clear_blobhashes() {
+inline void OutboundMessage::clear_blobhashes() {
blobhashes_.Clear();
}
-inline std::string* SendRequest::add_blobhashes() {
- // @@protoc_insertion_point(field_add_mutable:tunnelbroker.SendRequest.blobHashes)
+inline std::string* OutboundMessage::add_blobhashes() {
+ // @@protoc_insertion_point(field_add_mutable:tunnelbroker.OutboundMessage.blobHashes)
return _internal_add_blobhashes();
}
-inline const std::string& SendRequest::_internal_blobhashes(int index) const {
+inline const std::string& OutboundMessage::_internal_blobhashes(int index) const {
return blobhashes_.Get(index);
}
-inline const std::string& SendRequest::blobhashes(int index) const {
- // @@protoc_insertion_point(field_get:tunnelbroker.SendRequest.blobHashes)
+inline const std::string& OutboundMessage::blobhashes(int index) const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.OutboundMessage.blobHashes)
return _internal_blobhashes(index);
}
-inline std::string* SendRequest::mutable_blobhashes(int index) {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.SendRequest.blobHashes)
+inline std::string* OutboundMessage::mutable_blobhashes(int index) {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.OutboundMessage.blobHashes)
return blobhashes_.Mutable(index);
}
-inline void SendRequest::set_blobhashes(int index, const std::string& value) {
- // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.blobHashes)
+inline void OutboundMessage::set_blobhashes(int index, const std::string& value) {
+ // @@protoc_insertion_point(field_set:tunnelbroker.OutboundMessage.blobHashes)
blobhashes_.Mutable(index)->assign(value);
}
-inline void SendRequest::set_blobhashes(int index, std::string&& value) {
- // @@protoc_insertion_point(field_set:tunnelbroker.SendRequest.blobHashes)
+inline void OutboundMessage::set_blobhashes(int index, std::string&& value) {
+ // @@protoc_insertion_point(field_set:tunnelbroker.OutboundMessage.blobHashes)
blobhashes_.Mutable(index)->assign(std::move(value));
}
-inline void SendRequest::set_blobhashes(int index, const char* value) {
+inline void OutboundMessage::set_blobhashes(int index, const char* value) {
GOOGLE_DCHECK(value != nullptr);
blobhashes_.Mutable(index)->assign(value);
- // @@protoc_insertion_point(field_set_char:tunnelbroker.SendRequest.blobHashes)
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.OutboundMessage.blobHashes)
}
-inline void SendRequest::set_blobhashes(int index, const char* value, size_t size) {
+inline void OutboundMessage::set_blobhashes(int index, const char* value, size_t size) {
blobhashes_.Mutable(index)->assign(
reinterpret_cast<const char*>(value), size);
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.SendRequest.blobHashes)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.OutboundMessage.blobHashes)
}
-inline std::string* SendRequest::_internal_add_blobhashes() {
+inline std::string* OutboundMessage::_internal_add_blobhashes() {
return blobhashes_.Add();
}
-inline void SendRequest::add_blobhashes(const std::string& value) {
+inline void OutboundMessage::add_blobhashes(const std::string& value) {
blobhashes_.Add()->assign(value);
- // @@protoc_insertion_point(field_add:tunnelbroker.SendRequest.blobHashes)
+ // @@protoc_insertion_point(field_add:tunnelbroker.OutboundMessage.blobHashes)
}
-inline void SendRequest::add_blobhashes(std::string&& value) {
+inline void OutboundMessage::add_blobhashes(std::string&& value) {
blobhashes_.Add(std::move(value));
- // @@protoc_insertion_point(field_add:tunnelbroker.SendRequest.blobHashes)
+ // @@protoc_insertion_point(field_add:tunnelbroker.OutboundMessage.blobHashes)
}
-inline void SendRequest::add_blobhashes(const char* value) {
+inline void OutboundMessage::add_blobhashes(const char* value) {
GOOGLE_DCHECK(value != nullptr);
blobhashes_.Add()->assign(value);
- // @@protoc_insertion_point(field_add_char:tunnelbroker.SendRequest.blobHashes)
+ // @@protoc_insertion_point(field_add_char:tunnelbroker.OutboundMessage.blobHashes)
}
-inline void SendRequest::add_blobhashes(const char* value, size_t size) {
+inline void OutboundMessage::add_blobhashes(const char* value, size_t size) {
blobhashes_.Add()->assign(reinterpret_cast<const char*>(value), size);
- // @@protoc_insertion_point(field_add_pointer:tunnelbroker.SendRequest.blobHashes)
+ // @@protoc_insertion_point(field_add_pointer:tunnelbroker.OutboundMessage.blobHashes)
}
inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>&
-SendRequest::blobhashes() const {
- // @@protoc_insertion_point(field_list:tunnelbroker.SendRequest.blobHashes)
+OutboundMessage::blobhashes() const {
+ // @@protoc_insertion_point(field_list:tunnelbroker.OutboundMessage.blobHashes)
return blobhashes_;
}
inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>*
-SendRequest::mutable_blobhashes() {
- // @@protoc_insertion_point(field_mutable_list:tunnelbroker.SendRequest.blobHashes)
+OutboundMessage::mutable_blobhashes() {
+ // @@protoc_insertion_point(field_mutable_list:tunnelbroker.OutboundMessage.blobHashes)
return &blobhashes_;
}
// -------------------------------------------------------------------
-// GetRequest
+// InboundMessage
-// string sessionID = 1;
-inline void GetRequest::clear_sessionid() {
- sessionid_.ClearToEmpty();
+// string fromDeviceID = 1;
+inline void InboundMessage::clear_fromdeviceid() {
+ fromdeviceid_.ClearToEmpty();
}
-inline const std::string& GetRequest::sessionid() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.GetRequest.sessionID)
- return _internal_sessionid();
+inline const std::string& InboundMessage::fromdeviceid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.InboundMessage.fromDeviceID)
+ return _internal_fromdeviceid();
}
-inline void GetRequest::set_sessionid(const std::string& value) {
- _internal_set_sessionid(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.GetRequest.sessionID)
+inline void InboundMessage::set_fromdeviceid(const std::string& value) {
+ _internal_set_fromdeviceid(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.InboundMessage.fromDeviceID)
}
-inline std::string* GetRequest::mutable_sessionid() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.GetRequest.sessionID)
- return _internal_mutable_sessionid();
+inline std::string* InboundMessage::mutable_fromdeviceid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.InboundMessage.fromDeviceID)
+ return _internal_mutable_fromdeviceid();
}
-inline const std::string& GetRequest::_internal_sessionid() const {
- return sessionid_.Get();
+inline const std::string& InboundMessage::_internal_fromdeviceid() const {
+ return fromdeviceid_.Get();
}
-inline void GetRequest::_internal_set_sessionid(const std::string& value) {
+inline void InboundMessage::_internal_set_fromdeviceid(const std::string& value) {
- sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+ fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void GetRequest::set_sessionid(std::string&& value) {
+inline void InboundMessage::set_fromdeviceid(std::string&& value) {
- sessionid_.Set(
+ fromdeviceid_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetRequest.sessionID)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.InboundMessage.fromDeviceID)
}
-inline void GetRequest::set_sessionid(const char* value) {
+inline void InboundMessage::set_fromdeviceid(const char* value) {
GOOGLE_DCHECK(value != nullptr);
- sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.GetRequest.sessionID)
+ fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.InboundMessage.fromDeviceID)
}
-inline void GetRequest::set_sessionid(const char* value,
+inline void InboundMessage::set_fromdeviceid(const char* value,
size_t size) {
- sessionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetRequest.sessionID)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.InboundMessage.fromDeviceID)
}
-inline std::string* GetRequest::_internal_mutable_sessionid() {
+inline std::string* InboundMessage::_internal_mutable_fromdeviceid() {
- return sessionid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+ return fromdeviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* GetRequest::release_sessionid() {
- // @@protoc_insertion_point(field_release:tunnelbroker.GetRequest.sessionID)
- return sessionid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* InboundMessage::release_fromdeviceid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.InboundMessage.fromDeviceID)
+ return fromdeviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void GetRequest::set_allocated_sessionid(std::string* sessionid) {
- if (sessionid != nullptr) {
+inline void InboundMessage::set_allocated_fromdeviceid(std::string* fromdeviceid) {
+ if (fromdeviceid != nullptr) {
} else {
}
- sessionid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), sessionid,
+ fromdeviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), fromdeviceid,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetRequest.sessionID)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.InboundMessage.fromDeviceID)
}
-// -------------------------------------------------------------------
-
-// GetResponse
-
-// string fromDeviceID = 1;
-inline void GetResponse::clear_fromdeviceid() {
- fromdeviceid_.ClearToEmpty();
+// string fromConnectionID = 2;
+inline void InboundMessage::clear_fromconnectionid() {
+ fromconnectionid_.ClearToEmpty();
}
-inline const std::string& GetResponse::fromdeviceid() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.fromDeviceID)
- return _internal_fromdeviceid();
+inline const std::string& InboundMessage::fromconnectionid() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.InboundMessage.fromConnectionID)
+ return _internal_fromconnectionid();
}
-inline void GetResponse::set_fromdeviceid(const std::string& value) {
- _internal_set_fromdeviceid(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.fromDeviceID)
+inline void InboundMessage::set_fromconnectionid(const std::string& value) {
+ _internal_set_fromconnectionid(value);
+ // @@protoc_insertion_point(field_set:tunnelbroker.InboundMessage.fromConnectionID)
}
-inline std::string* GetResponse::mutable_fromdeviceid() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.fromDeviceID)
- return _internal_mutable_fromdeviceid();
+inline std::string* InboundMessage::mutable_fromconnectionid() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.InboundMessage.fromConnectionID)
+ return _internal_mutable_fromconnectionid();
}
-inline const std::string& GetResponse::_internal_fromdeviceid() const {
- return fromdeviceid_.Get();
+inline const std::string& InboundMessage::_internal_fromconnectionid() const {
+ return fromconnectionid_.Get();
}
-inline void GetResponse::_internal_set_fromdeviceid(const std::string& value) {
+inline void InboundMessage::_internal_set_fromconnectionid(const std::string& value) {
- fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
+ fromconnectionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void GetResponse::set_fromdeviceid(std::string&& value) {
+inline void InboundMessage::set_fromconnectionid(std::string&& value) {
- fromdeviceid_.Set(
+ fromconnectionid_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetResponse.fromDeviceID)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.InboundMessage.fromConnectionID)
}
-inline void GetResponse::set_fromdeviceid(const char* value) {
+inline void InboundMessage::set_fromconnectionid(const char* value) {
GOOGLE_DCHECK(value != nullptr);
- fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponse.fromDeviceID)
+ fromconnectionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.InboundMessage.fromConnectionID)
}
-inline void GetResponse::set_fromdeviceid(const char* value,
+inline void InboundMessage::set_fromconnectionid(const char* value,
size_t size) {
- fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
+ fromconnectionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponse.fromDeviceID)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.InboundMessage.fromConnectionID)
}
-inline std::string* GetResponse::_internal_mutable_fromdeviceid() {
+inline std::string* InboundMessage::_internal_mutable_fromconnectionid() {
- return fromdeviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
+ return fromconnectionid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* GetResponse::release_fromdeviceid() {
- // @@protoc_insertion_point(field_release:tunnelbroker.GetResponse.fromDeviceID)
- return fromdeviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+inline std::string* InboundMessage::release_fromconnectionid() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.InboundMessage.fromConnectionID)
+ return fromconnectionid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void GetResponse::set_allocated_fromdeviceid(std::string* fromdeviceid) {
- if (fromdeviceid != nullptr) {
+inline void InboundMessage::set_allocated_fromconnectionid(std::string* fromconnectionid) {
+ if (fromconnectionid != nullptr) {
} else {
}
- fromdeviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), fromdeviceid,
+ fromconnectionid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), fromconnectionid,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponse.fromDeviceID)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.InboundMessage.fromConnectionID)
}
-// bytes payload = 2;
-inline void GetResponse::clear_payload() {
+// string payload = 3;
+inline void InboundMessage::clear_payload() {
payload_.ClearToEmpty();
}
-inline const std::string& GetResponse::payload() const {
- // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.payload)
+inline const std::string& InboundMessage::payload() const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.InboundMessage.payload)
return _internal_payload();
}
-inline void GetResponse::set_payload(const std::string& value) {
+inline void InboundMessage::set_payload(const std::string& value) {
_internal_set_payload(value);
- // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.payload)
+ // @@protoc_insertion_point(field_set:tunnelbroker.InboundMessage.payload)
}
-inline std::string* GetResponse::mutable_payload() {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.payload)
+inline std::string* InboundMessage::mutable_payload() {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.InboundMessage.payload)
return _internal_mutable_payload();
}
-inline const std::string& GetResponse::_internal_payload() const {
+inline const std::string& InboundMessage::_internal_payload() const {
return payload_.Get();
}
-inline void GetResponse::_internal_set_payload(const std::string& value) {
+inline void InboundMessage::_internal_set_payload(const std::string& value) {
payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena());
}
-inline void GetResponse::set_payload(std::string&& value) {
+inline void InboundMessage::set_payload(std::string&& value) {
payload_.Set(
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena());
- // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetResponse.payload)
+ // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.InboundMessage.payload)
}
-inline void GetResponse::set_payload(const char* value) {
+inline void InboundMessage::set_payload(const char* value) {
GOOGLE_DCHECK(value != nullptr);
payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena());
- // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponse.payload)
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.InboundMessage.payload)
}
-inline void GetResponse::set_payload(const void* value,
+inline void InboundMessage::set_payload(const char* value,
size_t size) {
payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(
reinterpret_cast<const char*>(value), size), GetArena());
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponse.payload)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.InboundMessage.payload)
}
-inline std::string* GetResponse::_internal_mutable_payload() {
+inline std::string* InboundMessage::_internal_mutable_payload() {
return payload_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena());
}
-inline std::string* GetResponse::release_payload() {
- // @@protoc_insertion_point(field_release:tunnelbroker.GetResponse.payload)
+inline std::string* InboundMessage::release_payload() {
+ // @@protoc_insertion_point(field_release:tunnelbroker.InboundMessage.payload)
return payload_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
}
-inline void GetResponse::set_allocated_payload(std::string* payload) {
+inline void InboundMessage::set_allocated_payload(std::string* payload) {
if (payload != nullptr) {
} else {
@@ -3228,80 +4091,80 @@
}
payload_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), payload,
GetArena());
- // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponse.payload)
+ // @@protoc_insertion_point(field_set_allocated:tunnelbroker.InboundMessage.payload)
}
-// repeated string blobHashes = 3;
-inline int GetResponse::_internal_blobhashes_size() const {
+// repeated string blobHashes = 4;
+inline int InboundMessage::_internal_blobhashes_size() const {
return blobhashes_.size();
}
-inline int GetResponse::blobhashes_size() const {
+inline int InboundMessage::blobhashes_size() const {
return _internal_blobhashes_size();
}
-inline void GetResponse::clear_blobhashes() {
+inline void InboundMessage::clear_blobhashes() {
blobhashes_.Clear();
}
-inline std::string* GetResponse::add_blobhashes() {
- // @@protoc_insertion_point(field_add_mutable:tunnelbroker.GetResponse.blobHashes)
+inline std::string* InboundMessage::add_blobhashes() {
+ // @@protoc_insertion_point(field_add_mutable:tunnelbroker.InboundMessage.blobHashes)
return _internal_add_blobhashes();
}
-inline const std::string& GetResponse::_internal_blobhashes(int index) const {
+inline const std::string& InboundMessage::_internal_blobhashes(int index) const {
return blobhashes_.Get(index);
}
-inline const std::string& GetResponse::blobhashes(int index) const {
- // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.blobHashes)
+inline const std::string& InboundMessage::blobhashes(int index) const {
+ // @@protoc_insertion_point(field_get:tunnelbroker.InboundMessage.blobHashes)
return _internal_blobhashes(index);
}
-inline std::string* GetResponse::mutable_blobhashes(int index) {
- // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.blobHashes)
+inline std::string* InboundMessage::mutable_blobhashes(int index) {
+ // @@protoc_insertion_point(field_mutable:tunnelbroker.InboundMessage.blobHashes)
return blobhashes_.Mutable(index);
}
-inline void GetResponse::set_blobhashes(int index, const std::string& value) {
- // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.blobHashes)
+inline void InboundMessage::set_blobhashes(int index, const std::string& value) {
+ // @@protoc_insertion_point(field_set:tunnelbroker.InboundMessage.blobHashes)
blobhashes_.Mutable(index)->assign(value);
}
-inline void GetResponse::set_blobhashes(int index, std::string&& value) {
- // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.blobHashes)
+inline void InboundMessage::set_blobhashes(int index, std::string&& value) {
+ // @@protoc_insertion_point(field_set:tunnelbroker.InboundMessage.blobHashes)
blobhashes_.Mutable(index)->assign(std::move(value));
}
-inline void GetResponse::set_blobhashes(int index, const char* value) {
+inline void InboundMessage::set_blobhashes(int index, const char* value) {
GOOGLE_DCHECK(value != nullptr);
blobhashes_.Mutable(index)->assign(value);
- // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponse.blobHashes)
+ // @@protoc_insertion_point(field_set_char:tunnelbroker.InboundMessage.blobHashes)
}
-inline void GetResponse::set_blobhashes(int index, const char* value, size_t size) {
+inline void InboundMessage::set_blobhashes(int index, const char* value, size_t size) {
blobhashes_.Mutable(index)->assign(
reinterpret_cast<const char*>(value), size);
- // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponse.blobHashes)
+ // @@protoc_insertion_point(field_set_pointer:tunnelbroker.InboundMessage.blobHashes)
}
-inline std::string* GetResponse::_internal_add_blobhashes() {
+inline std::string* InboundMessage::_internal_add_blobhashes() {
return blobhashes_.Add();
}
-inline void GetResponse::add_blobhashes(const std::string& value) {
+inline void InboundMessage::add_blobhashes(const std::string& value) {
blobhashes_.Add()->assign(value);
- // @@protoc_insertion_point(field_add:tunnelbroker.GetResponse.blobHashes)
+ // @@protoc_insertion_point(field_add:tunnelbroker.InboundMessage.blobHashes)
}
-inline void GetResponse::add_blobhashes(std::string&& value) {
+inline void InboundMessage::add_blobhashes(std::string&& value) {
blobhashes_.Add(std::move(value));
- // @@protoc_insertion_point(field_add:tunnelbroker.GetResponse.blobHashes)
+ // @@protoc_insertion_point(field_add:tunnelbroker.InboundMessage.blobHashes)
}
-inline void GetResponse::add_blobhashes(const char* value) {
+inline void InboundMessage::add_blobhashes(const char* value) {
GOOGLE_DCHECK(value != nullptr);
blobhashes_.Add()->assign(value);
- // @@protoc_insertion_point(field_add_char:tunnelbroker.GetResponse.blobHashes)
+ // @@protoc_insertion_point(field_add_char:tunnelbroker.InboundMessage.blobHashes)
}
-inline void GetResponse::add_blobhashes(const char* value, size_t size) {
+inline void InboundMessage::add_blobhashes(const char* value, size_t size) {
blobhashes_.Add()->assign(reinterpret_cast<const char*>(value), size);
- // @@protoc_insertion_point(field_add_pointer:tunnelbroker.GetResponse.blobHashes)
+ // @@protoc_insertion_point(field_add_pointer:tunnelbroker.InboundMessage.blobHashes)
}
inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>&
-GetResponse::blobhashes() const {
- // @@protoc_insertion_point(field_list:tunnelbroker.GetResponse.blobHashes)
+InboundMessage::blobhashes() const {
+ // @@protoc_insertion_point(field_list:tunnelbroker.InboundMessage.blobHashes)
return blobhashes_;
}
inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>*
-GetResponse::mutable_blobhashes() {
- // @@protoc_insertion_point(field_mutable_list:tunnelbroker.GetResponse.blobHashes)
+InboundMessage::mutable_blobhashes() {
+ // @@protoc_insertion_point(field_mutable_list:tunnelbroker.InboundMessage.blobHashes)
return &blobhashes_;
}
@@ -3756,6 +4619,10 @@
// -------------------------------------------------------------------
+// -------------------------------------------------------------------
+
+// -------------------------------------------------------------------
+
// @@protoc_insertion_point(namespace_scope)
diff --git a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.pb.cc b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.pb.cc
--- a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.pb.cc
+++ b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.pb.cc
@@ -113,6 +113,35 @@
};
};
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT GetResponseDefaultTypeInternal _GetResponse_default_instance_;
+constexpr OutboundMessage::OutboundMessage(
+ ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
+ : blobhashes_()
+ , todeviceid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string)
+ , payload_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string){}
+struct OutboundMessageDefaultTypeInternal {
+ constexpr OutboundMessageDefaultTypeInternal()
+ : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {}
+ ~OutboundMessageDefaultTypeInternal() {}
+ union {
+ OutboundMessage _instance;
+ };
+};
+PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT OutboundMessageDefaultTypeInternal _OutboundMessage_default_instance_;
+constexpr InboundMessage::InboundMessage(
+ ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
+ : blobhashes_()
+ , fromdeviceid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string)
+ , fromconnectionid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string)
+ , payload_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string){}
+struct InboundMessageDefaultTypeInternal {
+ constexpr InboundMessageDefaultTypeInternal()
+ : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {}
+ ~InboundMessageDefaultTypeInternal() {}
+ union {
+ InboundMessage _instance;
+ };
+};
+PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT InboundMessageDefaultTypeInternal _InboundMessage_default_instance_;
constexpr CheckRequest::CheckRequest(
::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
: userid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string)
@@ -178,7 +207,7 @@
};
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PongRequestDefaultTypeInternal _PongRequest_default_instance_;
} // namespace tunnelbroker
-static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_tunnelbroker_2eproto[12];
+static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_tunnelbroker_2eproto[14];
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* file_level_enum_descriptors_tunnelbroker_2eproto[2];
static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_tunnelbroker_2eproto = nullptr;
@@ -244,6 +273,23 @@
PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponse, payload_),
PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponse, blobhashes_),
~0u, // no _has_bits_
+ PROTOBUF_FIELD_OFFSET(::tunnelbroker::OutboundMessage, _internal_metadata_),
+ ~0u, // no _extensions_
+ ~0u, // no _oneof_case_
+ ~0u, // no _weak_field_map_
+ PROTOBUF_FIELD_OFFSET(::tunnelbroker::OutboundMessage, todeviceid_),
+ PROTOBUF_FIELD_OFFSET(::tunnelbroker::OutboundMessage, payload_),
+ PROTOBUF_FIELD_OFFSET(::tunnelbroker::OutboundMessage, blobhashes_),
+ ~0u, // no _has_bits_
+ PROTOBUF_FIELD_OFFSET(::tunnelbroker::InboundMessage, _internal_metadata_),
+ ~0u, // no _extensions_
+ ~0u, // no _oneof_case_
+ ~0u, // no _weak_field_map_
+ PROTOBUF_FIELD_OFFSET(::tunnelbroker::InboundMessage, fromdeviceid_),
+ PROTOBUF_FIELD_OFFSET(::tunnelbroker::InboundMessage, fromconnectionid_),
+ PROTOBUF_FIELD_OFFSET(::tunnelbroker::InboundMessage, payload_),
+ PROTOBUF_FIELD_OFFSET(::tunnelbroker::InboundMessage, blobhashes_),
+ ~0u, // no _has_bits_
PROTOBUF_FIELD_OFFSET(::tunnelbroker::CheckRequest, _internal_metadata_),
~0u, // no _extensions_
~0u, // no _oneof_case_
@@ -285,11 +331,13 @@
{ 37, -1, sizeof(::tunnelbroker::SendRequest)},
{ 46, -1, sizeof(::tunnelbroker::GetRequest)},
{ 52, -1, sizeof(::tunnelbroker::GetResponse)},
- { 60, -1, sizeof(::tunnelbroker::CheckRequest)},
- { 67, -1, sizeof(::tunnelbroker::CheckResponse)},
- { 73, -1, sizeof(::tunnelbroker::NewPrimaryRequest)},
- { 80, -1, sizeof(::tunnelbroker::NewPrimaryResponse)},
- { 86, -1, sizeof(::tunnelbroker::PongRequest)},
+ { 60, -1, sizeof(::tunnelbroker::OutboundMessage)},
+ { 68, -1, sizeof(::tunnelbroker::InboundMessage)},
+ { 77, -1, sizeof(::tunnelbroker::CheckRequest)},
+ { 84, -1, sizeof(::tunnelbroker::CheckResponse)},
+ { 90, -1, sizeof(::tunnelbroker::NewPrimaryRequest)},
+ { 97, -1, sizeof(::tunnelbroker::NewPrimaryResponse)},
+ { 103, -1, sizeof(::tunnelbroker::PongRequest)},
};
static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = {
@@ -300,6 +348,8 @@
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tunnelbroker::_SendRequest_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tunnelbroker::_GetRequest_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tunnelbroker::_GetResponse_default_instance_),
+ reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tunnelbroker::_OutboundMessage_default_instance_),
+ reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tunnelbroker::_InboundMessage_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tunnelbroker::_CheckRequest_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tunnelbroker::_CheckResponse_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tunnelbroker::_NewPrimaryRequest_default_instance_),
@@ -313,7 +363,7 @@
"ureRequest\022\020\n\010deviceID\030\001 \001(\t\"*\n\030SessionS"
"ignatureResponse\022\016\n\006toSign\030\001 \001(\t\"\225\002\n\021New"
"SessionRequest\022\020\n\010deviceID\030\001 \001(\t\022\021\n\tpubl"
- "icKey\030\002 \001(\014\022\021\n\tsignature\030\003 \001(\t\022\030\n\013notify"
+ "icKey\030\002 \001(\t\022\021\n\tsignature\030\003 \001(\t\022\030\n\013notify"
"Token\030\004 \001(\tH\000\210\001\001\022\?\n\ndeviceType\030\005 \001(\0162+.t"
"unnelbroker.NewSessionRequest.DeviceType"
"s\022\030\n\020deviceAppVersion\030\006 \001(\t\022\020\n\010deviceOS\030"
@@ -324,40 +374,46 @@
"D\030\002 \001(\t\022\017\n\007payload\030\003 \001(\014\022\022\n\nblobHashes\030\004"
" \003(\t\"\037\n\nGetRequest\022\021\n\tsessionID\030\001 \001(\t\"H\n"
"\013GetResponse\022\024\n\014fromDeviceID\030\001 \001(\t\022\017\n\007pa"
- "yload\030\002 \001(\014\022\022\n\nblobHashes\030\003 \003(\t\"3\n\014Check"
- "Request\022\016\n\006userId\030\001 \001(\t\022\023\n\013deviceToken\030\002"
- " \001(\t\"K\n\rCheckResponse\022:\n\021checkResponseTy"
- "pe\030\001 \001(\0162\037.tunnelbroker.CheckResponseTyp"
- "e\"8\n\021NewPrimaryRequest\022\016\n\006userId\030\001 \001(\t\022\023"
- "\n\013deviceToken\030\002 \001(\t\"%\n\022NewPrimaryRespons"
- "e\022\017\n\007success\030\001 \001(\010\"2\n\013PongRequest\022\016\n\006use"
- "rId\030\001 \001(\t\022\023\n\013deviceToken\030\002 \001(\t*n\n\021CheckR"
- "esponseType\022\030\n\024PRIMARY_DOESNT_EXIST\020\000\022\022\n"
- "\016PRIMARY_ONLINE\020\001\022\023\n\017PRIMARY_OFFLINE\020\002\022\026"
- "\n\022CURRENT_IS_PRIMARY\020\0032\303\004\n\023TunnelbrokerS"
- "ervice\022W\n\032CheckIfPrimaryDeviceOnline\022\032.t"
- "unnelbroker.CheckRequest\032\033.tunnelbroker."
- "CheckResponse\"\000\022]\n\026BecomeNewPrimaryDevic"
- "e\022\037.tunnelbroker.NewPrimaryRequest\032 .tun"
- "nelbroker.NewPrimaryResponse\"\000\022\?\n\010SendPo"
- "ng\022\031.tunnelbroker.PongRequest\032\026.google.p"
- "rotobuf.Empty\"\000\022c\n\020SessionSignature\022%.tu"
- "nnelbroker.SessionSignatureRequest\032&.tun"
- "nelbroker.SessionSignatureResponse\"\000\022Q\n\n"
- "NewSession\022\037.tunnelbroker.NewSessionRequ"
- "est\032 .tunnelbroker.NewSessionResponse\"\000\022"
- ";\n\004Send\022\031.tunnelbroker.SendRequest\032\026.goo"
- "gle.protobuf.Empty\"\000\022>\n\003Get\022\030.tunnelbrok"
- "er.GetRequest\032\031.tunnelbroker.GetResponse"
- "\"\0000\001b\006proto3"
+ "yload\030\002 \001(\014\022\022\n\nblobHashes\030\003 \003(\t\"J\n\017Outbo"
+ "undMessage\022\022\n\ntoDeviceID\030\001 \001(\t\022\017\n\007payloa"
+ "d\030\002 \001(\t\022\022\n\nblobHashes\030\003 \003(\t\"e\n\016InboundMe"
+ "ssage\022\024\n\014fromDeviceID\030\001 \001(\t\022\030\n\020fromConne"
+ "ctionID\030\002 \001(\t\022\017\n\007payload\030\003 \001(\t\022\022\n\nblobHa"
+ "shes\030\004 \003(\t\"3\n\014CheckRequest\022\016\n\006userId\030\001 \001"
+ "(\t\022\023\n\013deviceToken\030\002 \001(\t\"K\n\rCheckResponse"
+ "\022:\n\021checkResponseType\030\001 \001(\0162\037.tunnelbrok"
+ "er.CheckResponseType\"8\n\021NewPrimaryReques"
+ "t\022\016\n\006userId\030\001 \001(\t\022\023\n\013deviceToken\030\002 \001(\t\"%"
+ "\n\022NewPrimaryResponse\022\017\n\007success\030\001 \001(\010\"2\n"
+ "\013PongRequest\022\016\n\006userId\030\001 \001(\t\022\023\n\013deviceTo"
+ "ken\030\002 \001(\t*n\n\021CheckResponseType\022\030\n\024PRIMAR"
+ "Y_DOESNT_EXIST\020\000\022\022\n\016PRIMARY_ONLINE\020\001\022\023\n\017"
+ "PRIMARY_OFFLINE\020\002\022\026\n\022CURRENT_IS_PRIMARY\020"
+ "\0032\224\005\n\023TunnelbrokerService\022W\n\032CheckIfPrim"
+ "aryDeviceOnline\022\032.tunnelbroker.CheckRequ"
+ "est\032\033.tunnelbroker.CheckResponse\"\000\022]\n\026Be"
+ "comeNewPrimaryDevice\022\037.tunnelbroker.NewP"
+ "rimaryRequest\032 .tunnelbroker.NewPrimaryR"
+ "esponse\"\000\022\?\n\010SendPong\022\031.tunnelbroker.Pon"
+ "gRequest\032\026.google.protobuf.Empty\"\000\022c\n\020Se"
+ "ssionSignature\022%.tunnelbroker.SessionSig"
+ "natureRequest\032&.tunnelbroker.SessionSign"
+ "atureResponse\"\000\022Q\n\nNewSession\022\037.tunnelbr"
+ "oker.NewSessionRequest\032 .tunnelbroker.Ne"
+ "wSessionResponse\"\000\022;\n\004Send\022\031.tunnelbroke"
+ "r.SendRequest\032\026.google.protobuf.Empty\"\000\022"
+ ">\n\003Get\022\030.tunnelbroker.GetRequest\032\031.tunne"
+ "lbroker.GetResponse\"\0000\001\022O\n\nOpenStream\022\035."
+ "tunnelbroker.OutboundMessage\032\034.tunnelbro"
+ "ker.InboundMessage\"\000(\0010\001b\006proto3"
;
static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_tunnelbroker_2eproto_deps[1] = {
&::descriptor_table_google_2fprotobuf_2fempty_2eproto,
};
static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_tunnelbroker_2eproto_once;
const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_tunnelbroker_2eproto = {
- false, false, 1652, descriptor_table_protodef_tunnelbroker_2eproto, "tunnelbroker.proto",
- &descriptor_table_tunnelbroker_2eproto_once, descriptor_table_tunnelbroker_2eproto_deps, 1, 12,
+ false, false, 1912, descriptor_table_protodef_tunnelbroker_2eproto, "tunnelbroker.proto",
+ &descriptor_table_tunnelbroker_2eproto_once, descriptor_table_tunnelbroker_2eproto_deps, 1, 14,
schemas, file_default_instances, TableStruct_tunnelbroker_2eproto::offsets,
file_level_metadata_tunnelbroker_2eproto, file_level_enum_descriptors_tunnelbroker_2eproto, file_level_service_descriptors_tunnelbroker_2eproto,
};
@@ -937,11 +993,12 @@
CHK_(ptr);
} else goto handle_unusual;
continue;
- // bytes publicKey = 2;
+ // string publicKey = 2;
case 2:
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) {
auto str = _internal_mutable_publickey();
ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
+ CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.NewSessionRequest.publicKey"));
CHK_(ptr);
} else goto handle_unusual;
continue;
@@ -1028,9 +1085,13 @@
1, this->_internal_deviceid(), target);
}
- // bytes publicKey = 2;
+ // string publicKey = 2;
if (this->publickey().size() > 0) {
- target = stream->WriteBytesMaybeAliased(
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+ this->_internal_publickey().data(), static_cast<int>(this->_internal_publickey().length()),
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+ "tunnelbroker.NewSessionRequest.publicKey");
+ target = stream->WriteStringMaybeAliased(
2, this->_internal_publickey(), target);
}
@@ -1104,10 +1165,10 @@
this->_internal_deviceid());
}
- // bytes publicKey = 2;
+ // string publicKey = 2;
if (this->publickey().size() > 0) {
total_size += 1 +
- ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize(
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
this->_internal_publickey());
}
@@ -2214,6 +2275,594 @@
}
+// ===================================================================
+
+class OutboundMessage::_Internal {
+ public:
+};
+
+OutboundMessage::OutboundMessage(::PROTOBUF_NAMESPACE_ID::Arena* arena)
+ : ::PROTOBUF_NAMESPACE_ID::Message(arena),
+ blobhashes_(arena) {
+ SharedCtor();
+ RegisterArenaDtor(arena);
+ // @@protoc_insertion_point(arena_constructor:tunnelbroker.OutboundMessage)
+}
+OutboundMessage::OutboundMessage(const OutboundMessage& from)
+ : ::PROTOBUF_NAMESPACE_ID::Message(),
+ blobhashes_(from.blobhashes_) {
+ _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+ todeviceid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+ if (!from._internal_todeviceid().empty()) {
+ todeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_todeviceid(),
+ GetArena());
+ }
+ payload_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+ if (!from._internal_payload().empty()) {
+ payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_payload(),
+ GetArena());
+ }
+ // @@protoc_insertion_point(copy_constructor:tunnelbroker.OutboundMessage)
+}
+
+void OutboundMessage::SharedCtor() {
+todeviceid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+payload_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+}
+
+OutboundMessage::~OutboundMessage() {
+ // @@protoc_insertion_point(destructor:tunnelbroker.OutboundMessage)
+ SharedDtor();
+ _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
+}
+
+void OutboundMessage::SharedDtor() {
+ GOOGLE_DCHECK(GetArena() == nullptr);
+ todeviceid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+ payload_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+}
+
+void OutboundMessage::ArenaDtor(void* object) {
+ OutboundMessage* _this = reinterpret_cast< OutboundMessage* >(object);
+ (void)_this;
+}
+void OutboundMessage::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) {
+}
+void OutboundMessage::SetCachedSize(int size) const {
+ _cached_size_.Set(size);
+}
+
+void OutboundMessage::Clear() {
+// @@protoc_insertion_point(message_clear_start:tunnelbroker.OutboundMessage)
+ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
+ // Prevent compiler warnings about cached_has_bits being unused
+ (void) cached_has_bits;
+
+ blobhashes_.Clear();
+ todeviceid_.ClearToEmpty();
+ payload_.ClearToEmpty();
+ _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
+}
+
+const char* OutboundMessage::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) {
+#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
+ while (!ctx->Done(&ptr)) {
+ ::PROTOBUF_NAMESPACE_ID::uint32 tag;
+ ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag);
+ CHK_(ptr);
+ switch (tag >> 3) {
+ // string toDeviceID = 1;
+ case 1:
+ if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
+ auto str = _internal_mutable_todeviceid();
+ ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
+ CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.OutboundMessage.toDeviceID"));
+ CHK_(ptr);
+ } else goto handle_unusual;
+ continue;
+ // string payload = 2;
+ case 2:
+ if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) {
+ auto str = _internal_mutable_payload();
+ ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
+ CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.OutboundMessage.payload"));
+ CHK_(ptr);
+ } else goto handle_unusual;
+ continue;
+ // repeated string blobHashes = 3;
+ case 3:
+ if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) {
+ ptr -= 1;
+ do {
+ ptr += 1;
+ auto str = _internal_add_blobhashes();
+ ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
+ CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.OutboundMessage.blobHashes"));
+ CHK_(ptr);
+ if (!ctx->DataAvailable(ptr)) break;
+ } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<26>(ptr));
+ } else goto handle_unusual;
+ continue;
+ default: {
+ handle_unusual:
+ if ((tag & 7) == 4 || tag == 0) {
+ ctx->SetLastTag(tag);
+ goto success;
+ }
+ ptr = UnknownFieldParse(tag,
+ _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
+ ptr, ctx);
+ CHK_(ptr != nullptr);
+ continue;
+ }
+ } // switch
+ } // while
+success:
+ return ptr;
+failure:
+ ptr = nullptr;
+ goto success;
+#undef CHK_
+}
+
+::PROTOBUF_NAMESPACE_ID::uint8* OutboundMessage::_InternalSerialize(
+ ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
+ // @@protoc_insertion_point(serialize_to_array_start:tunnelbroker.OutboundMessage)
+ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
+ (void) cached_has_bits;
+
+ // string toDeviceID = 1;
+ if (this->todeviceid().size() > 0) {
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+ this->_internal_todeviceid().data(), static_cast<int>(this->_internal_todeviceid().length()),
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+ "tunnelbroker.OutboundMessage.toDeviceID");
+ target = stream->WriteStringMaybeAliased(
+ 1, this->_internal_todeviceid(), target);
+ }
+
+ // string payload = 2;
+ if (this->payload().size() > 0) {
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+ this->_internal_payload().data(), static_cast<int>(this->_internal_payload().length()),
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+ "tunnelbroker.OutboundMessage.payload");
+ target = stream->WriteStringMaybeAliased(
+ 2, this->_internal_payload(), target);
+ }
+
+ // repeated string blobHashes = 3;
+ for (int i = 0, n = this->_internal_blobhashes_size(); i < n; i++) {
+ const auto& s = this->_internal_blobhashes(i);
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+ s.data(), static_cast<int>(s.length()),
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+ "tunnelbroker.OutboundMessage.blobHashes");
+ target = stream->WriteString(3, s, target);
+ }
+
+ if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
+ target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::InternalSerializeUnknownFieldsToArray(
+ _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
+ }
+ // @@protoc_insertion_point(serialize_to_array_end:tunnelbroker.OutboundMessage)
+ return target;
+}
+
+size_t OutboundMessage::ByteSizeLong() const {
+// @@protoc_insertion_point(message_byte_size_start:tunnelbroker.OutboundMessage)
+ size_t total_size = 0;
+
+ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
+ // Prevent compiler warnings about cached_has_bits being unused
+ (void) cached_has_bits;
+
+ // repeated string blobHashes = 3;
+ total_size += 1 *
+ ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(blobhashes_.size());
+ for (int i = 0, n = blobhashes_.size(); i < n; i++) {
+ total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
+ blobhashes_.Get(i));
+ }
+
+ // string toDeviceID = 1;
+ if (this->todeviceid().size() > 0) {
+ total_size += 1 +
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
+ this->_internal_todeviceid());
+ }
+
+ // string payload = 2;
+ if (this->payload().size() > 0) {
+ total_size += 1 +
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
+ this->_internal_payload());
+ }
+
+ if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
+ return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize(
+ _internal_metadata_, total_size, &_cached_size_);
+ }
+ int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
+ SetCachedSize(cached_size);
+ return total_size;
+}
+
+void OutboundMessage::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
+// @@protoc_insertion_point(generalized_merge_from_start:tunnelbroker.OutboundMessage)
+ GOOGLE_DCHECK_NE(&from, this);
+ const OutboundMessage* source =
+ ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated<OutboundMessage>(
+ &from);
+ if (source == nullptr) {
+ // @@protoc_insertion_point(generalized_merge_from_cast_fail:tunnelbroker.OutboundMessage)
+ ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this);
+ } else {
+ // @@protoc_insertion_point(generalized_merge_from_cast_success:tunnelbroker.OutboundMessage)
+ MergeFrom(*source);
+ }
+}
+
+void OutboundMessage::MergeFrom(const OutboundMessage& from) {
+// @@protoc_insertion_point(class_specific_merge_from_start:tunnelbroker.OutboundMessage)
+ GOOGLE_DCHECK_NE(&from, this);
+ _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
+ (void) cached_has_bits;
+
+ blobhashes_.MergeFrom(from.blobhashes_);
+ if (from.todeviceid().size() > 0) {
+ _internal_set_todeviceid(from._internal_todeviceid());
+ }
+ if (from.payload().size() > 0) {
+ _internal_set_payload(from._internal_payload());
+ }
+}
+
+void OutboundMessage::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
+// @@protoc_insertion_point(generalized_copy_from_start:tunnelbroker.OutboundMessage)
+ if (&from == this) return;
+ Clear();
+ MergeFrom(from);
+}
+
+void OutboundMessage::CopyFrom(const OutboundMessage& from) {
+// @@protoc_insertion_point(class_specific_copy_from_start:tunnelbroker.OutboundMessage)
+ if (&from == this) return;
+ Clear();
+ MergeFrom(from);
+}
+
+bool OutboundMessage::IsInitialized() const {
+ return true;
+}
+
+void OutboundMessage::InternalSwap(OutboundMessage* other) {
+ using std::swap;
+ _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_);
+ blobhashes_.InternalSwap(&other->blobhashes_);
+ todeviceid_.Swap(&other->todeviceid_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+ payload_.Swap(&other->payload_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+
+::PROTOBUF_NAMESPACE_ID::Metadata OutboundMessage::GetMetadata() const {
+ return GetMetadataStatic();
+}
+
+
+// ===================================================================
+
+class InboundMessage::_Internal {
+ public:
+};
+
+InboundMessage::InboundMessage(::PROTOBUF_NAMESPACE_ID::Arena* arena)
+ : ::PROTOBUF_NAMESPACE_ID::Message(arena),
+ blobhashes_(arena) {
+ SharedCtor();
+ RegisterArenaDtor(arena);
+ // @@protoc_insertion_point(arena_constructor:tunnelbroker.InboundMessage)
+}
+InboundMessage::InboundMessage(const InboundMessage& from)
+ : ::PROTOBUF_NAMESPACE_ID::Message(),
+ blobhashes_(from.blobhashes_) {
+ _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+ fromdeviceid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+ if (!from._internal_fromdeviceid().empty()) {
+ fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_fromdeviceid(),
+ GetArena());
+ }
+ fromconnectionid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+ if (!from._internal_fromconnectionid().empty()) {
+ fromconnectionid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_fromconnectionid(),
+ GetArena());
+ }
+ payload_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+ if (!from._internal_payload().empty()) {
+ payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_payload(),
+ GetArena());
+ }
+ // @@protoc_insertion_point(copy_constructor:tunnelbroker.InboundMessage)
+}
+
+void InboundMessage::SharedCtor() {
+fromdeviceid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+fromconnectionid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+payload_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+}
+
+InboundMessage::~InboundMessage() {
+ // @@protoc_insertion_point(destructor:tunnelbroker.InboundMessage)
+ SharedDtor();
+ _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
+}
+
+void InboundMessage::SharedDtor() {
+ GOOGLE_DCHECK(GetArena() == nullptr);
+ fromdeviceid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+ fromconnectionid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+ payload_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
+}
+
+void InboundMessage::ArenaDtor(void* object) {
+ InboundMessage* _this = reinterpret_cast< InboundMessage* >(object);
+ (void)_this;
+}
+void InboundMessage::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) {
+}
+void InboundMessage::SetCachedSize(int size) const {
+ _cached_size_.Set(size);
+}
+
+void InboundMessage::Clear() {
+// @@protoc_insertion_point(message_clear_start:tunnelbroker.InboundMessage)
+ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
+ // Prevent compiler warnings about cached_has_bits being unused
+ (void) cached_has_bits;
+
+ blobhashes_.Clear();
+ fromdeviceid_.ClearToEmpty();
+ fromconnectionid_.ClearToEmpty();
+ payload_.ClearToEmpty();
+ _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
+}
+
+const char* InboundMessage::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) {
+#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
+ while (!ctx->Done(&ptr)) {
+ ::PROTOBUF_NAMESPACE_ID::uint32 tag;
+ ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag);
+ CHK_(ptr);
+ switch (tag >> 3) {
+ // string fromDeviceID = 1;
+ case 1:
+ if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
+ auto str = _internal_mutable_fromdeviceid();
+ ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
+ CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.InboundMessage.fromDeviceID"));
+ CHK_(ptr);
+ } else goto handle_unusual;
+ continue;
+ // string fromConnectionID = 2;
+ case 2:
+ if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) {
+ auto str = _internal_mutable_fromconnectionid();
+ ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
+ CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.InboundMessage.fromConnectionID"));
+ CHK_(ptr);
+ } else goto handle_unusual;
+ continue;
+ // string payload = 3;
+ case 3:
+ if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) {
+ auto str = _internal_mutable_payload();
+ ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
+ CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.InboundMessage.payload"));
+ CHK_(ptr);
+ } else goto handle_unusual;
+ continue;
+ // repeated string blobHashes = 4;
+ case 4:
+ if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 34)) {
+ ptr -= 1;
+ do {
+ ptr += 1;
+ auto str = _internal_add_blobhashes();
+ ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
+ CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.InboundMessage.blobHashes"));
+ CHK_(ptr);
+ if (!ctx->DataAvailable(ptr)) break;
+ } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<34>(ptr));
+ } else goto handle_unusual;
+ continue;
+ default: {
+ handle_unusual:
+ if ((tag & 7) == 4 || tag == 0) {
+ ctx->SetLastTag(tag);
+ goto success;
+ }
+ ptr = UnknownFieldParse(tag,
+ _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
+ ptr, ctx);
+ CHK_(ptr != nullptr);
+ continue;
+ }
+ } // switch
+ } // while
+success:
+ return ptr;
+failure:
+ ptr = nullptr;
+ goto success;
+#undef CHK_
+}
+
+::PROTOBUF_NAMESPACE_ID::uint8* InboundMessage::_InternalSerialize(
+ ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
+ // @@protoc_insertion_point(serialize_to_array_start:tunnelbroker.InboundMessage)
+ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
+ (void) cached_has_bits;
+
+ // string fromDeviceID = 1;
+ if (this->fromdeviceid().size() > 0) {
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+ this->_internal_fromdeviceid().data(), static_cast<int>(this->_internal_fromdeviceid().length()),
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+ "tunnelbroker.InboundMessage.fromDeviceID");
+ target = stream->WriteStringMaybeAliased(
+ 1, this->_internal_fromdeviceid(), target);
+ }
+
+ // string fromConnectionID = 2;
+ if (this->fromconnectionid().size() > 0) {
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+ this->_internal_fromconnectionid().data(), static_cast<int>(this->_internal_fromconnectionid().length()),
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+ "tunnelbroker.InboundMessage.fromConnectionID");
+ target = stream->WriteStringMaybeAliased(
+ 2, this->_internal_fromconnectionid(), target);
+ }
+
+ // string payload = 3;
+ if (this->payload().size() > 0) {
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+ this->_internal_payload().data(), static_cast<int>(this->_internal_payload().length()),
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+ "tunnelbroker.InboundMessage.payload");
+ target = stream->WriteStringMaybeAliased(
+ 3, this->_internal_payload(), target);
+ }
+
+ // repeated string blobHashes = 4;
+ for (int i = 0, n = this->_internal_blobhashes_size(); i < n; i++) {
+ const auto& s = this->_internal_blobhashes(i);
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+ s.data(), static_cast<int>(s.length()),
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+ "tunnelbroker.InboundMessage.blobHashes");
+ target = stream->WriteString(4, s, target);
+ }
+
+ if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
+ target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::InternalSerializeUnknownFieldsToArray(
+ _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
+ }
+ // @@protoc_insertion_point(serialize_to_array_end:tunnelbroker.InboundMessage)
+ return target;
+}
+
+size_t InboundMessage::ByteSizeLong() const {
+// @@protoc_insertion_point(message_byte_size_start:tunnelbroker.InboundMessage)
+ size_t total_size = 0;
+
+ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
+ // Prevent compiler warnings about cached_has_bits being unused
+ (void) cached_has_bits;
+
+ // repeated string blobHashes = 4;
+ total_size += 1 *
+ ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(blobhashes_.size());
+ for (int i = 0, n = blobhashes_.size(); i < n; i++) {
+ total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
+ blobhashes_.Get(i));
+ }
+
+ // string fromDeviceID = 1;
+ if (this->fromdeviceid().size() > 0) {
+ total_size += 1 +
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
+ this->_internal_fromdeviceid());
+ }
+
+ // string fromConnectionID = 2;
+ if (this->fromconnectionid().size() > 0) {
+ total_size += 1 +
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
+ this->_internal_fromconnectionid());
+ }
+
+ // string payload = 3;
+ if (this->payload().size() > 0) {
+ total_size += 1 +
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
+ this->_internal_payload());
+ }
+
+ if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
+ return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize(
+ _internal_metadata_, total_size, &_cached_size_);
+ }
+ int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
+ SetCachedSize(cached_size);
+ return total_size;
+}
+
+void InboundMessage::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
+// @@protoc_insertion_point(generalized_merge_from_start:tunnelbroker.InboundMessage)
+ GOOGLE_DCHECK_NE(&from, this);
+ const InboundMessage* source =
+ ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated<InboundMessage>(
+ &from);
+ if (source == nullptr) {
+ // @@protoc_insertion_point(generalized_merge_from_cast_fail:tunnelbroker.InboundMessage)
+ ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this);
+ } else {
+ // @@protoc_insertion_point(generalized_merge_from_cast_success:tunnelbroker.InboundMessage)
+ MergeFrom(*source);
+ }
+}
+
+void InboundMessage::MergeFrom(const InboundMessage& from) {
+// @@protoc_insertion_point(class_specific_merge_from_start:tunnelbroker.InboundMessage)
+ GOOGLE_DCHECK_NE(&from, this);
+ _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
+ (void) cached_has_bits;
+
+ blobhashes_.MergeFrom(from.blobhashes_);
+ if (from.fromdeviceid().size() > 0) {
+ _internal_set_fromdeviceid(from._internal_fromdeviceid());
+ }
+ if (from.fromconnectionid().size() > 0) {
+ _internal_set_fromconnectionid(from._internal_fromconnectionid());
+ }
+ if (from.payload().size() > 0) {
+ _internal_set_payload(from._internal_payload());
+ }
+}
+
+void InboundMessage::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
+// @@protoc_insertion_point(generalized_copy_from_start:tunnelbroker.InboundMessage)
+ if (&from == this) return;
+ Clear();
+ MergeFrom(from);
+}
+
+void InboundMessage::CopyFrom(const InboundMessage& from) {
+// @@protoc_insertion_point(class_specific_copy_from_start:tunnelbroker.InboundMessage)
+ if (&from == this) return;
+ Clear();
+ MergeFrom(from);
+}
+
+bool InboundMessage::IsInitialized() const {
+ return true;
+}
+
+void InboundMessage::InternalSwap(InboundMessage* other) {
+ using std::swap;
+ _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_);
+ blobhashes_.InternalSwap(&other->blobhashes_);
+ fromdeviceid_.Swap(&other->fromdeviceid_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+ fromconnectionid_.Swap(&other->fromconnectionid_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+ payload_.Swap(&other->payload_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
+}
+
+::PROTOBUF_NAMESPACE_ID::Metadata InboundMessage::GetMetadata() const {
+ return GetMetadataStatic();
+}
+
+
// ===================================================================
class CheckRequest::_Internal {
@@ -3329,6 +3978,12 @@
template<> PROTOBUF_NOINLINE ::tunnelbroker::GetResponse* Arena::CreateMaybeMessage< ::tunnelbroker::GetResponse >(Arena* arena) {
return Arena::CreateMessageInternal< ::tunnelbroker::GetResponse >(arena);
}
+template<> PROTOBUF_NOINLINE ::tunnelbroker::OutboundMessage* Arena::CreateMaybeMessage< ::tunnelbroker::OutboundMessage >(Arena* arena) {
+ return Arena::CreateMessageInternal< ::tunnelbroker::OutboundMessage >(arena);
+}
+template<> PROTOBUF_NOINLINE ::tunnelbroker::InboundMessage* Arena::CreateMaybeMessage< ::tunnelbroker::InboundMessage >(Arena* arena) {
+ return Arena::CreateMessageInternal< ::tunnelbroker::InboundMessage >(arena);
+}
template<> PROTOBUF_NOINLINE ::tunnelbroker::CheckRequest* Arena::CreateMaybeMessage< ::tunnelbroker::CheckRequest >(Arena* arena) {
return Arena::CreateMessageInternal< ::tunnelbroker::CheckRequest >(arena);
}

File Metadata

Mime Type
text/plain
Expires
Sun, Oct 6, 1:08 PM (21 h, 21 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2249778
Default Alt Text
D3238.diff (214 KB)

Event Timeline