| /aosp_15_r20/external/grpc-grpc/src/core/lib/iomgr/ |
| H A D | endpoint_cfstream.cc | 61 std::string peer_string; member
112 grpc_core::StatusStrProperty::kTargetAddress, ep->peer_string); in CFStreamAnnotateError()
127 gpr_log(GPR_DEBUG, "READ %p (peer=%s): %s", ep, ep->peer_string.c_str(), in CallReadCb()
233 gpr_log(GPR_DEBUG, "WRITE %p (peer=%s): %s", ep, ep->peer_string.c_str(), in WriteAction()
300 return ep_impl->peer_string; in CFStreamGetPeer()
332 const char* peer_string, in grpc_cfstream_endpoint_create() argument
349 ep_impl->peer_string = peer_string; in grpc_cfstream_endpoint_create()
|
| H A D | tcp_windows.cc | 127 std::string peer_string; member
211 tcp->peer_string.c_str(), dump); in on_read()
363 gpr_log(GPR_INFO, "WRITE %p (peer=%s): %s", tcp, tcp->peer_string.c_str(), in win_write()
501 return tcp->peer_string; in win_get_peer()
526 absl::string_view peer_string) { in grpc_tcp_create() argument
547 tcp->peer_string = std::string(peer_string); in grpc_tcp_create()
|
| H A D | tcp_posix.cc | 517 std::string peer_string; member
770 grpc_core::StatusStrProperty::kTargetAddress, tcp->peer_string); in tcp_annotate_error()
871 tcp->peer_string.c_str(), grpc_core::StatusToString(error).c_str()); in tcp_trace_read()
1874 gpr_log(GPR_INFO, "WRITE %p (peer=%s)", tcp, tcp->peer_string.c_str()); in tcp_write()
1947 return tcp->peer_string; in tcp_get_peer()
1987 absl::string_view peer_string) { in grpc_tcp_create() argument
1990 tcp->peer_string = std::string(peer_string); in grpc_tcp_create()
|
| H A D | endpoint_cfstream.h | 44 const char* peer_string,
|
| H A D | tcp_windows.h | 44 absl::string_view peer_string);
|
| H A D | tcp_posix.h | 47 absl::string_view peer_string);
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | endpoint_cfstream.cc | 61 std::string peer_string; member
112 grpc_core::StatusStrProperty::kTargetAddress, ep->peer_string); in CFStreamAnnotateError()
127 gpr_log(GPR_DEBUG, "READ %p (peer=%s): %s", ep, ep->peer_string.c_str(), in CallReadCb()
233 gpr_log(GPR_DEBUG, "WRITE %p (peer=%s): %s", ep, ep->peer_string.c_str(), in WriteAction()
300 return ep_impl->peer_string; in CFStreamGetPeer()
332 const char* peer_string, in grpc_cfstream_endpoint_create() argument
349 ep_impl->peer_string = peer_string; in grpc_cfstream_endpoint_create()
|
| D | tcp_windows.cc | 127 std::string peer_string; member
213 tcp->peer_string.c_str(), dump); in on_read()
365 gpr_log(GPR_INFO, "WRITE %p (peer=%s): %s", tcp, tcp->peer_string.c_str(), in win_write()
503 return tcp->peer_string; in win_get_peer()
528 absl::string_view peer_string) { in grpc_tcp_create() argument
549 tcp->peer_string = std::string(peer_string); in grpc_tcp_create()
|
| D | tcp_posix.cc | 516 std::string peer_string; member
722 grpc_core::StatusStrProperty::kTargetAddress, tcp->peer_string); in tcp_annotate_error()
814 tcp->peer_string.c_str(), grpc_core::StatusToString(error).c_str()); in tcp_trace_read()
1804 gpr_log(GPR_INFO, "WRITE %p (peer=%s)", tcp, tcp->peer_string.c_str()); in tcp_write()
1877 return tcp->peer_string; in tcp_get_peer()
1917 absl::string_view peer_string) { in grpc_tcp_create() argument
1920 tcp->peer_string = std::string(peer_string); in grpc_tcp_create()
1924 options.resource_quota->memory_quota()->CreateMemoryOwner(peer_string); in grpc_tcp_create()
|
| D | endpoint_cfstream.h | 44 const char* peer_string,
|
| D | tcp_windows.h | 44 absl::string_view peer_string);
|
| D | tcp_posix.h | 47 absl::string_view peer_string);
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/stateful_session/ |
| D | stateful_session_filter.cc | 92 Slice* peer_string = server_initial_metadata->get_pointer(PeerString()); in MaybeUpdateServerInitialMetadata() local
93 if (peer_string == nullptr) return; // Nothing we can do. in MaybeUpdateServerInitialMetadata()
96 peer_string->as_string_view() != *cookie_value) { in MaybeUpdateServerInitialMetadata()
99 absl::Base64Escape(peer_string->as_string_view()), "; HttpOnly")}; in MaybeUpdateServerInitialMetadata()
|
| /aosp_15_r20/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| H A D | chttp2_transport.cc | 506 std::string(t->peer_string.as_string_view()), in read_channel_args()
508 t->peer_string.as_string_view()), in read_channel_args()
604 peer_string( in grpc_chttp2_transport()
621 peer_string.as_string_view(), in grpc_chttp2_transport()
918 std::string(t->peer_string.as_string_view()).c_str(), in set_write_state()
1153 std::string(t->peer_string.as_string_view()).c_str(), goaway_error, in grpc_chttp2_add_incoming_goaway()
1184 std::string(t->peer_string.as_string_view()).c_str(), in grpc_chttp2_add_incoming_goaway()
1307 std::string(t->peer_string.as_string_view())); in grpc_chttp2_complete_closure_step()
1720 std::string(t->peer_string.as_string_view()).c_str(), id); in grpc_chttp2_ack_ping()
1733 std::string(t->peer_string.as_string_view()).c_str()); in grpc_chttp2_keepalive_timeout()
[all …]
|
| H A D | writing.cc | 142 std::string(t->peer_string.as_string_view()).c_str(), in maybe_initiate_ping()
155 std::string(t->peer_string.as_string_view()).c_str(), in maybe_initiate_ping()
170 std::string(t->peer_string.as_string_view()).c_str(), in maybe_initiate_ping()
218 std::string(t->peer_string.as_string_view()).c_str(), t, s->id, staller, in report_stall()
|
| H A D | parsing.cc | 688 t, std::string(t->peer_string.as_string_view()).c_str(), in init_header_frame_parser()
697 t, std::string(t->peer_string.as_string_view()).c_str(), in init_header_frame_parser()
724 std::string(t->peer_string.as_string_view()).c_str(), in init_header_frame_parser()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 405 std::string(t->peer_string.as_string_view()), in read_channel_args()
407 t->peer_string.as_string_view()), in read_channel_args()
576 peer_string( in grpc_chttp2_transport()
590 peer_string.as_string_view(), in grpc_chttp2_transport()
920 std::string(t->peer_string.as_string_view()).c_str(), in set_write_state()
1166 std::string(t->peer_string.as_string_view()).c_str(), goaway_error, in grpc_chttp2_add_incoming_goaway()
1198 std::string(t->peer_string.as_string_view()).c_str(), in grpc_chttp2_add_incoming_goaway()
1330 std::string(t->peer_string.as_string_view())); in grpc_chttp2_complete_closure_step()
1734 std::string(t->peer_string.as_string_view()).c_str(), id); in grpc_chttp2_ack_ping()
1795 std::string(t_->peer_string.as_string_view()).c_str())); in MaybeSendFinalGoawayLocked()
[all …]
|
| D | writing.cc | 99 std::string(t->peer_string.as_string_view()).c_str()); in maybe_initiate_ping()
111 std::string(t->peer_string.as_string_view()).c_str(), in maybe_initiate_ping()
155 std::string(t->peer_string.as_string_view()).c_str(), in maybe_initiate_ping()
187 std::string(t->peer_string.as_string_view()).c_str(), in maybe_initiate_ping()
225 std::string(t->peer_string.as_string_view()).c_str(), t, s->id, staller, in report_stall()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | call.cc | 218 void SetPeerString(Slice peer_string) { in SetPeerString() argument
220 peer_string_ = std::move(peer_string); in SetPeerString()
397 char* peer_string = in GetPeer() local
399 memcpy(peer_string, peer_string_view.data(), peer_string_view.size()); in GetPeer()
400 peer_string[peer_string_view.size()] = '\0'; in GetPeer()
401 return peer_string; in GetPeer()
403 char* peer_string = grpc_channel_get_target(channel_->c_ptr()); in GetPeer() local
404 if (peer_string != nullptr) return peer_string; in GetPeer()
453 Slice* peer_string = md.get_pointer(PeerString()); in ProcessIncomingInitialMetadata() local
454 if (peer_string != nullptr) SetPeerString(peer_string->Ref()); in ProcessIncomingInitialMetadata()
|
| /aosp_15_r20/external/grpc-grpc/src/core/lib/surface/ |
| H A D | call.cc | 221 void SetPeerString(Slice peer_string) { in SetPeerString() argument
223 peer_string_ = std::move(peer_string); in SetPeerString()
400 char* peer_string = in GetPeer() local
402 memcpy(peer_string, peer_string_view.data(), peer_string_view.size()); in GetPeer()
403 peer_string[peer_string_view.size()] = '\0'; in GetPeer()
404 return peer_string; in GetPeer()
406 char* peer_string = grpc_channel_get_target(channel_->c_ptr()); in GetPeer() local
407 if (peer_string != nullptr) return peer_string; in GetPeer()
455 Slice* peer_string = md.get_pointer(PeerString()); in ProcessIncomingInitialMetadata() local
456 if (peer_string != nullptr) SetPeerString(peer_string->Ref()); in ProcessIncomingInitialMetadata()
|
| /aosp_15_r20/external/grpc-grpc/src/core/client_channel/ |
| H A D | client_channel_filter.cc | 3329 auto* peer_string = self->recv_initial_metadata_->get_pointer(PeerString()); in RecvInitialMetadataReady() local
3330 if (peer_string != nullptr) self->peer_string_ = peer_string->Ref(); in RecvInitialMetadataReady()
3373 absl::string_view peer_string; in RecvTrailingMetadataReady() local
3375 peer_string = self->peer_string_->as_string_view(); in RecvTrailingMetadataReady()
3378 self->transport_stream_stats_, peer_string); in RecvTrailingMetadataReady()
3554 Slice* peer_string = metadata->get_pointer(PeerString()); in MakeCallPromise() local
3555 if (peer_string != nullptr) self->peer_string_ = peer_string->Ref(); in MakeCallPromise()
|
| /aosp_15_r20/external/grpc-grpc/src/core/ext/filters/logging/ |
| H A D | logging_filter.cc | 156 LoggingSink::Entry::Address PeerStringToAddress(const Slice& peer_string) { in PeerStringToAddress() argument
158 absl::StatusOr<URI> uri = URI::Parse(peer_string.as_string_view()); in PeerStringToAddress()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/logging/ |
| D | logging_filter.cc | 160 LoggingSink::Entry::Address PeerStringToAddress(const Slice& peer_string) { in PeerStringToAddress() argument
162 absl::StatusOr<URI> uri = URI::Parse(peer_string.as_string_view()); in PeerStringToAddress()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/posix_engine/ |
| D | posix_endpoint.cc | 282 auto peer_string = ResolvedAddressToNormalizedString(peer_address_); in TcpAnnotateError() local
286 peer_string.ok() ? *peer_string : ""); in TcpAnnotateError()
|
| /aosp_15_r20/external/grpc-grpc/src/core/lib/event_engine/posix_engine/ |
| H A D | posix_endpoint.cc | 285 auto peer_string = ResolvedAddressToNormalizedString(peer_address_); in TcpAnnotateError() local
289 peer_string.ok() ? *peer_string : ""); in TcpAnnotateError()
|