File Coverage

blib/lib/Hypersonic/Event/Poll.pm

Criterion	Covered	Total	%
statement	28	30	93.3
branch			n/a
condition			n/a
subroutine	16	17	94.1
pod	12	13	92.3
total	56	60	93.3

package Hypersonic::Event::Poll;

use strict;
use warnings;
use 5.010;

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

our $VERSION = '0.15';

sub name { 'poll' }

sub available {
    # poll() is POSIX - available on all Unix systems
    # Not available on Windows (use select instead)
    return $^O ne 'MSWin32';
}

sub includes {
    return '#include ';
}

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

sub event_struct { 'pollfd' }

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

# poll() needs additional state tracking
sub gen_create {
    my ($class, $builder, $listen_fd_var) = @_;

    $builder->comment('poll() backend - allocate pollfd array')
      ->line('static struct pollfd poll_fds[MAX_POLL_FDS];')
      ->line('static int poll_nfds = 0;')
      ->blank
      ->line("poll_fds[0].fd = $listen_fd_var;")
      ->line('poll_fds[0].events = POLLIN;')
      ->line('poll_nfds = 1;')
      ->line('int ev_fd = 0;')  # Dummy - poll doesn't use event fd
      ->blank;
}

# Add fd to poll array
sub gen_add {
    my ($class, $builder, $loop_var, $fd_var) = @_;

    $builder->if('poll_nfds < MAX_POLL_FDS')
      ->line("poll_fds[poll_nfds].fd = $fd_var;")
      ->line('poll_fds[poll_nfds].events = POLLIN;')
      ->line('poll_nfds++;')
    ->endif;
}

# Remove fd from poll array (compact)
sub gen_del {
    my ($class, $builder, $loop_var, $fd_var) = @_;

    $builder->comment('Find and remove fd from poll array')
      ->line('{ int j;')
      ->line('for (j = 0; j < poll_nfds; j++) {')
      ->line("    if (poll_fds[j].fd == $fd_var) {")
      ->line('        poll_fds[j] = poll_fds[poll_nfds - 1];')
      ->line('        poll_nfds--;')
      ->line('        break;')
      ->line('    }')
      ->line('} }');
}

# Wait using poll()
sub gen_wait {
    my ($class, $builder, $loop_var, $events_var, $count_var, $timeout_var) = @_;

    # poll() modifies the array in-place, doesn't need separate events array
    $builder->line("int poll_result = poll(poll_fds, poll_nfds, $timeout_var);")
      ->if('poll_result < 0')
        ->if('errno == EINTR')
          ->line('continue;')
        ->endif
        ->line('perror("poll");')
        ->line('break;')
      ->endif
      ->line("int $count_var = poll_nfds;")  # We check all fds
      ->line("(void)$events_var;");  # Unused - we use poll_fds directly
}

# poll() iteration is different - check revents
sub gen_get_fd {
    my ($class, $builder, $events_var, $index_var, $fd_var) = @_;

    $builder->comment('Check if this fd has events')
      ->if("!(poll_fds[$index_var].revents & POLLIN)")
        ->line('continue;')  # Skip fds without events
      ->endif
      ->line("int $fd_var = poll_fds[$index_var].fd;");
}

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

    $builder->line("/* Add pool notify fd to poll array */")
            ->if('poll_nfds < MAX_POLL_FDS')
              ->line("poll_fds[poll_nfds].fd = $notify_fd_var;")
              ->line('poll_fds[poll_nfds].events = POLLIN;')
              ->line('poll_nfds++;')
            ->endif;
}

1;

__END__