Home
last modified time | relevance | path

Searched refs:FRAMING_BUFFER (Results 1 – 7 of 7) sorted by relevance

/dports/www/p5-POE-Component-Client-HTTP/POE-Component-Client-HTTP-0.949/lib/POE/Filter/
H A DHTTPChunk.pm14 FRAMING_BUFFER => 0, constant
68 push (@{$self->[FRAMING_BUFFER]}, @$chunks);
77 while (defined (my $chunk = shift (@{$self->[FRAMING_BUFFER]}))) {
90 if (@{$self->[FRAMING_BUFFER]} == 0) {
92 unshift (@{$self->[FRAMING_BUFFER]}, $chunk);
96 $chunk .= shift (@{$self->[FRAMING_BUFFER]});
154 unshift (@{$self->[FRAMING_BUFFER]}, $chunk);
178 if (@{$self->[FRAMING_BUFFER]}) {
179 $self->[FRAMING_BUFFER]->[0] = $chunk . $self->[FRAMING_BUFFER]->[0];
181 unshift (@{$self->[FRAMING_BUFFER]}, $chunk);
[all …]
H A DHTTPHead.pm12 FRAMING_BUFFER => 0, constant
46 push (@{$self->[FRAMING_BUFFER]}, @$chunks);
54 LINE: while (@{$self->[FRAMING_BUFFER]}) {
55 my $line = shift @{$self->[FRAMING_BUFFER]};
124 CONTINUATION: while ($i < @{$self->[FRAMING_BUFFER]}) {
127 $i++, next CONTINUATION if $self->[FRAMING_BUFFER]->[$i] =~ /^\s+\S/;
136 splice(@{$self->[FRAMING_BUFFER]}, 0, $i)
161 unshift @{$self->[FRAMING_BUFFER]}, $line;
186 return $self->[FRAMING_BUFFER];
/dports/devel/p5-POE/POE-1.368/lib/POE/Filter/
H A DBlock.pm12 sub FRAMING_BUFFER () { 0 } subroutine
109 $self->[FRAMING_BUFFER] .= join '', @$stream;
111 if $self->[MAX_BUFFER] < length( $self->[FRAMING_BUFFER] );
125 my $block = substr($self->[FRAMING_BUFFER], 0, $self->[BLOCK_SIZE]);
126 substr($self->[FRAMING_BUFFER], 0, $self->[BLOCK_SIZE]) = '';
134 $self->[EXPECTED_SIZE] = $self->[DECODER]->(\$self->[FRAMING_BUFFER]);
140 return [ ] if length($self->[FRAMING_BUFFER]) < $self->[EXPECTED_SIZE];
144 my $block = substr($self->[FRAMING_BUFFER], 0, $self->[EXPECTED_SIZE]);
145 substr($self->[FRAMING_BUFFER], 0, $self->[EXPECTED_SIZE]) = '';
189 return undef unless length $self->[FRAMING_BUFFER];
[all …]
H A DLine.pm14 sub FRAMING_BUFFER () { 0 } subroutine
138 $self->[FRAMING_BUFFER] .= join '', @$stream;
140 if $self->[MAX_BUFFER] < length( $self->[FRAMING_BUFFER] );
155 unless $self->[FRAMING_BUFFER] =~ s/^(.*?)$self->[INPUT_REGEXP]//s;
167 unless $self->[FRAMING_BUFFER] =~ s/^(.*?)(\x0D\x0A?|\x0A\x0D?)//;
175 (length $self->[FRAMING_BUFFER])
199 return [ ] unless length $self->[FRAMING_BUFFER];
204 substr($self->[FRAMING_BUFFER], 0, 1) eq
212 $self->[INPUT_REGEXP] .= substr($self->[FRAMING_BUFFER], 0, 1);
213 substr($self->[FRAMING_BUFFER], 0, 1) = '';
[all …]
/dports/dns/p5-POE-Filter-DNS-TCP/POE-Filter-DNS-TCP-0.06/lib/POE/Filter/DNS/
H A DTCP.pm14 sub FRAMING_BUFFER () { 0 } subroutine
29 $self->[FRAMING_BUFFER] .= join '', @$stream;
38 $self->[EXPECTED_SIZE] = _decoder(\$self->[FRAMING_BUFFER])
41 return [ ] if length($self->[FRAMING_BUFFER]) < $self->[EXPECTED_SIZE];
45 my $block = substr($self->[FRAMING_BUFFER], 0, $self->[EXPECTED_SIZE]);
46 substr($self->[FRAMING_BUFFER], 0, $self->[EXPECTED_SIZE]) = '';
70 return $self->[FRAMING_BUFFER];
/dports/net/freeswitch/freeswitch-1.10.3.-release/scripts/perl/POE-Filter-FSSocket/lib/POE/Filter/
H A DFSSocket.pm114 sub FRAMING_BUFFER() {0} subroutine
162 $self->[FRAMING_BUFFER] .= join('', @{$stream});
177 if($self->[FRAMING_BUFFER] =~ s/^(.{$length})//s) {
186 if($self->[FRAMING_BUFFER] =~ s/^(.*?)(\x0D\x0A?|\x0A\x0D?)//) {
301 return $self->[FRAMING_BUFFER];
/dports/sysutils/p5-Tail-Stat/Tail-Stat-0.26/bin/
H A Dtstatd622 …$w->[2][ POE::Wheel::FollowTail::SELF_FILTER ][ POE::Filter::Line::FRAMING_BUFFER ] =~ s/[^\n]+\z//
623 if $w->[2][ POE::Wheel::FollowTail::SELF_FILTER ][ POE::Filter::Line::FRAMING_BUFFER ];