diff --git a/src/File/FileRequest.py b/src/File/FileRequest.py
index ea114a1c..7b90b036 100644
--- a/src/File/FileRequest.py
+++ b/src/File/FileRequest.py
@@ -198,6 +198,10 @@ class FileRequest(object):
                 file.seek(params["location"])
                 file.read_bytes = FILE_BUFF
                 file_size = os.fstat(file.fileno()).st_size
+                if params.get("file_size") and params["file_size"] != file_size:
+                    self.connection.badAction(5)
+                    raise RequestError("File size does not match")
+
                 if params["location"] > file_size:
                     self.connection.badAction(5)
                     raise RequestError("Bad file location")
diff --git a/src/Peer/Peer.py b/src/Peer/Peer.py
index 17e6431e..ff38e153 100644
--- a/src/Peer/Peer.py
+++ b/src/Peer/Peer.py
@@ -155,7 +155,7 @@ class Peer(object):
         return None  # Failed after 4 retry
 
     # Get a file content from peer
-    def getFile(self, site, inner_path):
+    def getFile(self, site, inner_path, file_size=None):
         # Use streamFile if client supports it
         if config.stream_downloads and self.connection and self.connection.handshake and self.connection.handshake["rev"] > 310:
             return self.streamFile(site, inner_path)
@@ -168,7 +168,7 @@ class Peer(object):
 
         s = time.time()
         while True:  # Read in 512k parts
-            res = self.request("getFile", {"site": site, "inner_path": inner_path, "location": location})
+            res = self.request("getFile", {"site": site, "inner_path": inner_path, "location": location, "file_size": file_size})
 
             if not res or "body" not in res:  # Error
                 return False
diff --git a/src/Worker/Worker.py b/src/Worker/Worker.py
index bdeb2431..a3592d7c 100644
--- a/src/Worker/Worker.py
+++ b/src/Worker/Worker.py
@@ -46,7 +46,7 @@ class Worker(object):
                 site = task["site"]
                 task["workers_num"] += 1
                 try:
-                    buff = self.peer.getFile(site.address, task["inner_path"])
+                    buff = self.peer.getFile(site.address, task["inner_path"], task["size"])
                 except Exception, err:
                     self.manager.log.debug("%s: getFile error: %s" % (self.key, err))
                     buff = None