… | |
… | |
1016 | my $write = sub { |
1016 | my $write = sub { |
1017 | # we write as many messages as have been queued |
1017 | # we write as many messages as have been queued |
1018 | my $data = join "", @queue; |
1018 | my $data = join "", @queue; |
1019 | @queue = (); |
1019 | @queue = (); |
1020 | |
1020 | |
1021 | AnyEvent::IO::ae_write $fh, $data, sub { |
1021 | AnyEvent::IO::io_write $fh, $data, sub { |
1022 | $disable = 1; |
1022 | $disable = 1; |
1023 | @_ |
1023 | @_ |
1024 | ? ($_[0] == length $data or AE::log 4 => "unable to write to logfile '$path': short write") |
1024 | ? ($_[0] == length $data or AE::log 4 => "unable to write to logfile '$path': short write") |
1025 | : AE::log 4 => "unable to write to logfile '$path': $!"; |
1025 | : AE::log 4 => "unable to write to logfile '$path': $!"; |
1026 | undef $disable; |
1026 | undef $disable; |
1027 | |
1027 | |
1028 | if ($keepopen) { |
1028 | if ($keepopen) { |
1029 | $kick->($kick); |
1029 | $kick->($kick); |
1030 | } else { |
1030 | } else { |
1031 | AnyEvent::IO::ae_close ($fh, sub { |
1031 | AnyEvent::IO::io_close ($fh, sub { |
1032 | undef $fh; |
1032 | undef $fh; |
1033 | $kick->($kick); |
1033 | $kick->($kick); |
1034 | }); |
1034 | }); |
1035 | } |
1035 | } |
1036 | }; |
1036 | }; |
1037 | }; |
1037 | }; |
1038 | |
1038 | |
1039 | if ($fh) { |
1039 | if ($fh) { |
1040 | $write->(); |
1040 | $write->(); |
1041 | } else { |
1041 | } else { |
1042 | AnyEvent::IO::ae_open |
1042 | AnyEvent::IO::io_open |
1043 | $path, |
1043 | $path, |
1044 | AnyEvent::IO::O_CREAT | AnyEvent::IO::O_WRONLY | AnyEvent::IO::O_APPEND, |
1044 | AnyEvent::IO::O_CREAT | AnyEvent::IO::O_WRONLY | AnyEvent::IO::O_APPEND, |
1045 | 0666, |
1045 | 0666, |
1046 | sub { |
1046 | sub { |
1047 | $fh = shift |
1047 | $fh = shift |