Searched refs:kq (Results 1 - 25 of 45) sorted by relevance

12

/macosx-10.10/CPANInternal-159.1/IO-KQueue-0.34/examples/
H A Dchat.pl16 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 Dtail.pl26 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 Dkq++.h26 // 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 Dkq++.cpp26 // kq++ - kqueue/kevent interface
28 #include <security_utilities/kq++.h>
/macosx-10.10/Security-57031.1.35/Security/libsecurity_utilities/lib/
H A Dkq++.h26 // 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 Dkq++.cpp26 // kq++ - kqueue/kevent interface
28 #include <security_utilities/kq++.h>
/macosx-10.10/xnu-2782.1.97/bsd/kern/
H A Dkern_event.c110 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 DKQueue.xs46 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 DMakefile.PL10 my $kq = eval { syscall($SYS_kqueue) };
H A DKQueue.pm123 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 Dauditevents.h33 #include <security_utilities/kq++.h>
/macosx-10.10/mDNSResponder-561.1.1/mDNSMacOSX/
H A DDNSProxySupport.c102 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 Dkqueue_timer_tests.c10 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 Dossl-dsa-eay.c234 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 Ddsa_ossl.c208 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 Dkern_synch.c277 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 Dfips_dsa_ossl.c198 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 Dfsck.c826 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 Ddfile.c139 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 Ddfile.c370 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 Dforward.c75 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 Dvtwrapper.c258 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 Dmdns_module.c1007 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 Dres_query.c303 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 DKQMPMMtest.c342 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);

Completed in 299 milliseconds

12