Cutlery/calibre
1
0
Fork 0
mirror of https://github.com/kovidgoyal/calibre.git synced 2025-07-09 03:04:10 -04:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/Polyfun/calibre

Browse Source
This commit is contained in:
Kovid Goyal 2014-11-13 20:32:23 +05:30
commit ff5c6cd143
1 changed files with 33 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
src/calibre/devices/idevice/libimobiledevice.py
View File

@ -284,22 +284,22 @@ class libiMobileDevice():
if handle is not None:
file_stats = self._afc_get_file_info(src)
file_size = int(file_stats['st_size'])
self._log("file_size: {:,} bytes".format(file_size))
self._log("file {0} file_size: {1:,} bytes".format(repr(src), file_size))
if file_size > BUFFER_SIZE:
bytes_remaining = file_size
while bytes_remaining:
if bytes_remaining > BUFFER_SIZE:
self._log("copying {:,} byte chunk".format(BUFFER_SIZE))
self._log("copying file {0} to {1}, {2:,} byte chunk".format(repr(src), dst.name, BUFFER_SIZE))
data = self._afc_file_read(handle, BUFFER_SIZE, mode)
dst.write(data)
bytes_remaining -= BUFFER_SIZE
else:
self._log("copying final {:,} bytes".format(bytes_remaining))
self._log("copying file {0} to {1}, final {2:,} bytes".format(repr(src), dst.name, bytes_remaining))
data = self._afc_file_read(handle, bytes_remaining, mode)
dst.write(data)
bytes_remaining = 0
else:
self._log("copying {:,} bytes".format(file_size))
self._log("copying file {0} to {1}, {2:,} bytes".format(repr(src), dst.name, file_size))
data = self._afc_file_read(handle, file_size, mode)
dst.write(data)
@ -308,6 +308,7 @@ class libiMobileDevice():
# Update timestamps to match
file_stats = self._afc_get_file_info(src)
self._log("copied file {0} ({1:,} bytes) to file '{2}' ({3:,} bytes)".format(repr(src), file_size, dst.name, os.path.getsize(dst.name)))
os.utime(dst.name, (file_stats['st_mtime'], file_stats['st_mtime']))
else:
@ -901,24 +902,39 @@ class libiMobileDevice():
'''
self._log_location("handle:{0} size:{1:,} mode='{2}'".format(handle.value, size, mode))
bytes_read = c_uint(0)
bytes_remaining = size
if 'b' in mode:
data = bytearray(size)
datatype = c_char * size
error = self.lib.afc_file_read(byref(self.afc),
handle,
byref(datatype.from_buffer(data)),
size,
byref(bytes_read)) & 0xFFFF
if error:
self._log_error(" ERROR: {0} handle:{1}".format(self._afc_error(error), handle))
while bytes_remaining > 0:
bytes_read = c_uint(0)
error = self.lib.afc_file_read(byref(self.afc),
handle,
byref(datatype.from_buffer(data), size - bytes_remaining),
bytes_remaining,
byref(bytes_read)) & 0xFFFF
if error:
self._log_error(" ERROR: {0} handle:{1}".format(self._afc_error(error), handle.value))
bytes_remaining = 0
elif bytes_read.value <= 0:
self._log_error(" ERROR: reading {0:,} bytes, 0 bytes read, handle:{1}".format(bytes_remaining, handle.value))
bytes_remaining = 0
else:
bytes_remaining -= bytes_read.value
return data
else:
data = create_string_buffer(size)
error = self.lib.afc_file_read(byref(self.afc), handle, byref(data), size, byref(bytes_read))
if error:
self._log_error(" ERROR: {0} handle:{1}".format(self._afc_error(error), handle))
while bytes_remaining > 0:
bytes_read = c_uint(0)
error = self.lib.afc_file_read(byref(self.afc), handle, byref(data, size - bytes_remaining), bytes_remaining, byref(bytes_read))
if error:
self._log_error(" ERROR: {0} handle:{1}".format(self._afc_error(error), handle.value))
bytes_remaining = 0
elif bytes_read.value <= 0:
self._log_error(" ERROR: reading {0:,} bytes, 0 bytes read, handle:{1}".format(bytes_remaining, handle.value))
bytes_remaining = 0
else:
bytes_remaining -= bytes_read.value
return data.value
def _afc_file_write(self, handle, content, mode='w'):
@ -1914,3 +1930,4 @@ class libiMobileDevice():
def __null(self, *args, **kwargs):
pass