Home
last modified time | relevance | path

Searched refs:queue_type (Results 1 – 22 of 22) sorted by relevance

/external/crosvm/devices/src/virtio/video/
Dcommand.rs65 queue_type: QueueType,
79 queue_type: QueueType,
86 queue_type: QueueType,
93 queue_type: QueueType,
97 queue_type: QueueType,
101 queue_type: QueueType,
105 queue_type: QueueType,
134 let virtio_video_query_capability { queue_type, .. } = r.read_obj()?; in from_reader()
136 queue_type: queue_type.try_into()?, in from_reader()
172 queue_type, in from_reader()
[all …]
Dasync_cmd_desc_map.rs45 queue_type, in create_cancellation_responses()
48 && target_queue_type.as_ref().unwrap_or(&queue_type) == queue_type => in create_cancellation_responses()
69 queue_type, in create_cancellation_responses()
71 && target_queue_type.as_ref().unwrap_or(&queue_type) == queue_type => in create_cancellation_responses()
Ddevice.rs30 queue_type: QueueType,
38 queue_type: QueueType,
43 queue_type: QueueType,
Dparams.rs78 pub fn to_virtio_video_params(&self, queue_type: QueueType) -> virtio_video_params { in to_virtio_video_params()
97 queue_type: (queue_type as u32).into(), in to_virtio_video_params()
Dprotocol.rs147 pub queue_type: Le32, field
250 pub queue_type: Le32, field
263 pub queue_type: Le32, field
293 pub queue_type: Le32, field
302 pub queue_type: Le32, field
325 pub queue_type: Le32, field
339 pub queue_type: Le32, field
Dresponse.rs44 queue_type: QueueType,
119 GetParams { queue_type, params } => { in write()
120 let params = params.to_virtio_video_params(*queue_type); in write()
Dworker.rs166 queue_type, in handle_command_desc()
167 } => desc_map.create_cancellation_responses(&stream_id, Some(queue_type), None), in handle_command_desc()
173 queue_type: QueueType::Output, in handle_command_desc()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-currentthread.hpp137 typedef detail::action_queue queue_type; typedef
157 queue_type::push(queue_type::item_type(now(), scbl)); in schedule()
161 queue_type::push(queue_type::item_type(when, scbl)); in schedule()
193 if (queue_type::owned()) { in schedule()
195 queue_type::get_worker_interface()->schedule(when, scbl); in schedule()
200 queue_type::ensure(std::make_shared<derecurser>()); in schedule()
204 queue_type::destroy(); in schedule()
207 const auto& recursor = queue_type::get_recursion().get_recurse(); in schedule()
212 if (queue_type::empty()) { in schedule()
218 auto next = queue_type::top().when; in schedule()
[all …]
Drx-newthread.hpp27 typedef detail::action_queue queue_type; typedef
95 queue_type::ensure(std::make_shared<new_worker>(keepAlive)); in new_worker()
98 queue_type::destroy(); in new_worker()
Drx-runloop.hpp127 typedef detail::action_queue queue_type; typedef in rxcpp::schedulers::run_loop
143 queue_type::ensure(sc->create_worker_interface()); in run_loop()
152 queue_type::destroy(); in ~run_loop()
/external/crosvm/devices/src/virtio/video/decoder/
Dmod.rs238 queue_type: QueueType::Output, in output_pending_picture()
258 queue_type: QueueType, in get_resource_info()
262 let res_id_to_res_handle = match queue_type { in get_resource_info()
283 fn register_buffer(&mut self, queue_type: QueueType, resource_id: u32, uuid: &u128) { in register_buffer()
288 let res_id_to_res_handle = match queue_type { in register_buffer()
405 fn query_capabilities(&self, queue_type: QueueType) -> CmdResponse { in query_capabilities()
406 let descs = match queue_type { in query_capabilities()
467 queue_type: QueueType, in create_resource()
485 ctx.register_buffer(queue_type, resource_id, &uuid); in create_resource()
487 if queue_type == QueueType::Input { in create_resource()
[all …]
/external/crosvm/devices/src/virtio/video/encoder/
Dmod.rs251 queue_type: QueueType::Input, in require_input_buffers()
254 queue_type: QueueType::Input, in require_input_buffers()
265 queue_type: QueueType::Output, in require_input_buffers()
268 queue_type: QueueType::Output, in require_input_buffers()
323 queue_type: QueueType::Input, in processed_input_buffer()
379 queue_type: QueueType::Output, in processed_output_buffer()
427 queue_type: QueueType::Output, in flush_response()
455 queue_type: QueueType::Input, in flush_response()
467 queue_type: QueueType::Output, in flush_response()
522 fn query_capabilities(&self, queue_type: QueueType) -> VideoResult<VideoCmdResponseType> { in query_capabilities()
[all …]
/external/llvm-project/lldb/test/API/commands/expression/import-std-module/queue/
DTestQueueFromStdModule.py25 queue_type = "std::queue<C>"
26 size_type = queue_type + "::size_type"
32 result_type=queue_type,
57 queue_type = "std::queue<C, std::list<C> >"
58 size_type = queue_type + "::size_type"
62 result_type=queue_type,
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-skip_last.hpp47 typedef std::queue<T> queue_type; typedef
48 typedef typename queue_type::size_type queue_size_type;
80 queue_type items; in on_subscribe()
Drx-take_last.hpp47 typedef std::queue<T> queue_type; typedef
48 typedef typename queue_type::size_type queue_size_type;
80 queue_type items; in on_subscribe()
Drx-observe_on.hpp69 typedef std::deque<base_notification_type> queue_type; typedef
84 mutable queue_type fill_queue;
85 mutable queue_type drain_queue;
105 queue_type fill_expired; in finish()
107 queue_type drain_expired; in finish()
/external/libchrome/base/task/sequence_manager/
Dwork_queue.h36 WorkQueue(TaskQueueImpl* task_queue, const char* name, QueueType queue_type);
101 QueueType queue_type() const { return queue_type_; } in queue_type() function
Dwork_queue.cc15 QueueType queue_type) in WorkQueue() argument
16 : task_queue_(task_queue), name_(name), queue_type_(queue_type) {} in WorkQueue()
Dsequence_manager_impl.cc344 work_queue->queue_type()}; in TakeTask()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-synchronize.hpp30 typedef std::deque<base_notification_type> queue_type; typedef
44 mutable queue_type fill_queue;
/external/kernel-headers/original/uapi/linux/
Dkfd_ioctl.h58 __u32 queue_type; /* to KFD */ member
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-scheduler.hpp913 > queue_type; typedef in rxcpp::schedulers::detail::schedulable_queue
915 queue_type q;