File Coverage

blib/lib/Hypersonic/Event/Epoll.pm

Criterion	Covered	Total	%
statement	37	41	90.2
branch	3	4	75.0
condition			n/a
subroutine	20	22	90.9
pod	12	18	66.6
total	72	85	84.7

package Hypersonic::Event::Epoll;

use strict;
use warnings;
use 5.010;

use parent 'Hypersonic::Event::Role';

our $VERSION = '0.15';

sub name { 'epoll' }

sub available {
    return $^O eq 'linux';
}

sub includes {
    return '#include ';
}

sub defines {
    return <<'C';
#define EV_BACKEND_EPOLL 1
#ifndef MAX_EVENTS
#define MAX_EVENTS 1024
#endif
C
}

sub event_struct { 'epoll_event' }

sub extra_cflags  { '' }
sub extra_ldflags { '' }

# Generate: create epoll instance and add listen socket
sub gen_create {
    my ($class, $builder, $listen_fd_var) = @_;

    $builder->line('int ev_fd;')
      ->line('struct epoll_event ev;')
      ->blank
      ->line('ev_fd = epoll_create1(0);')
      ->if('ev_fd < 0')
        ->line('croak("epoll_create1() failed");')
      ->endif
      ->blank
      ->line('ev.events = EPOLLIN | EPOLLET;')
      ->line("ev.data.fd = $listen_fd_var;")
      ->if("epoll_ctl(ev_fd, EPOLL_CTL_ADD, $listen_fd_var, &ev) < 0")
        ->line('close(ev_fd);')
        ->line('croak("epoll_ctl() failed to add listen socket");')
      ->endif;
}

# Generate: add fd to epoll
sub gen_add {
    my ($class, $builder, $loop_var, $fd_var) = @_;

    $builder->line('ev.events = EPOLLIN | EPOLLET;')
      ->line("ev.data.fd = $fd_var;")
      ->line("epoll_ctl($loop_var, EPOLL_CTL_ADD, $fd_var, &ev);");
}

# Generate: remove fd from epoll
sub gen_del {
    my ($class, $builder, $loop_var, $fd_var) = @_;

    $builder->line("epoll_ctl($loop_var, EPOLL_CTL_DEL, $fd_var, NULL);");
}

# Generate: wait for events (inside a loop - can use continue/break)
sub gen_wait {
    my ($class, $builder, $loop_var, $events_var, $count_var, $timeout_var) = @_;

    $builder->line("int $count_var;")
      ->line("$count_var = epoll_wait($loop_var, $events_var, MAX_EVENTS, $timeout_var);")
      ->if("$count_var < 0")
        ->if('errno == EINTR')
          ->line('continue;')
        ->endif
        ->line('perror("epoll_wait");')
        ->line('break;')
      ->endif;
}

# Generate: wait for events - single call version (no loop control)
sub gen_wait_once {
    my ($class, $builder, $loop_var, $events_var, $count_var, $timeout_ms) = @_;

    $builder->line("$count_var = epoll_wait($loop_var, $events_var, MAX_EVENTS, $timeout_ms);")
      ->line("if ($count_var < 0 && errno == EINTR) $count_var = 0;");
}

# Generate: extract fd from event
sub gen_get_fd {
    my ($class, $builder, $events_var, $index_var, $fd_var) = @_;

    $builder->line("int $fd_var;")
      ->line("$fd_var = ${events_var}[$index_var].data.fd;");
}

# ============================================================
# Async Slot Integration Methods (UA Async)
# ============================================================

# Generate: create epoll without adding any fds
# Note: loop_var must be already declared
sub gen_create_loop {
    my ($class, $builder, $loop_var) = @_;

    $builder->line("$loop_var = epoll_create1(0);")
      ->if("$loop_var < 0")
        ->line('croak("epoll_create1() failed");')
      ->endif;
}

# Generate: add fd with slot as user data
# Note: epoll_event.data is a union - we use data.u32 for slot
sub gen_add_with_slot {
    my ($class, $builder, $loop_var, $fd_var, $slot_var, $events) = @_;

    my $ev_flags = $events eq 'read' ? 'EPOLLIN | EPOLLET | EPOLLONESHOT'
                 : $events eq 'write' ? 'EPOLLOUT | EPOLLET | EPOLLONESHOT'
                 : 'EPOLLIN | EPOLLET | EPOLLONESHOT';

    $builder->line('{')
      ->line('    struct epoll_event _ev;')
      ->line("    _ev.events = $ev_flags;")
      ->line("    _ev.data.u32 = (uint32_t)$slot_var;")
      ->line("    epoll_ctl($loop_var, EPOLL_CTL_ADD, $fd_var, &_ev);")
      ->line('}');
}

# Generate: extract slot from event data
sub gen_get_slot {
    my ($class, $builder, $events_var, $index_var, $slot_var) = @_;

    $builder->line("int $slot_var;")
      ->line("$slot_var = (int)${events_var}[$index_var].data.u32;");
}

# ============================================================
# Future/Pool Integration Methods
# ============================================================

# Future/Pool integration - add pool notify fd to epoll
sub gen_add_pool_notify {
    my ($class, $builder, $loop_var, $notify_fd_var) = @_;

    $builder->line("/* Add pool notify fd to epoll */")
            ->line('ev.events = EPOLLIN;')
            ->line("ev.data.fd = $notify_fd_var;")
            ->line("epoll_ctl($loop_var, EPOLL_CTL_ADD, $notify_fd_var, &ev);");
}

# Multi-pool integration - add all pool notify fds to epoll
sub gen_add_multi_pool_notify {
    my ($class, $builder, $loop_var, $pool_slots_var, $pool_count_var) = @_;

    $builder->line("/* Add all pool notify fds to epoll */")
            ->line("{ int _pi; int _pool_notify_fd;")
            ->line("for (_pi = 0; _pi < $pool_count_var; _pi++) {")
            ->line("    _pool_notify_fd = pool_get_notify_fd_slot($pool_slots_var\[_pi]);")
            ->line("    if (_pool_notify_fd >= 0) {")
            ->line("        ev.events = EPOLLIN;")
            ->line("        ev.data.fd = _pool_notify_fd;")
            ->line("        epoll_ctl($loop_var, EPOLL_CTL_ADD, _pool_notify_fd, &ev);")
            ->line("    }")
            ->line("} }");
}

1;

__END__