// Generated by the protocol buffer compiler. DO NOT EDIT! // source: src/proto/grpc/testing/control.proto #pragma warning disable 1591, 0612, 3021 #region Designer generated code using pb = global::Google.Protobuf; using pbc = global::Google.Protobuf.Collections; using pbr = global::Google.Protobuf.Reflection; using scg = global::System.Collections.Generic; namespace Grpc.Testing { /// Holder for reflection information generated from src/proto/grpc/testing/control.proto [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public static partial class ControlReflection { #region Descriptor /// File descriptor for src/proto/grpc/testing/control.proto public static pbr::FileDescriptor Descriptor { get { return descriptor; } } private static pbr::FileDescriptor descriptor; static ControlReflection() { byte[] descriptorData = global::System.Convert.FromBase64String( string.Concat( "CiRzcmMvcHJvdG8vZ3JwYy90ZXN0aW5nL2NvbnRyb2wucHJvdG8SDGdycGMu", "dGVzdGluZxolc3JjL3Byb3RvL2dycGMvdGVzdGluZy9wYXlsb2Fkcy5wcm90", "bxoic3JjL3Byb3RvL2dycGMvdGVzdGluZy9zdGF0cy5wcm90byIlCg1Qb2lz", "c29uUGFyYW1zEhQKDG9mZmVyZWRfbG9hZBgBIAEoASISChBDbG9zZWRMb29w", "UGFyYW1zInsKCkxvYWRQYXJhbXMSNQoLY2xvc2VkX2xvb3AYASABKAsyHi5n", "cnBjLnRlc3RpbmcuQ2xvc2VkTG9vcFBhcmFtc0gAEi4KB3BvaXNzb24YAiAB", "KAsyGy5ncnBjLnRlc3RpbmcuUG9pc3NvblBhcmFtc0gAQgYKBGxvYWQiQwoO", "U2VjdXJpdHlQYXJhbXMSEwoLdXNlX3Rlc3RfY2EYASABKAgSHAoUc2VydmVy", "X2hvc3Rfb3ZlcnJpZGUYAiABKAki8AMKDENsaWVudENvbmZpZxIWCg5zZXJ2", "ZXJfdGFyZ2V0cxgBIAMoCRItCgtjbGllbnRfdHlwZRgCIAEoDjIYLmdycGMu", "dGVzdGluZy5DbGllbnRUeXBlEjUKD3NlY3VyaXR5X3BhcmFtcxgDIAEoCzIc", "LmdycGMudGVzdGluZy5TZWN1cml0eVBhcmFtcxIkChxvdXRzdGFuZGluZ19y", "cGNzX3Blcl9jaGFubmVsGAQgASgFEhcKD2NsaWVudF9jaGFubmVscxgFIAEo", "BRIcChRhc3luY19jbGllbnRfdGhyZWFkcxgHIAEoBRInCghycGNfdHlwZRgI", "IAEoDjIVLmdycGMudGVzdGluZy5ScGNUeXBlEi0KC2xvYWRfcGFyYW1zGAog", "ASgLMhguZ3JwYy50ZXN0aW5nLkxvYWRQYXJhbXMSMwoOcGF5bG9hZF9jb25m", "aWcYCyABKAsyGy5ncnBjLnRlc3RpbmcuUGF5bG9hZENvbmZpZxI3ChBoaXN0", "b2dyYW1fcGFyYW1zGAwgASgLMh0uZ3JwYy50ZXN0aW5nLkhpc3RvZ3JhbVBh", "cmFtcxIRCgljb3JlX2xpc3QYDSADKAUSEgoKY29yZV9saW1pdBgOIAEoBRIY", "ChBvdGhlcl9jbGllbnRfYXBpGA8gASgJIjgKDENsaWVudFN0YXR1cxIoCgVz", "dGF0cxgBIAEoCzIZLmdycGMudGVzdGluZy5DbGllbnRTdGF0cyIVCgRNYXJr", "Eg0KBXJlc2V0GAEgASgIImgKCkNsaWVudEFyZ3MSKwoFc2V0dXAYASABKAsy", "Gi5ncnBjLnRlc3RpbmcuQ2xpZW50Q29uZmlnSAASIgoEbWFyaxgCIAEoCzIS", "LmdycGMudGVzdGluZy5NYXJrSABCCQoHYXJndHlwZSKWAgoMU2VydmVyQ29u", "ZmlnEi0KC3NlcnZlcl90eXBlGAEgASgOMhguZ3JwYy50ZXN0aW5nLlNlcnZl", "clR5cGUSNQoPc2VjdXJpdHlfcGFyYW1zGAIgASgLMhwuZ3JwYy50ZXN0aW5n", "LlNlY3VyaXR5UGFyYW1zEgwKBHBvcnQYBCABKAUSHAoUYXN5bmNfc2VydmVy", "X3RocmVhZHMYByABKAUSEgoKY29yZV9saW1pdBgIIAEoBRIzCg5wYXlsb2Fk", "X2NvbmZpZxgJIAEoCzIbLmdycGMudGVzdGluZy5QYXlsb2FkQ29uZmlnEhEK", "CWNvcmVfbGlzdBgKIAMoBRIYChBvdGhlcl9zZXJ2ZXJfYXBpGAsgASgJImgK", "ClNlcnZlckFyZ3MSKwoFc2V0dXAYASABKAsyGi5ncnBjLnRlc3RpbmcuU2Vy", "dmVyQ29uZmlnSAASIgoEbWFyaxgCIAEoCzISLmdycGMudGVzdGluZy5NYXJr", "SABCCQoHYXJndHlwZSJVCgxTZXJ2ZXJTdGF0dXMSKAoFc3RhdHMYASABKAsy", "GS5ncnBjLnRlc3RpbmcuU2VydmVyU3RhdHMSDAoEcG9ydBgCIAEoBRINCgVj", "b3JlcxgDIAEoBSINCgtDb3JlUmVxdWVzdCIdCgxDb3JlUmVzcG9uc2USDQoF", "Y29yZXMYASABKAUiBgoEVm9pZCL9AQoIU2NlbmFyaW8SDAoEbmFtZRgBIAEo", "CRIxCg1jbGllbnRfY29uZmlnGAIgASgLMhouZ3JwYy50ZXN0aW5nLkNsaWVu", "dENvbmZpZxITCgtudW1fY2xpZW50cxgDIAEoBRIxCg1zZXJ2ZXJfY29uZmln", "GAQgASgLMhouZ3JwYy50ZXN0aW5nLlNlcnZlckNvbmZpZxITCgtudW1fc2Vy", "dmVycxgFIAEoBRIWCg53YXJtdXBfc2Vjb25kcxgGIAEoBRIZChFiZW5jaG1h", "cmtfc2Vjb25kcxgHIAEoBRIgChhzcGF3bl9sb2NhbF93b3JrZXJfY291bnQY", "CCABKAUiNgoJU2NlbmFyaW9zEikKCXNjZW5hcmlvcxgBIAMoCzIWLmdycGMu", "dGVzdGluZy5TY2VuYXJpbyKSAgoVU2NlbmFyaW9SZXN1bHRTdW1tYXJ5EgsK", "A3FwcxgBIAEoARIbChNxcHNfcGVyX3NlcnZlcl9jb3JlGAIgASgBEhoKEnNl", "cnZlcl9zeXN0ZW1fdGltZRgDIAEoARIYChBzZXJ2ZXJfdXNlcl90aW1lGAQg", "ASgBEhoKEmNsaWVudF9zeXN0ZW1fdGltZRgFIAEoARIYChBjbGllbnRfdXNl", "cl90aW1lGAYgASgBEhIKCmxhdGVuY3lfNTAYByABKAESEgoKbGF0ZW5jeV85", "MBgIIAEoARISCgpsYXRlbmN5Xzk1GAkgASgBEhIKCmxhdGVuY3lfOTkYCiAB", "KAESEwoLbGF0ZW5jeV85OTkYCyABKAEimAIKDlNjZW5hcmlvUmVzdWx0EigK", "CHNjZW5hcmlvGAEgASgLMhYuZ3JwYy50ZXN0aW5nLlNjZW5hcmlvEi4KCWxh", "dGVuY2llcxgCIAEoCzIbLmdycGMudGVzdGluZy5IaXN0b2dyYW1EYXRhEi8K", "DGNsaWVudF9zdGF0cxgDIAMoCzIZLmdycGMudGVzdGluZy5DbGllbnRTdGF0", "cxIvCgxzZXJ2ZXJfc3RhdHMYBCADKAsyGS5ncnBjLnRlc3RpbmcuU2VydmVy", "U3RhdHMSFAoMc2VydmVyX2NvcmVzGAUgAygFEjQKB3N1bW1hcnkYBiABKAsy", "Iy5ncnBjLnRlc3RpbmcuU2NlbmFyaW9SZXN1bHRTdW1tYXJ5KkEKCkNsaWVu", "dFR5cGUSDwoLU1lOQ19DTElFTlQQABIQCgxBU1lOQ19DTElFTlQQARIQCgxP", "VEhFUl9DTElFTlQQAipbCgpTZXJ2ZXJUeXBlEg8KC1NZTkNfU0VSVkVSEAAS", "EAoMQVNZTkNfU0VSVkVSEAESGAoUQVNZTkNfR0VORVJJQ19TRVJWRVIQAhIQ", "CgxPVEhFUl9TRVJWRVIQAyojCgdScGNUeXBlEgkKBVVOQVJZEAASDQoJU1RS", "RUFNSU5HEAFiBnByb3RvMw==")); descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData, new pbr::FileDescriptor[] { global::Grpc.Testing.PayloadsReflection.Descriptor, global::Grpc.Testing.StatsReflection.Descriptor, }, new pbr::GeneratedClrTypeInfo(new[] {typeof(global::Grpc.Testing.ClientType), typeof(global::Grpc.Testing.ServerType), typeof(global::Grpc.Testing.RpcType), }, new pbr::GeneratedClrTypeInfo[] { new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.PoissonParams), global::Grpc.Testing.PoissonParams.Parser, new[]{ "OfferedLoad" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ClosedLoopParams), global::Grpc.Testing.ClosedLoopParams.Parser, null, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.LoadParams), global::Grpc.Testing.LoadParams.Parser, new[]{ "ClosedLoop", "Poisson" }, new[]{ "Load" }, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.SecurityParams), global::Grpc.Testing.SecurityParams.Parser, new[]{ "UseTestCa", "ServerHostOverride" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ClientConfig), global::Grpc.Testing.ClientConfig.Parser, new[]{ "ServerTargets", "ClientType", "SecurityParams", "OutstandingRpcsPerChannel", "ClientChannels", "AsyncClientThreads", "RpcType", "LoadParams", "PayloadConfig", "HistogramParams", "CoreList", "CoreLimit", "OtherClientApi" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ClientStatus), global::Grpc.Testing.ClientStatus.Parser, new[]{ "Stats" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.Mark), global::Grpc.Testing.Mark.Parser, new[]{ "Reset" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ClientArgs), global::Grpc.Testing.ClientArgs.Parser, new[]{ "Setup", "Mark" }, new[]{ "Argtype" }, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ServerConfig), global::Grpc.Testing.ServerConfig.Parser, new[]{ "ServerType", "SecurityParams", "Port", "AsyncServerThreads", "CoreLimit", "PayloadConfig", "CoreList", "OtherServerApi" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ServerArgs), global::Grpc.Testing.ServerArgs.Parser, new[]{ "Setup", "Mark" }, new[]{ "Argtype" }, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ServerStatus), global::Grpc.Testing.ServerStatus.Parser, new[]{ "Stats", "Port", "Cores" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.CoreRequest), global::Grpc.Testing.CoreRequest.Parser, null, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.CoreResponse), global::Grpc.Testing.CoreResponse.Parser, new[]{ "Cores" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.Void), global::Grpc.Testing.Void.Parser, null, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.Scenario), global::Grpc.Testing.Scenario.Parser, new[]{ "Name", "ClientConfig", "NumClients", "ServerConfig", "NumServers", "WarmupSeconds", "BenchmarkSeconds", "SpawnLocalWorkerCount" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.Scenarios), global::Grpc.Testing.Scenarios.Parser, new[]{ "Scenarios_" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ScenarioResultSummary), global::Grpc.Testing.ScenarioResultSummary.Parser, new[]{ "Qps", "QpsPerServerCore", "ServerSystemTime", "ServerUserTime", "ClientSystemTime", "ClientUserTime", "Latency50", "Latency90", "Latency95", "Latency99", "Latency999" }, null, null, null), new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ScenarioResult), global::Grpc.Testing.ScenarioResult.Parser, new[]{ "Scenario", "Latencies", "ClientStats", "ServerStats", "ServerCores", "Summary" }, null, null, null) })); } #endregion } #region Enums public enum ClientType { /// /// Many languages support a basic distinction between using /// sync or async client, and this allows the specification /// [pbr::OriginalName("SYNC_CLIENT")] SyncClient = 0, [pbr::OriginalName("ASYNC_CLIENT")] AsyncClient = 1, /// /// used for some language-specific variants /// [pbr::OriginalName("OTHER_CLIENT")] OtherClient = 2, } public enum ServerType { [pbr::OriginalName("SYNC_SERVER")] SyncServer = 0, [pbr::OriginalName("ASYNC_SERVER")] AsyncServer = 1, [pbr::OriginalName("ASYNC_GENERIC_SERVER")] AsyncGenericServer = 2, /// /// used for some language-specific variants /// [pbr::OriginalName("OTHER_SERVER")] OtherServer = 3, } public enum RpcType { [pbr::OriginalName("UNARY")] Unary = 0, [pbr::OriginalName("STREAMING")] Streaming = 1, } #endregion #region Messages /// /// Parameters of poisson process distribution, which is a good representation /// of activity coming in from independent identical stationary sources. /// [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class PoissonParams : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new PoissonParams()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[0]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public PoissonParams() { OnConstruction(); } partial void OnConstruction(); public PoissonParams(PoissonParams other) : this() { offeredLoad_ = other.offeredLoad_; } public PoissonParams Clone() { return new PoissonParams(this); } /// Field number for the "offered_load" field. public const int OfferedLoadFieldNumber = 1; private double offeredLoad_; /// /// The rate of arrivals (a.k.a. lambda parameter of the exp distribution). /// public double OfferedLoad { get { return offeredLoad_; } set { offeredLoad_ = value; } } public override bool Equals(object other) { return Equals(other as PoissonParams); } public bool Equals(PoissonParams other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (OfferedLoad != other.OfferedLoad) return false; return true; } public override int GetHashCode() { int hash = 1; if (OfferedLoad != 0D) hash ^= OfferedLoad.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (OfferedLoad != 0D) { output.WriteRawTag(9); output.WriteDouble(OfferedLoad); } } public int CalculateSize() { int size = 0; if (OfferedLoad != 0D) { size += 1 + 8; } return size; } public void MergeFrom(PoissonParams other) { if (other == null) { return; } if (other.OfferedLoad != 0D) { OfferedLoad = other.OfferedLoad; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 9: { OfferedLoad = input.ReadDouble(); break; } } } } } /// /// Once an RPC finishes, immediately start a new one. /// No configuration parameters needed. /// [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class ClosedLoopParams : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new ClosedLoopParams()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[1]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public ClosedLoopParams() { OnConstruction(); } partial void OnConstruction(); public ClosedLoopParams(ClosedLoopParams other) : this() { } public ClosedLoopParams Clone() { return new ClosedLoopParams(this); } public override bool Equals(object other) { return Equals(other as ClosedLoopParams); } public bool Equals(ClosedLoopParams other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } return true; } public override int GetHashCode() { int hash = 1; return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { } public int CalculateSize() { int size = 0; return size; } public void MergeFrom(ClosedLoopParams other) { if (other == null) { return; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class LoadParams : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new LoadParams()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[2]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public LoadParams() { OnConstruction(); } partial void OnConstruction(); public LoadParams(LoadParams other) : this() { switch (other.LoadCase) { case LoadOneofCase.ClosedLoop: ClosedLoop = other.ClosedLoop.Clone(); break; case LoadOneofCase.Poisson: Poisson = other.Poisson.Clone(); break; } } public LoadParams Clone() { return new LoadParams(this); } /// Field number for the "closed_loop" field. public const int ClosedLoopFieldNumber = 1; public global::Grpc.Testing.ClosedLoopParams ClosedLoop { get { return loadCase_ == LoadOneofCase.ClosedLoop ? (global::Grpc.Testing.ClosedLoopParams) load_ : null; } set { load_ = value; loadCase_ = value == null ? LoadOneofCase.None : LoadOneofCase.ClosedLoop; } } /// Field number for the "poisson" field. public const int PoissonFieldNumber = 2; public global::Grpc.Testing.PoissonParams Poisson { get { return loadCase_ == LoadOneofCase.Poisson ? (global::Grpc.Testing.PoissonParams) load_ : null; } set { load_ = value; loadCase_ = value == null ? LoadOneofCase.None : LoadOneofCase.Poisson; } } private object load_; /// Enum of possible cases for the "load" oneof. public enum LoadOneofCase { None = 0, ClosedLoop = 1, Poisson = 2, } private LoadOneofCase loadCase_ = LoadOneofCase.None; public LoadOneofCase LoadCase { get { return loadCase_; } } public void ClearLoad() { loadCase_ = LoadOneofCase.None; load_ = null; } public override bool Equals(object other) { return Equals(other as LoadParams); } public bool Equals(LoadParams other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (!object.Equals(ClosedLoop, other.ClosedLoop)) return false; if (!object.Equals(Poisson, other.Poisson)) return false; if (LoadCase != other.LoadCase) return false; return true; } public override int GetHashCode() { int hash = 1; if (loadCase_ == LoadOneofCase.ClosedLoop) hash ^= ClosedLoop.GetHashCode(); if (loadCase_ == LoadOneofCase.Poisson) hash ^= Poisson.GetHashCode(); hash ^= (int) loadCase_; return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (loadCase_ == LoadOneofCase.ClosedLoop) { output.WriteRawTag(10); output.WriteMessage(ClosedLoop); } if (loadCase_ == LoadOneofCase.Poisson) { output.WriteRawTag(18); output.WriteMessage(Poisson); } } public int CalculateSize() { int size = 0; if (loadCase_ == LoadOneofCase.ClosedLoop) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(ClosedLoop); } if (loadCase_ == LoadOneofCase.Poisson) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Poisson); } return size; } public void MergeFrom(LoadParams other) { if (other == null) { return; } switch (other.LoadCase) { case LoadOneofCase.ClosedLoop: ClosedLoop = other.ClosedLoop; break; case LoadOneofCase.Poisson: Poisson = other.Poisson; break; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 10: { global::Grpc.Testing.ClosedLoopParams subBuilder = new global::Grpc.Testing.ClosedLoopParams(); if (loadCase_ == LoadOneofCase.ClosedLoop) { subBuilder.MergeFrom(ClosedLoop); } input.ReadMessage(subBuilder); ClosedLoop = subBuilder; break; } case 18: { global::Grpc.Testing.PoissonParams subBuilder = new global::Grpc.Testing.PoissonParams(); if (loadCase_ == LoadOneofCase.Poisson) { subBuilder.MergeFrom(Poisson); } input.ReadMessage(subBuilder); Poisson = subBuilder; break; } } } } } /// /// presence of SecurityParams implies use of TLS /// [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class SecurityParams : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new SecurityParams()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[3]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public SecurityParams() { OnConstruction(); } partial void OnConstruction(); public SecurityParams(SecurityParams other) : this() { useTestCa_ = other.useTestCa_; serverHostOverride_ = other.serverHostOverride_; } public SecurityParams Clone() { return new SecurityParams(this); } /// Field number for the "use_test_ca" field. public const int UseTestCaFieldNumber = 1; private bool useTestCa_; public bool UseTestCa { get { return useTestCa_; } set { useTestCa_ = value; } } /// Field number for the "server_host_override" field. public const int ServerHostOverrideFieldNumber = 2; private string serverHostOverride_ = ""; public string ServerHostOverride { get { return serverHostOverride_; } set { serverHostOverride_ = pb::ProtoPreconditions.CheckNotNull(value, "value"); } } public override bool Equals(object other) { return Equals(other as SecurityParams); } public bool Equals(SecurityParams other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (UseTestCa != other.UseTestCa) return false; if (ServerHostOverride != other.ServerHostOverride) return false; return true; } public override int GetHashCode() { int hash = 1; if (UseTestCa != false) hash ^= UseTestCa.GetHashCode(); if (ServerHostOverride.Length != 0) hash ^= ServerHostOverride.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (UseTestCa != false) { output.WriteRawTag(8); output.WriteBool(UseTestCa); } if (ServerHostOverride.Length != 0) { output.WriteRawTag(18); output.WriteString(ServerHostOverride); } } public int CalculateSize() { int size = 0; if (UseTestCa != false) { size += 1 + 1; } if (ServerHostOverride.Length != 0) { size += 1 + pb::CodedOutputStream.ComputeStringSize(ServerHostOverride); } return size; } public void MergeFrom(SecurityParams other) { if (other == null) { return; } if (other.UseTestCa != false) { UseTestCa = other.UseTestCa; } if (other.ServerHostOverride.Length != 0) { ServerHostOverride = other.ServerHostOverride; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 8: { UseTestCa = input.ReadBool(); break; } case 18: { ServerHostOverride = input.ReadString(); break; } } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class ClientConfig : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new ClientConfig()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[4]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public ClientConfig() { OnConstruction(); } partial void OnConstruction(); public ClientConfig(ClientConfig other) : this() { serverTargets_ = other.serverTargets_.Clone(); clientType_ = other.clientType_; SecurityParams = other.securityParams_ != null ? other.SecurityParams.Clone() : null; outstandingRpcsPerChannel_ = other.outstandingRpcsPerChannel_; clientChannels_ = other.clientChannels_; asyncClientThreads_ = other.asyncClientThreads_; rpcType_ = other.rpcType_; LoadParams = other.loadParams_ != null ? other.LoadParams.Clone() : null; PayloadConfig = other.payloadConfig_ != null ? other.PayloadConfig.Clone() : null; HistogramParams = other.histogramParams_ != null ? other.HistogramParams.Clone() : null; coreList_ = other.coreList_.Clone(); coreLimit_ = other.coreLimit_; otherClientApi_ = other.otherClientApi_; } public ClientConfig Clone() { return new ClientConfig(this); } /// Field number for the "server_targets" field. public const int ServerTargetsFieldNumber = 1; private static readonly pb::FieldCodec _repeated_serverTargets_codec = pb::FieldCodec.ForString(10); private readonly pbc::RepeatedField serverTargets_ = new pbc::RepeatedField(); /// /// List of targets to connect to. At least one target needs to be specified. /// public pbc::RepeatedField ServerTargets { get { return serverTargets_; } } /// Field number for the "client_type" field. public const int ClientTypeFieldNumber = 2; private global::Grpc.Testing.ClientType clientType_ = 0; public global::Grpc.Testing.ClientType ClientType { get { return clientType_; } set { clientType_ = value; } } /// Field number for the "security_params" field. public const int SecurityParamsFieldNumber = 3; private global::Grpc.Testing.SecurityParams securityParams_; public global::Grpc.Testing.SecurityParams SecurityParams { get { return securityParams_; } set { securityParams_ = value; } } /// Field number for the "outstanding_rpcs_per_channel" field. public const int OutstandingRpcsPerChannelFieldNumber = 4; private int outstandingRpcsPerChannel_; /// /// How many concurrent RPCs to start for each channel. /// For synchronous client, use a separate thread for each outstanding RPC. /// public int OutstandingRpcsPerChannel { get { return outstandingRpcsPerChannel_; } set { outstandingRpcsPerChannel_ = value; } } /// Field number for the "client_channels" field. public const int ClientChannelsFieldNumber = 5; private int clientChannels_; /// /// Number of independent client channels to create. /// i-th channel will connect to server_target[i % server_targets.size()] /// public int ClientChannels { get { return clientChannels_; } set { clientChannels_ = value; } } /// Field number for the "async_client_threads" field. public const int AsyncClientThreadsFieldNumber = 7; private int asyncClientThreads_; /// /// Only for async client. Number of threads to use to start/manage RPCs. /// public int AsyncClientThreads { get { return asyncClientThreads_; } set { asyncClientThreads_ = value; } } /// Field number for the "rpc_type" field. public const int RpcTypeFieldNumber = 8; private global::Grpc.Testing.RpcType rpcType_ = 0; public global::Grpc.Testing.RpcType RpcType { get { return rpcType_; } set { rpcType_ = value; } } /// Field number for the "load_params" field. public const int LoadParamsFieldNumber = 10; private global::Grpc.Testing.LoadParams loadParams_; /// /// The requested load for the entire client (aggregated over all the threads). /// public global::Grpc.Testing.LoadParams LoadParams { get { return loadParams_; } set { loadParams_ = value; } } /// Field number for the "payload_config" field. public const int PayloadConfigFieldNumber = 11; private global::Grpc.Testing.PayloadConfig payloadConfig_; public global::Grpc.Testing.PayloadConfig PayloadConfig { get { return payloadConfig_; } set { payloadConfig_ = value; } } /// Field number for the "histogram_params" field. public const int HistogramParamsFieldNumber = 12; private global::Grpc.Testing.HistogramParams histogramParams_; public global::Grpc.Testing.HistogramParams HistogramParams { get { return histogramParams_; } set { histogramParams_ = value; } } /// Field number for the "core_list" field. public const int CoreListFieldNumber = 13; private static readonly pb::FieldCodec _repeated_coreList_codec = pb::FieldCodec.ForInt32(106); private readonly pbc::RepeatedField coreList_ = new pbc::RepeatedField(); /// /// Specify the cores we should run the client on, if desired /// public pbc::RepeatedField CoreList { get { return coreList_; } } /// Field number for the "core_limit" field. public const int CoreLimitFieldNumber = 14; private int coreLimit_; public int CoreLimit { get { return coreLimit_; } set { coreLimit_ = value; } } /// Field number for the "other_client_api" field. public const int OtherClientApiFieldNumber = 15; private string otherClientApi_ = ""; /// /// If we use an OTHER_CLIENT client_type, this string gives more detail /// public string OtherClientApi { get { return otherClientApi_; } set { otherClientApi_ = pb::ProtoPreconditions.CheckNotNull(value, "value"); } } public override bool Equals(object other) { return Equals(other as ClientConfig); } public bool Equals(ClientConfig other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if(!serverTargets_.Equals(other.serverTargets_)) return false; if (ClientType != other.ClientType) return false; if (!object.Equals(SecurityParams, other.SecurityParams)) return false; if (OutstandingRpcsPerChannel != other.OutstandingRpcsPerChannel) return false; if (ClientChannels != other.ClientChannels) return false; if (AsyncClientThreads != other.AsyncClientThreads) return false; if (RpcType != other.RpcType) return false; if (!object.Equals(LoadParams, other.LoadParams)) return false; if (!object.Equals(PayloadConfig, other.PayloadConfig)) return false; if (!object.Equals(HistogramParams, other.HistogramParams)) return false; if(!coreList_.Equals(other.coreList_)) return false; if (CoreLimit != other.CoreLimit) return false; if (OtherClientApi != other.OtherClientApi) return false; return true; } public override int GetHashCode() { int hash = 1; hash ^= serverTargets_.GetHashCode(); if (ClientType != 0) hash ^= ClientType.GetHashCode(); if (securityParams_ != null) hash ^= SecurityParams.GetHashCode(); if (OutstandingRpcsPerChannel != 0) hash ^= OutstandingRpcsPerChannel.GetHashCode(); if (ClientChannels != 0) hash ^= ClientChannels.GetHashCode(); if (AsyncClientThreads != 0) hash ^= AsyncClientThreads.GetHashCode(); if (RpcType != 0) hash ^= RpcType.GetHashCode(); if (loadParams_ != null) hash ^= LoadParams.GetHashCode(); if (payloadConfig_ != null) hash ^= PayloadConfig.GetHashCode(); if (histogramParams_ != null) hash ^= HistogramParams.GetHashCode(); hash ^= coreList_.GetHashCode(); if (CoreLimit != 0) hash ^= CoreLimit.GetHashCode(); if (OtherClientApi.Length != 0) hash ^= OtherClientApi.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { serverTargets_.WriteTo(output, _repeated_serverTargets_codec); if (ClientType != 0) { output.WriteRawTag(16); output.WriteEnum((int) ClientType); } if (securityParams_ != null) { output.WriteRawTag(26); output.WriteMessage(SecurityParams); } if (OutstandingRpcsPerChannel != 0) { output.WriteRawTag(32); output.WriteInt32(OutstandingRpcsPerChannel); } if (ClientChannels != 0) { output.WriteRawTag(40); output.WriteInt32(ClientChannels); } if (AsyncClientThreads != 0) { output.WriteRawTag(56); output.WriteInt32(AsyncClientThreads); } if (RpcType != 0) { output.WriteRawTag(64); output.WriteEnum((int) RpcType); } if (loadParams_ != null) { output.WriteRawTag(82); output.WriteMessage(LoadParams); } if (payloadConfig_ != null) { output.WriteRawTag(90); output.WriteMessage(PayloadConfig); } if (histogramParams_ != null) { output.WriteRawTag(98); output.WriteMessage(HistogramParams); } coreList_.WriteTo(output, _repeated_coreList_codec); if (CoreLimit != 0) { output.WriteRawTag(112); output.WriteInt32(CoreLimit); } if (OtherClientApi.Length != 0) { output.WriteRawTag(122); output.WriteString(OtherClientApi); } } public int CalculateSize() { int size = 0; size += serverTargets_.CalculateSize(_repeated_serverTargets_codec); if (ClientType != 0) { size += 1 + pb::CodedOutputStream.ComputeEnumSize((int) ClientType); } if (securityParams_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(SecurityParams); } if (OutstandingRpcsPerChannel != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(OutstandingRpcsPerChannel); } if (ClientChannels != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(ClientChannels); } if (AsyncClientThreads != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(AsyncClientThreads); } if (RpcType != 0) { size += 1 + pb::CodedOutputStream.ComputeEnumSize((int) RpcType); } if (loadParams_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(LoadParams); } if (payloadConfig_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(PayloadConfig); } if (histogramParams_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(HistogramParams); } size += coreList_.CalculateSize(_repeated_coreList_codec); if (CoreLimit != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(CoreLimit); } if (OtherClientApi.Length != 0) { size += 1 + pb::CodedOutputStream.ComputeStringSize(OtherClientApi); } return size; } public void MergeFrom(ClientConfig other) { if (other == null) { return; } serverTargets_.Add(other.serverTargets_); if (other.ClientType != 0) { ClientType = other.ClientType; } if (other.securityParams_ != null) { if (securityParams_ == null) { securityParams_ = new global::Grpc.Testing.SecurityParams(); } SecurityParams.MergeFrom(other.SecurityParams); } if (other.OutstandingRpcsPerChannel != 0) { OutstandingRpcsPerChannel = other.OutstandingRpcsPerChannel; } if (other.ClientChannels != 0) { ClientChannels = other.ClientChannels; } if (other.AsyncClientThreads != 0) { AsyncClientThreads = other.AsyncClientThreads; } if (other.RpcType != 0) { RpcType = other.RpcType; } if (other.loadParams_ != null) { if (loadParams_ == null) { loadParams_ = new global::Grpc.Testing.LoadParams(); } LoadParams.MergeFrom(other.LoadParams); } if (other.payloadConfig_ != null) { if (payloadConfig_ == null) { payloadConfig_ = new global::Grpc.Testing.PayloadConfig(); } PayloadConfig.MergeFrom(other.PayloadConfig); } if (other.histogramParams_ != null) { if (histogramParams_ == null) { histogramParams_ = new global::Grpc.Testing.HistogramParams(); } HistogramParams.MergeFrom(other.HistogramParams); } coreList_.Add(other.coreList_); if (other.CoreLimit != 0) { CoreLimit = other.CoreLimit; } if (other.OtherClientApi.Length != 0) { OtherClientApi = other.OtherClientApi; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 10: { serverTargets_.AddEntriesFrom(input, _repeated_serverTargets_codec); break; } case 16: { clientType_ = (global::Grpc.Testing.ClientType) input.ReadEnum(); break; } case 26: { if (securityParams_ == null) { securityParams_ = new global::Grpc.Testing.SecurityParams(); } input.ReadMessage(securityParams_); break; } case 32: { OutstandingRpcsPerChannel = input.ReadInt32(); break; } case 40: { ClientChannels = input.ReadInt32(); break; } case 56: { AsyncClientThreads = input.ReadInt32(); break; } case 64: { rpcType_ = (global::Grpc.Testing.RpcType) input.ReadEnum(); break; } case 82: { if (loadParams_ == null) { loadParams_ = new global::Grpc.Testing.LoadParams(); } input.ReadMessage(loadParams_); break; } case 90: { if (payloadConfig_ == null) { payloadConfig_ = new global::Grpc.Testing.PayloadConfig(); } input.ReadMessage(payloadConfig_); break; } case 98: { if (histogramParams_ == null) { histogramParams_ = new global::Grpc.Testing.HistogramParams(); } input.ReadMessage(histogramParams_); break; } case 106: case 104: { coreList_.AddEntriesFrom(input, _repeated_coreList_codec); break; } case 112: { CoreLimit = input.ReadInt32(); break; } case 122: { OtherClientApi = input.ReadString(); break; } } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class ClientStatus : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new ClientStatus()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[5]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public ClientStatus() { OnConstruction(); } partial void OnConstruction(); public ClientStatus(ClientStatus other) : this() { Stats = other.stats_ != null ? other.Stats.Clone() : null; } public ClientStatus Clone() { return new ClientStatus(this); } /// Field number for the "stats" field. public const int StatsFieldNumber = 1; private global::Grpc.Testing.ClientStats stats_; public global::Grpc.Testing.ClientStats Stats { get { return stats_; } set { stats_ = value; } } public override bool Equals(object other) { return Equals(other as ClientStatus); } public bool Equals(ClientStatus other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (!object.Equals(Stats, other.Stats)) return false; return true; } public override int GetHashCode() { int hash = 1; if (stats_ != null) hash ^= Stats.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (stats_ != null) { output.WriteRawTag(10); output.WriteMessage(Stats); } } public int CalculateSize() { int size = 0; if (stats_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Stats); } return size; } public void MergeFrom(ClientStatus other) { if (other == null) { return; } if (other.stats_ != null) { if (stats_ == null) { stats_ = new global::Grpc.Testing.ClientStats(); } Stats.MergeFrom(other.Stats); } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 10: { if (stats_ == null) { stats_ = new global::Grpc.Testing.ClientStats(); } input.ReadMessage(stats_); break; } } } } } /// /// Request current stats /// [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class Mark : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new Mark()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[6]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public Mark() { OnConstruction(); } partial void OnConstruction(); public Mark(Mark other) : this() { reset_ = other.reset_; } public Mark Clone() { return new Mark(this); } /// Field number for the "reset" field. public const int ResetFieldNumber = 1; private bool reset_; /// /// if true, the stats will be reset after taking their snapshot. /// public bool Reset { get { return reset_; } set { reset_ = value; } } public override bool Equals(object other) { return Equals(other as Mark); } public bool Equals(Mark other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (Reset != other.Reset) return false; return true; } public override int GetHashCode() { int hash = 1; if (Reset != false) hash ^= Reset.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (Reset != false) { output.WriteRawTag(8); output.WriteBool(Reset); } } public int CalculateSize() { int size = 0; if (Reset != false) { size += 1 + 1; } return size; } public void MergeFrom(Mark other) { if (other == null) { return; } if (other.Reset != false) { Reset = other.Reset; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 8: { Reset = input.ReadBool(); break; } } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class ClientArgs : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new ClientArgs()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[7]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public ClientArgs() { OnConstruction(); } partial void OnConstruction(); public ClientArgs(ClientArgs other) : this() { switch (other.ArgtypeCase) { case ArgtypeOneofCase.Setup: Setup = other.Setup.Clone(); break; case ArgtypeOneofCase.Mark: Mark = other.Mark.Clone(); break; } } public ClientArgs Clone() { return new ClientArgs(this); } /// Field number for the "setup" field. public const int SetupFieldNumber = 1; public global::Grpc.Testing.ClientConfig Setup { get { return argtypeCase_ == ArgtypeOneofCase.Setup ? (global::Grpc.Testing.ClientConfig) argtype_ : null; } set { argtype_ = value; argtypeCase_ = value == null ? ArgtypeOneofCase.None : ArgtypeOneofCase.Setup; } } /// Field number for the "mark" field. public const int MarkFieldNumber = 2; public global::Grpc.Testing.Mark Mark { get { return argtypeCase_ == ArgtypeOneofCase.Mark ? (global::Grpc.Testing.Mark) argtype_ : null; } set { argtype_ = value; argtypeCase_ = value == null ? ArgtypeOneofCase.None : ArgtypeOneofCase.Mark; } } private object argtype_; /// Enum of possible cases for the "argtype" oneof. public enum ArgtypeOneofCase { None = 0, Setup = 1, Mark = 2, } private ArgtypeOneofCase argtypeCase_ = ArgtypeOneofCase.None; public ArgtypeOneofCase ArgtypeCase { get { return argtypeCase_; } } public void ClearArgtype() { argtypeCase_ = ArgtypeOneofCase.None; argtype_ = null; } public override bool Equals(object other) { return Equals(other as ClientArgs); } public bool Equals(ClientArgs other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (!object.Equals(Setup, other.Setup)) return false; if (!object.Equals(Mark, other.Mark)) return false; if (ArgtypeCase != other.ArgtypeCase) return false; return true; } public override int GetHashCode() { int hash = 1; if (argtypeCase_ == ArgtypeOneofCase.Setup) hash ^= Setup.GetHashCode(); if (argtypeCase_ == ArgtypeOneofCase.Mark) hash ^= Mark.GetHashCode(); hash ^= (int) argtypeCase_; return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (argtypeCase_ == ArgtypeOneofCase.Setup) { output.WriteRawTag(10); output.WriteMessage(Setup); } if (argtypeCase_ == ArgtypeOneofCase.Mark) { output.WriteRawTag(18); output.WriteMessage(Mark); } } public int CalculateSize() { int size = 0; if (argtypeCase_ == ArgtypeOneofCase.Setup) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Setup); } if (argtypeCase_ == ArgtypeOneofCase.Mark) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Mark); } return size; } public void MergeFrom(ClientArgs other) { if (other == null) { return; } switch (other.ArgtypeCase) { case ArgtypeOneofCase.Setup: Setup = other.Setup; break; case ArgtypeOneofCase.Mark: Mark = other.Mark; break; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 10: { global::Grpc.Testing.ClientConfig subBuilder = new global::Grpc.Testing.ClientConfig(); if (argtypeCase_ == ArgtypeOneofCase.Setup) { subBuilder.MergeFrom(Setup); } input.ReadMessage(subBuilder); Setup = subBuilder; break; } case 18: { global::Grpc.Testing.Mark subBuilder = new global::Grpc.Testing.Mark(); if (argtypeCase_ == ArgtypeOneofCase.Mark) { subBuilder.MergeFrom(Mark); } input.ReadMessage(subBuilder); Mark = subBuilder; break; } } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class ServerConfig : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new ServerConfig()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[8]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public ServerConfig() { OnConstruction(); } partial void OnConstruction(); public ServerConfig(ServerConfig other) : this() { serverType_ = other.serverType_; SecurityParams = other.securityParams_ != null ? other.SecurityParams.Clone() : null; port_ = other.port_; asyncServerThreads_ = other.asyncServerThreads_; coreLimit_ = other.coreLimit_; PayloadConfig = other.payloadConfig_ != null ? other.PayloadConfig.Clone() : null; coreList_ = other.coreList_.Clone(); otherServerApi_ = other.otherServerApi_; } public ServerConfig Clone() { return new ServerConfig(this); } /// Field number for the "server_type" field. public const int ServerTypeFieldNumber = 1; private global::Grpc.Testing.ServerType serverType_ = 0; public global::Grpc.Testing.ServerType ServerType { get { return serverType_; } set { serverType_ = value; } } /// Field number for the "security_params" field. public const int SecurityParamsFieldNumber = 2; private global::Grpc.Testing.SecurityParams securityParams_; public global::Grpc.Testing.SecurityParams SecurityParams { get { return securityParams_; } set { securityParams_ = value; } } /// Field number for the "port" field. public const int PortFieldNumber = 4; private int port_; /// /// Port on which to listen. Zero means pick unused port. /// public int Port { get { return port_; } set { port_ = value; } } /// Field number for the "async_server_threads" field. public const int AsyncServerThreadsFieldNumber = 7; private int asyncServerThreads_; /// /// Only for async server. Number of threads used to serve the requests. /// public int AsyncServerThreads { get { return asyncServerThreads_; } set { asyncServerThreads_ = value; } } /// Field number for the "core_limit" field. public const int CoreLimitFieldNumber = 8; private int coreLimit_; /// /// Specify the number of cores to limit server to, if desired /// public int CoreLimit { get { return coreLimit_; } set { coreLimit_ = value; } } /// Field number for the "payload_config" field. public const int PayloadConfigFieldNumber = 9; private global::Grpc.Testing.PayloadConfig payloadConfig_; /// /// payload config, used in generic server /// public global::Grpc.Testing.PayloadConfig PayloadConfig { get { return payloadConfig_; } set { payloadConfig_ = value; } } /// Field number for the "core_list" field. public const int CoreListFieldNumber = 10; private static readonly pb::FieldCodec _repeated_coreList_codec = pb::FieldCodec.ForInt32(82); private readonly pbc::RepeatedField coreList_ = new pbc::RepeatedField(); /// /// Specify the cores we should run the server on, if desired /// public pbc::RepeatedField CoreList { get { return coreList_; } } /// Field number for the "other_server_api" field. public const int OtherServerApiFieldNumber = 11; private string otherServerApi_ = ""; /// /// If we use an OTHER_SERVER client_type, this string gives more detail /// public string OtherServerApi { get { return otherServerApi_; } set { otherServerApi_ = pb::ProtoPreconditions.CheckNotNull(value, "value"); } } public override bool Equals(object other) { return Equals(other as ServerConfig); } public bool Equals(ServerConfig other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (ServerType != other.ServerType) return false; if (!object.Equals(SecurityParams, other.SecurityParams)) return false; if (Port != other.Port) return false; if (AsyncServerThreads != other.AsyncServerThreads) return false; if (CoreLimit != other.CoreLimit) return false; if (!object.Equals(PayloadConfig, other.PayloadConfig)) return false; if(!coreList_.Equals(other.coreList_)) return false; if (OtherServerApi != other.OtherServerApi) return false; return true; } public override int GetHashCode() { int hash = 1; if (ServerType != 0) hash ^= ServerType.GetHashCode(); if (securityParams_ != null) hash ^= SecurityParams.GetHashCode(); if (Port != 0) hash ^= Port.GetHashCode(); if (AsyncServerThreads != 0) hash ^= AsyncServerThreads.GetHashCode(); if (CoreLimit != 0) hash ^= CoreLimit.GetHashCode(); if (payloadConfig_ != null) hash ^= PayloadConfig.GetHashCode(); hash ^= coreList_.GetHashCode(); if (OtherServerApi.Length != 0) hash ^= OtherServerApi.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (ServerType != 0) { output.WriteRawTag(8); output.WriteEnum((int) ServerType); } if (securityParams_ != null) { output.WriteRawTag(18); output.WriteMessage(SecurityParams); } if (Port != 0) { output.WriteRawTag(32); output.WriteInt32(Port); } if (AsyncServerThreads != 0) { output.WriteRawTag(56); output.WriteInt32(AsyncServerThreads); } if (CoreLimit != 0) { output.WriteRawTag(64); output.WriteInt32(CoreLimit); } if (payloadConfig_ != null) { output.WriteRawTag(74); output.WriteMessage(PayloadConfig); } coreList_.WriteTo(output, _repeated_coreList_codec); if (OtherServerApi.Length != 0) { output.WriteRawTag(90); output.WriteString(OtherServerApi); } } public int CalculateSize() { int size = 0; if (ServerType != 0) { size += 1 + pb::CodedOutputStream.ComputeEnumSize((int) ServerType); } if (securityParams_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(SecurityParams); } if (Port != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(Port); } if (AsyncServerThreads != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(AsyncServerThreads); } if (CoreLimit != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(CoreLimit); } if (payloadConfig_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(PayloadConfig); } size += coreList_.CalculateSize(_repeated_coreList_codec); if (OtherServerApi.Length != 0) { size += 1 + pb::CodedOutputStream.ComputeStringSize(OtherServerApi); } return size; } public void MergeFrom(ServerConfig other) { if (other == null) { return; } if (other.ServerType != 0) { ServerType = other.ServerType; } if (other.securityParams_ != null) { if (securityParams_ == null) { securityParams_ = new global::Grpc.Testing.SecurityParams(); } SecurityParams.MergeFrom(other.SecurityParams); } if (other.Port != 0) { Port = other.Port; } if (other.AsyncServerThreads != 0) { AsyncServerThreads = other.AsyncServerThreads; } if (other.CoreLimit != 0) { CoreLimit = other.CoreLimit; } if (other.payloadConfig_ != null) { if (payloadConfig_ == null) { payloadConfig_ = new global::Grpc.Testing.PayloadConfig(); } PayloadConfig.MergeFrom(other.PayloadConfig); } coreList_.Add(other.coreList_); if (other.OtherServerApi.Length != 0) { OtherServerApi = other.OtherServerApi; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 8: { serverType_ = (global::Grpc.Testing.ServerType) input.ReadEnum(); break; } case 18: { if (securityParams_ == null) { securityParams_ = new global::Grpc.Testing.SecurityParams(); } input.ReadMessage(securityParams_); break; } case 32: { Port = input.ReadInt32(); break; } case 56: { AsyncServerThreads = input.ReadInt32(); break; } case 64: { CoreLimit = input.ReadInt32(); break; } case 74: { if (payloadConfig_ == null) { payloadConfig_ = new global::Grpc.Testing.PayloadConfig(); } input.ReadMessage(payloadConfig_); break; } case 82: case 80: { coreList_.AddEntriesFrom(input, _repeated_coreList_codec); break; } case 90: { OtherServerApi = input.ReadString(); break; } } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class ServerArgs : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new ServerArgs()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[9]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public ServerArgs() { OnConstruction(); } partial void OnConstruction(); public ServerArgs(ServerArgs other) : this() { switch (other.ArgtypeCase) { case ArgtypeOneofCase.Setup: Setup = other.Setup.Clone(); break; case ArgtypeOneofCase.Mark: Mark = other.Mark.Clone(); break; } } public ServerArgs Clone() { return new ServerArgs(this); } /// Field number for the "setup" field. public const int SetupFieldNumber = 1; public global::Grpc.Testing.ServerConfig Setup { get { return argtypeCase_ == ArgtypeOneofCase.Setup ? (global::Grpc.Testing.ServerConfig) argtype_ : null; } set { argtype_ = value; argtypeCase_ = value == null ? ArgtypeOneofCase.None : ArgtypeOneofCase.Setup; } } /// Field number for the "mark" field. public const int MarkFieldNumber = 2; public global::Grpc.Testing.Mark Mark { get { return argtypeCase_ == ArgtypeOneofCase.Mark ? (global::Grpc.Testing.Mark) argtype_ : null; } set { argtype_ = value; argtypeCase_ = value == null ? ArgtypeOneofCase.None : ArgtypeOneofCase.Mark; } } private object argtype_; /// Enum of possible cases for the "argtype" oneof. public enum ArgtypeOneofCase { None = 0, Setup = 1, Mark = 2, } private ArgtypeOneofCase argtypeCase_ = ArgtypeOneofCase.None; public ArgtypeOneofCase ArgtypeCase { get { return argtypeCase_; } } public void ClearArgtype() { argtypeCase_ = ArgtypeOneofCase.None; argtype_ = null; } public override bool Equals(object other) { return Equals(other as ServerArgs); } public bool Equals(ServerArgs other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (!object.Equals(Setup, other.Setup)) return false; if (!object.Equals(Mark, other.Mark)) return false; if (ArgtypeCase != other.ArgtypeCase) return false; return true; } public override int GetHashCode() { int hash = 1; if (argtypeCase_ == ArgtypeOneofCase.Setup) hash ^= Setup.GetHashCode(); if (argtypeCase_ == ArgtypeOneofCase.Mark) hash ^= Mark.GetHashCode(); hash ^= (int) argtypeCase_; return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (argtypeCase_ == ArgtypeOneofCase.Setup) { output.WriteRawTag(10); output.WriteMessage(Setup); } if (argtypeCase_ == ArgtypeOneofCase.Mark) { output.WriteRawTag(18); output.WriteMessage(Mark); } } public int CalculateSize() { int size = 0; if (argtypeCase_ == ArgtypeOneofCase.Setup) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Setup); } if (argtypeCase_ == ArgtypeOneofCase.Mark) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Mark); } return size; } public void MergeFrom(ServerArgs other) { if (other == null) { return; } switch (other.ArgtypeCase) { case ArgtypeOneofCase.Setup: Setup = other.Setup; break; case ArgtypeOneofCase.Mark: Mark = other.Mark; break; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 10: { global::Grpc.Testing.ServerConfig subBuilder = new global::Grpc.Testing.ServerConfig(); if (argtypeCase_ == ArgtypeOneofCase.Setup) { subBuilder.MergeFrom(Setup); } input.ReadMessage(subBuilder); Setup = subBuilder; break; } case 18: { global::Grpc.Testing.Mark subBuilder = new global::Grpc.Testing.Mark(); if (argtypeCase_ == ArgtypeOneofCase.Mark) { subBuilder.MergeFrom(Mark); } input.ReadMessage(subBuilder); Mark = subBuilder; break; } } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class ServerStatus : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new ServerStatus()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[10]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public ServerStatus() { OnConstruction(); } partial void OnConstruction(); public ServerStatus(ServerStatus other) : this() { Stats = other.stats_ != null ? other.Stats.Clone() : null; port_ = other.port_; cores_ = other.cores_; } public ServerStatus Clone() { return new ServerStatus(this); } /// Field number for the "stats" field. public const int StatsFieldNumber = 1; private global::Grpc.Testing.ServerStats stats_; public global::Grpc.Testing.ServerStats Stats { get { return stats_; } set { stats_ = value; } } /// Field number for the "port" field. public const int PortFieldNumber = 2; private int port_; /// /// the port bound by the server /// public int Port { get { return port_; } set { port_ = value; } } /// Field number for the "cores" field. public const int CoresFieldNumber = 3; private int cores_; /// /// Number of cores available to the server /// public int Cores { get { return cores_; } set { cores_ = value; } } public override bool Equals(object other) { return Equals(other as ServerStatus); } public bool Equals(ServerStatus other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (!object.Equals(Stats, other.Stats)) return false; if (Port != other.Port) return false; if (Cores != other.Cores) return false; return true; } public override int GetHashCode() { int hash = 1; if (stats_ != null) hash ^= Stats.GetHashCode(); if (Port != 0) hash ^= Port.GetHashCode(); if (Cores != 0) hash ^= Cores.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (stats_ != null) { output.WriteRawTag(10); output.WriteMessage(Stats); } if (Port != 0) { output.WriteRawTag(16); output.WriteInt32(Port); } if (Cores != 0) { output.WriteRawTag(24); output.WriteInt32(Cores); } } public int CalculateSize() { int size = 0; if (stats_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Stats); } if (Port != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(Port); } if (Cores != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(Cores); } return size; } public void MergeFrom(ServerStatus other) { if (other == null) { return; } if (other.stats_ != null) { if (stats_ == null) { stats_ = new global::Grpc.Testing.ServerStats(); } Stats.MergeFrom(other.Stats); } if (other.Port != 0) { Port = other.Port; } if (other.Cores != 0) { Cores = other.Cores; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 10: { if (stats_ == null) { stats_ = new global::Grpc.Testing.ServerStats(); } input.ReadMessage(stats_); break; } case 16: { Port = input.ReadInt32(); break; } case 24: { Cores = input.ReadInt32(); break; } } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class CoreRequest : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new CoreRequest()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[11]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public CoreRequest() { OnConstruction(); } partial void OnConstruction(); public CoreRequest(CoreRequest other) : this() { } public CoreRequest Clone() { return new CoreRequest(this); } public override bool Equals(object other) { return Equals(other as CoreRequest); } public bool Equals(CoreRequest other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } return true; } public override int GetHashCode() { int hash = 1; return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { } public int CalculateSize() { int size = 0; return size; } public void MergeFrom(CoreRequest other) { if (other == null) { return; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class CoreResponse : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new CoreResponse()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[12]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public CoreResponse() { OnConstruction(); } partial void OnConstruction(); public CoreResponse(CoreResponse other) : this() { cores_ = other.cores_; } public CoreResponse Clone() { return new CoreResponse(this); } /// Field number for the "cores" field. public const int CoresFieldNumber = 1; private int cores_; /// /// Number of cores available on the server /// public int Cores { get { return cores_; } set { cores_ = value; } } public override bool Equals(object other) { return Equals(other as CoreResponse); } public bool Equals(CoreResponse other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (Cores != other.Cores) return false; return true; } public override int GetHashCode() { int hash = 1; if (Cores != 0) hash ^= Cores.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (Cores != 0) { output.WriteRawTag(8); output.WriteInt32(Cores); } } public int CalculateSize() { int size = 0; if (Cores != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(Cores); } return size; } public void MergeFrom(CoreResponse other) { if (other == null) { return; } if (other.Cores != 0) { Cores = other.Cores; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 8: { Cores = input.ReadInt32(); break; } } } } } [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class Void : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new Void()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[13]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public Void() { OnConstruction(); } partial void OnConstruction(); public Void(Void other) : this() { } public Void Clone() { return new Void(this); } public override bool Equals(object other) { return Equals(other as Void); } public bool Equals(Void other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } return true; } public override int GetHashCode() { int hash = 1; return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { } public int CalculateSize() { int size = 0; return size; } public void MergeFrom(Void other) { if (other == null) { return; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; } } } } /// /// A single performance scenario: input to qps_json_driver /// [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class Scenario : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new Scenario()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[14]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public Scenario() { OnConstruction(); } partial void OnConstruction(); public Scenario(Scenario other) : this() { name_ = other.name_; ClientConfig = other.clientConfig_ != null ? other.ClientConfig.Clone() : null; numClients_ = other.numClients_; ServerConfig = other.serverConfig_ != null ? other.ServerConfig.Clone() : null; numServers_ = other.numServers_; warmupSeconds_ = other.warmupSeconds_; benchmarkSeconds_ = other.benchmarkSeconds_; spawnLocalWorkerCount_ = other.spawnLocalWorkerCount_; } public Scenario Clone() { return new Scenario(this); } /// Field number for the "name" field. public const int NameFieldNumber = 1; private string name_ = ""; /// /// Human readable name for this scenario /// public string Name { get { return name_; } set { name_ = pb::ProtoPreconditions.CheckNotNull(value, "value"); } } /// Field number for the "client_config" field. public const int ClientConfigFieldNumber = 2; private global::Grpc.Testing.ClientConfig clientConfig_; /// /// Client configuration /// public global::Grpc.Testing.ClientConfig ClientConfig { get { return clientConfig_; } set { clientConfig_ = value; } } /// Field number for the "num_clients" field. public const int NumClientsFieldNumber = 3; private int numClients_; /// /// Number of clients to start for the test /// public int NumClients { get { return numClients_; } set { numClients_ = value; } } /// Field number for the "server_config" field. public const int ServerConfigFieldNumber = 4; private global::Grpc.Testing.ServerConfig serverConfig_; /// /// Server configuration /// public global::Grpc.Testing.ServerConfig ServerConfig { get { return serverConfig_; } set { serverConfig_ = value; } } /// Field number for the "num_servers" field. public const int NumServersFieldNumber = 5; private int numServers_; /// /// Number of servers to start for the test /// public int NumServers { get { return numServers_; } set { numServers_ = value; } } /// Field number for the "warmup_seconds" field. public const int WarmupSecondsFieldNumber = 6; private int warmupSeconds_; /// /// Warmup period, in seconds /// public int WarmupSeconds { get { return warmupSeconds_; } set { warmupSeconds_ = value; } } /// Field number for the "benchmark_seconds" field. public const int BenchmarkSecondsFieldNumber = 7; private int benchmarkSeconds_; /// /// Benchmark time, in seconds /// public int BenchmarkSeconds { get { return benchmarkSeconds_; } set { benchmarkSeconds_ = value; } } /// Field number for the "spawn_local_worker_count" field. public const int SpawnLocalWorkerCountFieldNumber = 8; private int spawnLocalWorkerCount_; /// /// Number of workers to spawn locally (usually zero) /// public int SpawnLocalWorkerCount { get { return spawnLocalWorkerCount_; } set { spawnLocalWorkerCount_ = value; } } public override bool Equals(object other) { return Equals(other as Scenario); } public bool Equals(Scenario other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (Name != other.Name) return false; if (!object.Equals(ClientConfig, other.ClientConfig)) return false; if (NumClients != other.NumClients) return false; if (!object.Equals(ServerConfig, other.ServerConfig)) return false; if (NumServers != other.NumServers) return false; if (WarmupSeconds != other.WarmupSeconds) return false; if (BenchmarkSeconds != other.BenchmarkSeconds) return false; if (SpawnLocalWorkerCount != other.SpawnLocalWorkerCount) return false; return true; } public override int GetHashCode() { int hash = 1; if (Name.Length != 0) hash ^= Name.GetHashCode(); if (clientConfig_ != null) hash ^= ClientConfig.GetHashCode(); if (NumClients != 0) hash ^= NumClients.GetHashCode(); if (serverConfig_ != null) hash ^= ServerConfig.GetHashCode(); if (NumServers != 0) hash ^= NumServers.GetHashCode(); if (WarmupSeconds != 0) hash ^= WarmupSeconds.GetHashCode(); if (BenchmarkSeconds != 0) hash ^= BenchmarkSeconds.GetHashCode(); if (SpawnLocalWorkerCount != 0) hash ^= SpawnLocalWorkerCount.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (Name.Length != 0) { output.WriteRawTag(10); output.WriteString(Name); } if (clientConfig_ != null) { output.WriteRawTag(18); output.WriteMessage(ClientConfig); } if (NumClients != 0) { output.WriteRawTag(24); output.WriteInt32(NumClients); } if (serverConfig_ != null) { output.WriteRawTag(34); output.WriteMessage(ServerConfig); } if (NumServers != 0) { output.WriteRawTag(40); output.WriteInt32(NumServers); } if (WarmupSeconds != 0) { output.WriteRawTag(48); output.WriteInt32(WarmupSeconds); } if (BenchmarkSeconds != 0) { output.WriteRawTag(56); output.WriteInt32(BenchmarkSeconds); } if (SpawnLocalWorkerCount != 0) { output.WriteRawTag(64); output.WriteInt32(SpawnLocalWorkerCount); } } public int CalculateSize() { int size = 0; if (Name.Length != 0) { size += 1 + pb::CodedOutputStream.ComputeStringSize(Name); } if (clientConfig_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(ClientConfig); } if (NumClients != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(NumClients); } if (serverConfig_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(ServerConfig); } if (NumServers != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(NumServers); } if (WarmupSeconds != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(WarmupSeconds); } if (BenchmarkSeconds != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(BenchmarkSeconds); } if (SpawnLocalWorkerCount != 0) { size += 1 + pb::CodedOutputStream.ComputeInt32Size(SpawnLocalWorkerCount); } return size; } public void MergeFrom(Scenario other) { if (other == null) { return; } if (other.Name.Length != 0) { Name = other.Name; } if (other.clientConfig_ != null) { if (clientConfig_ == null) { clientConfig_ = new global::Grpc.Testing.ClientConfig(); } ClientConfig.MergeFrom(other.ClientConfig); } if (other.NumClients != 0) { NumClients = other.NumClients; } if (other.serverConfig_ != null) { if (serverConfig_ == null) { serverConfig_ = new global::Grpc.Testing.ServerConfig(); } ServerConfig.MergeFrom(other.ServerConfig); } if (other.NumServers != 0) { NumServers = other.NumServers; } if (other.WarmupSeconds != 0) { WarmupSeconds = other.WarmupSeconds; } if (other.BenchmarkSeconds != 0) { BenchmarkSeconds = other.BenchmarkSeconds; } if (other.SpawnLocalWorkerCount != 0) { SpawnLocalWorkerCount = other.SpawnLocalWorkerCount; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 10: { Name = input.ReadString(); break; } case 18: { if (clientConfig_ == null) { clientConfig_ = new global::Grpc.Testing.ClientConfig(); } input.ReadMessage(clientConfig_); break; } case 24: { NumClients = input.ReadInt32(); break; } case 34: { if (serverConfig_ == null) { serverConfig_ = new global::Grpc.Testing.ServerConfig(); } input.ReadMessage(serverConfig_); break; } case 40: { NumServers = input.ReadInt32(); break; } case 48: { WarmupSeconds = input.ReadInt32(); break; } case 56: { BenchmarkSeconds = input.ReadInt32(); break; } case 64: { SpawnLocalWorkerCount = input.ReadInt32(); break; } } } } } /// /// A set of scenarios to be run with qps_json_driver /// [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class Scenarios : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new Scenarios()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[15]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public Scenarios() { OnConstruction(); } partial void OnConstruction(); public Scenarios(Scenarios other) : this() { scenarios_ = other.scenarios_.Clone(); } public Scenarios Clone() { return new Scenarios(this); } /// Field number for the "scenarios" field. public const int Scenarios_FieldNumber = 1; private static readonly pb::FieldCodec _repeated_scenarios_codec = pb::FieldCodec.ForMessage(10, global::Grpc.Testing.Scenario.Parser); private readonly pbc::RepeatedField scenarios_ = new pbc::RepeatedField(); public pbc::RepeatedField Scenarios_ { get { return scenarios_; } } public override bool Equals(object other) { return Equals(other as Scenarios); } public bool Equals(Scenarios other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if(!scenarios_.Equals(other.scenarios_)) return false; return true; } public override int GetHashCode() { int hash = 1; hash ^= scenarios_.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { scenarios_.WriteTo(output, _repeated_scenarios_codec); } public int CalculateSize() { int size = 0; size += scenarios_.CalculateSize(_repeated_scenarios_codec); return size; } public void MergeFrom(Scenarios other) { if (other == null) { return; } scenarios_.Add(other.scenarios_); } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 10: { scenarios_.AddEntriesFrom(input, _repeated_scenarios_codec); break; } } } } } /// /// Basic summary that can be computed from ClientStats and ServerStats /// once the scenario has finished. /// [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class ScenarioResultSummary : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new ScenarioResultSummary()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[16]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public ScenarioResultSummary() { OnConstruction(); } partial void OnConstruction(); public ScenarioResultSummary(ScenarioResultSummary other) : this() { qps_ = other.qps_; qpsPerServerCore_ = other.qpsPerServerCore_; serverSystemTime_ = other.serverSystemTime_; serverUserTime_ = other.serverUserTime_; clientSystemTime_ = other.clientSystemTime_; clientUserTime_ = other.clientUserTime_; latency50_ = other.latency50_; latency90_ = other.latency90_; latency95_ = other.latency95_; latency99_ = other.latency99_; latency999_ = other.latency999_; } public ScenarioResultSummary Clone() { return new ScenarioResultSummary(this); } /// Field number for the "qps" field. public const int QpsFieldNumber = 1; private double qps_; /// /// Total number of operations per second over all clients. /// public double Qps { get { return qps_; } set { qps_ = value; } } /// Field number for the "qps_per_server_core" field. public const int QpsPerServerCoreFieldNumber = 2; private double qpsPerServerCore_; /// /// QPS per one server core. /// public double QpsPerServerCore { get { return qpsPerServerCore_; } set { qpsPerServerCore_ = value; } } /// Field number for the "server_system_time" field. public const int ServerSystemTimeFieldNumber = 3; private double serverSystemTime_; /// /// server load based on system_time (0.85 => 85%) /// public double ServerSystemTime { get { return serverSystemTime_; } set { serverSystemTime_ = value; } } /// Field number for the "server_user_time" field. public const int ServerUserTimeFieldNumber = 4; private double serverUserTime_; /// /// server load based on user_time (0.85 => 85%) /// public double ServerUserTime { get { return serverUserTime_; } set { serverUserTime_ = value; } } /// Field number for the "client_system_time" field. public const int ClientSystemTimeFieldNumber = 5; private double clientSystemTime_; /// /// client load based on system_time (0.85 => 85%) /// public double ClientSystemTime { get { return clientSystemTime_; } set { clientSystemTime_ = value; } } /// Field number for the "client_user_time" field. public const int ClientUserTimeFieldNumber = 6; private double clientUserTime_; /// /// client load based on user_time (0.85 => 85%) /// public double ClientUserTime { get { return clientUserTime_; } set { clientUserTime_ = value; } } /// Field number for the "latency_50" field. public const int Latency50FieldNumber = 7; private double latency50_; /// /// X% latency percentiles (in nanoseconds) /// public double Latency50 { get { return latency50_; } set { latency50_ = value; } } /// Field number for the "latency_90" field. public const int Latency90FieldNumber = 8; private double latency90_; public double Latency90 { get { return latency90_; } set { latency90_ = value; } } /// Field number for the "latency_95" field. public const int Latency95FieldNumber = 9; private double latency95_; public double Latency95 { get { return latency95_; } set { latency95_ = value; } } /// Field number for the "latency_99" field. public const int Latency99FieldNumber = 10; private double latency99_; public double Latency99 { get { return latency99_; } set { latency99_ = value; } } /// Field number for the "latency_999" field. public const int Latency999FieldNumber = 11; private double latency999_; public double Latency999 { get { return latency999_; } set { latency999_ = value; } } public override bool Equals(object other) { return Equals(other as ScenarioResultSummary); } public bool Equals(ScenarioResultSummary other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (Qps != other.Qps) return false; if (QpsPerServerCore != other.QpsPerServerCore) return false; if (ServerSystemTime != other.ServerSystemTime) return false; if (ServerUserTime != other.ServerUserTime) return false; if (ClientSystemTime != other.ClientSystemTime) return false; if (ClientUserTime != other.ClientUserTime) return false; if (Latency50 != other.Latency50) return false; if (Latency90 != other.Latency90) return false; if (Latency95 != other.Latency95) return false; if (Latency99 != other.Latency99) return false; if (Latency999 != other.Latency999) return false; return true; } public override int GetHashCode() { int hash = 1; if (Qps != 0D) hash ^= Qps.GetHashCode(); if (QpsPerServerCore != 0D) hash ^= QpsPerServerCore.GetHashCode(); if (ServerSystemTime != 0D) hash ^= ServerSystemTime.GetHashCode(); if (ServerUserTime != 0D) hash ^= ServerUserTime.GetHashCode(); if (ClientSystemTime != 0D) hash ^= ClientSystemTime.GetHashCode(); if (ClientUserTime != 0D) hash ^= ClientUserTime.GetHashCode(); if (Latency50 != 0D) hash ^= Latency50.GetHashCode(); if (Latency90 != 0D) hash ^= Latency90.GetHashCode(); if (Latency95 != 0D) hash ^= Latency95.GetHashCode(); if (Latency99 != 0D) hash ^= Latency99.GetHashCode(); if (Latency999 != 0D) hash ^= Latency999.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (Qps != 0D) { output.WriteRawTag(9); output.WriteDouble(Qps); } if (QpsPerServerCore != 0D) { output.WriteRawTag(17); output.WriteDouble(QpsPerServerCore); } if (ServerSystemTime != 0D) { output.WriteRawTag(25); output.WriteDouble(ServerSystemTime); } if (ServerUserTime != 0D) { output.WriteRawTag(33); output.WriteDouble(ServerUserTime); } if (ClientSystemTime != 0D) { output.WriteRawTag(41); output.WriteDouble(ClientSystemTime); } if (ClientUserTime != 0D) { output.WriteRawTag(49); output.WriteDouble(ClientUserTime); } if (Latency50 != 0D) { output.WriteRawTag(57); output.WriteDouble(Latency50); } if (Latency90 != 0D) { output.WriteRawTag(65); output.WriteDouble(Latency90); } if (Latency95 != 0D) { output.WriteRawTag(73); output.WriteDouble(Latency95); } if (Latency99 != 0D) { output.WriteRawTag(81); output.WriteDouble(Latency99); } if (Latency999 != 0D) { output.WriteRawTag(89); output.WriteDouble(Latency999); } } public int CalculateSize() { int size = 0; if (Qps != 0D) { size += 1 + 8; } if (QpsPerServerCore != 0D) { size += 1 + 8; } if (ServerSystemTime != 0D) { size += 1 + 8; } if (ServerUserTime != 0D) { size += 1 + 8; } if (ClientSystemTime != 0D) { size += 1 + 8; } if (ClientUserTime != 0D) { size += 1 + 8; } if (Latency50 != 0D) { size += 1 + 8; } if (Latency90 != 0D) { size += 1 + 8; } if (Latency95 != 0D) { size += 1 + 8; } if (Latency99 != 0D) { size += 1 + 8; } if (Latency999 != 0D) { size += 1 + 8; } return size; } public void MergeFrom(ScenarioResultSummary other) { if (other == null) { return; } if (other.Qps != 0D) { Qps = other.Qps; } if (other.QpsPerServerCore != 0D) { QpsPerServerCore = other.QpsPerServerCore; } if (other.ServerSystemTime != 0D) { ServerSystemTime = other.ServerSystemTime; } if (other.ServerUserTime != 0D) { ServerUserTime = other.ServerUserTime; } if (other.ClientSystemTime != 0D) { ClientSystemTime = other.ClientSystemTime; } if (other.ClientUserTime != 0D) { ClientUserTime = other.ClientUserTime; } if (other.Latency50 != 0D) { Latency50 = other.Latency50; } if (other.Latency90 != 0D) { Latency90 = other.Latency90; } if (other.Latency95 != 0D) { Latency95 = other.Latency95; } if (other.Latency99 != 0D) { Latency99 = other.Latency99; } if (other.Latency999 != 0D) { Latency999 = other.Latency999; } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 9: { Qps = input.ReadDouble(); break; } case 17: { QpsPerServerCore = input.ReadDouble(); break; } case 25: { ServerSystemTime = input.ReadDouble(); break; } case 33: { ServerUserTime = input.ReadDouble(); break; } case 41: { ClientSystemTime = input.ReadDouble(); break; } case 49: { ClientUserTime = input.ReadDouble(); break; } case 57: { Latency50 = input.ReadDouble(); break; } case 65: { Latency90 = input.ReadDouble(); break; } case 73: { Latency95 = input.ReadDouble(); break; } case 81: { Latency99 = input.ReadDouble(); break; } case 89: { Latency999 = input.ReadDouble(); break; } } } } } /// /// Results of a single benchmark scenario. /// [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] public sealed partial class ScenarioResult : pb::IMessage { private static readonly pb::MessageParser _parser = new pb::MessageParser(() => new ScenarioResult()); public static pb::MessageParser Parser { get { return _parser; } } public static pbr::MessageDescriptor Descriptor { get { return global::Grpc.Testing.ControlReflection.Descriptor.MessageTypes[17]; } } pbr::MessageDescriptor pb::IMessage.Descriptor { get { return Descriptor; } } public ScenarioResult() { OnConstruction(); } partial void OnConstruction(); public ScenarioResult(ScenarioResult other) : this() { Scenario = other.scenario_ != null ? other.Scenario.Clone() : null; Latencies = other.latencies_ != null ? other.Latencies.Clone() : null; clientStats_ = other.clientStats_.Clone(); serverStats_ = other.serverStats_.Clone(); serverCores_ = other.serverCores_.Clone(); Summary = other.summary_ != null ? other.Summary.Clone() : null; } public ScenarioResult Clone() { return new ScenarioResult(this); } /// Field number for the "scenario" field. public const int ScenarioFieldNumber = 1; private global::Grpc.Testing.Scenario scenario_; /// /// Inputs used to run the scenario. /// public global::Grpc.Testing.Scenario Scenario { get { return scenario_; } set { scenario_ = value; } } /// Field number for the "latencies" field. public const int LatenciesFieldNumber = 2; private global::Grpc.Testing.HistogramData latencies_; /// /// Histograms from all clients merged into one histogram. /// public global::Grpc.Testing.HistogramData Latencies { get { return latencies_; } set { latencies_ = value; } } /// Field number for the "client_stats" field. public const int ClientStatsFieldNumber = 3; private static readonly pb::FieldCodec _repeated_clientStats_codec = pb::FieldCodec.ForMessage(26, global::Grpc.Testing.ClientStats.Parser); private readonly pbc::RepeatedField clientStats_ = new pbc::RepeatedField(); /// /// Client stats for each client /// public pbc::RepeatedField ClientStats { get { return clientStats_; } } /// Field number for the "server_stats" field. public const int ServerStatsFieldNumber = 4; private static readonly pb::FieldCodec _repeated_serverStats_codec = pb::FieldCodec.ForMessage(34, global::Grpc.Testing.ServerStats.Parser); private readonly pbc::RepeatedField serverStats_ = new pbc::RepeatedField(); /// /// Server stats for each server /// public pbc::RepeatedField ServerStats { get { return serverStats_; } } /// Field number for the "server_cores" field. public const int ServerCoresFieldNumber = 5; private static readonly pb::FieldCodec _repeated_serverCores_codec = pb::FieldCodec.ForInt32(42); private readonly pbc::RepeatedField serverCores_ = new pbc::RepeatedField(); /// /// Number of cores available to each server /// public pbc::RepeatedField ServerCores { get { return serverCores_; } } /// Field number for the "summary" field. public const int SummaryFieldNumber = 6; private global::Grpc.Testing.ScenarioResultSummary summary_; /// /// An after-the-fact computed summary /// public global::Grpc.Testing.ScenarioResultSummary Summary { get { return summary_; } set { summary_ = value; } } public override bool Equals(object other) { return Equals(other as ScenarioResult); } public bool Equals(ScenarioResult other) { if (ReferenceEquals(other, null)) { return false; } if (ReferenceEquals(other, this)) { return true; } if (!object.Equals(Scenario, other.Scenario)) return false; if (!object.Equals(Latencies, other.Latencies)) return false; if(!clientStats_.Equals(other.clientStats_)) return false; if(!serverStats_.Equals(other.serverStats_)) return false; if(!serverCores_.Equals(other.serverCores_)) return false; if (!object.Equals(Summary, other.Summary)) return false; return true; } public override int GetHashCode() { int hash = 1; if (scenario_ != null) hash ^= Scenario.GetHashCode(); if (latencies_ != null) hash ^= Latencies.GetHashCode(); hash ^= clientStats_.GetHashCode(); hash ^= serverStats_.GetHashCode(); hash ^= serverCores_.GetHashCode(); if (summary_ != null) hash ^= Summary.GetHashCode(); return hash; } public override string ToString() { return pb::JsonFormatter.ToDiagnosticString(this); } public void WriteTo(pb::CodedOutputStream output) { if (scenario_ != null) { output.WriteRawTag(10); output.WriteMessage(Scenario); } if (latencies_ != null) { output.WriteRawTag(18); output.WriteMessage(Latencies); } clientStats_.WriteTo(output, _repeated_clientStats_codec); serverStats_.WriteTo(output, _repeated_serverStats_codec); serverCores_.WriteTo(output, _repeated_serverCores_codec); if (summary_ != null) { output.WriteRawTag(50); output.WriteMessage(Summary); } } public int CalculateSize() { int size = 0; if (scenario_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Scenario); } if (latencies_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Latencies); } size += clientStats_.CalculateSize(_repeated_clientStats_codec); size += serverStats_.CalculateSize(_repeated_serverStats_codec); size += serverCores_.CalculateSize(_repeated_serverCores_codec); if (summary_ != null) { size += 1 + pb::CodedOutputStream.ComputeMessageSize(Summary); } return size; } public void MergeFrom(ScenarioResult other) { if (other == null) { return; } if (other.scenario_ != null) { if (scenario_ == null) { scenario_ = new global::Grpc.Testing.Scenario(); } Scenario.MergeFrom(other.Scenario); } if (other.latencies_ != null) { if (latencies_ == null) { latencies_ = new global::Grpc.Testing.HistogramData(); } Latencies.MergeFrom(other.Latencies); } clientStats_.Add(other.clientStats_); serverStats_.Add(other.serverStats_); serverCores_.Add(other.serverCores_); if (other.summary_ != null) { if (summary_ == null) { summary_ = new global::Grpc.Testing.ScenarioResultSummary(); } Summary.MergeFrom(other.Summary); } } public void MergeFrom(pb::CodedInputStream input) { uint tag; while ((tag = input.ReadTag()) != 0) { switch(tag) { default: input.SkipLastField(); break; case 10: { if (scenario_ == null) { scenario_ = new global::Grpc.Testing.Scenario(); } input.ReadMessage(scenario_); break; } case 18: { if (latencies_ == null) { latencies_ = new global::Grpc.Testing.HistogramData(); } input.ReadMessage(latencies_); break; } case 26: { clientStats_.AddEntriesFrom(input, _repeated_clientStats_codec); break; } case 34: { serverStats_.AddEntriesFrom(input, _repeated_serverStats_codec); break; } case 42: case 40: { serverCores_.AddEntriesFrom(input, _repeated_serverCores_codec); break; } case 50: { if (summary_ == null) { summary_ = new global::Grpc.Testing.ScenarioResultSummary(); } input.ReadMessage(summary_); break; } } } } } #endregion } #endregion Designer generated code