Lines Matching refs:waiter
538 // caller responsibile for setting up the lock and cleaning up the waiter
539 static int signalWaiter(CFMachPortRef waiter, int status)
545 replyPort=(mach_port_t)(intptr_t)CFDictionaryGetValue(sReplyPorts,waiter);
546 CFDictionaryRemoveValue(sReplyPorts, waiter);
549 if (waiter == sRebootWaiter) {
579 // signal the waiter
581 // on success, make the waiter the locker
596 CFMachPortRef waiter = NULL;
605 waiter = (CFMachPortRef)CFArrayGetValueAtIndex(watched->waiters, 0);
607 // move waiter into the pole position and remove from the array
609 "granting lock for %s to waiter %d", watched->caches->root,
610 CFMachPortGetPort(waiter));
611 watched->lock = waiter; // context already set to 'watched'
614 // signal the waiter, cleaning up on failure
615 if (signalWaiter(waiter, KERN_SUCCESS)) {
616 // XX should loop back to try next waiter if this one failed
617 cleanupPort(&watched->lock); // deallocates former waiter
1022 CFMachPortRef waiter;
1025 waiter = (CFMachPortRef)CFArrayGetValueAtIndex(watched->waiters,i);
1026 signalWaiter(waiter, ENOENT);
1027 cleanupPort(&waiter);
1652 CFMachPortRef waiter;
1654 // create waiter array (of CFMachPortRefs) if needed
1663 // create waiter and insert into array
1664 if (!(waiter = createWatchedPort(client, watched))) {
1669 // store waiter, replyPort
1670 // cleanupPort() CFRelease()s all waiter objects
1671 CFArrayAppendValue(watched->waiters, waiter);
1672 CFDictionarySetValue(sReplyPorts, waiter, (void*)(intptr_t)replyPort);
1891 } else { // it must have been a waiter
1896 "Warning: presumed waiter died, but no waiters.");
1901 CFMachPortRef waiter;
1903 waiter = (CFMachPortRef)CFArrayGetValueAtIndex(watched->waiters,i);
1904 if (mport == CFMachPortGetPort(waiter)) {
1905 cleanupPort(&waiter); // --retainCount