[svn:dbi] r8783 - in dbi/trunk/lib: DBD/Gofer/Transport DBI/Gofer/Transport

[timbo]

Author: timbo
Date: Thu Feb  1 16:30:23 2007
New Revision: 8783

Added:
   dbi/trunk/lib/DBD/Gofer/Transport/stream.pm
      - copied, changed from r8782, 
/dbi/trunk/lib/DBD/Gofer/Transport/pipestream.pm
   dbi/trunk/lib/DBI/Gofer/Transport/stream.pm
      - copied, changed from r8782, 
/dbi/trunk/lib/DBI/Gofer/Transport/pipestream.pm
Removed:
   dbi/trunk/lib/DBD/Gofer/Transport/pipestream.pm
   dbi/trunk/lib/DBI/Gofer/Transport/pipestream.pm

Log:
Rename pipestream to stream.


Copied: dbi/trunk/lib/DBD/Gofer/Transport/stream.pm (from r8782, 
/dbi/trunk/lib/DBD/Gofer/Transport/pipestream.pm)
==============================================================================
--- /dbi/trunk/lib/DBD/Gofer/Transport/pipestream.pm    (original)
+++ dbi/trunk/lib/DBD/Gofer/Transport/stream.pm Thu Feb  1 16:30:23 2007
@@ -1,4 +1,4 @@
-package DBD::Gofer::Transport::pipestream;
+package DBD::Gofer::Transport::stream;
 
 #   $Id: pipeone.pm 8748 2007-01-29 22:49:42Z timbo $
 #
@@ -31,13 +31,13 @@
 
         my $connection = $self->connection_info;
         if (not $connection || ($connection->{pid} && not kill 0, 
$connection->{pid})) {
-            my $cmd = [qw(perl -MDBI::Gofer::Transport::pipestream -e 
run_stdio_hex)];
-            #push @$cmd, "DBI_TRACE=2=/tmp/pipestream.log", "sh", "-c";
+            my $cmd = [qw(perl -MDBI::Gofer::Transport::stream -e 
run_stdio_hex)];
+            #push @$cmd, "DBI_TRACE=2=/tmp/goferstream.log", "sh", "-c";
             if (0) {
                 my $ssh = '[EMAIL PROTECTED]';
                 unshift @$cmd, 'ssh', '-q', split(' ', $ssh);
             }
-            # XXX add a handshake - some message from 
DBI::Gofer::Transport::pipestream that's
+            # XXX add a handshake - some message from 
DBI::Gofer::Transport::stream that's
             # sent as soon as it starts that we can wait for to report success 
- and soak up
             # and useful warnings etc from shh before we get it.
             $connection = $self->start_pipe_command($cmd);
@@ -96,7 +96,7 @@
         return DBI::Gofer::Response->new({ err => 1, errstr => $msg }); 
     }
     #warn DBI::neat($frozen_response);
-    warn "pipestream stderr message: $stderr_msg\n" if $stderr_msg && 
$self->trace;
+    warn "Gofer stream stderr message: $stderr_msg\n" if $stderr_msg && 
$self->trace;
 
     # XXX need to be able to detect and deal with corruption
     $response = $self->thaw_data(pack("H*",$frozen_response));

Copied: dbi/trunk/lib/DBI/Gofer/Transport/stream.pm (from r8782, 
/dbi/trunk/lib/DBI/Gofer/Transport/pipestream.pm)
==============================================================================
--- /dbi/trunk/lib/DBI/Gofer/Transport/pipestream.pm    (original)
+++ dbi/trunk/lib/DBI/Gofer/Transport/stream.pm Thu Feb  1 16:30:23 2007
@@ -1,6 +1,6 @@
-package DBI::Gofer::Transport::pipestream;
+package DBI::Gofer::Transport::stream;
 
-#   $Id: pipestream.pm 8748 2007-01-29 22:49:42Z timbo $
+#   $Id: stream.pm 8748 2007-01-29 22:49:42Z timbo $
 #
 #   Copyright (c) 2007, Tim Bunce, Ireland
 #
@@ -21,7 +21,7 @@
 
 sub run_stdio_hex {
 
-    my $self = DBI::Gofer::Transport::pipestream->new();
+    my $self = DBI::Gofer::Transport::stream->new();
     local $| = 1;
 
     #warn "STARTED $$";