Geforce File Manager

NAME	SIZE	ACTIONS
📄 Formatter.t	1,677 B	[ EDIT ] \| [ DEL ]
📄 Subtest_buffer_formatter.t	2,680 B	[ EDIT ] \| [ DEL ]
📄 Subtest_callback.t	906 B	[ EDIT ] \| [ DEL ]
📄 Subtest_events.t	441 B	[ EDIT ] \| [ DEL ]
📄 Subtest_plan.t	355 B	[ EDIT ] \| [ DEL ]
📄 Subtest_todo.t	932 B	[ EDIT ] \| [ DEL ]
📄 Taint.t	356 B	[ EDIT ] \| [ DEL ]
📄 disable_ipc_a.t	203 B	[ EDIT ] \| [ DEL ]
📄 disable_ipc_b.t	219 B	[ EDIT ] \| [ DEL ]
📄 disable_ipc_c.t	256 B	[ EDIT ] \| [ DEL ]
📄 disable_ipc_d.t	458 B	[ EDIT ] \| [ DEL ]
📄 err_var.t	177 B	[ EDIT ] \| [ DEL ]
📄 init_croak.t	589 B	[ EDIT ] \| [ DEL ]
📄 intercept.t	1,117 B	[ EDIT ] \| [ DEL ]
📄 ipc_wait_timeout.t	2,351 B	[ EDIT ] \| [ DEL ]
📄 nested_context_exception.t	2,139 B	[ EDIT ] \| [ DEL ]
📄 no_load_api.t	1,561 B	[ EDIT ] \| [ DEL ]
📄 run_subtest_inherit.t	2,264 B	[ EDIT ] \| [ DEL ]
📄 special_names.t	1,314 B	[ EDIT ] \| [ DEL ]
📄 subtest_bailout.t	1,182 B	[ EDIT ] \| [ DEL ]
📄 trace_signature.t	1,507 B	[ EDIT ] \| [ DEL ]
📄 uuid.t	3,414 B	[ EDIT ] \| [ DEL ]

[ CLOSE ]

EDIT: ipc_wait_timeout.t

use strict;
use warnings;

# The things done in this test can trigger a buggy return value on some
# platforms. This prevents that. The harness should catch actual failures. If
# no harness is active then we will NOT sanitize the exit value, false fails
# are better than false passes.
END { $? = 0 if $ENV{HARNESS_ACTIVE} }

# Some platforms throw a sigpipe in this test, we can ignore it.
BEGIN { $SIG{PIPE} = 'IGNORE' }

BEGIN { local ($@, $?, $!); eval { require threads } }
use Test2::Tools::Tiny;
use Test2::Util qw/CAN_THREAD CAN_REALLY_FORK/;
use Test2::IPC;
use Test2::API qw/test2_ipc_set_timeout test2_ipc_get_timeout/;

my $plan = 2;
$plan += 2 if CAN_REALLY_FORK;
$plan += 2 if CAN_THREAD && threads->can('is_joinable');
plan $plan;

is(test2_ipc_get_timeout(), 30, "got default timeout");
test2_ipc_set_timeout(10);
is(test2_ipc_get_timeout(), 10, "hanged the timeout");

if (CAN_REALLY_FORK) {
    note "Testing process waiting";
    my ($ppiper, $ppipew);
    pipe($ppiper, $ppipew) or die "Could not create pipe for fork";

my $proc = fork();
    die "Could not fork!" unless defined $proc;

unless ($proc) {
        local $SIG{ALRM} = sub { die "PROCESS TIMEOUT" };
        alarm 15;
        my $ignore = <$ppiper>;
        exit 0;
    }

my $exit;
    my $warnings = warnings {
        $exit = Test2::API::Instance::_ipc_wait(1);
    };
    is($exit, 255, "Exited 255");
    like($warnings->[0], qr/Timeout waiting on child processes/, "Warned about timeout");
    print $ppipew "end\n";

close($ppiper);
    close($ppipew);
}

if (CAN_THREAD) {
    note "Testing thread waiting";
    my ($tpiper, $tpipew);
    pipe($tpiper, $tpipew) or die "Could not create pipe for threads";

my $thread = threads->create(
        sub {
            local $SIG{ALRM} = sub { die "THREAD TIMEOUT" };
            alarm 15;
            my $ignore = <$tpiper>;
        }
    );

if ($thread->can('is_joinable')) {
        my $exit;
        my $warnings = warnings {
            $exit = Test2::API::Instance::_ipc_wait(1);
        };
        is($exit, 255, "Exited 255");
        like($warnings->[0], qr/Timeout waiting on child thread/, "Warned about timeout");
    }
    else {
        note "threads.pm is too old for a thread joining timeout :-(";
    }
    print $tpipew "end\n";

close($tpiper);
    close($tpipew);
}