Commit bb334947 authored by Georg Brandl's avatar Georg Brandl

Issue #16038: CVE-2013-1752: ftplib: Limit amount of data read by

limiting the call to readline().  Original patch by Michał
Jastrzębski and Giampaolo Rodola.
parent c4e759fc
...@@ -49,6 +49,8 @@ MSG_OOB = 0x1 # Process data out of band ...@@ -49,6 +49,8 @@ MSG_OOB = 0x1 # Process data out of band
# The standard FTP server control port # The standard FTP server control port
FTP_PORT = 21 FTP_PORT = 21
# The sizehint parameter passed to readline() calls
MAXLINE = 8192
# Exception raised when an error or invalid response is received # Exception raised when an error or invalid response is received
...@@ -96,6 +98,7 @@ class FTP: ...@@ -96,6 +98,7 @@ class FTP:
debugging = 0 debugging = 0
host = '' host = ''
port = FTP_PORT port = FTP_PORT
maxline = MAXLINE
sock = None sock = None
file = None file = None
welcome = None welcome = None
...@@ -190,7 +193,9 @@ class FTP: ...@@ -190,7 +193,9 @@ class FTP:
# Internal: return one line from the server, stripping CRLF. # Internal: return one line from the server, stripping CRLF.
# Raise EOFError if the connection is closed # Raise EOFError if the connection is closed
def getline(self): def getline(self):
line = self.file.readline() line = self.file.readline(self.maxline + 1)
if len(line) > self.maxline:
raise Error("got more than %d bytes" % self.maxline)
if self.debugging > 1: if self.debugging > 1:
print('*get*', self.sanitize(line)) print('*get*', self.sanitize(line))
if not line: raise EOFError if not line: raise EOFError
...@@ -444,7 +449,9 @@ class FTP: ...@@ -444,7 +449,9 @@ class FTP:
with self.transfercmd(cmd) as conn, \ with self.transfercmd(cmd) as conn, \
conn.makefile('r', encoding=self.encoding) as fp: conn.makefile('r', encoding=self.encoding) as fp:
while 1: while 1:
line = fp.readline() line = fp.readline(self.maxline + 1)
if len(line) > self.maxline:
raise Error("got more than %d bytes" % self.maxline)
if self.debugging > 2: print('*retr*', repr(line)) if self.debugging > 2: print('*retr*', repr(line))
if not line: if not line:
break break
...@@ -494,7 +501,9 @@ class FTP: ...@@ -494,7 +501,9 @@ class FTP:
self.voidcmd('TYPE A') self.voidcmd('TYPE A')
with self.transfercmd(cmd) as conn: with self.transfercmd(cmd) as conn:
while 1: while 1:
buf = fp.readline() buf = fp.readline(self.maxline + 1)
if len(buf) > self.maxline:
raise Error("got more than %d bytes" % self.maxline)
if not buf: break if not buf: break
if buf[-2:] != B_CRLF: if buf[-2:] != B_CRLF:
if buf[-1] in B_CRLF: buf = buf[:-1] if buf[-1] in B_CRLF: buf = buf[:-1]
...@@ -741,7 +750,9 @@ else: ...@@ -741,7 +750,9 @@ else:
fp = conn.makefile('r', encoding=self.encoding) fp = conn.makefile('r', encoding=self.encoding)
try: try:
while 1: while 1:
line = fp.readline() line = fp.readline(self.maxline + 1)
if len(line) > self.maxline:
raise Error("got more than %d bytes" % self.maxline)
if self.debugging > 2: print('*retr*', repr(line)) if self.debugging > 2: print('*retr*', repr(line))
if not line: if not line:
break break
...@@ -779,7 +790,9 @@ else: ...@@ -779,7 +790,9 @@ else:
conn = self.transfercmd(cmd) conn = self.transfercmd(cmd)
try: try:
while 1: while 1:
buf = fp.readline() buf = fp.readline(self.maxline + 1)
if len(buf) > self.maxline:
raise Error("got more than %d bytes" % self.maxline)
if not buf: break if not buf: break
if buf[-2:] != B_CRLF: if buf[-2:] != B_CRLF:
if buf[-1] in B_CRLF: buf = buf[:-1] if buf[-1] in B_CRLF: buf = buf[:-1]
......
...@@ -70,6 +70,7 @@ class DummyFTPHandler(asynchat.async_chat): ...@@ -70,6 +70,7 @@ class DummyFTPHandler(asynchat.async_chat):
self.last_received_data = '' self.last_received_data = ''
self.next_response = '' self.next_response = ''
self.rest = None self.rest = None
self.next_retr_data = RETR_DATA
self.push('220 welcome') self.push('220 welcome')
def collect_incoming_data(self, data): def collect_incoming_data(self, data):
...@@ -199,7 +200,7 @@ class DummyFTPHandler(asynchat.async_chat): ...@@ -199,7 +200,7 @@ class DummyFTPHandler(asynchat.async_chat):
offset = int(self.rest) offset = int(self.rest)
else: else:
offset = 0 offset = 0
self.dtp.push(RETR_DATA[offset:]) self.dtp.push(self.next_retr_data[offset:])
self.dtp.close_when_done() self.dtp.close_when_done()
self.rest = None self.rest = None
...@@ -213,6 +214,11 @@ class DummyFTPHandler(asynchat.async_chat): ...@@ -213,6 +214,11 @@ class DummyFTPHandler(asynchat.async_chat):
self.dtp.push(NLST_DATA) self.dtp.push(NLST_DATA)
self.dtp.close_when_done() self.dtp.close_when_done()
def cmd_setlongretr(self, arg):
# For testing. Next RETR will return long line.
self.next_retr_data = 'x' * int(arg)
self.push('125 setlongretr ok')
class DummyFTPServer(asyncore.dispatcher, threading.Thread): class DummyFTPServer(asyncore.dispatcher, threading.Thread):
...@@ -628,6 +634,20 @@ class TestFTPClass(TestCase): ...@@ -628,6 +634,20 @@ class TestFTPClass(TestCase):
self.assertEqual(ftplib.parse257('257 "/foo/b""ar"'), '/foo/b"ar') self.assertEqual(ftplib.parse257('257 "/foo/b""ar"'), '/foo/b"ar')
self.assertEqual(ftplib.parse257('257 "/foo/b""ar" created'), '/foo/b"ar') self.assertEqual(ftplib.parse257('257 "/foo/b""ar" created'), '/foo/b"ar')
def test_line_too_long(self):
self.assertRaises(ftplib.Error, self.client.sendcmd,
'x' * self.client.maxline * 2)
def test_retrlines_too_long(self):
self.client.sendcmd('SETLONGRETR %d' % (self.client.maxline * 2))
received = []
self.assertRaises(ftplib.Error,
self.client.retrlines, 'retr', received.append)
def test_storlines_too_long(self):
f = io.BytesIO(b'x' * self.client.maxline * 2)
self.assertRaises(ftplib.Error, self.client.storlines, 'stor', f)
class TestIPv6Environment(TestCase): class TestIPv6Environment(TestCase):
......
...@@ -10,6 +10,10 @@ What's New in Python 3.2.6? ...@@ -10,6 +10,10 @@ What's New in Python 3.2.6?
Library Library
------- -------
- Issue #16038: CVE-2013-1752: ftplib: Limit amount of data read by
limiting the call to readline(). Original patch by Michał
Jastrzębski and Giampaolo Rodola.
- Issue #16037: HTTPMessage.readheaders() raises an HTTPException when more than - Issue #16037: HTTPMessage.readheaders() raises an HTTPException when more than
100 headers are read. Adapted from patch by Jyrki Pulliainen. 100 headers are read. Adapted from patch by Jyrki Pulliainen.
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment