diff --git a/hda/api.py b/hda/api.py
index 973c651..229f406 100644
--- a/hda/api.py
+++ b/hda/api.py
@@ -794,7 +794,7 @@ def stream(self, download_id, size, download_dir):
                 r.close()
 
             if size is None or total >= size:
-                size = os.path.getsize(filename)
+                size = os.path.getsize(os.path.join(download_dir, filename))
                 break
 
             logger.error(
@@ -804,7 +804,7 @@ def stream(self, download_id, size, download_dir):
             logger.warning("Sleeping %s seconds" % (sleep,))
             time.sleep(sleep)
             mode = "ab"
-            total = os.path.getsize(filename)
+            total = os.path.getsize(os.path.join(download_dir, filename))
             sleep *= 1.5
             if sleep > self.sleep_max:
                 sleep = self.sleep_max