Changeset 16218 for misc/runpugs/bin

Timestamp:

05/07/07 16:26:38 (19 months ago)

Author:

andara

Message:

[runpugs]
- Session.pm: now with Moose
- Session startup handling now more robust
- Repl.pm: a very simple mini-REPL for testing

Location:

misc/runpugs/bin

Files:

• multi_client_model.pl (modified) (4 diffs)
• perl_repl.pl (added)
• termdispatcher.pl (modified) (1 diff)
• termserv.pl (modified) (1 diff)
• test_session.pl (added)
• test_session_dispatcher.pl (added)

misc/runpugs/bin/multi_client_model.pl

@@ -6 +6 @@
 use strict;
 
-use threads;           # pull in threading routines
+#use threads;           # pull in threading routines
 
 use lib '../lib/';
@@ -19 +19 @@
 our $nclients_serial=500;
 
+#for my $i (0..$n_threads-1) {
+#       $threads[$i]=threads->create("client_session",$i);
+#}
+
+# program exits when first thread exits
+my $pid;
 for my $i (0..$n_threads-1) {
-        $threads[$i]=threads->create("client_session",$i);
-}
-
-# program exits when first thread exits
-$threads[0]->join(); 
+        if($pid=fork()) {
+                print "Spawned $i\n"; 
+        } elsif (defined $pid) { # Child
+                        print "Running $i\n";
+                        &client_session($i);
+                        exit(0);
+                } else {
+                        die "Fork failed!";
+                }
+}
+print "Parent: done creating clients.";
+sleep 3600;
+#$threads[0]->join(); 
 
 
@@ -108 +122 @@
 print "$i:WARNING2: $cmd<>$reply\n";# if $v;
 #if ($reply eq '0') {
-system("./killall_perl");
+#system("./killall_perl");
+kill 9,getppid();
 exit() ;
 #}
@@ -118 +133 @@
 } elsif ($abort) {
 &send_cmd(':A',$id,$ip,$app);
-} #�therwise do nothing, server should time the session out
+} #�otherwise do nothing, server should time the session out
 my $w_log= rand($w_max_log)+$w_min_log;
 my $wait=int(2**$w_log);
 print "\n$i:Waiting for $wait seconds...\n" if $v;
 sleep $wait; 
-} #�nd of nclients_serial loop
+} #�end of nclients_serial loop
 
 }

misc/runpugs/bin/termdispatcher.pl

@@ -6 +6 @@
 #
 use lib '../lib/';
-use WebTerminal::Dispatcher;
+use Web::Terminal::Settings;
+use Web::Terminal::Dispatcher;
+#$Web::Terminal::Settings::port=2058;
 
 
 my $id=$ARGV[0]||-1;
-my $cmd=$ARGV[1] || 'my $a='.$id.';say "Hello, $a";';
-#my $cmd='my $a='.$id.';say "Hello, $a";';
-my $prompt='pugs> ';
+my $cmd=$ARGV[1] || 'print "hello\n";say "there";print 4';
 print "Sending msg $id: $cmd\n";
 my $ip="127.0.0.1";
-my $dev=1;
-my $reply = &WebTerminal::Dispatcher::send($id,$ip,$dev,$prompt.$cmd);
+(my $reply,my $prompt,my $histref) =
+&Web::Terminal::Dispatcher::send($id,$ip,1,1,$cmd);
 print $reply;
+print "\nHistory\n";
+for my $entry (@{$histref}) {
+print "\t$entry\n";
+}
 

misc/runpugs/bin/termserv.pl

@@ -1 +1 @@
 #!/usr/bin/perl
+use strict;
+use warnings;
+#BEGIN {
+#$ENV{PERLIO}= ":utf8";
+#}
+#use utf8;
+
 use warnings;
 use strict;
-use utf8;
+
 use lib '../lib/';
-use WebTerminal::Server;
-my $host = 'localhost';
-my $port = 2057;
+use Web::Terminal::Server;
+use  Web::Terminal::Settings;
+$Web::Terminal::Settings::port=2059;
 $ENV{PUGS_SAFEMODE}=1;
-&WebTerminal::Server::run($host,$port);
+my $v=1-$Web::Terminal::Settings::daemon;
+print "Starting server\n" if $v;
+&Web::Terminal::Server::run();