/macosx-10.9.5/CPANInternal-140/IO-KQueue/examples/ |
H A D | chat.pl | 16 my $kq = IO::KQueue->new(); 18 $kq->EV_SET(fileno($server), EVFILT_READ, EV_ADD, 0, 5); 22 my @ret = $kq->kevent(); 38 $kq->EV_SET(fileno($client), EVFILT_READ, EV_ADD);
|
H A D | tail.pl | 26 my $kq = IO::KQueue->new(); 28 $kq->EV_SET(fileno($fh), EVFILT_READ, EV_ADD, 0, 0, \&read_file); 29 $kq->EV_SET(fileno($fh), EVFILT_VNODE, EV_ADD, NOTE_DELETE | NOTE_RENAME, 0, \&reopen_file); 32 my @events = $kq->kevent(); 58 $kq->EV_SET(fileno($fh), EVFILT_READ, EV_ADD, 0, 0, \&read_file); 59 $kq->EV_SET(fileno($fh), EVFILT_VNODE, EV_ADD, NOTE_DELETE | NOTE_RENAME, 0, \&reopen_file);
|
/macosx-10.9.5/CPANInternal-140/IO-KQueue-0.34/examples/ |
H A D | chat.pl | 16 my $kq = IO::KQueue->new(); 18 $kq->EV_SET(fileno($server), EVFILT_READ, EV_ADD, 0, 5); 22 my @ret = $kq->kevent(); 38 $kq->EV_SET(fileno($client), EVFILT_READ, EV_ADD);
|
H A D | tail.pl | 26 my $kq = IO::KQueue->new(); 28 $kq->EV_SET(fileno($fh), EVFILT_READ, EV_ADD, 0, 0, \&read_file); 29 $kq->EV_SET(fileno($fh), EVFILT_VNODE, EV_ADD, NOTE_DELETE | NOTE_RENAME, 0, \&reopen_file); 32 my @events = $kq->kevent(); 58 $kq->EV_SET(fileno($fh), EVFILT_READ, EV_ADD, 0, 0, \&read_file); 59 $kq->EV_SET(fileno($fh), EVFILT_VNODE, EV_ADD, NOTE_DELETE | NOTE_RENAME, 0, \&reopen_file);
|
/macosx-10.9.5/Security-55471.14.18/include/security_utilities/ |
H A D | kq++.h | 26 // kq++ - kqueue/kevent interface 67 void addTo(KQueue &kq, unsigned flags = 0) argument 68 { this->flags = EV_ADD | flags; kq.update(*this); } 69 void removeFrom(KQueue &kq, unsigned flags = 0) argument 70 { this->flags = EV_DELETE | flags; kq.update(*this); } 71 void enable(KQueue &kq, unsigned flags = 0) argument 72 { this->flags = EV_ENABLE | flags; kq.update(*this); } 73 void disable(KQueue &kq, unsigned flags = 0) argument 74 { this->flags = EV_DISABLE | flags; kq.update(*this); }
|
H A D | kq++.cpp | 26 // kq++ - kqueue/kevent interface 28 #include <security_utilities/kq++.h>
|
/macosx-10.9.5/Security-55471.14.18/libsecurity_utilities/lib/ |
H A D | kq++.h | 26 // kq++ - kqueue/kevent interface 67 void addTo(KQueue &kq, unsigned flags = 0) argument 68 { this->flags = EV_ADD | flags; kq.update(*this); } 69 void removeFrom(KQueue &kq, unsigned flags = 0) argument 70 { this->flags = EV_DELETE | flags; kq.update(*this); } 71 void enable(KQueue &kq, unsigned flags = 0) argument 72 { this->flags = EV_ENABLE | flags; kq.update(*this); } 73 void disable(KQueue &kq, unsigned flags = 0) argument 74 { this->flags = EV_DISABLE | flags; kq.update(*this); }
|
H A D | kq++.cpp | 26 // kq++ - kqueue/kevent interface 28 #include <security_utilities/kq++.h>
|
/macosx-10.9.5/xnu-2422.115.4/bsd/kern/ |
H A D | kern_event.c | 110 static inline void kqlock(struct kqueue *kq); 111 static inline void kqunlock(struct kqueue *kq); 113 static int kqlock2knoteuse(struct kqueue *kq, struct knote *kn); 114 static int kqlock2knoteusewait(struct kqueue *kq, struct knote *kn); 115 static int kqlock2knotedrop(struct kqueue *kq, struct knote *kn); 116 static int knoteuse2kqlock(struct kqueue *kq, struct knote *kn); 118 static void kqueue_wakeup(struct kqueue *kq, int closed); 154 static int kevent_callback(struct kqueue *kq, struct kevent64_s *kevp, 156 static void kevent_continue(struct kqueue *kq, void *data, int error); 158 static int kqueue_process(struct kqueue *kq, kevent_callback_ 317 kqlock(struct kqueue *kq) argument 323 kqunlock(struct kqueue *kq) argument 338 kqlock2knoteuse(struct kqueue *kq, struct knote *kn) argument 358 kqlock2knoteusewait(struct kqueue *kq, struct knote *kn) argument 384 knoteuse2kqlock(struct kqueue *kq, struct knote *kn) argument 415 kqlock2knotedrop(struct kqueue *kq, struct knote *kn) argument 441 struct kqueue *kq = kn->kn_kq; local 470 struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data; local 481 struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data; local 831 struct kqueue *kq = kn->kn_kq; local 846 struct kqueue *kq = kn->kn_kq; local 1159 struct kqueue *kq; local 1204 kqueue_dealloc(struct kqueue *kq) argument 1267 struct kqueue *kq; local 1398 kevent_continue(__unused struct kqueue *kq, void *data, int error) argument 1467 struct kqueue *kq; local 1568 kevent_callback(__unused struct kqueue *kq, struct kevent64_s *kevp, void *data) argument 1634 kevent_register(struct kqueue *kq, struct kevent64_s *kev, __unused struct proc *ctxp) argument 1860 struct kqueue *kq = kn->kn_kq; local 2011 kqueue_begin_processing(struct kqueue *kq) argument 2037 kqueue_end_processing(struct kqueue *kq) argument 2063 kqueue_process(struct kqueue *kq, kevent_callback_t callback, void *data, int *countp, struct proc *p) argument 2130 struct kqueue *kq = (struct kqueue *)data; local 2183 kqueue_scan(struct kqueue *kq, kevent_callback_t callback, kqueue_continue_t continuation, void *data, struct timeval *atvp, struct proc *p) argument 2311 struct kqueue *kq = (struct kqueue *)fp->f_data; local 2397 struct kqueue *kq = (struct kqueue *)fg->fg_data; local 2413 struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data; local 2463 struct kqueue *kq = (struct kqueue *)fp->f_fglob->fg_data; local 2475 struct kqueue *kq = (struct kqueue *)fp->f_data; local 2505 kqueue_wakeup(struct kqueue *kq, int closed) argument 2539 struct kqueue *kq = kn->kn_kq; local 2593 struct kqueue *kq = kn->kn_kq; local 2617 struct kqueue *kq = kn->kn_kq; local 2646 struct kqueue *kq = kn->kn_kq; local 2730 struct kqueue *kq = kn->kn_kq; local 2763 struct kqueue *kq = kn->kn_kq; local 2789 struct kqueue *kq = kn->kn_kq; local 2801 struct kqueue *kq = kn->kn_kq; local 3308 fill_kqueueinfo(struct kqueue *kq, struct kqueue_info * kinfo) argument [all...] |
/macosx-10.9.5/launchd-842.92.1/support/ |
H A D | wait4path.c | 33 int kq = kqueue(); local 44 if (kevent(kq, &kev, 1, NULL, 0, NULL) == -1) { 54 kevent(kq, NULL, 0, &kev, 1, NULL);
|
H A D | launchproxy.c | 46 static int kq = 0; variable 61 if (kevent(kq, &kev, 1, NULL, 0, NULL) == -1) 91 kq = kqueue(); 133 if ((r = kevent(kq, NULL, 0, &kev, 1, &timeout)) == -1) {
|
/macosx-10.9.5/CPANInternal-140/IO-KQueue/ |
H A D | KQueue.xs | 46 EV_SET(kq, ident, filter, flags, fflags = 0, data = 0, udata = NULL) 47 kqueue_t kq 64 i = kevent(kq, &ke, 1, NULL, 0, NULL); 70 kevent(kq, timeout=&PL_sv_undef) 71 kqueue_t kq 94 num_events = kevent(kq, NULL, 0, ke, max_events, tbuf); 117 kevent2(kq, timeout=&PL_sv_undef) 118 kqueue_t kq 134 RETVAL = kevent(kq, NULL, 0, ke2, 1000, tbuf); 140 get_kev(kq, [all...] |
H A D | Makefile.PL | 10 my $kq = eval { syscall($SYS_kqueue) };
|
H A D | KQueue.pm | 123 my $kq = IO::KQueue->new(); 124 $kq->EV_SET($fd, EVFILT_READ, EV_ADD, 0, 5); 126 my %results = $kq->kevent($timeout); 145 =head2 C<< $kq->EV_SET($ident, $filt, $flags, $fflags, $data, $udata) >> 149 $kq->EV_SET(fileno($server), EVFILT_READ, EV_ADD, 0, 5); 162 =head2 C<< $kq->kevent($timeout) >>
|
/macosx-10.9.5/CPANInternal-140/IO-KQueue-0.34/ |
H A D | KQueue.xs | 46 EV_SET(kq, ident, filter, flags, fflags = 0, data = 0, udata = NULL) 47 kqueue_t kq 64 i = kevent(kq, &ke, 1, NULL, 0, NULL); 70 kevent(kq, timeout=&PL_sv_undef) 71 kqueue_t kq 94 num_events = kevent(kq, NULL, 0, ke, max_events, tbuf); 117 kevent2(kq, timeout=&PL_sv_undef) 118 kqueue_t kq 134 RETVAL = kevent(kq, NULL, 0, ke2, 1000, tbuf); 140 get_kev(kq, [all...] |
H A D | Makefile.PL | 10 my $kq = eval { syscall($SYS_kqueue) };
|
H A D | KQueue.pm | 123 my $kq = IO::KQueue->new(); 124 $kq->EV_SET($fd, EVFILT_READ, EV_ADD, 0, 5); 126 my %results = $kq->kevent($timeout); 145 =head2 C<< $kq->EV_SET($ident, $filt, $flags, $fflags, $data, $udata) >> 149 $kq->EV_SET(fileno($server), EVFILT_READ, EV_ADD, 0, 5); 162 =head2 C<< $kq->kevent($timeout) >>
|
/macosx-10.9.5/securityd-55199.3/src/ |
H A D | auditevents.h | 33 #include <security_utilities/kq++.h>
|
/macosx-10.9.5/mDNSResponder-522.92.1/mDNSMacOSX/ |
H A D | DNSProxySupport.c | 102 KQSocketSet *kq = &sock->ss; local 175 kq->m->p->TCPProxyCallback(kq->m, sock, ti->reply, (mDNSu8 *)ti->reply + ti->replyLen, &senderAddr, senderPort, &destAddr, 194 KQSocketSet *kq; local 208 kq = &sock->ss; 209 kq->sktv4 = -1; 210 kq->sktv6 = -1; 211 kq->m = listenSet->m; 216 s = &kq->sktv4; 217 k = &kq 517 KQSocketSet *kq; local [all...] |
/macosx-10.9.5/xnu-2422.115.4/tools/tests/unit_tests/ptrace_test_12507045_src/ |
H A D | ptrace_test.c | 259 int kq; local 269 kq = kqueue(); 270 if (kq < 0) 275 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 281 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 288 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 295 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 301 ret = kevent64(kq, NULL, 0, &kev, 1, 0, NULL); 366 int kq; local 377 kq 503 int kq; local [all...] |
/macosx-10.9.5/xnu-2422.115.4/tools/tests/kqueue_tests/ |
H A D | kqueue_timer_tests.c | 10 int kq, passed, failed; variable 29 ret = kevent64(kq, kev, 1, kev, 1, 0, &timeout); 156 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 165 ret = kevent64(kq, NULL, 0, &kev, 1, 0, NULL); 183 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 198 ret = kevent64(kq, &kev, 1, NULL, 0, 0, NULL); 222 kq = kqueue(); 223 assert(kq > 0);
|
/macosx-10.9.5/OpenSSH-186/osslshim/ossl/ |
H A D | ossl-dsa-eay.c | 234 BIGNUM k, kq, *K, *kinv = NULL, *r = NULL; local 243 BN_init(&kq); 280 if (!BN_copy(&kq, &k)) { 290 if (!BN_add(&kq, &kq, dsa->q)) { 293 if (BN_num_bits(&kq) <= BN_num_bits(dsa->q)) { 294 if (!BN_add(&kq, &kq, dsa->q)) { 299 K = &kq; 347 BN_clear_free(&kq); [all...] |
/macosx-10.9.5/diskdev_cmds-572.1.1/fsck.tproj/ |
H A D | fsck.c | 826 int kq = -1; local 852 kq = kqueue(); 853 if (kq < 0) { 861 ct = kevent(kq, &kev, 1, NULL, 0, NULL); 866 close (kq); 867 kq = -1; 876 ct = kevent(kq, NULL, 0, &results, 1, &ts); 881 close (kq); 882 kq = -1; 888 if (kq > [all...] |
/macosx-10.9.5/lsof-52/lsof/dialects/darwin/kmem/ |
H A D | dfile.c | 139 struct kqueue kq; /* kqueue structure */ local 143 if (!ka || kread(ka, (char *)&kq, sizeof(kq))) 145 (void) snpf(Namech, Namechl, "count=%d, state=%#x", kq.kq_count, 146 kq.kq_state);
|
/macosx-10.9.5/lsof-52/lsof/dialects/darwin/libproc/ |
H A D | dfile.c | 370 struct kqueue_fdinfo kq; local 376 nb = proc_pidfdinfo(pid, fd, PROC_PIDFDKQUEUEINFO, &kq, sizeof(kq)); 380 } else if (nb < sizeof(kq)) { 386 sizeof(kq), nb); 392 enter_file_info(&kq.pfi); 398 (SZOFFTYPE)kq.kqueueinfo.kq_stat.vst_size, 399 kq.kqueueinfo.kq_state);
|