Searched refs:received_keys (Results 1 – 3 of 3) sorted by relevance
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | rendezvous_util_test.cc | 60 std::vector<Tensor> received_keys; in TEST_F() local
63 &received_keys, [&n](const Status& status) { n.Notify(); }); in TEST_F()
66 EXPECT_EQ(2, received_keys.size()); in TEST_F()
67 EXPECT_EQ("hello1", V(received_keys[0])); in TEST_F()
68 EXPECT_EQ("hello2", V(received_keys[1])); in TEST_F()
74 std::vector<Tensor> received_keys; in TEST_F() local
77 &received_keys, [&n](const Status& status) { n.Notify(); }); in TEST_F()
85 EXPECT_EQ(2, received_keys.size()); in TEST_F()
86 EXPECT_EQ("hello1", V(received_keys[0])); in TEST_F()
87 EXPECT_EQ("hello2", V(received_keys[1])); in TEST_F()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | graph_mgr.cc | 393 std::vector<Tensor>* received_keys = new std::vector<Tensor>; in RecvOutputsAsync() local
395 received_keys->reserve(out->size()); in RecvOutputsAsync()
398 received_keys->push_back(p.second); in RecvOutputsAsync()
401 rendezvous, nullptr, {}, keys, received_keys, in RecvOutputsAsync()
402 [done, rendezvous, received_keys, out, keys](const Status s) { in RecvOutputsAsync()
406 (*out)[keys[i]] = (*received_keys)[i]; in RecvOutputsAsync()
410 delete received_keys; in RecvOutputsAsync()
|
| /external/autotest/client/cros/enterprise/ |
| D | policy.py | 44 received_keys = set(['scope', 'source', 'level', 'value'])
45 return received_keys.issubset(set(data.keys()))
|