Searched refs:round_index (Results 1 – 5 of 5) sorted by relevance
| /external/tensorflow/tensorflow/core/data/service/ |
| D | task_runner.cc | 217 if (req.consumer_index() < 0 || req.round_index() < 0) { in ValidateRequest()
261 first_round_ = std::min(first_round_, req.round_index()); in PrepareRound()
263 requests_[req.round_index()]; in PrepareRound()
266 requests_[req.round_index()].erase(req.consumer_index()); in PrepareRound()
268 if (current_round_ < req.round_index() && round.size() == num_consumers_) { in PrepareRound()
269 current_round_ = req.round_index(); in PrepareRound()
281 while (!cancelled_ && current_round_ < req.round_index()) { in PrepareRound()
285 if (current_round_ < req.round_index() && cancelled_) { in PrepareRound()
288 if (current_round_ != req.round_index()) { in PrepareRound()
291 req.round_index(), ", but the current round has already reached ", in PrepareRound()
[all …]
|
| D | worker.proto | 24 int64 round_index = 3; field
|
| /external/uwb/src/rust/uwb_uci_packets/src/ |
| D | lib.rs | 76 pub round_index: u8, field
102 let round_index = extract_u8(bytes, &mut ptr, 1)?; in parse_one() localVariable
138 round_index, in parse_one()
1058 assert_eq!(measurement_1.round_index, 0x07); in test_short_dltdoa_ranging_measurement()
1088 assert_eq!(measurement_2.round_index, 0x07); in test_short_dltdoa_ranging_measurement()
1140 assert_eq!(measurement.round_index, 0x07); in test_extended_dltdoa_ranging_measurement()
|
| /external/uwb/src/rust/uwb_core/src/proto/ |
| D | mappings.rs | 796 result.set_round_index(item.measurement.round_index.into()); in from()
835 result.set_round_index(item.measurement.round_index.into()); in from()
|
| /external/uwb/src/rust/uwb_core/protos/ |
| D | uwb_service.proto | 465 uint32 round_index = 5; field
|