File Coverage

blib/lib/Hypersonic/Event/Select.pm

Criterion	Covered	Total	%
statement	31	38	81.5
branch	3	8	37.5
condition			n/a
subroutine	16	18	88.8
pod	13	14	92.8
total	63	78	80.7

package Hypersonic::Event::Select;

use strict;
use warnings;
use 5.010;

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

our $VERSION = '0.15';

sub name { 'select' }

sub available { 1 }  # Always available - most portable

sub includes {
    my $class = shift;
    if ($^O eq 'MSWin32') {
        return <<'C';
#include
#include
#pragma comment(lib, "ws2_32.lib")
C
    }
    return '#include ';
}

sub defines {
    return <<'C';
#define EV_BACKEND_SELECT 1

/* Increase FD_SETSIZE before including headers on some systems */
#ifndef FD_SETSIZE
#define FD_SETSIZE 1024
#endif

#ifndef MAX_EVENTS
#define MAX_EVENTS FD_SETSIZE
#endif
C
}

sub event_struct { 'fd_set' }  # Not really used as array

sub extra_cflags  { '' }
sub extra_ldflags { $^O eq 'MSWin32' ? '-lws2_32' : '' }

# select() needs to track all fds and rebuild fd_sets each iteration
sub gen_create {
    my ($class, $builder, $listen_fd_var) = @_;

    $builder->comment('select() backend - most portable, lowest performance')
      ->line('fd_set master_read_fds;')
      ->line('FD_ZERO(&master_read_fds);')
      ->line("FD_SET($listen_fd_var, &master_read_fds);")
      ->line("int max_fd = $listen_fd_var;")
      ->line('int ev_fd = 0;')  # Dummy - select doesn't use event fd
      ->blank;

    # Windows requires WSAStartup
    if ($^O eq 'MSWin32') {
        # gen_create is inlined into the void XS hypersonic_run_event_loop;
        # use croak instead of `return -1;` which trips GCC 14+
        # -Wreturn-mismatch (now an error).
        $builder->line('WSADATA wsa_data;')
          ->if('WSAStartup(MAKEWORD(2,2), &wsa_data) != 0')
            ->line('croak("WSAStartup failed");')
          ->endif;
    }
}

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

    $builder->line("FD_SET($fd_var, &master_read_fds);")
      ->if("$fd_var > max_fd")
        ->line("max_fd = $fd_var;")
      ->endif;
}

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

    $builder->line("FD_CLR($fd_var, &master_read_fds);")
      ->comment('Note: max_fd not updated (would need to scan)');
}

# Wait using select() - must copy fd_set each time
sub gen_wait {
    my ($class, $builder, $loop_var, $events_var, $count_var, $timeout_var) = @_;

    $builder->comment('Copy master set - select() modifies it')
      ->line('fd_set read_fds = master_read_fds;')
      ->blank
      ->line('struct timeval tv;')
      ->line("tv.tv_sec = $timeout_var / 1000;")
      ->line("tv.tv_usec = ($timeout_var % 1000) * 1000;")
      ->blank
      ->line('int select_result = select(max_fd + 1, &read_fds, NULL, NULL, &tv);')
      ->if('select_result < 0')
        ->if('errno == EINTR')
          ->line('continue;')
        ->endif
        ->line('perror("select");')
        ->line('break;')
      ->endif
      ->if('select_result == 0')
        ->line('continue;')  # Timeout
      ->endif
      ->blank
      ->comment('Store read_fds pointer for iteration')
      ->line("fd_set* $events_var = &read_fds;")
      ->line("int $count_var = max_fd + 1;");  # We check all fds up to max
}

# select() iteration is different - check each fd with FD_ISSET
sub gen_get_fd {
    my ($class, $builder, $events_var, $index_var, $fd_var) = @_;

    $builder->line("int $fd_var = $index_var;")  # fd IS the index for select
      ->if("!FD_ISSET($fd_var, $events_var)")
        ->line('continue;')  # Skip fds without events
      ->endif;
}

# Windows cleanup
sub gen_cleanup {
    my ($class, $builder) = @_;
    if ($^O eq 'MSWin32') {
        $builder->line('WSACleanup();');
    }
}

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

    $builder->line("/* Add pool notify fd to select master set */")
            ->line("FD_SET($notify_fd_var, &master_read_fds);")
            ->if("$notify_fd_var > max_fd")
              ->line("max_fd = $notify_fd_var;")
            ->endif;
}

1;

__END__