File Coverage

lib/IOMux/File/Write.pm

Criterion	Covered	Total	%
statement	43	46	93.4
branch	13	20	65.0
condition	4	8	50.0
subroutine	9	10	90.0
pod	2	3	66.6
total	71	87	81.6

# Copyrights 2011-2020 by [Mark Overmeer ].
#  For other contributors see ChangeLog.
# See the manual pages for details on the licensing terms.
# Pod stripped from pm file by OODoc 2.02.
# This code is part of distribution IOMux.  Meta-POD processed with OODoc
# into POD and HTML manual-pages.  See README.md
# Copyright Mark Overmeer.  Licensed under the same terms as Perl itself.

package IOMux::File::Write;
use vars '$VERSION';
$VERSION = '1.01';

use base 'IOMux::Handler::Write';

use warnings;
use strict;

use Log::Report    'iomux';
use Fcntl;
use File::Basename 'basename';


sub init($)
{   my ($self, $args) = @_;

    my $file  = $args->{file}
        or error __x"no file to open specified in {pkg}", pkg => __PACKAGE__;

    my $flags = $args->{modeflags};
    my $mode  = $args->{mode} || '>';
    unless(ref $file || defined $flags)
    {      if($mode eq '>>') { $args->{append} = 1 }
        elsif($mode eq '>')  { $mode = '>>' if $args->{append} }
        else
        {   error __x"unknown file mode '{mode}' for {fn} in {pkg}"
              , mode => $mode, fn => $file, pkg => __PACKAGE__;
        }

        $flags  = O_WRONLY|O_NONBLOCK;
        $flags |= O_CREAT  unless exists $args->{create} && !$args->{create};
        $flags |= O_APPEND if $args->{append};
        $flags |= O_EXCL   if $args->{exclusive};
    }

    my $fh;
    if(ref $file)
    {   $fh = $file;
    }
    else
    {   sysopen $fh, $file, $flags
            or fault __x"cannot open file {fn} for {pkg}"
               , fn => $file, pkg => __PACKAGE__;
        $self->{IMFW_mode} = $flags;
    }
    $args->{name} = $mode.(basename $file);
    $args->{fh}   = $fh;

    $self->SUPER::init($args);
    $self;
}


sub open($$@)
{   my ($class, $mode, $file, %args) = @_;
    $class->new(file => $file, mode => $mode, %args);
}


#-------------------

sub mode() {shift->{IMFW_mode}}

1;