Searched refs:queue (Results 101 - 125 of 738) sorted by relevance

1234567891011>>

/macosx-10.10/libdispatch-442.1.4/src/
H A Dprovider.d41 * Probes for dispatch queue push and pop operations
43 * dispatch$target:libdispatch*.dylib::queue-push
44 * dispatch$target:libdispatch*.dylib::queue-pop
46 probe queue__push(dispatch_queue_t queue, const char *label,
49 probe queue__pop(dispatch_queue_t queue, const char *label,
59 probe callout__entry(dispatch_queue_t queue, const char *label,
61 probe callout__return(dispatch_queue_t queue, const char *label,
/macosx-10.10/xnu-2782.1.97/bsd/sys/
H A Dfile.h71 #include <sys/queue.h>
75 #include <sys/queue.h>
/macosx-10.10/IOHIDFamily-606.1.7/IOHIDEventSystemPlugIns/
H A DIOHIDEventSystemStatistics.h30 void scheduleWithDispatchQueue(dispatch_queue_t queue);
31 void unscheduleFromDispatchQueue(dispatch_queue_t queue);
75 static void scheduleWithDispatchQueue(void * self, dispatch_queue_t queue);
76 static void unscheduleFromDispatchQueue(void * self, dispatch_queue_t queue);
/macosx-10.10/WebCore-7600.1.25/replay/
H A DFunctorInputCursor.h68 typename Functor::ReturnType FunctorInputCursor::forEachInputInQueue(InputQueue queue, Functor& functor) argument
70 for (size_t i = 0; i < m_storage.queueSize(queue); i++)
71 functor(i, m_storage.queue(queue).at(i).get());
/macosx-10.10/configd-699.1.5/SystemConfiguration.fproj/
H A Dscprefs_observer.h51 @param queue the queue to be called back on.
57 dispatch_queue_t queue, dispatch_block_t block);
/macosx-10.10/xnu-2782.1.97/bsd/net/
H A Dflowadv.h34 #include <sys/queue.h>
H A Dmulticast_list.h32 #include <sys/queue.h>
H A Dnet_str_id.h37 #include <sys/queue.h>
/macosx-10.10/xnu-2782.1.97/iokit/IOKit/
H A DIODataQueueShared.h38 * @abstract Represents an entry within the data queue
50 * @abstract A struct mapping to the header region of a data queue.
51 * @discussion This struct is variable sized. The struct represents the data queue header information plus a pointer to the actual data queue itself. The size of the struct is the combined size of the header fields (3 * sizeof(UInt32)) plus the actual size of the queue region. This size is stored in the queueSize field.
52 * @field queueSize The size of the queue region pointed to by the queue field.
53 * @field head The location of the queue head. This field is represented as a byte offset from the beginning of the queue memory region.
54 * @field tail The location of the queue tai
61 IODataQueueEntry queue[1]; member in struct:_IODataQueueMemory
[all...]
/macosx-10.10/libauto-186/auto_tester/
H A DEnliveningRace.m105 static ERQueue *queue;
132 list_address = queue.list = [ERList new];
133 ERList *list = queue.list;
140 // swap ownership of the list between the worker and the queue.
141 ERList *temp = queue.list;
142 queue.list = work;
147 ERList *list = queue.list;
176 // now that queue has been scanned, put it back.
209 queue = [ERQueue new];
210 worker_address = queue
[all...]
/macosx-10.10/ruby-106/ruby/lib/drb/
H A Dextservm.rb30 @queue = Queue.new
65 name = @queue.pop
72 @queue.push(name)
/macosx-10.10/tcl-105/tcl_ext/tcllib/tcllib/modules/struct/queue/
H A Dm.c1 /* struct::queue - critcl - layer 3 definitions.
4 * Implementations for all queue methods.
31 * Removes all elements currently on the queue. I.e empties the queue.
45 /* Syntax: queue clear
55 * Delete and recreate the queue memory. A combination of delete/new,
60 Tcl_DecrRefCount (q->queue);
65 q->queue = Tcl_NewListObj (0,NULL);
69 Tcl_IncrRefCount (q->queue);
81 * Destroys the whole queue objec
[all...]
/macosx-10.10/IOHIDFamily-606.1.7/IOHIDFamily/
H A DIOHIDEventServiceQueue.cpp63 // Add event to the queue.
80 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail);
86 // exactly matches the available space at the end of the queue.
97 dataQueue->queue->size = dataSize;
105 ((IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail))->size = dataSize;
108 event->readBytes(&dataQueue->queue->data, dataSize);
116 result = false; // queue is full
121 // Do not allow the tail to catch up to the head when the queue is full.
126 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail);
137 result = false; // queue i
[all...]
/macosx-10.10/ruby-106/ruby/lib/rake/
H A Dthread_pool.rb16 @queue = Queue.new
29 # a future which has been created and added to the queue in the
37 @queue.enq promise
43 # Waits until the queue of futures is empty and all threads have exited.
53 $stderr.print "Queue contains #{@queue.size} items. Thread pool contains #{@threads.count} threads\n"
92 # processes one item on the queue. Returns true if there was an
95 return false if @queue.empty?
97 # Even though we just asked if the queue was empty, it
101 promise = @queue.deq(true)
106 rescue ThreadError # this means the queue i
[all...]
/macosx-10.10/xnu-2782.1.97/osfmk/kern/
H A Dtimer_queue.h29 * Timer queue support routines.
39 #include <kern/queue.h>
66 /* Request an expiration deadline, returns queue association */
80 mpqueue_head_t *queue,
84 /* Return a pointer to the local timer queue for a given cpu */
142 /* Process deadline expiration for queue, returns new deadline */
144 mpqueue_head_t *queue,
152 /* Shutdown a timer queue and reassign existing activities */
154 mpqueue_head_t *queue);
156 /* Move timer requests from one queue t
[all...]
/macosx-10.10/libdispatch-442.1.4/dispatch/
H A Dio.h95 * @param queue The dispatch queue to which the handler should be
108 dispatch_queue_t queue,
133 * @param queue The dispatch queue to which the handler should be
147 dispatch_queue_t queue,
204 * @param queue The dispatch queue to which the handler should be submitted.
218 dispatch_queue_t queue,
238 * @param queue Th
[all...]
/macosx-10.10/xnu-2782.1.97/iokit/Kernel/
H A DIOCommandQueue.cpp94 queue = (void *)kalloc(size * sizeof(commandEntryT));
95 if (!queue)
133 if (queue)
134 kfree(queue, size * sizeof(commandEntryT));
156 commandEntryT *q = (commandEntryT *) queue;
187 Key method that enqueues the four input fields onto the command queue
209 /* Make sure there is room in the queue before doing anything else */
235 commandEntryT *q = (commandEntryT *) queue;
272 // now step over all remaining entries in the command queue
277 commandEntryT *q = (commandEntryT *) queue;
[all...]
/macosx-10.10/postfix-255/postfix/src/global/
H A Dmail_stream.c12 /* char *id; /* queue ID */
18 /* MAIL_STREAM *mail_stream_file(queue, class, service, mode)
19 /* const char *queue;
42 /* This module provides a generic interface to Postfix queue file
45 /* stream and queue id member. The handle is either given to a cleanup
56 /* and receives queue ID information from the command. The result
62 /* and receives queue ID information from the command. The result
83 /* The argument specifies an alternate destination queue. The
84 /* queue file is moved to the specified queue befor
404 mail_stream_file(const char *queue, const char *class, const char *service, int mode) argument
[all...]
/macosx-10.10/ruby-106/ruby/ext/psych/yaml/
H A Dyaml_private.h417 * Stack and queue management.
460 #define QUEUE_INIT(context,queue,size) \
461 (((queue).start = yaml_malloc((size)*sizeof(*(queue).start))) ? \
462 ((queue).head = (queue).tail = (queue).start, \
463 (queue).end = (queue).start+(size), \
468 #define QUEUE_DEL(context,queue) \
[all...]
/macosx-10.10/Libnotify-133.1.1/notifyd/
H A Dtimer.c244 * It is dispatched on the timer's dispatch source queue to make it safe.
269 * before we free the timer. We let the source's queue do the actual free.
275 timer_oneshot(time_t when, dispatch_queue_t queue) argument
288 dispatch_retain(queue);
292 t->t_queue = queue;
294 t->t_src = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, queue);
295 t->src = dispatch_source_create(DISPATCH_SOURCE_TYPE_DATA_ADD, 0, 0, queue);
323 timer_clock(time_t first, time_t freq_sec, time_t end, dispatch_queue_t queue) argument
330 if (freq_sec == 0) return timer_oneshot(first, queue);
351 t->t_queue = queue;
380 timer_calendar(time_t first, time_t freq_mth, time_t end, int day, dispatch_queue_t queue) argument
435 timer_calendar_long(uint32_t start_year, uint32_t start_month, uint32_t start_day, uint32_t start_hour, uint32_t start_min, uint32_t start_sec, time_t freq, int day, uint32_t end_year, uint32_t end_month, uint32_t end_day, uint32_t end_hour, uint32_t end_min, uint32_t end_sec, dispatch_queue_t queue) argument
[all...]
/macosx-10.10/tcl-105/tcl_ext/memchan/memchan/generic/
H A DbufDecls.h130 EXTERN void Buf_FreeQueue _ANSI_ARGS_((Buf_BufferQueue queue));
132 EXTERN int Buf_QueueRead _ANSI_ARGS_((Buf_BufferQueue queue,
135 EXTERN int Buf_QueueWrite _ANSI_ARGS_((Buf_BufferQueue queue,
138 EXTERN void Buf_QueueAppend _ANSI_ARGS_((Buf_BufferQueue queue,
141 EXTERN int Buf_QueueSize _ANSI_ARGS_((Buf_BufferQueue queue));
213 void (*buf_FreeQueue) _ANSI_ARGS_((Buf_BufferQueue queue)); /* 61 */
214 int (*buf_QueueRead) _ANSI_ARGS_((Buf_BufferQueue queue, char* outbuf, int size)); /* 62 */
215 int (*buf_QueueWrite) _ANSI_ARGS_((Buf_BufferQueue queue, CONST char* inbuf, int size)); /* 63 */
216 void (*buf_QueueAppend) _ANSI_ARGS_((Buf_BufferQueue queue, Buf_Buffer buf)); /* 64 */
217 int (*buf_QueueSize) _ANSI_ARGS_((Buf_BufferQueue queue)); /* 6
[all...]
/macosx-10.10/IOKitUser-1050.1.21/IOServiceAuthorizeAgent/
H A Dapplication.m33 static dispatch_queue_t queue;
37 queue = dispatch_queue_create( 0, 0 );
40 return queue;
/macosx-10.10/IOHIDFamily-606.1.7/IOHIDLib/
H A DIOHIDEventServiceClass.h83 static void _scheduleWithDispatchQueue(void *self, dispatch_queue_t queue);
84 static void _unscheduleFromDispatchQueue(void *self, dispatch_queue_t queue);
108 virtual void scheduleWithDispatchQueue(dispatch_queue_t queue);
109 virtual void unscheduleFromDispatchQueue(dispatch_queue_t queue);
/macosx-10.10/Libc-1044.1.2/gen/FreeBSD/
H A Dtelldir.h38 #include <sys/queue.h>
/macosx-10.10/Security-57031.1.35/Security/libsecurity_transform/lib/
H A DMonitor.h35 BlockMonitor(dispatch_queue_t queue, SecMessageBlock block);

Completed in 247 milliseconds

1234567891011>>