Home
last modified time | relevance | path

Searched refs:calls_started (Results 1 – 7 of 7) sorted by relevance

/third_party/grpc/src/python/grpcio_tests/tests/channelz/
D_channelz_servicer_test.py168 self.assertEqual(resp.channel.data.calls_started, 1)
177 self.assertEqual(resp.channel.data.calls_started, 1)
191 self.assertEqual(resp.channel.data.calls_started, k_success + k_failed)
217 self.assertEqual(resp.channel.data.calls_started, k_success)
224 self.assertEqual(resp.channel.data.calls_started, k_failed)
231 self.assertEqual(resp.channel.data.calls_started, k_success + k_failed)
238 self.assertEqual(resp.channel.data.calls_started, 0)
259 if gtc_resp.channel[i].data.calls_started == 0:
269 self.assertEqual(gtc_resp.channel[i].data.calls_started,
270 gsc_resp.subchannel.data.calls_started)
[all …]
/third_party/grpc/src/python/grpcio_tests/tests_aio/channelz/
Dchannelz_servicer_test.py190 self.assertEqual(resp.channel.data.calls_started, 1)
202 self.assertEqual(resp.channel.data.calls_started, 1)
219 self.assertEqual(resp.channel.data.calls_started, k_success + k_failed)
241 self.assertEqual(resp.channel.data.calls_started, k_success)
248 self.assertEqual(resp.channel.data.calls_started, k_failed)
255 self.assertEqual(resp.channel.data.calls_started, k_success + k_failed)
262 self.assertEqual(resp.channel.data.calls_started, 0)
286 if gc_resp.channel.data.calls_started == 0:
296 self.assertEqual(gc_resp.channel.data.calls_started,
297 gsc_resp.subchannel.data.calls_started)
[all …]
/third_party/grpc/test/cpp/end2end/
Dchannelz_service_test.cc295 EXPECT_EQ(response.channel().data().calls_started(), 1); in TEST_F()
310 EXPECT_EQ(response.channel().data().calls_started(), 1); in TEST_F()
333 EXPECT_EQ(response.channel().data().calls_started(), in TEST_F()
375 EXPECT_EQ(response.channel().data().calls_started(), kNumSuccess); in TEST_F()
388 EXPECT_EQ(response.channel().data().calls_started(), kNumFailed); in TEST_F()
401 EXPECT_EQ(response.channel().data().calls_started(), in TEST_F()
415 EXPECT_EQ(response.channel().data().calls_started(), 0); in TEST_F()
446 if (gtc_response.channel(i).data().calls_started() == 0) { in TEST_F()
460 EXPECT_EQ(gtc_response.channel(i).data().calls_started(), in TEST_F()
461 gsc_response.subchannel().data().calls_started()); in TEST_F()
[all …]
/third_party/grpc/src/core/lib/channel/
Dchannelz.h136 : calls_started(that.calls_started.Load(MemoryOrder::RELAXED)), in AtomicCounterData()
142 Atomic<int64_t> calls_started{0};
158 int64_t calls_started = 0; member
Dchannelz.cc85 data.calls_started.FetchAdd(1, MemoryOrder::RELAXED); in RecordCallStarted()
104 out->calls_started += data.calls_started.Load(MemoryOrder::RELAXED); in CollectData()
122 if (data.calls_started != 0) { in PopulateCallCounts()
123 (*json)["callsStarted"] = std::to_string(data.calls_started); in PopulateCallCounts()
/third_party/grpc/test/core/channel/
Dchannelz_test.cc189 int64_t calls_started; member
217 ValidateChildInteger(data.object_value(), "callsStarted", args.calls_started); in ValidateCounters()
/third_party/grpc/src/proto/grpc/channelz/
Dchannelz.proto110 int64 calls_started = 4; field
217 int64 calls_started = 2; field