Lines Matching defs:recv
216 const auto* recv = recv_manager_.GetCurrNode();
217 candidates.emplace_back(recv, node_state_->at(recv).time_ready);
225 // Note that there can be only 1 Send and only 1 Recv in candidates,
226 // at most; hence, score is 2 for Send, 1 for Recv, and 0 for a
412 const auto* recv = send_and_recv.second;
414 curr_node_state.inputs.push_back(std::make_pair(recv, 0));
419 cached_recv_nodes[recv_node] = recv;
576 auto* recv = new NodeDef();
577 recv->set_name("Recv_" + src_name + "_on_" + SanitizedDeviceName(to));
578 recv->set_op("_Recv");
579 recv->add_input(send->name());
580 recv->set_device(DeviceName(to));
581 auto& recv_attr = *(recv->mutable_attr());
588 send_node_state.outputs[0].push_back(recv);
591 auto& recv_node_state = GetNodeStateOrCreateIt(recv);
597 additional_nodes_.emplace_back(std::unique_ptr<NodeDef>(recv));
600 return std::make_pair(send, recv);
