Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
G
Grpc
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Wiki
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Snippets
Build
Pipelines
Jobs
Pipeline schedules
Artifacts
Deploy
Releases
Container Registry
Model registry
Operate
Environments
Monitor
Incidents
Service Desk
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
tci-gateway-module
Grpc
Commits
4d7dbbfc
Commit
4d7dbbfc
authored
9 years ago
by
Jan Tattermusch
Browse files
Options
Downloads
Patches
Plain Diff
regenerate protos
parent
90dd3270
No related branches found
No related tags found
No related merge requests found
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
src/csharp/Grpc.IntegrationTesting/Control.cs
+81
-21
81 additions, 21 deletions
src/csharp/Grpc.IntegrationTesting/Control.cs
src/csharp/Grpc.IntegrationTesting/Stats.cs
+139
-9
139 additions, 9 deletions
src/csharp/Grpc.IntegrationTesting/Stats.cs
with
220 additions
and
30 deletions
src/csharp/Grpc.IntegrationTesting/Control.cs
+
81
−
21
View file @
4d7dbbfc
...
@@ -36,7 +36,7 @@ namespace Grpc.Testing {
...
@@ -36,7 +36,7 @@ namespace Grpc.Testing {
"cGMudGVzdGluZy5EZXRlcm1pbmlzdGljUGFyYW1zSAASLAoGcGFyZXRvGAUg"
,
"cGMudGVzdGluZy5EZXRlcm1pbmlzdGljUGFyYW1zSAASLAoGcGFyZXRvGAUg"
,
"ASgLMhouZ3JwYy50ZXN0aW5nLlBhcmV0b1BhcmFtc0gAQgYKBGxvYWQiQwoO"
,
"ASgLMhouZ3JwYy50ZXN0aW5nLlBhcmV0b1BhcmFtc0gAQgYKBGxvYWQiQwoO"
,
"U2VjdXJpdHlQYXJhbXMSEwoLdXNlX3Rlc3RfY2EYASABKAgSHAoUc2VydmVy"
,
"U2VjdXJpdHlQYXJhbXMSEwoLdXNlX3Rlc3RfY2EYASABKAgSHAoUc2VydmVy"
,
"X2hvc3Rfb3ZlcnJpZGUYAiABKAki
9gI
KDENsaWVudENvbmZpZxIWCg5zZXJ2"
,
"X2hvc3Rfb3ZlcnJpZGUYAiABKAki
rwM
KDENsaWVudENvbmZpZxIWCg5zZXJ2"
,
"ZXJfdGFyZ2V0cxgBIAMoCRItCgtjbGllbnRfdHlwZRgCIAEoDjIYLmdycGMu"
,
"ZXJfdGFyZ2V0cxgBIAMoCRItCgtjbGllbnRfdHlwZRgCIAEoDjIYLmdycGMu"
,
"dGVzdGluZy5DbGllbnRUeXBlEjUKD3NlY3VyaXR5X3BhcmFtcxgDIAEoCzIc"
,
"dGVzdGluZy5DbGllbnRUeXBlEjUKD3NlY3VyaXR5X3BhcmFtcxgDIAEoCzIc"
,
"LmdycGMudGVzdGluZy5TZWN1cml0eVBhcmFtcxIkChxvdXRzdGFuZGluZ19y"
,
"LmdycGMudGVzdGluZy5TZWN1cml0eVBhcmFtcxIkChxvdXRzdGFuZGluZ19y"
,
...
@@ -44,24 +44,26 @@ namespace Grpc.Testing {
...
@@ -44,24 +44,26 @@ namespace Grpc.Testing {
"BRIcChRhc3luY19jbGllbnRfdGhyZWFkcxgHIAEoBRInCghycGNfdHlwZRgI"
,
"BRIcChRhc3luY19jbGllbnRfdGhyZWFkcxgHIAEoBRInCghycGNfdHlwZRgI"
,
"IAEoDjIVLmdycGMudGVzdGluZy5ScGNUeXBlEi0KC2xvYWRfcGFyYW1zGAog"
,
"IAEoDjIVLmdycGMudGVzdGluZy5ScGNUeXBlEi0KC2xvYWRfcGFyYW1zGAog"
,
"ASgLMhguZ3JwYy50ZXN0aW5nLkxvYWRQYXJhbXMSMwoOcGF5bG9hZF9jb25m"
,
"ASgLMhguZ3JwYy50ZXN0aW5nLkxvYWRQYXJhbXMSMwoOcGF5bG9hZF9jb25m"
,
"aWcYCyABKAsyGy5ncnBjLnRlc3RpbmcuUGF5bG9hZENvbmZpZyI4CgxDbGll"
,
"aWcYCyABKAsyGy5ncnBjLnRlc3RpbmcuUGF5bG9hZENvbmZpZxI3ChBoaXN0"
,
"bnRTdGF0dXMSKAoFc3RhdHMYASABKAsyGS5ncnBjLnRlc3RpbmcuQ2xpZW50"
,
"b2dyYW1fcGFyYW1zGAwgASgLMh0uZ3JwYy50ZXN0aW5nLkhpc3RvZ3JhbVBh"
,
"U3RhdHMiFQoETWFyaxINCgVyZXNldBgBIAEoCCJoCgpDbGllbnRBcmdzEisK"
,
"cmFtcyI4CgxDbGllbnRTdGF0dXMSKAoFc3RhdHMYASABKAsyGS5ncnBjLnRl"
,
"BXNldHVwGAEgASgLMhouZ3JwYy50ZXN0aW5nLkNsaWVudENvbmZpZ0gAEiIK"
,
"c3RpbmcuQ2xpZW50U3RhdHMiFQoETWFyaxINCgVyZXNldBgBIAEoCCJoCgpD"
,
"BG1hcmsYAiABKAsyEi5ncnBjLnRlc3RpbmcuTWFya0gAQgkKB2FyZ3R5cGUi"
,
"bGllbnRBcmdzEisKBXNldHVwGAEgASgLMhouZ3JwYy50ZXN0aW5nLkNsaWVu"
,
"6QEKDFNlcnZlckNvbmZpZxItCgtzZXJ2ZXJfdHlwZRgBIAEoDjIYLmdycGMu"
,
"dENvbmZpZ0gAEiIKBG1hcmsYAiABKAsyEi5ncnBjLnRlc3RpbmcuTWFya0gA"
,
"dGVzdGluZy5TZXJ2ZXJUeXBlEjUKD3NlY3VyaXR5X3BhcmFtcxgCIAEoCzIc"
,
"QgkKB2FyZ3R5cGUi9wEKDFNlcnZlckNvbmZpZxItCgtzZXJ2ZXJfdHlwZRgB"
,
"LmdycGMudGVzdGluZy5TZWN1cml0eVBhcmFtcxIMCgRwb3J0GAQgASgFEhwK"
,
"IAEoDjIYLmdycGMudGVzdGluZy5TZXJ2ZXJUeXBlEjUKD3NlY3VyaXR5X3Bh"
,
"FGFzeW5jX3NlcnZlcl90aHJlYWRzGAcgASgFEhIKCmNvcmVfbGltaXQYCCAB"
,
"cmFtcxgCIAEoCzIcLmdycGMudGVzdGluZy5TZWN1cml0eVBhcmFtcxIMCgRo"
,
"KAUSMwoOcGF5bG9hZF9jb25maWcYCSABKAsyGy5ncnBjLnRlc3RpbmcuUGF5"
,
"b3N0GAMgASgJEgwKBHBvcnQYBCABKAUSHAoUYXN5bmNfc2VydmVyX3RocmVh"
,
"bG9hZENvbmZpZyJoCgpTZXJ2ZXJBcmdzEisKBXNldHVwGAEgASgLMhouZ3Jw"
,
"ZHMYByABKAUSEgoKY29yZV9saW1pdBgIIAEoBRIzCg5wYXlsb2FkX2NvbmZp"
,
"Yy50ZXN0aW5nLlNlcnZlckNvbmZpZ0gAEiIKBG1hcmsYAiABKAsyEi5ncnBj"
,
"ZxgJIAEoCzIbLmdycGMudGVzdGluZy5QYXlsb2FkQ29uZmlnImgKClNlcnZl"
,
"LnRlc3RpbmcuTWFya0gAQgkKB2FyZ3R5cGUiVQoMU2VydmVyU3RhdHVzEigK"
,
"ckFyZ3MSKwoFc2V0dXAYASABKAsyGi5ncnBjLnRlc3RpbmcuU2VydmVyQ29u"
,
"BXN0YXRzGAEgASgLMhkuZ3JwYy50ZXN0aW5nLlNlcnZlclN0YXRzEgwKBHBv"
,
"ZmlnSAASIgoEbWFyaxgCIAEoCzISLmdycGMudGVzdGluZy5NYXJrSABCCQoH"
,
"cnQYAiABKAUSDQoFY29yZXMYAyABKAUqLwoKQ2xpZW50VHlwZRIPCgtTWU5D"
,
"YXJndHlwZSJVCgxTZXJ2ZXJTdGF0dXMSKAoFc3RhdHMYASABKAsyGS5ncnBj"
,
"X0NMSUVOVBAAEhAKDEFTWU5DX0NMSUVOVBABKi8KClNlcnZlclR5cGUSDwoL"
,
"LnRlc3RpbmcuU2VydmVyU3RhdHMSDAoEcG9ydBgCIAEoBRINCgVjb3JlcxgD"
,
"U1lOQ19TRVJWRVIQABIQCgxBU1lOQ19TRVJWRVIQASojCgdScGNUeXBlEgkK"
,
"IAEoBSovCgpDbGllbnRUeXBlEg8KC1NZTkNfQ0xJRU5UEAASEAoMQVNZTkNf"
,
"BVVOQVJZEAASDQoJU1RSRUFNSU5HEAFiBnByb3RvMw=="
));
"Q0xJRU5UEAEqLwoKU2VydmVyVHlwZRIPCgtTWU5DX1NFUlZFUhAAEhAKDEFT"
,
"WU5DX1NFUlZFUhABKiMKB1JwY1R5cGUSCQoFVU5BUlkQABINCglTVFJFQU1J"
,
"TkcQAWIGcHJvdG8z"
));
descriptor
=
pbr
::
FileDescriptor
.
InternalBuildGeneratedFileFrom
(
descriptorData
,
descriptor
=
pbr
::
FileDescriptor
.
InternalBuildGeneratedFileFrom
(
descriptorData
,
new
pbr
::
FileDescriptor
[]
{
global
::
Grpc
.
Testing
.
Payloads
.
Descriptor
,
global
::
Grpc
.
Testing
.
Stats
.
Descriptor
,
},
new
pbr
::
FileDescriptor
[]
{
global
::
Grpc
.
Testing
.
Payloads
.
Descriptor
,
global
::
Grpc
.
Testing
.
Stats
.
Descriptor
,
},
new
pbr
::
GeneratedCodeInfo
(
new
[]
{
typeof
(
global
::
Grpc
.
Testing
.
ClientType
),
typeof
(
global
::
Grpc
.
Testing
.
ServerType
),
typeof
(
global
::
Grpc
.
Testing
.
RpcType
),
},
new
pbr
::
GeneratedCodeInfo
[]
{
new
pbr
::
GeneratedCodeInfo
(
new
[]
{
typeof
(
global
::
Grpc
.
Testing
.
ClientType
),
typeof
(
global
::
Grpc
.
Testing
.
ServerType
),
typeof
(
global
::
Grpc
.
Testing
.
RpcType
),
},
new
pbr
::
GeneratedCodeInfo
[]
{
...
@@ -72,11 +74,11 @@ namespace Grpc.Testing {
...
@@ -72,11 +74,11 @@ namespace Grpc.Testing {
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClosedLoopParams
),
null
,
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClosedLoopParams
),
null
,
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
LoadParams
),
new
[]{
"ClosedLoop"
,
"Poisson"
,
"Uniform"
,
"Determ"
,
"Pareto"
},
new
[]{
"Load"
},
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
LoadParams
),
new
[]{
"ClosedLoop"
,
"Poisson"
,
"Uniform"
,
"Determ"
,
"Pareto"
},
new
[]{
"Load"
},
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
SecurityParams
),
new
[]{
"UseTestCa"
,
"ServerHostOverride"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
SecurityParams
),
new
[]{
"UseTestCa"
,
"ServerHostOverride"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClientConfig
),
new
[]{
"ServerTargets"
,
"ClientType"
,
"SecurityParams"
,
"OutstandingRpcsPerChannel"
,
"ClientChannels"
,
"AsyncClientThreads"
,
"RpcType"
,
"LoadParams"
,
"PayloadConfig"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClientConfig
),
new
[]{
"ServerTargets"
,
"ClientType"
,
"SecurityParams"
,
"OutstandingRpcsPerChannel"
,
"ClientChannels"
,
"AsyncClientThreads"
,
"RpcType"
,
"LoadParams"
,
"PayloadConfig"
,
"HistogramParams"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClientStatus
),
new
[]{
"Stats"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClientStatus
),
new
[]{
"Stats"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
Mark
),
new
[]{
"Reset"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
Mark
),
new
[]{
"Reset"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClientArgs
),
new
[]{
"Setup"
,
"Mark"
},
new
[]{
"Argtype"
},
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClientArgs
),
new
[]{
"Setup"
,
"Mark"
},
new
[]{
"Argtype"
},
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ServerConfig
),
new
[]{
"ServerType"
,
"SecurityParams"
,
"Port"
,
"AsyncServerThreads"
,
"CoreLimit"
,
"PayloadConfig"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ServerConfig
),
new
[]{
"ServerType"
,
"SecurityParams"
,
"Host"
,
"Port"
,
"AsyncServerThreads"
,
"CoreLimit"
,
"PayloadConfig"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ServerArgs
),
new
[]{
"Setup"
,
"Mark"
},
new
[]{
"Argtype"
},
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ServerArgs
),
new
[]{
"Setup"
,
"Mark"
},
new
[]{
"Argtype"
},
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ServerStatus
),
new
[]{
"Stats"
,
"Port"
,
"Cores"
},
null
,
null
,
null
)
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ServerStatus
),
new
[]{
"Stats"
,
"Port"
,
"Cores"
},
null
,
null
,
null
)
}));
}));
...
@@ -1062,6 +1064,7 @@ namespace Grpc.Testing {
...
@@ -1062,6 +1064,7 @@ namespace Grpc.Testing {
rpcType_
=
other
.
rpcType_
;
rpcType_
=
other
.
rpcType_
;
LoadParams
=
other
.
loadParams_
!=
null
?
other
.
LoadParams
.
Clone
()
:
null
;
LoadParams
=
other
.
loadParams_
!=
null
?
other
.
LoadParams
.
Clone
()
:
null
;
PayloadConfig
=
other
.
payloadConfig_
!=
null
?
other
.
PayloadConfig
.
Clone
()
:
null
;
PayloadConfig
=
other
.
payloadConfig_
!=
null
?
other
.
PayloadConfig
.
Clone
()
:
null
;
HistogramParams
=
other
.
histogramParams_
!=
null
?
other
.
HistogramParams
.
Clone
()
:
null
;
}
}
public
ClientConfig
Clone
()
{
public
ClientConfig
Clone
()
{
...
@@ -1148,6 +1151,15 @@ namespace Grpc.Testing {
...
@@ -1148,6 +1151,15 @@ namespace Grpc.Testing {
}
}
}
}
public
const
int
HistogramParamsFieldNumber
=
12
;
private
global
::
Grpc
.
Testing
.
HistogramParams
histogramParams_
;
public
global
::
Grpc
.
Testing
.
HistogramParams
HistogramParams
{
get
{
return
histogramParams_
;
}
set
{
histogramParams_
=
value
;
}
}
public
override
bool
Equals
(
object
other
)
{
public
override
bool
Equals
(
object
other
)
{
return
Equals
(
other
as
ClientConfig
);
return
Equals
(
other
as
ClientConfig
);
}
}
...
@@ -1168,6 +1180,7 @@ namespace Grpc.Testing {
...
@@ -1168,6 +1180,7 @@ namespace Grpc.Testing {
if
(
RpcType
!=
other
.
RpcType
)
return
false
;
if
(
RpcType
!=
other
.
RpcType
)
return
false
;
if
(!
object
.
Equals
(
LoadParams
,
other
.
LoadParams
))
return
false
;
if
(!
object
.
Equals
(
LoadParams
,
other
.
LoadParams
))
return
false
;
if
(!
object
.
Equals
(
PayloadConfig
,
other
.
PayloadConfig
))
return
false
;
if
(!
object
.
Equals
(
PayloadConfig
,
other
.
PayloadConfig
))
return
false
;
if
(!
object
.
Equals
(
HistogramParams
,
other
.
HistogramParams
))
return
false
;
return
true
;
return
true
;
}
}
...
@@ -1182,6 +1195,7 @@ namespace Grpc.Testing {
...
@@ -1182,6 +1195,7 @@ namespace Grpc.Testing {
if
(
RpcType
!=
global
::
Grpc
.
Testing
.
RpcType
.
UNARY
)
hash
^=
RpcType
.
GetHashCode
();
if
(
RpcType
!=
global
::
Grpc
.
Testing
.
RpcType
.
UNARY
)
hash
^=
RpcType
.
GetHashCode
();
if
(
loadParams_
!=
null
)
hash
^=
LoadParams
.
GetHashCode
();
if
(
loadParams_
!=
null
)
hash
^=
LoadParams
.
GetHashCode
();
if
(
payloadConfig_
!=
null
)
hash
^=
PayloadConfig
.
GetHashCode
();
if
(
payloadConfig_
!=
null
)
hash
^=
PayloadConfig
.
GetHashCode
();
if
(
histogramParams_
!=
null
)
hash
^=
HistogramParams
.
GetHashCode
();
return
hash
;
return
hash
;
}
}
...
@@ -1223,6 +1237,10 @@ namespace Grpc.Testing {
...
@@ -1223,6 +1237,10 @@ namespace Grpc.Testing {
output
.
WriteRawTag
(
90
);
output
.
WriteRawTag
(
90
);
output
.
WriteMessage
(
PayloadConfig
);
output
.
WriteMessage
(
PayloadConfig
);
}
}
if
(
histogramParams_
!=
null
)
{
output
.
WriteRawTag
(
98
);
output
.
WriteMessage
(
HistogramParams
);
}
}
}
public
int
CalculateSize
()
{
public
int
CalculateSize
()
{
...
@@ -1252,6 +1270,9 @@ namespace Grpc.Testing {
...
@@ -1252,6 +1270,9 @@ namespace Grpc.Testing {
if
(
payloadConfig_
!=
null
)
{
if
(
payloadConfig_
!=
null
)
{
size
+=
1
+
pb
::
CodedOutputStream
.
ComputeMessageSize
(
PayloadConfig
);
size
+=
1
+
pb
::
CodedOutputStream
.
ComputeMessageSize
(
PayloadConfig
);
}
}
if
(
histogramParams_
!=
null
)
{
size
+=
1
+
pb
::
CodedOutputStream
.
ComputeMessageSize
(
HistogramParams
);
}
return
size
;
return
size
;
}
}
...
@@ -1293,6 +1314,12 @@ namespace Grpc.Testing {
...
@@ -1293,6 +1314,12 @@ namespace Grpc.Testing {
}
}
PayloadConfig
.
MergeFrom
(
other
.
PayloadConfig
);
PayloadConfig
.
MergeFrom
(
other
.
PayloadConfig
);
}
}
if
(
other
.
histogramParams_
!=
null
)
{
if
(
histogramParams_
==
null
)
{
histogramParams_
=
new
global
::
Grpc
.
Testing
.
HistogramParams
();
}
HistogramParams
.
MergeFrom
(
other
.
HistogramParams
);
}
}
}
public
void
MergeFrom
(
pb
::
CodedInputStream
input
)
{
public
void
MergeFrom
(
pb
::
CodedInputStream
input
)
{
...
@@ -1347,6 +1374,13 @@ namespace Grpc.Testing {
...
@@ -1347,6 +1374,13 @@ namespace Grpc.Testing {
input
.
ReadMessage
(
payloadConfig_
);
input
.
ReadMessage
(
payloadConfig_
);
break
;
break
;
}
}
case
98
:
{
if
(
histogramParams_
==
null
)
{
histogramParams_
=
new
global
::
Grpc
.
Testing
.
HistogramParams
();
}
input
.
ReadMessage
(
histogramParams_
);
break
;
}
}
}
}
}
}
}
...
@@ -1749,6 +1783,7 @@ namespace Grpc.Testing {
...
@@ -1749,6 +1783,7 @@ namespace Grpc.Testing {
public
ServerConfig
(
ServerConfig
other
)
:
this
()
{
public
ServerConfig
(
ServerConfig
other
)
:
this
()
{
serverType_
=
other
.
serverType_
;
serverType_
=
other
.
serverType_
;
SecurityParams
=
other
.
securityParams_
!=
null
?
other
.
SecurityParams
.
Clone
()
:
null
;
SecurityParams
=
other
.
securityParams_
!=
null
?
other
.
SecurityParams
.
Clone
()
:
null
;
host_
=
other
.
host_
;
port_
=
other
.
port_
;
port_
=
other
.
port_
;
asyncServerThreads_
=
other
.
asyncServerThreads_
;
asyncServerThreads_
=
other
.
asyncServerThreads_
;
coreLimit_
=
other
.
coreLimit_
;
coreLimit_
=
other
.
coreLimit_
;
...
@@ -1777,6 +1812,15 @@ namespace Grpc.Testing {
...
@@ -1777,6 +1812,15 @@ namespace Grpc.Testing {
}
}
}
}
public
const
int
HostFieldNumber
=
3
;
private
string
host_
=
""
;
public
string
Host
{
get
{
return
host_
;
}
set
{
host_
=
pb
::
Preconditions
.
CheckNotNull
(
value
,
"value"
);
}
}
public
const
int
PortFieldNumber
=
4
;
public
const
int
PortFieldNumber
=
4
;
private
int
port_
;
private
int
port_
;
public
int
Port
{
public
int
Port
{
...
@@ -1826,6 +1870,7 @@ namespace Grpc.Testing {
...
@@ -1826,6 +1870,7 @@ namespace Grpc.Testing {
}
}
if
(
ServerType
!=
other
.
ServerType
)
return
false
;
if
(
ServerType
!=
other
.
ServerType
)
return
false
;
if
(!
object
.
Equals
(
SecurityParams
,
other
.
SecurityParams
))
return
false
;
if
(!
object
.
Equals
(
SecurityParams
,
other
.
SecurityParams
))
return
false
;
if
(
Host
!=
other
.
Host
)
return
false
;
if
(
Port
!=
other
.
Port
)
return
false
;
if
(
Port
!=
other
.
Port
)
return
false
;
if
(
AsyncServerThreads
!=
other
.
AsyncServerThreads
)
return
false
;
if
(
AsyncServerThreads
!=
other
.
AsyncServerThreads
)
return
false
;
if
(
CoreLimit
!=
other
.
CoreLimit
)
return
false
;
if
(
CoreLimit
!=
other
.
CoreLimit
)
return
false
;
...
@@ -1837,6 +1882,7 @@ namespace Grpc.Testing {
...
@@ -1837,6 +1882,7 @@ namespace Grpc.Testing {
int
hash
=
1
;
int
hash
=
1
;
if
(
ServerType
!=
global
::
Grpc
.
Testing
.
ServerType
.
SYNC_SERVER
)
hash
^=
ServerType
.
GetHashCode
();
if
(
ServerType
!=
global
::
Grpc
.
Testing
.
ServerType
.
SYNC_SERVER
)
hash
^=
ServerType
.
GetHashCode
();
if
(
securityParams_
!=
null
)
hash
^=
SecurityParams
.
GetHashCode
();
if
(
securityParams_
!=
null
)
hash
^=
SecurityParams
.
GetHashCode
();
if
(
Host
.
Length
!=
0
)
hash
^=
Host
.
GetHashCode
();
if
(
Port
!=
0
)
hash
^=
Port
.
GetHashCode
();
if
(
Port
!=
0
)
hash
^=
Port
.
GetHashCode
();
if
(
AsyncServerThreads
!=
0
)
hash
^=
AsyncServerThreads
.
GetHashCode
();
if
(
AsyncServerThreads
!=
0
)
hash
^=
AsyncServerThreads
.
GetHashCode
();
if
(
CoreLimit
!=
0
)
hash
^=
CoreLimit
.
GetHashCode
();
if
(
CoreLimit
!=
0
)
hash
^=
CoreLimit
.
GetHashCode
();
...
@@ -1857,6 +1903,10 @@ namespace Grpc.Testing {
...
@@ -1857,6 +1903,10 @@ namespace Grpc.Testing {
output
.
WriteRawTag
(
18
);
output
.
WriteRawTag
(
18
);
output
.
WriteMessage
(
SecurityParams
);
output
.
WriteMessage
(
SecurityParams
);
}
}
if
(
Host
.
Length
!=
0
)
{
output
.
WriteRawTag
(
26
);
output
.
WriteString
(
Host
);
}
if
(
Port
!=
0
)
{
if
(
Port
!=
0
)
{
output
.
WriteRawTag
(
32
);
output
.
WriteRawTag
(
32
);
output
.
WriteInt32
(
Port
);
output
.
WriteInt32
(
Port
);
...
@@ -1883,6 +1933,9 @@ namespace Grpc.Testing {
...
@@ -1883,6 +1933,9 @@ namespace Grpc.Testing {
if
(
securityParams_
!=
null
)
{
if
(
securityParams_
!=
null
)
{
size
+=
1
+
pb
::
CodedOutputStream
.
ComputeMessageSize
(
SecurityParams
);
size
+=
1
+
pb
::
CodedOutputStream
.
ComputeMessageSize
(
SecurityParams
);
}
}
if
(
Host
.
Length
!=
0
)
{
size
+=
1
+
pb
::
CodedOutputStream
.
ComputeStringSize
(
Host
);
}
if
(
Port
!=
0
)
{
if
(
Port
!=
0
)
{
size
+=
1
+
pb
::
CodedOutputStream
.
ComputeInt32Size
(
Port
);
size
+=
1
+
pb
::
CodedOutputStream
.
ComputeInt32Size
(
Port
);
}
}
...
@@ -1911,6 +1964,9 @@ namespace Grpc.Testing {
...
@@ -1911,6 +1964,9 @@ namespace Grpc.Testing {
}
}
SecurityParams
.
MergeFrom
(
other
.
SecurityParams
);
SecurityParams
.
MergeFrom
(
other
.
SecurityParams
);
}
}
if
(
other
.
Host
.
Length
!=
0
)
{
Host
=
other
.
Host
;
}
if
(
other
.
Port
!=
0
)
{
if
(
other
.
Port
!=
0
)
{
Port
=
other
.
Port
;
Port
=
other
.
Port
;
}
}
...
@@ -1946,6 +2002,10 @@ namespace Grpc.Testing {
...
@@ -1946,6 +2002,10 @@ namespace Grpc.Testing {
input
.
ReadMessage
(
securityParams_
);
input
.
ReadMessage
(
securityParams_
);
break
;
break
;
}
}
case
26
:
{
Host
=
input
.
ReadString
();
break
;
}
case
32
:
{
case
32
:
{
Port
=
input
.
ReadInt32
();
Port
=
input
.
ReadInt32
();
break
;
break
;
...
...
This diff is collapsed.
Click to expand it.
src/csharp/Grpc.IntegrationTesting/Stats.cs
+
139
−
9
View file @
4d7dbbfc
...
@@ -23,17 +23,19 @@ namespace Grpc.Testing {
...
@@ -23,17 +23,19 @@ namespace Grpc.Testing {
string
.
Concat
(
string
.
Concat
(
"CiF0ZXN0L3Byb3RvL2JlbmNobWFya3Mvc3RhdHMucHJvdG8SDGdycGMudGVz"
,
"CiF0ZXN0L3Byb3RvL2JlbmNobWFya3Mvc3RhdHMucHJvdG8SDGdycGMudGVz"
,
"dGluZyJLCgtTZXJ2ZXJTdGF0cxIUCgx0aW1lX2VsYXBzZWQYASABKAESEQoJ"
,
"dGluZyJLCgtTZXJ2ZXJTdGF0cxIUCgx0aW1lX2VsYXBzZWQYASABKAESEQoJ"
,
"dGltZV91c2VyGAIgASgBEhMKC3RpbWVfc3lzdGVtGAMgASgBIncKDUhpc3Rv"
,
"dGltZV91c2VyGAIgASgBEhMKC3RpbWVfc3lzdGVtGAMgASgBIjsKD0hpc3Rv"
,
"Z3JhbURhdGESDgoGYnVja2V0GAEgAygNEhAKCG1pbl9zZWVuGAIgASgBEhAK"
,
"Z3JhbVBhcmFtcxISCgpyZXNvbHV0aW9uGAEgASgBEhQKDG1heF9wb3NzaWJs"
,
"CG1heF9zZWVuGAMgASgBEgsKA3N1bRgEIAEoARIWCg5zdW1fb2Zfc3F1YXJl"
,
"ZRgCIAEoASJ3Cg1IaXN0b2dyYW1EYXRhEg4KBmJ1Y2tldBgBIAMoDRIQCght"
,
"cxgFIAEoARINCgVjb3VudBgGIAEoASJ7CgtDbGllbnRTdGF0cxIuCglsYXRl"
,
"aW5fc2VlbhgCIAEoARIQCghtYXhfc2VlbhgDIAEoARILCgNzdW0YBCABKAES"
,
"bmNpZXMYASABKAsyGy5ncnBjLnRlc3RpbmcuSGlzdG9ncmFtRGF0YRIUCgx0"
,
"FgoOc3VtX29mX3NxdWFyZXMYBSABKAESDQoFY291bnQYBiABKAEiewoLQ2xp"
,
"aW1lX2VsYXBzZWQYAiABKAESEQoJdGltZV91c2VyGAMgASgBEhMKC3RpbWVf"
,
"ZW50U3RhdHMSLgoJbGF0ZW5jaWVzGAEgASgLMhsuZ3JwYy50ZXN0aW5nLkhp"
,
"c3lzdGVtGAQgASgBYgZwcm90bzM="
));
"c3RvZ3JhbURhdGESFAoMdGltZV9lbGFwc2VkGAIgASgBEhEKCXRpbWVfdXNl"
,
"chgDIAEoARITCgt0aW1lX3N5c3RlbRgEIAEoAWIGcHJvdG8z"
));
descriptor
=
pbr
::
FileDescriptor
.
InternalBuildGeneratedFileFrom
(
descriptorData
,
descriptor
=
pbr
::
FileDescriptor
.
InternalBuildGeneratedFileFrom
(
descriptorData
,
new
pbr
::
FileDescriptor
[]
{
},
new
pbr
::
FileDescriptor
[]
{
},
new
pbr
::
GeneratedCodeInfo
(
null
,
new
pbr
::
GeneratedCodeInfo
[]
{
new
pbr
::
GeneratedCodeInfo
(
null
,
new
pbr
::
GeneratedCodeInfo
[]
{
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ServerStats
),
new
[]{
"TimeElapsed"
,
"TimeUser"
,
"TimeSystem"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ServerStats
),
new
[]{
"TimeElapsed"
,
"TimeUser"
,
"TimeSystem"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
HistogramParams
),
new
[]{
"Resolution"
,
"MaxPossible"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
HistogramData
),
new
[]{
"Bucket"
,
"MinSeen"
,
"MaxSeen"
,
"Sum"
,
"SumOfSquares"
,
"Count"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
HistogramData
),
new
[]{
"Bucket"
,
"MinSeen"
,
"MaxSeen"
,
"Sum"
,
"SumOfSquares"
,
"Count"
},
null
,
null
,
null
),
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClientStats
),
new
[]{
"Latencies"
,
"TimeElapsed"
,
"TimeUser"
,
"TimeSystem"
},
null
,
null
,
null
)
new
pbr
::
GeneratedCodeInfo
(
typeof
(
global
::
Grpc
.
Testing
.
ClientStats
),
new
[]{
"Latencies"
,
"TimeElapsed"
,
"TimeUser"
,
"TimeSystem"
},
null
,
null
,
null
)
}));
}));
...
@@ -196,13 +198,141 @@ namespace Grpc.Testing {
...
@@ -196,13 +198,141 @@ namespace Grpc.Testing {
}
}
[
global
::
System
.
Diagnostics
.
DebuggerNonUserCodeAttribute
()]
public
sealed
partial
class
HistogramParams
:
pb
::
IMessage
<
HistogramParams
>
{
private
static
readonly
pb
::
MessageParser
<
HistogramParams
>
_parser
=
new
pb
::
MessageParser
<
HistogramParams
>(()
=>
new
HistogramParams
());
public
static
pb
::
MessageParser
<
HistogramParams
>
Parser
{
get
{
return
_parser
;
}
}
public
static
pbr
::
MessageDescriptor
Descriptor
{
get
{
return
global
::
Grpc
.
Testing
.
Stats
.
Descriptor
.
MessageTypes
[
1
];
}
}
pbr
::
MessageDescriptor
pb
::
IMessage
.
Descriptor
{
get
{
return
Descriptor
;
}
}
public
HistogramParams
()
{
OnConstruction
();
}
partial
void
OnConstruction
();
public
HistogramParams
(
HistogramParams
other
)
:
this
()
{
resolution_
=
other
.
resolution_
;
maxPossible_
=
other
.
maxPossible_
;
}
public
HistogramParams
Clone
()
{
return
new
HistogramParams
(
this
);
}
public
const
int
ResolutionFieldNumber
=
1
;
private
double
resolution_
;
public
double
Resolution
{
get
{
return
resolution_
;
}
set
{
resolution_
=
value
;
}
}
public
const
int
MaxPossibleFieldNumber
=
2
;
private
double
maxPossible_
;
public
double
MaxPossible
{
get
{
return
maxPossible_
;
}
set
{
maxPossible_
=
value
;
}
}
public
override
bool
Equals
(
object
other
)
{
return
Equals
(
other
as
HistogramParams
);
}
public
bool
Equals
(
HistogramParams
other
)
{
if
(
ReferenceEquals
(
other
,
null
))
{
return
false
;
}
if
(
ReferenceEquals
(
other
,
this
))
{
return
true
;
}
if
(
Resolution
!=
other
.
Resolution
)
return
false
;
if
(
MaxPossible
!=
other
.
MaxPossible
)
return
false
;
return
true
;
}
public
override
int
GetHashCode
()
{
int
hash
=
1
;
if
(
Resolution
!=
0D
)
hash
^=
Resolution
.
GetHashCode
();
if
(
MaxPossible
!=
0D
)
hash
^=
MaxPossible
.
GetHashCode
();
return
hash
;
}
public
override
string
ToString
()
{
return
pb
::
JsonFormatter
.
Default
.
Format
(
this
);
}
public
void
WriteTo
(
pb
::
CodedOutputStream
output
)
{
if
(
Resolution
!=
0D
)
{
output
.
WriteRawTag
(
9
);
output
.
WriteDouble
(
Resolution
);
}
if
(
MaxPossible
!=
0D
)
{
output
.
WriteRawTag
(
17
);
output
.
WriteDouble
(
MaxPossible
);
}
}
public
int
CalculateSize
()
{
int
size
=
0
;
if
(
Resolution
!=
0D
)
{
size
+=
1
+
8
;
}
if
(
MaxPossible
!=
0D
)
{
size
+=
1
+
8
;
}
return
size
;
}
public
void
MergeFrom
(
HistogramParams
other
)
{
if
(
other
==
null
)
{
return
;
}
if
(
other
.
Resolution
!=
0D
)
{
Resolution
=
other
.
Resolution
;
}
if
(
other
.
MaxPossible
!=
0D
)
{
MaxPossible
=
other
.
MaxPossible
;
}
}
public
void
MergeFrom
(
pb
::
CodedInputStream
input
)
{
uint
tag
;
while
((
tag
=
input
.
ReadTag
())
!=
0
)
{
switch
(
tag
)
{
default
:
input
.
SkipLastField
();
break
;
case
9
:
{
Resolution
=
input
.
ReadDouble
();
break
;
}
case
17
:
{
MaxPossible
=
input
.
ReadDouble
();
break
;
}
}
}
}
}
[
global
::
System
.
Diagnostics
.
DebuggerNonUserCodeAttribute
()]
[
global
::
System
.
Diagnostics
.
DebuggerNonUserCodeAttribute
()]
public
sealed
partial
class
HistogramData
:
pb
::
IMessage
<
HistogramData
>
{
public
sealed
partial
class
HistogramData
:
pb
::
IMessage
<
HistogramData
>
{
private
static
readonly
pb
::
MessageParser
<
HistogramData
>
_parser
=
new
pb
::
MessageParser
<
HistogramData
>(()
=>
new
HistogramData
());
private
static
readonly
pb
::
MessageParser
<
HistogramData
>
_parser
=
new
pb
::
MessageParser
<
HistogramData
>(()
=>
new
HistogramData
());
public
static
pb
::
MessageParser
<
HistogramData
>
Parser
{
get
{
return
_parser
;
}
}
public
static
pb
::
MessageParser
<
HistogramData
>
Parser
{
get
{
return
_parser
;
}
}
public
static
pbr
::
MessageDescriptor
Descriptor
{
public
static
pbr
::
MessageDescriptor
Descriptor
{
get
{
return
global
::
Grpc
.
Testing
.
Stats
.
Descriptor
.
MessageTypes
[
1
];
}
get
{
return
global
::
Grpc
.
Testing
.
Stats
.
Descriptor
.
MessageTypes
[
2
];
}
}
}
pbr
::
MessageDescriptor
pb
::
IMessage
.
Descriptor
{
pbr
::
MessageDescriptor
pb
::
IMessage
.
Descriptor
{
...
@@ -427,7 +557,7 @@ namespace Grpc.Testing {
...
@@ -427,7 +557,7 @@ namespace Grpc.Testing {
public
static
pb
::
MessageParser
<
ClientStats
>
Parser
{
get
{
return
_parser
;
}
}
public
static
pb
::
MessageParser
<
ClientStats
>
Parser
{
get
{
return
_parser
;
}
}
public
static
pbr
::
MessageDescriptor
Descriptor
{
public
static
pbr
::
MessageDescriptor
Descriptor
{
get
{
return
global
::
Grpc
.
Testing
.
Stats
.
Descriptor
.
MessageTypes
[
2
];
}
get
{
return
global
::
Grpc
.
Testing
.
Stats
.
Descriptor
.
MessageTypes
[
3
];
}
}
}
pbr
::
MessageDescriptor
pb
::
IMessage
.
Descriptor
{
pbr
::
MessageDescriptor
pb
::
IMessage
.
Descriptor
{
...
...
This diff is collapsed.
Click to expand it.
Preview
0%
Loading
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Save comment
Cancel
Please
register
or
sign in
to comment