Sree Kuchibhotla
9 years ago
commit
fd59e4e5f9
771 changed files with 20401 additions and 17778 deletions
@ -0,0 +1,3 @@ |
|||||||
|
bin |
||||||
|
obj |
||||||
|
|
||||||
@ -0,0 +1,60 @@ |
|||||||
|
<?xml version="1.0" encoding="utf-8"?> |
||||||
|
<Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> |
||||||
|
<PropertyGroup> |
||||||
|
<Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> |
||||||
|
<Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> |
||||||
|
<ProjectGuid>{ADEBA147-80AE-4710-82E9-5B7F93690266}</ProjectGuid> |
||||||
|
<OutputType>Exe</OutputType> |
||||||
|
<RootNamespace>Grpc.IntegrationTesting.StressClient</RootNamespace> |
||||||
|
<AssemblyName>Grpc.IntegrationTesting.StressClient</AssemblyName> |
||||||
|
<TargetFrameworkVersion>v4.5</TargetFrameworkVersion> |
||||||
|
</PropertyGroup> |
||||||
|
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' "> |
||||||
|
<DebugSymbols>true</DebugSymbols> |
||||||
|
<DebugType>full</DebugType> |
||||||
|
<Optimize>false</Optimize> |
||||||
|
<OutputPath>bin\Debug</OutputPath> |
||||||
|
<DefineConstants>DEBUG;</DefineConstants> |
||||||
|
<ErrorReport>prompt</ErrorReport> |
||||||
|
<WarningLevel>4</WarningLevel> |
||||||
|
<PlatformTarget>AnyCPU</PlatformTarget> |
||||||
|
</PropertyGroup> |
||||||
|
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' "> |
||||||
|
<DebugType>pdbonly</DebugType> |
||||||
|
<Optimize>true</Optimize> |
||||||
|
<OutputPath>bin\Release</OutputPath> |
||||||
|
<ErrorReport>prompt</ErrorReport> |
||||||
|
<WarningLevel>4</WarningLevel> |
||||||
|
<PlatformTarget>AnyCPU</PlatformTarget> |
||||||
|
</PropertyGroup> |
||||||
|
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'ReleaseSigned|AnyCPU' "> |
||||||
|
<DebugType>pdbonly</DebugType> |
||||||
|
<Optimize>true</Optimize> |
||||||
|
<OutputPath>bin\ReleaseSigned</OutputPath> |
||||||
|
<ErrorReport>prompt</ErrorReport> |
||||||
|
<WarningLevel>4</WarningLevel> |
||||||
|
<SignAssembly>True</SignAssembly> |
||||||
|
<AssemblyOriginatorKeyFile>..\keys\Grpc.snk</AssemblyOriginatorKeyFile> |
||||||
|
</PropertyGroup> |
||||||
|
<ItemGroup> |
||||||
|
<Reference Include="System" /> |
||||||
|
</ItemGroup> |
||||||
|
<ItemGroup> |
||||||
|
<Compile Include="..\Grpc.Core\Version.cs"> |
||||||
|
<Link>Version.cs</Link> |
||||||
|
</Compile> |
||||||
|
<Compile Include="Program.cs" /> |
||||||
|
<Compile Include="Properties\AssemblyInfo.cs" /> |
||||||
|
</ItemGroup> |
||||||
|
<Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" /> |
||||||
|
<ItemGroup> |
||||||
|
<ProjectReference Include="..\Grpc.Core\Grpc.Core.csproj"> |
||||||
|
<Project>{CCC4440E-49F7-4790-B0AF-FEABB0837AE7}</Project> |
||||||
|
<Name>Grpc.Core</Name> |
||||||
|
</ProjectReference> |
||||||
|
<ProjectReference Include="..\Grpc.IntegrationTesting\Grpc.IntegrationTesting.csproj"> |
||||||
|
<Project>{C61154BA-DD4A-4838-8420-0162A28925E0}</Project> |
||||||
|
<Name>Grpc.IntegrationTesting</Name> |
||||||
|
</ProjectReference> |
||||||
|
</ItemGroup> |
||||||
|
</Project> |
||||||
@ -0,0 +1,452 @@ |
|||||||
|
// Generated by the protocol buffer compiler. DO NOT EDIT! |
||||||
|
// source: src/proto/grpc/testing/metrics.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 { |
||||||
|
|
||||||
|
/// <summary>Holder for reflection information generated from src/proto/grpc/testing/metrics.proto</summary> |
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute()] |
||||||
|
public static partial class MetricsReflection { |
||||||
|
|
||||||
|
#region Descriptor |
||||||
|
/// <summary>File descriptor for src/proto/grpc/testing/metrics.proto</summary> |
||||||
|
public static pbr::FileDescriptor Descriptor { |
||||||
|
get { return descriptor; } |
||||||
|
} |
||||||
|
private static pbr::FileDescriptor descriptor; |
||||||
|
|
||||||
|
static MetricsReflection() { |
||||||
|
byte[] descriptorData = global::System.Convert.FromBase64String( |
||||||
|
string.Concat( |
||||||
|
"CiRzcmMvcHJvdG8vZ3JwYy90ZXN0aW5nL21ldHJpY3MucHJvdG8SDGdycGMu", |
||||||
|
"dGVzdGluZyJsCg1HYXVnZVJlc3BvbnNlEgwKBG5hbWUYASABKAkSFAoKbG9u", |
||||||
|
"Z192YWx1ZRgCIAEoA0gAEhYKDGRvdWJsZV92YWx1ZRgDIAEoAUgAEhYKDHN0", |
||||||
|
"cmluZ192YWx1ZRgEIAEoCUgAQgcKBXZhbHVlIhwKDEdhdWdlUmVxdWVzdBIM", |
||||||
|
"CgRuYW1lGAEgASgJIg4KDEVtcHR5TWVzc2FnZTKgAQoOTWV0cmljc1NlcnZp", |
||||||
|
"Y2USSQoMR2V0QWxsR2F1Z2VzEhouZ3JwYy50ZXN0aW5nLkVtcHR5TWVzc2Fn", |
||||||
|
"ZRobLmdycGMudGVzdGluZy5HYXVnZVJlc3BvbnNlMAESQwoIR2V0R2F1Z2US", |
||||||
|
"Gi5ncnBjLnRlc3RpbmcuR2F1Z2VSZXF1ZXN0GhsuZ3JwYy50ZXN0aW5nLkdh", |
||||||
|
"dWdlUmVzcG9uc2ViBnByb3RvMw==")); |
||||||
|
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData, |
||||||
|
new pbr::FileDescriptor[] { }, |
||||||
|
new pbr::GeneratedCodeInfo(null, new pbr::GeneratedCodeInfo[] { |
||||||
|
new pbr::GeneratedCodeInfo(typeof(global::Grpc.Testing.GaugeResponse), global::Grpc.Testing.GaugeResponse.Parser, new[]{ "Name", "LongValue", "DoubleValue", "StringValue" }, new[]{ "Value" }, null, null), |
||||||
|
new pbr::GeneratedCodeInfo(typeof(global::Grpc.Testing.GaugeRequest), global::Grpc.Testing.GaugeRequest.Parser, new[]{ "Name" }, null, null, null), |
||||||
|
new pbr::GeneratedCodeInfo(typeof(global::Grpc.Testing.EmptyMessage), global::Grpc.Testing.EmptyMessage.Parser, null, null, null, null) |
||||||
|
})); |
||||||
|
} |
||||||
|
#endregion |
||||||
|
|
||||||
|
} |
||||||
|
#region Messages |
||||||
|
/// <summary> |
||||||
|
/// Reponse message containing the gauge name and value |
||||||
|
/// </summary> |
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute()] |
||||||
|
public sealed partial class GaugeResponse : pb::IMessage<GaugeResponse> { |
||||||
|
private static readonly pb::MessageParser<GaugeResponse> _parser = new pb::MessageParser<GaugeResponse>(() => new GaugeResponse()); |
||||||
|
public static pb::MessageParser<GaugeResponse> Parser { get { return _parser; } } |
||||||
|
|
||||||
|
public static pbr::MessageDescriptor Descriptor { |
||||||
|
get { return global::Grpc.Testing.MetricsReflection.Descriptor.MessageTypes[0]; } |
||||||
|
} |
||||||
|
|
||||||
|
pbr::MessageDescriptor pb::IMessage.Descriptor { |
||||||
|
get { return Descriptor; } |
||||||
|
} |
||||||
|
|
||||||
|
public GaugeResponse() { |
||||||
|
OnConstruction(); |
||||||
|
} |
||||||
|
|
||||||
|
partial void OnConstruction(); |
||||||
|
|
||||||
|
public GaugeResponse(GaugeResponse other) : this() { |
||||||
|
name_ = other.name_; |
||||||
|
switch (other.ValueCase) { |
||||||
|
case ValueOneofCase.LongValue: |
||||||
|
LongValue = other.LongValue; |
||||||
|
break; |
||||||
|
case ValueOneofCase.DoubleValue: |
||||||
|
DoubleValue = other.DoubleValue; |
||||||
|
break; |
||||||
|
case ValueOneofCase.StringValue: |
||||||
|
StringValue = other.StringValue; |
||||||
|
break; |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
public GaugeResponse Clone() { |
||||||
|
return new GaugeResponse(this); |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Field number for the "name" field.</summary> |
||||||
|
public const int NameFieldNumber = 1; |
||||||
|
private string name_ = ""; |
||||||
|
public string Name { |
||||||
|
get { return name_; } |
||||||
|
set { |
||||||
|
name_ = pb::Preconditions.CheckNotNull(value, "value"); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Field number for the "long_value" field.</summary> |
||||||
|
public const int LongValueFieldNumber = 2; |
||||||
|
public long LongValue { |
||||||
|
get { return valueCase_ == ValueOneofCase.LongValue ? (long) value_ : 0L; } |
||||||
|
set { |
||||||
|
value_ = value; |
||||||
|
valueCase_ = ValueOneofCase.LongValue; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Field number for the "double_value" field.</summary> |
||||||
|
public const int DoubleValueFieldNumber = 3; |
||||||
|
public double DoubleValue { |
||||||
|
get { return valueCase_ == ValueOneofCase.DoubleValue ? (double) value_ : 0D; } |
||||||
|
set { |
||||||
|
value_ = value; |
||||||
|
valueCase_ = ValueOneofCase.DoubleValue; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Field number for the "string_value" field.</summary> |
||||||
|
public const int StringValueFieldNumber = 4; |
||||||
|
public string StringValue { |
||||||
|
get { return valueCase_ == ValueOneofCase.StringValue ? (string) value_ : ""; } |
||||||
|
set { |
||||||
|
value_ = pb::Preconditions.CheckNotNull(value, "value"); |
||||||
|
valueCase_ = ValueOneofCase.StringValue; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private object value_; |
||||||
|
/// <summary>Enum of possible cases for the "value" oneof.</summary> |
||||||
|
public enum ValueOneofCase { |
||||||
|
None = 0, |
||||||
|
LongValue = 2, |
||||||
|
DoubleValue = 3, |
||||||
|
StringValue = 4, |
||||||
|
} |
||||||
|
private ValueOneofCase valueCase_ = ValueOneofCase.None; |
||||||
|
public ValueOneofCase ValueCase { |
||||||
|
get { return valueCase_; } |
||||||
|
} |
||||||
|
|
||||||
|
public void ClearValue() { |
||||||
|
valueCase_ = ValueOneofCase.None; |
||||||
|
value_ = null; |
||||||
|
} |
||||||
|
|
||||||
|
public override bool Equals(object other) { |
||||||
|
return Equals(other as GaugeResponse); |
||||||
|
} |
||||||
|
|
||||||
|
public bool Equals(GaugeResponse other) { |
||||||
|
if (ReferenceEquals(other, null)) { |
||||||
|
return false; |
||||||
|
} |
||||||
|
if (ReferenceEquals(other, this)) { |
||||||
|
return true; |
||||||
|
} |
||||||
|
if (Name != other.Name) return false; |
||||||
|
if (LongValue != other.LongValue) return false; |
||||||
|
if (DoubleValue != other.DoubleValue) return false; |
||||||
|
if (StringValue != other.StringValue) return false; |
||||||
|
if (ValueCase != other.ValueCase) return false; |
||||||
|
return true; |
||||||
|
} |
||||||
|
|
||||||
|
public override int GetHashCode() { |
||||||
|
int hash = 1; |
||||||
|
if (Name.Length != 0) hash ^= Name.GetHashCode(); |
||||||
|
if (valueCase_ == ValueOneofCase.LongValue) hash ^= LongValue.GetHashCode(); |
||||||
|
if (valueCase_ == ValueOneofCase.DoubleValue) hash ^= DoubleValue.GetHashCode(); |
||||||
|
if (valueCase_ == ValueOneofCase.StringValue) hash ^= StringValue.GetHashCode(); |
||||||
|
hash ^= (int) valueCase_; |
||||||
|
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 (valueCase_ == ValueOneofCase.LongValue) { |
||||||
|
output.WriteRawTag(16); |
||||||
|
output.WriteInt64(LongValue); |
||||||
|
} |
||||||
|
if (valueCase_ == ValueOneofCase.DoubleValue) { |
||||||
|
output.WriteRawTag(25); |
||||||
|
output.WriteDouble(DoubleValue); |
||||||
|
} |
||||||
|
if (valueCase_ == ValueOneofCase.StringValue) { |
||||||
|
output.WriteRawTag(34); |
||||||
|
output.WriteString(StringValue); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public int CalculateSize() { |
||||||
|
int size = 0; |
||||||
|
if (Name.Length != 0) { |
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(Name); |
||||||
|
} |
||||||
|
if (valueCase_ == ValueOneofCase.LongValue) { |
||||||
|
size += 1 + pb::CodedOutputStream.ComputeInt64Size(LongValue); |
||||||
|
} |
||||||
|
if (valueCase_ == ValueOneofCase.DoubleValue) { |
||||||
|
size += 1 + 8; |
||||||
|
} |
||||||
|
if (valueCase_ == ValueOneofCase.StringValue) { |
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(StringValue); |
||||||
|
} |
||||||
|
return size; |
||||||
|
} |
||||||
|
|
||||||
|
public void MergeFrom(GaugeResponse other) { |
||||||
|
if (other == null) { |
||||||
|
return; |
||||||
|
} |
||||||
|
if (other.Name.Length != 0) { |
||||||
|
Name = other.Name; |
||||||
|
} |
||||||
|
switch (other.ValueCase) { |
||||||
|
case ValueOneofCase.LongValue: |
||||||
|
LongValue = other.LongValue; |
||||||
|
break; |
||||||
|
case ValueOneofCase.DoubleValue: |
||||||
|
DoubleValue = other.DoubleValue; |
||||||
|
break; |
||||||
|
case ValueOneofCase.StringValue: |
||||||
|
StringValue = other.StringValue; |
||||||
|
break; |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
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 16: { |
||||||
|
LongValue = input.ReadInt64(); |
||||||
|
break; |
||||||
|
} |
||||||
|
case 25: { |
||||||
|
DoubleValue = input.ReadDouble(); |
||||||
|
break; |
||||||
|
} |
||||||
|
case 34: { |
||||||
|
StringValue = input.ReadString(); |
||||||
|
break; |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
/// <summary> |
||||||
|
/// Request message containing the gauge name |
||||||
|
/// </summary> |
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute()] |
||||||
|
public sealed partial class GaugeRequest : pb::IMessage<GaugeRequest> { |
||||||
|
private static readonly pb::MessageParser<GaugeRequest> _parser = new pb::MessageParser<GaugeRequest>(() => new GaugeRequest()); |
||||||
|
public static pb::MessageParser<GaugeRequest> Parser { get { return _parser; } } |
||||||
|
|
||||||
|
public static pbr::MessageDescriptor Descriptor { |
||||||
|
get { return global::Grpc.Testing.MetricsReflection.Descriptor.MessageTypes[1]; } |
||||||
|
} |
||||||
|
|
||||||
|
pbr::MessageDescriptor pb::IMessage.Descriptor { |
||||||
|
get { return Descriptor; } |
||||||
|
} |
||||||
|
|
||||||
|
public GaugeRequest() { |
||||||
|
OnConstruction(); |
||||||
|
} |
||||||
|
|
||||||
|
partial void OnConstruction(); |
||||||
|
|
||||||
|
public GaugeRequest(GaugeRequest other) : this() { |
||||||
|
name_ = other.name_; |
||||||
|
} |
||||||
|
|
||||||
|
public GaugeRequest Clone() { |
||||||
|
return new GaugeRequest(this); |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Field number for the "name" field.</summary> |
||||||
|
public const int NameFieldNumber = 1; |
||||||
|
private string name_ = ""; |
||||||
|
public string Name { |
||||||
|
get { return name_; } |
||||||
|
set { |
||||||
|
name_ = pb::Preconditions.CheckNotNull(value, "value"); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public override bool Equals(object other) { |
||||||
|
return Equals(other as GaugeRequest); |
||||||
|
} |
||||||
|
|
||||||
|
public bool Equals(GaugeRequest other) { |
||||||
|
if (ReferenceEquals(other, null)) { |
||||||
|
return false; |
||||||
|
} |
||||||
|
if (ReferenceEquals(other, this)) { |
||||||
|
return true; |
||||||
|
} |
||||||
|
if (Name != other.Name) return false; |
||||||
|
return true; |
||||||
|
} |
||||||
|
|
||||||
|
public override int GetHashCode() { |
||||||
|
int hash = 1; |
||||||
|
if (Name.Length != 0) hash ^= Name.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); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public int CalculateSize() { |
||||||
|
int size = 0; |
||||||
|
if (Name.Length != 0) { |
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(Name); |
||||||
|
} |
||||||
|
return size; |
||||||
|
} |
||||||
|
|
||||||
|
public void MergeFrom(GaugeRequest other) { |
||||||
|
if (other == null) { |
||||||
|
return; |
||||||
|
} |
||||||
|
if (other.Name.Length != 0) { |
||||||
|
Name = other.Name; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
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; |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute()] |
||||||
|
public sealed partial class EmptyMessage : pb::IMessage<EmptyMessage> { |
||||||
|
private static readonly pb::MessageParser<EmptyMessage> _parser = new pb::MessageParser<EmptyMessage>(() => new EmptyMessage()); |
||||||
|
public static pb::MessageParser<EmptyMessage> Parser { get { return _parser; } } |
||||||
|
|
||||||
|
public static pbr::MessageDescriptor Descriptor { |
||||||
|
get { return global::Grpc.Testing.MetricsReflection.Descriptor.MessageTypes[2]; } |
||||||
|
} |
||||||
|
|
||||||
|
pbr::MessageDescriptor pb::IMessage.Descriptor { |
||||||
|
get { return Descriptor; } |
||||||
|
} |
||||||
|
|
||||||
|
public EmptyMessage() { |
||||||
|
OnConstruction(); |
||||||
|
} |
||||||
|
|
||||||
|
partial void OnConstruction(); |
||||||
|
|
||||||
|
public EmptyMessage(EmptyMessage other) : this() { |
||||||
|
} |
||||||
|
|
||||||
|
public EmptyMessage Clone() { |
||||||
|
return new EmptyMessage(this); |
||||||
|
} |
||||||
|
|
||||||
|
public override bool Equals(object other) { |
||||||
|
return Equals(other as EmptyMessage); |
||||||
|
} |
||||||
|
|
||||||
|
public bool Equals(EmptyMessage 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(EmptyMessage other) { |
||||||
|
if (other == null) { |
||||||
|
return; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public void MergeFrom(pb::CodedInputStream input) { |
||||||
|
uint tag; |
||||||
|
while ((tag = input.ReadTag()) != 0) { |
||||||
|
switch(tag) { |
||||||
|
default: |
||||||
|
input.SkipLastField(); |
||||||
|
break; |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
#endregion |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
#endregion Designer generated code |
||||||
@ -0,0 +1,146 @@ |
|||||||
|
// Generated by the protocol buffer compiler. DO NOT EDIT! |
||||||
|
// source: src/proto/grpc/testing/metrics.proto |
||||||
|
#region Designer generated code |
||||||
|
|
||||||
|
using System; |
||||||
|
using System.Threading; |
||||||
|
using System.Threading.Tasks; |
||||||
|
using Grpc.Core; |
||||||
|
|
||||||
|
namespace Grpc.Testing { |
||||||
|
public static class MetricsService |
||||||
|
{ |
||||||
|
static readonly string __ServiceName = "grpc.testing.MetricsService"; |
||||||
|
|
||||||
|
static readonly Marshaller<global::Grpc.Testing.EmptyMessage> __Marshaller_EmptyMessage = Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.EmptyMessage.Parser.ParseFrom); |
||||||
|
static readonly Marshaller<global::Grpc.Testing.GaugeResponse> __Marshaller_GaugeResponse = Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.GaugeResponse.Parser.ParseFrom); |
||||||
|
static readonly Marshaller<global::Grpc.Testing.GaugeRequest> __Marshaller_GaugeRequest = Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.GaugeRequest.Parser.ParseFrom); |
||||||
|
|
||||||
|
static readonly Method<global::Grpc.Testing.EmptyMessage, global::Grpc.Testing.GaugeResponse> __Method_GetAllGauges = new Method<global::Grpc.Testing.EmptyMessage, global::Grpc.Testing.GaugeResponse>( |
||||||
|
MethodType.ServerStreaming, |
||||||
|
__ServiceName, |
||||||
|
"GetAllGauges", |
||||||
|
__Marshaller_EmptyMessage, |
||||||
|
__Marshaller_GaugeResponse); |
||||||
|
|
||||||
|
static readonly Method<global::Grpc.Testing.GaugeRequest, global::Grpc.Testing.GaugeResponse> __Method_GetGauge = new Method<global::Grpc.Testing.GaugeRequest, global::Grpc.Testing.GaugeResponse>( |
||||||
|
MethodType.Unary, |
||||||
|
__ServiceName, |
||||||
|
"GetGauge", |
||||||
|
__Marshaller_GaugeRequest, |
||||||
|
__Marshaller_GaugeResponse); |
||||||
|
|
||||||
|
// service descriptor |
||||||
|
public static global::Google.Protobuf.Reflection.ServiceDescriptor Descriptor |
||||||
|
{ |
||||||
|
get { return global::Grpc.Testing.MetricsReflection.Descriptor.Services[0]; } |
||||||
|
} |
||||||
|
|
||||||
|
// client interface |
||||||
|
[System.Obsolete("Client side interfaced will be removed in the next release. Use client class directly.")] |
||||||
|
public interface IMetricsServiceClient |
||||||
|
{ |
||||||
|
AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(global::Grpc.Testing.EmptyMessage request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken)); |
||||||
|
AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(global::Grpc.Testing.EmptyMessage request, CallOptions options); |
||||||
|
global::Grpc.Testing.GaugeResponse GetGauge(global::Grpc.Testing.GaugeRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken)); |
||||||
|
global::Grpc.Testing.GaugeResponse GetGauge(global::Grpc.Testing.GaugeRequest request, CallOptions options); |
||||||
|
AsyncUnaryCall<global::Grpc.Testing.GaugeResponse> GetGaugeAsync(global::Grpc.Testing.GaugeRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken)); |
||||||
|
AsyncUnaryCall<global::Grpc.Testing.GaugeResponse> GetGaugeAsync(global::Grpc.Testing.GaugeRequest request, CallOptions options); |
||||||
|
} |
||||||
|
|
||||||
|
// server-side interface |
||||||
|
[System.Obsolete("Service implementations should inherit from the generated abstract base class instead.")] |
||||||
|
public interface IMetricsService |
||||||
|
{ |
||||||
|
Task GetAllGauges(global::Grpc.Testing.EmptyMessage request, IServerStreamWriter<global::Grpc.Testing.GaugeResponse> responseStream, ServerCallContext context); |
||||||
|
Task<global::Grpc.Testing.GaugeResponse> GetGauge(global::Grpc.Testing.GaugeRequest request, ServerCallContext context); |
||||||
|
} |
||||||
|
|
||||||
|
// server-side abstract class |
||||||
|
public abstract class MetricsServiceBase |
||||||
|
{ |
||||||
|
public virtual Task GetAllGauges(global::Grpc.Testing.EmptyMessage request, IServerStreamWriter<global::Grpc.Testing.GaugeResponse> responseStream, ServerCallContext context) |
||||||
|
{ |
||||||
|
throw new RpcException(new Status(StatusCode.Unimplemented, "")); |
||||||
|
} |
||||||
|
|
||||||
|
public virtual Task<global::Grpc.Testing.GaugeResponse> GetGauge(global::Grpc.Testing.GaugeRequest request, ServerCallContext context) |
||||||
|
{ |
||||||
|
throw new RpcException(new Status(StatusCode.Unimplemented, "")); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
// client stub |
||||||
|
public class MetricsServiceClient : ClientBase<MetricsServiceClient>, IMetricsServiceClient |
||||||
|
{ |
||||||
|
public MetricsServiceClient(Channel channel) : base(channel) |
||||||
|
{ |
||||||
|
} |
||||||
|
public MetricsServiceClient(CallInvoker callInvoker) : base(callInvoker) |
||||||
|
{ |
||||||
|
} |
||||||
|
///<summary>Protected parameterless constructor to allow creation of test doubles.</summary> |
||||||
|
protected MetricsServiceClient() : base() |
||||||
|
{ |
||||||
|
} |
||||||
|
///<summary>Protected constructor to allow creation of configured clients.</summary> |
||||||
|
protected MetricsServiceClient(ClientBaseConfiguration configuration) : base(configuration) |
||||||
|
{ |
||||||
|
} |
||||||
|
|
||||||
|
public virtual AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(global::Grpc.Testing.EmptyMessage request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken)) |
||||||
|
{ |
||||||
|
return GetAllGauges(request, new CallOptions(headers, deadline, cancellationToken)); |
||||||
|
} |
||||||
|
public virtual AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(global::Grpc.Testing.EmptyMessage request, CallOptions options) |
||||||
|
{ |
||||||
|
return CallInvoker.AsyncServerStreamingCall(__Method_GetAllGauges, null, options, request); |
||||||
|
} |
||||||
|
public virtual global::Grpc.Testing.GaugeResponse GetGauge(global::Grpc.Testing.GaugeRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken)) |
||||||
|
{ |
||||||
|
return GetGauge(request, new CallOptions(headers, deadline, cancellationToken)); |
||||||
|
} |
||||||
|
public virtual global::Grpc.Testing.GaugeResponse GetGauge(global::Grpc.Testing.GaugeRequest request, CallOptions options) |
||||||
|
{ |
||||||
|
return CallInvoker.BlockingUnaryCall(__Method_GetGauge, null, options, request); |
||||||
|
} |
||||||
|
public virtual AsyncUnaryCall<global::Grpc.Testing.GaugeResponse> GetGaugeAsync(global::Grpc.Testing.GaugeRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken)) |
||||||
|
{ |
||||||
|
return GetGaugeAsync(request, new CallOptions(headers, deadline, cancellationToken)); |
||||||
|
} |
||||||
|
public virtual AsyncUnaryCall<global::Grpc.Testing.GaugeResponse> GetGaugeAsync(global::Grpc.Testing.GaugeRequest request, CallOptions options) |
||||||
|
{ |
||||||
|
return CallInvoker.AsyncUnaryCall(__Method_GetGauge, null, options, request); |
||||||
|
} |
||||||
|
protected override MetricsServiceClient NewInstance(ClientBaseConfiguration configuration) |
||||||
|
{ |
||||||
|
return new MetricsServiceClient(configuration); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
// creates service definition that can be registered with a server |
||||||
|
public static ServerServiceDefinition BindService(IMetricsService serviceImpl) |
||||||
|
{ |
||||||
|
return ServerServiceDefinition.CreateBuilder(__ServiceName) |
||||||
|
.AddMethod(__Method_GetAllGauges, serviceImpl.GetAllGauges) |
||||||
|
.AddMethod(__Method_GetGauge, serviceImpl.GetGauge).Build(); |
||||||
|
} |
||||||
|
|
||||||
|
// creates service definition that can be registered with a server |
||||||
|
public static ServerServiceDefinition BindService(MetricsServiceBase serviceImpl) |
||||||
|
{ |
||||||
|
return ServerServiceDefinition.CreateBuilder(__ServiceName) |
||||||
|
.AddMethod(__Method_GetAllGauges, serviceImpl.GetAllGauges) |
||||||
|
.AddMethod(__Method_GetGauge, serviceImpl.GetGauge).Build(); |
||||||
|
} |
||||||
|
|
||||||
|
// creates a new client |
||||||
|
public static MetricsServiceClient NewClient(Channel channel) |
||||||
|
{ |
||||||
|
return new MetricsServiceClient(channel); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
} |
||||||
|
#endregion |
||||||
@ -0,0 +1,318 @@ |
|||||||
|
#region Copyright notice and license |
||||||
|
|
||||||
|
// Copyright 2015-2016, Google Inc. |
||||||
|
// All rights reserved. |
||||||
|
// |
||||||
|
// Redistribution and use in source and binary forms, with or without |
||||||
|
// modification, are permitted provided that the following conditions are |
||||||
|
// met: |
||||||
|
// |
||||||
|
// * Redistributions of source code must retain the above copyright |
||||||
|
// notice, this list of conditions and the following disclaimer. |
||||||
|
// * Redistributions in binary form must reproduce the above |
||||||
|
// copyright notice, this list of conditions and the following disclaimer |
||||||
|
// in the documentation and/or other materials provided with the |
||||||
|
// distribution. |
||||||
|
// * Neither the name of Google Inc. nor the names of its |
||||||
|
// contributors may be used to endorse or promote products derived from |
||||||
|
// this software without specific prior written permission. |
||||||
|
// |
||||||
|
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||||
|
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||||
|
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||||
|
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||||
|
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||||
|
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||||
|
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||||
|
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||||
|
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||||
|
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||||
|
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||||
|
|
||||||
|
#endregion |
||||||
|
|
||||||
|
using System; |
||||||
|
using System.Collections.Generic; |
||||||
|
using System.Diagnostics; |
||||||
|
using System.Linq; |
||||||
|
using System.Threading; |
||||||
|
using System.Threading.Tasks; |
||||||
|
|
||||||
|
using CommandLine; |
||||||
|
using CommandLine.Text; |
||||||
|
using Grpc.Core; |
||||||
|
using Grpc.Core.Logging; |
||||||
|
using Grpc.Core.Utils; |
||||||
|
using Grpc.Testing; |
||||||
|
|
||||||
|
namespace Grpc.IntegrationTesting |
||||||
|
{ |
||||||
|
public class StressTestClient |
||||||
|
{ |
||||||
|
static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<StressTestClient>(); |
||||||
|
const double SecondsToNanos = 1e9; |
||||||
|
|
||||||
|
private class ClientOptions |
||||||
|
{ |
||||||
|
[Option("server_addresses", DefaultValue = "localhost:8080")] |
||||||
|
public string ServerAddresses { get; set; } |
||||||
|
|
||||||
|
[Option("test_cases", DefaultValue = "large_unary:100")] |
||||||
|
public string TestCases { get; set; } |
||||||
|
|
||||||
|
[Option("test_duration_secs", DefaultValue = -1)] |
||||||
|
public int TestDurationSecs { get; set; } |
||||||
|
|
||||||
|
[Option("num_channels_per_server", DefaultValue = 1)] |
||||||
|
public int NumChannelsPerServer { get; set; } |
||||||
|
|
||||||
|
[Option("num_stubs_per_channel", DefaultValue = 1)] |
||||||
|
public int NumStubsPerChannel { get; set; } |
||||||
|
|
||||||
|
[Option("metrics_port", DefaultValue = 8081)] |
||||||
|
public int MetricsPort { get; set; } |
||||||
|
|
||||||
|
[HelpOption] |
||||||
|
public string GetUsage() |
||||||
|
{ |
||||||
|
var help = new HelpText |
||||||
|
{ |
||||||
|
Heading = "gRPC C# stress test client", |
||||||
|
AddDashesToOption = true |
||||||
|
}; |
||||||
|
help.AddPreOptionsLine("Usage:"); |
||||||
|
help.AddOptions(this); |
||||||
|
return help; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
ClientOptions options; |
||||||
|
List<string> serverAddresses; |
||||||
|
Dictionary<string, int> weightedTestCases; |
||||||
|
WeightedRandomGenerator testCaseGenerator; |
||||||
|
|
||||||
|
// cancellation will be emitted once test_duration_secs has elapsed. |
||||||
|
CancellationTokenSource finishedTokenSource = new CancellationTokenSource(); |
||||||
|
Histogram histogram = new Histogram(0.01, 60 * SecondsToNanos); |
||||||
|
|
||||||
|
private StressTestClient(ClientOptions options, List<string> serverAddresses, Dictionary<string, int> weightedTestCases) |
||||||
|
{ |
||||||
|
this.options = options; |
||||||
|
this.serverAddresses = serverAddresses; |
||||||
|
this.weightedTestCases = weightedTestCases; |
||||||
|
this.testCaseGenerator = new WeightedRandomGenerator(this.weightedTestCases); |
||||||
|
} |
||||||
|
|
||||||
|
public static void Run(string[] args) |
||||||
|
{ |
||||||
|
var options = new ClientOptions(); |
||||||
|
if (!Parser.Default.ParseArguments(args, options)) |
||||||
|
{ |
||||||
|
Environment.Exit(1); |
||||||
|
} |
||||||
|
|
||||||
|
GrpcPreconditions.CheckArgument(options.NumChannelsPerServer > 0); |
||||||
|
GrpcPreconditions.CheckArgument(options.NumStubsPerChannel > 0); |
||||||
|
|
||||||
|
var serverAddresses = options.ServerAddresses.Split(','); |
||||||
|
GrpcPreconditions.CheckArgument(serverAddresses.Length > 0, "You need to provide at least one server address"); |
||||||
|
|
||||||
|
var testCases = ParseWeightedTestCases(options.TestCases); |
||||||
|
GrpcPreconditions.CheckArgument(testCases.Count > 0, "You need to provide at least one test case"); |
||||||
|
|
||||||
|
var interopClient = new StressTestClient(options, serverAddresses.ToList(), testCases); |
||||||
|
interopClient.Run().Wait(); |
||||||
|
} |
||||||
|
|
||||||
|
async Task Run() |
||||||
|
{ |
||||||
|
var metricsServer = new Server() |
||||||
|
{ |
||||||
|
Services = { MetricsService.BindService(new MetricsServiceImpl(histogram)) }, |
||||||
|
Ports = { { "[::]", options.MetricsPort, ServerCredentials.Insecure } } |
||||||
|
}; |
||||||
|
metricsServer.Start(); |
||||||
|
|
||||||
|
if (options.TestDurationSecs >= 0) |
||||||
|
{ |
||||||
|
finishedTokenSource.CancelAfter(TimeSpan.FromSeconds(options.TestDurationSecs)); |
||||||
|
} |
||||||
|
|
||||||
|
var tasks = new List<Task>(); |
||||||
|
var channels = new List<Channel>(); |
||||||
|
foreach (var serverAddress in serverAddresses) |
||||||
|
{ |
||||||
|
for (int i = 0; i < options.NumChannelsPerServer; i++) |
||||||
|
{ |
||||||
|
var channel = new Channel(serverAddress, ChannelCredentials.Insecure); |
||||||
|
channels.Add(channel); |
||||||
|
for (int j = 0; j < options.NumStubsPerChannel; j++) |
||||||
|
{ |
||||||
|
var client = TestService.NewClient(channel); |
||||||
|
var task = Task.Factory.StartNew(() => RunBodyAsync(client).GetAwaiter().GetResult(), |
||||||
|
TaskCreationOptions.LongRunning); |
||||||
|
tasks.Add(task); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
await Task.WhenAll(tasks); |
||||||
|
|
||||||
|
foreach (var channel in channels) |
||||||
|
{ |
||||||
|
await channel.ShutdownAsync(); |
||||||
|
} |
||||||
|
|
||||||
|
await metricsServer.ShutdownAsync(); |
||||||
|
} |
||||||
|
|
||||||
|
async Task RunBodyAsync(TestService.TestServiceClient client) |
||||||
|
{ |
||||||
|
Logger.Info("Starting stress test client thread."); |
||||||
|
while (!finishedTokenSource.Token.IsCancellationRequested) |
||||||
|
{ |
||||||
|
var testCase = testCaseGenerator.GetNext(); |
||||||
|
|
||||||
|
var stopwatch = Stopwatch.StartNew(); |
||||||
|
|
||||||
|
await RunTestCaseAsync(client, testCase); |
||||||
|
|
||||||
|
stopwatch.Stop(); |
||||||
|
histogram.AddObservation(stopwatch.Elapsed.TotalSeconds * SecondsToNanos); |
||||||
|
} |
||||||
|
Logger.Info("Stress test client thread finished."); |
||||||
|
} |
||||||
|
|
||||||
|
async Task RunTestCaseAsync(TestService.TestServiceClient client, string testCase) |
||||||
|
{ |
||||||
|
switch (testCase) |
||||||
|
{ |
||||||
|
case "empty_unary": |
||||||
|
InteropClient.RunEmptyUnary(client); |
||||||
|
break; |
||||||
|
case "large_unary": |
||||||
|
InteropClient.RunLargeUnary(client); |
||||||
|
break; |
||||||
|
case "client_streaming": |
||||||
|
await InteropClient.RunClientStreamingAsync(client); |
||||||
|
break; |
||||||
|
case "server_streaming": |
||||||
|
await InteropClient.RunServerStreamingAsync(client); |
||||||
|
break; |
||||||
|
case "ping_pong": |
||||||
|
await InteropClient.RunPingPongAsync(client); |
||||||
|
break; |
||||||
|
case "empty_stream": |
||||||
|
await InteropClient.RunEmptyStreamAsync(client); |
||||||
|
break; |
||||||
|
case "cancel_after_begin": |
||||||
|
await InteropClient.RunCancelAfterBeginAsync(client); |
||||||
|
break; |
||||||
|
case "cancel_after_first_response": |
||||||
|
await InteropClient.RunCancelAfterFirstResponseAsync(client); |
||||||
|
break; |
||||||
|
case "timeout_on_sleeping_server": |
||||||
|
await InteropClient.RunTimeoutOnSleepingServerAsync(client); |
||||||
|
break; |
||||||
|
case "custom_metadata": |
||||||
|
await InteropClient.RunCustomMetadataAsync(client); |
||||||
|
break; |
||||||
|
case "status_code_and_message": |
||||||
|
await InteropClient.RunStatusCodeAndMessageAsync(client); |
||||||
|
break; |
||||||
|
default: |
||||||
|
throw new ArgumentException("Unsupported test case " + testCase); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
static Dictionary<string, int> ParseWeightedTestCases(string weightedTestCases) |
||||||
|
{ |
||||||
|
var result = new Dictionary<string, int>(); |
||||||
|
foreach (var weightedTestCase in weightedTestCases.Split(',')) |
||||||
|
{ |
||||||
|
var parts = weightedTestCase.Split(new char[] {':'}, 2); |
||||||
|
GrpcPreconditions.CheckArgument(parts.Length == 2, "Malformed test_cases option."); |
||||||
|
result.Add(parts[0], int.Parse(parts[1])); |
||||||
|
} |
||||||
|
return result; |
||||||
|
} |
||||||
|
|
||||||
|
class WeightedRandomGenerator |
||||||
|
{ |
||||||
|
readonly Random random = new Random(); |
||||||
|
readonly List<Tuple<int, string>> cumulativeSums; |
||||||
|
readonly int weightSum; |
||||||
|
|
||||||
|
public WeightedRandomGenerator(Dictionary<string, int> weightedItems) |
||||||
|
{ |
||||||
|
cumulativeSums = new List<Tuple<int, string>>(); |
||||||
|
weightSum = 0; |
||||||
|
foreach (var entry in weightedItems) |
||||||
|
{ |
||||||
|
weightSum += entry.Value; |
||||||
|
cumulativeSums.Add(Tuple.Create(weightSum, entry.Key)); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public string GetNext() |
||||||
|
{ |
||||||
|
int rand = random.Next(weightSum); |
||||||
|
foreach (var entry in cumulativeSums) |
||||||
|
{ |
||||||
|
if (rand < entry.Item1) |
||||||
|
{ |
||||||
|
return entry.Item2; |
||||||
|
} |
||||||
|
} |
||||||
|
throw new InvalidOperationException("GetNext() failed."); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
class MetricsServiceImpl : MetricsService.MetricsServiceBase |
||||||
|
{ |
||||||
|
const string GaugeName = "csharp_overall_qps"; |
||||||
|
|
||||||
|
readonly Histogram histogram; |
||||||
|
readonly WallClockStopwatch wallClockStopwatch = new WallClockStopwatch(); |
||||||
|
|
||||||
|
public MetricsServiceImpl(Histogram histogram) |
||||||
|
{ |
||||||
|
this.histogram = histogram; |
||||||
|
} |
||||||
|
|
||||||
|
public override Task<GaugeResponse> GetGauge(GaugeRequest request, ServerCallContext context) |
||||||
|
{ |
||||||
|
if (request.Name == GaugeName) |
||||||
|
{ |
||||||
|
long qps = GetQpsAndReset(); |
||||||
|
|
||||||
|
return Task.FromResult(new GaugeResponse |
||||||
|
{ |
||||||
|
Name = GaugeName, |
||||||
|
LongValue = qps |
||||||
|
}); |
||||||
|
} |
||||||
|
throw new RpcException(new Status(StatusCode.InvalidArgument, "Gauge does not exist")); |
||||||
|
} |
||||||
|
|
||||||
|
public override async Task GetAllGauges(EmptyMessage request, IServerStreamWriter<GaugeResponse> responseStream, ServerCallContext context) |
||||||
|
{ |
||||||
|
long qps = GetQpsAndReset(); |
||||||
|
|
||||||
|
var response = new GaugeResponse |
||||||
|
{ |
||||||
|
Name = GaugeName, |
||||||
|
LongValue = qps |
||||||
|
}; |
||||||
|
await responseStream.WriteAsync(response); |
||||||
|
} |
||||||
|
|
||||||
|
long GetQpsAndReset() |
||||||
|
{ |
||||||
|
var snapshot = histogram.GetSnapshot(true); |
||||||
|
var elapsedSnapshot = wallClockStopwatch.GetElapsedSnapshot(true); |
||||||
|
|
||||||
|
return (long) (snapshot.Count / elapsedSnapshot.Seconds); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,896 @@ |
|||||||
|
/*
|
||||||
|
* |
||||||
|
* Copyright 2016, Google Inc. |
||||||
|
* All rights reserved. |
||||||
|
* |
||||||
|
* Redistribution and use in source and binary forms, with or without |
||||||
|
* modification, are permitted provided that the following conditions are |
||||||
|
* met: |
||||||
|
* |
||||||
|
* * Redistributions of source code must retain the above copyright |
||||||
|
* notice, this list of conditions and the following disclaimer. |
||||||
|
* * Redistributions in binary form must reproduce the above |
||||||
|
* copyright notice, this list of conditions and the following disclaimer |
||||||
|
* in the documentation and/or other materials provided with the |
||||||
|
* distribution. |
||||||
|
* * Neither the name of Google Inc. nor the names of its |
||||||
|
* contributors may be used to endorse or promote products derived from |
||||||
|
* this software without specific prior written permission. |
||||||
|
* |
||||||
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||||
|
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||||
|
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||||
|
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||||
|
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||||
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||||
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||||
|
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||||
|
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||||
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||||
|
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||||
|
* |
||||||
|
*/ |
||||||
|
|
||||||
|
#include <string.h> |
||||||
|
|
||||||
|
#include <grpc/grpc.h> |
||||||
|
#include <grpc/support/alloc.h> |
||||||
|
#include <grpc/support/log.h> |
||||||
|
#include <grpc/support/string_util.h> |
||||||
|
|
||||||
|
#include "src/core/ext/transport/chttp2/transport/chttp2_transport.h" |
||||||
|
#include "src/core/lib/channel/channel_args.h" |
||||||
|
#include "src/core/lib/iomgr/resolve_address.h" |
||||||
|
#include "src/core/lib/iomgr/tcp_client.h" |
||||||
|
#include "src/core/lib/iomgr/timer.h" |
||||||
|
#include "src/core/lib/surface/server.h" |
||||||
|
#include "src/core/lib/transport/metadata.h" |
||||||
|
#include "test/core/util/passthru_endpoint.h" |
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
// logging
|
||||||
|
|
||||||
|
static const bool squelch = true; |
||||||
|
|
||||||
|
static void dont_log(gpr_log_func_args *args) {} |
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
// input_stream: allows easy access to input bytes, and allows reading a little
|
||||||
|
// past the end (avoiding needing to check everywhere)
|
||||||
|
|
||||||
|
typedef struct { |
||||||
|
const uint8_t *cur; |
||||||
|
const uint8_t *end; |
||||||
|
} input_stream; |
||||||
|
|
||||||
|
static uint8_t next_byte(input_stream *inp) { |
||||||
|
if (inp->cur == inp->end) { |
||||||
|
return 0; |
||||||
|
} |
||||||
|
return *inp->cur++; |
||||||
|
} |
||||||
|
|
||||||
|
static void end(input_stream *inp) { inp->cur = inp->end; } |
||||||
|
|
||||||
|
static char *read_string(input_stream *inp) { |
||||||
|
char *str = NULL; |
||||||
|
size_t cap = 0; |
||||||
|
size_t sz = 0; |
||||||
|
char c; |
||||||
|
do { |
||||||
|
if (cap == sz) { |
||||||
|
cap = GPR_MAX(3 * cap / 2, cap + 8); |
||||||
|
str = gpr_realloc(str, cap); |
||||||
|
} |
||||||
|
c = (char)next_byte(inp); |
||||||
|
str[sz++] = c; |
||||||
|
} while (c != 0); |
||||||
|
return str; |
||||||
|
} |
||||||
|
|
||||||
|
static void read_buffer(input_stream *inp, char **buffer, size_t *length) { |
||||||
|
*length = next_byte(inp); |
||||||
|
*buffer = gpr_malloc(*length); |
||||||
|
for (size_t i = 0; i < *length; i++) { |
||||||
|
(*buffer)[i] = (char)next_byte(inp); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
static uint32_t read_uint22(input_stream *inp) { |
||||||
|
uint8_t b = next_byte(inp); |
||||||
|
uint32_t x = b & 0x7f; |
||||||
|
if (b & 0x80) { |
||||||
|
x <<= 7; |
||||||
|
b = next_byte(inp); |
||||||
|
x |= b & 0x7f; |
||||||
|
if (b & 0x80) { |
||||||
|
x <<= 8; |
||||||
|
x |= next_byte(inp); |
||||||
|
} |
||||||
|
} |
||||||
|
return x; |
||||||
|
} |
||||||
|
|
||||||
|
static uint32_t read_uint32(input_stream *inp) { |
||||||
|
uint8_t b = next_byte(inp); |
||||||
|
uint32_t x = b & 0x7f; |
||||||
|
if (b & 0x80) { |
||||||
|
x <<= 7; |
||||||
|
b = next_byte(inp); |
||||||
|
x |= b & 0x7f; |
||||||
|
if (b & 0x80) { |
||||||
|
x <<= 7; |
||||||
|
b = next_byte(inp); |
||||||
|
x |= b & 0x7f; |
||||||
|
if (b & 0x80) { |
||||||
|
x <<= 7; |
||||||
|
b = next_byte(inp); |
||||||
|
x |= b & 0x7f; |
||||||
|
if (b & 0x80) { |
||||||
|
x = (x << 4) | (next_byte(inp) & 0x0f); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
return x; |
||||||
|
} |
||||||
|
|
||||||
|
static grpc_byte_buffer *read_message(input_stream *inp) { |
||||||
|
gpr_slice slice = gpr_slice_malloc(read_uint22(inp)); |
||||||
|
memset(GPR_SLICE_START_PTR(slice), 0, GPR_SLICE_LENGTH(slice)); |
||||||
|
grpc_byte_buffer *out = grpc_raw_byte_buffer_create(&slice, 1); |
||||||
|
gpr_slice_unref(slice); |
||||||
|
return out; |
||||||
|
} |
||||||
|
|
||||||
|
static int read_int(input_stream *inp) { return (int)read_uint32(inp); } |
||||||
|
|
||||||
|
static grpc_channel_args *read_args(input_stream *inp) { |
||||||
|
size_t n = next_byte(inp); |
||||||
|
grpc_arg *args = gpr_malloc(sizeof(*args) * n); |
||||||
|
for (size_t i = 0; i < n; i++) { |
||||||
|
bool is_string = next_byte(inp) & 1; |
||||||
|
args[i].type = is_string ? GRPC_ARG_STRING : GRPC_ARG_INTEGER; |
||||||
|
args[i].key = read_string(inp); |
||||||
|
if (is_string) { |
||||||
|
args[i].value.string = read_string(inp); |
||||||
|
} else { |
||||||
|
args[i].value.integer = read_int(inp); |
||||||
|
} |
||||||
|
} |
||||||
|
grpc_channel_args *a = gpr_malloc(sizeof(*a)); |
||||||
|
a->args = args; |
||||||
|
a->num_args = n; |
||||||
|
return a; |
||||||
|
} |
||||||
|
|
||||||
|
static bool is_eof(input_stream *inp) { return inp->cur == inp->end; } |
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
// global state
|
||||||
|
|
||||||
|
static gpr_timespec g_now; |
||||||
|
static grpc_server *g_server; |
||||||
|
static grpc_channel *g_channel; |
||||||
|
|
||||||
|
extern gpr_timespec (*gpr_now_impl)(gpr_clock_type clock_type); |
||||||
|
|
||||||
|
static gpr_timespec now_impl(gpr_clock_type clock_type) { |
||||||
|
GPR_ASSERT(clock_type != GPR_TIMESPAN); |
||||||
|
return g_now; |
||||||
|
} |
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
// dns resolution
|
||||||
|
|
||||||
|
typedef struct addr_req { |
||||||
|
grpc_timer timer; |
||||||
|
char *addr; |
||||||
|
grpc_resolve_cb cb; |
||||||
|
void *arg; |
||||||
|
} addr_req; |
||||||
|
|
||||||
|
static void finish_resolve(grpc_exec_ctx *exec_ctx, void *arg, bool success) { |
||||||
|
addr_req *r = arg; |
||||||
|
|
||||||
|
if (success && 0 == strcmp(r->addr, "server")) { |
||||||
|
grpc_resolved_addresses *addrs = gpr_malloc(sizeof(*addrs)); |
||||||
|
addrs->naddrs = 1; |
||||||
|
addrs->addrs = gpr_malloc(sizeof(*addrs->addrs)); |
||||||
|
addrs->addrs[0].len = 0; |
||||||
|
r->cb(exec_ctx, r->arg, addrs); |
||||||
|
} else { |
||||||
|
r->cb(exec_ctx, r->arg, NULL); |
||||||
|
} |
||||||
|
|
||||||
|
gpr_free(r->addr); |
||||||
|
gpr_free(r); |
||||||
|
} |
||||||
|
|
||||||
|
void my_resolve_address(grpc_exec_ctx *exec_ctx, const char *addr, |
||||||
|
const char *default_port, grpc_resolve_cb cb, |
||||||
|
void *arg) { |
||||||
|
addr_req *r = gpr_malloc(sizeof(*r)); |
||||||
|
r->addr = gpr_strdup(addr); |
||||||
|
r->cb = cb; |
||||||
|
r->arg = arg; |
||||||
|
grpc_timer_init(exec_ctx, &r->timer, |
||||||
|
gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC), |
||||||
|
gpr_time_from_seconds(1, GPR_TIMESPAN)), |
||||||
|
finish_resolve, r, gpr_now(GPR_CLOCK_MONOTONIC)); |
||||||
|
} |
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
// client connection
|
||||||
|
|
||||||
|
// defined in tcp_client_posix.c
|
||||||
|
extern void (*grpc_tcp_client_connect_impl)( |
||||||
|
grpc_exec_ctx *exec_ctx, grpc_closure *closure, grpc_endpoint **ep, |
||||||
|
grpc_pollset_set *interested_parties, const struct sockaddr *addr, |
||||||
|
size_t addr_len, gpr_timespec deadline); |
||||||
|
|
||||||
|
static void sched_connect(grpc_exec_ctx *exec_ctx, grpc_closure *closure, |
||||||
|
grpc_endpoint **ep, gpr_timespec deadline); |
||||||
|
|
||||||
|
typedef struct { |
||||||
|
grpc_timer timer; |
||||||
|
grpc_closure *closure; |
||||||
|
grpc_endpoint **ep; |
||||||
|
gpr_timespec deadline; |
||||||
|
} future_connect; |
||||||
|
|
||||||
|
static void do_connect(grpc_exec_ctx *exec_ctx, void *arg, bool success) { |
||||||
|
future_connect *fc = arg; |
||||||
|
if (!success) { |
||||||
|
*fc->ep = NULL; |
||||||
|
grpc_exec_ctx_enqueue(exec_ctx, fc->closure, false, NULL); |
||||||
|
} else if (g_server != NULL) { |
||||||
|
grpc_endpoint *client; |
||||||
|
grpc_endpoint *server; |
||||||
|
grpc_passthru_endpoint_create(&client, &server); |
||||||
|
*fc->ep = client; |
||||||
|
|
||||||
|
grpc_transport *transport = |
||||||
|
grpc_create_chttp2_transport(exec_ctx, NULL, server, 0); |
||||||
|
grpc_server_setup_transport(exec_ctx, g_server, transport, NULL); |
||||||
|
grpc_chttp2_transport_start_reading(exec_ctx, transport, NULL, 0); |
||||||
|
|
||||||
|
grpc_exec_ctx_enqueue(exec_ctx, fc->closure, false, NULL); |
||||||
|
} else { |
||||||
|
sched_connect(exec_ctx, fc->closure, fc->ep, fc->deadline); |
||||||
|
} |
||||||
|
gpr_free(fc); |
||||||
|
} |
||||||
|
|
||||||
|
static void sched_connect(grpc_exec_ctx *exec_ctx, grpc_closure *closure, |
||||||
|
grpc_endpoint **ep, gpr_timespec deadline) { |
||||||
|
if (gpr_time_cmp(deadline, gpr_now(deadline.clock_type)) < 0) { |
||||||
|
*ep = NULL; |
||||||
|
grpc_exec_ctx_enqueue(exec_ctx, closure, false, NULL); |
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
future_connect *fc = gpr_malloc(sizeof(*fc)); |
||||||
|
fc->closure = closure; |
||||||
|
fc->ep = ep; |
||||||
|
fc->deadline = deadline; |
||||||
|
grpc_timer_init(exec_ctx, &fc->timer, |
||||||
|
gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC), |
||||||
|
gpr_time_from_millis(1, GPR_TIMESPAN)), |
||||||
|
do_connect, fc, gpr_now(GPR_CLOCK_MONOTONIC)); |
||||||
|
} |
||||||
|
|
||||||
|
static void my_tcp_client_connect(grpc_exec_ctx *exec_ctx, |
||||||
|
grpc_closure *closure, grpc_endpoint **ep, |
||||||
|
grpc_pollset_set *interested_parties, |
||||||
|
const struct sockaddr *addr, size_t addr_len, |
||||||
|
gpr_timespec deadline) { |
||||||
|
sched_connect(exec_ctx, closure, ep, deadline); |
||||||
|
} |
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
// test driver
|
||||||
|
|
||||||
|
typedef struct validator { |
||||||
|
void (*validate)(void *arg, bool success); |
||||||
|
void *arg; |
||||||
|
} validator; |
||||||
|
|
||||||
|
static validator *create_validator(void (*validate)(void *arg, bool success), |
||||||
|
void *arg) { |
||||||
|
validator *v = gpr_malloc(sizeof(*v)); |
||||||
|
v->validate = validate; |
||||||
|
v->arg = arg; |
||||||
|
return v; |
||||||
|
} |
||||||
|
|
||||||
|
static void assert_success_and_decrement(void *counter, bool success) { |
||||||
|
GPR_ASSERT(success); |
||||||
|
--*(int *)counter; |
||||||
|
} |
||||||
|
|
||||||
|
static void decrement(void *counter, bool success) { --*(int *)counter; } |
||||||
|
|
||||||
|
typedef struct connectivity_watch { |
||||||
|
int *counter; |
||||||
|
gpr_timespec deadline; |
||||||
|
} connectivity_watch; |
||||||
|
|
||||||
|
static connectivity_watch *make_connectivity_watch(gpr_timespec s, |
||||||
|
int *counter) { |
||||||
|
connectivity_watch *o = gpr_malloc(sizeof(*o)); |
||||||
|
o->deadline = s; |
||||||
|
o->counter = counter; |
||||||
|
return o; |
||||||
|
} |
||||||
|
|
||||||
|
static void validate_connectivity_watch(void *p, bool success) { |
||||||
|
connectivity_watch *w = p; |
||||||
|
if (!success) { |
||||||
|
GPR_ASSERT(gpr_time_cmp(gpr_now(w->deadline.clock_type), w->deadline) >= 0); |
||||||
|
} |
||||||
|
--*w->counter; |
||||||
|
gpr_free(w); |
||||||
|
} |
||||||
|
|
||||||
|
static void free_non_null(void *p) { |
||||||
|
GPR_ASSERT(p != NULL); |
||||||
|
gpr_free(p); |
||||||
|
} |
||||||
|
|
||||||
|
typedef enum { ROOT, CLIENT, SERVER, PENDING_SERVER } call_state_type; |
||||||
|
|
||||||
|
typedef struct call_state { |
||||||
|
call_state_type type; |
||||||
|
grpc_call *call; |
||||||
|
grpc_byte_buffer *recv_message; |
||||||
|
grpc_status_code status; |
||||||
|
grpc_metadata_array recv_initial_metadata; |
||||||
|
grpc_metadata_array recv_trailing_metadata; |
||||||
|
char *recv_status_details; |
||||||
|
size_t recv_status_details_capacity; |
||||||
|
int cancelled; |
||||||
|
int pending_ops; |
||||||
|
grpc_call_details call_details; |
||||||
|
|
||||||
|
// array of pointers to free later
|
||||||
|
size_t num_to_free; |
||||||
|
size_t cap_to_free; |
||||||
|
void **to_free; |
||||||
|
|
||||||
|
struct call_state *next; |
||||||
|
struct call_state *prev; |
||||||
|
} call_state; |
||||||
|
|
||||||
|
static call_state *g_active_call; |
||||||
|
|
||||||
|
static call_state *new_call(call_state *sibling, call_state_type type) { |
||||||
|
call_state *c = gpr_malloc(sizeof(*c)); |
||||||
|
memset(c, 0, sizeof(*c)); |
||||||
|
if (sibling != NULL) { |
||||||
|
c->next = sibling; |
||||||
|
c->prev = sibling->prev; |
||||||
|
c->next->prev = c->prev->next = c; |
||||||
|
} else { |
||||||
|
c->next = c->prev = c; |
||||||
|
} |
||||||
|
c->type = type; |
||||||
|
return c; |
||||||
|
} |
||||||
|
|
||||||
|
static call_state *maybe_delete_call_state(call_state *call) { |
||||||
|
call_state *next = call->next; |
||||||
|
|
||||||
|
if (call->call != NULL) return next; |
||||||
|
if (call->pending_ops != 0) return next; |
||||||
|
|
||||||
|
if (call == g_active_call) { |
||||||
|
g_active_call = call->next; |
||||||
|
GPR_ASSERT(call != g_active_call); |
||||||
|
} |
||||||
|
|
||||||
|
call->prev->next = call->next; |
||||||
|
call->next->prev = call->prev; |
||||||
|
grpc_metadata_array_destroy(&call->recv_initial_metadata); |
||||||
|
grpc_metadata_array_destroy(&call->recv_trailing_metadata); |
||||||
|
gpr_free(call->recv_status_details); |
||||||
|
grpc_call_details_destroy(&call->call_details); |
||||||
|
|
||||||
|
for (size_t i = 0; i < call->num_to_free; i++) { |
||||||
|
gpr_free(call->to_free[i]); |
||||||
|
} |
||||||
|
gpr_free(call->to_free); |
||||||
|
|
||||||
|
gpr_free(call); |
||||||
|
|
||||||
|
return next; |
||||||
|
} |
||||||
|
|
||||||
|
static void add_to_free(call_state *call, void *p) { |
||||||
|
if (call->num_to_free == call->cap_to_free) { |
||||||
|
call->cap_to_free = GPR_MAX(8, 2 * call->cap_to_free); |
||||||
|
call->to_free = |
||||||
|
gpr_realloc(call->to_free, sizeof(*call->to_free) * call->cap_to_free); |
||||||
|
} |
||||||
|
call->to_free[call->num_to_free++] = p; |
||||||
|
} |
||||||
|
|
||||||
|
static void read_metadata(input_stream *inp, size_t *count, |
||||||
|
grpc_metadata **metadata, call_state *cs) { |
||||||
|
*count = next_byte(inp); |
||||||
|
*metadata = gpr_malloc(*count * sizeof(**metadata)); |
||||||
|
memset(*metadata, 0, *count * sizeof(**metadata)); |
||||||
|
for (size_t i = 0; i < *count; i++) { |
||||||
|
(*metadata)[i].key = read_string(inp); |
||||||
|
read_buffer(inp, (char **)&(*metadata)[i].value, |
||||||
|
&(*metadata)[i].value_length); |
||||||
|
(*metadata)[i].flags = read_uint32(inp); |
||||||
|
add_to_free(cs, (void *)(*metadata)[i].key); |
||||||
|
add_to_free(cs, (void *)(*metadata)[i].value); |
||||||
|
} |
||||||
|
add_to_free(cs, *metadata); |
||||||
|
} |
||||||
|
|
||||||
|
static call_state *destroy_call(call_state *call) { |
||||||
|
grpc_call_destroy(call->call); |
||||||
|
call->call = NULL; |
||||||
|
return maybe_delete_call_state(call); |
||||||
|
} |
||||||
|
|
||||||
|
static void finished_request_call(void *csp, bool success) { |
||||||
|
call_state *cs = csp; |
||||||
|
GPR_ASSERT(cs->pending_ops > 0); |
||||||
|
--cs->pending_ops; |
||||||
|
if (success) { |
||||||
|
GPR_ASSERT(cs->call != NULL); |
||||||
|
cs->type = SERVER; |
||||||
|
} else { |
||||||
|
maybe_delete_call_state(cs); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
static void finished_batch(void *csp, bool success) { |
||||||
|
call_state *cs = csp; |
||||||
|
--cs->pending_ops; |
||||||
|
maybe_delete_call_state(cs); |
||||||
|
} |
||||||
|
|
||||||
|
int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) { |
||||||
|
grpc_test_only_set_metadata_hash_seed(0); |
||||||
|
if (squelch) gpr_set_log_function(dont_log); |
||||||
|
input_stream inp = {data, data + size}; |
||||||
|
grpc_resolve_address = my_resolve_address; |
||||||
|
grpc_tcp_client_connect_impl = my_tcp_client_connect; |
||||||
|
gpr_now_impl = now_impl; |
||||||
|
grpc_init(); |
||||||
|
|
||||||
|
GPR_ASSERT(g_channel == NULL); |
||||||
|
GPR_ASSERT(g_server == NULL); |
||||||
|
|
||||||
|
bool server_shutdown = false; |
||||||
|
int pending_server_shutdowns = 0; |
||||||
|
int pending_channel_watches = 0; |
||||||
|
int pending_pings = 0; |
||||||
|
|
||||||
|
g_active_call = new_call(NULL, ROOT); |
||||||
|
|
||||||
|
grpc_completion_queue *cq = grpc_completion_queue_create(NULL); |
||||||
|
|
||||||
|
while (!is_eof(&inp) || g_channel != NULL || g_server != NULL || |
||||||
|
pending_channel_watches > 0 || pending_pings > 0 || |
||||||
|
g_active_call->type != ROOT || g_active_call->next != g_active_call) { |
||||||
|
if (is_eof(&inp)) { |
||||||
|
if (g_channel != NULL) { |
||||||
|
grpc_channel_destroy(g_channel); |
||||||
|
g_channel = NULL; |
||||||
|
} |
||||||
|
if (g_server != NULL) { |
||||||
|
if (!server_shutdown) { |
||||||
|
grpc_server_shutdown_and_notify( |
||||||
|
g_server, cq, create_validator(assert_success_and_decrement, |
||||||
|
&pending_server_shutdowns)); |
||||||
|
server_shutdown = true; |
||||||
|
pending_server_shutdowns++; |
||||||
|
} else if (pending_server_shutdowns == 0) { |
||||||
|
grpc_server_destroy(g_server); |
||||||
|
g_server = NULL; |
||||||
|
} |
||||||
|
} |
||||||
|
call_state *s = g_active_call; |
||||||
|
do { |
||||||
|
if (s->type != PENDING_SERVER && s->call != NULL) { |
||||||
|
s = destroy_call(s); |
||||||
|
} else { |
||||||
|
s = s->next; |
||||||
|
} |
||||||
|
} while (s != g_active_call); |
||||||
|
|
||||||
|
g_now = gpr_time_add(g_now, gpr_time_from_seconds(1, GPR_TIMESPAN)); |
||||||
|
} |
||||||
|
|
||||||
|
switch (next_byte(&inp)) { |
||||||
|
// terminate on bad bytes
|
||||||
|
default: |
||||||
|
end(&inp); |
||||||
|
break; |
||||||
|
// tickle completion queue
|
||||||
|
case 0: { |
||||||
|
grpc_event ev = grpc_completion_queue_next( |
||||||
|
cq, gpr_inf_past(GPR_CLOCK_REALTIME), NULL); |
||||||
|
switch (ev.type) { |
||||||
|
case GRPC_OP_COMPLETE: { |
||||||
|
validator *v = ev.tag; |
||||||
|
v->validate(v->arg, ev.success); |
||||||
|
gpr_free(v); |
||||||
|
break; |
||||||
|
} |
||||||
|
case GRPC_QUEUE_TIMEOUT: |
||||||
|
break; |
||||||
|
case GRPC_QUEUE_SHUTDOWN: |
||||||
|
abort(); |
||||||
|
break; |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// increment global time
|
||||||
|
case 1: { |
||||||
|
g_now = gpr_time_add( |
||||||
|
g_now, gpr_time_from_micros(read_uint32(&inp), GPR_TIMESPAN)); |
||||||
|
break; |
||||||
|
} |
||||||
|
// create an insecure channel
|
||||||
|
case 2: { |
||||||
|
if (g_channel == NULL) { |
||||||
|
char *target = read_string(&inp); |
||||||
|
char *target_uri; |
||||||
|
gpr_asprintf(&target_uri, "dns:%s", target); |
||||||
|
grpc_channel_args *args = read_args(&inp); |
||||||
|
g_channel = grpc_insecure_channel_create(target_uri, args, NULL); |
||||||
|
GPR_ASSERT(g_channel != NULL); |
||||||
|
grpc_channel_args_destroy(args); |
||||||
|
gpr_free(target_uri); |
||||||
|
gpr_free(target); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// destroy a channel
|
||||||
|
case 3: { |
||||||
|
if (g_channel != NULL) { |
||||||
|
grpc_channel_destroy(g_channel); |
||||||
|
g_channel = NULL; |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// bring up a server
|
||||||
|
case 4: { |
||||||
|
if (g_server == NULL) { |
||||||
|
grpc_channel_args *args = read_args(&inp); |
||||||
|
g_server = grpc_server_create(args, NULL); |
||||||
|
GPR_ASSERT(g_server != NULL); |
||||||
|
grpc_channel_args_destroy(args); |
||||||
|
grpc_server_register_completion_queue(g_server, cq, NULL); |
||||||
|
grpc_server_start(g_server); |
||||||
|
server_shutdown = false; |
||||||
|
GPR_ASSERT(pending_server_shutdowns == 0); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
} |
||||||
|
// begin server shutdown
|
||||||
|
case 5: { |
||||||
|
if (g_server != NULL) { |
||||||
|
grpc_server_shutdown_and_notify( |
||||||
|
g_server, cq, create_validator(assert_success_and_decrement, |
||||||
|
&pending_server_shutdowns)); |
||||||
|
pending_server_shutdowns++; |
||||||
|
server_shutdown = true; |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// cancel all calls if shutdown
|
||||||
|
case 6: { |
||||||
|
if (g_server != NULL && server_shutdown) { |
||||||
|
grpc_server_cancel_all_calls(g_server); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// destroy server
|
||||||
|
case 7: { |
||||||
|
if (g_server != NULL && server_shutdown && |
||||||
|
pending_server_shutdowns == 0) { |
||||||
|
grpc_server_destroy(g_server); |
||||||
|
g_server = NULL; |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// check connectivity
|
||||||
|
case 8: { |
||||||
|
if (g_channel != NULL) { |
||||||
|
uint8_t try_to_connect = next_byte(&inp); |
||||||
|
if (try_to_connect == 0 || try_to_connect == 1) { |
||||||
|
grpc_channel_check_connectivity_state(g_channel, try_to_connect); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// watch connectivity
|
||||||
|
case 9: { |
||||||
|
if (g_channel != NULL) { |
||||||
|
grpc_connectivity_state st = |
||||||
|
grpc_channel_check_connectivity_state(g_channel, 0); |
||||||
|
if (st != GRPC_CHANNEL_FATAL_FAILURE) { |
||||||
|
gpr_timespec deadline = gpr_time_add( |
||||||
|
gpr_now(GPR_CLOCK_REALTIME), |
||||||
|
gpr_time_from_micros(read_uint32(&inp), GPR_TIMESPAN)); |
||||||
|
grpc_channel_watch_connectivity_state( |
||||||
|
g_channel, st, deadline, cq, |
||||||
|
create_validator(validate_connectivity_watch, |
||||||
|
make_connectivity_watch( |
||||||
|
deadline, &pending_channel_watches))); |
||||||
|
pending_channel_watches++; |
||||||
|
} |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// create a call
|
||||||
|
case 10: { |
||||||
|
bool ok = true; |
||||||
|
if (g_channel == NULL) ok = false; |
||||||
|
grpc_call *parent_call = NULL; |
||||||
|
if (g_active_call->type != ROOT) { |
||||||
|
if (g_active_call->call == NULL || g_active_call->type == CLIENT) { |
||||||
|
end(&inp); |
||||||
|
break; |
||||||
|
} |
||||||
|
parent_call = g_active_call->call; |
||||||
|
} |
||||||
|
uint32_t propagation_mask = read_uint32(&inp); |
||||||
|
char *method = read_string(&inp); |
||||||
|
char *host = read_string(&inp); |
||||||
|
gpr_timespec deadline = |
||||||
|
gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), |
||||||
|
gpr_time_from_micros(read_uint32(&inp), GPR_TIMESPAN)); |
||||||
|
|
||||||
|
if (ok) { |
||||||
|
call_state *cs = new_call(g_active_call, CLIENT); |
||||||
|
cs->call = |
||||||
|
grpc_channel_create_call(g_channel, parent_call, propagation_mask, |
||||||
|
cq, method, host, deadline, NULL); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
gpr_free(method); |
||||||
|
gpr_free(host); |
||||||
|
break; |
||||||
|
} |
||||||
|
// switch the 'current' call
|
||||||
|
case 11: { |
||||||
|
g_active_call = g_active_call->next; |
||||||
|
break; |
||||||
|
} |
||||||
|
// queue some ops on a call
|
||||||
|
case 12: { |
||||||
|
if (g_active_call->type == PENDING_SERVER || |
||||||
|
g_active_call->type == ROOT || g_active_call->call == NULL) { |
||||||
|
end(&inp); |
||||||
|
break; |
||||||
|
} |
||||||
|
size_t num_ops = next_byte(&inp); |
||||||
|
if (num_ops > 6) { |
||||||
|
end(&inp); |
||||||
|
break; |
||||||
|
} |
||||||
|
grpc_op *ops = gpr_malloc(sizeof(grpc_op) * num_ops); |
||||||
|
bool ok = true; |
||||||
|
size_t i; |
||||||
|
grpc_op *op; |
||||||
|
for (i = 0; i < num_ops; i++) { |
||||||
|
op = &ops[i]; |
||||||
|
switch (next_byte(&inp)) { |
||||||
|
default: |
||||||
|
/* invalid value */ |
||||||
|
op->op = (grpc_op_type)-1; |
||||||
|
ok = false; |
||||||
|
break; |
||||||
|
case GRPC_OP_SEND_INITIAL_METADATA: |
||||||
|
op->op = GRPC_OP_SEND_INITIAL_METADATA; |
||||||
|
read_metadata(&inp, &op->data.send_initial_metadata.count, |
||||||
|
&op->data.send_initial_metadata.metadata, |
||||||
|
g_active_call); |
||||||
|
break; |
||||||
|
case GRPC_OP_SEND_MESSAGE: |
||||||
|
op->op = GRPC_OP_SEND_MESSAGE; |
||||||
|
op->data.send_message = read_message(&inp); |
||||||
|
break; |
||||||
|
case GRPC_OP_SEND_CLOSE_FROM_CLIENT: |
||||||
|
op->op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; |
||||||
|
break; |
||||||
|
case GRPC_OP_SEND_STATUS_FROM_SERVER: |
||||||
|
op->op = GRPC_OP_SEND_STATUS_FROM_SERVER; |
||||||
|
read_metadata( |
||||||
|
&inp, |
||||||
|
&op->data.send_status_from_server.trailing_metadata_count, |
||||||
|
&op->data.send_status_from_server.trailing_metadata, |
||||||
|
g_active_call); |
||||||
|
op->data.send_status_from_server.status = next_byte(&inp); |
||||||
|
op->data.send_status_from_server.status_details = |
||||||
|
read_string(&inp); |
||||||
|
break; |
||||||
|
case GRPC_OP_RECV_INITIAL_METADATA: |
||||||
|
op->op = GRPC_OP_RECV_INITIAL_METADATA; |
||||||
|
op->data.recv_initial_metadata = |
||||||
|
&g_active_call->recv_initial_metadata; |
||||||
|
break; |
||||||
|
case GRPC_OP_RECV_MESSAGE: |
||||||
|
op->op = GRPC_OP_RECV_MESSAGE; |
||||||
|
op->data.recv_message = &g_active_call->recv_message; |
||||||
|
break; |
||||||
|
case GRPC_OP_RECV_STATUS_ON_CLIENT: |
||||||
|
op->op = GRPC_OP_RECV_STATUS_ON_CLIENT; |
||||||
|
op->data.recv_status_on_client.status = &g_active_call->status; |
||||||
|
op->data.recv_status_on_client.trailing_metadata = |
||||||
|
&g_active_call->recv_trailing_metadata; |
||||||
|
op->data.recv_status_on_client.status_details = |
||||||
|
&g_active_call->recv_status_details; |
||||||
|
op->data.recv_status_on_client.status_details_capacity = |
||||||
|
&g_active_call->recv_status_details_capacity; |
||||||
|
break; |
||||||
|
case GRPC_OP_RECV_CLOSE_ON_SERVER: |
||||||
|
op->op = GRPC_OP_RECV_CLOSE_ON_SERVER; |
||||||
|
op->data.recv_close_on_server.cancelled = |
||||||
|
&g_active_call->cancelled; |
||||||
|
break; |
||||||
|
} |
||||||
|
op->reserved = NULL; |
||||||
|
op->flags = read_uint32(&inp); |
||||||
|
} |
||||||
|
if (ok) { |
||||||
|
validator *v = create_validator(finished_batch, g_active_call); |
||||||
|
g_active_call->pending_ops++; |
||||||
|
grpc_call_error error = |
||||||
|
grpc_call_start_batch(g_active_call->call, ops, num_ops, v, NULL); |
||||||
|
if (error != GRPC_CALL_OK) { |
||||||
|
v->validate(v->arg, false); |
||||||
|
gpr_free(v); |
||||||
|
} |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
for (i = 0; i < num_ops; i++) { |
||||||
|
op = &ops[i]; |
||||||
|
switch (op->op) { |
||||||
|
case GRPC_OP_SEND_INITIAL_METADATA: |
||||||
|
break; |
||||||
|
case GRPC_OP_SEND_MESSAGE: |
||||||
|
grpc_byte_buffer_destroy(op->data.send_message); |
||||||
|
break; |
||||||
|
case GRPC_OP_SEND_STATUS_FROM_SERVER: |
||||||
|
gpr_free((void *)op->data.send_status_from_server.status_details); |
||||||
|
break; |
||||||
|
case GRPC_OP_SEND_CLOSE_FROM_CLIENT: |
||||||
|
case GRPC_OP_RECV_INITIAL_METADATA: |
||||||
|
case GRPC_OP_RECV_MESSAGE: |
||||||
|
case GRPC_OP_RECV_STATUS_ON_CLIENT: |
||||||
|
case GRPC_OP_RECV_CLOSE_ON_SERVER: |
||||||
|
break; |
||||||
|
} |
||||||
|
} |
||||||
|
gpr_free(ops); |
||||||
|
|
||||||
|
break; |
||||||
|
} |
||||||
|
// cancel current call
|
||||||
|
case 13: { |
||||||
|
if (g_active_call->type != ROOT && g_active_call->call != NULL) { |
||||||
|
grpc_call_cancel(g_active_call->call, NULL); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// get a calls peer
|
||||||
|
case 14: { |
||||||
|
if (g_active_call->type != ROOT && g_active_call->call != NULL) { |
||||||
|
free_non_null(grpc_call_get_peer(g_active_call->call)); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// get a channels target
|
||||||
|
case 15: { |
||||||
|
if (g_channel != NULL) { |
||||||
|
free_non_null(grpc_channel_get_target(g_channel)); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// send a ping on a channel
|
||||||
|
case 16: { |
||||||
|
if (g_channel != NULL) { |
||||||
|
pending_pings++; |
||||||
|
grpc_channel_ping(g_channel, cq, |
||||||
|
create_validator(decrement, &pending_pings), NULL); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// enable a tracer
|
||||||
|
case 17: { |
||||||
|
char *tracer = read_string(&inp); |
||||||
|
grpc_tracer_set_enabled(tracer, 1); |
||||||
|
gpr_free(tracer); |
||||||
|
break; |
||||||
|
} |
||||||
|
// disable a tracer
|
||||||
|
case 18: { |
||||||
|
char *tracer = read_string(&inp); |
||||||
|
grpc_tracer_set_enabled(tracer, 0); |
||||||
|
gpr_free(tracer); |
||||||
|
break; |
||||||
|
} |
||||||
|
// request a server call
|
||||||
|
case 19: { |
||||||
|
if (g_server == NULL) { |
||||||
|
end(&inp); |
||||||
|
break; |
||||||
|
} |
||||||
|
call_state *cs = new_call(g_active_call, PENDING_SERVER); |
||||||
|
cs->pending_ops++; |
||||||
|
validator *v = create_validator(finished_request_call, cs); |
||||||
|
grpc_call_error error = |
||||||
|
grpc_server_request_call(g_server, &cs->call, &cs->call_details, |
||||||
|
&cs->recv_initial_metadata, cq, cq, v); |
||||||
|
if (error != GRPC_CALL_OK) { |
||||||
|
v->validate(v->arg, false); |
||||||
|
gpr_free(v); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
// destroy a call
|
||||||
|
case 20: { |
||||||
|
if (g_active_call->type != ROOT && |
||||||
|
g_active_call->type != PENDING_SERVER && |
||||||
|
g_active_call->call != NULL) { |
||||||
|
destroy_call(g_active_call); |
||||||
|
} else { |
||||||
|
end(&inp); |
||||||
|
} |
||||||
|
break; |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
GPR_ASSERT(g_channel == NULL); |
||||||
|
GPR_ASSERT(g_server == NULL); |
||||||
|
GPR_ASSERT(g_active_call->type == ROOT); |
||||||
|
GPR_ASSERT(g_active_call->next == g_active_call); |
||||||
|
gpr_free(g_active_call); |
||||||
|
|
||||||
|
grpc_completion_queue_shutdown(cq); |
||||||
|
GPR_ASSERT( |
||||||
|
grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), NULL) |
||||||
|
.type == GRPC_QUEUE_SHUTDOWN); |
||||||
|
grpc_completion_queue_destroy(cq); |
||||||
|
|
||||||
|
grpc_shutdown(); |
||||||
|
return 0; |
||||||
|
} |
||||||
@ -0,0 +1,27 @@ |
|||||||
|
# tracers |
||||||
|
"api\x00" |
||||||
|
"channel\x00" |
||||||
|
"channel_stack_builder\x00" |
||||||
|
"connectivity_state\x00" |
||||||
|
"flowctl\x00" |
||||||
|
"http\x00" |
||||||
|
"http1\x00" |
||||||
|
"round_robin\x00" |
||||||
|
"secure_endpoint\x00" |
||||||
|
"tcp\x00" |
||||||
|
"transport_security\x00" |
||||||
|
|
||||||
|
# channel args |
||||||
|
"\x00grpc.census\x00" |
||||||
|
"\x00grpc.max_concurrent_streams\x00" |
||||||
|
"\x00grpc.max_message_length\x00" |
||||||
|
"\x00grpc.http2.initial_sequence_number\x00" |
||||||
|
"\x00grpc.http2.lookahead_bytes\x00" |
||||||
|
"\x00grpc.http2.hpack_table_size.decoder\x00" |
||||||
|
"\x00grpc.http2.hpack_table_size.encoder\x00" |
||||||
|
"\x01grpc.default_authority\x00" |
||||||
|
"\x01grpc.primary_user_agent\x00" |
||||||
|
"\x01grpc.secondary_user_agent\x00" |
||||||
|
"\x00grpc.max_reconnect_backoff_ms\x00" |
||||||
|
"\x01grpc.ssl_target_name_override\x00" |
||||||
|
|
||||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -0,0 +1 @@ |
|||||||
|
|
||||||
Binary file not shown.
Binary file not shown.
@ -0,0 +1 @@ |
|||||||
|
|
||||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -0,0 +1 @@ |
|||||||
|
|
||||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in new issue