/[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 141 by dpavlin, Tue Aug 4 17:29:59 2009 UTC revision 544 by dpavlin, Sat Oct 9 13:34:37 2010 UTC
# Line 6  use strict; Line 6  use strict;
6  use Net::TFTPd 0.03 qw(%OPCODES);  use Net::TFTPd 0.03 qw(%OPCODES);
7  use IO::Socket::INET;  use IO::Socket::INET;
8  use Data::Dump qw/dump/;  use Data::Dump qw/dump/;
9    use store;
10    
11  use server;  use server;
12    
# Line 42  use config; Line 43  use config;
43  sub tftp_request {  sub tftp_request {
44          my $request = shift;          my $request = shift;
45    
         server->refresh;  
   
46          warn 'request: ', dump( $request ) if $debug;          warn 'request: ', dump( $request ) if $debug;
47    
48          config::for_ip( $request->{_REQUEST_}->{PeerAddr} );          my $ip = $request->{_REQUEST_}->{PeerAddr};
49            config::for_ip( $ip );
50    
51          if ( $request->{RootDir} ne $dir ) {          if ( $request->{RootDir} ne $dir ) {
52                  $request->{RootDir} = $dir;                  $request->{RootDir} = $dir;
# Line 54  sub tftp_request { Line 54  sub tftp_request {
54          }          }
55    
56          my $file = $request->{'_REQUEST_'}{'FileName'};          my $file = $request->{'_REQUEST_'}{'FileName'};
57          # received request          my $opcode = $OPCODES{$request->{'_REQUEST_'}{'OPCODE'}};
58          print $OPCODES{$request->{'_REQUEST_'}{'OPCODE'}}, " $file\n";  
59            my $audit = {
60                    ip => $ip,
61                    opcode => $opcode,
62                    path => $file,
63                    state => 'start',
64            };
65            store::audit( $opcode, $audit );
66    
67          progress_bar::start;          progress_bar::start;
68    
69          # process the request          # process the request
70          if( $request->processRQ() ) {          if( $request->processRQ() ) {
71                  print "\nOK completed $file ", -s "$dir/$file", "\n";                  my $size = -s "$dir/$file";
72                    $audit->{state} = 'finish';
73                    $audit->{size} = $size;
74                    store::audit( $opcode, $audit );
75          } else {          } else {
76                  print "ERROR ", Net::TFTPd->error, "\n";                  $audit->{state} = 'error';
77                  $request->processRQ();                  $audit->{error} = Net::TFTPd->error;
78                    store::audit( $opcode, $audit );
79          }          }
80    
81  }  }
# Line 90  sub start { Line 101  sub start {
101          my $listener = bless {          my $listener = bless {
102                  RootDir => $dir,                  RootDir => $dir,
103    
104                  ACKtimeout  => 4,                  ACKtimeout  => 1, # 4
105                  ACKretries  => 4,                  ACKretries  => 2, # 4
106                  Readable    => 1,                  Readable    => 1,
107                  Writable    => 0,                  Writable    => 0,
108                  Timeout => 3600,                  Timeout => 3600,
109    
110                  CallBack => \&transfer_status,                  CallBack => \&transfer_status,
111  #               BlkSize => 8192,  #               BlkSize => 8192,
112  #               BlkSize => 512,                  BlkSize => 512,         # Dell's RAC doesn't like bigger packets
113                  BlkSize => 1456,        # IBM GE seems to be picky  #               BlkSize => 1456,        # IBM GE seems to be picky
114                  Debug => 99,                  Debug => 99,
115                  %params, # merge user parameters                  %params, # merge user parameters
116                  _UDPSERVER_ => $udpserver,                  _UDPSERVER_ => $udpserver,
# Line 107  sub start { Line 118  sub start {
118    
119          warn 'listener: ',dump( $listener ) if $debug;          warn 'listener: ',dump( $listener ) if $debug;
120    
121          printf "TFTP listen %s:%d timeout: %d dir: $dir\n",          store::audit( 'start', {
122                  $listener->{LocalAddr},                  addr => $listener->{LocalAddr},
123                  $listener->{LocalPort},                  port => $listener->{LocalPort},
124                  $listener->{Timeout};                  timeout => $listener->{Timeout},
125                    params => { %params },
126            });
127    
128          while(1) {          while(1) {
129    
130                  # wait for any request (RRQ or WRQ)                  # wait for any request (RRQ or WRQ)
131                  if(my $request = $listener->waitRQ()) {                  if(my $request = $listener->waitRQ()) {
132                            server->refresh;
133                          tftp_request $request;                          tftp_request $request;
134                  } elsif ( my $error = Net::TFTPd->error ) {                  } elsif ( my $error = Net::TFTPd->error ) {
135                          warn $error;                          warn $error;
Legend:
Removed from v.141  
changed lines
  Added in v.544
  ViewVC Help
Powered by ViewVC 1.1.26