headers/cpp/stack.h

38

using __STD::queue;

headers/cpp/stl_queue.h

106

operator>=(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y)

headers/cpp/stl_queue.h

41

class queue {

headers/cpp/stl_queue.h

42

friend bool operator== __STL_NULL_TMPL_ARGS (const queue&, const queue&);

headers/cpp/stl_queue.h

43

friend bool operator< __STL_NULL_TMPL_ARGS (const queue&, const queue&);

headers/cpp/stl_queue.h

54

queue() : c() {}

headers/cpp/stl_queue.h

55

explicit queue(const _Sequence& __c) : c(__c) {}

headers/cpp/stl_queue.h

69

operator==(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y)

headers/cpp/stl_queue.h

76

operator<(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y)

headers/cpp/stl_queue.h

85

operator!=(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y)

headers/cpp/stl_queue.h

92

operator>(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y)

headers/cpp/stl_queue.h

99

operator<=(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y)

headers/os/drivers/dpc.h

23

status_t (*new_dpc_queue)(void **queue, const char *name, int32 priority);

headers/os/drivers/dpc.h

24

status_t (*delete_dpc_queue)(void *queue);

headers/os/drivers/dpc.h

25

status_t (*queue_dpc)(void *queue, dpc_func func, void *arg);

headers/os/media/PlaySound.h

15

sound_handle play_sound(const entry_ref* soundRef, bool mix, bool queue,

headers/private/kernel/DPC.h

29

virtual void DoDPC(DPCQueue* queue) = 0;

headers/private/kernel/DPC.h

45

virtual void DoDPC(DPCQueue* queue);

headers/private/kernel/UserEvent.h

58

virtual void DoDPC(DPCQueue* queue);

headers/private/kernel/UserEvent.h

77

virtual void DoDPC(DPCQueue* queue);

headers/private/kernel/UserEvent.h

98

virtual void DoDPC(DPCQueue* queue);

headers/private/kernel/event_queue.h

19

extern status_t _user_event_queue_select(int queue, event_wait_info* userInfos,

headers/private/kernel/event_queue.h

21

extern ssize_t _user_event_queue_wait(int queue, event_wait_info* infos,

headers/private/kernel/util/queue.h

20

int queue_init(queue *q);

headers/private/kernel/util/queue.h

21

int queue_remove_item(queue *q, void *e);

headers/private/kernel/util/queue.h

22

int queue_enqueue(queue *q, void *e);

headers/private/kernel/util/queue.h

23

void *queue_dequeue(queue *q);

headers/private/kernel/util/queue.h

24

void *queue_peek(queue *q);

headers/private/kernel/vm/vm_types.h

134

void* queue;

headers/private/kernel/vm/vm_types.h

218

queue = NULL;

headers/private/system/syscalls.h

80

extern status_t _kern_event_queue_select(int queue,

headers/private/system/syscalls.h

82

extern ssize_t _kern_event_queue_wait(int queue, struct event_wait_info* infos,

headers/private/util/DoublyLinkedQueue.h

36

Iterator(Queue *queue)

headers/private/util/DoublyLinkedQueue.h

38

fQueue(queue)

headers/private/util/DoublyLinkedQueue.h

93

ConstIterator(const Queue *queue)

headers/private/util/DoublyLinkedQueue.h

95

fQueue(queue)

headers/private/virtio/virtio.h

101

void (*notify_queue)(void* cookie, uint16 queue);

headers/private/virtio/virtio.h

129

status_t (*queue_setup_interrupt)(virtio_queue queue,

headers/private/virtio/virtio.h

132

status_t (*queue_request)(virtio_queue queue,

headers/private/virtio/virtio.h

136

status_t (*queue_request_v)(virtio_queue queue,

headers/private/virtio/virtio.h

141

bool (*queue_is_full)(virtio_queue queue);

headers/private/virtio/virtio.h

143

bool (*queue_is_empty)(virtio_queue queue);

headers/private/virtio/virtio.h

145

uint16 (*queue_size)(virtio_queue queue);

headers/private/virtio/virtio.h

147

bool (*queue_dequeue)(virtio_queue queue, void** _cookie,

headers/private/virtio/virtio.h

76

status_t (*queue_interrupt_handler)(virtio_sim sim, uint16 queue);

headers/private/virtio/virtio.h

96

uint16 (*get_queue_ring_size)(void* cookie, uint16 queue);

headers/private/virtio/virtio.h

97

status_t (*setup_queue)(void* cookie, uint16 queue, phys_addr_t phy, phys_addr_t phyAvail,

src/add-ons/accelerants/intel_extreme/engine.cpp

242

QueueCommands queue(gInfo->shared_info->primary_ring_buffer);

src/add-ons/accelerants/intel_extreme/engine.cpp

243

queue.PutFlush();

src/add-ons/accelerants/intel_extreme/engine.cpp

298

QueueCommands queue(gInfo->shared_info->primary_ring_buffer);

src/add-ons/accelerants/intel_extreme/engine.cpp

309

queue.Put(blit, sizeof(blit));

src/add-ons/accelerants/intel_extreme/engine.cpp

318

QueueCommands queue(gInfo->shared_info->primary_ring_buffer);

src/add-ons/accelerants/intel_extreme/engine.cpp

328

queue.Put(blit, sizeof(blit));

src/add-ons/accelerants/intel_extreme/engine.cpp

337

QueueCommands queue(gInfo->shared_info->primary_ring_buffer);

src/add-ons/accelerants/intel_extreme/engine.cpp

347

queue.Put(blit, sizeof(blit));

src/add-ons/accelerants/intel_extreme/engine.cpp

362

QueueCommands queue(gInfo->shared_info->primary_ring_buffer);

src/add-ons/accelerants/intel_extreme/engine.cpp

367

queue.Put(setup, sizeof(setup));

src/add-ons/accelerants/intel_extreme/overlay.cpp

241

QueueCommands queue(gInfo->shared_info->primary_ring_buffer);

src/add-ons/accelerants/intel_extreme/overlay.cpp

242

queue.PutFlush();

src/add-ons/accelerants/intel_extreme/overlay.cpp

243

queue.PutWaitFor(COMMAND_WAIT_FOR_OVERLAY_FLIP);

src/add-ons/accelerants/intel_extreme/overlay.cpp

244

queue.PutOverlayFlip(COMMAND_OVERLAY_CONTINUE, updateCoefficients);

src/add-ons/accelerants/intel_extreme/overlay.cpp

247

queue.PutWaitFor(COMMAND_WAIT_FOR_OVERLAY_FLIP);

src/add-ons/accelerants/intel_extreme/overlay.cpp

248

queue.PutFlush();

src/add-ons/accelerants/intel_extreme/overlay.cpp

268

QueueCommands queue(gInfo->shared_info->primary_ring_buffer);

src/add-ons/accelerants/intel_extreme/overlay.cpp

269

queue.PutOverlayFlip(COMMAND_OVERLAY_ON, true);

src/add-ons/accelerants/intel_extreme/overlay.cpp

270

queue.PutFlush();

src/add-ons/accelerants/intel_extreme/overlay.cpp

292

QueueCommands queue(gInfo->shared_info->primary_ring_buffer);

src/add-ons/accelerants/intel_extreme/overlay.cpp

295

queue.PutFlush();

src/add-ons/accelerants/intel_extreme/overlay.cpp

296

queue.PutWaitFor(COMMAND_WAIT_FOR_OVERLAY_FLIP);

src/add-ons/accelerants/intel_extreme/overlay.cpp

299

queue.PutOverlayFlip(COMMAND_OVERLAY_CONTINUE, false);

src/add-ons/accelerants/intel_extreme/overlay.cpp

300

queue.PutWaitFor(COMMAND_WAIT_FOR_OVERLAY_FLIP);

src/add-ons/accelerants/intel_extreme/overlay.cpp

303

queue.PutOverlayFlip(COMMAND_OVERLAY_OFF, false);

src/add-ons/accelerants/intel_extreme/overlay.cpp

304

queue.PutWaitFor(COMMAND_WAIT_FOR_OVERLAY_FLIP);

src/add-ons/kernel/bus_managers/virtio/VirtioBalloonDevice.cpp

141

::virtio_queue queue;

src/add-ons/kernel/bus_managers/virtio/VirtioBalloonDevice.cpp

145

queue = fVirtioQueues[0];

src/add-ons/kernel/bus_managers/virtio/VirtioBalloonDevice.cpp

169

queue = fVirtioQueues[1];

src/add-ons/kernel/bus_managers/virtio/VirtioBalloonDevice.cpp

192

status_t result = fVirtio->queue_request(queue, &fEntry, NULL, NULL);

src/add-ons/kernel/bus_managers/virtio/VirtioBalloonDevice.cpp

198

while (!fVirtio->queue_dequeue(queue, NULL, NULL)) {

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

142

VirtioQueue *queue = (VirtioQueue *)_queue;

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

143

return queue->SetupInterrupt(handler, cookie);

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

152

VirtioQueue *queue = (VirtioQueue *)_queue;

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

153

return queue->QueueRequest(vector, readVectorCount, writtenVectorCount,

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

178

VirtioQueue *queue = (VirtioQueue *)_queue;

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

179

return queue->IsFull();

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

186

VirtioQueue *queue = (VirtioQueue *)_queue;

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

187

return queue->IsEmpty();

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

194

VirtioQueue *queue = (VirtioQueue *)_queue;

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

195

return queue->Size();

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

202

VirtioQueue *queue = (VirtioQueue *)_queue;

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

203

return queue->Dequeue(_cookie, _usedLength);

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

236

virtio_queue_interrupt_handler(virtio_sim sim, uint16 queue)

src/add-ons/kernel/bus_managers/virtio/VirtioModule.cpp

239

return device->QueueInterrupt(queue);

src/add-ons/kernel/bus_managers/virtio/VirtioQueue.cpp

53

TransferDescriptor(VirtioQueue* queue,

src/add-ons/kernel/bus_managers/virtio/VirtioQueue.cpp

78

TransferDescriptor::TransferDescriptor(VirtioQueue* queue, uint16 indirectMaxSize)

src/add-ons/kernel/bus_managers/virtio/VirtioQueue.cpp

79

: fQueue(queue),

src/add-ons/kernel/busses/usb/uhci.cpp

1133

Queue *queue = NULL;

src/add-ons/kernel/busses/usb/uhci.cpp

1135

queue = fQueues[UHCI_LOW_SPEED_CONTROL_QUEUE];

src/add-ons/kernel/busses/usb/uhci.cpp

1137

queue = fQueues[UHCI_FULL_SPEED_CONTROL_QUEUE];

src/add-ons/kernel/busses/usb/uhci.cpp

1140

status_t result = AddPendingTransfer(transfer, queue, transferQueue,

src/add-ons/kernel/busses/usb/uhci.cpp

1149

queue->AppendTransfer(transferQueue);

src/add-ons/kernel/busses/usb/uhci.cpp

1155

UHCI::AddPendingTransfer(Transfer *transfer, Queue *queue,

src/add-ons/kernel/busses/usb/uhci.cpp

1159

if (!transfer || !queue || !transferQueue || !firstDescriptor)

src/add-ons/kernel/busses/usb/uhci.cpp

1173

data->queue = queue;

src/add-ons/kernel/busses/usb/uhci.cpp

1641

transfer->queue->RemoveTransfer(

src/add-ons/kernel/busses/usb/uhci.cpp

1666

transfer->queue->RemoveTransfer(transfer->transfer_queue);

src/add-ons/kernel/busses/usb/uhci.cpp

855

Queue *queue = NULL;

src/add-ons/kernel/busses/usb/uhci.cpp

857

queue = fQueues[UHCI_INTERRUPT_QUEUE];

src/add-ons/kernel/busses/usb/uhci.cpp

859

queue = fQueues[UHCI_BULK_QUEUE];

src/add-ons/kernel/busses/usb/uhci.cpp

862

result = AddPendingTransfer(transfer, queue, transferQueue,

src/add-ons/kernel/busses/usb/uhci.cpp

871

queue->AppendTransfer(transferQueue);

src/add-ons/kernel/busses/usb/uhci.h

132

Queue *queue,

src/add-ons/kernel/busses/usb/uhci.h

67

Queue * queue;

src/add-ons/kernel/busses/virtio/virtio_mmio/VirtioDevice.cpp

260

VirtioQueue* queue = dev->fQueues[i].Get();

src/add-ons/kernel/busses/virtio/virtio_mmio/VirtioDevice.cpp

261

if (queue->fUsed->idx != queue->fLastUsed

src/add-ons/kernel/busses/virtio/virtio_mmio/VirtioDevice.cpp

262

&& queue->fQueueHandler != NULL) {

src/add-ons/kernel/busses/virtio/virtio_mmio/VirtioDevice.cpp

263

queue->fQueueHandler(dev->fConfigHandlerCookie,

src/add-ons/kernel/busses/virtio/virtio_mmio/VirtioDevice.cpp

264

queue->fQueueHandlerCookie);

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

537

VirtioQueue* queue = dev->fQueues[i].Get();

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

538

queue->fQueueHandler = NULL;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

539

queue->fQueueHandlerCookie = NULL;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

540

queue->fQueueHandlerRef.Unset();

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

557

VirtioQueue* queue = (VirtioQueue*)aQueue;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

558

VirtioDevice* dev = queue->fDev;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

560

queue->fQueueHandler = handler;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

561

queue->fQueueHandlerCookie = cookie;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

562

queue->fQueueHandlerRef.SetTo((handler == NULL) ? NULL : &dev->fIrqHandler);

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

576

VirtioQueue* queue = (VirtioQueue*)aQueue;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

578

return queue->Enqueue(vector, readVectorCount, writtenVectorCount, cookie);

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

587

VirtioQueue* queue = (VirtioQueue*)aQueue;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

598

return queue->Enqueue(vector, (readEntry != NULL) ? 1 : 0,

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

604

virtio_device_queue_is_full(virtio_queue queue)

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

614

VirtioQueue *queue = (VirtioQueue *)aQueue;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

615

return queue->fUsed->idx == queue->fLastUsed;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

622

VirtioQueue *queue = (VirtioQueue *)aQueue;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

623

return (uint16)queue->fQueueLen;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

632

VirtioQueue* queue = (VirtioQueue*)aQueue;

src/add-ons/kernel/busses/virtio/virtio_mmio/virtio_mmio.cpp

633

return queue->Dequeue(_cookie, _usedLength);

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

149

gVirtio->queue_interrupt_handler(cookie->sim, cookie->queue);

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

186

for (uint16 queue = 0; queue < bus->queue_count; queue++) {

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

190

*queueSelect = queue;

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

196

+ VIRTIO_PCI_QUEUE_SEL, queue);

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

405

get_queue_ring_size(void* cookie, uint16 queue)

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

412

*queueSelect = queue;

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

418

queue);

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

426

setup_queue(void* cookie, uint16 queue, phys_addr_t phy, phys_addr_t phyAvail,

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

432

if (queue >= bus->queue_count)

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

436

*queueSelect = queue;

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

45

uint16 queue;

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

453

bus->notifyOffsets[queue] = *queueNotifyOffset * bus->notifyOffsetMultiplier;

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

455

bus->pci->write_io_16(bus->device, bus->base_addr + VIRTIO_PCI_QUEUE_SEL, queue);

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

525

for (int32 queue = 0; queue < queueCount; queue++, irq++) {

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

526

bus->cookies[queue].sim = bus->sim;

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

527

bus->cookies[queue].queue = queue;

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

529

virtio_pci_queue_interrupt, &bus->cookies[queue], 0);

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

570

for (int32 queue = 0; queue < bus->queue_count; queue++, irq++)

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

571

remove_io_interrupt_handler(irq, virtio_pci_queue_interrupt, &bus->cookies[queue]);

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

587

notify_queue(void* cookie, uint16 queue)

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

591

if (queue >= bus->queue_count)

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

594

volatile uint16* notifyAddr = (volatile uint16*)(bus->notifyAddr + bus->notifyOffsets[queue]);

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

595

*notifyAddr = queue;

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

598

+ VIRTIO_PCI_QUEUE_NOTIFY, queue);

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

745

for (int32 queue = 0; queue < bus->queue_count; queue++, irq++)

src/add-ons/kernel/busses/virtio/virtio_pci/virtio_pci.cpp

746

remove_io_interrupt_handler(irq, virtio_pci_queue_interrupt, &bus->cookies[queue]);

src/add-ons/kernel/drivers/network/wlan/atheroswifi/dev/ath/ath_hal/ar5212/ar5212_reset.c

1137

uint32_t queue;

src/add-ons/kernel/drivers/network/wlan/atheroswifi/dev/ath/ath_hal/ar5212/ar5212_reset.c

1168

for (queue = 0; queue < AR_NUM_DCU; queue++) {

src/add-ons/kernel/drivers/network/wlan/atheroswifi/dev/ath/ath_hal/ar5212/ar5212_reset.c

1170

AR_Q0_STS + (queue * 4)) &

src/add-ons/kernel/file_systems/nfs4/WorkQueue.cpp

128

WorkQueue* queue = reinterpret_cast<WorkQueue*>(object);

src/add-ons/kernel/file_systems/nfs4/WorkQueue.cpp

129

return queue->WorkingThread();

src/add-ons/kernel/generic/dpc/dpc.c

103

queue->wakeup_sem = create_sem(0, str);

src/add-ons/kernel/generic/dpc/dpc.c

104

if (queue->wakeup_sem < B_OK) {

src/add-ons/kernel/generic/dpc/dpc.c

105

status_t status = queue->wakeup_sem;

src/add-ons/kernel/generic/dpc/dpc.c

106

free(queue);

src/add-ons/kernel/generic/dpc/dpc.c

112

queue->thread = spawn_kernel_thread(dpc_thread, name, priority, queue);

src/add-ons/kernel/generic/dpc/dpc.c

113

if (queue->thread < 0) {

src/add-ons/kernel/generic/dpc/dpc.c

114

status_t status = queue->thread;

src/add-ons/kernel/generic/dpc/dpc.c

115

delete_sem(queue->wakeup_sem);

src/add-ons/kernel/generic/dpc/dpc.c

116

free(queue);

src/add-ons/kernel/generic/dpc/dpc.c

119

resume_thread(queue->thread);

src/add-ons/kernel/generic/dpc/dpc.c

121

*handle = queue;

src/add-ons/kernel/generic/dpc/dpc.c

130

dpc_queue *queue = handle;

src/add-ons/kernel/generic/dpc/dpc.c

135

if (!queue)

src/add-ons/kernel/generic/dpc/dpc.c

140

acquire_spinlock(&queue->lock);

src/add-ons/kernel/generic/dpc/dpc.c

142

thread = queue->thread;

src/add-ons/kernel/generic/dpc/dpc.c

143

queue->thread = -1;

src/add-ons/kernel/generic/dpc/dpc.c

145

release_spinlock(&queue->lock);

src/add-ons/kernel/generic/dpc/dpc.c

149

delete_sem(queue->wakeup_sem);

src/add-ons/kernel/generic/dpc/dpc.c

152

free(queue);

src/add-ons/kernel/generic/dpc/dpc.c

161

dpc_queue *queue = handle;

src/add-ons/kernel/generic/dpc/dpc.c

165

if (!queue || !function)

src/add-ons/kernel/generic/dpc/dpc.c

170

acquire_spinlock(&queue->lock);

src/add-ons/kernel/generic/dpc/dpc.c

172

if (queue->thread < 0) {

src/add-ons/kernel/generic/dpc/dpc.c

175

} else if (queue->count == queue->size)

src/add-ons/kernel/generic/dpc/dpc.c

179

queue->slots[queue->tail].function = function;

src/add-ons/kernel/generic/dpc/dpc.c

180

queue->slots[queue->tail].arg = arg;

src/add-ons/kernel/generic/dpc/dpc.c

181

queue->tail = (queue->tail + 1) % queue->size;

src/add-ons/kernel/generic/dpc/dpc.c

182

queue->count++;

src/add-ons/kernel/generic/dpc/dpc.c

185

release_spinlock(&queue->lock);

src/add-ons/kernel/generic/dpc/dpc.c

192

status = release_sem_etc(queue->wakeup_sem, 1, B_DO_NOT_RESCHEDULE);

src/add-ons/kernel/generic/dpc/dpc.c

45

dpc_queue *queue = arg;

src/add-ons/kernel/generic/dpc/dpc.c

49

while (acquire_sem(queue->wakeup_sem) == B_OK) {

src/add-ons/kernel/generic/dpc/dpc.c

54

acquire_spinlock(&queue->lock);

src/add-ons/kernel/generic/dpc/dpc.c

56

dpc = queue->slots[queue->head];

src/add-ons/kernel/generic/dpc/dpc.c

57

queue->head = (queue->head + 1) % queue->size;

src/add-ons/kernel/generic/dpc/dpc.c

58

queue->count--;

src/add-ons/kernel/generic/dpc/dpc.c

60

release_spinlock(&queue->lock);

src/add-ons/kernel/generic/dpc/dpc.c

68

while (queue->count--) {

src/add-ons/kernel/generic/dpc/dpc.c

69

dpc = queue->slots[queue->head];

src/add-ons/kernel/generic/dpc/dpc.c

70

queue->head = (queue->head + 1) % queue->size;

src/add-ons/kernel/generic/dpc/dpc.c

86

dpc_queue *queue;

src/add-ons/kernel/generic/dpc/dpc.c

91

queue = malloc(sizeof(dpc_queue) + DPC_QUEUE_SIZE * sizeof(dpc_slot));

src/add-ons/kernel/generic/dpc/dpc.c

92

if (!queue)

src/add-ons/kernel/generic/dpc/dpc.c

95

queue->head = queue->tail = 0;

src/add-ons/kernel/generic/dpc/dpc.c

96

queue->size = DPC_QUEUE_SIZE;

src/add-ons/kernel/generic/dpc/dpc.c

97

queue->count = 0;

src/add-ons/kernel/generic/dpc/dpc.c

98

B_INITIALIZE_SPINLOCK(&queue->lock); // Init the spinlock

src/add-ons/kernel/network/datalink_protocols/arp/arp.cpp

1053

entry->queue.Add(buffer);

src/add-ons/kernel/network/datalink_protocols/arp/arp.cpp

313

BufferList::Iterator iterator = queue.GetIterator();

src/add-ons/kernel/network/datalink_protocols/arp/arp.cpp

336

queue.Count()));

src/add-ons/kernel/network/datalink_protocols/arp/arp.cpp

340

BufferList::Iterator iterator = queue.GetIterator();

src/add-ons/kernel/network/datalink_protocols/arp/arp.cpp

81

BufferList queue;

src/add-ons/kernel/network/datalink_protocols/ipv6_datagram/ipv6_datagram.cpp

1055

entry->queue.Add(buffer);

src/add-ons/kernel/network/datalink_protocols/ipv6_datagram/ipv6_datagram.cpp

111

BufferList queue;

src/add-ons/kernel/network/datalink_protocols/ipv6_datagram/ipv6_datagram.cpp

343

BufferList::Iterator iterator = queue.GetIterator();

src/add-ons/kernel/network/datalink_protocols/ipv6_datagram/ipv6_datagram.cpp

369

BufferList::Iterator iterator = queue.GetIterator();

src/add-ons/media/media-add-ons/dvb/DVBMediaNode.cpp

2131

DVBMediaNode::GetStreamFormat(PacketQueue *queue, media_format *format)

src/add-ons/media/media-add-ons/dvb/DVBMediaNode.cpp

2140

status = queue->Peek(&packet);

src/add-ons/media/media-add-ons/dvb/DVBMediaNode.h

137

status_t GetStreamFormat(PacketQueue *queue, media_format *format);

src/add-ons/print/transports/lpr/LpsClient.h

42

void receiveJob(const char* queue);

src/apps/haikudepot/ui/MainWindow.h

200

std::queue<ProcessCoordinator*>

src/apps/icon-o-matic/import_export/flat_icon/FlatIconExporter.cpp

391

PathCommandQueue queue;

src/apps/icon-o-matic/import_export/flat_icon/FlatIconExporter.cpp

392

return queue.Write(buffer, path, pointCount);

src/kits/interface/View.cpp

1560

BMessageQueue* queue = Window()->MessageQueue();

src/kits/interface/View.cpp

1561

queue->Lock();

src/kits/interface/View.cpp

1566

for (int32 i = 0; (message = queue->FindMessage(i)) != NULL; i++) {

src/kits/interface/View.cpp

1603

queue->Unlock();

src/kits/interface/View.cpp

1616

queue->Unlock();

src/kits/interface/View.cpp

5420

BMessageQueue* queue = window->MessageQueue();

src/kits/interface/View.cpp

5421

queue->Lock();

src/kits/interface/View.cpp

5424

for (int32 i = 0; (moved = queue->FindMessage(i)) != NULL;

src/kits/interface/View.cpp

5430

queue->Unlock();

src/kits/interface/View.cpp

5434

queue->Unlock();

src/kits/interface/Window.cpp

1830

BMessageQueue* queue = MessageQueue();

src/kits/interface/Window.cpp

1836

queue->Lock();

src/kits/interface/Window.cpp

1838

BMessage* message = queue->FindMessage(_UPDATE_, 0);

src/kits/interface/Window.cpp

1839

queue->RemoveMessage(message);

src/kits/interface/Window.cpp

1841

queue->Unlock();

src/kits/media/ChunkCache.h

32

typedef std::queue<chunk_buffer*> ChunkQueue;

src/kits/media/PlaySound.cpp

16

bool queue,

src/kits/tracker/Thumbnails.cpp

251

JobQueue* queue = (JobQueue*)castToJobQueue;

src/kits/tracker/Thumbnails.cpp

254

status_t status = queue->Pop(B_INFINITE_TIMEOUT, false, &job);

src/libs/compat/freebsd_iflib/compat/sys/gtaskqueue.h

64

void gtaskqueue_block(struct gtaskqueue *queue);

src/libs/compat/freebsd_iflib/compat/sys/gtaskqueue.h

65

void gtaskqueue_unblock(struct gtaskqueue *queue);

src/libs/compat/freebsd_iflib/compat/sys/gtaskqueue.h

67

int gtaskqueue_cancel(struct gtaskqueue *queue, struct gtask *gtask);

src/libs/compat/freebsd_iflib/compat/sys/gtaskqueue.h

68

void gtaskqueue_drain(struct gtaskqueue *queue, struct gtask *task);

src/libs/compat/freebsd_iflib/compat/sys/gtaskqueue.h

69

void gtaskqueue_drain_all(struct gtaskqueue *queue);

src/libs/compat/freebsd_iflib/compat/sys/gtaskqueue.h

73

int grouptaskqueue_enqueue(struct gtaskqueue *queue, struct gtask *task);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

138

struct gtaskqueue *queue;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

147

queue = malloc(sizeof(struct gtaskqueue), M_GTASKQUEUE, mflags | M_ZERO);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

148

if (!queue) {

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

153

STAILQ_INIT(&queue->tq_queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

154

TAILQ_INIT(&queue->tq_active);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

155

queue->tq_enqueue = enqueue;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

156

queue->tq_context = context;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

157

queue->tq_name = tq_name;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

158

queue->tq_spin = (mtxflags & MTX_SPIN) != 0;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

159

queue->tq_flags |= TQ_FLAGS_ACTIVE;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

161

queue->tq_flags |= TQ_FLAGS_UNLOCKED_ENQUEUE;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

162

mtx_init(&queue->tq_mutex, tq_name, NULL, mtxflags);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

164

return (queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

182

gtaskqueue_free(struct gtaskqueue *queue)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

185

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

186

queue->tq_flags &= ~TQ_FLAGS_ACTIVE;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

187

gtaskqueue_terminate(queue->tq_threads, queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

188

KASSERT(TAILQ_EMPTY(&queue->tq_active), ("Tasks still running?"));

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

189

KASSERT(queue->tq_callouts == 0, ("Armed timeout tasks"));

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

190

mtx_destroy(&queue->tq_mutex);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

191

free(queue->tq_threads, M_GTASKQUEUE);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

192

free(queue->tq_name, M_GTASKQUEUE);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

193

free(queue, M_GTASKQUEUE);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

202

struct gtaskqueue *queue = grouptask->gt_taskqueue;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

206

if (queue == NULL) {

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

211

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

213

gtaskqueue_drain_locked(queue, gtask);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

214

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

220

struct gtaskqueue *queue = grouptask->gt_taskqueue;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

224

if (queue == NULL) {

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

229

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

231

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

235

grouptaskqueue_enqueue(struct gtaskqueue *queue, struct gtask *gtask)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

238

if (queue == NULL) {

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

243

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

245

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

249

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

252

STAILQ_INSERT_TAIL(&queue->tq_queue, gtask, ta_link);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

254

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

255

if ((queue->tq_flags & TQ_FLAGS_BLOCKED) == 0)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

256

queue->tq_enqueue(queue->tq_context);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

271

gtaskqueue_drain_tq_queue(struct gtaskqueue *queue)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

275

if (STAILQ_EMPTY(&queue->tq_queue))

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

287

STAILQ_INSERT_TAIL(&queue->tq_queue, &t_barrier, ta_link);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

295

TQ_SLEEP(queue, &t_barrier, &queue->tq_mutex, PWAIT, "-", 0);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

304

gtaskqueue_drain_tq_active(struct gtaskqueue *queue)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

308

if (TAILQ_EMPTY(&queue->tq_active))

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

312

queue->tq_callouts++;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

319

TAILQ_INSERT_TAIL(&queue->tq_active, &tb_marker, tb_link);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

320

while (TAILQ_FIRST(&queue->tq_active) != &tb_marker)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

321

TQ_SLEEP(queue, &tb_marker, &queue->tq_mutex, PWAIT, "-", 0);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

322

TAILQ_REMOVE(&queue->tq_active, &tb_marker, tb_link);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

328

tb_first = TAILQ_FIRST(&queue->tq_active);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

333

queue->tq_callouts--;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

334

if ((queue->tq_flags & TQ_FLAGS_ACTIVE) == 0)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

335

wakeup_one(queue->tq_threads);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

339

gtaskqueue_block(struct gtaskqueue *queue)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

342

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

343

queue->tq_flags |= TQ_FLAGS_BLOCKED;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

344

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

348

gtaskqueue_unblock(struct gtaskqueue *queue)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

351

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

352

queue->tq_flags &= ~TQ_FLAGS_BLOCKED;

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

353

if (!STAILQ_EMPTY(&queue->tq_queue))

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

354

queue->tq_enqueue(queue->tq_context);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

355

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

359

gtaskqueue_run_locked(struct gtaskqueue *queue)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

365

KASSERT(queue != NULL, ("tq is NULL"));

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

366

TQ_ASSERT_LOCKED(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

369

while (STAILQ_FIRST(&queue->tq_queue)) {

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

370

TAILQ_INSERT_TAIL(&queue->tq_active, &tb, tb_link);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

376

gtask = STAILQ_FIRST(&queue->tq_queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

378

STAILQ_REMOVE_HEAD(&queue->tq_queue, ta_link);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

381

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

386

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

390

TAILQ_REMOVE(&queue->tq_active, &tb, tb_link);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

391

tb_first = TAILQ_FIRST(&queue->tq_active);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

399

task_is_running(struct gtaskqueue *queue, struct gtask *gtask)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

403

TQ_ASSERT_LOCKED(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

404

TAILQ_FOREACH(tb, &queue->tq_active, tb_link) {

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

412

gtaskqueue_cancel_locked(struct gtaskqueue *queue, struct gtask *gtask)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

416

STAILQ_REMOVE(&queue->tq_queue, gtask, gtask, ta_link);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

418

return (task_is_running(queue, gtask) ? EBUSY : 0);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

422

gtaskqueue_cancel(struct gtaskqueue *queue, struct gtask *gtask)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

426

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

427

error = gtaskqueue_cancel_locked(queue, gtask);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

428

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

434

gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

436

while ((gtask->ta_flags & TASK_ENQUEUED) || task_is_running(queue, gtask))

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

437

TQ_SLEEP(queue, gtask, &queue->tq_mutex, PWAIT, "-", 0);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

441

gtaskqueue_drain(struct gtaskqueue *queue, struct gtask *gtask)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

444

if (!queue->tq_spin)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

448

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

449

gtaskqueue_drain_locked(queue, gtask);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

450

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

454

gtaskqueue_drain_all(struct gtaskqueue *queue)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

457

if (!queue->tq_spin)

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

461

TQ_LOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

462

gtaskqueue_drain_tq_queue(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

463

gtaskqueue_drain_tq_active(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

464

TQ_UNLOCK(queue);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

60

static int task_is_running(struct gtaskqueue *queue, struct gtask *gtask);

src/libs/compat/freebsd_iflib/subr_gtaskqueue.c

61

static void gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

109

void _timeout_task_init(struct taskqueue *queue,

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

112

#define TIMEOUT_TASK_INIT(queue, timeout_task, priority, func, context) \

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

113

_timeout_task_init(queue, timeout_task, priority, func, context);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

76

int taskqueue_enqueue(struct taskqueue *queue, struct task *task);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

77

int taskqueue_enqueue_timeout(struct taskqueue *queue,

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

79

int taskqueue_cancel(struct taskqueue *queue, struct task *task,

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

81

int taskqueue_cancel_timeout(struct taskqueue *queue,

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

83

void taskqueue_drain(struct taskqueue *queue, struct task *task);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

84

void taskqueue_drain_timeout(struct taskqueue *queue,

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

86

void taskqueue_drain_all(struct taskqueue *queue);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

87

void taskqueue_free(struct taskqueue *queue);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

88

void taskqueue_run(struct taskqueue *queue);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

89

void taskqueue_block(struct taskqueue *queue);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

90

void taskqueue_unblock(struct taskqueue *queue);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

91

int taskqueue_member(struct taskqueue *queue, struct thread *td);

src/libs/compat/freebsd_network/compat/sys/taskqueue.h

92

void taskqueue_set_callback(struct taskqueue *queue,

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

105

_timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task,

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

110

callout_init_mtx(&timeout_task->c, &queue->tq_mutex,

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

112

timeout_task->q = queue;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

121

struct taskqueue *queue;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

128

queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

129

if (queue == NULL) {

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

136

STAILQ_INIT(&queue->tq_queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

137

TAILQ_INIT(&queue->tq_active);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

138

queue->tq_enqueue = enqueue;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

139

queue->tq_context = context;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

140

queue->tq_name = tq_name;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

141

queue->tq_spin = (mtxflags & MTX_SPIN) != 0;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

142

queue->tq_flags |= TQ_FLAGS_ACTIVE;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

144

queue->tq_flags |= TQ_FLAGS_UNLOCKED_ENQUEUE;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

145

mtx_init(&queue->tq_mutex, tq_name, NULL, mtxflags);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

147

return (queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

160

taskqueue_set_callback(struct taskqueue *queue,

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

169

KASSERT((queue->tq_callbacks[cb_type] == NULL),

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

172

queue->tq_callbacks[cb_type] = callback;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

173

queue->tq_cb_contexts[cb_type] = context;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

177

taskqueue_free(struct taskqueue *queue)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

180

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

181

queue->tq_flags &= ~TQ_FLAGS_ACTIVE;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

182

taskqueue_terminate(queue->tq_threads, queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

183

KASSERT(TAILQ_EMPTY(&queue->tq_active), ("Tasks still running?"));

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

184

KASSERT(queue->tq_callouts == 0, ("Armed timeout tasks"));

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

186

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

188

mtx_destroy(&queue->tq_mutex);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

189

free(queue->tq_threads, M_TASKQUEUE);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

190

free(queue->tq_name, M_TASKQUEUE);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

191

free(queue, M_TASKQUEUE);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

195

taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

207

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

214

prev = STAILQ_LAST(&queue->tq_queue, task, ta_link);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

216

STAILQ_INSERT_TAIL(&queue->tq_queue, task, ta_link);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

219

for (ins = STAILQ_FIRST(&queue->tq_queue); ins;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

225

STAILQ_INSERT_AFTER(&queue->tq_queue, prev, task, ta_link);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

227

STAILQ_INSERT_HEAD(&queue->tq_queue, task, ta_link);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

231

if ((queue->tq_flags & TQ_FLAGS_UNLOCKED_ENQUEUE) != 0)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

232

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

233

if ((queue->tq_flags & TQ_FLAGS_BLOCKED) == 0)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

234

queue->tq_enqueue(queue->tq_context);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

235

if ((queue->tq_flags & TQ_FLAGS_UNLOCKED_ENQUEUE) == 0)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

236

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

243

taskqueue_enqueue(struct taskqueue *queue, struct task *task)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

247

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

248

res = taskqueue_enqueue_locked(queue, task);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

257

struct taskqueue *queue;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

261

queue = timeout_task->q;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

264

queue->tq_callouts--;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

270

taskqueue_enqueue_timeout(struct taskqueue *queue,

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

275

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

276

KASSERT(timeout_task->q == NULL || timeout_task->q == queue,

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

278

KASSERT(!queue->tq_spin, ("Timeout for spin-queue"));

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

279

timeout_task->q = queue;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

283

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

286

taskqueue_enqueue_locked(queue, &timeout_task->t);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

292

queue->tq_callouts++;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

301

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

312

taskqueue_block(struct taskqueue *queue)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

315

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

316

queue->tq_flags |= TQ_FLAGS_BLOCKED;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

317

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

321

taskqueue_unblock(struct taskqueue *queue)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

324

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

325

queue->tq_flags &= ~TQ_FLAGS_BLOCKED;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

326

if (!STAILQ_EMPTY(&queue->tq_queue))

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

327

queue->tq_enqueue(queue->tq_context);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

328

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

332

taskqueue_run_locked(struct taskqueue *queue)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

339

KASSERT(queue != NULL, ("tq is NULL"));

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

340

TQ_ASSERT_LOCKED(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

343

while (STAILQ_FIRST(&queue->tq_queue)) {

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

344

TAILQ_INSERT_TAIL(&queue->tq_active, &tb, tb_link);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

350

task = STAILQ_FIRST(&queue->tq_queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

352

STAILQ_REMOVE_HEAD(&queue->tq_queue, ta_link);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

356

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

369

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

372

TAILQ_REMOVE(&queue->tq_active, &tb, tb_link);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

373

tb_first = TAILQ_FIRST(&queue->tq_active);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

378

taskqueue_run(struct taskqueue *queue)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

381

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

382

taskqueue_run_locked(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

383

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

387

task_is_running(struct taskqueue *queue, struct task *task)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

391

TQ_ASSERT_LOCKED(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

392

TAILQ_FOREACH(tb, &queue->tq_active, tb_link) {

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

400

taskqueue_cancel_locked(struct taskqueue *queue, struct task *task,

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

405

STAILQ_REMOVE(&queue->tq_queue, task, task, ta_link);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

409

return (task_is_running(queue, task) ? EBUSY : 0);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

413

taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

417

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

418

error = taskqueue_cancel_locked(queue, task, pendp);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

419

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

425

taskqueue_cancel_timeout(struct taskqueue *queue,

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

431

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

433

error = taskqueue_cancel_locked(queue, &timeout_task->t, &pending1);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

436

queue->tq_callouts--;

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

438

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

446

taskqueue_drain_timeout(struct taskqueue *queue,

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

453

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

457

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

460

taskqueue_drain(queue, &timeout_task->t);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

465

TQ_LOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

467

TQ_UNLOCK(queue);

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

499

taskqueue_member(struct taskqueue *queue, struct thread *td)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

504

if (queue->tq_threads[i] == NULL)

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

506

if (queue->tq_threads[i] == td) {

src/libs/compat/freebsd_network/fbsd_subr_taskqueue.c

510

if (++j >= queue->tq_tcount)

src/libs/icon/flat_icon/FlatIconImporter.cpp

385

PathCommandQueue queue;

src/libs/icon/flat_icon/FlatIconImporter.cpp

386

return queue.Read(buffer, path, pointCount);

src/servers/launch/Worker.cpp

101

MainWorker::MainWorker(JobQueue& queue)

src/servers/launch/Worker.cpp

103

Worker(queue),

src/servers/launch/Worker.cpp

18

Worker::Worker(JobQueue& queue)

src/servers/launch/Worker.cpp

21

fJobQueue(queue)

src/servers/launch/Worker.h

19

Worker(JobQueue& queue);

src/servers/launch/Worker.h

41

MainWorker(JobQueue& queue);

src/servers/registrar/Event.cpp

168

Event::Do(EventQueue *queue)

src/servers/registrar/Event.h

47

virtual bool Do(EventQueue *queue);

src/servers/registrar/MessageEvent.cpp

152

MessageEvent::Do(EventQueue *queue)

src/servers/registrar/MessageEvent.h

47

virtual bool Do(EventQueue *queue);

src/servers/registrar/MessageRunnerManager.cpp

108

virtual bool Do(EventQueue *queue)

src/system/kernel/DPC.cpp

43

FunctionDPCCallback::DoDPC(DPCQueue* queue)

src/system/kernel/UserEvent.cpp

145

TeamSignalEvent::DoDPC(DPCQueue* queue)

src/system/kernel/UserEvent.cpp

215

ThreadSignalEvent::DoDPC(DPCQueue* queue)

src/system/kernel/UserEvent.cpp

276

CreateThreadEvent::DoDPC(DPCQueue* queue)

src/system/kernel/arch/arm/paging/32bit/ARMVMTranslationMap32Bit.cpp

374

VMAreaMappings queue;

src/system/kernel/arch/arm/paging/32bit/ARMVMTranslationMap32Bit.cpp

415

updatePageQueue, &queue);

src/system/kernel/arch/arm/paging/32bit/ARMVMTranslationMap32Bit.cpp

434

while (vm_page_mapping* mapping = queue.RemoveHead())

src/system/kernel/arch/arm64/VMSAv8TranslationMap.cpp

690

VMAreaMappings queue;

src/system/kernel/arch/arm64/VMSAv8TranslationMap.cpp

695

[=, &queue](uint64_t* ptePtr, uint64_t effectiveVa) {

src/system/kernel/arch/arm64/VMSAv8TranslationMap.cpp

707

updatePageQueue, &queue);

src/system/kernel/arch/arm64/VMSAv8TranslationMap.cpp

722

while (vm_page_mapping* mapping = queue.RemoveHead())

src/system/kernel/arch/generic/generic_vm_physical_page_mapper.cpp

45

static queue mapped_paddr_lru;

src/system/kernel/arch/m68k/paging/040/M68KVMTranslationMap040.cpp

531

VMAreaMappings queue;

src/system/kernel/arch/m68k/paging/040/M68KVMTranslationMap040.cpp

592

updatePageQueue, &queue);

src/system/kernel/arch/m68k/paging/040/M68KVMTranslationMap040.cpp

611

while (vm_page_mapping* mapping = queue.RemoveHead())

src/system/kernel/arch/ppc/paging/460/PPCVMTranslationMap460.cpp

713

VMAreaMappings queue;

src/system/kernel/arch/ppc/paging/460/PPCVMTranslationMap460.cpp

754

updatePageQueue, &queue);

src/system/kernel/arch/ppc/paging/460/PPCVMTranslationMap460.cpp

773

while (vm_page_mapping* mapping = queue.RemoveHead())

src/system/kernel/arch/ppc/paging/classic/PPCVMTranslationMapClassic.cpp

713

VMAreaMappings queue;

src/system/kernel/arch/ppc/paging/classic/PPCVMTranslationMapClassic.cpp

754

updatePageQueue, &queue);

src/system/kernel/arch/ppc/paging/classic/PPCVMTranslationMapClassic.cpp

773

while (vm_page_mapping* mapping = queue.RemoveHead())

src/system/kernel/arch/riscv64/RISCV64VMTranslationMap.cpp

376

VMAreaMappings queue;

src/system/kernel/arch/riscv64/RISCV64VMTranslationMap.cpp

396

updatePageQueue, &queue);

src/system/kernel/arch/riscv64/RISCV64VMTranslationMap.cpp

415

while (vm_page_mapping* mapping = queue.RemoveHead())

src/system/kernel/arch/x86/paging/32bit/X86VMTranslationMap32Bit.cpp

360

VMAreaMappings queue;

src/system/kernel/arch/x86/paging/32bit/X86VMTranslationMap32Bit.cpp

401

updatePageQueue, &queue);

src/system/kernel/arch/x86/paging/32bit/X86VMTranslationMap32Bit.cpp

420

while (vm_page_mapping* mapping = queue.RemoveHead())

src/system/kernel/arch/x86/paging/64bit/X86VMTranslationMap64Bit.cpp

405

VMAreaMappings queue;

src/system/kernel/arch/x86/paging/64bit/X86VMTranslationMap64Bit.cpp

443

updatePageQueue, &queue);

src/system/kernel/arch/x86/paging/64bit/X86VMTranslationMap64Bit.cpp

462

while (vm_page_mapping* mapping = queue.RemoveHead())

src/system/kernel/arch/x86/paging/pae/X86VMTranslationMapPAE.cpp

597

VMAreaMappings queue;

src/system/kernel/arch/x86/paging/pae/X86VMTranslationMapPAE.cpp

644

updatePageQueue, &queue);

src/system/kernel/arch/x86/paging/pae/X86VMTranslationMapPAE.cpp

663

while (vm_page_mapping* mapping = queue.RemoveHead())

src/system/kernel/events/event_queue.cpp

552

EventQueue* queue = (EventQueue*)descriptor->cookie;

src/system/kernel/events/event_queue.cpp

553

queue->Closed();

src/system/kernel/events/event_queue.cpp

561

EventQueue* queue = (EventQueue*)descriptor->cookie;

src/system/kernel/events/event_queue.cpp

562

put_select_sync(queue);

src/system/kernel/events/event_queue.cpp

605

EventQueue* queue = new(std::nothrow) EventQueue(false);

src/system/kernel/events/event_queue.cpp

606

if (queue == NULL)

src/system/kernel/events/event_queue.cpp

609

ObjectDeleter<EventQueue> deleter(queue);

src/system/kernel/events/event_queue.cpp

616

descriptor->cookie = (struct event_queue*)queue;

src/system/kernel/events/event_queue.cpp

637

_user_event_queue_select(int queue, event_wait_info* userInfos, int numInfos)

src/system/kernel/events/event_queue.cpp

649

GET_QUEUE_FD_OR_RETURN(queue, false, descriptor);

src/system/kernel/events/event_queue.cpp

687

_user_event_queue_wait(int queue, event_wait_info* userInfos, int numInfos,

src/system/kernel/events/event_queue.cpp

705

GET_QUEUE_FD_OR_RETURN(queue, false, descriptor);

src/system/kernel/sem.cpp

118

ThreadQueue queue; // should be in u.used, but has a constructor

src/system/kernel/sem.cpp

185

if (!sem->queue.IsEmpty()) {

src/system/kernel/sem.cpp

186

ThreadQueue::Iterator it = sem->queue.GetIterator();

src/system/kernel/sem.cpp

332

while (queued_thread* entry = sem.queue.RemoveHead()) {

src/system/kernel/sem.cpp

510

new(&sem->queue) ThreadQueue;

src/system/kernel/sem.cpp

606

sem->queue.Remove(entry);

src/system/kernel/sem.cpp

617

while ((entry = sem->queue.Head()) != NULL) {

src/system/kernel/sem.cpp

633

sem->queue.Remove(entry);

src/system/kernel/sem.cpp

810

sSems[slot].queue.Add(&queueEntry);

src/system/kernel/sem.cpp

934

queued_thread* entry = sSems[slot].queue.Head();

src/system/kernel/sem.cpp

965

sSems[slot].queue.Remove(entry);

src/system/kernel/util/queue.cpp

100

queue_peek(queue *q)

src/system/kernel/util/queue.cpp

25

queue_init(queue *q)

src/system/kernel/util/queue.cpp

34

queue_remove_item(queue *_q, void *e)

src/system/kernel/util/queue.cpp

62

queue_enqueue(queue *_q, void *e)

src/system/kernel/util/queue.cpp

81

queue_dequeue(queue *_q)

src/system/kernel/vm/VMPageQueue.h

102

page->queue = this;

src/system/kernel/vm/VMPageQueue.h

111

if (page->queue != NULL) {

src/system/kernel/vm/VMPageQueue.h

113

"already in queue %p", this, page, page->queue);

src/system/kernel/vm/VMPageQueue.h

121

page->queue = this;

src/system/kernel/vm/VMPageQueue.h

130

if (page->queue != this) {

src/system/kernel/vm/VMPageQueue.h

132

"is in queue %p", this, page, page->queue);

src/system/kernel/vm/VMPageQueue.h

140

page->queue = NULL;

src/system/kernel/vm/VMPageQueue.h

153

if (page->queue != this) {

src/system/kernel/vm/VMPageQueue.h

155

"queue %p", this, page, page->queue);

src/system/kernel/vm/VMPageQueue.h

158

page->queue = NULL;

src/system/kernel/vm/VMPageQueue.h

170

if (page->queue != this) {

src/system/kernel/vm/VMPageQueue.h

172

"queue %p", this, page, page->queue);

src/system/kernel/vm/VMPageQueue.h

195

if (page->queue != NULL) {

src/system/kernel/vm/VMPageQueue.h

197

"already in queue %p", this, page, page->queue);

src/system/kernel/vm/VMPageQueue.h

200

page->queue = this;

src/system/kernel/vm/VMPageQueue.h

73

if (page->queue != NULL) {

src/system/kernel/vm/VMPageQueue.h

75

"already in queue %p", this, page, page->queue);

src/system/kernel/vm/VMPageQueue.h

83

page->queue = this;

src/system/kernel/vm/VMPageQueue.h

92

if (page->queue != NULL) {

src/system/kernel/vm/VMPageQueue.h

94

"already in queue %p", this, page, page->queue);

src/system/kernel/vm/vm_page.cpp

1639

VMPageQueue& queue = page->State() == PAGE_STATE_FREE

src/system/kernel/vm/vm_page.cpp

1641

queue.Remove(page);

src/system/kernel/vm/vm_page.cpp

1761

marker.queue = NULL;

src/system/kernel/vm/vm_page.cpp

1915

VMPageQueue& queue = sActivePageQueue;

src/system/kernel/vm/vm_page.cpp

1918

uint32 maxToScan = queue.Count() / kIdleRunsForFullQueue + 1;

src/system/kernel/vm/vm_page.cpp

1927

vm_page* page = queue.Head();

src/system/kernel/vm/vm_page.cpp

2012

VMPageQueue& queue = sInactivePageQueue;

src/system/kernel/vm/vm_page.cpp

2013

InterruptsSpinLocker queueLocker(queue.GetLock());

src/system/kernel/vm/vm_page.cpp

2014

uint32 maxToScan = queue.Count();

src/system/kernel/vm/vm_page.cpp

2016

vm_page* nextPage = queue.Head();

src/system/kernel/vm/vm_page.cpp

2025

nextPage = queue.Next(page);

src/system/kernel/vm/vm_page.cpp

2031

queue.InsertAfter(page, &marker);

src/system/kernel/vm/vm_page.cpp

2041

nextPage = queue.Next(&marker);

src/system/kernel/vm/vm_page.cpp

2042

queue.Remove(&marker);

src/system/kernel/vm/vm_page.cpp

2105

nextPage = queue.Next(&marker);

src/system/kernel/vm/vm_page.cpp

2106

queue.Remove(&marker);

src/system/kernel/vm/vm_page.cpp

2129

VMPageQueue& queue = sActivePageQueue;

src/system/kernel/vm/vm_page.cpp

2130

InterruptsSpinLocker queueLocker(queue.GetLock());

src/system/kernel/vm/vm_page.cpp

2131

uint32 maxToScan = queue.Count();

src/system/kernel/vm/vm_page.cpp

2145

vm_page* nextPage = queue.Head();

src/system/kernel/vm/vm_page.cpp

2154

nextPage = queue.Next(page);

src/system/kernel/vm/vm_page.cpp

2160

queue.InsertAfter(page, &marker);

src/system/kernel/vm/vm_page.cpp

2169

nextPage = queue.Next(&marker);

src/system/kernel/vm/vm_page.cpp

2170

queue.Remove(&marker);

src/system/kernel/vm/vm_page.cpp

2207

nextPage = queue.Next(&marker);

src/system/kernel/vm/vm_page.cpp

2208

queue.Remove(&marker);

src/system/kernel/vm/vm_page.cpp

2694

VMPageQueue* queue;

src/system/kernel/vm/vm_page.cpp

2698

queue = &sClearPageQueue;

src/system/kernel/vm/vm_page.cpp

2701

queue = &sFreePageQueue;

src/system/kernel/vm/vm_page.cpp

2707

vm_page* page = queue->RemoveHeadUnlocked();

src/system/kernel/vm/vm_page.cpp

2720

page = queue->RemoveHead();

src/system/kernel/vm/vm_page.cpp

3177

VMPageQueue *queue = page_queue_for(page, page->State());

src/system/kernel/vm/vm_page.cpp

3179

*_queue = queue;

src/system/kernel/vm/vm_page.cpp

3180

if (queue == NULL)

src/system/kernel/vm/vm_page.cpp

3183

queue->RequeueUnlocked(page, tail);

src/system/kernel/vm/vm_page.cpp

730

VMPageQueue* queue;

src/system/kernel/vm/vm_page.cpp

753

VMPageQueue::Iterator it = pageQueueInfos[i].queue->GetIterator();

src/system/kernel/vm/vm_page.cpp

757

pageQueueInfos[i].queue, pageQueueInfos[i].name);

src/system/kernel/vm/vm_page.cpp

893

kprintf("queue: %p\n", page->queue);

src/system/kernel/vm/vm_page.cpp

960

struct VMPageQueue *queue;

src/system/kernel/vm/vm_page.cpp

968

queue = (VMPageQueue*)strtoul(argv[1], NULL, 16);

src/system/kernel/vm/vm_page.cpp

970

queue = &sFreePageQueue;

src/system/kernel/vm/vm_page.cpp

972

queue = &sClearPageQueue;

src/system/kernel/vm/vm_page.cpp

974

queue = &sModifiedPageQueue;

src/system/kernel/vm/vm_page.cpp

976

queue = &sActivePageQueue;

src/system/kernel/vm/vm_page.cpp

978

queue = &sInactivePageQueue;

src/system/kernel/vm/vm_page.cpp

980

queue = &sCachedPageQueue;

src/system/kernel/vm/vm_page.cpp

987

B_PRIuPHYSADDR "\n", queue, queue->Head(), queue->Tail(),

src/system/kernel/vm/vm_page.cpp

988

queue->Count());

src/system/kernel/vm/vm_page.cpp

991

struct vm_page *page = queue->Head();

src/system/kernel/vm/vm_page.cpp

994

for (page_num_t i = 0; page; i++, page = queue->Next(page)) {

src/system/kernel/vm/vm_page_writer.cpp

503

next_modified_page(VMPageQueue& queue, page_num_t& maxPagesToSee)

src/system/kernel/vm/vm_page_writer.cpp

505

InterruptsSpinLocker locker(queue.GetLock());

src/system/kernel/vm/vm_page_writer.cpp

508

vm_page* page = queue.Head();

src/system/kernel/vm/vm_page_writer.cpp

512

queue.Requeue(page, true);

src/system/kernel/vm/vm_page_writer.cpp

533

ModifiedPageQueue& queue = *this;

src/system/kernel/vm/vm_page_writer.cpp

553

if (queue.Count() < kNumPages) {

src/system/kernel/vm/vm_page_writer.cpp

558

page_num_t modifiedPages = queue.Count();

src/system/kernel/vm/vm_page_writer.cpp

602

vm_page *page = next_modified_page(queue, maxPagesToSee);

src/system/kernel/vm/vm_page_writer.cpp

680

queue.RequeueUnlocked(page, true);

src/system/kernel/vm/vm_page_writer.cpp

877

VMPageQueue* queue = NULL;

src/system/kernel/vm/vm_page_writer.cpp

878

vm_page_requeue(page, false, &queue);

src/system/kernel/vm/vm_page_writer.cpp

880

((ModifiedPageQueue*)queue)->NotifyWriter();

src/system/kernel/vm/vm_page_writer.cpp

890

VMPageQueue* queue = NULL;

src/system/kernel/vm/vm_page_writer.cpp

901

vm_page_requeue(page, false, &queue);

src/system/kernel/vm/vm_page_writer.cpp

908

((ModifiedPageQueue*)queue)->NotifyWriter();

src/system/runtime_loader/elf_symbol_lookup.cpp

325

image_t* queue[count_loaded_images()];

src/system/runtime_loader/elf_symbol_lookup.cpp

328

queue[count++] = image;

src/system/runtime_loader/elf_symbol_lookup.cpp

336

image = queue[index++];

src/system/runtime_loader/elf_symbol_lookup.cpp

354

queue[count++] = needed;

src/system/runtime_loader/elf_symbol_lookup.cpp

362

queue[i]->flags &= ~RFLAG_VISITED;

src/system/runtime_loader/images.cpp

107

find_image_in_queue(image_queue_t* queue, const char* name, bool isPath,

src/system/runtime_loader/images.cpp

110

for (image_t* image = queue->head; image; image = image->next) {

src/system/runtime_loader/images.cpp

128

image_t* queue[sLoadedImageCount];

src/system/runtime_loader/images.cpp

131

queue[count++] = image;

src/system/runtime_loader/images.cpp

136

image = queue[index++];

src/system/runtime_loader/images.cpp

142

queue[count++] = needed;

src/system/runtime_loader/images.cpp

150

queue[i]->flags = (queue[i]->flags | flagsToSet)

src/system/runtime_loader/images.cpp

74

enqueue_image(image_queue_t* queue, image_t* image)

src/system/runtime_loader/images.cpp

78

image->prev = queue->tail;

src/system/runtime_loader/images.cpp

79

if (queue->tail)

src/system/runtime_loader/images.cpp

80

queue->tail->next = image;

src/system/runtime_loader/images.cpp

82

queue->tail = image;

src/system/runtime_loader/images.cpp

83

if (!queue->head)

src/system/runtime_loader/images.cpp

84

queue->head = image;

src/system/runtime_loader/images.cpp

89

dequeue_image(image_queue_t* queue, image_t* image)

src/system/runtime_loader/images.cpp

94

queue->tail = image->prev;

src/system/runtime_loader/images.cpp

99

queue->head = image->next;

src/tests/kits/storage/MimeTypeTest.cpp

2710

std::queue<std::string> appList;

src/tests/kits/storage/MimeTypeTest.cpp

3435

BMessageQueue &queue = fApplication->Handler().Queue();

src/tests/kits/storage/MimeTypeTest.cpp

3436

CPPUNIT_ASSERT( queue.Lock() );

src/tests/kits/storage/MimeTypeTest.cpp

3439

while (BMessage *_message = queue.NextMessage()) {

src/tests/kits/storage/MimeTypeTest.cpp

3480

queue.Unlock();

src/tests/kits/storage/MimeTypeTest.cpp

3483

queue.Unlock();

src/tests/kits/storage/MimeTypeTest.cpp

536

QueueAdapter(std::queue<std::string> &queue)

src/tests/kits/storage/MimeTypeTest.cpp

537

: fQueue(queue) { }

src/tests/kits/storage/MimeTypeTest.cpp

542

std::queue<std::string> &fQueue;

src/tests/kits/storage/QueryTest.cpp

1341

BMessageQueue &queue = fApplication->Handler().Queue();

src/tests/kits/storage/QueryTest.cpp

1342

CPPUNIT_ASSERT( queue.Lock() );

src/tests/kits/storage/QueryTest.cpp

1345

while (BMessage *_message = queue.NextMessage()) {

src/tests/kits/storage/QueryTest.cpp

1377

queue.Unlock();

src/tests/kits/storage/QueryTest.cpp

1380

queue.Unlock();

src/tests/kits/storage/VolumeTest.cpp

530

BMessageQueue &queue = handler.Queue();

src/tests/kits/storage/VolumeTest.cpp

531

BMessage *_message = queue.NextMessage();