… | |
… | |
69 | |
69 | |
70 | package Net::FCP; |
70 | package Net::FCP; |
71 | |
71 | |
72 | use Carp; |
72 | use Carp; |
73 | |
73 | |
74 | $VERSION = 0.07; |
74 | $VERSION = 0.08; |
75 | |
75 | |
76 | no warnings; |
76 | no warnings; |
77 | |
77 | |
78 | our $EVENT = Net::FCP::Event::Auto::; |
78 | our $EVENT = Net::FCP::Event::Auto::; |
79 | $EVENT = Net::FCP::Event::Event;#d# |
79 | $EVENT = Net::FCP::Event::Event;#d# |
… | |
… | |
773 | sub rcv_data { |
773 | sub rcv_data { |
774 | my ($self, $chunk) = @_; |
774 | my ($self, $chunk) = @_; |
775 | |
775 | |
776 | $self->{data} .= $chunk; |
776 | $self->{data} .= $chunk; |
777 | |
777 | |
778 | $self->progress ("data", { chunk => length $chunk, total => length $self->{data}, end => $self->{datalength} }); |
778 | $self->progress ("data", { chunk => length $chunk, received => length $self->{data}, total => $self->{datalength} }); |
779 | |
779 | |
780 | if ($self->{datalength} == length $self->{data}) { |
780 | if ($self->{datalength} == length $self->{data}) { |
781 | my $data = delete $self->{data}; |
781 | my $data = delete $self->{data}; |
782 | my $meta = Net::FCP::parse_metadata substr $data, 0, $self->{metalength}, ""; |
782 | my $meta = Net::FCP::parse_metadata substr $data, 0, $self->{metalength}, ""; |
783 | |
783 | |