summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--Spline/Netstring.pm42
-rw-r--r--Spline/Socketmap.pm34
-rw-r--r--Spline/Srs.pm1
3 files changed, 33 insertions, 44 deletions
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( );