Searched refs:queueEntry (Results 1 - 5 of 5) sorted by relevance
| /haiku/src/apps/showimage/ |
| H A D | ImageCache.cpp | 221 ImageCache::_RetrieveImage(QueueEntry* queueEntry, CacheEntry** _entry) argument
234 status_t status = file.SetTo(&queueEntry->ref, B_READ_ONLY);
242 if (queueEntry->page != 0
243 && ioExtension.AddInt32("/documentIndex", queueEntry->page) != B_OK)
247 if (!queueEntry->listeners.empty()) {
249 progress.AddRef("ref", &queueEntry->ref);
251 *queueEntry->listeners.begin());
278 entry->ref = queueEntry->ref;
279 entry->page = queueEntry->page;
326 ImageCache::_NotifyListeners(CacheEntry* entry, QueueEntry* queueEntry) argument
[all...] |
| H A D | ImageCache.h | 70 QueueEntry* queueEntry);
|
| /haiku/src/system/kernel/posix/ |
| H A D | xsi_message_queue.cpp | 109 status_t BlockAndUnlock(ConditionVariableEntry *queueEntry, MutexLocker *queueLocker) argument
113 return queueEntry->Wait(B_CAN_INTERRUPT);
126 void Dequeue(ConditionVariableEntry *queueEntry) argument
128 queueEntry->Wait(B_RELATIVE_TIMEOUT, 0);
131 void Enqueue(ConditionVariableEntry *queueEntry, bool waitForMessage) argument
134 fWaitingToReceive.Add(queueEntry);
136 fWaitingToSend.Add(queueEntry);
714 ConditionVariableEntry queueEntry; local
715 messageQueue->Enqueue(&queueEntry, /* waitForMessage */ true);
721 = messageQueue->BlockAndUnlock(&queueEntry,
821 ConditionVariableEntry queueEntry; local
[all...] |
| H A D | xsi_semaphore.cpp | 129 static void Dequeue(ConditionVariableEntry *queueEntry) argument
131 queueEntry->Wait(B_RELATIVE_TIMEOUT, 0);
134 void Enqueue(ConditionVariableEntry *queueEntry, bool waitForZero) argument
137 fWaitingToBeZero.Add(queueEntry);
139 fWaitingToIncrease.Add(queueEntry);
1129 ConditionVariableEntry queueEntry; local
1130 semaphore->Enqueue(&queueEntry, waitOnZero);
1138 result = queueEntry.Wait(B_CAN_INTERRUPT);
1156 XsiSemaphore::Dequeue(&queueEntry);
|
| /haiku/src/system/kernel/ |
| H A D | sem.cpp | 811 queued_thread queueEntry(thread, count);
812 sSems[slot].queue.Add(&queueEntry);
813 queueEntry.queued = true;
833 if (queueEntry.queued)
834 remove_thread_from_sem(&queueEntry, &sSems[slot]);
|
Completed in 47 milliseconds