Lines Matching defs:local_id
103 MessageInTransit::EndpointId local_id;
115 local_id = next_local_id_;
117 local_id_to_endpoint_map_[local_id] = endpoint;
120 endpoint->AttachToChannel(this, local_id);
121 return local_id;
124 bool Channel::RunMessagePipeEndpoint(MessageInTransit::EndpointId local_id,
135 local_id_to_endpoint_map_.find(local_id);
146 "(local ID " << local_id << ", remote ID " << remote_id << ")";
157 MessageInTransit::EndpointId local_id,
162 DCHECK(local_id_to_endpoint_map_.find(local_id) !=
169 local_id,
174 static_cast<unsigned>(local_id),
200 MessageInTransit::EndpointId local_id,
202 DCHECK_NE(local_id, MessageInTransit::kInvalidEndpointId);
212 IdToEndpointMap::iterator it = local_id_to_endpoint_map_.find(local_id);
240 local_id,
245 static_cast<unsigned>(local_id),
318 MessageInTransit::EndpointId local_id = message_view.destination_id();
319 if (local_id == MessageInTransit::kInvalidEndpointId) {
337 local_id_to_endpoint_map_.find(local_id);
349 static_cast<unsigned>(local_id)));
361 << local_id << ", remote ID = " << message_view.source_id() << ")";
385 static_cast<unsigned>(local_id),
444 MessageInTransit::EndpointId local_id,
456 IdToEndpointMap::iterator it = local_id_to_endpoint_map_.find(local_id);
487 local_id,
492 static_cast<unsigned>(local_id),
502 MessageInTransit::EndpointId local_id,
505 << ", local ID " << local_id << ", remote ID " << remote_id;
508 message->set_source_id(local_id);
