Home
last modified time | relevance | path

Searched refs:QUEUE_SIZE (Results 1 – 25 of 27) sorted by relevance

12

/external/libchrome/base/android/javatests/src/org/chromium/base/
DAsyncTaskTest.java50 private static final int QUEUE_SIZE = 40; field in AsyncTaskTest
63 new ArrayBlockingQueue<Runnable>(QUEUE_SIZE), new ThreadFactory() { in testChromeThreadPoolExecutorRunnables()
69 for (int i = 0; i < QUEUE_SIZE; i++) { in testChromeThreadPoolExecutorRunnables()
88 new ArrayBlockingQueue<Runnable>(QUEUE_SIZE), new ThreadFactory() { in testChromeThreadPoolExecutorChromeAsyncTask()
94 for (int i = 0; i < QUEUE_SIZE; i++) { in testChromeThreadPoolExecutorChromeAsyncTask()
112 new ArrayBlockingQueue<Runnable>(QUEUE_SIZE), new ThreadFactory() { in testChromeThreadPoolExecutorOsAsyncTask()
118 for (int i = 0; i < QUEUE_SIZE; i++) { in testChromeThreadPoolExecutorOsAsyncTask()
/external/autotest/server/site_tests/enterprise_CFM_CEC/chameleon_cecservice/
Dit6803.py30 QUEUE_SIZE = 3 variable
41 queue = [[0x00 for i in range(19)] for j in range(QUEUE_SIZE)]
240 if (q_head % QUEUE_SIZE) != (q_tail % QUEUE_SIZE):
243 i = q_tail % QUEUE_SIZE
254 if (q_head % QUEUE_SIZE) == (q_tail % QUEUE_SIZE):
258 rxCecBuf = queue[q_head % QUEUE_SIZE]
/external/python/cpython2/Lib/test/
Dtest_queue.py9 QUEUE_SIZE = 5 variable
103 for i in range(QUEUE_SIZE-1):
107 last = 2 * QUEUE_SIZE
108 full = 3 * 2 * QUEUE_SIZE
125 for i in range(QUEUE_SIZE):
192 q = self.type2test(QUEUE_SIZE)
233 for i in range(QUEUE_SIZE-1):
279 for i in range(QUEUE_SIZE):
314 q = FailingQueue(QUEUE_SIZE)
/external/crosvm/fuzz/
Dblock_fuzzer.rs21 const QUEUE_SIZE: u16 = 16; // Max entries in the queue. constant
73 let mut q = Queue::new(QUEUE_SIZE);
75 q.size = QUEUE_SIZE / 2;
76 q.max_size = QUEUE_SIZE;
/external/python/cpython3/Lib/test/
Dtest_queue.py15 QUEUE_SIZE = 5 variable
107 for i in range(QUEUE_SIZE-1):
111 last = 2 * QUEUE_SIZE
112 full = 3 * 2 * QUEUE_SIZE
131 for i in range(QUEUE_SIZE):
203 q = self.type2test(QUEUE_SIZE)
208 q = self.type2test(QUEUE_SIZE)
215 q = self.type2test(QUEUE_SIZE)
216 for i in range(QUEUE_SIZE):
221 for i in range(QUEUE_SIZE):
[all …]
/external/kernel-headers/original/uapi/linux/
Dcyclades.h470 #define QUEUE_SIZE (10*MAX_CHAN) macro
473 unsigned char intr_code[QUEUE_SIZE];
474 unsigned long channel[QUEUE_SIZE];
475 unsigned long param[QUEUE_SIZE];
/external/ltp/testcases/kernel/fs/read_all/
Dread_all.c48 #define QUEUE_SIZE 16384 macro
57 char data[QUEUE_SIZE];
125 i = (i + 1) % QUEUE_SIZE; in queue_pop()
129 tst_atomic_store((i + 1) % QUEUE_SIZE, &q->front); in queue_pop()
142 i = (i + 1) % QUEUE_SIZE; in queue_push()
/external/crosvm/devices/src/virtio/
Dqueue.rs573 const QUEUE_SIZE: usize = 0x10; constant
593 ring: [Le16; QUEUE_SIZE],
603 ring: [Le16::from(0u16); QUEUE_SIZE], in default()
631 used_elem_ring: [UsedElem; QUEUE_SIZE],
641 used_elem_ring: [UsedElem::default(); QUEUE_SIZE], in default()
670 let mut queue = Queue::new(QUEUE_SIZE.try_into().unwrap()); in queue_event_id_guest_fast()
746 let mut queue = Queue::new(QUEUE_SIZE.try_into().unwrap()); in queue_event_id_guest_slow()
Dballoon.rs42 const QUEUE_SIZE: u16 = 128; constant
43 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE, QUEUE_SIZE, QUEUE_SIZE];
Dconsole.rs19 const QUEUE_SIZE: u16 = 256; constant
23 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE, QUEUE_SIZE];
Drng.rs15 const QUEUE_SIZE: u16 = 256; constant
16 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE];
Dp9.rs19 const QUEUE_SIZE: u16 = 128; constant
20 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE];
Dtpm.rs24 const QUEUE_SIZE: u16 = 2; constant
25 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE];
Dvirtio_pci_common_config.rs250 const QUEUE_SIZE: u16 = 256; constant
251 const QUEUE_SIZES: &'static [u16] = &[QUEUE_SIZE];
Dpmem.rs21 const QUEUE_SIZE: u16 = 256; constant
22 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE];
Dwl.rs107 const QUEUE_SIZE: u16 = 16; constant
108 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE, QUEUE_SIZE];
1502 VecDeque::with_capacity(QUEUE_SIZE as usize); in run()
1552 let mut rejects = [0u16; QUEUE_SIZE as usize]; in run()
Dblock.rs33 const QUEUE_SIZE: u16 = 256; constant
34 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE];
571 let seg_max = min(seg_max, u32::from(QUEUE_SIZE) - 2); in new()
/external/crosvm/devices/src/virtio/video/
Dmod.rs39 const QUEUE_SIZE: u16 = 256; constant
40 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE, QUEUE_SIZE];
/external/crosvm/devices/src/virtio/vhost/user/
Dblock.rs30 const QUEUE_SIZE: u16 = 256; constant
63 let queue_sizes = handler.queue_sizes(QUEUE_SIZE, 1)?; in new()
Dnet.rs26 const QUEUE_SIZE: u16 = 256; constant
61 let queue_sizes = handler.queue_sizes(QUEUE_SIZE, 2 /* 1 rx + 1 tx */)?; in new()
Dfs.rs18 use crate::virtio::fs::{virtio_fs_config, FS_MAX_TAG_LEN, QUEUE_SIZE};
68 let queue_sizes = handler.queue_sizes(QUEUE_SIZE, default_queue_size as usize)?; in new()
/external/crosvm/devices/src/virtio/vhost/
Dvsock.rs18 const QUEUE_SIZE: u16 = 256; constant
20 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE; NUM_QUEUES];
Dnet.rs23 const QUEUE_SIZE: u16 = 256; constant
25 const QUEUE_SIZES: &[u16] = &[QUEUE_SIZE; NUM_QUEUES];
/external/crosvm/devices/src/virtio/fs/
Dmod.rs36 pub const QUEUE_SIZE: u16 = 1024; constant
167 queue_sizes: vec![QUEUE_SIZE; num_queues].into_boxed_slice(), in new()
/external/crosvm/io_uring/src/
During.rs917 const QUEUE_SIZE: usize = 10; in read_parallel() constant
920 let uring = URingContext::new(QUEUE_SIZE).unwrap(); in read_parallel()
921 let mut buf = [0u8; BUF_SIZE * QUEUE_SIZE]; in read_parallel()
922 let f = create_test_file((BUF_SIZE * QUEUE_SIZE) as u64); in read_parallel()
926 for i in 0..QUEUE_SIZE * 64 { in read_parallel()
929 let offset = (i % QUEUE_SIZE) * BUF_SIZE; in read_parallel()

12