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

123

/macosx-10.9.5/CPANInternal-140/IO-KQueue/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.9.5/CPANInternal-140/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.9.5/Security-55471.14.18/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.9.5/Security-55471.14.18/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.9.5/xnu-2422.115.4/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);
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 Dwait4path.c33 int kq = kqueue(); local
44 if (kevent(kq, &kev, 1, NULL, 0, NULL) == -1) {
54 kevent(kq, NULL, 0, &kev, 1, NULL);
H A Dlaunchproxy.c46 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 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.9.5/CPANInternal-140/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.9.5/securityd-55199.3/src/
H A Dauditevents.h33 #include <security_utilities/kq++.h>
/macosx-10.9.5/mDNSResponder-522.92.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.9.5/xnu-2422.115.4/tools/tests/unit_tests/ptrace_test_12507045_src/
H A Dptrace_test.c259 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 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.9.5/OpenSSH-186/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.9.5/diskdev_cmds-572.1.1/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.9.5/lsof-52/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.9.5/lsof-52/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);

Completed in 747 milliseconds

123