lib/libevent/kqueue.c

129

kq_insert(struct kqop *kqop, struct kevent *kev)

lib/libevent/kqueue.c

131

int nevents = kqop->nevents;

lib/libevent/kqueue.c

133

if (kqop->nchanges == nevents) {

lib/libevent/kqueue.c

143

newchange = recallocarray(kqop->changes,

lib/libevent/kqueue.c

144

kqop->nevents, nevents, sizeof(struct kevent));

lib/libevent/kqueue.c

149

kqop->changes = newchange;

lib/libevent/kqueue.c

151

newresult = recallocarray(kqop->events,

lib/libevent/kqueue.c

152

kqop->nevents, nevents, sizeof(struct kevent));

lib/libevent/kqueue.c

162

kqop->events = newresult;

lib/libevent/kqueue.c

164

kqop->nevents = nevents;

lib/libevent/kqueue.c

167

memcpy(&kqop->changes[kqop->nchanges++], kev, sizeof(struct kevent));

lib/libevent/kqueue.c

186

struct kqop *kqop = arg;

lib/libevent/kqueue.c

187

struct kevent *changes = kqop->changes;

lib/libevent/kqueue.c

188

struct kevent *events = kqop->events;

lib/libevent/kqueue.c

198

res = kevent(kqop->kq, kqop->nchanges ? changes : NULL, kqop->nchanges,

lib/libevent/kqueue.c

199

events, kqop->nevents, ts_p);

lib/libevent/kqueue.c

200

kqop->nchanges = 0;

lib/libevent/kqueue.c

290

struct kqop *kqop = arg;

lib/libevent/kqueue.c

297

if (TAILQ_EMPTY(&kqop->evsigevents[nsignal])) {

lib/libevent/kqueue.c

304

kev.udata = &kqop->evsigevents[nsignal];

lib/libevent/kqueue.c

309

if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1)

lib/libevent/kqueue.c

317

TAILQ_INSERT_TAIL(&kqop->evsigevents[nsignal], ev,

lib/libevent/kqueue.c

334

if (kq_insert(kqop, &kev) == -1)

lib/libevent/kqueue.c

349

if (kq_insert(kqop, &kev) == -1)

lib/libevent/kqueue.c

362

struct kqop *kqop = arg;

lib/libevent/kqueue.c

373

TAILQ_REMOVE(&kqop->evsigevents[nsignal], ev, ev_signal_next);

lib/libevent/kqueue.c

374

if (TAILQ_EMPTY(&kqop->evsigevents[nsignal])) {

lib/libevent/kqueue.c

383

if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1)

lib/libevent/kqueue.c

395

for (i = j = 0; i < kqop->nchanges; i++) {

lib/libevent/kqueue.c

396

if (kqop->changes[i].udata == ev &&

lib/libevent/kqueue.c

397

(kqop->changes[i].flags & EV_ADD) != 0)

lib/libevent/kqueue.c

400

memcpy(&kqop->changes[j], &kqop->changes[i],

lib/libevent/kqueue.c

404

if (kqop->nchanges != j) {

lib/libevent/kqueue.c

405

kqop->nchanges = j;

lib/libevent/kqueue.c

416

if (kq_insert(kqop, &kev) == -1)

lib/libevent/kqueue.c

428

if (kq_insert(kqop, &kev) == -1)

lib/libevent/kqueue.c

440

struct kqop *kqop = arg;

lib/libevent/kqueue.c

444

free(kqop->changes);

lib/libevent/kqueue.c

445

free(kqop->events);

lib/libevent/kqueue.c

446

if (kqop->kq >= 0 && kqop->pid == getpid())

lib/libevent/kqueue.c

447

close(kqop->kq);

lib/libevent/kqueue.c

449

memset(kqop, 0, sizeof(struct kqop));

lib/libevent/kqueue.c

450

free(kqop);

lib/libevent/kqueue.c

68

static int kq_insert (struct kqop *, struct kevent *);

lib/libevent/kqueue.c

85

struct kqop *kqueueop;

lib/libevent/kqueue.c

91

if (!(kqueueop = calloc(1, sizeof(struct kqop))))