| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| D | pick_first.cc | 70 RefCountedPtr<SubchannelInterface> subchannel) in PickFirstSubchannelData() argument
71 : SubchannelData(subchannel_list, address, std::move(subchannel)) {} in PickFirstSubchannelData()
113 explicit Picker(RefCountedPtr<SubchannelInterface> subchannel) in Picker() argument
114 : subchannel_(std::move(subchannel)) {} in Picker()
119 result.subchannel = subchannel_; in Pick()
214 PickFirstSubchannelData* sd = subchannel_list->subchannel(i); in AttemptToConnectUsingLatestUpdateArgsLocked()
236 subchannel_list_->subchannel(0)->StartConnectivityWatchLocked(); in AttemptToConnectUsingLatestUpdateArgsLocked()
237 subchannel_list_->subchannel(0)->subchannel()->AttemptToConnect(); in AttemptToConnectUsingLatestUpdateArgsLocked()
256 latest_pending_subchannel_list_->subchannel(0) in AttemptToConnectUsingLatestUpdateArgsLocked()
258 latest_pending_subchannel_list_->subchannel(0) in AttemptToConnectUsingLatestUpdateArgsLocked()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| D | round_robin.cc | 85 RefCountedPtr<SubchannelInterface> subchannel) in RoundRobinSubchannelData() argument
86 : SubchannelData(subchannel_list, address, std::move(subchannel)) {} in RoundRobinSubchannelData()
189 RoundRobinSubchannelData* sd = subchannel_list->subchannel(i); in Picker()
191 subchannels_.push_back(sd->subchannel()->Ref()); in Picker()
218 result.subchannel = subchannels_[last_picked_index_]; in Pick()
263 subchannel(i)->CheckConnectivityStateLocked(); in StartWatchingLocked()
265 subchannel(i)->UpdateConnectivityStateLocked(state); in StartWatchingLocked()
270 if (subchannel(i)->subchannel() != nullptr) { in StartWatchingLocked()
271 subchannel(i)->StartConnectivityWatchLocked(); in StartWatchingLocked()
272 subchannel(i)->subchannel()->AttemptToConnect(); in StartWatchingLocked()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | subchannel_list.h | 88 subchannel_list_->subchannel(0)); in Index()
92 SubchannelInterface* subchannel() const { return subchannel_.get(); } in subchannel() function
124 RefCountedPtr<SubchannelInterface> subchannel);
184 SubchannelDataType* subchannel(size_t index) { return &subchannels_[index]; } in subchannel() function
270 RefCountedPtr<SubchannelInterface> subchannel) in SubchannelData() argument
272 subchannel_(std::move(subchannel)), in SubchannelData()
370 RefCountedPtr<SubchannelInterface> subchannel = in SubchannelList() local
372 if (subchannel == nullptr) { in SubchannelList()
387 subchannel.get(), address.ToString().c_str()); in SubchannelList()
389 subchannels_.emplace_back(this, std::move(address), std::move(subchannel)); in SubchannelList()
|
| /third_party/grpc/src/python/grpcio_tests/tests/channelz/ |
| D | _channelz_servicer_test.py | 270 gsc_resp.subchannel.data.calls_started)
272 gsc_resp.subchannel.data.calls_succeeded)
274 gsc_resp.subchannel.data.calls_failed)
337 self.assertEqual(len(gsc_resp.subchannel.socket_ref), 1)
341 socket_id=gsc_resp.subchannel.socket_ref[0].socket_id))
342 self.assertEqual(gsc_resp.subchannel.data.calls_started,
344 self.assertEqual(gsc_resp.subchannel.data.calls_started,
347 self.assertEqual(gsc_resp.subchannel.data.calls_started,
350 self.assertEqual(gsc_resp.subchannel.data.calls_succeeded,
370 self.assertEqual(gsc_resp.subchannel.data.calls_started, 1)
[all …]
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/channelz/ |
| D | channelz_servicer_test.py | 297 gsc_resp.subchannel.data.calls_started)
299 gsc_resp.subchannel.data.calls_succeeded)
301 gsc_resp.subchannel.data.calls_failed)
351 self.assertEqual(len(gsc_resp.subchannel.socket_ref), 1)
355 socket_id=gsc_resp.subchannel.socket_ref[0].socket_id))
356 self.assertEqual(gsc_resp.subchannel.data.calls_started,
360 self.assertEqual(gsc_resp.subchannel.data.calls_started,
382 self.assertEqual(gsc_resp.subchannel.data.calls_started, 1)
383 self.assertEqual(gsc_resp.subchannel.data.calls_succeeded, 1)
384 self.assertEqual(gsc_resp.subchannel.data.calls_failed, 0)
[all …]
|
| /third_party/grpc/test/cpp/end2end/ |
| D | channelz_service_test.cc | 461 gsc_response.subchannel().data().calls_started()); in TEST_F()
463 gsc_response.subchannel().data().calls_succeeded()); in TEST_F()
465 gsc_response.subchannel().data().calls_failed()); in TEST_F()
571 EXPECT_EQ(get_subchannel_resp.subchannel().socket_ref_size(), 1); in TEST_F()
577 get_subchannel_resp.subchannel().socket_ref(0).socket_id()); in TEST_F()
581 get_subchannel_resp.subchannel().socket_ref(0).name().find("http")); in TEST_F()
586 EXPECT_EQ(get_subchannel_resp.subchannel().data().calls_started(), in TEST_F()
588 EXPECT_EQ(get_subchannel_resp.subchannel().data().calls_started(), in TEST_F()
591 EXPECT_EQ(get_subchannel_resp.subchannel().data().calls_started(), in TEST_F()
595 EXPECT_EQ(get_subchannel_resp.subchannel().data().calls_succeeded(), in TEST_F()
[all …]
|
| /third_party/grpc/src/proto/grpc/channelz/ |
| D | channelz.proto | 46 // A channel ref may be present in more than one channel or subchannel.
50 // There are no ordering guarantees on the order of subchannel refs.
52 // A sub channel ref may be present in more than one channel or subchannel.
60 // A subchannel is load balanced over by it's ancestor
70 // A channel ref may be present in more than one channel or subchannel.
74 // There are no ordering guarantees on the order of subchannel refs.
76 // A sub channel ref may be present in more than one channel or subchannel.
99 // The connectivity state of the channel or subchannel. Implementations
121 // subchannel, such as creation, address resolution, subchannel creation, etc.
136 // ref of referenced channel or subchannel.
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | subchannel_interface.h | 98 explicit DelegatingSubchannel(RefCountedPtr<SubchannelInterface> subchannel) in DelegatingSubchannel() argument
99 : wrapped_subchannel_(std::move(subchannel)) {} in DelegatingSubchannel()
|
| D | subchannel.cc | 369 Subchannel* subchannel, grpc_connectivity_state state, in AsyncWatcherNotifierLocked() argument
374 connected_subchannel = subchannel->connected_subchannel_; in AsyncWatcherNotifierLocked()
411 Subchannel* subchannel, grpc_connectivity_state state, in NotifyLocked() argument
414 new AsyncWatcherNotifierLocked(p.second, subchannel, state, status); in NotifyLocked()
523 Subchannel* subchannel, grpc_connectivity_state initial_state, in AddWatcherLocked() argument
532 subchannel, health_check_service_name, subchannel->state_); in AddWatcherLocked()
562 Subchannel* subchannel, const std::string& health_check_service_name) { in CheckConnectivityStateLocked() argument
570 return subchannel->state_ == GRPC_CHANNEL_READY ? GRPC_CHANNEL_CONNECTING in CheckConnectivityStateLocked()
571 : subchannel->state_; in CheckConnectivityStateLocked()
|
| D | subchannel.h | 309 void NotifyLocked(Subchannel* subchannel, grpc_connectivity_state state,
336 Subchannel* subchannel, grpc_connectivity_state initial_state,
347 Subchannel* subchannel, const std::string& health_check_service_name);
|
| D | README.md | 43 concrete subchannel instances.
|
| D | client_channel.cc | 186 SubchannelInterface* subchannel) const;
1261 SubchannelWrapper(ChannelData* chand, Subchannel* subchannel, in SubchannelWrapper() argument
1268 subchannel_(subchannel), in SubchannelWrapper()
1761 Subchannel* subchannel = in CreateSubchannel() local
1764 if (subchannel == nullptr) return nullptr; in CreateSubchannel()
1766 subchannel->ThrottleKeepaliveTime(chand_->keepalive_time_); in CreateSubchannel()
1769 chand_, subchannel, std::move(health_check_service_name)); in CreateSubchannel()
2467 if (result.subchannel != nullptr) { in DoPingLocked()
2468 SubchannelWrapper* subchannel = in DoPingLocked() local
2469 static_cast<SubchannelWrapper*>(result.subchannel.get()); in DoPingLocked()
[all …]
|
| D | lb_policy.h | 227 RefCountedPtr<SubchannelInterface> subchannel; member
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Target/SystemZ/ |
| D | SystemZInstrSystem.td | 467 // Clear subchannel.
471 // Halt subchannel.
475 // Modify subchannel.
479 // Resume subchannel.
483 // Start subchannel.
487 // Store subchannel.
491 // Test subchannel.
495 // Cancel subchannel.
|
| /third_party/grpc/doc/ |
| D | load-balancing.md | 123 3. The load balancing policy creates a subchannel to each server address.
124 - For all policies *except* `grpclb`, this means one subchannel for each
139 policy. The `grpclb` policy will then create a subchannel to each of
142 subchannel (i.e., which server) the RPC should be sent to.
|
| D | environment_variables.md | 84 - subchannel - traces the connectivity state of subchannel
85 - subchannel_pool - traces subchannel pool
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | xds_cluster_impl.cc | 327 if (result.type == result.PICK_COMPLETE && result.subchannel != nullptr) { in Pick()
331 static_cast<StatsSubchannelWrapper*>(result.subchannel.get()); in Pick()
337 result.subchannel = subchannel_wrapper->wrapped_subchannel(); in Pick()
|
| D | lrs.cc | 172 result.subchannel != nullptr) { in Pick()
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | channelz.pyx.pxi | 62 raise ValueError('Failed to get the subchannel, please ensure your' \
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 241 SubchannelWrapper(RefCountedPtr<SubchannelInterface> subchannel, in SubchannelWrapper() argument
244 : DelegatingSubchannel(std::move(subchannel)), in SubchannelWrapper()
629 result.subchannel != nullptr) { in Pick()
631 static_cast<SubchannelWrapper*>(result.subchannel.get()); in Pick()
657 result.subchannel = subchannel_wrapper->wrapped_subchannel(); in Pick()
|
| /third_party/grpc/test/core/util/ |
| D | test_lb_policies.cc | 231 result.subchannel != nullptr) { in Pick()
|
| /third_party/grpc/ |
| D | gRPC-Core.podspec | 285 'src/core/ext/filters/client_channel/subchannel.cc',
286 'src/core/ext/filters/client_channel/subchannel.h',
1143 'src/core/ext/filters/client_channel/subchannel.h',
|
| D | gRPC-C++.podspec | 260 'src/core/ext/filters/client_channel/subchannel.h',
747 'src/core/ext/filters/client_channel/subchannel.h',
|
| D | BUILD | 1044 "src/core/ext/filters/client_channel/subchannel.cc",
1077 "src/core/ext/filters/client_channel/subchannel.h",
|
| D | grpc.gyp | 496 'src/core/ext/filters/client_channel/subchannel.cc',
1005 'src/core/ext/filters/client_channel/subchannel.cc',
|