| /macosx-10.9.5/IONetworkingFamily-100/ |
| H A D | IOPacketQueue.cpp | 72 _queue = IONew(IOMbufQueue, 1);
73 if (_queue == 0)
76 IOMbufQueueInit(_queue, capacity);
112 if (_queue)
115 IODelete(_queue, IOMbufQueue, 1);
116 _queue = 0;
127 return IOMbufQueueGetSize(_queue);
135 IOMbufQueueSetCapacity(_queue, capacity);
144 return IOMbufQueueGetCapacity(_queue);
152 return IOMbufQueuePeek(_queue);
[all...] |
| H A D | IOPacketQueue.h | 55 IOMbufQueue * _queue; // mbuf queue member in class:IOPacketQueue
|
| /macosx-10.9.5/IOHIDFamily-503.215.2/IOHIDFamily/ |
| H A D | IOHIDEventServiceUserClient.cpp | 122 _queue->setNotificationPort(port);
137 if ( _queue ) {
138 IOMemoryDescriptor * memoryToShare = _queue->getMemoryDescriptor();
226 _queue = IOHIDEventServiceQueue::withCapacity(queueSize);
228 _queue = __fakeQueue.queue;
229 if ( _queue )
230 _queue->retain();
233 if ( !_queue )
257 _queue->setState(true);
265 _queue
[all...] |
| H A D | IOHIDResourceUserClient.cpp | 122 if ( _queue )
123 _queue->release();
140 _queue->setNotificationPort(port);
154 if ( !_queue ) {
169 _queue = IOHIDResourceQueue::withEntries(4, max(maxFeatureReportSize, maxOutputReportSize)+sizeof(IOHIDResourceDataQueueHeader));
172 if ( _queue ) {
173 IOMemoryDescriptor * memoryToShare = _queue->getMemoryDescriptor();
484 if ( _queue && _queue->enqueueReport(&header) ){
534 if ( _queue
[all...] |
| H A D | IOHIDEventServiceUserClient.h | 50 IOHIDEventServiceQueue * _queue; member in class:IOHIDEventServiceUserClient
|
| H A D | IOHIDResourceUserClient.h | 124 IOHIDResourceQueue * _queue; member in class:IOHIDResourceDeviceUserClient
|
| /macosx-10.9.5/Heimdal-323.92.1/Sample/GSSSampleIOS/ |
| H A D | ViewController.h | 8 dispatch_queue_t _queue; variable
|
| /macosx-10.9.5/DiskArbitration-266/diskarbitrationd/ |
| H A D | DASession.c | 42 CFMutableArrayRef _queue; member in struct:__DASession
111 session->_queue = CFArrayCreateMutable( allocator, 0, &kCFTypeArrayCallBacks );
117 assert( session->_queue );
131 if ( session->_queue ) CFRelease( session->_queue );
274 return session->_queue;
321 CFArrayAppendValue( session->_queue, callback );
323 if ( CFArrayGetCount( session->_queue ) == 1 )
376 if ( CFArrayGetCount( session->_queue ) )
439 count = CFArrayGetCount( session->_queue );
[all...] |
| H A D | DAServer.defs | 76 out _queue : ___vm_address_t, dealloc );
|
| H A D | DAServer.c | 1391 kern_return_t _DAServerSessionCopyCallbackQueue( mach_port_t _session, vm_address_t * _queue, mach_msg_type_number_t * _queueSize ) argument
1438 *_queue = ___CFDataCopyBytes( queue, _queueSize );
1440 if ( *_queue )
|
| /macosx-10.9.5/Security-55471.14.18/sec/Security/ |
| H A D | SecOTRSessionPriv.h | 80 dispatch_queue_t _queue; member in struct:_SecOTRSession
|
| H A D | SecOTRSession.c | 119 dispatch_release(session->_queue);
144 dispatch_sync_f(session->_queue, session, (dispatch_function_t) SecOTRSessionResetInternal);
154 newID->_queue = dispatch_queue_create("OTRSession", DISPATCH_QUEUE_SERIAL);
264 session->_queue = dispatch_queue_create("OTRSession", DISPATCH_QUEUE_SERIAL);
375 dispatch_sync(session->_queue, ^{
455 dispatch_sync(session->_queue, ^{ result = session->_state == kDone; });
464 dispatch_sync(session->_queue, ^{ result = session->_state == kIdle; });
514 dispatch_sync_f(session->_queue, session, (dispatch_function_t) SecOTRSPrecalculateKeysInternal);
548 dispatch_sync(session->_queue, ^{
632 dispatch_sync(session->_queue,
[all...] |
| H A D | SecOTRSessionAKE.c | 48 dispatch_sync(session->_queue, ^{
79 dispatch_sync(session->_queue, ^{
518 dispatch_sync(session->_queue, ^{
|
| /macosx-10.9.5/WebCore-7537.78.1/inspector/front-end/ |
| H A D | HeapSnapshotProxy.js | 98 this._queue = [];
108 this._queue.push(task);
115 var queue = this._queue;
116 this._queue = [];
129 if (this._queue.length && !this._isTimerSheduled) {
|
| /macosx-10.9.5/DiskArbitration-266/DiskArbitration/ |
| H A D | DASession.c | 170 vm_address_t _queue; local
175 status = _DAServerSessionCopyCallbackQueue( session->_server, &_queue, &_queueSize );
181 queue = _DAUnserializeWithBytes( CFGetAllocator( session ), _queue, _queueSize );
217 vm_deallocate( mach_task_self( ), _queue, _queueSize ); local
|
| /macosx-10.9.5/Libc-997.90.3/stdio/FreeBSD/ |
| H A D | xprintf.c | 344 struct array *a = (struct array *)OSAtomicDequeue(&which ## _queue, offsetof(struct array, next)); \
364 OSAtomicEnqueue(&which ## _queue, a, offsetof(struct array, next)); \
372 while((a = (struct array *)OSAtomicDequeue(&which ## _queue, offsetof(struct array, next))) != NULL) { \
|
| /macosx-10.9.5/CF-855.17/ |
| H A D | CFRunLoop.c | 538 dispatch_queue_t _queue; member in struct:__CFRunLoopMode
582 CFStringAppendFormat(result, NULL, CFSTR("queue = %p, "), rlm->_queue);
609 if (rlm->_queue) {
610 dispatch_release(rlm->_queue);
789 rlm->_queue = _dispatch_runloop_root_queue_create_4CF("Run Loop Mode Queue", 0);
790 mach_port_t queuePort = _dispatch_runloop_root_queue_get_port_4CF(rlm->_queue);
792 rlm->_timerSource = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, rlm->_queue);
2325 if (rlm->_queue) {
2326 modeQueuePort = _dispatch_runloop_root_queue_get_port_4CF(rlm->_queue);
2423 while (_dispatch_runloop_root_queue_perform_4CF(rlm->_queue));
[all...] |