Lines Matching refs:waiter
526 // caller responsibile for setting up the lock and cleaning up the waiter
527 static int signalWaiter(CFMachPortRef waiter, int status)
533 replyPort=(mach_port_t)(intptr_t)CFDictionaryGetValue(sReplyPorts,waiter);
534 CFDictionaryRemoveValue(sReplyPorts, waiter);
537 if (waiter == sRebootWaiter) {
567 // signal the waiter
569 // on success, make the waiter the locker
584 CFMachPortRef waiter = NULL;
593 waiter = (CFMachPortRef)CFArrayGetValueAtIndex(watched->waiters, 0);
595 // move waiter into the pole position and remove from the array
597 "granting lock for %s to waiter %d", watched->caches->root,
598 CFMachPortGetPort(waiter));
599 watched->lock = waiter; // context already set to 'watched'
602 // signal the waiter, cleaning up on failure
603 if (signalWaiter(waiter, KERN_SUCCESS)) {
604 // XX should loop back to try next waiter if this one failed
605 cleanupPort(&watched->lock); // deallocates former waiter
1140 CFMachPortRef waiter;
1143 waiter = (CFMachPortRef)CFArrayGetValueAtIndex(watched->waiters,i);
1144 signalWaiter(waiter, ENOENT);
1145 cleanupPort(&waiter);
1797 CFMachPortRef waiter;
1799 // create waiter array (of CFMachPortRefs) if needed
1808 // create waiter and insert into array
1809 if (!(waiter = createWatchedPort(client, watched))) {
1814 // store waiter, replyPort
1815 // cleanupPort() CFRelease()s all waiter objects
1816 CFArrayAppendValue(watched->waiters, waiter);
1817 CFDictionarySetValue(sReplyPorts, waiter, (void*)(intptr_t)replyPort);
2036 } else { // it must have been a waiter
2041 "Warning: presumed waiter died, but no waiters.");
2046 CFMachPortRef waiter;
2048 waiter = (CFMachPortRef)CFArrayGetValueAtIndex(watched->waiters,i);
2049 if (mport == CFMachPortGetPort(waiter)) {
2050 cleanupPort(&waiter); // --retainCount