Home
last modified time | relevance | path

Searched refs:peer_string (Results 1 – 18 of 18) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_custom.cc72 char* peer_string; member
78 gpr_free(tcp->peer_string); in tcp_free()
137 gpr_log(GPR_INFO, "READ %p (peer=%s): %s", tcp, tcp->peer_string, dump); in call_read_cb()
234 gpr_log(GPR_INFO, "WRITE %p (peer=%s): %s", tcp->socket, tcp->peer_string, in endpoint_write()
319 return gpr_strdup(tcp->peer_string); in endpoint_get_peer()
342 char* peer_string) { in custom_tcp_endpoint_create() argument
356 tcp->peer_string = gpr_strdup(peer_string); in custom_tcp_endpoint_create()
358 tcp->resource_user = grpc_resource_user_create(resource_quota, peer_string); in custom_tcp_endpoint_create()
Dendpoint_cfstream.cc58 char* peer_string; member
68 gpr_free(ep->peer_string); in CFStreamFree()
114 grpc_slice_from_copied_string(ep->peer_string)); in CFStreamAnnotateError()
128 gpr_log(GPR_DEBUG, "READ %p (peer=%s): %s", ep, ep->peer_string, dump); in CallReadCb()
234 gpr_log(GPR_DEBUG, "WRITE %p (peer=%s): %s", ep, ep->peer_string, dump); in WriteAction()
313 return gpr_strdup(ep_impl->peer_string); in CFStreamGetPeer()
336 const char* peer_string, grpc_resource_quota* resource_quota, in grpc_cfstream_endpoint_create() argument
354 ep_impl->peer_string = gpr_strdup(peer_string); in grpc_cfstream_endpoint_create()
364 grpc_resource_user_create(resource_quota, peer_string); in grpc_cfstream_endpoint_create()
Dtcp_windows.cc127 char* peer_string; member
133 gpr_free(tcp->peer_string); in tcp_free()
420 return gpr_strdup(tcp->peer_string); in win_get_peer()
443 const char* peer_string) { in grpc_tcp_create() argument
462 tcp->peer_string = gpr_strdup(peer_string); in grpc_tcp_create()
463 tcp->resource_user = grpc_resource_user_create(resource_quota, peer_string); in grpc_tcp_create()
Dtcp_posix.cc105 char* peer_string; member
315 grpc_slice_from_copied_string(tcp->peer_string)); in tcp_annotate_error()
332 gpr_free(tcp->peer_string); in tcp_free()
398 gpr_log(GPR_INFO, "READ %p (peer=%s): %s", tcp, tcp->peer_string, dump); in call_read_cb()
923 gpr_log(GPR_INFO, "WRITE %p (peer=%s): %s", tcp, tcp->peer_string, data); in tcp_write()
980 return gpr_strdup(tcp->peer_string); in tcp_get_peer()
1008 const char* peer_string) { in grpc_tcp_create() argument
1048 tcp->peer_string = gpr_strdup(peer_string); in grpc_tcp_create()
1068 tcp->resource_user = grpc_resource_user_create(resource_quota, peer_string); in grpc_tcp_create()
Dendpoint_cfstream.h44 const char* peer_string, grpc_resource_quota* resource_quota,
Dtcp_windows.h45 const char* peer_string);
Dtcp_posix.h46 const char* peer_string);
Dtcp_custom.h79 char* peer_string);
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.h212 op_->payload->send_initial_metadata.peer_string != nullptr) { in get_peer_string()
213 return op_->payload->send_initial_metadata.peer_string; in get_peer_string()
215 op_->payload->recv_initial_metadata.peer_string != nullptr) { in get_peer_string()
216 return op_->payload->recv_initial_metadata.peer_string; in get_peer_string()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc56 t->is_client ? "CLIENT" : "SERVER", t->peer_string); in maybe_initiate_ping()
65 t->is_client ? "CLIENT" : "SERVER", t->peer_string, in maybe_initiate_ping()
87 t->is_client ? "CLIENT" : "SERVER", t->peer_string, in maybe_initiate_ping()
111 t->is_client ? "CLIENT" : "SERVER", t->peer_string, in maybe_initiate_ping()
151 t->peer_string, t, s->id, staller, s->flow_controlled_buffer.length, in report_stall()
Dchttp2_transport.cc197 gpr_free(t->peer_string); in destruct_transport()
477 t->peer_string = grpc_endpoint_get_peer(ep); in init_transport()
1242 grpc_slice_from_copied_string(t->peer_string)); in grpc_chttp2_complete_closure_step()
1487 if (op_payload->send_initial_metadata.peer_string != nullptr) { in perform_stream_op_locked()
1488 gpr_atm_rel_store(op_payload->send_initial_metadata.peer_string, in perform_stream_op_locked()
1489 (gpr_atm)t->peer_string); in perform_stream_op_locked()
1603 if (op_payload->recv_initial_metadata.peer_string != nullptr) { in perform_stream_op_locked()
1604 gpr_atm_rel_store(op_payload->recv_initial_metadata.peer_string, in perform_stream_op_locked()
1605 (gpr_atm)t->peer_string); in perform_stream_op_locked()
2570 gpr_log(GPR_INFO, "%s: Start BDP ping err=%s", t->peer_string, in start_bdp_ping_locked()
[all …]
Dframe_settings.cc228 t->is_client ? "CLI" : "SVR", t->peer_string, sp->name, in grpc_chttp2_settings_parser_parse()
Dflow_control.cc179 bdp_estimator_(t->peer_string), in TransportFlowControl()
Dinternal.h285 char* peer_string; member
/external/grpc-grpc/src/core/lib/transport/
Dtransport.h179 gpr_atm* peer_string; member
211 gpr_atm* peer_string; member
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc160 gpr_atm peer_string; member
615 char* peer_string = (char*)gpr_atm_acq_load(&call->peer_string); in grpc_call_get_peer() local
616 if (peer_string != nullptr) return gpr_strdup(peer_string); in grpc_call_get_peer()
617 peer_string = grpc_channel_get_target(call->channel); in grpc_call_get_peer()
618 if (peer_string != nullptr) return peer_string; in grpc_call_get_peer()
1586 stream_op_payload->send_initial_metadata.peer_string = in call_start_batch()
1587 &call->peer_string; in call_start_batch()
1735 stream_op_payload->recv_initial_metadata.peer_string = in call_start_batch()
1736 &call->peer_string; in call_start_batch()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc978 gpr_atm* peer_string; member
1030 calld->peer_string = batch->payload->send_initial_metadata.peer_string; in maybe_cache_send_ops_for_batch()
2234 batch_data->batch.payload->send_initial_metadata.peer_string = in add_retriable_send_initial_metadata_op()
2235 calld->peer_string; in add_retriable_send_initial_metadata_op()
/external/wpa_supplicant_8/wpa_supplicant/dbus/
Ddbus_new_handlers.c2196 const char *peer_string; in get_peer_hwaddr_helper() local
2201 DBUS_TYPE_STRING, &peer_string, in get_peer_hwaddr_helper()
2207 if (hwaddr_aton(peer_string, peer_address)) { in get_peer_hwaddr_helper()
2209 func_name, peer_string); in get_peer_hwaddr_helper()