##// END OF EJS Templates
bdiff: check and cast first parameter value on putbe32() calls...
Adrian Buehlmann -
r16750:5b1f869b default
parent child Browse files
Show More
@@ -1,474 +1,483 b''
1 /*
1 /*
2 bdiff.c - efficient binary diff extension for Mercurial
2 bdiff.c - efficient binary diff extension for Mercurial
3
3
4 Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>
4 Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>
5
5
6 This software may be used and distributed according to the terms of
6 This software may be used and distributed according to the terms of
7 the GNU General Public License, incorporated herein by reference.
7 the GNU General Public License, incorporated herein by reference.
8
8
9 Based roughly on Python difflib
9 Based roughly on Python difflib
10 */
10 */
11
11
12 #define PY_SSIZE_T_CLEAN
12 #define PY_SSIZE_T_CLEAN
13 #include <Python.h>
13 #include <Python.h>
14 #include <stdlib.h>
14 #include <stdlib.h>
15 #include <string.h>
15 #include <string.h>
16 #include <limits.h>
16 #include <limits.h>
17
17
18 #include "util.h"
18 #include "util.h"
19
19
20 struct line {
20 struct line {
21 int hash, n, e;
21 int hash, n, e;
22 Py_ssize_t len;
22 Py_ssize_t len;
23 const char *l;
23 const char *l;
24 };
24 };
25
25
26 struct pos {
26 struct pos {
27 int pos, len;
27 int pos, len;
28 };
28 };
29
29
30 struct hunk;
30 struct hunk;
31 struct hunk {
31 struct hunk {
32 int a1, a2, b1, b2;
32 int a1, a2, b1, b2;
33 struct hunk *next;
33 struct hunk *next;
34 };
34 };
35
35
36 static int splitlines(const char *a, Py_ssize_t len, struct line **lr)
36 static int splitlines(const char *a, Py_ssize_t len, struct line **lr)
37 {
37 {
38 unsigned hash;
38 unsigned hash;
39 int i;
39 int i;
40 const char *p, *b = a;
40 const char *p, *b = a;
41 const char * const plast = a + len - 1;
41 const char * const plast = a + len - 1;
42 struct line *l;
42 struct line *l;
43
43
44 /* count the lines */
44 /* count the lines */
45 i = 1; /* extra line for sentinel */
45 i = 1; /* extra line for sentinel */
46 for (p = a; p < a + len; p++)
46 for (p = a; p < a + len; p++)
47 if (*p == '\n' || p == plast)
47 if (*p == '\n' || p == plast)
48 i++;
48 i++;
49
49
50 *lr = l = (struct line *)malloc(sizeof(struct line) * i);
50 *lr = l = (struct line *)malloc(sizeof(struct line) * i);
51 if (!l)
51 if (!l)
52 return -1;
52 return -1;
53
53
54 /* build the line array and calculate hashes */
54 /* build the line array and calculate hashes */
55 hash = 0;
55 hash = 0;
56 for (p = a; p < a + len; p++) {
56 for (p = a; p < a + len; p++) {
57 /* Leonid Yuriev's hash */
57 /* Leonid Yuriev's hash */
58 hash = (hash * 1664525) + (unsigned char)*p + 1013904223;
58 hash = (hash * 1664525) + (unsigned char)*p + 1013904223;
59
59
60 if (*p == '\n' || p == plast) {
60 if (*p == '\n' || p == plast) {
61 l->hash = hash;
61 l->hash = hash;
62 hash = 0;
62 hash = 0;
63 l->len = p - b + 1;
63 l->len = p - b + 1;
64 l->l = b;
64 l->l = b;
65 l->n = INT_MAX;
65 l->n = INT_MAX;
66 l++;
66 l++;
67 b = p + 1;
67 b = p + 1;
68 }
68 }
69 }
69 }
70
70
71 /* set up a sentinel */
71 /* set up a sentinel */
72 l->hash = 0;
72 l->hash = 0;
73 l->len = 0;
73 l->len = 0;
74 l->l = a + len;
74 l->l = a + len;
75 return i - 1;
75 return i - 1;
76 }
76 }
77
77
78 static inline int cmp(struct line *a, struct line *b)
78 static inline int cmp(struct line *a, struct line *b)
79 {
79 {
80 return a->hash != b->hash || a->len != b->len || memcmp(a->l, b->l, a->len);
80 return a->hash != b->hash || a->len != b->len || memcmp(a->l, b->l, a->len);
81 }
81 }
82
82
83 static int equatelines(struct line *a, int an, struct line *b, int bn)
83 static int equatelines(struct line *a, int an, struct line *b, int bn)
84 {
84 {
85 int i, j, buckets = 1, t, scale;
85 int i, j, buckets = 1, t, scale;
86 struct pos *h = NULL;
86 struct pos *h = NULL;
87
87
88 /* build a hash table of the next highest power of 2 */
88 /* build a hash table of the next highest power of 2 */
89 while (buckets < bn + 1)
89 while (buckets < bn + 1)
90 buckets *= 2;
90 buckets *= 2;
91
91
92 /* try to allocate a large hash table to avoid collisions */
92 /* try to allocate a large hash table to avoid collisions */
93 for (scale = 4; scale; scale /= 2) {
93 for (scale = 4; scale; scale /= 2) {
94 h = (struct pos *)malloc(scale * buckets * sizeof(struct pos));
94 h = (struct pos *)malloc(scale * buckets * sizeof(struct pos));
95 if (h)
95 if (h)
96 break;
96 break;
97 }
97 }
98
98
99 if (!h)
99 if (!h)
100 return 0;
100 return 0;
101
101
102 buckets = buckets * scale - 1;
102 buckets = buckets * scale - 1;
103
103
104 /* clear the hash table */
104 /* clear the hash table */
105 for (i = 0; i <= buckets; i++) {
105 for (i = 0; i <= buckets; i++) {
106 h[i].pos = INT_MAX;
106 h[i].pos = INT_MAX;
107 h[i].len = 0;
107 h[i].len = 0;
108 }
108 }
109
109
110 /* add lines to the hash table chains */
110 /* add lines to the hash table chains */
111 for (i = bn - 1; i >= 0; i--) {
111 for (i = bn - 1; i >= 0; i--) {
112 /* find the equivalence class */
112 /* find the equivalence class */
113 for (j = b[i].hash & buckets; h[j].pos != INT_MAX;
113 for (j = b[i].hash & buckets; h[j].pos != INT_MAX;
114 j = (j + 1) & buckets)
114 j = (j + 1) & buckets)
115 if (!cmp(b + i, b + h[j].pos))
115 if (!cmp(b + i, b + h[j].pos))
116 break;
116 break;
117
117
118 /* add to the head of the equivalence class */
118 /* add to the head of the equivalence class */
119 b[i].n = h[j].pos;
119 b[i].n = h[j].pos;
120 b[i].e = j;
120 b[i].e = j;
121 h[j].pos = i;
121 h[j].pos = i;
122 h[j].len++; /* keep track of popularity */
122 h[j].len++; /* keep track of popularity */
123 }
123 }
124
124
125 /* compute popularity threshold */
125 /* compute popularity threshold */
126 t = (bn >= 31000) ? bn / 1000 : 1000000 / (bn + 1);
126 t = (bn >= 31000) ? bn / 1000 : 1000000 / (bn + 1);
127
127
128 /* match items in a to their equivalence class in b */
128 /* match items in a to their equivalence class in b */
129 for (i = 0; i < an; i++) {
129 for (i = 0; i < an; i++) {
130 /* find the equivalence class */
130 /* find the equivalence class */
131 for (j = a[i].hash & buckets; h[j].pos != INT_MAX;
131 for (j = a[i].hash & buckets; h[j].pos != INT_MAX;
132 j = (j + 1) & buckets)
132 j = (j + 1) & buckets)
133 if (!cmp(a + i, b + h[j].pos))
133 if (!cmp(a + i, b + h[j].pos))
134 break;
134 break;
135
135
136 a[i].e = j; /* use equivalence class for quick compare */
136 a[i].e = j; /* use equivalence class for quick compare */
137 if (h[j].len <= t)
137 if (h[j].len <= t)
138 a[i].n = h[j].pos; /* point to head of match list */
138 a[i].n = h[j].pos; /* point to head of match list */
139 else
139 else
140 a[i].n = INT_MAX; /* too popular */
140 a[i].n = INT_MAX; /* too popular */
141 }
141 }
142
142
143 /* discard hash tables */
143 /* discard hash tables */
144 free(h);
144 free(h);
145 return 1;
145 return 1;
146 }
146 }
147
147
148 static int longest_match(struct line *a, struct line *b, struct pos *pos,
148 static int longest_match(struct line *a, struct line *b, struct pos *pos,
149 int a1, int a2, int b1, int b2, int *omi, int *omj)
149 int a1, int a2, int b1, int b2, int *omi, int *omj)
150 {
150 {
151 int mi = a1, mj = b1, mk = 0, mb = 0, i, j, k;
151 int mi = a1, mj = b1, mk = 0, mb = 0, i, j, k;
152
152
153 for (i = a1; i < a2; i++) {
153 for (i = a1; i < a2; i++) {
154 /* skip things before the current block */
154 /* skip things before the current block */
155 for (j = a[i].n; j < b1; j = b[j].n)
155 for (j = a[i].n; j < b1; j = b[j].n)
156 ;
156 ;
157
157
158 /* loop through all lines match a[i] in b */
158 /* loop through all lines match a[i] in b */
159 for (; j < b2; j = b[j].n) {
159 for (; j < b2; j = b[j].n) {
160 /* does this extend an earlier match? */
160 /* does this extend an earlier match? */
161 if (i > a1 && j > b1 && pos[j - 1].pos == i - 1)
161 if (i > a1 && j > b1 && pos[j - 1].pos == i - 1)
162 k = pos[j - 1].len + 1;
162 k = pos[j - 1].len + 1;
163 else
163 else
164 k = 1;
164 k = 1;
165 pos[j].pos = i;
165 pos[j].pos = i;
166 pos[j].len = k;
166 pos[j].len = k;
167
167
168 /* best match so far? */
168 /* best match so far? */
169 if (k > mk) {
169 if (k > mk) {
170 mi = i;
170 mi = i;
171 mj = j;
171 mj = j;
172 mk = k;
172 mk = k;
173 }
173 }
174 }
174 }
175 }
175 }
176
176
177 if (mk) {
177 if (mk) {
178 mi = mi - mk + 1;
178 mi = mi - mk + 1;
179 mj = mj - mk + 1;
179 mj = mj - mk + 1;
180 }
180 }
181
181
182 /* expand match to include neighboring popular lines */
182 /* expand match to include neighboring popular lines */
183 while (mi - mb > a1 && mj - mb > b1 &&
183 while (mi - mb > a1 && mj - mb > b1 &&
184 a[mi - mb - 1].e == b[mj - mb - 1].e)
184 a[mi - mb - 1].e == b[mj - mb - 1].e)
185 mb++;
185 mb++;
186 while (mi + mk < a2 && mj + mk < b2 &&
186 while (mi + mk < a2 && mj + mk < b2 &&
187 a[mi + mk].e == b[mj + mk].e)
187 a[mi + mk].e == b[mj + mk].e)
188 mk++;
188 mk++;
189
189
190 *omi = mi - mb;
190 *omi = mi - mb;
191 *omj = mj - mb;
191 *omj = mj - mb;
192
192
193 return mk + mb;
193 return mk + mb;
194 }
194 }
195
195
196 static struct hunk *recurse(struct line *a, struct line *b, struct pos *pos,
196 static struct hunk *recurse(struct line *a, struct line *b, struct pos *pos,
197 int a1, int a2, int b1, int b2, struct hunk *l)
197 int a1, int a2, int b1, int b2, struct hunk *l)
198 {
198 {
199 int i, j, k;
199 int i, j, k;
200
200
201 while (1) {
201 while (1) {
202 /* find the longest match in this chunk */
202 /* find the longest match in this chunk */
203 k = longest_match(a, b, pos, a1, a2, b1, b2, &i, &j);
203 k = longest_match(a, b, pos, a1, a2, b1, b2, &i, &j);
204 if (!k)
204 if (!k)
205 return l;
205 return l;
206
206
207 /* and recurse on the remaining chunks on either side */
207 /* and recurse on the remaining chunks on either side */
208 l = recurse(a, b, pos, a1, i, b1, j, l);
208 l = recurse(a, b, pos, a1, i, b1, j, l);
209 if (!l)
209 if (!l)
210 return NULL;
210 return NULL;
211
211
212 l->next = (struct hunk *)malloc(sizeof(struct hunk));
212 l->next = (struct hunk *)malloc(sizeof(struct hunk));
213 if (!l->next)
213 if (!l->next)
214 return NULL;
214 return NULL;
215
215
216 l = l->next;
216 l = l->next;
217 l->a1 = i;
217 l->a1 = i;
218 l->a2 = i + k;
218 l->a2 = i + k;
219 l->b1 = j;
219 l->b1 = j;
220 l->b2 = j + k;
220 l->b2 = j + k;
221 l->next = NULL;
221 l->next = NULL;
222
222
223 /* tail-recursion didn't happen, so do equivalent iteration */
223 /* tail-recursion didn't happen, so do equivalent iteration */
224 a1 = i + k;
224 a1 = i + k;
225 b1 = j + k;
225 b1 = j + k;
226 }
226 }
227 }
227 }
228
228
229 static int diff(struct line *a, int an, struct line *b, int bn,
229 static int diff(struct line *a, int an, struct line *b, int bn,
230 struct hunk *base)
230 struct hunk *base)
231 {
231 {
232 struct hunk *curr;
232 struct hunk *curr;
233 struct pos *pos;
233 struct pos *pos;
234 int t, count = 0;
234 int t, count = 0;
235
235
236 /* allocate and fill arrays */
236 /* allocate and fill arrays */
237 t = equatelines(a, an, b, bn);
237 t = equatelines(a, an, b, bn);
238 pos = (struct pos *)calloc(bn ? bn : 1, sizeof(struct pos));
238 pos = (struct pos *)calloc(bn ? bn : 1, sizeof(struct pos));
239
239
240 if (pos && t) {
240 if (pos && t) {
241 /* generate the matching block list */
241 /* generate the matching block list */
242
242
243 curr = recurse(a, b, pos, 0, an, 0, bn, base);
243 curr = recurse(a, b, pos, 0, an, 0, bn, base);
244 if (!curr)
244 if (!curr)
245 return -1;
245 return -1;
246
246
247 /* sentinel end hunk */
247 /* sentinel end hunk */
248 curr->next = (struct hunk *)malloc(sizeof(struct hunk));
248 curr->next = (struct hunk *)malloc(sizeof(struct hunk));
249 if (!curr->next)
249 if (!curr->next)
250 return -1;
250 return -1;
251 curr = curr->next;
251 curr = curr->next;
252 curr->a1 = curr->a2 = an;
252 curr->a1 = curr->a2 = an;
253 curr->b1 = curr->b2 = bn;
253 curr->b1 = curr->b2 = bn;
254 curr->next = NULL;
254 curr->next = NULL;
255 }
255 }
256
256
257 free(pos);
257 free(pos);
258
258
259 /* normalize the hunk list, try to push each hunk towards the end */
259 /* normalize the hunk list, try to push each hunk towards the end */
260 for (curr = base->next; curr; curr = curr->next) {
260 for (curr = base->next; curr; curr = curr->next) {
261 struct hunk *next = curr->next;
261 struct hunk *next = curr->next;
262 int shift = 0;
262 int shift = 0;
263
263
264 if (!next)
264 if (!next)
265 break;
265 break;
266
266
267 if (curr->a2 == next->a1)
267 if (curr->a2 == next->a1)
268 while (curr->a2 + shift < an && curr->b2 + shift < bn
268 while (curr->a2 + shift < an && curr->b2 + shift < bn
269 && !cmp(a + curr->a2 + shift,
269 && !cmp(a + curr->a2 + shift,
270 b + curr->b2 + shift))
270 b + curr->b2 + shift))
271 shift++;
271 shift++;
272 else if (curr->b2 == next->b1)
272 else if (curr->b2 == next->b1)
273 while (curr->b2 + shift < bn && curr->a2 + shift < an
273 while (curr->b2 + shift < bn && curr->a2 + shift < an
274 && !cmp(b + curr->b2 + shift,
274 && !cmp(b + curr->b2 + shift,
275 a + curr->a2 + shift))
275 a + curr->a2 + shift))
276 shift++;
276 shift++;
277 if (!shift)
277 if (!shift)
278 continue;
278 continue;
279 curr->b2 += shift;
279 curr->b2 += shift;
280 next->b1 += shift;
280 next->b1 += shift;
281 curr->a2 += shift;
281 curr->a2 += shift;
282 next->a1 += shift;
282 next->a1 += shift;
283 }
283 }
284
284
285 for (curr = base->next; curr; curr = curr->next)
285 for (curr = base->next; curr; curr = curr->next)
286 count++;
286 count++;
287 return count;
287 return count;
288 }
288 }
289
289
290 static void freehunks(struct hunk *l)
290 static void freehunks(struct hunk *l)
291 {
291 {
292 struct hunk *n;
292 struct hunk *n;
293 for (; l; l = n) {
293 for (; l; l = n) {
294 n = l->next;
294 n = l->next;
295 free(l);
295 free(l);
296 }
296 }
297 }
297 }
298
298
299 static PyObject *blocks(PyObject *self, PyObject *args)
299 static PyObject *blocks(PyObject *self, PyObject *args)
300 {
300 {
301 PyObject *sa, *sb, *rl = NULL, *m;
301 PyObject *sa, *sb, *rl = NULL, *m;
302 struct line *a, *b;
302 struct line *a, *b;
303 struct hunk l, *h;
303 struct hunk l, *h;
304 int an, bn, count, pos = 0;
304 int an, bn, count, pos = 0;
305
305
306 if (!PyArg_ParseTuple(args, "SS:bdiff", &sa, &sb))
306 if (!PyArg_ParseTuple(args, "SS:bdiff", &sa, &sb))
307 return NULL;
307 return NULL;
308
308
309 an = splitlines(PyBytes_AsString(sa), PyBytes_Size(sa), &a);
309 an = splitlines(PyBytes_AsString(sa), PyBytes_Size(sa), &a);
310 bn = splitlines(PyBytes_AsString(sb), PyBytes_Size(sb), &b);
310 bn = splitlines(PyBytes_AsString(sb), PyBytes_Size(sb), &b);
311
311
312 if (!a || !b)
312 if (!a || !b)
313 goto nomem;
313 goto nomem;
314
314
315 l.next = NULL;
315 l.next = NULL;
316 count = diff(a, an, b, bn, &l);
316 count = diff(a, an, b, bn, &l);
317 if (count < 0)
317 if (count < 0)
318 goto nomem;
318 goto nomem;
319
319
320 rl = PyList_New(count);
320 rl = PyList_New(count);
321 if (!rl)
321 if (!rl)
322 goto nomem;
322 goto nomem;
323
323
324 for (h = l.next; h; h = h->next) {
324 for (h = l.next; h; h = h->next) {
325 m = Py_BuildValue("iiii", h->a1, h->a2, h->b1, h->b2);
325 m = Py_BuildValue("iiii", h->a1, h->a2, h->b1, h->b2);
326 PyList_SetItem(rl, pos, m);
326 PyList_SetItem(rl, pos, m);
327 pos++;
327 pos++;
328 }
328 }
329
329
330 nomem:
330 nomem:
331 free(a);
331 free(a);
332 free(b);
332 free(b);
333 freehunks(l.next);
333 freehunks(l.next);
334 return rl ? rl : PyErr_NoMemory();
334 return rl ? rl : PyErr_NoMemory();
335 }
335 }
336
336
337 static PyObject *bdiff(PyObject *self, PyObject *args)
337 static PyObject *bdiff(PyObject *self, PyObject *args)
338 {
338 {
339 char *sa, *sb, *rb;
339 char *sa, *sb, *rb;
340 PyObject *result = NULL;
340 PyObject *result = NULL;
341 struct line *al, *bl;
341 struct line *al, *bl;
342 struct hunk l, *h;
342 struct hunk l, *h;
343 int an, bn, count;
343 int an, bn, count;
344 Py_ssize_t len = 0, la, lb;
344 Py_ssize_t len = 0, la, lb;
345 PyThreadState *_save;
345 PyThreadState *_save;
346
346
347 if (!PyArg_ParseTuple(args, "s#s#:bdiff", &sa, &la, &sb, &lb))
347 if (!PyArg_ParseTuple(args, "s#s#:bdiff", &sa, &la, &sb, &lb))
348 return NULL;
348 return NULL;
349
349
350 _save = PyEval_SaveThread();
350 _save = PyEval_SaveThread();
351 an = splitlines(sa, la, &al);
351 an = splitlines(sa, la, &al);
352 bn = splitlines(sb, lb, &bl);
352 bn = splitlines(sb, lb, &bl);
353 if (!al || !bl)
353 if (!al || !bl)
354 goto nomem;
354 goto nomem;
355
355
356 l.next = NULL;
356 l.next = NULL;
357 count = diff(al, an, bl, bn, &l);
357 count = diff(al, an, bl, bn, &l);
358 if (count < 0)
358 if (count < 0)
359 goto nomem;
359 goto nomem;
360
360
361 /* calculate length of output */
361 /* calculate length of output */
362 la = lb = 0;
362 la = lb = 0;
363 for (h = l.next; h; h = h->next) {
363 for (h = l.next; h; h = h->next) {
364 if (h->a1 != la || h->b1 != lb)
364 if (h->a1 != la || h->b1 != lb)
365 len += 12 + bl[h->b1].l - bl[lb].l;
365 len += 12 + bl[h->b1].l - bl[lb].l;
366 la = h->a2;
366 la = h->a2;
367 lb = h->b2;
367 lb = h->b2;
368 }
368 }
369 PyEval_RestoreThread(_save);
369 PyEval_RestoreThread(_save);
370 _save = NULL;
370 _save = NULL;
371
371
372 result = PyBytes_FromStringAndSize(NULL, len);
372 result = PyBytes_FromStringAndSize(NULL, len);
373
373
374 if (!result)
374 if (!result)
375 goto nomem;
375 goto nomem;
376
376
377 /* build binary patch */
377 /* build binary patch */
378 rb = PyBytes_AsString(result);
378 rb = PyBytes_AsString(result);
379 la = lb = 0;
379 la = lb = 0;
380
380
381 for (h = l.next; h; h = h->next) {
381 for (h = l.next; h; h = h->next) {
382 if (h->a1 != la || h->b1 != lb) {
382 if (h->a1 != la || h->b1 != lb) {
383 len = bl[h->b1].l - bl[lb].l;
383 len = bl[h->b1].l - bl[lb].l;
384 putbe32(al[la].l - al->l, rb);
384
385 putbe32(al[h->a1].l - al->l, rb + 4);
385 #define checkputbe32(__x, __c) \
386 putbe32(len, rb + 8);
386 if (__x > UINT_MAX) { \
387 PyErr_SetString(PyExc_ValueError, \
388 "bdiff: value too large for putbe32"); \
389 goto nomem; \
390 } \
391 putbe32((uint32_t)(__x), __c);
392
393 checkputbe32(al[la].l - al->l, rb);
394 checkputbe32(al[h->a1].l - al->l, rb + 4);
395 checkputbe32(len, rb + 8);
387 memcpy(rb + 12, bl[lb].l, len);
396 memcpy(rb + 12, bl[lb].l, len);
388 rb += 12 + len;
397 rb += 12 + len;
389 }
398 }
390 la = h->a2;
399 la = h->a2;
391 lb = h->b2;
400 lb = h->b2;
392 }
401 }
393
402
394 nomem:
403 nomem:
395 if (_save)
404 if (_save)
396 PyEval_RestoreThread(_save);
405 PyEval_RestoreThread(_save);
397 free(al);
406 free(al);
398 free(bl);
407 free(bl);
399 freehunks(l.next);
408 freehunks(l.next);
400 return result ? result : PyErr_NoMemory();
409 return result ? result : PyErr_NoMemory();
401 }
410 }
402
411
403 /*
412 /*
404 * If allws != 0, remove all whitespace (' ', \t and \r). Otherwise,
413 * If allws != 0, remove all whitespace (' ', \t and \r). Otherwise,
405 * reduce whitespace sequences to a single space and trim remaining whitespace
414 * reduce whitespace sequences to a single space and trim remaining whitespace
406 * from end of lines.
415 * from end of lines.
407 */
416 */
408 static PyObject *fixws(PyObject *self, PyObject *args)
417 static PyObject *fixws(PyObject *self, PyObject *args)
409 {
418 {
410 PyObject *s, *result = NULL;
419 PyObject *s, *result = NULL;
411 char allws, c;
420 char allws, c;
412 const char *r;
421 const char *r;
413 Py_ssize_t i, rlen, wlen = 0;
422 Py_ssize_t i, rlen, wlen = 0;
414 char *w;
423 char *w;
415
424
416 if (!PyArg_ParseTuple(args, "Sb:fixws", &s, &allws))
425 if (!PyArg_ParseTuple(args, "Sb:fixws", &s, &allws))
417 return NULL;
426 return NULL;
418 r = PyBytes_AsString(s);
427 r = PyBytes_AsString(s);
419 rlen = PyBytes_Size(s);
428 rlen = PyBytes_Size(s);
420
429
421 w = (char *)malloc(rlen ? rlen : 1);
430 w = (char *)malloc(rlen ? rlen : 1);
422 if (!w)
431 if (!w)
423 goto nomem;
432 goto nomem;
424
433
425 for (i = 0; i != rlen; i++) {
434 for (i = 0; i != rlen; i++) {
426 c = r[i];
435 c = r[i];
427 if (c == ' ' || c == '\t' || c == '\r') {
436 if (c == ' ' || c == '\t' || c == '\r') {
428 if (!allws && (wlen == 0 || w[wlen - 1] != ' '))
437 if (!allws && (wlen == 0 || w[wlen - 1] != ' '))
429 w[wlen++] = ' ';
438 w[wlen++] = ' ';
430 } else if (c == '\n' && !allws
439 } else if (c == '\n' && !allws
431 && wlen > 0 && w[wlen - 1] == ' ') {
440 && wlen > 0 && w[wlen - 1] == ' ') {
432 w[wlen - 1] = '\n';
441 w[wlen - 1] = '\n';
433 } else {
442 } else {
434 w[wlen++] = c;
443 w[wlen++] = c;
435 }
444 }
436 }
445 }
437
446
438 result = PyBytes_FromStringAndSize(w, wlen);
447 result = PyBytes_FromStringAndSize(w, wlen);
439
448
440 nomem:
449 nomem:
441 free(w);
450 free(w);
442 return result ? result : PyErr_NoMemory();
451 return result ? result : PyErr_NoMemory();
443 }
452 }
444
453
445
454
446 static char mdiff_doc[] = "Efficient binary diff.";
455 static char mdiff_doc[] = "Efficient binary diff.";
447
456
448 static PyMethodDef methods[] = {
457 static PyMethodDef methods[] = {
449 {"bdiff", bdiff, METH_VARARGS, "calculate a binary diff\n"},
458 {"bdiff", bdiff, METH_VARARGS, "calculate a binary diff\n"},
450 {"blocks", blocks, METH_VARARGS, "find a list of matching lines\n"},
459 {"blocks", blocks, METH_VARARGS, "find a list of matching lines\n"},
451 {"fixws", fixws, METH_VARARGS, "normalize diff whitespaces\n"},
460 {"fixws", fixws, METH_VARARGS, "normalize diff whitespaces\n"},
452 {NULL, NULL}
461 {NULL, NULL}
453 };
462 };
454
463
455 #ifdef IS_PY3K
464 #ifdef IS_PY3K
456 static struct PyModuleDef bdiff_module = {
465 static struct PyModuleDef bdiff_module = {
457 PyModuleDef_HEAD_INIT,
466 PyModuleDef_HEAD_INIT,
458 "bdiff",
467 "bdiff",
459 mdiff_doc,
468 mdiff_doc,
460 -1,
469 -1,
461 methods
470 methods
462 };
471 };
463
472
464 PyMODINIT_FUNC PyInit_bdiff(void)
473 PyMODINIT_FUNC PyInit_bdiff(void)
465 {
474 {
466 return PyModule_Create(&bdiff_module);
475 return PyModule_Create(&bdiff_module);
467 }
476 }
468 #else
477 #else
469 PyMODINIT_FUNC initbdiff(void)
478 PyMODINIT_FUNC initbdiff(void)
470 {
479 {
471 Py_InitModule3("bdiff", methods, mdiff_doc);
480 Py_InitModule3("bdiff", methods, mdiff_doc);
472 }
481 }
473 #endif
482 #endif
474
483
General Comments 0
You need to be logged in to leave comments. Login now