Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 66) sorted by relevance

123

/device/linaro/hikey/hifi/xaf/hifi-dpf/include/
Dxf-msg.h106 static inline void xf_msg_queue_init(xf_msg_queue_t *queue) in xf_msg_queue_init() argument
108 queue->head = queue->tail = NULL; in xf_msg_queue_init()
112 static inline int xf_msg_enqueue(xf_msg_queue_t *queue, xf_message_t *m) in xf_msg_enqueue() argument
114 int empty = (queue->head == NULL); in xf_msg_enqueue()
120 queue->head = m; in xf_msg_enqueue()
122 queue->tail->next = m; in xf_msg_enqueue()
125 queue->tail = m; in xf_msg_enqueue()
131 #define xf_msg_enqueue(queue, m) \ argument
134 (xf_msg_enqueue)((queue), (m)); \
138 static inline xf_message_t * xf_msg_dequeue(xf_msg_queue_t *queue) in xf_msg_dequeue() argument
[all …]
Dxf-io.h42 xf_msg_queue_t queue; member
102 return (xf_msg_queue_head(&port->queue) != NULL); in xf_input_port_ready()
142 xf_msg_queue_t queue; member
220 return (xf_msg_queue_head(&port->queue) != NULL && !xf_output_port_unrouting(port)); in xf_output_port_ready()
Dxf-trace.h54 xf_msg_queue_t queue; member
Dxf-core.h109 xf_msg_queue_t queue; member
/device/google/taimen/
Dinit-taimen.rc3 write /sys/block/sda/queue/iostats 0
4 write /sys/block/sda/queue/scheduler cfq
5 write /sys/block/sda/queue/iosched/slice_idle 0
6 write /sys/block/sda/queue/read_ahead_kb 2048
7 write /sys/block/sda/queue/nr_requests 256
8 write /sys/block/sde/queue/iostats 0
9 write /sys/block/sde/queue/scheduler cfq
10 write /sys/block/sde/queue/iosched/slice_idle 0
11 write /sys/block/sde/queue/read_ahead_kb 2048
12 write /sys/block/sde/queue/nr_requests 256
[all …]
/device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/
DQueue.py198 self.queue = deque()
201 return len(self.queue)
205 self.queue.append(item)
209 return self.queue.popleft()
219 self.queue = []
222 return len(self.queue)
225 heappush(self.queue, item)
228 return heappop(self.queue)
235 self.queue = []
238 return len(self.queue)
[all …]
Dmutex.py24 self.queue = deque()
46 self.queue.append((function, argument))
51 if self.queue:
52 function, argument = self.queue.popleft()
/device/google/muskie/
Dinit-common.rc3 write /sys/block/sda/queue/iostats 0
4 write /sys/block/sda/queue/scheduler cfq
5 write /sys/block/sda/queue/iosched/slice_idle 0
6 write /sys/block/sda/queue/read_ahead_kb 2048
7 write /sys/block/sda/queue/nr_requests 256
8 write /sys/block/dm-0/queue/read_ahead_kb 2048
9 write /sys/block/dm-1/queue/read_ahead_kb 2048
13 write /sys/block/sda/queue/read_ahead_kb 128
14 write /sys/block/sda/queue/nr_requests 128
15 write /sys/block/sda/queue/iostats 1
[all …]
/device/linaro/hikey/hifi/xaf/hifi-dpf/core/
Dxf-io.c67 xf_msg_queue_init(&port->queue); in xf_input_port_init()
115 if (xf_msg_enqueue(&port->queue, m)) in xf_input_port_put()
137 xf_message_t *m = xf_msg_dequeue(&port->queue); in xf_input_port_complete()
146 if ((m = xf_msg_queue_head(&port->queue)) != NULL) in xf_input_port_complete()
176 if (!xf_msg_queue_head(&port->queue)) in xf_input_port_fill()
273 if (xf_msg_queue_head(&port->queue) && !port->access) in xf_input_port_consume()
315 while ((m = xf_msg_dequeue(&port->queue)) != NULL) in xf_input_port_purge()
336 xf_msg_enqueue(&port->queue, m); in xf_input_port_control_save()
351 xf_response_ok(xf_msg_dequeue(&port->queue)); in xf_input_port_purge_done()
382 xf_msg_queue_init(&port->queue); in xf_output_port_init()
[all …]
Dxf-isr.c49 if (xf_msg_enqueue(&cd->queue, m)) in xf_msg_schedule_isr()
/device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/
Dtest_multiprocessing.py353 def _test_put(cls, queue, child_can_start, parent_can_continue): argument
356 queue.get()
361 queue = self.Queue(maxsize=MAXSIZE)
367 args=(queue, child_can_start, parent_can_continue)
372 self.assertEqual(queue_empty(queue), True)
373 self.assertEqual(queue_full(queue, MAXSIZE), False)
375 queue.put(1)
376 queue.put(2, True)
377 queue.put(3, True, None)
378 queue.put(4, False)
[all …]
Dtest_dummy_thread.py124 def arg_tester(queue, arg1=False, arg2=False): argument
126 queue.put((arg1, arg2))
146 def queue_mark(queue, delay): argument
149 queue.put(_thread.get_ident())
/device/linaro/bootloader/OpenPlatformPkg/Chips/Hisilicon/Drivers/SasV1Dxe/
DSasV1Dxe.c280 int queue; member
319 int queue = hba->queue; in prepare_cmd() local
329 w = READ_REG32(base, DLVRY_Q_0_WR_PTR + (queue * 0x14)); in prepare_cmd()
330 r = READ_REG32(base, DLVRY_Q_0_RD_PTR + (queue * 0x14)); in prepare_cmd()
331 slot_idx = queue * QUEUE_SLOTS + w; in prepare_cmd()
334 queue = (queue + 1) % QUEUE_CNT; in prepare_cmd()
335 if (queue == hba->queue) { in prepare_cmd()
344 hdr = &hba->cmd_hdr[queue][w]; in prepare_cmd()
345 cmd = &hba->command_table[queue][w]; in prepare_cmd()
346 sts = &hba->status_buf[queue][w]; in prepare_cmd()
[all …]
/device/google/coral/
Dinit.hardware.rc49 write /sys/block/sda/queue/iostats 0
50 write /sys/block/sda/queue/scheduler cfq
51 write /sys/block/sda/queue/iosched/slice_idle 0
52 write /sys/block/sda/queue/read_ahead_kb 2048
53 write /sys/block/sda/queue/nr_requests 256
54 write /sys/block/sde/queue/iostats 0
55 write /sys/block/sde/queue/scheduler cfq
56 write /sys/block/sde/queue/iosched/slice_idle 0
57 write /sys/block/sde/queue/read_ahead_kb 2048
58 write /sys/block/sde/queue/nr_requests 256
[all …]
/device/google/crosshatch/
Dinit.hardware.rc87 write /sys/block/sda/queue/iostats 0
88 write /sys/block/sda/queue/scheduler cfq
89 write /sys/block/sda/queue/iosched/slice_idle 0
90 write /sys/block/sda/queue/read_ahead_kb 2048
91 write /sys/block/sda/queue/nr_requests 256
92 write /sys/block/sdf/queue/iostats 0
93 write /sys/block/sdf/queue/scheduler cfq
94 write /sys/block/sdf/queue/iosched/slice_idle 0
95 write /sys/block/sdf/queue/read_ahead_kb 2048
96 write /sys/block/sdf/queue/nr_requests 256
[all …]
/device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/lib2to3/
Drefactor.py693 self.queue = None
705 if self.queue is not None:
707 self.queue = multiprocessing.JoinableQueue()
717 self.queue.join()
719 self.queue.put(None)
723 self.queue = None
726 task = self.queue.get()
733 self.queue.task_done()
734 task = self.queue.get()
737 if self.queue is not None:
[all …]
/device/linaro/bootloader/OpenPlatformPkg/Chips/Hisilicon/Hi1616/D05AcpiTables/Dsdt/
DD05Sas.asl64 Package () {"queue-count", 16},
139 Package () {"queue-count", 16},
215 Package () {"queue-count", 16},
/device/google/crosshatch/vibrator/
Dimpl.cpp127 std::ofstream queue{EFFECT_QUEUE_PATH}; in makeVibratorService() local
147 std::move(queue), std::move(scale)); in makeVibratorService()
/device/google/crosshatch/sdm845/original-kernel-headers/linux/
Dmsm_adsp.h25 uint16_t queue; member
/device/google/bonito/sdm710/kernel-headers/linux/
Dmsm_adsp.h25 uint16_t queue; member
/device/google/crosshatch/sdm845/kernel-headers/linux/
Dmsm_adsp.h25 uint16_t queue; member
/device/google/bonito/sdm710/original-kernel-headers/linux/
Dmsm_adsp.h25 uint16_t queue; member
/device/google/sunfish/
Dinit.recovery.device.rc14 write /sys/block/sda/queue/discard_max_bytes 134217728
/device/linaro/bootloader/OpenPlatformPkg/Chips/Hisilicon/Pv660/Pv660AcpiTables/
DSASSSDT.ASL70 Package () {"queue-count", 32},
138 Package () {"queue-count", 32},
/device/linaro/bootloader/OpenPlatformPkg/Chips/Hisilicon/Hi1610/Hi1610AcpiTables/Dsdt/
DD03Sas.asl65 Package () {"queue-count", 16},
180 Package () {"queue-count", 16},
296 Package () {"queue-count", 16},

123