From 96f2d50d9a6b211562535f741d5c20810900b177 Mon Sep 17 00:00:00 2001 From: Alexander Sulfrian Date: Fri, 17 Jun 2016 21:17:59 +0200 Subject: Spline::Netstring: Remove extra module The netstring methods are now part of Spline::Socketmap --- Spline/Netstring.pm | 42 ------------------------------------------ Spline/Socketmap.pm | 34 +++++++++++++++++++++++++++++++++- Spline/Srs.pm | 1 - 3 files changed, 33 insertions(+), 44 deletions(-) delete mode 100644 Spline/Netstring.pm diff --git a/Spline/Netstring.pm b/Spline/Netstring.pm deleted file mode 100644 index e7e649f..0000000 --- a/Spline/Netstring.pm +++ /dev/null @@ -1,42 +0,0 @@ -package Spline::Netstring; - -use strict; -use warnings; - -our @EXPORT = qw( - netstring_read - netstring_write -); - -sub read_length($) { - my $fd = shift; - my $length; - - local $/ = ':'; - $length = <$fd>; - die "Cannot read netstring length" unless defined($length); - chomp $length; - - return $length; -} - -sub netstring_read($) { - my $fd = shift; - my ($length, $data); - - $length = read_length($fd); - if (read($fd, $data, $length) == $length) { - (getc() eq ',') or die "Closing , missing"; - } - else { - die 'Received only ' . length($data) . " of $length bytes"; - } - - return $data; -} - -sub netstring_write($$) { - my ($fd, $data) = @_; - - print $fd length($data).':'.$data.','; -} diff --git a/Spline/Socketmap.pm b/Spline/Socketmap.pm index df1a6a9..f78ed3f 100644 --- a/Spline/Socketmap.pm +++ b/Spline/Socketmap.pm @@ -4,7 +4,6 @@ use strict; use warnings; use base qw(Net::Server::PreFork); -use Spline::Netstring; use Spline::Srs qw( srs_forward srs_reverse ); use base 'Exporter'; @@ -32,6 +31,39 @@ sub handle_request($) { } } +sub netstring_read_length($) { + my $fd = shift; + my $length; + + local $/ = ':'; + $length = <$fd>; + die "Cannot read netstring length" unless defined($length); + chomp $length; + + return $length; +} + +sub netstring_read($) { + my $fd = shift; + my ($length, $data); + + $length = netstring_read_length($fd); + if (read($fd, $data, $length) == $length) { + (getc() eq ',') or die "Closing , missing"; + } + else { + die 'Received only ' . length($data) . " of $length bytes"; + } + + return $data; +} + +sub netstring_write($$) { + my ($fd, $data) = @_; + + print $fd length($data).':'.$data.','; +} + sub process_request { my $self = shift; diff --git a/Spline/Srs.pm b/Spline/Srs.pm index 8acb188..e799245 100644 --- a/Spline/Srs.pm +++ b/Spline/Srs.pm @@ -4,7 +4,6 @@ use strict; use warnings; use Mail::SRS; -use Spline::Netstring; use base 'Exporter'; our @EXPORT = qw( ); -- cgit v1.2.3-1-g7c22