X-Git-Url: http://www.dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXCommandmode.pm;h=84d809fd257e730e30ed388dd324be25e3d93665;hb=099c6b4a10d9f1e7471b0c94273cd992b5814cdc;hp=8af394b8898d4852b6e9ca0656a3a1c5014e3313;hpb=b060a0a3ee72530aa3f10d453186a662b66d7efe;p=spider.git

diff --git a/perl/DXCommandmode.pm b/perl/DXCommandmode.pm
index 8af394b8..84d809fd 100644
--- a/perl/DXCommandmode.pm
+++ b/perl/DXCommandmode.pm
@@ -18,6 +18,7 @@ use DXVars;
 use DXDebug;
 use DXM;
 use DXLog;
+use DXLogPrint;
 use CmdAlias;
 use FileHandle;
 use Carp;
@@ -51,14 +52,14 @@ sub start
   my $user = $self->{user};
   my $call = $self->{call};
   my $name = $user->{name};
-
+  
   $self->{name} = $name ? $name : $call;
   $self->send($self->msg('l2',$self->{name}));
   $self->send_file($main::motd) if (-e $main::motd);
-  $self->send($self->msg('pr', $call));
   $self->state('prompt');                  # a bit of room for further expansion, passwords etc
   $self->{priv} = $user->priv;
   $self->{lang} = $user->lang;
+  $self->{pagelth} = 20;
   $self->{priv} = 0 if $line =~ /^(ax|te)/;     # set the connection priv to 0 - can be upgraded later
   $self->{consort} = $line;                # save the connection type
 
@@ -76,6 +77,11 @@ sub start
   my @pc16 = DXProt::pc16($nchan, $cuser);
   DXProt::broadcast_ak1a(@pc16);
   Log('DXCommand', "$call connected");
+
+  # send prompts and things
+  my $info = DXCluster::cluster();
+  $self->send("Cluster:$info");
+  $self->send($self->msg('pr', $call));
 }
 
 #
@@ -86,9 +92,56 @@ sub normal
 {
 	my $self = shift;
 	my $cmdline = shift;
+	my @ans;
 	
-	my @ans = run_cmd($self, $cmdline);
-	$self->send(@ans) if @ans > 0;
+	# remove leading and trailing spaces
+	$cmdline =~ s/^\s*(.*)\s*$/$1/;
+	
+	if ($self->{state} eq 'prompt') {
+		@ans = run_cmd($self, $cmdline) if length $cmdline;
+       
+		if ($self->{pagelth} && @ans > $self->{pagelth}) {
+			my $i;
+			for ($i = $self->{pagelth}; $i-- > 0; ) {
+				my $line = shift @ans;
+				$line =~ s/\s+$//o;            # why am having to do this? 
+				$self->send($line);
+			}
+			$self->{pagedata} =  \@ans;
+			$self->state('page');
+			$self->send($self->msg('page', scalar @ans));
+		} else {
+			for (@ans) {
+				s/\s+$//o;                     # why ?????????
+				$self->send($_);
+			}
+		} 
+	} elsif ($self->{state} eq 'page') {
+		my $i = $self->{pagelth};
+		my $ref = $self->{pagedata};
+		my $tot = @$ref;
+		
+		# abort if we get a line starting in with a
+		if ($cmdline =~ /^a/io) {
+			undef $ref;
+			$i = 0;
+		}
+        
+		# send a tranche of data
+		while ($i-- > 0 && @$ref) {
+			my $line = shift @$ref;
+			$line =~ s/\s+$//o;            # why am having to do this? 
+			$self->send($line);
+		}
+
+		# reset state if none or else chuck out an intermediate prompt
+		if ($ref && @$ref) {
+			$tot -= $self->{pagelth};
+			$self->send($self->msg('page', $tot));
+		} else {
+			$self->state('prompt');
+		}
+	}
 	
 	# send a prompt only if we are in a prompt state
 	$self->prompt() if $self->{state} =~ /^prompt/o;
@@ -118,10 +171,10 @@ sub run_cmd
   } else {
 
     # special case only \n input => " "
-    if ($cmdline eq " ") {
-	  $self->prompt();
-	  return;
-	}
+#    if ($cmdline eq " ") {
+#	  $self->prompt();
+#	  return;
+#	}
 	
     # strip out //
     $cmdline =~ s|//|/|og;
@@ -167,7 +220,7 @@ sub run_cmd
 		@ans = $self->msg('e1');
 	}
   }
-  return @ans;
+  return (@ans);
 }
 
 #