Skip to content
Snippets Groups Projects
Commit 76dd9a55 authored by Tim Übelhör's avatar Tim Übelhör
Browse files

Split the setvalues rpc calls. 

Restructured values messages.
parent 3441164b
Branches
No related tags found
No related merge requests found
Expand all Show whitespace changes
Inline Side-by-side
ModeliRpc.proto
+ 57
− 16
View file @ 76dd9a55
......@@ -22,7 +22,10 @@ service ModeliBackend {
rpc RemoveChannelLink (RemoveChannelLinkRequest) returns (RemoveChannelLinkResponse);
// Transfer settable channel values
rpc SetValues (SetValuesReqest) returns (SetValuesResponse);
rpc SetInt (SetIntRequest) returns (SetIntResponse);
rpc SetReal (SetRealRequest) returns (SetRealResponse);
rpc SetBool (SetBoolRequest) returns (SetBoolResponse);
rpc SetString (SetStringRequest) returns (SetStringResponse);
// Stream simulation results to the client
rpc NewValues (NewValuesRequest) returns (stream NewValuesResponse);
......@@ -41,16 +44,23 @@ enum Fmi2Status {
}
// Contains values from and for the fmu
message Values {
string instance_name = 1;
repeated uint32 int_vrs = 2;
repeated int32 int_values = 3;
repeated uint32 real_vrs = 4;
repeated double real_values = 5;
repeated uint32 bool_vrs = 6;
repeated int32 bool_values = 7; // fmi2Bool = int32 (0 = false, 1 = true)
repeated uint32 string_vrs = 8;
repeated string string_values = 9;
message IntValues {
repeated uint32 valueRefs = 1;
repeated int32 values = 2;
}
message RealValues {
repeated uint32 valueRefs = 1;
repeated double values = 2;
}
message BoolValues {
repeated uint32 valueRefs = 1;
repeated int32 values = 2; // Fmi2 standard encodes bools as int (1: true, 0: false)
}
message StringValues {
repeated uint32 valueRefs = 1;
repeated string values = 2;
}
// The metadata of a ChannelLink
......@@ -121,19 +131,50 @@ message RemoveChannelLinkResponse {
bool success = 1;
}
message SetValuesReqest {
Values values = 1;
message SetIntRequest {
string instance_name = 1;
IntValues values = 2;
}
message SetIntResponse {
Fmi2Status status = 1;
}
message SetRealRequest {
string instance_name = 1;
RealValues values = 2;
}
message SetRealResponse {
Fmi2Status status = 1;
}
message SetBoolRequest {
string instance_name = 1;
BoolValues values = 2;
}
message SetBoolResponse {
Fmi2Status status = 1;
}
message SetStringRequest {
string instance_name = 1;
StringValues values = 2;
}
message SetValuesResponse {
message SetStringResponse {
Fmi2Status status = 1;
}
message NewValuesRequest {}
message NewValuesResponse {
Values values = 1;
double timestamp = 2;
double timestamp = 1;
IntValues intValues = 2;
RealValues realValues = 3;
BoolValues boolValues = 4;
StringValues stringValues = 5;
}
message LogRequest {}
......
ModeliRpc_Cpp/ModeliRpc.grpc.pb.cc
+ 92
− 14
View file @ 76dd9a55
......@@ -24,7 +24,10 @@ static const char* ModeliBackend_method_names[] = {
"/ModeliRpc.ModeliBackend/RemoveFmu",
"/ModeliRpc.ModeliBackend/AddChannelLink",
"/ModeliRpc.ModeliBackend/RemoveChannelLink",
"/ModeliRpc.ModeliBackend/SetValues",
"/ModeliRpc.ModeliBackend/SetInt",
"/ModeliRpc.ModeliBackend/SetReal",
"/ModeliRpc.ModeliBackend/SetBool",
"/ModeliRpc.ModeliBackend/SetString",
"/ModeliRpc.ModeliBackend/NewValues",
"/ModeliRpc.ModeliBackend/Log",
};
......@@ -44,9 +47,12 @@ ModeliBackend::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& chan
, rpcmethod_RemoveFmu_(ModeliBackend_method_names[5], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_AddChannelLink_(ModeliBackend_method_names[6], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_RemoveChannelLink_(ModeliBackend_method_names[7], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SetValues_(ModeliBackend_method_names[8], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_NewValues_(ModeliBackend_method_names[9], ::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_Log_(ModeliBackend_method_names[10], ::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_SetInt_(ModeliBackend_method_names[8], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SetReal_(ModeliBackend_method_names[9], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SetBool_(ModeliBackend_method_names[10], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SetString_(ModeliBackend_method_names[11], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_NewValues_(ModeliBackend_method_names[12], ::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_Log_(ModeliBackend_method_names[13], ::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
{}
::grpc::Status ModeliBackend::Stub::Play(::grpc::ClientContext* context, const ::ModeliRpc::PlayRequest& request, ::ModeliRpc::PlayResponse* response) {
......@@ -145,16 +151,52 @@ ModeliBackend::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& chan
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::RemoveChannelLinkResponse>::Create(channel_.get(), cq, rpcmethod_RemoveChannelLink_, context, request, false);
}
::grpc::Status ModeliBackend::Stub::SetValues(::grpc::ClientContext* context, const ::ModeliRpc::SetValuesReqest& request, ::ModeliRpc::SetValuesResponse* response) {
return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_SetValues_, context, request, response);
::grpc::Status ModeliBackend::Stub::SetInt(::grpc::ClientContext* context, const ::ModeliRpc::SetIntRequest& request, ::ModeliRpc::SetIntResponse* response) {
return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_SetInt_, context, request, response);
}
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetValuesResponse>* ModeliBackend::Stub::AsyncSetValuesRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetValuesReqest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetValuesResponse>::Create(channel_.get(), cq, rpcmethod_SetValues_, context, request, true);
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetIntResponse>* ModeliBackend::Stub::AsyncSetIntRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetIntRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetIntResponse>::Create(channel_.get(), cq, rpcmethod_SetInt_, context, request, true);
}
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetValuesResponse>* ModeliBackend::Stub::PrepareAsyncSetValuesRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetValuesReqest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetValuesResponse>::Create(channel_.get(), cq, rpcmethod_SetValues_, context, request, false);
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetIntResponse>* ModeliBackend::Stub::PrepareAsyncSetIntRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetIntRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetIntResponse>::Create(channel_.get(), cq, rpcmethod_SetInt_, context, request, false);
}
::grpc::Status ModeliBackend::Stub::SetReal(::grpc::ClientContext* context, const ::ModeliRpc::SetRealRequest& request, ::ModeliRpc::SetRealResponse* response) {
return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_SetReal_, context, request, response);
}
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetRealResponse>* ModeliBackend::Stub::AsyncSetRealRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetRealRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetRealResponse>::Create(channel_.get(), cq, rpcmethod_SetReal_, context, request, true);
}
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetRealResponse>* ModeliBackend::Stub::PrepareAsyncSetRealRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetRealRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetRealResponse>::Create(channel_.get(), cq, rpcmethod_SetReal_, context, request, false);
}
::grpc::Status ModeliBackend::Stub::SetBool(::grpc::ClientContext* context, const ::ModeliRpc::SetBoolRequest& request, ::ModeliRpc::SetBoolResponse* response) {
return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_SetBool_, context, request, response);
}
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetBoolResponse>* ModeliBackend::Stub::AsyncSetBoolRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetBoolRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetBoolResponse>::Create(channel_.get(), cq, rpcmethod_SetBool_, context, request, true);
}
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetBoolResponse>* ModeliBackend::Stub::PrepareAsyncSetBoolRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetBoolRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetBoolResponse>::Create(channel_.get(), cq, rpcmethod_SetBool_, context, request, false);
}
::grpc::Status ModeliBackend::Stub::SetString(::grpc::ClientContext* context, const ::ModeliRpc::SetStringRequest& request, ::ModeliRpc::SetStringResponse* response) {
return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_SetString_, context, request, response);
}
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetStringResponse>* ModeliBackend::Stub::AsyncSetStringRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetStringRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetStringResponse>::Create(channel_.get(), cq, rpcmethod_SetString_, context, request, true);
}
::grpc::ClientAsyncResponseReader< ::ModeliRpc::SetStringResponse>* ModeliBackend::Stub::PrepareAsyncSetStringRaw(::grpc::ClientContext* context, const ::ModeliRpc::SetStringRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderFactory< ::ModeliRpc::SetStringResponse>::Create(channel_.get(), cq, rpcmethod_SetString_, context, request, false);
}
::grpc::ClientReader< ::ModeliRpc::NewValuesResponse>* ModeliBackend::Stub::NewValuesRaw(::grpc::ClientContext* context, const ::ModeliRpc::NewValuesRequest& request) {
......@@ -225,15 +267,30 @@ ModeliBackend::Service::Service() {
AddMethod(new ::grpc::internal::RpcServiceMethod(
ModeliBackend_method_names[8],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< ModeliBackend::Service, ::ModeliRpc::SetValuesReqest, ::ModeliRpc::SetValuesResponse>(
std::mem_fn(&ModeliBackend::Service::SetValues), this)));
new ::grpc::internal::RpcMethodHandler< ModeliBackend::Service, ::ModeliRpc::SetIntRequest, ::ModeliRpc::SetIntResponse>(
std::mem_fn(&ModeliBackend::Service::SetInt), this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
ModeliBackend_method_names[9],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< ModeliBackend::Service, ::ModeliRpc::SetRealRequest, ::ModeliRpc::SetRealResponse>(
std::mem_fn(&ModeliBackend::Service::SetReal), this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
ModeliBackend_method_names[10],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< ModeliBackend::Service, ::ModeliRpc::SetBoolRequest, ::ModeliRpc::SetBoolResponse>(
std::mem_fn(&ModeliBackend::Service::SetBool), this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
ModeliBackend_method_names[11],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< ModeliBackend::Service, ::ModeliRpc::SetStringRequest, ::ModeliRpc::SetStringResponse>(
std::mem_fn(&ModeliBackend::Service::SetString), this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
ModeliBackend_method_names[12],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< ModeliBackend::Service, ::ModeliRpc::NewValuesRequest, ::ModeliRpc::NewValuesResponse>(
std::mem_fn(&ModeliBackend::Service::NewValues), this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
ModeliBackend_method_names[10],
ModeliBackend_method_names[13],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< ModeliBackend::Service, ::ModeliRpc::LogRequest, ::ModeliRpc::LogResponse>(
std::mem_fn(&ModeliBackend::Service::Log), this)));
......@@ -298,7 +355,28 @@ ModeliBackend::Service::~Service() {
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
}
::grpc::Status ModeliBackend::Service::SetValues(::grpc::ServerContext* context, const ::ModeliRpc::SetValuesReqest* request, ::ModeliRpc::SetValuesResponse* response) {
::grpc::Status ModeliBackend::Service::SetInt(::grpc::ServerContext* context, const ::ModeliRpc::SetIntRequest* request, ::ModeliRpc::SetIntResponse* response) {
(void) context;
(void) request;
(void) response;
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
}
::grpc::Status ModeliBackend::Service::SetReal(::grpc::ServerContext* context, const ::ModeliRpc::SetRealRequest* request, ::ModeliRpc::SetRealResponse* response) {
(void) context;
(void) request;
(void) response;
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
}
::grpc::Status ModeliBackend::Service::SetBool(::grpc::ServerContext* context, const ::ModeliRpc::SetBoolRequest* request, ::ModeliRpc::SetBoolResponse* response) {
(void) context;
(void) request;
(void) response;
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
}
::grpc::Status ModeliBackend::Service::SetString(::grpc::ServerContext* context, const ::ModeliRpc::SetStringRequest* request, ::ModeliRpc::SetStringResponse* response) {
(void) context;
(void) request;
(void) response;
......
ModeliRpc_Cpp/ModeliRpc.grpc.pb.h
+ 273
− 42
View file @ 76dd9a55
This diff is collapsed.
ModeliRpc_Cpp/ModeliRpc.pb.cc
+ 4819
− 2103
View file @ 76dd9a55
This diff is collapsed.
ModeliRpc_Cpp/ModeliRpc.pb.h
+ 2628
− 1065
View file @ 76dd9a55
This diff is collapsed.
ModeliRpc_Cs/ModeliRpc.cs
+ 2018
− 819
View file @ 76dd9a55
This diff is collapsed.
ModeliRpc_Cs/ModeliRpcGrpc.cs
+ 109
− 16
View file @ 76dd9a55
......@@ -37,8 +37,14 @@ namespace ModeliRpc {
static readonly grpc::Marshaller<global::ModeliRpc.AddChannelLinkResponse> __Marshaller_AddChannelLinkResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.AddChannelLinkResponse.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.RemoveChannelLinkRequest> __Marshaller_RemoveChannelLinkRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.RemoveChannelLinkRequest.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.RemoveChannelLinkResponse> __Marshaller_RemoveChannelLinkResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.RemoveChannelLinkResponse.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetValuesReqest> __Marshaller_SetValuesReqest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetValuesReqest.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetValuesResponse> __Marshaller_SetValuesResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetValuesResponse.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetIntRequest> __Marshaller_SetIntRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetIntRequest.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetIntResponse> __Marshaller_SetIntResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetIntResponse.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetRealRequest> __Marshaller_SetRealRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetRealRequest.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetRealResponse> __Marshaller_SetRealResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetRealResponse.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetBoolRequest> __Marshaller_SetBoolRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetBoolRequest.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetBoolResponse> __Marshaller_SetBoolResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetBoolResponse.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetStringRequest> __Marshaller_SetStringRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetStringRequest.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.SetStringResponse> __Marshaller_SetStringResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.SetStringResponse.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.NewValuesRequest> __Marshaller_NewValuesRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.NewValuesRequest.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.NewValuesResponse> __Marshaller_NewValuesResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.NewValuesResponse.Parser.ParseFrom);
static readonly grpc::Marshaller<global::ModeliRpc.LogRequest> __Marshaller_LogRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::ModeliRpc.LogRequest.Parser.ParseFrom);
......@@ -100,12 +106,33 @@ namespace ModeliRpc {
__Marshaller_RemoveChannelLinkRequest,
__Marshaller_RemoveChannelLinkResponse);
static readonly grpc::Method<global::ModeliRpc.SetValuesReqest, global::ModeliRpc.SetValuesResponse> __Method_SetValues = new grpc::Method<global::ModeliRpc.SetValuesReqest, global::ModeliRpc.SetValuesResponse>(
static readonly grpc::Method<global::ModeliRpc.SetIntRequest, global::ModeliRpc.SetIntResponse> __Method_SetInt = new grpc::Method<global::ModeliRpc.SetIntRequest, global::ModeliRpc.SetIntResponse>(
grpc::MethodType.Unary,
__ServiceName,
"SetValues",
__Marshaller_SetValuesReqest,
__Marshaller_SetValuesResponse);
"SetInt",
__Marshaller_SetIntRequest,
__Marshaller_SetIntResponse);
static readonly grpc::Method<global::ModeliRpc.SetRealRequest, global::ModeliRpc.SetRealResponse> __Method_SetReal = new grpc::Method<global::ModeliRpc.SetRealRequest, global::ModeliRpc.SetRealResponse>(
grpc::MethodType.Unary,
__ServiceName,
"SetReal",
__Marshaller_SetRealRequest,
__Marshaller_SetRealResponse);
static readonly grpc::Method<global::ModeliRpc.SetBoolRequest, global::ModeliRpc.SetBoolResponse> __Method_SetBool = new grpc::Method<global::ModeliRpc.SetBoolRequest, global::ModeliRpc.SetBoolResponse>(
grpc::MethodType.Unary,
__ServiceName,
"SetBool",
__Marshaller_SetBoolRequest,
__Marshaller_SetBoolResponse);
static readonly grpc::Method<global::ModeliRpc.SetStringRequest, global::ModeliRpc.SetStringResponse> __Method_SetString = new grpc::Method<global::ModeliRpc.SetStringRequest, global::ModeliRpc.SetStringResponse>(
grpc::MethodType.Unary,
__ServiceName,
"SetString",
__Marshaller_SetStringRequest,
__Marshaller_SetStringResponse);
static readonly grpc::Method<global::ModeliRpc.NewValuesRequest, global::ModeliRpc.NewValuesResponse> __Method_NewValues = new grpc::Method<global::ModeliRpc.NewValuesRequest, global::ModeliRpc.NewValuesResponse>(
grpc::MethodType.ServerStreaming,
......@@ -195,7 +222,22 @@ namespace ModeliRpc {
/// <param name="request">The request received from the client.</param>
/// <param name="context">The context of the server-side call handler being invoked.</param>
/// <returns>The response to send back to the client (wrapped by a task).</returns>
public virtual global::System.Threading.Tasks.Task<global::ModeliRpc.SetValuesResponse> SetValues(global::ModeliRpc.SetValuesReqest request, grpc::ServerCallContext context)
public virtual global::System.Threading.Tasks.Task<global::ModeliRpc.SetIntResponse> SetInt(global::ModeliRpc.SetIntRequest request, grpc::ServerCallContext context)
{
throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
}
public virtual global::System.Threading.Tasks.Task<global::ModeliRpc.SetRealResponse> SetReal(global::ModeliRpc.SetRealRequest request, grpc::ServerCallContext context)
{
throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
}
public virtual global::System.Threading.Tasks.Task<global::ModeliRpc.SetBoolResponse> SetBool(global::ModeliRpc.SetBoolRequest request, grpc::ServerCallContext context)
{
throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
}
public virtual global::System.Threading.Tasks.Task<global::ModeliRpc.SetStringResponse> SetString(global::ModeliRpc.SetStringRequest request, grpc::ServerCallContext context)
{
throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
}
......@@ -447,9 +489,9 @@ namespace ModeliRpc {
/// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param>
/// <param name="cancellationToken">An optional token for canceling the call.</param>
/// <returns>The response received from the server.</returns>
public virtual global::ModeliRpc.SetValuesResponse SetValues(global::ModeliRpc.SetValuesReqest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
public virtual global::ModeliRpc.SetIntResponse SetInt(global::ModeliRpc.SetIntRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
{
return SetValues(request, new grpc::CallOptions(headers, deadline, cancellationToken));
return SetInt(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
/// <summary>
/// Transfer settable channel values
......@@ -457,9 +499,9 @@ namespace ModeliRpc {
/// <param name="request">The request to send to the server.</param>
/// <param name="options">The options for the call.</param>
/// <returns>The response received from the server.</returns>
public virtual global::ModeliRpc.SetValuesResponse SetValues(global::ModeliRpc.SetValuesReqest request, grpc::CallOptions options)
public virtual global::ModeliRpc.SetIntResponse SetInt(global::ModeliRpc.SetIntRequest request, grpc::CallOptions options)
{
return CallInvoker.BlockingUnaryCall(__Method_SetValues, null, options, request);
return CallInvoker.BlockingUnaryCall(__Method_SetInt, null, options, request);
}
/// <summary>
/// Transfer settable channel values
......@@ -469,9 +511,9 @@ namespace ModeliRpc {
/// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param>
/// <param name="cancellationToken">An optional token for canceling the call.</param>
/// <returns>The call object.</returns>
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetValuesResponse> SetValuesAsync(global::ModeliRpc.SetValuesReqest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetIntResponse> SetIntAsync(global::ModeliRpc.SetIntRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
{
return SetValuesAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
return SetIntAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
/// <summary>
/// Transfer settable channel values
......@@ -479,9 +521,57 @@ namespace ModeliRpc {
/// <param name="request">The request to send to the server.</param>
/// <param name="options">The options for the call.</param>
/// <returns>The call object.</returns>
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetValuesResponse> SetValuesAsync(global::ModeliRpc.SetValuesReqest request, grpc::CallOptions options)
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetIntResponse> SetIntAsync(global::ModeliRpc.SetIntRequest request, grpc::CallOptions options)
{
return CallInvoker.AsyncUnaryCall(__Method_SetInt, null, options, request);
}
public virtual global::ModeliRpc.SetRealResponse SetReal(global::ModeliRpc.SetRealRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
{
return SetReal(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
public virtual global::ModeliRpc.SetRealResponse SetReal(global::ModeliRpc.SetRealRequest request, grpc::CallOptions options)
{
return CallInvoker.BlockingUnaryCall(__Method_SetReal, null, options, request);
}
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetRealResponse> SetRealAsync(global::ModeliRpc.SetRealRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
{
return SetRealAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetRealResponse> SetRealAsync(global::ModeliRpc.SetRealRequest request, grpc::CallOptions options)
{
return CallInvoker.AsyncUnaryCall(__Method_SetReal, null, options, request);
}
public virtual global::ModeliRpc.SetBoolResponse SetBool(global::ModeliRpc.SetBoolRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
{
return SetBool(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
public virtual global::ModeliRpc.SetBoolResponse SetBool(global::ModeliRpc.SetBoolRequest request, grpc::CallOptions options)
{
return CallInvoker.BlockingUnaryCall(__Method_SetBool, null, options, request);
}
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetBoolResponse> SetBoolAsync(global::ModeliRpc.SetBoolRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
{
return SetBoolAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetBoolResponse> SetBoolAsync(global::ModeliRpc.SetBoolRequest request, grpc::CallOptions options)
{
return CallInvoker.AsyncUnaryCall(__Method_SetBool, null, options, request);
}
public virtual global::ModeliRpc.SetStringResponse SetString(global::ModeliRpc.SetStringRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
{
return SetString(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
public virtual global::ModeliRpc.SetStringResponse SetString(global::ModeliRpc.SetStringRequest request, grpc::CallOptions options)
{
return CallInvoker.BlockingUnaryCall(__Method_SetString, null, options, request);
}
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetStringResponse> SetStringAsync(global::ModeliRpc.SetStringRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))
{
return SetStringAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
public virtual grpc::AsyncUnaryCall<global::ModeliRpc.SetStringResponse> SetStringAsync(global::ModeliRpc.SetStringRequest request, grpc::CallOptions options)
{
return CallInvoker.AsyncUnaryCall(__Method_SetValues, null, options, request);
return CallInvoker.AsyncUnaryCall(__Method_SetString, null, options, request);
}
/// <summary>
/// Stream simulation results to the client
......@@ -547,7 +637,10 @@ namespace ModeliRpc {
.AddMethod(__Method_RemoveFmu, serviceImpl.RemoveFmu)
.AddMethod(__Method_AddChannelLink, serviceImpl.AddChannelLink)
.AddMethod(__Method_RemoveChannelLink, serviceImpl.RemoveChannelLink)
.AddMethod(__Method_SetValues, serviceImpl.SetValues)
.AddMethod(__Method_SetInt, serviceImpl.SetInt)
.AddMethod(__Method_SetReal, serviceImpl.SetReal)
.AddMethod(__Method_SetBool, serviceImpl.SetBool)
.AddMethod(__Method_SetString, serviceImpl.SetString)
.AddMethod(__Method_NewValues, serviceImpl.NewValues)
.AddMethod(__Method_Log, serviceImpl.Log).Build();
}
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment