/macosx-10.10/CPANInternal-159.1/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.10/Security-57031.1.35/Security/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.10/Security-57031.1.35/Security/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.10/xnu-2782.1.97/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); 152 static int kevent_callback(struct kqueue *kq, struct kevent64_s *kevp, 154 static void kevent_continue(struct kqueue *kq, void *data, int error); 156 static int kqueue_process(struct kqueue *kq, kevent_callback_ 315 kqlock(struct kqueue *kq) argument 321 kqunlock(struct kqueue *kq) argument 336 kqlock2knoteuse(struct kqueue *kq, struct knote *kn) argument 356 kqlock2knoteusewait(struct kqueue *kq, struct knote *kn) argument 382 knoteuse2kqlock(struct kqueue *kq, struct knote *kn) argument 413 kqlock2knotedrop(struct kqueue *kq, struct knote *kn) argument 439 struct kqueue *kq = kn->kn_kq; local 468 struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data; local 479 struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data; local 838 struct kqueue *kq = kn->kn_kq; local 853 struct kqueue *kq = kn->kn_kq; local 1166 struct kqueue *kq; local 1211 kqueue_dealloc(struct kqueue *kq) argument 1274 struct kqueue *kq; local 1405 kevent_continue(__unused struct kqueue *kq, void *data, int error) argument 1474 struct kqueue *kq; local 1575 kevent_callback(__unused struct kqueue *kq, struct kevent64_s *kevp, void *data) argument 1641 kevent_register(struct kqueue *kq, struct kevent64_s *kev, __unused struct proc *ctxp) argument 1867 struct kqueue *kq = kn->kn_kq; local 2018 kqueue_begin_processing(struct kqueue *kq) argument 2044 kqueue_end_processing(struct kqueue *kq) argument 2070 kqueue_process(struct kqueue *kq, kevent_callback_t callback, void *data, int *countp, struct proc *p) argument 2137 struct kqueue *kq = (struct kqueue *)data; local 2190 kqueue_scan(struct kqueue *kq, kevent_callback_t callback, kqueue_continue_t continuation, void *data, struct timeval *atvp, struct proc *p) argument 2318 struct kqueue *kq = (struct kqueue *)fp->f_data; local 2404 struct kqueue *kq = (struct kqueue *)fg->fg_data; local 2420 struct kqueue *kq = (struct kqueue *)kn->kn_fp->f_data; local 2470 struct kqueue *kq = (struct kqueue *)fp->f_fglob->fg_data; local 2479 kqueue_stat(struct kqueue *kq, void *ub, int isstat64, proc_t p) argument 2511 kqueue_wakeup(struct kqueue *kq, int closed) argument 2545 struct kqueue *kq = kn->kn_kq; local 2599 struct kqueue *kq = kn->kn_kq; local 2623 struct kqueue *kq = kn->kn_kq; local 2652 struct kqueue *kq = kn->kn_kq; local 2736 struct kqueue *kq = kn->kn_kq; local 2769 struct kqueue *kq = kn->kn_kq; local 2795 struct kqueue *kq = kn->kn_kq; local 2807 struct kqueue *kq = kn->kn_kq; local 3491 fill_kqueueinfo(struct kqueue *kq, struct kqueue_info * kinfo) argument [all...] |
/macosx-10.10/CPANInternal-159.1/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.10/Security-57031.1.35/securityd/src/ |
H A D | auditevents.h | 33 #include <security_utilities/kq++.h>
|
/macosx-10.10/mDNSResponder-561.1.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.10/xnu-2782.1.97/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.10/OpenSSH-189/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.10/OpenSSL098-52/src/crypto/dsa/ |
H A D | dsa_ossl.c | 208 BIGNUM k,kq,*K,*kinv=NULL,*r=NULL; local 218 BN_init(&kq); 250 if (!BN_copy(&kq, &k)) goto err; 258 if (!BN_add(&kq, &kq, dsa->q)) goto err; 259 if (BN_num_bits(&kq) <= BN_num_bits(dsa->q)) 261 if (!BN_add(&kq, &kq, dsa->q)) goto err; 264 K = &kq; 293 BN_clear_free(&kq); [all...] |
/macosx-10.10/libpthread-105.1.4/kern/ |
H A D | kern_synch.c | 277 static void ksyn_freeallkwe(ksyn_queue_t kq); 286 static void ksyn_queue_init(ksyn_queue_t kq); 288 static void ksyn_queue_remove_item(ksyn_wait_queue_t kwq, ksyn_queue_t kq, ksyn_waitq_element_t kwe); 296 static uint32_t ksyn_queue_count_tolowest(ksyn_queue_t kq, uint32_t upto); 298 static ksyn_waitq_element_t ksyn_queue_find_cvpreposeq(ksyn_queue_t kq, uint32_t cgen); 301 static ksyn_waitq_element_t ksyn_queue_find_signalseq(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t toseq, uint32_t lockseq); 308 static ksyn_waitq_element_t ksyn_queue_find_seq(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t seq); 861 ksyn_queue_t kq = &ckwq->kw_ksynqueues[KSYN_QUEUE_WRITER]; local 883 kwe = ksyn_queue_find_signalseq(ckwq, kq, uptoseq, signalseq); 1122 ksyn_queue_t kq local 1579 ksyn_freeallkwe(ksyn_queue_t kq) argument 1982 ksyn_queue_t kq; local 2028 ksyn_queue_t kq; local 2166 ksyn_queue_init(ksyn_queue_t kq) argument 2177 ksyn_queue_t kq = &kwq->kw_ksynqueues[kqi]; local 2238 ksyn_queue_remove_item(ksyn_wait_queue_t kwq, ksyn_queue_t kq, ksyn_waitq_element_t kwe) argument 2279 ksyn_queue_find_seq(__unused ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t seq) argument 2294 ksyn_queue_find_cvpreposeq(ksyn_queue_t kq, uint32_t cgen) argument 2316 ksyn_queue_find_signalseq(__unused ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t uptoseq, uint32_t signalseq) argument 2369 ksyn_queue_t kq = &kwq->kw_ksynqueues[kqi]; local 2481 ksyn_queue_count_tolowest(ksyn_queue_t kq, uint32_t upto) argument 2511 ksyn_queue_t kq = &ckwq->kw_ksynqueues[KSYN_QUEUE_WRITER]; local [all...] |
/macosx-10.10/OpenSSL098-52/src/fips/dsa/ |
H A D | fips_dsa_ossl.c | 198 BIGNUM k,kq,*K,*kinv=NULL,*r=NULL; local 208 BN_init(&kq); 240 if (!BN_copy(&kq, &k)) goto err; 248 if (!BN_add(&kq, &kq, dsa->q)) goto err; 249 if (BN_num_bits(&kq) <= BN_num_bits(dsa->q)) 251 if (!BN_add(&kq, &kq, dsa->q)) goto err; 254 K = &kq; 283 BN_clear_free(&kq); [all...] |
/macosx-10.10/diskdev_cmds-576/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.10/lsof-53/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.10/lsof-53/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);
|
/macosx-10.10/text_cmds-88/tail/ |
H A D | forward.c | 75 int kq; variable 421 if (kevent(kq, ev, n, NULL, 0, &ts) < 0) { 461 kq = kqueue(); 462 if (kq < 0) 500 n = kevent(kq, NULL, 0, ev, 1, Fflag ? &ts : NULL);
|
/macosx-10.10/bind9-45.101/bind9/bin/tests/virtual-time/ |
H A D | vtwrapper.c | 258 kevent(int kq, struct kevent *changelist, int nchanges, argument 269 return syscall(SYS_kevent, kq, changelist, nchanges, 277 return syscall(SYS_kevent, kq, changelist, nchanges, eventlist, 280 return syscall(SYS_kevent, kq, changelist, nchanges, eventlist,
|
/macosx-10.10/Libinfo-459/lookup.subproj/ |
H A D | mdns_module.c | 1007 int kq; // kqueue to notify when callback received member in struct:__anon2863 1017 _mdns_query_start(mdns_query_context_t *ctx, mdns_reply_t *reply, uint8_t *answer, uint32_t *anslen, const char* name, int class, int type, const char *interface, DNSServiceFlags flags, int kq) argument 1040 ctx->kq = kq; 1142 ctx->kq = -1; 1332 if (context->kq != -1) { 1335 int res = kevent(context->kq, &ev, 1, NULL, 0, NULL); 1392 int kq, n, wait = 1; local 1444 kq = kqueue(); 1446 n = kevent(kq, [all...] |
/macosx-10.10/libresolv-57/ |
H A D | res_query.c | 303 int i, kq, n, wait, cancelled, notify_token, status; local 316 kq = -1; 382 kq = kqueue(); 396 n = kevent(kq, &mevent, 1, NULL, 0, NULL); 409 n = kevent(kq, &ievent, 1, NULL, 0, NULL); 433 n = kevent(kq, NULL, 0, &event, 1, &timeout); 504 close(kq);
|
/macosx-10.10/xnu-2782.1.97/tools/tests/MPMMTest/ |
H A D | KQMPMMtest.c | 342 int kq; local 357 kq = kqueue(); 358 if (kq == -1) { 368 err = kevent64(kq, kev, 1, NULL, 0, 0, NULL); 381 FD_SET(kq, &readfds); 386 count = select(kq + 1, &readfds, NULL, NULL, NULL); 399 err = kevent64(kq, kev, 1, kev, 1, 0, NULL);
|