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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
|
# Copyright (C) 2008 Canonical Limited.
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License version 2 as published
# by the Free Software Foundation.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
#
"""Compiled extensions for doing compression."""
cdef extern from *:
ctypedef unsigned long size_t
void * malloc(size_t)
void * realloc(void *, size_t)
void free(void *)
void memcpy(void *, void *, size_t)
cdef extern from "delta.h":
void * diff_delta(void *src_buf, unsigned long src_bufsize,
void *trg_buf, unsigned long trg_bufsize,
unsigned long *delta_size, unsigned long max_delta_size)
struct delta_index:
unsigned long memsize
void *src_buf
unsigned long src_size
unsigned int hash_mask
# struct index_entry *hash[]
delta_index * create_delta_index(void *buf, unsigned long bufsize)
void free_delta_index(delta_index *index)
void * create_delta(delta_index *index,
void *buf, unsigned long bufsize,
unsigned long *delta_size, unsigned long max_delta_size)
unsigned long get_delta_hdr_size(unsigned char **datap,
unsigned char *top)
Py_ssize_t DELTA_SIZE_MIN
void *patch_delta(void *src_buf, unsigned long src_size,
void *delta_buf, unsigned long delta_size,
unsigned long *dst_size)
cdef extern from "Python.h":
int PyString_CheckExact(object)
char * PyString_AS_STRING(object)
Py_ssize_t PyString_GET_SIZE(object)
object PyString_FromStringAndSize(char *, Py_ssize_t)
# cdef void *safe_malloc(size_t count) except NULL:
# cdef void *result
# result = malloc(count)
# if result == NULL:
# raise MemoryError('Failed to allocate %d bytes of memory' % (count,))
# return result
#
#
# cdef void *safe_realloc(void * old, size_t count) except NULL:
# cdef void *result
# result = realloc(old, count)
# if result == NULL:
# raise MemoryError('Failed to reallocate to %d bytes of memory'
# % (count,))
# return result
#
#
# cdef int safe_free(void **val) except -1:
# assert val != NULL
# if val[0] != NULL:
# free(val[0])
# val[0] = NULL
def make_delta(source_bytes, target_bytes):
"""Create a delta from source_bytes => target_bytes."""
cdef char *source
cdef Py_ssize_t source_size
cdef char *target
cdef Py_ssize_t target_size
cdef delta_index *index
cdef void * delta
cdef unsigned long delta_size
cdef unsigned long max_delta_size
max_delta_size = 0 # Unlimited
if not PyString_CheckExact(source_bytes):
raise TypeError('source is not a str')
if not PyString_CheckExact(target_bytes):
raise TypeError('target is not a str')
source = PyString_AS_STRING(source_bytes)
source_size = PyString_GET_SIZE(source_bytes)
target = PyString_AS_STRING(target_bytes)
target_size = PyString_GET_SIZE(target_bytes)
result = None
index = create_delta_index(source, source_size)
if index != NULL:
delta = create_delta(index, target, target_size,
&delta_size, max_delta_size)
free_delta_index(index);
if delta:
result = PyString_FromStringAndSize(<char *>delta, delta_size)
free(delta)
return result
def apply_delta(source_bytes, delta_bytes):
"""Apply a delta generated by make_delta to source_bytes."""
cdef char *source
cdef Py_ssize_t source_size
cdef char *delta
cdef Py_ssize_t delta_size
cdef unsigned char *data, *top
cdef unsigned char *dst_buf, *out, cmd
cdef Py_ssize_t size
cdef unsigned long cp_off, cp_size
if not PyString_CheckExact(source_bytes):
raise TypeError('source is not a str')
if not PyString_CheckExact(delta_bytes):
raise TypeError('delta is not a str')
source = PyString_AS_STRING(source_bytes)
source_size = PyString_GET_SIZE(source_bytes)
delta = PyString_AS_STRING(delta_bytes)
delta_size = PyString_GET_SIZE(delta_bytes)
# Code taken from patch-delta.c, only brought here to give better error
# handling, and to avoid double allocating memory
if (delta_size < DELTA_SIZE_MIN):
# XXX: Invalid delta block
return None
data = <unsigned char *>delta
top = data + delta_size
# make sure the orig file size matches what we expect
# XXX: gcc warns because data isn't defined as 'const'
size = get_delta_hdr_size(&data, top)
if (size > source_size):
# XXX: mismatched source size
return None
source_size = size
# now the result size
size = get_delta_hdr_size(&data, top)
result = PyString_FromStringAndSize(NULL, size)
dst_buf = <unsigned char*>PyString_AS_STRING(result)
# XXX: The original code added a trailing null here, but this shouldn't be
# necessary when using PyString_FromStringAndSize
# dst_buf[size] = 0
out = dst_buf
while (data < top):
cmd = data[0]
data = data + 1
if (cmd & 0x80):
cp_off = cp_size = 0
if (cmd & 0x01):
cp_off = data[0]
data = data + 1
if (cmd & 0x02):
cp_off |= (data[0] << 8)
data = data + 1
if (cmd & 0x04):
cp_off |= (data[0] << 16)
data = data + 1
if (cmd & 0x08):
cp_off |= (data[0] << 24)
data[0] += 1
if (cmd & 0x10):
cp_size = data[0]
data = data + 1
if (cmd & 0x20):
cp_size |= (data[0] << 8)
data = data + 1
if (cmd & 0x40):
cp_size |= (data[0] << 16)
data = data + 1
if (cp_size == 0):
cp_size = 0x10000
if (cp_off + cp_size < cp_size or
cp_off + cp_size > source_size or
cp_size > size):
break
memcpy(out, source + cp_off, cp_size)
out = out + cp_size
size -= cp_size
elif (cmd):
if (cmd > size):
break
memcpy(out, data, cmd)
out = out + cmd
data = data + cmd
size -= cmd
else:
# /*
# * cmd == 0 is reserved for future encoding
# * extensions. In the mean time we must fail when
# * encountering them (might be data corruption).
# */
## /* XXX: error("unexpected delta opcode 0"); */
return None
# /* sanity check */
if (data != top or size != 0):
## /* XXX: error("delta replay has gone wild"); */
return None
# *dst_size = out - dst_buf;
assert (out - dst_buf) == PyString_GET_SIZE(result)
return result
def apply_delta2(source_bytes, delta_bytes):
"""Apply a delta generated by make_delta to source_bytes."""
# This defers to the patch-delta code rather than implementing it here
# If this is faster, we can bring the memory allocation and error handling
# into apply_delta(), and leave the primary loop in a separate C func.
cdef char *source, *delta, *target
cdef Py_ssize_t source_size, delta_size
cdef unsigned long target_size
if not PyString_CheckExact(source_bytes):
raise TypeError('source is not a str')
if not PyString_CheckExact(delta_bytes):
raise TypeError('delta is not a str')
source = PyString_AS_STRING(source_bytes)
source_size = PyString_GET_SIZE(source_bytes)
delta = PyString_AS_STRING(delta_bytes)
delta_size = PyString_GET_SIZE(delta_bytes)
target = <char *>patch_delta(source, source_size,
delta, delta_size,
&target_size)
if target == NULL:
return None
result = PyString_FromStringAndSize(target, target_size)
free(target)
return result
|