6 use Net::TFTPd 0.03 qw(%OPCODES);
8 use Data::Dump qw/dump/;
13 our $debug = server::debug;
15 our $dir = "$server::base_dir/tftp";
19 my $path = (glob("$dir/$glob"))[0];
20 die "can't find anything for $dir/$glob" unless $path;
21 warn 'path ', $path if $debug;
30 my $r = $request->{'_REQUEST_'} || die "no _REQUEST_ in ",dump( $request );
32 if( $r->{'OPCODE'} eq $OPCODES{'RRQ'} ) {
33 progress_bar::tick( $r->{FileName}, $r->{BlkSize} * $r->{LASTACK}, $r->{BlkSize} * $r->{LASTBLK} );
34 } elsif ( $r->{'OPCODE'} eq $OPCODES{'WRQ'} ) {
37 warn "IGNORED: ", dump( $request );
48 warn 'request: ', dump( $request ) if $debug;
50 my $ip = $request->{_REQUEST_}->{PeerAddr};
51 config::for_ip( $ip );
53 if ( $request->{RootDir} ne $dir ) {
54 $request->{RootDir} = $dir;
55 warn "new root: $dir";
58 my $file = $request->{'_REQUEST_'}{'FileName'};
59 my $opcode = $OPCODES{$request->{'_REQUEST_'}{'OPCODE'}};
61 CouchDB::audit('request', {
70 if( $request->processRQ() ) {
71 my $size = -s "$dir/$file";
72 CouchDB::audit('completed', { file => $file, size => $size });
74 CouchDB::audit('error', { file => $file, error => Net::TFTPd->error });
75 $request->processRQ();
86 # XXX we need to setup listener ourselfs because we need Reuse
89 # LocalAddr => $server::ip,
90 # LocalAddr => '0.0.0.0',
95 my $udpserver = IO::Socket::INET->new(%params);
96 die "can't start server ",dump( \%params ), " $!" unless $udpserver;
98 my $listener = bless {
107 CallBack => \&transfer_status,
110 BlkSize => 1456, # IBM GE seems to be picky
112 %params, # merge user parameters
113 _UDPSERVER_ => $udpserver,
116 warn 'listener: ',dump( $listener ) if $debug;
118 CouchDB::audit( 'start', {
119 addr => $listener->{LocalAddr},
120 port => $listener->{LocalPort},
121 timeout => $listener->{Timeout},
122 params => { %params },
127 # wait for any request (RRQ or WRQ)
128 if(my $request = $listener->waitRQ()) {
129 tftp_request $request;
130 } elsif ( my $error = Net::TFTPd->error ) {