… | |
… | |
327 | RETVAL = e_new (fh, events, cb); |
327 | RETVAL = e_new (fh, events, cb); |
328 | if (!ix) e_start (RETVAL); |
328 | if (!ix) e_start (RETVAL); |
329 | OUTPUT: |
329 | OUTPUT: |
330 | RETVAL |
330 | RETVAL |
331 | |
331 | |
|
|
332 | Event timed_io (SV *fh, short events, double timeout, SV *cb) |
|
|
333 | ALIAS: |
|
|
334 | timed_io_ns = 1 |
|
|
335 | CODE: |
|
|
336 | { |
|
|
337 | events = timeout ? events & ~EV_PERSIST : events | EV_PERSIST; |
|
|
338 | |
|
|
339 | RETVAL = e_new (fh, events, cb); |
|
|
340 | |
|
|
341 | if (timeout) |
|
|
342 | { |
|
|
343 | RETVAL->timeout = timeout; |
|
|
344 | RETVAL->interval = 1; |
|
|
345 | } |
|
|
346 | |
|
|
347 | if (!ix) e_start (RETVAL); |
|
|
348 | } |
|
|
349 | OUTPUT: |
|
|
350 | RETVAL |
|
|
351 | |
332 | Event timer (double after, int repeat, SV *cb) |
352 | Event timer (double after, int repeat, SV *cb) |
333 | ALIAS: |
353 | ALIAS: |
334 | timer_ns = 1 |
354 | timer_ns = 1 |
335 | CODE: |
355 | CODE: |
336 | RETVAL = e_new (NEWSV (0, 0), 0, cb); |
356 | RETVAL = e_new (NEWSV (0, 0), 0, cb); |
… | |
… | |
436 | OUTPUT: |
456 | OUTPUT: |
437 | RETVAL |
457 | RETVAL |
438 | |
458 | |
439 | SV *fh (Event ev, SV *new_fh = 0) |
459 | SV *fh (Event ev, SV *new_fh = 0) |
440 | ALIAS: |
460 | ALIAS: |
441 | signal = 0 |
461 | signal = 1 |
442 | CODE: |
462 | CODE: |
443 | RETVAL = newSVsv (ev->fh); |
463 | RETVAL = newSVsv (ev->fh); |
444 | if (items > 1) |
464 | if (items > 1) |
445 | { |
465 | { |
446 | if (ev->active) event_del (&ev->ev); |
466 | if (ev->active) event_del (&ev->ev); |
447 | sv_setsv (ev->fh, new_fh); |
467 | sv_setsv (ev->fh, new_fh); |
448 | ev->ev.ev_fd = sv_fileno (ev->fh); |
468 | ev->ev.ev_fd = sv_fileno (ev->fh); |
|
|
469 | ev->ev.ev_events = signal ? ev->ev.ev_events | EV_SIGNAL : ev->ev.ev_events & ~EV_SIGNAL; |
449 | if (ev->active) event_add (&ev->ev, e_tv (ev)); |
470 | if (ev->active) event_add (&ev->ev, e_tv (ev)); |
450 | } |
471 | } |
451 | OUTPUT: |
472 | OUTPUT: |
452 | RETVAL |
473 | RETVAL |
453 | |
474 | |