Home
last modified time | relevance | path

Searched refs:queue_event (Results 1 – 25 of 28) sorted by relevance

12

/external/python/watchdog/src/watchdog/observers/
Dinotify.py146 self.queue_event(cls(src_path, dest_path))
147 self.queue_event(DirModifiedEvent(os.path.dirname(src_path)))
148 self.queue_event(DirModifiedEvent(os.path.dirname(dest_path)))
151 self.queue_event(sub_moved_event)
158 self.queue_event(cls("", src_path))
161 self.queue_event(cls(src_path))
162 self.queue_event(DirModifiedEvent(os.path.dirname(src_path)))
165 self.queue_event(sub_created_event)
168 self.queue_event(cls(src_path))
171 self.queue_event(cls(src_path))
[all …]
Dpolling.py89 self.queue_event(DirDeletedEvent(self.watch.path))
98 self.queue_event(FileDeletedEvent(src_path))
100 self.queue_event(FileModifiedEvent(src_path))
102 self.queue_event(FileCreatedEvent(src_path))
104 self.queue_event(FileMovedEvent(src_path, dest_path))
108 self.queue_event(DirDeletedEvent(src_path))
110 self.queue_event(DirModifiedEvent(src_path))
112 self.queue_event(DirCreatedEvent(src_path))
114 self.queue_event(DirMovedEvent(src_path, dest_path))
Dread_directory_changes.py82 self.queue_event(DirMovedEvent(src_path, dest_path))
85 self.queue_event(sub_moved_event)
87 self.queue_event(FileMovedEvent(src_path, dest_path))
90 self.queue_event(cls(src_path))
94 self.queue_event(cls(src_path))
97 self.queue_event(sub_created_event)
99 self.queue_event(FileDeletedEvent(src_path))
101 self.queue_event(DirDeletedEvent(self.watch.path))
Dfsevents2.py221 self.queue_event(cls(event.path, events[i + 1].path))
222 self.queue_event(DirModifiedEvent(os.path.dirname(event.path)))
223 self.queue_event(DirModifiedEvent(os.path.dirname(events[i + 1].path)))
227 self.queue_event(cls(event.path))
228 self.queue_event(DirModifiedEvent(os.path.dirname(event.path)))
231 self.queue_event(cls(event.path))
232 self.queue_event(DirModifiedEvent(os.path.dirname(event.path)))
237 self.queue_event(cls(event.path))
241 self.queue_event(cls(event.path))
242 self.queue_event(DirModifiedEvent(os.path.dirname(event.path)))
[all …]
Dfsevents.py86 def queue_event(self, event: FileSystemEvent) -> None: member in FSEventsEmitter
91 EventEmitter.queue_event(self, event)
111 self.queue_event(cls(src_path))
112 self.queue_event(DirModifiedEvent(dirname))
116 self.queue_event(cls(src_path))
117 self.queue_event(DirModifiedEvent(dirname))
121 self.queue_event(cls(src_path))
133 self.queue_event(cls(src_path, dst_path))
134 self.queue_event(DirModifiedEvent(src_dirname))
135 self.queue_event(DirModifiedEvent(dst_dirname))
[all …]
Dkqueue.py468 def queue_event(self, event: FileSystemEvent) -> None: member in KqueueEmitter
479 EventEmitter.queue_event(self, event)
628 self.queue_event(DirCreatedEvent(directory_created))
630 self.queue_event(FileCreatedEvent(file_created))
632 self.queue_event(FileModifiedEvent(file_modified))
636 self.queue_event(event)
Dapi.py133 def queue_event(self, event: FileSystemEvent) -> None: member in EventEmitter
/external/virtio-media/extras/ffmpeg-decoder/src/
Devent_queue.rs32 pub fn queue_event(&mut self, event: T) -> nix::Result<()> { in queue_event() method
97 .queue_event(VideoDecoderBackendEvent::InputBufferDone(1)) in event_queue()
101 .queue_event(VideoDecoderBackendEvent::FrameCompleted { in event_queue()
150 .queue_event(VideoDecoderBackendEvent::InputBufferDone(1)) in decoder_event_queue_polling()
154 .queue_event(VideoDecoderBackendEvent::InputBufferDone(2)) in decoder_event_queue_polling()
158 .queue_event(VideoDecoderBackendEvent::InputBufferDone(3)) in decoder_event_queue_polling()
Dlib.rs407 .queue_event(VideoDecoderBackendEvent::InputBufferDone(*input_index)) in try_send_input_job()
481 .queue_event(VideoDecoderBackendEvent::StreamFormatChanged) in try_receive_frame()
551 .queue_event(VideoDecoderBackendEvent::FrameCompleted { in try_output_frame()
620 .queue_event(VideoDecoderBackendEvent::FrameCompleted { in try_output_frame()
/external/crosvm/devices/src/virtio/video/
Dutils.rs41 pub fn queue_event(&mut self, event: T) -> base::Result<()> { in queue_event() method
109 pub fn queue_event(&self, event: T) -> base::Result<()> { in queue_event() method
110 self.0.lock().queue_event(event) in queue_event()
276 event_queue.queue_event(TestEvent::NotifyEndOfBitstreamBuffer(1)), in event_queue()
281 event_queue.queue_event(TestEvent::PictureReady { in event_queue()
332 .queue_event(TestEvent::NotifyEndOfBitstreamBuffer(1)) in decoder_event_queue_polling()
336 .queue_event(TestEvent::NotifyEndOfBitstreamBuffer(2)) in decoder_event_queue_polling()
340 .queue_event(TestEvent::NotifyEndOfBitstreamBuffer(3)) in decoder_event_queue_polling()
/external/crosvm/devices/src/virtio/video/decoder/backend/
Dffmpeg.rs69 .queue_event(DecoderEvent::NotifyEndOfBitstreamBuffer(self.resource_id)) in drop()
183 fn queue_event(&mut self, event: DecoderEvent) -> base::Result<()> { in queue_event() method
184 self.event_queue.queue_event(event) in queue_event()
195 self.queue_event(DecoderEvent::ProvidePictureBuffers { in change_resolution()
320 self.queue_event(DecoderEvent::FlushCompleted(Err( in try_receive_frame()
333 self.queue_event(DecoderEvent::FlushCompleted(Ok(())))?; in try_receive_frame()
345 if let Err(e) = self.event_queue.queue_event(DecoderEvent::NotifyError( in try_receive_frame()
400 self.event_queue.queue_event(picture_ready_event)?; in try_send_frame()
502 self.queue_event(DecoderEvent::ResetCompleted(Ok(()))) in reset()
Dvaapi.rs552 .queue_event(DecoderEvent::PictureReady { in output_picture()
570 .queue_event(DecoderEvent::FlushCompleted(Ok(()))) in try_emit_flush_completed()
593 .queue_event(DecoderEvent::NotifyEndOfBitstreamBuffer(job.resource_id)) in drain_submit_queue()
614 .queue_event(DecoderEvent::NotifyError(VideoError::BackendFailure( in drain_submit_queue()
647 .queue_event(DecoderEvent::ProvidePictureBuffers { in process_decoder_events()
846 .queue_event(DecoderEvent::ResetCompleted(Ok(()))) in reset()
/external/crosvm/devices/src/virtio/video/encoder/backend/
Dffmpeg.rs71 .queue_event(EncoderEvent::ProcessedInputBuffer { id: self.buffer_id }) in drop()
183 .queue_event(EncoderEvent::FlushResponse { flush_done: false }) in try_receive_packet()
195 .queue_event(EncoderEvent::FlushResponse { flush_done: true }) in try_receive_packet()
215 .queue_event(EncoderEvent::ProcessedOutputBuffer { in try_receive_packet()
515 .queue_event(EncoderEvent::RequireInputBuffers { in start_session()
/external/crosvm/devices/src/virtio/
Dballoon.rs350 mut queue_event: EventAsync, in handle_queue()
360 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_queue()
402 mut queue_event: EventAsync, in handle_reporting_queue()
412 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_reporting_queue()
451 mut queue_event: EventAsync, in handle_stats_queue()
459 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_stats_queue()
491 avail_desc = match queue.next_async(&mut queue_event).await { in handle_stats_queue()
542 mut queue_event: EventAsync, in handle_ws_op_queue()
563 .next_async(&mut queue_event) in handle_ws_op_queue()
638 mut queue_event: EventAsync, in handle_ws_data_queue()
[all …]
Dqueue.rs431 queue_event: &mut EventAsync, in next_async_interruptable()
435 avail_desc_res = self.next_async(queue_event).fuse() => { in next_async_interruptable()
Dpmem.rs268 mut queue_event: EventAsync, in handle_queue()
274 let mut avail_desc = match queue.next_async(&mut queue_event).await { in handle_queue()
Diommu.rs607 mut queue_event: EventAsync, in request_queue()
611 .next_async(&mut queue_event) in request_queue()
/external/mesa3d/src/amd/vulkan/
Dradv_sqtt.c714 struct rgp_queue_event *queue_event = &sqtt->rgp_queue_event; in radv_reset_sqtt_trace() local
726 simple_mtx_lock(&queue_event->lock); in radv_reset_sqtt_trace()
727 list_for_each_entry_safe (struct rgp_queue_event_record, record, &queue_event->record, list) { in radv_reset_sqtt_trace()
731 queue_event->record_count = 0; in radv_reset_sqtt_trace()
732 simple_mtx_unlock(&queue_event->lock); in radv_reset_sqtt_trace()
/external/crosvm/devices/src/virtio/snd/common_backend/
Dasync_funcs.rs653 queue_event: &EventAsync, in handle_pcm_queue()
668 queue_event.next_val().await?; in handle_pcm_queue()
739 queue_event: &mut EventAsync, in handle_ctrl_queue()
751 let next_async = queue.next_async(queue_event).fuse(); in handle_ctrl_queue()
999 mut queue_event: EventAsync, in handle_event_queue()
1003 .next_async(&mut queue_event) in handle_event_queue()
/external/mesa3d/src/amd/common/
Dac_rgp.c1111 struct sqtt_queue_event_record queue_event = { in ac_sqtt_dump_data() local
1121 switch (queue_event.event_type) in ac_sqtt_dump_data()
1123 queue_event.gpu_timestamps[0] = *record->gpu_timestamps[0]; in ac_sqtt_dump_data()
1124 queue_event.gpu_timestamps[1] = *record->gpu_timestamps[1]; in ac_sqtt_dump_data()
1127 queue_event.gpu_timestamps[0] = *record->gpu_timestamps[0]; in ac_sqtt_dump_data()
1134 fwrite(&queue_event, sizeof(struct sqtt_queue_event_record), 1, output); in ac_sqtt_dump_data()
/external/ublksrv/
Ddemo_event.c172 static int queue_event(struct ublksrv_aio_ctx *ctx) in queue_event() function
250 queue_event(ctx); in demo_event_uring_io_handler_fn()
264 queue_event(ctx); in demo_event_uring_io_handler_fn()
/external/python/watchdog/tests/
Dtest_observers_api.py55 event_emitter.queue_event(FileModifiedEvent("/foobar/blah"))
Dtest_observer.py82 emitter.queue_event(FileModifiedEvent(""))
/external/wayland/patches/
D0006-client-Log-unknown-messages-through-the-observer-API.diff104 @@ -1626,8 +1675,6 @@ queue_event(struct wl_display *display, int len)
113 @@ -1645,17 +1692,9 @@ queue_event(struct wl_display *display, int len)
/external/mesa3d/src/amd/vulkan/layers/
Dradv_sqtt_layer.c593 struct rgp_queue_event *queue_event = &sqtt->rgp_queue_event; in radv_describe_queue_event() local
595 simple_mtx_lock(&queue_event->lock); in radv_describe_queue_event()
596 list_addtail(&record->list, &queue_event->record); in radv_describe_queue_event()
597 queue_event->record_count++; in radv_describe_queue_event()
598 simple_mtx_unlock(&queue_event->lock); in radv_describe_queue_event()

12