| /external/opencensus-java/api/src/test/java/io/opencensus/common/ |
| D | ServerStatsEncodingTest.java | 37 ServerStats serverStatsToBeEncoded = null; in encodeDecodeTest()
38 ServerStats serverStatsDecoded = null; in encodeDecodeTest()
41 serverStatsToBeEncoded = ServerStats.create(31, 22, (byte) 1); in encodeDecodeTest()
46 serverStatsToBeEncoded = ServerStats.create(0, 22, (byte) 0); in encodeDecodeTest()
51 serverStatsToBeEncoded = ServerStats.create(450, 0, (byte) 0); in encodeDecodeTest()
59 ServerStats serverStatsToBeEncoded = null; in skipUnknownFieldTest()
60 ServerStats serverStatsDecoded = null; in skipUnknownFieldTest()
63 serverStatsToBeEncoded = ServerStats.create(31, 22, (byte) 1); in skipUnknownFieldTest()
82 ServerStats serverStatsToBeEncoded = null; in negativeLbLatencyValueTest()
83 ServerStats serverStatsDecoded = null; in negativeLbLatencyValueTest()
[all …]
|
| D | ServerStatsTest.java | 35 ServerStats serverStats = null; in serverStatsCreate()
37 serverStats = ServerStats.create(31, 22, (byte) 0); in serverStatsCreate()
42 serverStats = ServerStats.create(1000011L, 900022L, (byte) 1); in serverStatsCreate()
47 serverStats = ServerStats.create(0, 22, (byte) 0); in serverStatsCreate()
52 serverStats = ServerStats.create(1010, 0, (byte) 0); in serverStatsCreate()
62 ServerStats.create(-1L, 100, (byte) 0); in create_LbLatencyNegative()
69 ServerStats.create(100L, -1L, (byte) 0); in create_ServerLatencyNegative()
76 ServerStats.create(-100L, -1L, (byte) 0); in create_LbLatencyAndServerLatencyNegative()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | InternalChannelzTest.java | 35 import io.grpc.InternalChannelz.ServerStats;
130 InternalInstrumented<ServerStats> server1 = create(); in getServers_onePage()
139 InternalInstrumented<ServerStats> server1 = create(); in getServers_onePage_multi()
140 InternalInstrumented<ServerStats> server2 = create(); in getServers_onePage_multi()
150 InternalInstrumented<ServerStats> server1 = create(); in getServers_paginate()
151 InternalInstrumented<ServerStats> server2 = create(); in getServers_paginate()
165 InternalInstrumented<ServerStats> server1 = create(); in getServers_remove()
175 InternalInstrumented<ServerStats> server1 = create(); in getServers_addAfterLastPage()
183 InternalInstrumented<ServerStats> server2 = create(); in getServers_addAfterLastPage()
238 InternalInstrumented<ServerStats> server = create(); in serverSocket()
[all …]
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | ChannelzTestHelper.java | 26 import io.grpc.InternalChannelz.ServerStats;
120 static final class TestServer implements InternalInstrumented<ServerStats> {
122 ServerStats serverStats = new ServerStats(
130 public ListenableFuture<ServerStats> getStats() { in getStats()
131 SettableFuture<ServerStats> ret = SettableFuture.create(); in getStats()
|
| D | ChannelzProtoUtilTest.java | 42 import io.grpc.InternalChannelz.ServerStats;
711 new ServerList(Collections.<InternalInstrumented<ServerStats>>emptyList(), false))); in toGetServersResponse()
720 new ServerList(ImmutableList.<InternalInstrumented<ServerStats>>of(server), false))); in toGetServersResponse()
730 new ServerList(ImmutableList.<InternalInstrumented<ServerStats>>of(server), true))); in toGetServersResponse()
743 ImmutableList.<InternalInstrumented<ServerStats>>of(server, server2), true))); in toGetServersResponse()
941 private static ServerStats.Builder toBuilder(ServerStats stats) { in toBuilder()
942 return new ServerStats.Builder() in toBuilder()
|
| /external/grpc-grpc-java/core/src/jmh/java/io/grpc/internal/ |
| D | ChannelzBenchmark.java | 21 import io.grpc.InternalChannelz.ServerStats;
46 public InternalInstrumented<ServerStats> serverToRemove;
48 public InternalInstrumented<ServerStats> serverToAdd;
50 public InternalInstrumented<ServerStats> serverForServerSocket;
79 InternalInstrumented<ServerStats> srv = create(); in populate()
|
| /external/opencensus-java/api/src/main/java/io/opencensus/common/ |
| D | ServerStats.java | 29 public abstract class ServerStats { class
31 ServerStats() {} in ServerStats() method in ServerStats
73 public static ServerStats create(long lbLatencyNs, long serviceLatencyNs, byte traceOption) { in create()
|
| D | ServerStatsEncoding.java | 53 public static byte[] toBytes(ServerStats stats) { in toBytes()
81 public static ServerStats parseBytes(byte[] serialized) in parseBytes()
119 return ServerStats.create(lbLatencyNs, serviceLatencyNs, traceOption); in parseBytes()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | InternalChannelz.java | 52 private final ConcurrentNavigableMap<Long, InternalInstrumented<ServerStats>> servers
53 = new ConcurrentSkipListMap<Long, InternalInstrumented<ServerStats>>();
79 public void addServer(InternalInstrumented<ServerStats> server) { in addServer()
106 InternalInstrumented<ServerStats> server, InternalInstrumented<SocketStats> socket) { in addServerSocket()
113 public void removeServer(InternalInstrumented<ServerStats> server) { in removeServer()
138 InternalInstrumented<ServerStats> server, InternalInstrumented<SocketStats> socket) { in removeServerSocket()
171 List<InternalInstrumented<ServerStats>> serverList in getServers()
172 = new ArrayList<InternalInstrumented<ServerStats>>(maxPageSize); in getServers()
173 Iterator<InternalInstrumented<ServerStats>> iterator in getServers()
264 public final List<InternalInstrumented<ServerStats>> servers;
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | Stats.cs | 47 …br::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ServerStats), global::Grpc.Testing.ServerStat… in StatsReflection()
58 public sealed partial class ServerStats : pb::IMessage<ServerStats> { class
59 …te static readonly pb::MessageParser<ServerStats> _parser = new pb::MessageParser<ServerStats>(() …
62 public static pb::MessageParser<ServerStats> Parser { get { return _parser; } }
75 public ServerStats() { in ServerStats() method in Grpc.Testing.ServerStats
82 public ServerStats(ServerStats other) : this() { in ServerStats() method in Grpc.Testing.ServerStats
94 public ServerStats Clone() { in Clone()
95 return new ServerStats(this); in Clone()
199 return Equals(other as ServerStats); in Equals()
203 public bool Equals(ServerStats other) { in Equals()
[all …]
|
| D | ServerRunners.cs | 139 public ServerStats GetStats(bool reset) in GetStats()
146 return new ServerStats in GetStats()
|
| D | IServerRunner.cs | 48 ServerStats GetStats(bool reset); in GetStats()
|
| /external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/ |
| D | Stats.java | 79 public static final class ServerStats extends class in Stats
85 private ServerStats(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in ServerStats() method in Stats.ServerStats
88 private ServerStats() { in ServerStats() method in Stats.ServerStats
102 private ServerStats( in ServerStats() method in Stats.ServerStats
179 …io.grpc.benchmarks.proto.Stats.ServerStats.class, io.grpc.benchmarks.proto.Stats.ServerStats.Build… in internalGetFieldAccessorTable()
333 if (!(obj instanceof io.grpc.benchmarks.proto.Stats.ServerStats)) { in equals()
336 …io.grpc.benchmarks.proto.Stats.ServerStats other = (io.grpc.benchmarks.proto.Stats.ServerStats) ob… in equals()
391 public static io.grpc.benchmarks.proto.Stats.ServerStats parseFrom( in parseFrom()
396 public static io.grpc.benchmarks.proto.Stats.ServerStats parseFrom( in parseFrom()
402 public static io.grpc.benchmarks.proto.Stats.ServerStats parseFrom( in parseFrom()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | CallTracer.java | 22 import io.grpc.InternalChannelz.ServerStats;
59 void updateBuilder(ServerStats.Builder builder) { in updateBuilder()
|
| D | ServerImpl.java | 40 import io.grpc.InternalChannelz.ServerStats;
81 public final class ServerImpl extends io.grpc.Server implements InternalInstrumented<ServerStats> {
578 public ListenableFuture<ServerStats> getStats() { in getStats()
579 ServerStats.Builder builder in getStats()
580 = new ServerStats.Builder() in getStats()
583 SettableFuture<ServerStats> ret = SettableFuture.create(); in getStats()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | driver.cc | 103 static double SvrPollCount(const ServerStats& s) { return s.cq_poll_count(); } in SvrPollCount()
104 static double ServerWallTime(const ServerStats& s) { return s.time_elapsed(); } in ServerWallTime()
105 static double ServerSystemTime(const ServerStats& s) { return s.time_system(); } in ServerSystemTime()
106 static double ServerUserTime(const ServerStats& s) { return s.time_user(); } in ServerUserTime()
107 static double ServerTotalCpuTime(const ServerStats& s) { in ServerTotalCpuTime()
110 static double ServerIdleCpuTime(const ServerStats& s) { in ServerIdleCpuTime()
|
| D | server.h | 53 ServerStats Mark(bool reset) { in Mark()
69 ServerStats stats; in Mark()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadServer.java | 177 Stats.ServerStats getStats() { in getStats()
178 Stats.ServerStats.Builder builder = Stats.ServerStats.newBuilder(); in getStats()
|
| /external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/ |
| D | stats.proto | 21 message ServerStats { message
67 // See ServerStats for details.
|
| D | control.proto | 161 ServerStats stats = 1;
204 // Basic summary that can be computed from ClientStats and ServerStats
249 repeated ServerStats server_stats = 4;
|
| /external/grpc-grpc/src/proto/grpc/testing/ |
| D | stats.proto | 21 message ServerStats { message
70 // See ServerStats for details.
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzProtoUtil.java | 33 import io.grpc.InternalChannelz.ServerStats;
123 static Server toServer(InternalInstrumented<ServerStats> obj) { in toServer()
124 ServerStats stats = getFuture(obj.getStats()); in toServer()
135 static ServerData toServerData(ServerStats stats) { in toServerData()
440 for (InternalInstrumented<ServerStats> s : servers.servers) { in toGetServersResponse()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ServerCallImplTest.java | 37 import io.grpc.InternalChannelz.ServerStats;
38 import io.grpc.InternalChannelz.ServerStats.Builder;
111 ServerStats before = beforeBuilder.build(); in callTracer0()
127 ServerStats after = afterBuilder.build(); in callTracer0()
|
| /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/ |
| D | ServerStatus.php | 54 GPBUtil::checkMessage($var, \Grpc\Testing\ServerStats::class);
|
| /external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/ |
| D | stats_pb.rb | 46 …ServerStats = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.ServerStats").m… constant
|