| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| gpu_event_mgr_test.cc | 40 size_t queue_size() { function in class:tensorflow::TEST_EventMgrHelper
57 while (queue_size() > 0) {
105 EXPECT_EQ(0, th.queue_size());
122 EXPECT_EQ(0, th.queue_size());
131 EXPECT_EQ(i + 1, th.queue_size());
135 EXPECT_EQ(0, th.queue_size());
142 EXPECT_EQ(i + 1, th.queue_size());
146 EXPECT_EQ(0, th.queue_size());
235 EXPECT_EQ(0, th.queue_size());
244 EXPECT_EQ(1 + i, th.queue_size());
[all...] |
| /external/tensorflow/tensorflow/core/kernels/ |
| fifo_queue.cc | 168 const int64 queue_size = queues_[0].size();
169 if (closed_ && queue_size == 0) {
173 queue_size, ")"));
176 if (queue_size > 0) {
260 int64 queue_size = queues_[0].size();
262 if (closed_ && queue_size < attempt->elements_requested) {
288 queue_size = queues_[0].size();
290 attempt->elements_requested = queue_size;
303 queue_size, ")"));
310 for (; queue_size > 0; --queue_size)
[all...] |
| random_shuffle_queue_op.cc | 246 int32 queue_size = queues_[0].size();
247 if (closed_ && queue_size == 0) {
251 queue_size, ")"));
254 if (!closed_) queue_size -= min_after_dequeue_;
255 if (queue_size > 0) {
339 int32 queue_size = queues_[0].size();
340 if (closed_ && queue_size < attempt->elements_requested) {
365 queue_size = queues_[0].size();
367 attempt->elements_requested = queue_size;
380 queue_size, ")"));
[all...] |
| padding_fifo_queue.cc | 102 int32 queue_size = queues_[0].size();
103 if (closed_ && queue_size < attempt->elements_requested) {
126 queue_size = queues_[0].size();
128 attempt->elements_requested = queue_size;
141 queue_size, ")"));
148 for (; queue_size > 0; --queue_size) {
|
| /system/bt/stack/rfcomm/ |
| port_api.cc | 643 *p_rx_queue_count = p_port->rx.queue_size;
647 *p_rx_queue_count, p_port->rx.queue_size);
821 if (enable && (p_port->rx.queue_size != 0)) {
888 if (enable && (p_port->rx.queue_size != 0)) {
[all...] |
| port_utils.cc | 214 p_port->rx.queue_size = 0;
220 p_port->tx.queue_size = 0;
390 (p_port->tx.queue_size > PORT_TX_HIGH_WM) ||
498 if (p_port->rx.peer_fc && (p_port->rx.queue_size < PORT_RX_LOW_WM) &&
516 else if (((p_port->rx.queue_size > PORT_RX_HIGH_WM) ||
|
| port_int.h | 60 uint32_t queue_size; /* Number of data bytes in the queue */ member in struct:__anon2507
|
| port_rfc.cc | 797 if ((p_port->rx.queue_size + p_buf->len > PORT_RX_CRITICAL_WM) ||
820 p_port->rx.queue_size += p_buf->len;
906 if (p_port->tx.queue_size > 0) {
915 p_port->tx.queue_size -= p_buf->len;
919 RFCOMM_TRACE_DEBUG("Sending RFCOMM_DataReq tx.queue_size=%d",
920 p_port->tx.queue_size);
926 if (p_port->tx.queue_size == 0) {
[all...] |
| /external/skia/infra/bots/recipe_modules/core/resources/ |
| elf_symbolizer.py | 172 return (a2l.queue_size, a2l.first_request_id)
176 if (a2l.queue_size >= self.max_queue_size and
181 if a2l.queue_size >= self.max_queue_size:
236 self.queue_size = 0
253 self.queue_size += 1
258 while self.queue_size > 0:
263 if not self.queue_size:
300 if not self.queue_size:
340 self.queue_size -= 1
|
| /external/skqp/infra/bots/recipe_modules/core/resources/ |
| elf_symbolizer.py | 172 return (a2l.queue_size, a2l.first_request_id)
176 if (a2l.queue_size >= self.max_queue_size and
181 if a2l.queue_size >= self.max_queue_size:
236 self.queue_size = 0
253 self.queue_size += 1
258 while self.queue_size > 0:
263 if not self.queue_size:
300 if not self.queue_size:
340 self.queue_size -= 1
|
| /bionic/libc/kernel/uapi/linux/ |
| virtio_pci.h | 71 __le16 queue_size; member in struct:virtio_pci_common_cfg
|
| /external/kernel-headers/original/uapi/linux/ |
| virtio_pci.h | 148 __le16 queue_size; /* read-write, power of 2. */ member in struct:virtio_pci_common_cfg
|
| /external/webrtc/webrtc/video/ |
| video_loopback.cc | 111 DEFINE_int32(queue_size, 0, "Size of the bottleneck link queue in packets.");
|
| screenshare_loopback.cc | 109 DEFINE_int32(queue_size, 0, "Size of the bottleneck link queue in packets.");
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/sysroot/usr/include/alsa/ |
| timer.h | 231 void snd_timer_params_set_queue_size(snd_timer_params_t * params, long queue_size);
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_queues.py | 288 queue_size = 1
290 q = asyncio.Queue(queue_size, loop=self.loop)
|
| /bionic/libc/kernel/uapi/sound/ |
| asound.h | 592 unsigned int queue_size; member in struct:snd_timer_params
|
| /hardware/qcom/msm8994/kernel-headers/sound/ |
| asound.h | 695 unsigned int queue_size; member in struct:snd_timer_params
[all...] |
| /hardware/qcom/msm8994/original-kernel-headers/sound/ |
| asound.h | 697 unsigned int queue_size; /* total size of queue (32-1024) */ member in struct:snd_timer_params
[all...] |
| /hardware/qcom/msm8996/kernel-headers/sound/ |
| asound.h | 702 unsigned int queue_size; member in struct:snd_timer_params
[all...] |
| /hardware/qcom/msm8996/original-kernel-headers/sound/ |
| asound.h | 706 unsigned int queue_size; /* total size of queue (32-1024) */ member in struct:snd_timer_params
[all...] |
| /hardware/qcom/msm8998/kernel-headers/sound/ |
| asound.h | 727 unsigned int queue_size; member in struct:snd_timer_params
[all...] |
| /hardware/qcom/msm8998/original-kernel-headers/sound/ |
| asound.h | 737 unsigned int queue_size; \/* total size of queue (32-1024) *\/ member in struct:snd_timer_params
[all...] |
| /hardware/qcom/msm8x09/kernel-headers/sound/ |
| asound.h | 700 unsigned int queue_size; member in struct:snd_timer_params
[all...] |
| /hardware/qcom/msm8x09/original-kernel-headers/sound/ |
| asound.h | 706 unsigned int queue_size; /* total size of queue (32-1024) */ member in struct:snd_timer_params
[all...] |
