##// END OF EJS Templates
patch: fix sort() comparator argument...
Jim Hague -
r5547:77799674 default
parent child Browse files
Show More
@@ -1,1348 +1,1348 b''
1 # patch.py - patch file parsing routines
1 # patch.py - patch file parsing routines
2 #
2 #
3 # Copyright 2006 Brendan Cully <brendan@kublai.com>
3 # Copyright 2006 Brendan Cully <brendan@kublai.com>
4 # Copyright 2007 Chris Mason <chris.mason@oracle.com>
4 # Copyright 2007 Chris Mason <chris.mason@oracle.com>
5 #
5 #
6 # This software may be used and distributed according to the terms
6 # This software may be used and distributed according to the terms
7 # of the GNU General Public License, incorporated herein by reference.
7 # of the GNU General Public License, incorporated herein by reference.
8
8
9 from i18n import _
9 from i18n import _
10 from node import *
10 from node import *
11 import base85, cmdutil, mdiff, util, context, revlog, diffhelpers
11 import base85, cmdutil, mdiff, util, context, revlog, diffhelpers
12 import cStringIO, email.Parser, os, popen2, re, sha, errno
12 import cStringIO, email.Parser, os, popen2, re, sha, errno
13 import sys, tempfile, zlib
13 import sys, tempfile, zlib
14
14
15 class PatchError(Exception):
15 class PatchError(Exception):
16 pass
16 pass
17
17
18 class NoHunks(PatchError):
18 class NoHunks(PatchError):
19 pass
19 pass
20
20
21 # helper functions
21 # helper functions
22
22
23 def copyfile(src, dst, basedir=None):
23 def copyfile(src, dst, basedir=None):
24 if not basedir:
24 if not basedir:
25 basedir = os.getcwd()
25 basedir = os.getcwd()
26
26
27 abssrc, absdst = [os.path.join(basedir, n) for n in (src, dst)]
27 abssrc, absdst = [os.path.join(basedir, n) for n in (src, dst)]
28 if os.path.exists(absdst):
28 if os.path.exists(absdst):
29 raise util.Abort(_("cannot create %s: destination already exists") %
29 raise util.Abort(_("cannot create %s: destination already exists") %
30 dst)
30 dst)
31
31
32 targetdir = os.path.dirname(absdst)
32 targetdir = os.path.dirname(absdst)
33 if not os.path.isdir(targetdir):
33 if not os.path.isdir(targetdir):
34 os.makedirs(targetdir)
34 os.makedirs(targetdir)
35
35
36 util.copyfile(abssrc, absdst)
36 util.copyfile(abssrc, absdst)
37
37
38 # public functions
38 # public functions
39
39
40 def extract(ui, fileobj):
40 def extract(ui, fileobj):
41 '''extract patch from data read from fileobj.
41 '''extract patch from data read from fileobj.
42
42
43 patch can be a normal patch or contained in an email message.
43 patch can be a normal patch or contained in an email message.
44
44
45 return tuple (filename, message, user, date, node, p1, p2).
45 return tuple (filename, message, user, date, node, p1, p2).
46 Any item in the returned tuple can be None. If filename is None,
46 Any item in the returned tuple can be None. If filename is None,
47 fileobj did not contain a patch. Caller must unlink filename when done.'''
47 fileobj did not contain a patch. Caller must unlink filename when done.'''
48
48
49 # attempt to detect the start of a patch
49 # attempt to detect the start of a patch
50 # (this heuristic is borrowed from quilt)
50 # (this heuristic is borrowed from quilt)
51 diffre = re.compile(r'^(?:Index:[ \t]|diff[ \t]|RCS file: |' +
51 diffre = re.compile(r'^(?:Index:[ \t]|diff[ \t]|RCS file: |' +
52 'retrieving revision [0-9]+(\.[0-9]+)*$|' +
52 'retrieving revision [0-9]+(\.[0-9]+)*$|' +
53 '(---|\*\*\*)[ \t])', re.MULTILINE)
53 '(---|\*\*\*)[ \t])', re.MULTILINE)
54
54
55 fd, tmpname = tempfile.mkstemp(prefix='hg-patch-')
55 fd, tmpname = tempfile.mkstemp(prefix='hg-patch-')
56 tmpfp = os.fdopen(fd, 'w')
56 tmpfp = os.fdopen(fd, 'w')
57 try:
57 try:
58 msg = email.Parser.Parser().parse(fileobj)
58 msg = email.Parser.Parser().parse(fileobj)
59
59
60 subject = msg['Subject']
60 subject = msg['Subject']
61 user = msg['From']
61 user = msg['From']
62 gitsendmail = 'git-send-email' in msg.get('X-Mailer', '')
62 gitsendmail = 'git-send-email' in msg.get('X-Mailer', '')
63 # should try to parse msg['Date']
63 # should try to parse msg['Date']
64 date = None
64 date = None
65 nodeid = None
65 nodeid = None
66 branch = None
66 branch = None
67 parents = []
67 parents = []
68
68
69 if subject:
69 if subject:
70 if subject.startswith('[PATCH'):
70 if subject.startswith('[PATCH'):
71 pend = subject.find(']')
71 pend = subject.find(']')
72 if pend >= 0:
72 if pend >= 0:
73 subject = subject[pend+1:].lstrip()
73 subject = subject[pend+1:].lstrip()
74 subject = subject.replace('\n\t', ' ')
74 subject = subject.replace('\n\t', ' ')
75 ui.debug('Subject: %s\n' % subject)
75 ui.debug('Subject: %s\n' % subject)
76 if user:
76 if user:
77 ui.debug('From: %s\n' % user)
77 ui.debug('From: %s\n' % user)
78 diffs_seen = 0
78 diffs_seen = 0
79 ok_types = ('text/plain', 'text/x-diff', 'text/x-patch')
79 ok_types = ('text/plain', 'text/x-diff', 'text/x-patch')
80 message = ''
80 message = ''
81 for part in msg.walk():
81 for part in msg.walk():
82 content_type = part.get_content_type()
82 content_type = part.get_content_type()
83 ui.debug('Content-Type: %s\n' % content_type)
83 ui.debug('Content-Type: %s\n' % content_type)
84 if content_type not in ok_types:
84 if content_type not in ok_types:
85 continue
85 continue
86 payload = part.get_payload(decode=True)
86 payload = part.get_payload(decode=True)
87 m = diffre.search(payload)
87 m = diffre.search(payload)
88 if m:
88 if m:
89 hgpatch = False
89 hgpatch = False
90 ignoretext = False
90 ignoretext = False
91
91
92 ui.debug(_('found patch at byte %d\n') % m.start(0))
92 ui.debug(_('found patch at byte %d\n') % m.start(0))
93 diffs_seen += 1
93 diffs_seen += 1
94 cfp = cStringIO.StringIO()
94 cfp = cStringIO.StringIO()
95 for line in payload[:m.start(0)].splitlines():
95 for line in payload[:m.start(0)].splitlines():
96 if line.startswith('# HG changeset patch'):
96 if line.startswith('# HG changeset patch'):
97 ui.debug(_('patch generated by hg export\n'))
97 ui.debug(_('patch generated by hg export\n'))
98 hgpatch = True
98 hgpatch = True
99 # drop earlier commit message content
99 # drop earlier commit message content
100 cfp.seek(0)
100 cfp.seek(0)
101 cfp.truncate()
101 cfp.truncate()
102 subject = None
102 subject = None
103 elif hgpatch:
103 elif hgpatch:
104 if line.startswith('# User '):
104 if line.startswith('# User '):
105 user = line[7:]
105 user = line[7:]
106 ui.debug('From: %s\n' % user)
106 ui.debug('From: %s\n' % user)
107 elif line.startswith("# Date "):
107 elif line.startswith("# Date "):
108 date = line[7:]
108 date = line[7:]
109 elif line.startswith("# Branch "):
109 elif line.startswith("# Branch "):
110 branch = line[9:]
110 branch = line[9:]
111 elif line.startswith("# Node ID "):
111 elif line.startswith("# Node ID "):
112 nodeid = line[10:]
112 nodeid = line[10:]
113 elif line.startswith("# Parent "):
113 elif line.startswith("# Parent "):
114 parents.append(line[10:])
114 parents.append(line[10:])
115 elif line == '---' and gitsendmail:
115 elif line == '---' and gitsendmail:
116 ignoretext = True
116 ignoretext = True
117 if not line.startswith('# ') and not ignoretext:
117 if not line.startswith('# ') and not ignoretext:
118 cfp.write(line)
118 cfp.write(line)
119 cfp.write('\n')
119 cfp.write('\n')
120 message = cfp.getvalue()
120 message = cfp.getvalue()
121 if tmpfp:
121 if tmpfp:
122 tmpfp.write(payload)
122 tmpfp.write(payload)
123 if not payload.endswith('\n'):
123 if not payload.endswith('\n'):
124 tmpfp.write('\n')
124 tmpfp.write('\n')
125 elif not diffs_seen and message and content_type == 'text/plain':
125 elif not diffs_seen and message and content_type == 'text/plain':
126 message += '\n' + payload
126 message += '\n' + payload
127 except:
127 except:
128 tmpfp.close()
128 tmpfp.close()
129 os.unlink(tmpname)
129 os.unlink(tmpname)
130 raise
130 raise
131
131
132 if subject and not message.startswith(subject):
132 if subject and not message.startswith(subject):
133 message = '%s\n%s' % (subject, message)
133 message = '%s\n%s' % (subject, message)
134 tmpfp.close()
134 tmpfp.close()
135 if not diffs_seen:
135 if not diffs_seen:
136 os.unlink(tmpname)
136 os.unlink(tmpname)
137 return None, message, user, date, branch, None, None, None
137 return None, message, user, date, branch, None, None, None
138 p1 = parents and parents.pop(0) or None
138 p1 = parents and parents.pop(0) or None
139 p2 = parents and parents.pop(0) or None
139 p2 = parents and parents.pop(0) or None
140 return tmpname, message, user, date, branch, nodeid, p1, p2
140 return tmpname, message, user, date, branch, nodeid, p1, p2
141
141
142 GP_PATCH = 1 << 0 # we have to run patch
142 GP_PATCH = 1 << 0 # we have to run patch
143 GP_FILTER = 1 << 1 # there's some copy/rename operation
143 GP_FILTER = 1 << 1 # there's some copy/rename operation
144 GP_BINARY = 1 << 2 # there's a binary patch
144 GP_BINARY = 1 << 2 # there's a binary patch
145
145
146 def readgitpatch(fp, firstline=None):
146 def readgitpatch(fp, firstline=None):
147 """extract git-style metadata about patches from <patchname>"""
147 """extract git-style metadata about patches from <patchname>"""
148 class gitpatch:
148 class gitpatch:
149 "op is one of ADD, DELETE, RENAME, MODIFY or COPY"
149 "op is one of ADD, DELETE, RENAME, MODIFY or COPY"
150 def __init__(self, path):
150 def __init__(self, path):
151 self.path = path
151 self.path = path
152 self.oldpath = None
152 self.oldpath = None
153 self.mode = None
153 self.mode = None
154 self.op = 'MODIFY'
154 self.op = 'MODIFY'
155 self.lineno = 0
155 self.lineno = 0
156 self.binary = False
156 self.binary = False
157
157
158 def reader(fp, firstline):
158 def reader(fp, firstline):
159 if firstline is not None:
159 if firstline is not None:
160 yield firstline
160 yield firstline
161 for line in fp:
161 for line in fp:
162 yield line
162 yield line
163
163
164 # Filter patch for git information
164 # Filter patch for git information
165 gitre = re.compile('diff --git a/(.*) b/(.*)')
165 gitre = re.compile('diff --git a/(.*) b/(.*)')
166 gp = None
166 gp = None
167 gitpatches = []
167 gitpatches = []
168 # Can have a git patch with only metadata, causing patch to complain
168 # Can have a git patch with only metadata, causing patch to complain
169 dopatch = 0
169 dopatch = 0
170
170
171 lineno = 0
171 lineno = 0
172 for line in reader(fp, firstline):
172 for line in reader(fp, firstline):
173 lineno += 1
173 lineno += 1
174 if line.startswith('diff --git'):
174 if line.startswith('diff --git'):
175 m = gitre.match(line)
175 m = gitre.match(line)
176 if m:
176 if m:
177 if gp:
177 if gp:
178 gitpatches.append(gp)
178 gitpatches.append(gp)
179 src, dst = m.group(1, 2)
179 src, dst = m.group(1, 2)
180 gp = gitpatch(dst)
180 gp = gitpatch(dst)
181 gp.lineno = lineno
181 gp.lineno = lineno
182 elif gp:
182 elif gp:
183 if line.startswith('--- '):
183 if line.startswith('--- '):
184 if gp.op in ('COPY', 'RENAME'):
184 if gp.op in ('COPY', 'RENAME'):
185 dopatch |= GP_FILTER
185 dopatch |= GP_FILTER
186 gitpatches.append(gp)
186 gitpatches.append(gp)
187 gp = None
187 gp = None
188 dopatch |= GP_PATCH
188 dopatch |= GP_PATCH
189 continue
189 continue
190 if line.startswith('rename from '):
190 if line.startswith('rename from '):
191 gp.op = 'RENAME'
191 gp.op = 'RENAME'
192 gp.oldpath = line[12:].rstrip()
192 gp.oldpath = line[12:].rstrip()
193 elif line.startswith('rename to '):
193 elif line.startswith('rename to '):
194 gp.path = line[10:].rstrip()
194 gp.path = line[10:].rstrip()
195 elif line.startswith('copy from '):
195 elif line.startswith('copy from '):
196 gp.op = 'COPY'
196 gp.op = 'COPY'
197 gp.oldpath = line[10:].rstrip()
197 gp.oldpath = line[10:].rstrip()
198 elif line.startswith('copy to '):
198 elif line.startswith('copy to '):
199 gp.path = line[8:].rstrip()
199 gp.path = line[8:].rstrip()
200 elif line.startswith('deleted file'):
200 elif line.startswith('deleted file'):
201 gp.op = 'DELETE'
201 gp.op = 'DELETE'
202 elif line.startswith('new file mode '):
202 elif line.startswith('new file mode '):
203 gp.op = 'ADD'
203 gp.op = 'ADD'
204 gp.mode = int(line.rstrip()[-6:], 8)
204 gp.mode = int(line.rstrip()[-6:], 8)
205 elif line.startswith('new mode '):
205 elif line.startswith('new mode '):
206 gp.mode = int(line.rstrip()[-6:], 8)
206 gp.mode = int(line.rstrip()[-6:], 8)
207 elif line.startswith('GIT binary patch'):
207 elif line.startswith('GIT binary patch'):
208 dopatch |= GP_BINARY
208 dopatch |= GP_BINARY
209 gp.binary = True
209 gp.binary = True
210 if gp:
210 if gp:
211 gitpatches.append(gp)
211 gitpatches.append(gp)
212
212
213 if not gitpatches:
213 if not gitpatches:
214 dopatch = GP_PATCH
214 dopatch = GP_PATCH
215
215
216 return (dopatch, gitpatches)
216 return (dopatch, gitpatches)
217
217
218 def patch(patchname, ui, strip=1, cwd=None, files={}):
218 def patch(patchname, ui, strip=1, cwd=None, files={}):
219 """apply <patchname> to the working directory.
219 """apply <patchname> to the working directory.
220 returns whether patch was applied with fuzz factor."""
220 returns whether patch was applied with fuzz factor."""
221 patcher = ui.config('ui', 'patch')
221 patcher = ui.config('ui', 'patch')
222 args = []
222 args = []
223 try:
223 try:
224 if patcher:
224 if patcher:
225 return externalpatch(patcher, args, patchname, ui, strip, cwd,
225 return externalpatch(patcher, args, patchname, ui, strip, cwd,
226 files)
226 files)
227 else:
227 else:
228 try:
228 try:
229 return internalpatch(patchname, ui, strip, cwd, files)
229 return internalpatch(patchname, ui, strip, cwd, files)
230 except NoHunks:
230 except NoHunks:
231 patcher = util.find_exe('gpatch') or util.find_exe('patch')
231 patcher = util.find_exe('gpatch') or util.find_exe('patch')
232 ui.debug('no valid hunks found; trying with %r instead\n' %
232 ui.debug('no valid hunks found; trying with %r instead\n' %
233 patcher)
233 patcher)
234 if util.needbinarypatch():
234 if util.needbinarypatch():
235 args.append('--binary')
235 args.append('--binary')
236 return externalpatch(patcher, args, patchname, ui, strip, cwd,
236 return externalpatch(patcher, args, patchname, ui, strip, cwd,
237 files)
237 files)
238 except PatchError, err:
238 except PatchError, err:
239 s = str(err)
239 s = str(err)
240 if s:
240 if s:
241 raise util.Abort(s)
241 raise util.Abort(s)
242 else:
242 else:
243 raise util.Abort(_('patch failed to apply'))
243 raise util.Abort(_('patch failed to apply'))
244
244
245 def externalpatch(patcher, args, patchname, ui, strip, cwd, files):
245 def externalpatch(patcher, args, patchname, ui, strip, cwd, files):
246 """use <patcher> to apply <patchname> to the working directory.
246 """use <patcher> to apply <patchname> to the working directory.
247 returns whether patch was applied with fuzz factor."""
247 returns whether patch was applied with fuzz factor."""
248
248
249 fuzz = False
249 fuzz = False
250 if cwd:
250 if cwd:
251 args.append('-d %s' % util.shellquote(cwd))
251 args.append('-d %s' % util.shellquote(cwd))
252 fp = util.popen('%s %s -p%d < %s' % (patcher, ' '.join(args), strip,
252 fp = util.popen('%s %s -p%d < %s' % (patcher, ' '.join(args), strip,
253 util.shellquote(patchname)))
253 util.shellquote(patchname)))
254
254
255 for line in fp:
255 for line in fp:
256 line = line.rstrip()
256 line = line.rstrip()
257 ui.note(line + '\n')
257 ui.note(line + '\n')
258 if line.startswith('patching file '):
258 if line.startswith('patching file '):
259 pf = util.parse_patch_output(line)
259 pf = util.parse_patch_output(line)
260 printed_file = False
260 printed_file = False
261 files.setdefault(pf, (None, None))
261 files.setdefault(pf, (None, None))
262 elif line.find('with fuzz') >= 0:
262 elif line.find('with fuzz') >= 0:
263 fuzz = True
263 fuzz = True
264 if not printed_file:
264 if not printed_file:
265 ui.warn(pf + '\n')
265 ui.warn(pf + '\n')
266 printed_file = True
266 printed_file = True
267 ui.warn(line + '\n')
267 ui.warn(line + '\n')
268 elif line.find('saving rejects to file') >= 0:
268 elif line.find('saving rejects to file') >= 0:
269 ui.warn(line + '\n')
269 ui.warn(line + '\n')
270 elif line.find('FAILED') >= 0:
270 elif line.find('FAILED') >= 0:
271 if not printed_file:
271 if not printed_file:
272 ui.warn(pf + '\n')
272 ui.warn(pf + '\n')
273 printed_file = True
273 printed_file = True
274 ui.warn(line + '\n')
274 ui.warn(line + '\n')
275 code = fp.close()
275 code = fp.close()
276 if code:
276 if code:
277 raise PatchError(_("patch command failed: %s") %
277 raise PatchError(_("patch command failed: %s") %
278 util.explain_exit(code)[0])
278 util.explain_exit(code)[0])
279 return fuzz
279 return fuzz
280
280
281 def internalpatch(patchobj, ui, strip, cwd, files={}):
281 def internalpatch(patchobj, ui, strip, cwd, files={}):
282 """use builtin patch to apply <patchobj> to the working directory.
282 """use builtin patch to apply <patchobj> to the working directory.
283 returns whether patch was applied with fuzz factor."""
283 returns whether patch was applied with fuzz factor."""
284 try:
284 try:
285 fp = file(patchobj, 'rb')
285 fp = file(patchobj, 'rb')
286 except TypeError:
286 except TypeError:
287 fp = patchobj
287 fp = patchobj
288 if cwd:
288 if cwd:
289 curdir = os.getcwd()
289 curdir = os.getcwd()
290 os.chdir(cwd)
290 os.chdir(cwd)
291 try:
291 try:
292 ret = applydiff(ui, fp, files, strip=strip)
292 ret = applydiff(ui, fp, files, strip=strip)
293 finally:
293 finally:
294 if cwd:
294 if cwd:
295 os.chdir(curdir)
295 os.chdir(curdir)
296 if ret < 0:
296 if ret < 0:
297 raise PatchError
297 raise PatchError
298 return ret > 0
298 return ret > 0
299
299
300 # @@ -start,len +start,len @@ or @@ -start +start @@ if len is 1
300 # @@ -start,len +start,len @@ or @@ -start +start @@ if len is 1
301 unidesc = re.compile('@@ -(\d+)(,(\d+))? \+(\d+)(,(\d+))? @@')
301 unidesc = re.compile('@@ -(\d+)(,(\d+))? \+(\d+)(,(\d+))? @@')
302 contextdesc = re.compile('(---|\*\*\*) (\d+)(,(\d+))? (---|\*\*\*)')
302 contextdesc = re.compile('(---|\*\*\*) (\d+)(,(\d+))? (---|\*\*\*)')
303
303
304 class patchfile:
304 class patchfile:
305 def __init__(self, ui, fname):
305 def __init__(self, ui, fname):
306 self.fname = fname
306 self.fname = fname
307 self.ui = ui
307 self.ui = ui
308 try:
308 try:
309 fp = file(fname, 'rb')
309 fp = file(fname, 'rb')
310 self.lines = fp.readlines()
310 self.lines = fp.readlines()
311 self.exists = True
311 self.exists = True
312 except IOError:
312 except IOError:
313 dirname = os.path.dirname(fname)
313 dirname = os.path.dirname(fname)
314 if dirname and not os.path.isdir(dirname):
314 if dirname and not os.path.isdir(dirname):
315 dirs = dirname.split(os.path.sep)
315 dirs = dirname.split(os.path.sep)
316 d = ""
316 d = ""
317 for x in dirs:
317 for x in dirs:
318 d = os.path.join(d, x)
318 d = os.path.join(d, x)
319 if not os.path.isdir(d):
319 if not os.path.isdir(d):
320 os.mkdir(d)
320 os.mkdir(d)
321 self.lines = []
321 self.lines = []
322 self.exists = False
322 self.exists = False
323
323
324 self.hash = {}
324 self.hash = {}
325 self.dirty = 0
325 self.dirty = 0
326 self.offset = 0
326 self.offset = 0
327 self.rej = []
327 self.rej = []
328 self.fileprinted = False
328 self.fileprinted = False
329 self.printfile(False)
329 self.printfile(False)
330 self.hunks = 0
330 self.hunks = 0
331
331
332 def printfile(self, warn):
332 def printfile(self, warn):
333 if self.fileprinted:
333 if self.fileprinted:
334 return
334 return
335 if warn or self.ui.verbose:
335 if warn or self.ui.verbose:
336 self.fileprinted = True
336 self.fileprinted = True
337 s = _("patching file %s\n") % self.fname
337 s = _("patching file %s\n") % self.fname
338 if warn:
338 if warn:
339 self.ui.warn(s)
339 self.ui.warn(s)
340 else:
340 else:
341 self.ui.note(s)
341 self.ui.note(s)
342
342
343
343
344 def findlines(self, l, linenum):
344 def findlines(self, l, linenum):
345 # looks through the hash and finds candidate lines. The
345 # looks through the hash and finds candidate lines. The
346 # result is a list of line numbers sorted based on distance
346 # result is a list of line numbers sorted based on distance
347 # from linenum
347 # from linenum
348 def sorter(a, b):
348 def sorter(a, b):
349 vala = abs(a - linenum)
349 vala = abs(a - linenum)
350 valb = abs(b - linenum)
350 valb = abs(b - linenum)
351 return cmp(vala, valb)
351 return cmp(vala, valb)
352
352
353 try:
353 try:
354 cand = self.hash[l]
354 cand = self.hash[l]
355 except:
355 except:
356 return []
356 return []
357
357
358 if len(cand) > 1:
358 if len(cand) > 1:
359 # resort our list of potentials forward then back.
359 # resort our list of potentials forward then back.
360 cand.sort(cmp=sorter)
360 cand.sort(sorter)
361 return cand
361 return cand
362
362
363 def hashlines(self):
363 def hashlines(self):
364 self.hash = {}
364 self.hash = {}
365 for x in xrange(len(self.lines)):
365 for x in xrange(len(self.lines)):
366 s = self.lines[x]
366 s = self.lines[x]
367 self.hash.setdefault(s, []).append(x)
367 self.hash.setdefault(s, []).append(x)
368
368
369 def write_rej(self):
369 def write_rej(self):
370 # our rejects are a little different from patch(1). This always
370 # our rejects are a little different from patch(1). This always
371 # creates rejects in the same form as the original patch. A file
371 # creates rejects in the same form as the original patch. A file
372 # header is inserted so that you can run the reject through patch again
372 # header is inserted so that you can run the reject through patch again
373 # without having to type the filename.
373 # without having to type the filename.
374
374
375 if not self.rej:
375 if not self.rej:
376 return
376 return
377 if self.hunks != 1:
377 if self.hunks != 1:
378 hunkstr = "s"
378 hunkstr = "s"
379 else:
379 else:
380 hunkstr = ""
380 hunkstr = ""
381
381
382 fname = self.fname + ".rej"
382 fname = self.fname + ".rej"
383 self.ui.warn(
383 self.ui.warn(
384 _("%d out of %d hunk%s FAILED -- saving rejects to file %s\n") %
384 _("%d out of %d hunk%s FAILED -- saving rejects to file %s\n") %
385 (len(self.rej), self.hunks, hunkstr, fname))
385 (len(self.rej), self.hunks, hunkstr, fname))
386 try: os.unlink(fname)
386 try: os.unlink(fname)
387 except:
387 except:
388 pass
388 pass
389 fp = file(fname, 'wb')
389 fp = file(fname, 'wb')
390 base = os.path.basename(self.fname)
390 base = os.path.basename(self.fname)
391 fp.write("--- %s\n+++ %s\n" % (base, base))
391 fp.write("--- %s\n+++ %s\n" % (base, base))
392 for x in self.rej:
392 for x in self.rej:
393 for l in x.hunk:
393 for l in x.hunk:
394 fp.write(l)
394 fp.write(l)
395 if l[-1] != '\n':
395 if l[-1] != '\n':
396 fp.write("\n\ No newline at end of file\n")
396 fp.write("\n\ No newline at end of file\n")
397
397
398 def write(self, dest=None):
398 def write(self, dest=None):
399 if self.dirty:
399 if self.dirty:
400 if not dest:
400 if not dest:
401 dest = self.fname
401 dest = self.fname
402 st = None
402 st = None
403 try:
403 try:
404 st = os.lstat(dest)
404 st = os.lstat(dest)
405 except OSError, inst:
405 except OSError, inst:
406 if inst.errno != errno.ENOENT:
406 if inst.errno != errno.ENOENT:
407 raise
407 raise
408 if st and st.st_nlink > 1:
408 if st and st.st_nlink > 1:
409 os.unlink(dest)
409 os.unlink(dest)
410 fp = file(dest, 'wb')
410 fp = file(dest, 'wb')
411 if st and st.st_nlink > 1:
411 if st and st.st_nlink > 1:
412 os.chmod(dest, st.st_mode)
412 os.chmod(dest, st.st_mode)
413 fp.writelines(self.lines)
413 fp.writelines(self.lines)
414 fp.close()
414 fp.close()
415
415
416 def close(self):
416 def close(self):
417 self.write()
417 self.write()
418 self.write_rej()
418 self.write_rej()
419
419
420 def apply(self, h, reverse):
420 def apply(self, h, reverse):
421 if not h.complete():
421 if not h.complete():
422 raise PatchError(_("bad hunk #%d %s (%d %d %d %d)") %
422 raise PatchError(_("bad hunk #%d %s (%d %d %d %d)") %
423 (h.number, h.desc, len(h.a), h.lena, len(h.b),
423 (h.number, h.desc, len(h.a), h.lena, len(h.b),
424 h.lenb))
424 h.lenb))
425
425
426 self.hunks += 1
426 self.hunks += 1
427 if reverse:
427 if reverse:
428 h.reverse()
428 h.reverse()
429
429
430 if self.exists and h.createfile():
430 if self.exists and h.createfile():
431 self.ui.warn(_("file %s already exists\n") % self.fname)
431 self.ui.warn(_("file %s already exists\n") % self.fname)
432 self.rej.append(h)
432 self.rej.append(h)
433 return -1
433 return -1
434
434
435 if isinstance(h, binhunk):
435 if isinstance(h, binhunk):
436 if h.rmfile():
436 if h.rmfile():
437 os.unlink(self.fname)
437 os.unlink(self.fname)
438 else:
438 else:
439 self.lines[:] = h.new()
439 self.lines[:] = h.new()
440 self.offset += len(h.new())
440 self.offset += len(h.new())
441 self.dirty = 1
441 self.dirty = 1
442 return 0
442 return 0
443
443
444 # fast case first, no offsets, no fuzz
444 # fast case first, no offsets, no fuzz
445 old = h.old()
445 old = h.old()
446 # patch starts counting at 1 unless we are adding the file
446 # patch starts counting at 1 unless we are adding the file
447 if h.starta == 0:
447 if h.starta == 0:
448 start = 0
448 start = 0
449 else:
449 else:
450 start = h.starta + self.offset - 1
450 start = h.starta + self.offset - 1
451 orig_start = start
451 orig_start = start
452 if diffhelpers.testhunk(old, self.lines, start) == 0:
452 if diffhelpers.testhunk(old, self.lines, start) == 0:
453 if h.rmfile():
453 if h.rmfile():
454 os.unlink(self.fname)
454 os.unlink(self.fname)
455 else:
455 else:
456 self.lines[start : start + h.lena] = h.new()
456 self.lines[start : start + h.lena] = h.new()
457 self.offset += h.lenb - h.lena
457 self.offset += h.lenb - h.lena
458 self.dirty = 1
458 self.dirty = 1
459 return 0
459 return 0
460
460
461 # ok, we couldn't match the hunk. Lets look for offsets and fuzz it
461 # ok, we couldn't match the hunk. Lets look for offsets and fuzz it
462 self.hashlines()
462 self.hashlines()
463 if h.hunk[-1][0] != ' ':
463 if h.hunk[-1][0] != ' ':
464 # if the hunk tried to put something at the bottom of the file
464 # if the hunk tried to put something at the bottom of the file
465 # override the start line and use eof here
465 # override the start line and use eof here
466 search_start = len(self.lines)
466 search_start = len(self.lines)
467 else:
467 else:
468 search_start = orig_start
468 search_start = orig_start
469
469
470 for fuzzlen in xrange(3):
470 for fuzzlen in xrange(3):
471 for toponly in [ True, False ]:
471 for toponly in [ True, False ]:
472 old = h.old(fuzzlen, toponly)
472 old = h.old(fuzzlen, toponly)
473
473
474 cand = self.findlines(old[0][1:], search_start)
474 cand = self.findlines(old[0][1:], search_start)
475 for l in cand:
475 for l in cand:
476 if diffhelpers.testhunk(old, self.lines, l) == 0:
476 if diffhelpers.testhunk(old, self.lines, l) == 0:
477 newlines = h.new(fuzzlen, toponly)
477 newlines = h.new(fuzzlen, toponly)
478 self.lines[l : l + len(old)] = newlines
478 self.lines[l : l + len(old)] = newlines
479 self.offset += len(newlines) - len(old)
479 self.offset += len(newlines) - len(old)
480 self.dirty = 1
480 self.dirty = 1
481 if fuzzlen:
481 if fuzzlen:
482 fuzzstr = "with fuzz %d " % fuzzlen
482 fuzzstr = "with fuzz %d " % fuzzlen
483 f = self.ui.warn
483 f = self.ui.warn
484 self.printfile(True)
484 self.printfile(True)
485 else:
485 else:
486 fuzzstr = ""
486 fuzzstr = ""
487 f = self.ui.note
487 f = self.ui.note
488 offset = l - orig_start - fuzzlen
488 offset = l - orig_start - fuzzlen
489 if offset == 1:
489 if offset == 1:
490 linestr = "line"
490 linestr = "line"
491 else:
491 else:
492 linestr = "lines"
492 linestr = "lines"
493 f(_("Hunk #%d succeeded at %d %s(offset %d %s).\n") %
493 f(_("Hunk #%d succeeded at %d %s(offset %d %s).\n") %
494 (h.number, l+1, fuzzstr, offset, linestr))
494 (h.number, l+1, fuzzstr, offset, linestr))
495 return fuzzlen
495 return fuzzlen
496 self.printfile(True)
496 self.printfile(True)
497 self.ui.warn(_("Hunk #%d FAILED at %d\n") % (h.number, orig_start))
497 self.ui.warn(_("Hunk #%d FAILED at %d\n") % (h.number, orig_start))
498 self.rej.append(h)
498 self.rej.append(h)
499 return -1
499 return -1
500
500
501 class hunk:
501 class hunk:
502 def __init__(self, desc, num, lr, context):
502 def __init__(self, desc, num, lr, context):
503 self.number = num
503 self.number = num
504 self.desc = desc
504 self.desc = desc
505 self.hunk = [ desc ]
505 self.hunk = [ desc ]
506 self.a = []
506 self.a = []
507 self.b = []
507 self.b = []
508 if context:
508 if context:
509 self.read_context_hunk(lr)
509 self.read_context_hunk(lr)
510 else:
510 else:
511 self.read_unified_hunk(lr)
511 self.read_unified_hunk(lr)
512
512
513 def read_unified_hunk(self, lr):
513 def read_unified_hunk(self, lr):
514 m = unidesc.match(self.desc)
514 m = unidesc.match(self.desc)
515 if not m:
515 if not m:
516 raise PatchError(_("bad hunk #%d") % self.number)
516 raise PatchError(_("bad hunk #%d") % self.number)
517 self.starta, foo, self.lena, self.startb, foo2, self.lenb = m.groups()
517 self.starta, foo, self.lena, self.startb, foo2, self.lenb = m.groups()
518 if self.lena == None:
518 if self.lena == None:
519 self.lena = 1
519 self.lena = 1
520 else:
520 else:
521 self.lena = int(self.lena)
521 self.lena = int(self.lena)
522 if self.lenb == None:
522 if self.lenb == None:
523 self.lenb = 1
523 self.lenb = 1
524 else:
524 else:
525 self.lenb = int(self.lenb)
525 self.lenb = int(self.lenb)
526 self.starta = int(self.starta)
526 self.starta = int(self.starta)
527 self.startb = int(self.startb)
527 self.startb = int(self.startb)
528 diffhelpers.addlines(lr.fp, self.hunk, self.lena, self.lenb, self.a, self.b)
528 diffhelpers.addlines(lr.fp, self.hunk, self.lena, self.lenb, self.a, self.b)
529 # if we hit eof before finishing out the hunk, the last line will
529 # if we hit eof before finishing out the hunk, the last line will
530 # be zero length. Lets try to fix it up.
530 # be zero length. Lets try to fix it up.
531 while len(self.hunk[-1]) == 0:
531 while len(self.hunk[-1]) == 0:
532 del self.hunk[-1]
532 del self.hunk[-1]
533 del self.a[-1]
533 del self.a[-1]
534 del self.b[-1]
534 del self.b[-1]
535 self.lena -= 1
535 self.lena -= 1
536 self.lenb -= 1
536 self.lenb -= 1
537
537
538 def read_context_hunk(self, lr):
538 def read_context_hunk(self, lr):
539 self.desc = lr.readline()
539 self.desc = lr.readline()
540 m = contextdesc.match(self.desc)
540 m = contextdesc.match(self.desc)
541 if not m:
541 if not m:
542 raise PatchError(_("bad hunk #%d") % self.number)
542 raise PatchError(_("bad hunk #%d") % self.number)
543 foo, self.starta, foo2, aend, foo3 = m.groups()
543 foo, self.starta, foo2, aend, foo3 = m.groups()
544 self.starta = int(self.starta)
544 self.starta = int(self.starta)
545 if aend == None:
545 if aend == None:
546 aend = self.starta
546 aend = self.starta
547 self.lena = int(aend) - self.starta
547 self.lena = int(aend) - self.starta
548 if self.starta:
548 if self.starta:
549 self.lena += 1
549 self.lena += 1
550 for x in xrange(self.lena):
550 for x in xrange(self.lena):
551 l = lr.readline()
551 l = lr.readline()
552 if l.startswith('---'):
552 if l.startswith('---'):
553 lr.push(l)
553 lr.push(l)
554 break
554 break
555 s = l[2:]
555 s = l[2:]
556 if l.startswith('- ') or l.startswith('! '):
556 if l.startswith('- ') or l.startswith('! '):
557 u = '-' + s
557 u = '-' + s
558 elif l.startswith(' '):
558 elif l.startswith(' '):
559 u = ' ' + s
559 u = ' ' + s
560 else:
560 else:
561 raise PatchError(_("bad hunk #%d old text line %d") %
561 raise PatchError(_("bad hunk #%d old text line %d") %
562 (self.number, x))
562 (self.number, x))
563 self.a.append(u)
563 self.a.append(u)
564 self.hunk.append(u)
564 self.hunk.append(u)
565
565
566 l = lr.readline()
566 l = lr.readline()
567 if l.startswith('\ '):
567 if l.startswith('\ '):
568 s = self.a[-1][:-1]
568 s = self.a[-1][:-1]
569 self.a[-1] = s
569 self.a[-1] = s
570 self.hunk[-1] = s
570 self.hunk[-1] = s
571 l = lr.readline()
571 l = lr.readline()
572 m = contextdesc.match(l)
572 m = contextdesc.match(l)
573 if not m:
573 if not m:
574 raise PatchError(_("bad hunk #%d") % self.number)
574 raise PatchError(_("bad hunk #%d") % self.number)
575 foo, self.startb, foo2, bend, foo3 = m.groups()
575 foo, self.startb, foo2, bend, foo3 = m.groups()
576 self.startb = int(self.startb)
576 self.startb = int(self.startb)
577 if bend == None:
577 if bend == None:
578 bend = self.startb
578 bend = self.startb
579 self.lenb = int(bend) - self.startb
579 self.lenb = int(bend) - self.startb
580 if self.startb:
580 if self.startb:
581 self.lenb += 1
581 self.lenb += 1
582 hunki = 1
582 hunki = 1
583 for x in xrange(self.lenb):
583 for x in xrange(self.lenb):
584 l = lr.readline()
584 l = lr.readline()
585 if l.startswith('\ '):
585 if l.startswith('\ '):
586 s = self.b[-1][:-1]
586 s = self.b[-1][:-1]
587 self.b[-1] = s
587 self.b[-1] = s
588 self.hunk[hunki-1] = s
588 self.hunk[hunki-1] = s
589 continue
589 continue
590 if not l:
590 if not l:
591 lr.push(l)
591 lr.push(l)
592 break
592 break
593 s = l[2:]
593 s = l[2:]
594 if l.startswith('+ ') or l.startswith('! '):
594 if l.startswith('+ ') or l.startswith('! '):
595 u = '+' + s
595 u = '+' + s
596 elif l.startswith(' '):
596 elif l.startswith(' '):
597 u = ' ' + s
597 u = ' ' + s
598 elif len(self.b) == 0:
598 elif len(self.b) == 0:
599 # this can happen when the hunk does not add any lines
599 # this can happen when the hunk does not add any lines
600 lr.push(l)
600 lr.push(l)
601 break
601 break
602 else:
602 else:
603 raise PatchError(_("bad hunk #%d old text line %d") %
603 raise PatchError(_("bad hunk #%d old text line %d") %
604 (self.number, x))
604 (self.number, x))
605 self.b.append(s)
605 self.b.append(s)
606 while True:
606 while True:
607 if hunki >= len(self.hunk):
607 if hunki >= len(self.hunk):
608 h = ""
608 h = ""
609 else:
609 else:
610 h = self.hunk[hunki]
610 h = self.hunk[hunki]
611 hunki += 1
611 hunki += 1
612 if h == u:
612 if h == u:
613 break
613 break
614 elif h.startswith('-'):
614 elif h.startswith('-'):
615 continue
615 continue
616 else:
616 else:
617 self.hunk.insert(hunki-1, u)
617 self.hunk.insert(hunki-1, u)
618 break
618 break
619
619
620 if not self.a:
620 if not self.a:
621 # this happens when lines were only added to the hunk
621 # this happens when lines were only added to the hunk
622 for x in self.hunk:
622 for x in self.hunk:
623 if x.startswith('-') or x.startswith(' '):
623 if x.startswith('-') or x.startswith(' '):
624 self.a.append(x)
624 self.a.append(x)
625 if not self.b:
625 if not self.b:
626 # this happens when lines were only deleted from the hunk
626 # this happens when lines were only deleted from the hunk
627 for x in self.hunk:
627 for x in self.hunk:
628 if x.startswith('+') or x.startswith(' '):
628 if x.startswith('+') or x.startswith(' '):
629 self.b.append(x[1:])
629 self.b.append(x[1:])
630 # @@ -start,len +start,len @@
630 # @@ -start,len +start,len @@
631 self.desc = "@@ -%d,%d +%d,%d @@\n" % (self.starta, self.lena,
631 self.desc = "@@ -%d,%d +%d,%d @@\n" % (self.starta, self.lena,
632 self.startb, self.lenb)
632 self.startb, self.lenb)
633 self.hunk[0] = self.desc
633 self.hunk[0] = self.desc
634
634
635 def reverse(self):
635 def reverse(self):
636 origlena = self.lena
636 origlena = self.lena
637 origstarta = self.starta
637 origstarta = self.starta
638 self.lena = self.lenb
638 self.lena = self.lenb
639 self.starta = self.startb
639 self.starta = self.startb
640 self.lenb = origlena
640 self.lenb = origlena
641 self.startb = origstarta
641 self.startb = origstarta
642 self.a = []
642 self.a = []
643 self.b = []
643 self.b = []
644 # self.hunk[0] is the @@ description
644 # self.hunk[0] is the @@ description
645 for x in xrange(1, len(self.hunk)):
645 for x in xrange(1, len(self.hunk)):
646 o = self.hunk[x]
646 o = self.hunk[x]
647 if o.startswith('-'):
647 if o.startswith('-'):
648 n = '+' + o[1:]
648 n = '+' + o[1:]
649 self.b.append(o[1:])
649 self.b.append(o[1:])
650 elif o.startswith('+'):
650 elif o.startswith('+'):
651 n = '-' + o[1:]
651 n = '-' + o[1:]
652 self.a.append(n)
652 self.a.append(n)
653 else:
653 else:
654 n = o
654 n = o
655 self.b.append(o[1:])
655 self.b.append(o[1:])
656 self.a.append(o)
656 self.a.append(o)
657 self.hunk[x] = o
657 self.hunk[x] = o
658
658
659 def fix_newline(self):
659 def fix_newline(self):
660 diffhelpers.fix_newline(self.hunk, self.a, self.b)
660 diffhelpers.fix_newline(self.hunk, self.a, self.b)
661
661
662 def complete(self):
662 def complete(self):
663 return len(self.a) == self.lena and len(self.b) == self.lenb
663 return len(self.a) == self.lena and len(self.b) == self.lenb
664
664
665 def createfile(self):
665 def createfile(self):
666 return self.starta == 0 and self.lena == 0
666 return self.starta == 0 and self.lena == 0
667
667
668 def rmfile(self):
668 def rmfile(self):
669 return self.startb == 0 and self.lenb == 0
669 return self.startb == 0 and self.lenb == 0
670
670
671 def fuzzit(self, l, fuzz, toponly):
671 def fuzzit(self, l, fuzz, toponly):
672 # this removes context lines from the top and bottom of list 'l'. It
672 # this removes context lines from the top and bottom of list 'l'. It
673 # checks the hunk to make sure only context lines are removed, and then
673 # checks the hunk to make sure only context lines are removed, and then
674 # returns a new shortened list of lines.
674 # returns a new shortened list of lines.
675 fuzz = min(fuzz, len(l)-1)
675 fuzz = min(fuzz, len(l)-1)
676 if fuzz:
676 if fuzz:
677 top = 0
677 top = 0
678 bot = 0
678 bot = 0
679 hlen = len(self.hunk)
679 hlen = len(self.hunk)
680 for x in xrange(hlen-1):
680 for x in xrange(hlen-1):
681 # the hunk starts with the @@ line, so use x+1
681 # the hunk starts with the @@ line, so use x+1
682 if self.hunk[x+1][0] == ' ':
682 if self.hunk[x+1][0] == ' ':
683 top += 1
683 top += 1
684 else:
684 else:
685 break
685 break
686 if not toponly:
686 if not toponly:
687 for x in xrange(hlen-1):
687 for x in xrange(hlen-1):
688 if self.hunk[hlen-bot-1][0] == ' ':
688 if self.hunk[hlen-bot-1][0] == ' ':
689 bot += 1
689 bot += 1
690 else:
690 else:
691 break
691 break
692
692
693 # top and bot now count context in the hunk
693 # top and bot now count context in the hunk
694 # adjust them if either one is short
694 # adjust them if either one is short
695 context = max(top, bot, 3)
695 context = max(top, bot, 3)
696 if bot < context:
696 if bot < context:
697 bot = max(0, fuzz - (context - bot))
697 bot = max(0, fuzz - (context - bot))
698 else:
698 else:
699 bot = min(fuzz, bot)
699 bot = min(fuzz, bot)
700 if top < context:
700 if top < context:
701 top = max(0, fuzz - (context - top))
701 top = max(0, fuzz - (context - top))
702 else:
702 else:
703 top = min(fuzz, top)
703 top = min(fuzz, top)
704
704
705 return l[top:len(l)-bot]
705 return l[top:len(l)-bot]
706 return l
706 return l
707
707
708 def old(self, fuzz=0, toponly=False):
708 def old(self, fuzz=0, toponly=False):
709 return self.fuzzit(self.a, fuzz, toponly)
709 return self.fuzzit(self.a, fuzz, toponly)
710
710
711 def newctrl(self):
711 def newctrl(self):
712 res = []
712 res = []
713 for x in self.hunk:
713 for x in self.hunk:
714 c = x[0]
714 c = x[0]
715 if c == ' ' or c == '+':
715 if c == ' ' or c == '+':
716 res.append(x)
716 res.append(x)
717 return res
717 return res
718
718
719 def new(self, fuzz=0, toponly=False):
719 def new(self, fuzz=0, toponly=False):
720 return self.fuzzit(self.b, fuzz, toponly)
720 return self.fuzzit(self.b, fuzz, toponly)
721
721
722 class binhunk:
722 class binhunk:
723 'A binary patch file. Only understands literals so far.'
723 'A binary patch file. Only understands literals so far.'
724 def __init__(self, gitpatch):
724 def __init__(self, gitpatch):
725 self.gitpatch = gitpatch
725 self.gitpatch = gitpatch
726 self.text = None
726 self.text = None
727 self.hunk = ['GIT binary patch\n']
727 self.hunk = ['GIT binary patch\n']
728
728
729 def createfile(self):
729 def createfile(self):
730 return self.gitpatch.op in ('ADD', 'RENAME', 'COPY')
730 return self.gitpatch.op in ('ADD', 'RENAME', 'COPY')
731
731
732 def rmfile(self):
732 def rmfile(self):
733 return self.gitpatch.op == 'DELETE'
733 return self.gitpatch.op == 'DELETE'
734
734
735 def complete(self):
735 def complete(self):
736 return self.text is not None
736 return self.text is not None
737
737
738 def new(self):
738 def new(self):
739 return [self.text]
739 return [self.text]
740
740
741 def extract(self, fp):
741 def extract(self, fp):
742 line = fp.readline()
742 line = fp.readline()
743 self.hunk.append(line)
743 self.hunk.append(line)
744 while line and not line.startswith('literal '):
744 while line and not line.startswith('literal '):
745 line = fp.readline()
745 line = fp.readline()
746 self.hunk.append(line)
746 self.hunk.append(line)
747 if not line:
747 if not line:
748 raise PatchError(_('could not extract binary patch'))
748 raise PatchError(_('could not extract binary patch'))
749 size = int(line[8:].rstrip())
749 size = int(line[8:].rstrip())
750 dec = []
750 dec = []
751 line = fp.readline()
751 line = fp.readline()
752 self.hunk.append(line)
752 self.hunk.append(line)
753 while len(line) > 1:
753 while len(line) > 1:
754 l = line[0]
754 l = line[0]
755 if l <= 'Z' and l >= 'A':
755 if l <= 'Z' and l >= 'A':
756 l = ord(l) - ord('A') + 1
756 l = ord(l) - ord('A') + 1
757 else:
757 else:
758 l = ord(l) - ord('a') + 27
758 l = ord(l) - ord('a') + 27
759 dec.append(base85.b85decode(line[1:-1])[:l])
759 dec.append(base85.b85decode(line[1:-1])[:l])
760 line = fp.readline()
760 line = fp.readline()
761 self.hunk.append(line)
761 self.hunk.append(line)
762 text = zlib.decompress(''.join(dec))
762 text = zlib.decompress(''.join(dec))
763 if len(text) != size:
763 if len(text) != size:
764 raise PatchError(_('binary patch is %d bytes, not %d') %
764 raise PatchError(_('binary patch is %d bytes, not %d') %
765 len(text), size)
765 len(text), size)
766 self.text = text
766 self.text = text
767
767
768 def parsefilename(str):
768 def parsefilename(str):
769 # --- filename \t|space stuff
769 # --- filename \t|space stuff
770 s = str[4:]
770 s = str[4:]
771 i = s.find('\t')
771 i = s.find('\t')
772 if i < 0:
772 if i < 0:
773 i = s.find(' ')
773 i = s.find(' ')
774 if i < 0:
774 if i < 0:
775 return s
775 return s
776 return s[:i]
776 return s[:i]
777
777
778 def selectfile(afile_orig, bfile_orig, hunk, strip, reverse):
778 def selectfile(afile_orig, bfile_orig, hunk, strip, reverse):
779 def pathstrip(path, count=1):
779 def pathstrip(path, count=1):
780 pathlen = len(path)
780 pathlen = len(path)
781 i = 0
781 i = 0
782 if count == 0:
782 if count == 0:
783 return path.rstrip()
783 return path.rstrip()
784 while count > 0:
784 while count > 0:
785 i = path.find('/', i)
785 i = path.find('/', i)
786 if i == -1:
786 if i == -1:
787 raise PatchError(_("unable to strip away %d dirs from %s") %
787 raise PatchError(_("unable to strip away %d dirs from %s") %
788 (count, path))
788 (count, path))
789 i += 1
789 i += 1
790 # consume '//' in the path
790 # consume '//' in the path
791 while i < pathlen - 1 and path[i] == '/':
791 while i < pathlen - 1 and path[i] == '/':
792 i += 1
792 i += 1
793 count -= 1
793 count -= 1
794 return path[i:].rstrip()
794 return path[i:].rstrip()
795
795
796 nulla = afile_orig == "/dev/null"
796 nulla = afile_orig == "/dev/null"
797 nullb = bfile_orig == "/dev/null"
797 nullb = bfile_orig == "/dev/null"
798 afile = pathstrip(afile_orig, strip)
798 afile = pathstrip(afile_orig, strip)
799 gooda = os.path.exists(afile) and not nulla
799 gooda = os.path.exists(afile) and not nulla
800 bfile = pathstrip(bfile_orig, strip)
800 bfile = pathstrip(bfile_orig, strip)
801 if afile == bfile:
801 if afile == bfile:
802 goodb = gooda
802 goodb = gooda
803 else:
803 else:
804 goodb = os.path.exists(bfile) and not nullb
804 goodb = os.path.exists(bfile) and not nullb
805 createfunc = hunk.createfile
805 createfunc = hunk.createfile
806 if reverse:
806 if reverse:
807 createfunc = hunk.rmfile
807 createfunc = hunk.rmfile
808 if not goodb and not gooda and not createfunc():
808 if not goodb and not gooda and not createfunc():
809 raise PatchError(_("unable to find %s or %s for patching") %
809 raise PatchError(_("unable to find %s or %s for patching") %
810 (afile, bfile))
810 (afile, bfile))
811 if gooda and goodb:
811 if gooda and goodb:
812 fname = bfile
812 fname = bfile
813 if afile in bfile:
813 if afile in bfile:
814 fname = afile
814 fname = afile
815 elif gooda:
815 elif gooda:
816 fname = afile
816 fname = afile
817 elif not nullb:
817 elif not nullb:
818 fname = bfile
818 fname = bfile
819 if afile in bfile:
819 if afile in bfile:
820 fname = afile
820 fname = afile
821 elif not nulla:
821 elif not nulla:
822 fname = afile
822 fname = afile
823 return fname
823 return fname
824
824
825 class linereader:
825 class linereader:
826 # simple class to allow pushing lines back into the input stream
826 # simple class to allow pushing lines back into the input stream
827 def __init__(self, fp):
827 def __init__(self, fp):
828 self.fp = fp
828 self.fp = fp
829 self.buf = []
829 self.buf = []
830
830
831 def push(self, line):
831 def push(self, line):
832 self.buf.append(line)
832 self.buf.append(line)
833
833
834 def readline(self):
834 def readline(self):
835 if self.buf:
835 if self.buf:
836 l = self.buf[0]
836 l = self.buf[0]
837 del self.buf[0]
837 del self.buf[0]
838 return l
838 return l
839 return self.fp.readline()
839 return self.fp.readline()
840
840
841 def applydiff(ui, fp, changed, strip=1, sourcefile=None, reverse=False,
841 def applydiff(ui, fp, changed, strip=1, sourcefile=None, reverse=False,
842 rejmerge=None, updatedir=None):
842 rejmerge=None, updatedir=None):
843 """reads a patch from fp and tries to apply it. The dict 'changed' is
843 """reads a patch from fp and tries to apply it. The dict 'changed' is
844 filled in with all of the filenames changed by the patch. Returns 0
844 filled in with all of the filenames changed by the patch. Returns 0
845 for a clean patch, -1 if any rejects were found and 1 if there was
845 for a clean patch, -1 if any rejects were found and 1 if there was
846 any fuzz."""
846 any fuzz."""
847
847
848 def scangitpatch(fp, firstline, cwd=None):
848 def scangitpatch(fp, firstline, cwd=None):
849 '''git patches can modify a file, then copy that file to
849 '''git patches can modify a file, then copy that file to
850 a new file, but expect the source to be the unmodified form.
850 a new file, but expect the source to be the unmodified form.
851 So we scan the patch looking for that case so we can do
851 So we scan the patch looking for that case so we can do
852 the copies ahead of time.'''
852 the copies ahead of time.'''
853
853
854 pos = 0
854 pos = 0
855 try:
855 try:
856 pos = fp.tell()
856 pos = fp.tell()
857 except IOError:
857 except IOError:
858 fp = cStringIO.StringIO(fp.read())
858 fp = cStringIO.StringIO(fp.read())
859
859
860 (dopatch, gitpatches) = readgitpatch(fp, firstline)
860 (dopatch, gitpatches) = readgitpatch(fp, firstline)
861 for gp in gitpatches:
861 for gp in gitpatches:
862 if gp.op in ('COPY', 'RENAME'):
862 if gp.op in ('COPY', 'RENAME'):
863 copyfile(gp.oldpath, gp.path, basedir=cwd)
863 copyfile(gp.oldpath, gp.path, basedir=cwd)
864
864
865 fp.seek(pos)
865 fp.seek(pos)
866
866
867 return fp, dopatch, gitpatches
867 return fp, dopatch, gitpatches
868
868
869 current_hunk = None
869 current_hunk = None
870 current_file = None
870 current_file = None
871 afile = ""
871 afile = ""
872 bfile = ""
872 bfile = ""
873 state = None
873 state = None
874 hunknum = 0
874 hunknum = 0
875 rejects = 0
875 rejects = 0
876
876
877 git = False
877 git = False
878 gitre = re.compile('diff --git (a/.*) (b/.*)')
878 gitre = re.compile('diff --git (a/.*) (b/.*)')
879
879
880 # our states
880 # our states
881 BFILE = 1
881 BFILE = 1
882 err = 0
882 err = 0
883 context = None
883 context = None
884 lr = linereader(fp)
884 lr = linereader(fp)
885 dopatch = True
885 dopatch = True
886 gitworkdone = False
886 gitworkdone = False
887
887
888 while True:
888 while True:
889 newfile = False
889 newfile = False
890 x = lr.readline()
890 x = lr.readline()
891 if not x:
891 if not x:
892 break
892 break
893 if current_hunk:
893 if current_hunk:
894 if x.startswith('\ '):
894 if x.startswith('\ '):
895 current_hunk.fix_newline()
895 current_hunk.fix_newline()
896 ret = current_file.apply(current_hunk, reverse)
896 ret = current_file.apply(current_hunk, reverse)
897 if ret >= 0:
897 if ret >= 0:
898 changed.setdefault(current_file.fname, (None, None))
898 changed.setdefault(current_file.fname, (None, None))
899 if ret > 0:
899 if ret > 0:
900 err = 1
900 err = 1
901 current_hunk = None
901 current_hunk = None
902 gitworkdone = False
902 gitworkdone = False
903 if ((sourcefile or state == BFILE) and ((not context and x[0] == '@') or
903 if ((sourcefile or state == BFILE) and ((not context and x[0] == '@') or
904 ((context or context == None) and x.startswith('***************')))):
904 ((context or context == None) and x.startswith('***************')))):
905 try:
905 try:
906 if context == None and x.startswith('***************'):
906 if context == None and x.startswith('***************'):
907 context = True
907 context = True
908 current_hunk = hunk(x, hunknum + 1, lr, context)
908 current_hunk = hunk(x, hunknum + 1, lr, context)
909 except PatchError, err:
909 except PatchError, err:
910 ui.debug(err)
910 ui.debug(err)
911 current_hunk = None
911 current_hunk = None
912 continue
912 continue
913 hunknum += 1
913 hunknum += 1
914 if not current_file:
914 if not current_file:
915 if sourcefile:
915 if sourcefile:
916 current_file = patchfile(ui, sourcefile)
916 current_file = patchfile(ui, sourcefile)
917 else:
917 else:
918 current_file = selectfile(afile, bfile, current_hunk,
918 current_file = selectfile(afile, bfile, current_hunk,
919 strip, reverse)
919 strip, reverse)
920 current_file = patchfile(ui, current_file)
920 current_file = patchfile(ui, current_file)
921 elif state == BFILE and x.startswith('GIT binary patch'):
921 elif state == BFILE and x.startswith('GIT binary patch'):
922 current_hunk = binhunk(changed[bfile[2:]][1])
922 current_hunk = binhunk(changed[bfile[2:]][1])
923 if not current_file:
923 if not current_file:
924 if sourcefile:
924 if sourcefile:
925 current_file = patchfile(ui, sourcefile)
925 current_file = patchfile(ui, sourcefile)
926 else:
926 else:
927 current_file = selectfile(afile, bfile, current_hunk,
927 current_file = selectfile(afile, bfile, current_hunk,
928 strip, reverse)
928 strip, reverse)
929 current_file = patchfile(ui, current_file)
929 current_file = patchfile(ui, current_file)
930 hunknum += 1
930 hunknum += 1
931 current_hunk.extract(fp)
931 current_hunk.extract(fp)
932 elif x.startswith('diff --git'):
932 elif x.startswith('diff --git'):
933 # check for git diff, scanning the whole patch file if needed
933 # check for git diff, scanning the whole patch file if needed
934 m = gitre.match(x)
934 m = gitre.match(x)
935 if m:
935 if m:
936 afile, bfile = m.group(1, 2)
936 afile, bfile = m.group(1, 2)
937 if not git:
937 if not git:
938 git = True
938 git = True
939 fp, dopatch, gitpatches = scangitpatch(fp, x)
939 fp, dopatch, gitpatches = scangitpatch(fp, x)
940 for gp in gitpatches:
940 for gp in gitpatches:
941 changed[gp.path] = (gp.op, gp)
941 changed[gp.path] = (gp.op, gp)
942 # else error?
942 # else error?
943 # copy/rename + modify should modify target, not source
943 # copy/rename + modify should modify target, not source
944 if changed.get(bfile[2:], (None, None))[0] in ('COPY',
944 if changed.get(bfile[2:], (None, None))[0] in ('COPY',
945 'RENAME'):
945 'RENAME'):
946 afile = bfile
946 afile = bfile
947 gitworkdone = True
947 gitworkdone = True
948 newfile = True
948 newfile = True
949 elif x.startswith('---'):
949 elif x.startswith('---'):
950 # check for a unified diff
950 # check for a unified diff
951 l2 = lr.readline()
951 l2 = lr.readline()
952 if not l2.startswith('+++'):
952 if not l2.startswith('+++'):
953 lr.push(l2)
953 lr.push(l2)
954 continue
954 continue
955 newfile = True
955 newfile = True
956 context = False
956 context = False
957 afile = parsefilename(x)
957 afile = parsefilename(x)
958 bfile = parsefilename(l2)
958 bfile = parsefilename(l2)
959 elif x.startswith('***'):
959 elif x.startswith('***'):
960 # check for a context diff
960 # check for a context diff
961 l2 = lr.readline()
961 l2 = lr.readline()
962 if not l2.startswith('---'):
962 if not l2.startswith('---'):
963 lr.push(l2)
963 lr.push(l2)
964 continue
964 continue
965 l3 = lr.readline()
965 l3 = lr.readline()
966 lr.push(l3)
966 lr.push(l3)
967 if not l3.startswith("***************"):
967 if not l3.startswith("***************"):
968 lr.push(l2)
968 lr.push(l2)
969 continue
969 continue
970 newfile = True
970 newfile = True
971 context = True
971 context = True
972 afile = parsefilename(x)
972 afile = parsefilename(x)
973 bfile = parsefilename(l2)
973 bfile = parsefilename(l2)
974
974
975 if newfile:
975 if newfile:
976 if current_file:
976 if current_file:
977 current_file.close()
977 current_file.close()
978 if rejmerge:
978 if rejmerge:
979 rejmerge(current_file)
979 rejmerge(current_file)
980 rejects += len(current_file.rej)
980 rejects += len(current_file.rej)
981 state = BFILE
981 state = BFILE
982 current_file = None
982 current_file = None
983 hunknum = 0
983 hunknum = 0
984 if current_hunk:
984 if current_hunk:
985 if current_hunk.complete():
985 if current_hunk.complete():
986 ret = current_file.apply(current_hunk, reverse)
986 ret = current_file.apply(current_hunk, reverse)
987 if ret >= 0:
987 if ret >= 0:
988 changed.setdefault(current_file.fname, (None, None))
988 changed.setdefault(current_file.fname, (None, None))
989 if ret > 0:
989 if ret > 0:
990 err = 1
990 err = 1
991 else:
991 else:
992 fname = current_file and current_file.fname or None
992 fname = current_file and current_file.fname or None
993 raise PatchError(_("malformed patch %s %s") % (fname,
993 raise PatchError(_("malformed patch %s %s") % (fname,
994 current_hunk.desc))
994 current_hunk.desc))
995 if current_file:
995 if current_file:
996 current_file.close()
996 current_file.close()
997 if rejmerge:
997 if rejmerge:
998 rejmerge(current_file)
998 rejmerge(current_file)
999 rejects += len(current_file.rej)
999 rejects += len(current_file.rej)
1000 if updatedir and git:
1000 if updatedir and git:
1001 updatedir(gitpatches)
1001 updatedir(gitpatches)
1002 if rejects:
1002 if rejects:
1003 return -1
1003 return -1
1004 if hunknum == 0 and dopatch and not gitworkdone:
1004 if hunknum == 0 and dopatch and not gitworkdone:
1005 raise NoHunks
1005 raise NoHunks
1006 return err
1006 return err
1007
1007
1008 def diffopts(ui, opts={}, untrusted=False):
1008 def diffopts(ui, opts={}, untrusted=False):
1009 def get(key, name=None):
1009 def get(key, name=None):
1010 return (opts.get(key) or
1010 return (opts.get(key) or
1011 ui.configbool('diff', name or key, None, untrusted=untrusted))
1011 ui.configbool('diff', name or key, None, untrusted=untrusted))
1012 return mdiff.diffopts(
1012 return mdiff.diffopts(
1013 text=opts.get('text'),
1013 text=opts.get('text'),
1014 git=get('git'),
1014 git=get('git'),
1015 nodates=get('nodates'),
1015 nodates=get('nodates'),
1016 showfunc=get('show_function', 'showfunc'),
1016 showfunc=get('show_function', 'showfunc'),
1017 ignorews=get('ignore_all_space', 'ignorews'),
1017 ignorews=get('ignore_all_space', 'ignorews'),
1018 ignorewsamount=get('ignore_space_change', 'ignorewsamount'),
1018 ignorewsamount=get('ignore_space_change', 'ignorewsamount'),
1019 ignoreblanklines=get('ignore_blank_lines', 'ignoreblanklines'))
1019 ignoreblanklines=get('ignore_blank_lines', 'ignoreblanklines'))
1020
1020
1021 def updatedir(ui, repo, patches):
1021 def updatedir(ui, repo, patches):
1022 '''Update dirstate after patch application according to metadata'''
1022 '''Update dirstate after patch application according to metadata'''
1023 if not patches:
1023 if not patches:
1024 return
1024 return
1025 copies = []
1025 copies = []
1026 removes = {}
1026 removes = {}
1027 cfiles = patches.keys()
1027 cfiles = patches.keys()
1028 cwd = repo.getcwd()
1028 cwd = repo.getcwd()
1029 if cwd:
1029 if cwd:
1030 cfiles = [util.pathto(repo.root, cwd, f) for f in patches.keys()]
1030 cfiles = [util.pathto(repo.root, cwd, f) for f in patches.keys()]
1031 for f in patches:
1031 for f in patches:
1032 ctype, gp = patches[f]
1032 ctype, gp = patches[f]
1033 if ctype == 'RENAME':
1033 if ctype == 'RENAME':
1034 copies.append((gp.oldpath, gp.path))
1034 copies.append((gp.oldpath, gp.path))
1035 removes[gp.oldpath] = 1
1035 removes[gp.oldpath] = 1
1036 elif ctype == 'COPY':
1036 elif ctype == 'COPY':
1037 copies.append((gp.oldpath, gp.path))
1037 copies.append((gp.oldpath, gp.path))
1038 elif ctype == 'DELETE':
1038 elif ctype == 'DELETE':
1039 removes[gp.path] = 1
1039 removes[gp.path] = 1
1040 for src, dst in copies:
1040 for src, dst in copies:
1041 repo.copy(src, dst)
1041 repo.copy(src, dst)
1042 removes = removes.keys()
1042 removes = removes.keys()
1043 if removes:
1043 if removes:
1044 removes.sort()
1044 removes.sort()
1045 repo.remove(removes, True)
1045 repo.remove(removes, True)
1046 for f in patches:
1046 for f in patches:
1047 ctype, gp = patches[f]
1047 ctype, gp = patches[f]
1048 if gp and gp.mode:
1048 if gp and gp.mode:
1049 x = gp.mode & 0100 != 0
1049 x = gp.mode & 0100 != 0
1050 l = gp.mode & 020000 != 0
1050 l = gp.mode & 020000 != 0
1051 dst = os.path.join(repo.root, gp.path)
1051 dst = os.path.join(repo.root, gp.path)
1052 # patch won't create empty files
1052 # patch won't create empty files
1053 if ctype == 'ADD' and not os.path.exists(dst):
1053 if ctype == 'ADD' and not os.path.exists(dst):
1054 repo.wwrite(gp.path, '', x and 'x' or '')
1054 repo.wwrite(gp.path, '', x and 'x' or '')
1055 else:
1055 else:
1056 util.set_link(dst, l)
1056 util.set_link(dst, l)
1057 if not l:
1057 if not l:
1058 util.set_exec(dst, x)
1058 util.set_exec(dst, x)
1059 cmdutil.addremove(repo, cfiles)
1059 cmdutil.addremove(repo, cfiles)
1060 files = patches.keys()
1060 files = patches.keys()
1061 files.extend([r for r in removes if r not in files])
1061 files.extend([r for r in removes if r not in files])
1062 files.sort()
1062 files.sort()
1063
1063
1064 return files
1064 return files
1065
1065
1066 def b85diff(to, tn):
1066 def b85diff(to, tn):
1067 '''print base85-encoded binary diff'''
1067 '''print base85-encoded binary diff'''
1068 def gitindex(text):
1068 def gitindex(text):
1069 if not text:
1069 if not text:
1070 return '0' * 40
1070 return '0' * 40
1071 l = len(text)
1071 l = len(text)
1072 s = sha.new('blob %d\0' % l)
1072 s = sha.new('blob %d\0' % l)
1073 s.update(text)
1073 s.update(text)
1074 return s.hexdigest()
1074 return s.hexdigest()
1075
1075
1076 def fmtline(line):
1076 def fmtline(line):
1077 l = len(line)
1077 l = len(line)
1078 if l <= 26:
1078 if l <= 26:
1079 l = chr(ord('A') + l - 1)
1079 l = chr(ord('A') + l - 1)
1080 else:
1080 else:
1081 l = chr(l - 26 + ord('a') - 1)
1081 l = chr(l - 26 + ord('a') - 1)
1082 return '%c%s\n' % (l, base85.b85encode(line, True))
1082 return '%c%s\n' % (l, base85.b85encode(line, True))
1083
1083
1084 def chunk(text, csize=52):
1084 def chunk(text, csize=52):
1085 l = len(text)
1085 l = len(text)
1086 i = 0
1086 i = 0
1087 while i < l:
1087 while i < l:
1088 yield text[i:i+csize]
1088 yield text[i:i+csize]
1089 i += csize
1089 i += csize
1090
1090
1091 tohash = gitindex(to)
1091 tohash = gitindex(to)
1092 tnhash = gitindex(tn)
1092 tnhash = gitindex(tn)
1093 if tohash == tnhash:
1093 if tohash == tnhash:
1094 return ""
1094 return ""
1095
1095
1096 # TODO: deltas
1096 # TODO: deltas
1097 ret = ['index %s..%s\nGIT binary patch\nliteral %s\n' %
1097 ret = ['index %s..%s\nGIT binary patch\nliteral %s\n' %
1098 (tohash, tnhash, len(tn))]
1098 (tohash, tnhash, len(tn))]
1099 for l in chunk(zlib.compress(tn)):
1099 for l in chunk(zlib.compress(tn)):
1100 ret.append(fmtline(l))
1100 ret.append(fmtline(l))
1101 ret.append('\n')
1101 ret.append('\n')
1102 return ''.join(ret)
1102 return ''.join(ret)
1103
1103
1104 def diff(repo, node1=None, node2=None, files=None, match=util.always,
1104 def diff(repo, node1=None, node2=None, files=None, match=util.always,
1105 fp=None, changes=None, opts=None):
1105 fp=None, changes=None, opts=None):
1106 '''print diff of changes to files between two nodes, or node and
1106 '''print diff of changes to files between two nodes, or node and
1107 working directory.
1107 working directory.
1108
1108
1109 if node1 is None, use first dirstate parent instead.
1109 if node1 is None, use first dirstate parent instead.
1110 if node2 is None, compare node1 with working directory.'''
1110 if node2 is None, compare node1 with working directory.'''
1111
1111
1112 if opts is None:
1112 if opts is None:
1113 opts = mdiff.defaultopts
1113 opts = mdiff.defaultopts
1114 if fp is None:
1114 if fp is None:
1115 fp = repo.ui
1115 fp = repo.ui
1116
1116
1117 if not node1:
1117 if not node1:
1118 node1 = repo.dirstate.parents()[0]
1118 node1 = repo.dirstate.parents()[0]
1119
1119
1120 ccache = {}
1120 ccache = {}
1121 def getctx(r):
1121 def getctx(r):
1122 if r not in ccache:
1122 if r not in ccache:
1123 ccache[r] = context.changectx(repo, r)
1123 ccache[r] = context.changectx(repo, r)
1124 return ccache[r]
1124 return ccache[r]
1125
1125
1126 flcache = {}
1126 flcache = {}
1127 def getfilectx(f, ctx):
1127 def getfilectx(f, ctx):
1128 flctx = ctx.filectx(f, filelog=flcache.get(f))
1128 flctx = ctx.filectx(f, filelog=flcache.get(f))
1129 if f not in flcache:
1129 if f not in flcache:
1130 flcache[f] = flctx._filelog
1130 flcache[f] = flctx._filelog
1131 return flctx
1131 return flctx
1132
1132
1133 # reading the data for node1 early allows it to play nicely
1133 # reading the data for node1 early allows it to play nicely
1134 # with repo.status and the revlog cache.
1134 # with repo.status and the revlog cache.
1135 ctx1 = context.changectx(repo, node1)
1135 ctx1 = context.changectx(repo, node1)
1136 # force manifest reading
1136 # force manifest reading
1137 man1 = ctx1.manifest()
1137 man1 = ctx1.manifest()
1138 date1 = util.datestr(ctx1.date())
1138 date1 = util.datestr(ctx1.date())
1139
1139
1140 if not changes:
1140 if not changes:
1141 changes = repo.status(node1, node2, files, match=match)[:5]
1141 changes = repo.status(node1, node2, files, match=match)[:5]
1142 modified, added, removed, deleted, unknown = changes
1142 modified, added, removed, deleted, unknown = changes
1143
1143
1144 if not modified and not added and not removed:
1144 if not modified and not added and not removed:
1145 return
1145 return
1146
1146
1147 if node2:
1147 if node2:
1148 ctx2 = context.changectx(repo, node2)
1148 ctx2 = context.changectx(repo, node2)
1149 execf2 = ctx2.manifest().execf
1149 execf2 = ctx2.manifest().execf
1150 linkf2 = ctx2.manifest().linkf
1150 linkf2 = ctx2.manifest().linkf
1151 else:
1151 else:
1152 ctx2 = context.workingctx(repo)
1152 ctx2 = context.workingctx(repo)
1153 execf2 = util.execfunc(repo.root, None)
1153 execf2 = util.execfunc(repo.root, None)
1154 linkf2 = util.linkfunc(repo.root, None)
1154 linkf2 = util.linkfunc(repo.root, None)
1155 if execf2 is None:
1155 if execf2 is None:
1156 mc = ctx2.parents()[0].manifest().copy()
1156 mc = ctx2.parents()[0].manifest().copy()
1157 execf2 = mc.execf
1157 execf2 = mc.execf
1158 linkf2 = mc.linkf
1158 linkf2 = mc.linkf
1159
1159
1160 # returns False if there was no rename between ctx1 and ctx2
1160 # returns False if there was no rename between ctx1 and ctx2
1161 # returns None if the file was created between ctx1 and ctx2
1161 # returns None if the file was created between ctx1 and ctx2
1162 # returns the (file, node) present in ctx1 that was renamed to f in ctx2
1162 # returns the (file, node) present in ctx1 that was renamed to f in ctx2
1163 # This will only really work if c1 is the Nth 1st parent of c2.
1163 # This will only really work if c1 is the Nth 1st parent of c2.
1164 def renamed(c1, c2, man, f):
1164 def renamed(c1, c2, man, f):
1165 startrev = c1.rev()
1165 startrev = c1.rev()
1166 c = c2
1166 c = c2
1167 crev = c.rev()
1167 crev = c.rev()
1168 if crev is None:
1168 if crev is None:
1169 crev = repo.changelog.count()
1169 crev = repo.changelog.count()
1170 orig = f
1170 orig = f
1171 files = (f,)
1171 files = (f,)
1172 while crev > startrev:
1172 while crev > startrev:
1173 if f in files:
1173 if f in files:
1174 try:
1174 try:
1175 src = getfilectx(f, c).renamed()
1175 src = getfilectx(f, c).renamed()
1176 except revlog.LookupError:
1176 except revlog.LookupError:
1177 return None
1177 return None
1178 if src:
1178 if src:
1179 f = src[0]
1179 f = src[0]
1180 crev = c.parents()[0].rev()
1180 crev = c.parents()[0].rev()
1181 # try to reuse
1181 # try to reuse
1182 c = getctx(crev)
1182 c = getctx(crev)
1183 files = c.files()
1183 files = c.files()
1184 if f not in man:
1184 if f not in man:
1185 return None
1185 return None
1186 if f == orig:
1186 if f == orig:
1187 return False
1187 return False
1188 return f
1188 return f
1189
1189
1190 if repo.ui.quiet:
1190 if repo.ui.quiet:
1191 r = None
1191 r = None
1192 else:
1192 else:
1193 hexfunc = repo.ui.debugflag and hex or short
1193 hexfunc = repo.ui.debugflag and hex or short
1194 r = [hexfunc(node) for node in [node1, node2] if node]
1194 r = [hexfunc(node) for node in [node1, node2] if node]
1195
1195
1196 if opts.git:
1196 if opts.git:
1197 copied = {}
1197 copied = {}
1198 c1, c2 = ctx1, ctx2
1198 c1, c2 = ctx1, ctx2
1199 files = added
1199 files = added
1200 man = man1
1200 man = man1
1201 if node2 and ctx1.rev() >= ctx2.rev():
1201 if node2 and ctx1.rev() >= ctx2.rev():
1202 # renamed() starts at c2 and walks back in history until c1.
1202 # renamed() starts at c2 and walks back in history until c1.
1203 # Since ctx1.rev() >= ctx2.rev(), invert ctx2 and ctx1 to
1203 # Since ctx1.rev() >= ctx2.rev(), invert ctx2 and ctx1 to
1204 # detect (inverted) copies.
1204 # detect (inverted) copies.
1205 c1, c2 = ctx2, ctx1
1205 c1, c2 = ctx2, ctx1
1206 files = removed
1206 files = removed
1207 man = ctx2.manifest()
1207 man = ctx2.manifest()
1208 for f in files:
1208 for f in files:
1209 src = renamed(c1, c2, man, f)
1209 src = renamed(c1, c2, man, f)
1210 if src:
1210 if src:
1211 copied[f] = src
1211 copied[f] = src
1212 if ctx1 == c2:
1212 if ctx1 == c2:
1213 # invert the copied dict
1213 # invert the copied dict
1214 copied = dict([(v, k) for (k, v) in copied.iteritems()])
1214 copied = dict([(v, k) for (k, v) in copied.iteritems()])
1215 # If we've renamed file foo to bar (copied['bar'] = 'foo'),
1215 # If we've renamed file foo to bar (copied['bar'] = 'foo'),
1216 # avoid showing a diff for foo if we're going to show
1216 # avoid showing a diff for foo if we're going to show
1217 # the rename to bar.
1217 # the rename to bar.
1218 srcs = [x[1] for x in copied.iteritems() if x[0] in added]
1218 srcs = [x[1] for x in copied.iteritems() if x[0] in added]
1219
1219
1220 all = modified + added + removed
1220 all = modified + added + removed
1221 all.sort()
1221 all.sort()
1222 gone = {}
1222 gone = {}
1223
1223
1224 for f in all:
1224 for f in all:
1225 to = None
1225 to = None
1226 tn = None
1226 tn = None
1227 dodiff = True
1227 dodiff = True
1228 header = []
1228 header = []
1229 if f in man1:
1229 if f in man1:
1230 to = getfilectx(f, ctx1).data()
1230 to = getfilectx(f, ctx1).data()
1231 if f not in removed:
1231 if f not in removed:
1232 tn = getfilectx(f, ctx2).data()
1232 tn = getfilectx(f, ctx2).data()
1233 a, b = f, f
1233 a, b = f, f
1234 if opts.git:
1234 if opts.git:
1235 def gitmode(x, l):
1235 def gitmode(x, l):
1236 return l and '120000' or (x and '100755' or '100644')
1236 return l and '120000' or (x and '100755' or '100644')
1237 def addmodehdr(header, omode, nmode):
1237 def addmodehdr(header, omode, nmode):
1238 if omode != nmode:
1238 if omode != nmode:
1239 header.append('old mode %s\n' % omode)
1239 header.append('old mode %s\n' % omode)
1240 header.append('new mode %s\n' % nmode)
1240 header.append('new mode %s\n' % nmode)
1241
1241
1242 if f in added:
1242 if f in added:
1243 mode = gitmode(execf2(f), linkf2(f))
1243 mode = gitmode(execf2(f), linkf2(f))
1244 if f in copied:
1244 if f in copied:
1245 a = copied[f]
1245 a = copied[f]
1246 omode = gitmode(man1.execf(a), man1.linkf(a))
1246 omode = gitmode(man1.execf(a), man1.linkf(a))
1247 addmodehdr(header, omode, mode)
1247 addmodehdr(header, omode, mode)
1248 if a in removed and a not in gone:
1248 if a in removed and a not in gone:
1249 op = 'rename'
1249 op = 'rename'
1250 gone[a] = 1
1250 gone[a] = 1
1251 else:
1251 else:
1252 op = 'copy'
1252 op = 'copy'
1253 header.append('%s from %s\n' % (op, a))
1253 header.append('%s from %s\n' % (op, a))
1254 header.append('%s to %s\n' % (op, f))
1254 header.append('%s to %s\n' % (op, f))
1255 to = getfilectx(a, ctx1).data()
1255 to = getfilectx(a, ctx1).data()
1256 else:
1256 else:
1257 header.append('new file mode %s\n' % mode)
1257 header.append('new file mode %s\n' % mode)
1258 if util.binary(tn):
1258 if util.binary(tn):
1259 dodiff = 'binary'
1259 dodiff = 'binary'
1260 elif f in removed:
1260 elif f in removed:
1261 if f in srcs:
1261 if f in srcs:
1262 dodiff = False
1262 dodiff = False
1263 else:
1263 else:
1264 mode = gitmode(man1.execf(f), man1.linkf(f))
1264 mode = gitmode(man1.execf(f), man1.linkf(f))
1265 header.append('deleted file mode %s\n' % mode)
1265 header.append('deleted file mode %s\n' % mode)
1266 else:
1266 else:
1267 omode = gitmode(man1.execf(f), man1.linkf(f))
1267 omode = gitmode(man1.execf(f), man1.linkf(f))
1268 nmode = gitmode(execf2(f), linkf2(f))
1268 nmode = gitmode(execf2(f), linkf2(f))
1269 addmodehdr(header, omode, nmode)
1269 addmodehdr(header, omode, nmode)
1270 if util.binary(to) or util.binary(tn):
1270 if util.binary(to) or util.binary(tn):
1271 dodiff = 'binary'
1271 dodiff = 'binary'
1272 r = None
1272 r = None
1273 header.insert(0, 'diff --git a/%s b/%s\n' % (a, b))
1273 header.insert(0, 'diff --git a/%s b/%s\n' % (a, b))
1274 if dodiff:
1274 if dodiff:
1275 if dodiff == 'binary':
1275 if dodiff == 'binary':
1276 text = b85diff(to, tn)
1276 text = b85diff(to, tn)
1277 else:
1277 else:
1278 text = mdiff.unidiff(to, date1,
1278 text = mdiff.unidiff(to, date1,
1279 # ctx2 date may be dynamic
1279 # ctx2 date may be dynamic
1280 tn, util.datestr(ctx2.date()),
1280 tn, util.datestr(ctx2.date()),
1281 a, b, r, opts=opts)
1281 a, b, r, opts=opts)
1282 if text or len(header) > 1:
1282 if text or len(header) > 1:
1283 fp.write(''.join(header))
1283 fp.write(''.join(header))
1284 fp.write(text)
1284 fp.write(text)
1285
1285
1286 def export(repo, revs, template='hg-%h.patch', fp=None, switch_parent=False,
1286 def export(repo, revs, template='hg-%h.patch', fp=None, switch_parent=False,
1287 opts=None):
1287 opts=None):
1288 '''export changesets as hg patches.'''
1288 '''export changesets as hg patches.'''
1289
1289
1290 total = len(revs)
1290 total = len(revs)
1291 revwidth = max([len(str(rev)) for rev in revs])
1291 revwidth = max([len(str(rev)) for rev in revs])
1292
1292
1293 def single(rev, seqno, fp):
1293 def single(rev, seqno, fp):
1294 ctx = repo.changectx(rev)
1294 ctx = repo.changectx(rev)
1295 node = ctx.node()
1295 node = ctx.node()
1296 parents = [p.node() for p in ctx.parents() if p]
1296 parents = [p.node() for p in ctx.parents() if p]
1297 branch = ctx.branch()
1297 branch = ctx.branch()
1298 if switch_parent:
1298 if switch_parent:
1299 parents.reverse()
1299 parents.reverse()
1300 prev = (parents and parents[0]) or nullid
1300 prev = (parents and parents[0]) or nullid
1301
1301
1302 if not fp:
1302 if not fp:
1303 fp = cmdutil.make_file(repo, template, node, total=total,
1303 fp = cmdutil.make_file(repo, template, node, total=total,
1304 seqno=seqno, revwidth=revwidth)
1304 seqno=seqno, revwidth=revwidth)
1305 if fp != sys.stdout and hasattr(fp, 'name'):
1305 if fp != sys.stdout and hasattr(fp, 'name'):
1306 repo.ui.note("%s\n" % fp.name)
1306 repo.ui.note("%s\n" % fp.name)
1307
1307
1308 fp.write("# HG changeset patch\n")
1308 fp.write("# HG changeset patch\n")
1309 fp.write("# User %s\n" % ctx.user())
1309 fp.write("# User %s\n" % ctx.user())
1310 fp.write("# Date %d %d\n" % ctx.date())
1310 fp.write("# Date %d %d\n" % ctx.date())
1311 if branch and (branch != 'default'):
1311 if branch and (branch != 'default'):
1312 fp.write("# Branch %s\n" % branch)
1312 fp.write("# Branch %s\n" % branch)
1313 fp.write("# Node ID %s\n" % hex(node))
1313 fp.write("# Node ID %s\n" % hex(node))
1314 fp.write("# Parent %s\n" % hex(prev))
1314 fp.write("# Parent %s\n" % hex(prev))
1315 if len(parents) > 1:
1315 if len(parents) > 1:
1316 fp.write("# Parent %s\n" % hex(parents[1]))
1316 fp.write("# Parent %s\n" % hex(parents[1]))
1317 fp.write(ctx.description().rstrip())
1317 fp.write(ctx.description().rstrip())
1318 fp.write("\n\n")
1318 fp.write("\n\n")
1319
1319
1320 diff(repo, prev, node, fp=fp, opts=opts)
1320 diff(repo, prev, node, fp=fp, opts=opts)
1321 if fp not in (sys.stdout, repo.ui):
1321 if fp not in (sys.stdout, repo.ui):
1322 fp.close()
1322 fp.close()
1323
1323
1324 for seqno, rev in enumerate(revs):
1324 for seqno, rev in enumerate(revs):
1325 single(rev, seqno+1, fp)
1325 single(rev, seqno+1, fp)
1326
1326
1327 def diffstat(patchlines):
1327 def diffstat(patchlines):
1328 if not util.find_exe('diffstat'):
1328 if not util.find_exe('diffstat'):
1329 return
1329 return
1330 fd, name = tempfile.mkstemp(prefix="hg-patchbomb-", suffix=".txt")
1330 fd, name = tempfile.mkstemp(prefix="hg-patchbomb-", suffix=".txt")
1331 try:
1331 try:
1332 p = popen2.Popen3('diffstat -p1 -w79 2>/dev/null > ' + name)
1332 p = popen2.Popen3('diffstat -p1 -w79 2>/dev/null > ' + name)
1333 try:
1333 try:
1334 for line in patchlines: print >> p.tochild, line
1334 for line in patchlines: print >> p.tochild, line
1335 p.tochild.close()
1335 p.tochild.close()
1336 if p.wait(): return
1336 if p.wait(): return
1337 fp = os.fdopen(fd, 'r')
1337 fp = os.fdopen(fd, 'r')
1338 stat = []
1338 stat = []
1339 for line in fp: stat.append(line.lstrip())
1339 for line in fp: stat.append(line.lstrip())
1340 last = stat.pop()
1340 last = stat.pop()
1341 stat.insert(0, last)
1341 stat.insert(0, last)
1342 stat = ''.join(stat)
1342 stat = ''.join(stat)
1343 if stat.startswith('0 files'): raise ValueError
1343 if stat.startswith('0 files'): raise ValueError
1344 return stat
1344 return stat
1345 except: raise
1345 except: raise
1346 finally:
1346 finally:
1347 try: os.unlink(name)
1347 try: os.unlink(name)
1348 except: pass
1348 except: pass
General Comments 0
You need to be logged in to leave comments. Login now