1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
#!/usr/bin/env python
import sys, logging, os
from optparse import OptionParser
import tftpy
log = logging.getLogger('tftpy')
log.setLevel(logging.INFO)
# console handler
handler = logging.StreamHandler()
handler.setLevel(logging.DEBUG)
default_formatter = logging.Formatter('[%(asctime)s] %(message)s')
handler.setFormatter(default_formatter)
log.addHandler(handler)
def main():
usage=""
parser = OptionParser(usage=usage)
parser.add_option('-H',
'--host',
help='remote host or ip address')
parser.add_option('-p',
'--port',
help='remote port to use (default: 69)',
default=69)
parser.add_option('-f',
'--filename',
help='filename to fetch (deprecated, use download)')
parser.add_option('-D',
'--download',
help='filename to download')
parser.add_option('-u',
'--upload',
help='filename to upload')
parser.add_option('-b',
'--blksize',
help='udp packet size to use (default: 512)')
parser.add_option('-o',
'--output',
help='output file, - for stdout (default: same as download)')
parser.add_option('-i',
'--input',
help='input file, - for stdin (default: same as upload)')
parser.add_option('-d',
'--debug',
action='store_true',
default=False,
help='upgrade logging from info to debug')
parser.add_option('-q',
'--quiet',
action='store_true',
default=False,
help="downgrade logging from info to warning")
parser.add_option('-t',
'--tsize',
action='store_true',
default=False,
help="ask client to send tsize option in download")
parser.add_option('-l',
'--localip',
action='store',
dest='localip',
default="",
help='local IP for client to bind to (ie. interface)')
options, args = parser.parse_args()
# Handle legacy --filename argument.
if options.filename:
options.download = options.filename
if not options.host or (not options.download and not options.upload):
sys.stderr.write("Both the --host and --filename options "
"are required.\n")
parser.print_help()
sys.exit(1)
if options.debug and options.quiet:
sys.stderr.write("The --debug and --quiet options are "
"mutually exclusive.\n")
parser.print_help()
sys.exit(1)
class Progress(object):
def __init__(self, out):
self.progress = 0
self.out = out
def progresshook(self, pkt):
if isinstance(pkt, tftpy.TftpPacketTypes.TftpPacketDAT):
self.progress += len(pkt.data)
self.out("Transferred %d bytes" % self.progress)
elif isinstance(pkt, tftpy.TftpPacketTypes.TftpPacketOACK):
self.out("Received OACK, options are: %s" % pkt.options)
if options.debug:
log.setLevel(logging.DEBUG)
# increase the verbosity of the formatter
debug_formatter = logging.Formatter('[%(asctime)s%(msecs)03d] %(levelname)s [%(name)s:%(lineno)s] %(message)s')
handler.setFormatter(debug_formatter)
elif options.quiet:
log.setLevel(logging.WARNING)
progresshook = Progress(log.info).progresshook
tftp_options = {}
if options.blksize:
tftp_options['blksize'] = int(options.blksize)
if options.tsize:
tftp_options['tsize'] = 0
tclient = tftpy.TftpClient(options.host,
int(options.port),
tftp_options,
options.localip)
try:
if options.download:
if not options.output:
options.output = os.path.basename(options.download)
tclient.download(options.download,
options.output,
progresshook)
elif options.upload:
if not options.input:
options.input = os.path.basename(options.upload)
tclient.upload(options.upload,
options.input,
progresshook)
except tftpy.TftpException as err:
sys.stderr.write("%s\n" % str(err))
sys.exit(1)
except KeyboardInterrupt:
pass
if __name__ == '__main__':
main()
|
