| /aosp_15_r20/external/pigweed/pw_bluetooth_sapphire/host/hci/ |
| H A D | sequential_command_runner.cc | 37 command_queue_.emplace( in QueueCommand()
55 command_queue_.emplace( in QueueLeAsyncCommand()
71 PW_DCHECK(!command_queue_.empty()); in RunCommands()
86 return !command_queue_.empty(); in HasQueuedCommands()
93 if (status.is_error() || (command_queue_.empty() && running_commands_ == 0)) { in TryRunNextQueuedCommand()
99 if (command_queue_.empty() || in TryRunNextQueuedCommand()
100 (running_commands_ > 0 && command_queue_.front().wait)) { in TryRunNextQueuedCommand()
104 QueuedCommand next = std::move(command_queue_.front()); in TryRunNextQueuedCommand()
105 command_queue_.pop(); in TryRunNextQueuedCommand()
183 if (!command_queue_.empty()) { in Reset()
[all …]
|
| /aosp_15_r20/packages/modules/Bluetooth/system/gd/hci/ |
| D | hci_layer_fake.cc | 80 command_queue_.push(std::move(command)); in EnqueueCommand()
83 if (command_queue_.size() == 1) { in EnqueueCommand()
96 command_queue_.push(std::move(command)); in EnqueueCommand()
99 if (command_queue_.size() == 1) { in EnqueueCommand()
117 if (command_queue_.empty()) { in GetCommand()
122 auto last = std::move(command_queue_.front()); in GetCommand()
123 command_queue_.pop(); in GetCommand()
125 if (command_queue_.empty()) { in GetCommand()
143 void HciLayerFake::AssertNoQueuedCommand() { EXPECT_TRUE(command_queue_.empty()); } in AssertNoQueuedCommand()
|
| D | hci_layer.cc | 160 command_queue_.clear(); in ~impl()
194 command_queue_.emplace_back(std::move(command), std::move(on_response)); in enqueue_command()
226 log::assert_that(!command_queue_.empty(), "Unexpected {} event with OpCode {}", logging_id, in handle_command_response()
239 WaitingFor waiting_for = command_queue_.front().waiting_for_; in handle_command_response()
259 (*command_queue_.front().GetCallback<CommandCompleteView>())(command_complete_view); in handle_command_response()
264 (*command_queue_.front().GetCallback<TResponse>())(std::move(response_view)); in handle_command_response()
266 (*command_queue_.front().GetCallback<CommandStatusOrCompleteView>())( in handle_command_response()
278 auto& command_view = *command_queue_.front().command_view; in handle_command_response()
288 command_queue_.pop_front(); in handle_command_response()
302 log::error("Flushing {} waiting commands", command_queue_.size()); in on_hci_timeout()
[all …]
|
| D | le_periodic_sync_manager_test.cc | 54 command_queue_.push(std::move(command)); in EnqueueCommand()
65 command_queue_.push(std::move(command)); in EnqueueCommand()
87 if (command_queue_.empty()) { in GetLastCommand()
91 auto last = std::move(command_queue_.front()); in GetLastCommand()
92 command_queue_.pop(); in GetLastCommand()
97 if (!command_queue_.empty()) { in GetCommand()
108 log::assert_that(!command_queue_.empty(), "Expecting command {} but command queue was empty", in GetCommand()
137 std::queue<std::unique_ptr<CommandBuilder>> command_queue_; member in bluetooth::hci::__anon9f5ede890111::TestLeScanningInterface
|
| D | hci_layer_fake.h | 116 std::queue<std::unique_ptr<CommandBuilder>> command_queue_; variable
|
| /aosp_15_r20/packages/modules/Bluetooth/system/gd/hci/acl_manager/ |
| D | le_acl_connection_test.cc | 70 command_queue_.push(std::move(command)); in EnqueueCommand()
83 command_queue_.push(std::move(command)); in EnqueueCommand()
104 auto packet = std::move(command_queue_.front()); in DequeueCommand()
105 command_queue_.pop(); in DequeueCommand()
125 return command_queue_.empty(); in IsPacketQueueEmpty()
130 return command_queue_.size(); in NumberOfQueuedCommands()
137 std::queue<std::unique_ptr<hci::CommandBuilder>> command_queue_; member in bluetooth::hci::acl_manager::__anon67124b5c0111::TestLeAclConnectionInterface
|
| D | classic_acl_connection_test.cc | 123 command_queue_.push(std::move(command)); in EnqueueCommand()
136 command_queue_.push(std::move(command)); in EnqueueCommand()
157 auto packet = std::move(command_queue_.front()); in DequeueCommand()
158 command_queue_.pop(); in DequeueCommand()
172 return command_queue_.empty(); in IsPacketQueueEmpty()
177 return command_queue_.size(); in NumberOfQueuedCommands()
184 std::queue<std::unique_ptr<hci::CommandBuilder>> command_queue_; member in TestAclConnectionInterface
|
| /aosp_15_r20/external/tensorflow/tensorflow/lite/delegates/gpu/gl/kernels/ |
| H A D | converter.cc | 55 : command_queue_(command_queue) {} in OpenGlConverterImpl()
73 if (command_queue_) { in Dispatch()
74 return command_queue_->Dispatch(program_, num_workgroups); in Dispatch()
81 CommandQueue* command_queue_; member in tflite::gpu::gl::__anonf5dd32d10111::OpenGlConverterImpl
350 : command_queue_(command_queue) {} in TensorConverterBuilderImpl()
378 impl = std::make_unique<FromTensorConverter>(command_queue_); in MakeConverter()
380 impl = std::make_unique<ToTensorConverter>(command_queue_); in MakeConverter()
390 CommandQueue* command_queue_; member in tflite::gpu::gl::__anonf5dd32d10111::TensorConverterBuilderImpl
|
| /aosp_15_r20/device/google/cuttlefish/host/commands/secure_env/ |
| D | in_process_tpm.cpp | 65 impl->command_queue_.emplace_back(command, command + size); in Transmit()
79 if (impl->command_queue_.empty()) { in Receive()
82 request = std::move(impl->command_queue_.front()); in Receive()
83 impl->command_queue_.pop_front(); in Receive()
176 std::list<std::vector<uint8_t>> command_queue_; member in cuttlefish::InProcessTpm::Impl
|
| /aosp_15_r20/external/tensorflow/tensorflow/lite/delegates/gpu/ |
| H A D | gl_delegate.cc | 263 command_queue_ = NewCommandQueue(gpu_info); in Prepare()
273 command_queue_.get(), in Prepare()
295 ref.shape, *external_object, command_queue_.get(), in Invoke()
320 command_queue_.get(), external_object)); in Invoke()
327 RETURN_IF_ERROR(command_queue_->WaitForCompletion()); in Invoke()
368 std::unique_ptr<CommandQueue> command_queue_; member in tflite::gpu::gl::__anonb2eaa8210111::Delegate
|
| H A D | metal_delegate.mm | 109 command_queue_ = command_queue;
110 device_ = [command_queue_ device];
128 id<MTLCommandBuffer> command_buffer = [command_queue_ commandBuffer];
154 id<MTLCommandQueue> command_queue_;
183 command_queue_ = [metal_device_ newCommandQueue];
185 gpu_alarm_clock_ = std::unique_ptr<GpuAlarmClock>(new GpuAlarmClock(command_queue_));
479 command_buffer = [command_queue_ commandBuffer];
512 inference_context_.EncodeWithCommandQueue(command_queue_, flush_period);
513 command_buffer = [command_queue_ commandBuffer];
548 id<MTLCommandBuffer> signal_cb = [command_queue_ commandBuffer];
[all …]
|
| /aosp_15_r20/external/tensorflow/tensorflow/lite/delegates/gpu/gl/ |
| H A D | runtime.h | 63 CommandQueue* command_queue() { return command_queue_; } in command_queue()
88 CommandQueue* command_queue_; variable
|
| H A D | runtime.cc | 249 command_queue_(command_queue) { in Runtime()
653 RETURN_IF_ERROR(command_queue_->Dispatch(descriptor.program, in Execute()
|
| /aosp_15_r20/external/pigweed/pw_bluetooth_sapphire/public/pw_bluetooth_sapphire/internal/host/hci/ |
| H A D | sequential_command_runner.h | 151 std::queue<QueuedCommand> command_queue_; variable
|