Searched refs:queue_get (Results 1 – 6 of 6) sorted by relevance
159 async def queue_get(): function162 res = self.loop.run_until_complete(queue_get())190 async def queue_get(): function199 queue_get_task = asyncio.Task(queue_get(), loop=loop)232 async def queue_get(): function236 get_task = asyncio.Task(queue_get(), loop=loop)336 async def queue_get(): function344 loop.run_until_complete(queue_get())
177 extern void *queue_get(struct queue *);
215 void *queue_get(struct queue *queue) in queue_get() function1973 struct cache_entry *entry = queue_get(to_reader); in reader()2005 struct squashfs_file *file = queue_get(to_writer); in writer()2028 struct file_entry *block = queue_get(to_writer); in writer()2107 struct cache_entry *entry = queue_get(to_inflate); in inflator()2806 queue_get(from_writer); in main()
274 struct file_buffer *file_buffer = queue_get(to_process_frag); in frag_thrd()
1644 write_buffer = queue_get(locked_fragment); in unlock_fragments()2441 reader_scan(queue_get(to_reader)); in reader()2446 queue_get(to_reader); in reader()2460 struct file_buffer *file_buffer = queue_get(to_writer); in writer()2524 struct file_buffer *file_buffer = queue_get(to_deflate); in deflator()2562 struct file_buffer *file_buffer = queue_get(to_frag); in frag_deflator()2724 if(queue_get(from_writer) != 0) in write_file_process()2821 if(queue_get(from_writer) != 0) in write_file_blocks_dup()2863 if(queue_get(from_writer) != 0) in write_file_blocks_dup()2979 if(queue_get(from_writer) != 0) in write_file_blocks()[all …]
81 void *queue_get(struct queue *queue) in queue_get() function