File Coverage

blib/lib/Hypersonic/Event/EventPorts.pm

Criterion	Covered	Total	%
statement	12	33	36.3
branch	1	2	50.0
condition			n/a
subroutine	5	18	27.7
pod	12	14	85.7
total	30	67	44.7

package Hypersonic::Event::EventPorts;

use strict;
use warnings;
use 5.010;

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

our $VERSION = '0.15';

sub name { 'event_ports' }

sub available {
    # Event ports are available on Solaris 10+ and illumos
    return 0 unless $^O eq 'solaris';

    # Check for port_create in libc
    return -f '/usr/include/port.h';
}

sub includes {
    return <<'C';
#include
#include
#include
C
}

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

sub event_struct { 'port_event_t' }

sub extra_cflags  { '' }
sub extra_ldflags { '' }  # Event ports are in libc on Solaris

# Create event port and associate listen socket
sub gen_create {
    my ($class, $builder, $listen_fd_var) = @_;

    $builder->comment('Event Ports backend - Solaris/illumos high-performance I/O')
      ->blank
      ->line('int ev_fd = port_create();')
      ->if('ev_fd < 0')
        ->line('croak("port_create() failed");')
      ->endif
      ->blank
      ->comment('Associate listen socket with port')
      ->if("port_associate(ev_fd, PORT_SOURCE_FD, $listen_fd_var, POLLIN, NULL) < 0")
        ->line('close(ev_fd);')
        ->line('croak("port_associate() failed for listen socket");')
      ->endif
      ->blank;
}

# Associate fd with event port
sub gen_add {
    my ($class, $builder, $loop_var, $fd_var) = @_;

    # Event ports require re-association after each event (one-shot)
    $builder->if("port_associate($loop_var, PORT_SOURCE_FD, $fd_var, POLLIN, (void*)(intptr_t)$fd_var) < 0")
      ->line('perror("port_associate");')
    ->endif;
}

# Dissociate fd from event port
sub gen_del {
    my ($class, $builder, $loop_var, $fd_var) = @_;

    $builder->line("port_dissociate($loop_var, PORT_SOURCE_FD, $fd_var);");
}

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

    $builder->line("static port_event_t $events_var" . "[MAX_EVENTS];")
      ->line('uint_t nget = 1;')  # Minimum events to wait for
      ->line('uint_t max_events = MAX_EVENTS;')
      ->blank
      ->line('struct timespec ts;')
      ->line("ts.tv_sec = $timeout_var / 1000;")
      ->line("ts.tv_nsec = ($timeout_var % 1000) * 1000000;")
      ->blank
      ->line("int result = port_getn($loop_var, $events_var, max_events, &nget, &ts);")
      ->if('result < 0')
        ->if('errno == EINTR || errno == ETIME')
          ->line('continue;')  # Timeout or interrupted - normal
        ->endif
        ->line('perror("port_getn");')
        ->line('break;')
      ->endif
      ->line("int $count_var = (int)nget;");
}

# Extract fd from event - note: must re-associate after each event
sub gen_get_fd {
    my ($class, $builder, $events_var, $index_var, $fd_var) = @_;

    $builder->line("port_event_t* pe = &${events_var}[$index_var];")
      ->line("int $fd_var = (int)pe->portev_object;")
      ->blank
      ->comment('Event ports are one-shot - must re-associate for more events')
      ->if("$fd_var != listen_fd")
        ->line("port_associate(ev_fd, PORT_SOURCE_FD, $fd_var, POLLIN, (void*)(intptr_t)$fd_var);")
      ->endif;
}

# Re-associate listen socket after accept
sub gen_rearm_listen {
    my ($class, $builder, $loop_var, $listen_fd_var) = @_;

    $builder->comment('Re-associate listen socket (event ports are one-shot)')
      ->line("port_associate($loop_var, PORT_SOURCE_FD, $listen_fd_var, POLLIN, NULL);");
}

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

    $builder->line("/* Add pool notify fd to event port */")
            ->if("port_associate($loop_var, PORT_SOURCE_FD, $notify_fd_var, POLLIN, (void*)(intptr_t)$notify_fd_var) < 0")
              ->line('perror("port_associate pool notify");')
            ->endif;
}

1;

__END__