| /external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/ |
| D | GetSubchannelResponse.java | 54 if (subchannel_ != null) { in GetSubchannelResponse()
55 subBuilder = subchannel_.toBuilder(); in GetSubchannelResponse()
57 … subchannel_ = input.readMessage(io.grpc.channelz.v1.Subchannel.parser(), extensionRegistry); in GetSubchannelResponse()
59 subBuilder.mergeFrom(subchannel_); in GetSubchannelResponse()
60 subchannel_ = subBuilder.buildPartial(); in GetSubchannelResponse()
90 private io.grpc.channelz.v1.Subchannel subchannel_; field in GetSubchannelResponse
100 return subchannel_ != null; in hasSubchannel()
111 return subchannel_ == null ? io.grpc.channelz.v1.Subchannel.getDefaultInstance() : subchannel_; in getSubchannel()
137 if (subchannel_ != null) { in writeTo()
148 if (subchannel_ != null) { in getSerializedSize()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | subchannel_list.h | 90 grpc_subchannel* subchannel() const { return subchannel_; } in subchannel()
174 grpc_subchannel* subchannel_; variable
283 subchannel_(subchannel), in SubchannelData()
302 if (subchannel_ != nullptr) { in UnrefSubchannelLocked()
309 subchannel_); in UnrefSubchannelLocked()
311 GRPC_SUBCHANNEL_UNREF(subchannel_, reason); in UnrefSubchannelLocked()
312 subchannel_ = nullptr; in UnrefSubchannelLocked()
320 if (subchannel_ != nullptr) { in ResetBackoffLocked()
321 grpc_subchannel_reset_backoff(subchannel_); in ResetBackoffLocked()
335 subchannel_, in StartConnectivityWatchLocked()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | subchannel_list.h | 92 SubchannelInterface* subchannel() const { return subchannel_.get(); } in subchannel()
100 connectivity_state_ = subchannel_->CheckConnectivityState(); in CheckConnectivityStateLocked()
166 RefCountedPtr<SubchannelInterface> subchannel_; variable
250 subchannel_data_->subchannel_.get(), in OnConnectivityStateChange()
272 subchannel_(std::move(subchannel)), in SubchannelData()
279 GPR_ASSERT(subchannel_ == nullptr); in ~SubchannelData()
285 if (subchannel_ != nullptr) { in UnrefSubchannelLocked()
292 subchannel_.get(), reason); in UnrefSubchannelLocked()
294 subchannel_.reset(); in UnrefSubchannelLocked()
301 if (subchannel_ != nullptr) { in ResetBackoffLocked()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel_channelz.h | 73 GPR_ASSERT(subchannel_ != nullptr); in MarkSubchannelDestroyed()
74 subchannel_ = nullptr; in MarkSubchannelDestroyed()
94 grpc_subchannel* subchannel_;
|
| D | client_channel_channelz.cc | 118 subchannel_(subchannel), in SubchannelNode()
120 UniquePtr<char>(gpr_strdup(grpc_subchannel_get_target(subchannel_)))), in SubchannelNode()
127 if (subchannel_ == nullptr) { in PopulateConnectivityState()
130 state = grpc_subchannel_check_connectivity(subchannel_, nullptr); in PopulateConnectivityState()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | subchannel.cc | 306 explicit ConnectedSubchannelStateWatcher(Subchannel* c) : subchannel_(c) { in ConnectedSubchannelStateWatcher()
308 GRPC_SUBCHANNEL_WEAK_REF(subchannel_, "state_watcher"); in ConnectedSubchannelStateWatcher()
309 GRPC_SUBCHANNEL_WEAK_UNREF(subchannel_, "connecting"); in ConnectedSubchannelStateWatcher()
313 GRPC_SUBCHANNEL_WEAK_UNREF(subchannel_, "state_watcher"); in ~ConnectedSubchannelStateWatcher()
319 Subchannel* c = subchannel_; in OnConnectivityStateChange()
360 Subchannel* subchannel_; member in grpc_core::Subchannel::ConnectedSubchannelStateWatcher
429 : subchannel_(c), in HealthWatcher()
433 GRPC_SUBCHANNEL_WEAK_REF(subchannel_, "health_watcher"); in HealthWatcher()
439 GRPC_SUBCHANNEL_WEAK_UNREF(subchannel_, "health_watcher"); in ~HealthWatcher()
452 new AsyncWatcherNotifierLocked(watcher, subchannel_, state_, status_); in AddWatcherLocked()
[all …]
|
| D | client_channel.cc | 1268 subchannel_(subchannel), in SubchannelWrapper()
1273 chand, this, subchannel_); in SubchannelWrapper()
1276 auto* subchannel_node = subchannel_->channelz_node(); in SubchannelWrapper()
1278 auto it = chand_->subchannel_refcount_map_.find(subchannel_); in SubchannelWrapper()
1281 it = chand_->subchannel_refcount_map_.emplace(subchannel_, 0).first; in SubchannelWrapper()
1292 chand_, this, subchannel_); in ~SubchannelWrapper()
1295 auto* subchannel_node = subchannel_->channelz_node(); in ~SubchannelWrapper()
1297 auto it = chand_->subchannel_refcount_map_.find(subchannel_); in ~SubchannelWrapper()
1305 GRPC_SUBCHANNEL_UNREF(subchannel_, "unref from LB"); in ~SubchannelWrapper()
1312 subchannel_->CheckConnectivityState(health_check_service_name_, in CheckConnectivityState()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| D | pick_first.cc | 114 : subchannel_(std::move(subchannel)) {} in Picker()
119 result.subchannel = subchannel_; in Pick()
124 RefCountedPtr<SubchannelInterface> subchannel_; member in grpc_core::__anonbc2f1c810111::PickFirst::Picker
|