/[pxelator]/lib/PXElator/tftpd.pm
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 /lib/PXElator/tftpd.pm

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

revision 93 by dpavlin, Fri Jul 31 19:59:28 2009 UTC revision 118 by dpavlin, Mon Aug 3 08:52:32 2009 UTC
# Line 5  use strict; Line 5  use strict;
5    
6  use Net::TFTPd 0.03 qw(%OPCODES);  use Net::TFTPd 0.03 qw(%OPCODES);
7  use Data::Dump qw/dump/;  use Data::Dump qw/dump/;
 use Module::Refresh;  
8    
9  use server;  use server;
10    
# Line 22  sub path { Line 21  sub path {
21          return $path;          return $path;
22  }  }
23    
24  STDERR->autoflush(1);  use progress_bar;
25    
26  sub transfer_status {  sub transfer_status {
27          my $req = shift;          my $request = shift;
28          if( $req->{'_REQUEST_'}{'OPCODE'} eq $OPCODES{'RRQ'} ) {          my $r = $request->{'_REQUEST_'} || die "no _REQUEST_ in ",dump( $request );
29                  printf STDERR "RRQ %s %u\/%u\r", map { $req->{_REQUEST_}->{$_} } ( 'FileName', 'LASTACK', 'LASTBLK' );  
30          } elsif ( $req->{'_REQUEST_'}{'OPCODE'} eq $OPCODES{'WRQ'} ) {          if( $r->{'OPCODE'} eq $OPCODES{'RRQ'} ) {
31                    progress_bar::tick( $r->{FileName}, $r->{BlkSize} * $r->{LASTACK}, $r->{BlkSize} * $r->{LASTBLK} );
32            } elsif ( $r->{'OPCODE'} eq $OPCODES{'WRQ'} ) {
33                  die "WRQ disabled";                  die "WRQ disabled";
                 printf STDERR "WRQ: %u\/%u\n", $req->{'_REQUEST_'}{'LASTBLK'}, $req->{'_REQUEST_'}{'LASTACK'};  
34          } else {          } else {
35                  warn "IGNORED: ", dump( $req );                  warn "IGNORED: ", dump( $request );
36          }          }
37  }  }
38    
# Line 41  sub tftp_request { Line 41  sub tftp_request {
41    
42          warn 'request: ', dump( $request ) if $debug;          warn 'request: ', dump( $request ) if $debug;
43    
44            config::for_ip();
45    
46          if ( $request->{RootDir} ne $dir ) {          if ( $request->{RootDir} ne $dir ) {
47                  $request->{RootDir} = $dir;                  $request->{RootDir} = $dir;
48                  warn "new root: $dir";                  warn "new root: $dir";
# Line 50  sub tftp_request { Line 52  sub tftp_request {
52          # received request          # received request
53          print $OPCODES{$request->{'_REQUEST_'}{'OPCODE'}}, " $file\n";          print $OPCODES{$request->{'_REQUEST_'}{'OPCODE'}}, " $file\n";
54    
55            progress_bar::start;
56    
57          # process the request          # process the request
58          if( $request->processRQ() ) {          if( $request->processRQ() ) {
59                  print "\nOK completed $file ", -s "$dir/$file", "\n";                  print "\nOK completed $file ", -s "$dir/$file", "\n";
# Line 88  sub start { Line 92  sub start {
92    
93          while(1) {          while(1) {
94    
                 Module::Refresh->refresh;  
   
95                  # wait for any request (RRQ or WRQ)                  # wait for any request (RRQ or WRQ)
96                  if(my $request = $listener->waitRQ()) {                  if(my $request = $listener->waitRQ()) {
97                          tftp_request $request;                          tftp_request $request;
98                  } else {                  } elsif ( my $error = Net::TFTPd->error ) {
99                          warn Net::TFTPd->error;                          warn $error;
100                  }                  }
101    
102          }          }
Legend:
Removed from v.93  
changed lines
  Added in v.118
  ViewVC Help
Powered by ViewVC 1.1.26