/[cwmp]/google/trunk/bin/cpe-queue.pl
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /google/trunk/bin/cpe-queue.pl

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 197 by dpavlin, Mon Nov 12 22:03:01 2007 UTC revision 199 by dpavlin, Wed Nov 14 18:16:14 2007 UTC
# Line 9  use strict; Line 9  use strict;
9  use lib './lib';  use lib './lib';
10  use CWMP::Queue;  use CWMP::Queue;
11  use Getopt::Long;  use Getopt::Long;
12    use File::Slurp;
13    
14  my $debug = 0;  my $debug = 1;
15  my $protocol_dump = 1;  my $protocol_dump = 0;
16    my $list = 0;
17    
18  GetOptions(  GetOptions(
19          'debug+' => \$debug,          'debug+' => \$debug,
20          'protocol-dump!' => \$protocol_dump,          'protocol-dump!' => \$protocol_dump,
21            'list!' => \$list,
22  );  );
23    
24  my $id = shift @ARGV || die "usage: $0 CPE_id [--protocol-dump]\n";  my $id = shift @ARGV || die "usage: $0 CPE_id [--protocol-dump]\n";
# Line 27  die "ID isn't valid: $id\n" unless $id = Line 30  die "ID isn't valid: $id\n" unless $id =
30    
31  my $q = CWMP::Queue->new({ id => $id, debug => $debug });  my $q = CWMP::Queue->new({ id => $id, debug => $debug });
32    
33    
34  if ( $protocol_dump ) {  if ( $protocol_dump ) {
35    
36          warn "generating dump of xml protocol with CPE\n";          warn "generating dump of xml protocol with CPE\n";
# Line 34  if ( $protocol_dump ) { Line 38  if ( $protocol_dump ) {
38          $q->enqueue( 'GetRPCMethods' );          $q->enqueue( 'GetRPCMethods' );
39          $q->enqueue( 'GetParameterNames' );          $q->enqueue( 'GetParameterNames' );
40    
41  #       $q->enqueue( 'GetParameterNames', 'InternetGatewayDevice.DeviceInfo.SerialNumber', 0 );          $q->enqueue( 'GetParameterNames', [ 'InternetGatewayDevice.DeviceInfo.SerialNumber', 0 ] );
42  #       $q->enqueue( 'GetParameterNames', 'InternetGatewayDevice.DeviceInfo.', 1 );          $q->enqueue( 'GetParameterNames', [ 'InternetGatewayDevice.DeviceInfo.', 1 ] );
43    
44          $q->enqueue( 'GetParameterValues',          $q->enqueue( 'GetParameterValues', [
45                                  'InternetGatewayDevice.DeviceInfo.SerialNumber',                  'InternetGatewayDevice.DeviceInfo.SerialNumber',
46                                  'InternetGatewayDevice.DeviceInfo.VendorConfigFile.',                  'InternetGatewayDevice.DeviceInfo.VendorConfigFile.',
47                                  'InternetGatewayDevice.DeviceInfo.X_000E50_Country',                  'InternetGatewayDevice.DeviceInfo.X_000E50_Country',
48          );          ] );
49          $q->enqueue( 'SetParameterValues',          $q->enqueue( 'SetParameterValues', {
50                                  'InternetGatewayDevice.DeviceInfo.ProvisioningCode' => 'test provision',                  'InternetGatewayDevice.DeviceInfo.ProvisioningCode' => 'test provision',
51  #                       'InternetGatewayDevice.DeviceInfo.X_000E50_Country' => 1,  #               'InternetGatewayDevice.DeviceInfo.X_000E50_Country' => 1,
52          );          });
53    
54  #       $q->enqueue( 'Reboot' );  #       $q->enqueue( 'Reboot' );
55    
56  }  }
57    
58    if ( $list ) {
59    
60            warn "list all jobs for $id\n";
61    
62            my @active = ();
63            my @queued = ();
64            my $hostname = $q->dq->gethostname();
65    
66            sub wanted {
67              my ($visitcontext, $job) = @_;
68    
69              my $data = $job->get_data_path();
70              my $nbytes = $job->get_data_size_bytes();
71              my $timet = $job->get_time_submitted_secs();
72              my $hname = $job->get_hostname_submitted();
73              my $jobid = $job->{jobid};
74    
75              my $text = sprintf (
76                                    "%s (%d bytes)\n  Submitted: %s on %s\n",
77                                    $jobid, $nbytes, scalar localtime $timet, $hname);
78    
79                    $text .= read_file( $data ) || die "can't open $data: $!";
80    
81              if ($job->{active_pid})
82              {
83                    if ($hostname eq $job->{active_host}
84                            && !kill (0, $job->{active_pid}))
85                    {
86                      $text = sprintf (
87                                    "(dead lockfile)\n  %s",
88                                    $text);
89                    }
90                    else {
91                      $text = sprintf (
92                                    "(pid: %d\@%s)\n  %s",
93                                    $job->{active_pid}, $job->{active_host}, $text);
94                    }
95    
96                    push (@active, $text);
97              }
98              else {
99                    push (@queued, $text);
100              }
101    
102              $job->finish();
103            }
104    
105            $q->dq->visit_all_jobs(\&wanted, undef);
106            printf "Jobs: active: %d  queued: %d\n",
107                            scalar @active, scalar @queued;
108            
109            print "Active jobs [", scalar @active, "]\n",join("\n\n", @active) if @active;
110            print "Queued jobs [", scalar @queued, "]\n",join("\n\n", @queued) if @queued;
111    
112    } else {
113    
114            warn "injecting some tests commands\n";
115    
116            $q->enqueue( 'SetParameterValues', {
117                    'InternetGatewayDevice.DeviceInfo.ProvisioningCode' => 'test provision',
118    #               'InternetGatewayDevice.DeviceInfo.X_000E50_Country' => 1,
119            });
120    
121            $q->enqueue( 'GetParameterValues', [
122                    'InternetGatewayDevice.DeviceInfo.ProvisioningCode',
123            ]);
124    
125    }
Legend:
Removed from v.197  
changed lines
  Added in v.199
  ViewVC Help
Powered by ViewVC 1.1.26