##// END OF EJS Templates
hg qseries -m: guards file was not ignored
Thomas Arendsen Hein -
r4241:7c59ade0 default
parent child Browse files
Show More
@@ -1,2192 +1,2193 b''
1 # queue.py - patch queues for mercurial
1 # queue.py - patch queues for mercurial
2 #
2 #
3 # Copyright 2005, 2006 Chris Mason <mason@suse.com>
3 # Copyright 2005, 2006 Chris Mason <mason@suse.com>
4 #
4 #
5 # This software may be used and distributed according to the terms
5 # This software may be used and distributed according to the terms
6 # of the GNU General Public License, incorporated herein by reference.
6 # of the GNU General Public License, incorporated herein by reference.
7
7
8 '''patch management and development
8 '''patch management and development
9
9
10 This extension lets you work with a stack of patches in a Mercurial
10 This extension lets you work with a stack of patches in a Mercurial
11 repository. It manages two stacks of patches - all known patches, and
11 repository. It manages two stacks of patches - all known patches, and
12 applied patches (subset of known patches).
12 applied patches (subset of known patches).
13
13
14 Known patches are represented as patch files in the .hg/patches
14 Known patches are represented as patch files in the .hg/patches
15 directory. Applied patches are both patch files and changesets.
15 directory. Applied patches are both patch files and changesets.
16
16
17 Common tasks (use "hg help command" for more details):
17 Common tasks (use "hg help command" for more details):
18
18
19 prepare repository to work with patches qinit
19 prepare repository to work with patches qinit
20 create new patch qnew
20 create new patch qnew
21 import existing patch qimport
21 import existing patch qimport
22
22
23 print patch series qseries
23 print patch series qseries
24 print applied patches qapplied
24 print applied patches qapplied
25 print name of top applied patch qtop
25 print name of top applied patch qtop
26
26
27 add known patch to applied stack qpush
27 add known patch to applied stack qpush
28 remove patch from applied stack qpop
28 remove patch from applied stack qpop
29 refresh contents of top applied patch qrefresh
29 refresh contents of top applied patch qrefresh
30 '''
30 '''
31
31
32 from mercurial.demandload import *
32 from mercurial.demandload import *
33 from mercurial.i18n import gettext as _
33 from mercurial.i18n import gettext as _
34 from mercurial import commands
34 from mercurial import commands
35 demandload(globals(), "os sys re struct traceback errno bz2")
35 demandload(globals(), "os sys re struct traceback errno bz2")
36 demandload(globals(), "mercurial:cmdutil,hg,patch,revlog,util,changegroup")
36 demandload(globals(), "mercurial:cmdutil,hg,patch,revlog,util,changegroup")
37
37
38 commands.norepo += " qclone qversion"
38 commands.norepo += " qclone qversion"
39
39
40 class statusentry:
40 class statusentry:
41 def __init__(self, rev, name=None):
41 def __init__(self, rev, name=None):
42 if not name:
42 if not name:
43 fields = rev.split(':', 1)
43 fields = rev.split(':', 1)
44 if len(fields) == 2:
44 if len(fields) == 2:
45 self.rev, self.name = fields
45 self.rev, self.name = fields
46 else:
46 else:
47 self.rev, self.name = None, None
47 self.rev, self.name = None, None
48 else:
48 else:
49 self.rev, self.name = rev, name
49 self.rev, self.name = rev, name
50
50
51 def __str__(self):
51 def __str__(self):
52 return self.rev + ':' + self.name
52 return self.rev + ':' + self.name
53
53
54 class queue:
54 class queue:
55 def __init__(self, ui, path, patchdir=None):
55 def __init__(self, ui, path, patchdir=None):
56 self.basepath = path
56 self.basepath = path
57 self.path = patchdir or os.path.join(path, "patches")
57 self.path = patchdir or os.path.join(path, "patches")
58 self.opener = util.opener(self.path)
58 self.opener = util.opener(self.path)
59 self.ui = ui
59 self.ui = ui
60 self.applied = []
60 self.applied = []
61 self.full_series = []
61 self.full_series = []
62 self.applied_dirty = 0
62 self.applied_dirty = 0
63 self.series_dirty = 0
63 self.series_dirty = 0
64 self.series_path = "series"
64 self.series_path = "series"
65 self.status_path = "status"
65 self.status_path = "status"
66 self.guards_path = "guards"
66 self.guards_path = "guards"
67 self.active_guards = None
67 self.active_guards = None
68 self.guards_dirty = False
68 self.guards_dirty = False
69 self._diffopts = None
69 self._diffopts = None
70
70
71 if os.path.exists(self.join(self.series_path)):
71 if os.path.exists(self.join(self.series_path)):
72 self.full_series = self.opener(self.series_path).read().splitlines()
72 self.full_series = self.opener(self.series_path).read().splitlines()
73 self.parse_series()
73 self.parse_series()
74
74
75 if os.path.exists(self.join(self.status_path)):
75 if os.path.exists(self.join(self.status_path)):
76 lines = self.opener(self.status_path).read().splitlines()
76 lines = self.opener(self.status_path).read().splitlines()
77 self.applied = [statusentry(l) for l in lines]
77 self.applied = [statusentry(l) for l in lines]
78
78
79 def diffopts(self):
79 def diffopts(self):
80 if self._diffopts is None:
80 if self._diffopts is None:
81 self._diffopts = patch.diffopts(self.ui)
81 self._diffopts = patch.diffopts(self.ui)
82 return self._diffopts
82 return self._diffopts
83
83
84 def join(self, *p):
84 def join(self, *p):
85 return os.path.join(self.path, *p)
85 return os.path.join(self.path, *p)
86
86
87 def find_series(self, patch):
87 def find_series(self, patch):
88 pre = re.compile("(\s*)([^#]+)")
88 pre = re.compile("(\s*)([^#]+)")
89 index = 0
89 index = 0
90 for l in self.full_series:
90 for l in self.full_series:
91 m = pre.match(l)
91 m = pre.match(l)
92 if m:
92 if m:
93 s = m.group(2)
93 s = m.group(2)
94 s = s.rstrip()
94 s = s.rstrip()
95 if s == patch:
95 if s == patch:
96 return index
96 return index
97 index += 1
97 index += 1
98 return None
98 return None
99
99
100 guard_re = re.compile(r'\s?#([-+][^-+# \t\r\n\f][^# \t\r\n\f]*)')
100 guard_re = re.compile(r'\s?#([-+][^-+# \t\r\n\f][^# \t\r\n\f]*)')
101
101
102 def parse_series(self):
102 def parse_series(self):
103 self.series = []
103 self.series = []
104 self.series_guards = []
104 self.series_guards = []
105 for l in self.full_series:
105 for l in self.full_series:
106 h = l.find('#')
106 h = l.find('#')
107 if h == -1:
107 if h == -1:
108 patch = l
108 patch = l
109 comment = ''
109 comment = ''
110 elif h == 0:
110 elif h == 0:
111 continue
111 continue
112 else:
112 else:
113 patch = l[:h]
113 patch = l[:h]
114 comment = l[h:]
114 comment = l[h:]
115 patch = patch.strip()
115 patch = patch.strip()
116 if patch:
116 if patch:
117 if patch in self.series:
117 if patch in self.series:
118 raise util.Abort(_('%s appears more than once in %s') %
118 raise util.Abort(_('%s appears more than once in %s') %
119 (patch, self.join(self.series_path)))
119 (patch, self.join(self.series_path)))
120 self.series.append(patch)
120 self.series.append(patch)
121 self.series_guards.append(self.guard_re.findall(comment))
121 self.series_guards.append(self.guard_re.findall(comment))
122
122
123 def check_guard(self, guard):
123 def check_guard(self, guard):
124 bad_chars = '# \t\r\n\f'
124 bad_chars = '# \t\r\n\f'
125 first = guard[0]
125 first = guard[0]
126 for c in '-+':
126 for c in '-+':
127 if first == c:
127 if first == c:
128 return (_('guard %r starts with invalid character: %r') %
128 return (_('guard %r starts with invalid character: %r') %
129 (guard, c))
129 (guard, c))
130 for c in bad_chars:
130 for c in bad_chars:
131 if c in guard:
131 if c in guard:
132 return _('invalid character in guard %r: %r') % (guard, c)
132 return _('invalid character in guard %r: %r') % (guard, c)
133
133
134 def set_active(self, guards):
134 def set_active(self, guards):
135 for guard in guards:
135 for guard in guards:
136 bad = self.check_guard(guard)
136 bad = self.check_guard(guard)
137 if bad:
137 if bad:
138 raise util.Abort(bad)
138 raise util.Abort(bad)
139 guards = dict.fromkeys(guards).keys()
139 guards = dict.fromkeys(guards).keys()
140 guards.sort()
140 guards.sort()
141 self.ui.debug('active guards: %s\n' % ' '.join(guards))
141 self.ui.debug('active guards: %s\n' % ' '.join(guards))
142 self.active_guards = guards
142 self.active_guards = guards
143 self.guards_dirty = True
143 self.guards_dirty = True
144
144
145 def active(self):
145 def active(self):
146 if self.active_guards is None:
146 if self.active_guards is None:
147 self.active_guards = []
147 self.active_guards = []
148 try:
148 try:
149 guards = self.opener(self.guards_path).read().split()
149 guards = self.opener(self.guards_path).read().split()
150 except IOError, err:
150 except IOError, err:
151 if err.errno != errno.ENOENT: raise
151 if err.errno != errno.ENOENT: raise
152 guards = []
152 guards = []
153 for i, guard in enumerate(guards):
153 for i, guard in enumerate(guards):
154 bad = self.check_guard(guard)
154 bad = self.check_guard(guard)
155 if bad:
155 if bad:
156 self.ui.warn('%s:%d: %s\n' %
156 self.ui.warn('%s:%d: %s\n' %
157 (self.join(self.guards_path), i + 1, bad))
157 (self.join(self.guards_path), i + 1, bad))
158 else:
158 else:
159 self.active_guards.append(guard)
159 self.active_guards.append(guard)
160 return self.active_guards
160 return self.active_guards
161
161
162 def set_guards(self, idx, guards):
162 def set_guards(self, idx, guards):
163 for g in guards:
163 for g in guards:
164 if len(g) < 2:
164 if len(g) < 2:
165 raise util.Abort(_('guard %r too short') % g)
165 raise util.Abort(_('guard %r too short') % g)
166 if g[0] not in '-+':
166 if g[0] not in '-+':
167 raise util.Abort(_('guard %r starts with invalid char') % g)
167 raise util.Abort(_('guard %r starts with invalid char') % g)
168 bad = self.check_guard(g[1:])
168 bad = self.check_guard(g[1:])
169 if bad:
169 if bad:
170 raise util.Abort(bad)
170 raise util.Abort(bad)
171 drop = self.guard_re.sub('', self.full_series[idx])
171 drop = self.guard_re.sub('', self.full_series[idx])
172 self.full_series[idx] = drop + ''.join([' #' + g for g in guards])
172 self.full_series[idx] = drop + ''.join([' #' + g for g in guards])
173 self.parse_series()
173 self.parse_series()
174 self.series_dirty = True
174 self.series_dirty = True
175
175
176 def pushable(self, idx):
176 def pushable(self, idx):
177 if isinstance(idx, str):
177 if isinstance(idx, str):
178 idx = self.series.index(idx)
178 idx = self.series.index(idx)
179 patchguards = self.series_guards[idx]
179 patchguards = self.series_guards[idx]
180 if not patchguards:
180 if not patchguards:
181 return True, None
181 return True, None
182 default = False
182 default = False
183 guards = self.active()
183 guards = self.active()
184 exactneg = [g for g in patchguards if g[0] == '-' and g[1:] in guards]
184 exactneg = [g for g in patchguards if g[0] == '-' and g[1:] in guards]
185 if exactneg:
185 if exactneg:
186 return False, exactneg[0]
186 return False, exactneg[0]
187 pos = [g for g in patchguards if g[0] == '+']
187 pos = [g for g in patchguards if g[0] == '+']
188 exactpos = [g for g in pos if g[1:] in guards]
188 exactpos = [g for g in pos if g[1:] in guards]
189 if pos:
189 if pos:
190 if exactpos:
190 if exactpos:
191 return True, exactpos[0]
191 return True, exactpos[0]
192 return False, pos
192 return False, pos
193 return True, ''
193 return True, ''
194
194
195 def explain_pushable(self, idx, all_patches=False):
195 def explain_pushable(self, idx, all_patches=False):
196 write = all_patches and self.ui.write or self.ui.warn
196 write = all_patches and self.ui.write or self.ui.warn
197 if all_patches or self.ui.verbose:
197 if all_patches or self.ui.verbose:
198 if isinstance(idx, str):
198 if isinstance(idx, str):
199 idx = self.series.index(idx)
199 idx = self.series.index(idx)
200 pushable, why = self.pushable(idx)
200 pushable, why = self.pushable(idx)
201 if all_patches and pushable:
201 if all_patches and pushable:
202 if why is None:
202 if why is None:
203 write(_('allowing %s - no guards in effect\n') %
203 write(_('allowing %s - no guards in effect\n') %
204 self.series[idx])
204 self.series[idx])
205 else:
205 else:
206 if not why:
206 if not why:
207 write(_('allowing %s - no matching negative guards\n') %
207 write(_('allowing %s - no matching negative guards\n') %
208 self.series[idx])
208 self.series[idx])
209 else:
209 else:
210 write(_('allowing %s - guarded by %r\n') %
210 write(_('allowing %s - guarded by %r\n') %
211 (self.series[idx], why))
211 (self.series[idx], why))
212 if not pushable:
212 if not pushable:
213 if why:
213 if why:
214 write(_('skipping %s - guarded by %r\n') %
214 write(_('skipping %s - guarded by %r\n') %
215 (self.series[idx], why))
215 (self.series[idx], why))
216 else:
216 else:
217 write(_('skipping %s - no matching guards\n') %
217 write(_('skipping %s - no matching guards\n') %
218 self.series[idx])
218 self.series[idx])
219
219
220 def save_dirty(self):
220 def save_dirty(self):
221 def write_list(items, path):
221 def write_list(items, path):
222 fp = self.opener(path, 'w')
222 fp = self.opener(path, 'w')
223 for i in items:
223 for i in items:
224 print >> fp, i
224 print >> fp, i
225 fp.close()
225 fp.close()
226 if self.applied_dirty: write_list(map(str, self.applied), self.status_path)
226 if self.applied_dirty: write_list(map(str, self.applied), self.status_path)
227 if self.series_dirty: write_list(self.full_series, self.series_path)
227 if self.series_dirty: write_list(self.full_series, self.series_path)
228 if self.guards_dirty: write_list(self.active_guards, self.guards_path)
228 if self.guards_dirty: write_list(self.active_guards, self.guards_path)
229
229
230 def readheaders(self, patch):
230 def readheaders(self, patch):
231 def eatdiff(lines):
231 def eatdiff(lines):
232 while lines:
232 while lines:
233 l = lines[-1]
233 l = lines[-1]
234 if (l.startswith("diff -") or
234 if (l.startswith("diff -") or
235 l.startswith("Index:") or
235 l.startswith("Index:") or
236 l.startswith("===========")):
236 l.startswith("===========")):
237 del lines[-1]
237 del lines[-1]
238 else:
238 else:
239 break
239 break
240 def eatempty(lines):
240 def eatempty(lines):
241 while lines:
241 while lines:
242 l = lines[-1]
242 l = lines[-1]
243 if re.match('\s*$', l):
243 if re.match('\s*$', l):
244 del lines[-1]
244 del lines[-1]
245 else:
245 else:
246 break
246 break
247
247
248 pf = self.join(patch)
248 pf = self.join(patch)
249 message = []
249 message = []
250 comments = []
250 comments = []
251 user = None
251 user = None
252 date = None
252 date = None
253 format = None
253 format = None
254 subject = None
254 subject = None
255 diffstart = 0
255 diffstart = 0
256
256
257 for line in file(pf):
257 for line in file(pf):
258 line = line.rstrip()
258 line = line.rstrip()
259 if line.startswith('diff --git'):
259 if line.startswith('diff --git'):
260 diffstart = 2
260 diffstart = 2
261 break
261 break
262 if diffstart:
262 if diffstart:
263 if line.startswith('+++ '):
263 if line.startswith('+++ '):
264 diffstart = 2
264 diffstart = 2
265 break
265 break
266 if line.startswith("--- "):
266 if line.startswith("--- "):
267 diffstart = 1
267 diffstart = 1
268 continue
268 continue
269 elif format == "hgpatch":
269 elif format == "hgpatch":
270 # parse values when importing the result of an hg export
270 # parse values when importing the result of an hg export
271 if line.startswith("# User "):
271 if line.startswith("# User "):
272 user = line[7:]
272 user = line[7:]
273 elif line.startswith("# Date "):
273 elif line.startswith("# Date "):
274 date = line[7:]
274 date = line[7:]
275 elif not line.startswith("# ") and line:
275 elif not line.startswith("# ") and line:
276 message.append(line)
276 message.append(line)
277 format = None
277 format = None
278 elif line == '# HG changeset patch':
278 elif line == '# HG changeset patch':
279 format = "hgpatch"
279 format = "hgpatch"
280 elif (format != "tagdone" and (line.startswith("Subject: ") or
280 elif (format != "tagdone" and (line.startswith("Subject: ") or
281 line.startswith("subject: "))):
281 line.startswith("subject: "))):
282 subject = line[9:]
282 subject = line[9:]
283 format = "tag"
283 format = "tag"
284 elif (format != "tagdone" and (line.startswith("From: ") or
284 elif (format != "tagdone" and (line.startswith("From: ") or
285 line.startswith("from: "))):
285 line.startswith("from: "))):
286 user = line[6:]
286 user = line[6:]
287 format = "tag"
287 format = "tag"
288 elif format == "tag" and line == "":
288 elif format == "tag" and line == "":
289 # when looking for tags (subject: from: etc) they
289 # when looking for tags (subject: from: etc) they
290 # end once you find a blank line in the source
290 # end once you find a blank line in the source
291 format = "tagdone"
291 format = "tagdone"
292 elif message or line:
292 elif message or line:
293 message.append(line)
293 message.append(line)
294 comments.append(line)
294 comments.append(line)
295
295
296 eatdiff(message)
296 eatdiff(message)
297 eatdiff(comments)
297 eatdiff(comments)
298 eatempty(message)
298 eatempty(message)
299 eatempty(comments)
299 eatempty(comments)
300
300
301 # make sure message isn't empty
301 # make sure message isn't empty
302 if format and format.startswith("tag") and subject:
302 if format and format.startswith("tag") and subject:
303 message.insert(0, "")
303 message.insert(0, "")
304 message.insert(0, subject)
304 message.insert(0, subject)
305 return (message, comments, user, date, diffstart > 1)
305 return (message, comments, user, date, diffstart > 1)
306
306
307 def printdiff(self, repo, node1, node2=None, files=None,
307 def printdiff(self, repo, node1, node2=None, files=None,
308 fp=None, changes=None, opts={}):
308 fp=None, changes=None, opts={}):
309 fns, matchfn, anypats = cmdutil.matchpats(repo, files, opts)
309 fns, matchfn, anypats = cmdutil.matchpats(repo, files, opts)
310
310
311 patch.diff(repo, node1, node2, fns, match=matchfn,
311 patch.diff(repo, node1, node2, fns, match=matchfn,
312 fp=fp, changes=changes, opts=self.diffopts())
312 fp=fp, changes=changes, opts=self.diffopts())
313
313
314 def mergeone(self, repo, mergeq, head, patch, rev, wlock):
314 def mergeone(self, repo, mergeq, head, patch, rev, wlock):
315 # first try just applying the patch
315 # first try just applying the patch
316 (err, n) = self.apply(repo, [ patch ], update_status=False,
316 (err, n) = self.apply(repo, [ patch ], update_status=False,
317 strict=True, merge=rev, wlock=wlock)
317 strict=True, merge=rev, wlock=wlock)
318
318
319 if err == 0:
319 if err == 0:
320 return (err, n)
320 return (err, n)
321
321
322 if n is None:
322 if n is None:
323 raise util.Abort(_("apply failed for patch %s") % patch)
323 raise util.Abort(_("apply failed for patch %s") % patch)
324
324
325 self.ui.warn("patch didn't work out, merging %s\n" % patch)
325 self.ui.warn("patch didn't work out, merging %s\n" % patch)
326
326
327 # apply failed, strip away that rev and merge.
327 # apply failed, strip away that rev and merge.
328 hg.clean(repo, head, wlock=wlock)
328 hg.clean(repo, head, wlock=wlock)
329 self.strip(repo, n, update=False, backup='strip', wlock=wlock)
329 self.strip(repo, n, update=False, backup='strip', wlock=wlock)
330
330
331 c = repo.changelog.read(rev)
331 c = repo.changelog.read(rev)
332 ret = hg.merge(repo, rev, wlock=wlock)
332 ret = hg.merge(repo, rev, wlock=wlock)
333 if ret:
333 if ret:
334 raise util.Abort(_("update returned %d") % ret)
334 raise util.Abort(_("update returned %d") % ret)
335 n = repo.commit(None, c[4], c[1], force=1, wlock=wlock)
335 n = repo.commit(None, c[4], c[1], force=1, wlock=wlock)
336 if n == None:
336 if n == None:
337 raise util.Abort(_("repo commit failed"))
337 raise util.Abort(_("repo commit failed"))
338 try:
338 try:
339 message, comments, user, date, patchfound = mergeq.readheaders(patch)
339 message, comments, user, date, patchfound = mergeq.readheaders(patch)
340 except:
340 except:
341 raise util.Abort(_("unable to read %s") % patch)
341 raise util.Abort(_("unable to read %s") % patch)
342
342
343 patchf = self.opener(patch, "w")
343 patchf = self.opener(patch, "w")
344 if comments:
344 if comments:
345 comments = "\n".join(comments) + '\n\n'
345 comments = "\n".join(comments) + '\n\n'
346 patchf.write(comments)
346 patchf.write(comments)
347 self.printdiff(repo, head, n, fp=patchf)
347 self.printdiff(repo, head, n, fp=patchf)
348 patchf.close()
348 patchf.close()
349 return (0, n)
349 return (0, n)
350
350
351 def qparents(self, repo, rev=None):
351 def qparents(self, repo, rev=None):
352 if rev is None:
352 if rev is None:
353 (p1, p2) = repo.dirstate.parents()
353 (p1, p2) = repo.dirstate.parents()
354 if p2 == revlog.nullid:
354 if p2 == revlog.nullid:
355 return p1
355 return p1
356 if len(self.applied) == 0:
356 if len(self.applied) == 0:
357 return None
357 return None
358 return revlog.bin(self.applied[-1].rev)
358 return revlog.bin(self.applied[-1].rev)
359 pp = repo.changelog.parents(rev)
359 pp = repo.changelog.parents(rev)
360 if pp[1] != revlog.nullid:
360 if pp[1] != revlog.nullid:
361 arevs = [ x.rev for x in self.applied ]
361 arevs = [ x.rev for x in self.applied ]
362 p0 = revlog.hex(pp[0])
362 p0 = revlog.hex(pp[0])
363 p1 = revlog.hex(pp[1])
363 p1 = revlog.hex(pp[1])
364 if p0 in arevs:
364 if p0 in arevs:
365 return pp[0]
365 return pp[0]
366 if p1 in arevs:
366 if p1 in arevs:
367 return pp[1]
367 return pp[1]
368 return pp[0]
368 return pp[0]
369
369
370 def mergepatch(self, repo, mergeq, series, wlock):
370 def mergepatch(self, repo, mergeq, series, wlock):
371 if len(self.applied) == 0:
371 if len(self.applied) == 0:
372 # each of the patches merged in will have two parents. This
372 # each of the patches merged in will have two parents. This
373 # can confuse the qrefresh, qdiff, and strip code because it
373 # can confuse the qrefresh, qdiff, and strip code because it
374 # needs to know which parent is actually in the patch queue.
374 # needs to know which parent is actually in the patch queue.
375 # so, we insert a merge marker with only one parent. This way
375 # so, we insert a merge marker with only one parent. This way
376 # the first patch in the queue is never a merge patch
376 # the first patch in the queue is never a merge patch
377 #
377 #
378 pname = ".hg.patches.merge.marker"
378 pname = ".hg.patches.merge.marker"
379 n = repo.commit(None, '[mq]: merge marker', user=None, force=1,
379 n = repo.commit(None, '[mq]: merge marker', user=None, force=1,
380 wlock=wlock)
380 wlock=wlock)
381 self.applied.append(statusentry(revlog.hex(n), pname))
381 self.applied.append(statusentry(revlog.hex(n), pname))
382 self.applied_dirty = 1
382 self.applied_dirty = 1
383
383
384 head = self.qparents(repo)
384 head = self.qparents(repo)
385
385
386 for patch in series:
386 for patch in series:
387 patch = mergeq.lookup(patch, strict=True)
387 patch = mergeq.lookup(patch, strict=True)
388 if not patch:
388 if not patch:
389 self.ui.warn("patch %s does not exist\n" % patch)
389 self.ui.warn("patch %s does not exist\n" % patch)
390 return (1, None)
390 return (1, None)
391 pushable, reason = self.pushable(patch)
391 pushable, reason = self.pushable(patch)
392 if not pushable:
392 if not pushable:
393 self.explain_pushable(patch, all_patches=True)
393 self.explain_pushable(patch, all_patches=True)
394 continue
394 continue
395 info = mergeq.isapplied(patch)
395 info = mergeq.isapplied(patch)
396 if not info:
396 if not info:
397 self.ui.warn("patch %s is not applied\n" % patch)
397 self.ui.warn("patch %s is not applied\n" % patch)
398 return (1, None)
398 return (1, None)
399 rev = revlog.bin(info[1])
399 rev = revlog.bin(info[1])
400 (err, head) = self.mergeone(repo, mergeq, head, patch, rev, wlock)
400 (err, head) = self.mergeone(repo, mergeq, head, patch, rev, wlock)
401 if head:
401 if head:
402 self.applied.append(statusentry(revlog.hex(head), patch))
402 self.applied.append(statusentry(revlog.hex(head), patch))
403 self.applied_dirty = 1
403 self.applied_dirty = 1
404 if err:
404 if err:
405 return (err, head)
405 return (err, head)
406 return (0, head)
406 return (0, head)
407
407
408 def patch(self, repo, patchfile):
408 def patch(self, repo, patchfile):
409 '''Apply patchfile to the working directory.
409 '''Apply patchfile to the working directory.
410 patchfile: file name of patch'''
410 patchfile: file name of patch'''
411 files = {}
411 files = {}
412 try:
412 try:
413 fuzz = patch.patch(patchfile, self.ui, strip=1, cwd=repo.root,
413 fuzz = patch.patch(patchfile, self.ui, strip=1, cwd=repo.root,
414 files=files)
414 files=files)
415 except Exception, inst:
415 except Exception, inst:
416 self.ui.note(str(inst) + '\n')
416 self.ui.note(str(inst) + '\n')
417 if not self.ui.verbose:
417 if not self.ui.verbose:
418 self.ui.warn("patch failed, unable to continue (try -v)\n")
418 self.ui.warn("patch failed, unable to continue (try -v)\n")
419 return (False, files, False)
419 return (False, files, False)
420
420
421 return (True, files, fuzz)
421 return (True, files, fuzz)
422
422
423 def apply(self, repo, series, list=False, update_status=True,
423 def apply(self, repo, series, list=False, update_status=True,
424 strict=False, patchdir=None, merge=None, wlock=None):
424 strict=False, patchdir=None, merge=None, wlock=None):
425 # TODO unify with commands.py
425 # TODO unify with commands.py
426 if not patchdir:
426 if not patchdir:
427 patchdir = self.path
427 patchdir = self.path
428 err = 0
428 err = 0
429 if not wlock:
429 if not wlock:
430 wlock = repo.wlock()
430 wlock = repo.wlock()
431 lock = repo.lock()
431 lock = repo.lock()
432 tr = repo.transaction()
432 tr = repo.transaction()
433 n = None
433 n = None
434 for patchname in series:
434 for patchname in series:
435 pushable, reason = self.pushable(patchname)
435 pushable, reason = self.pushable(patchname)
436 if not pushable:
436 if not pushable:
437 self.explain_pushable(patchname, all_patches=True)
437 self.explain_pushable(patchname, all_patches=True)
438 continue
438 continue
439 self.ui.warn("applying %s\n" % patchname)
439 self.ui.warn("applying %s\n" % patchname)
440 pf = os.path.join(patchdir, patchname)
440 pf = os.path.join(patchdir, patchname)
441
441
442 try:
442 try:
443 message, comments, user, date, patchfound = self.readheaders(patchname)
443 message, comments, user, date, patchfound = self.readheaders(patchname)
444 except:
444 except:
445 self.ui.warn("Unable to read %s\n" % patchname)
445 self.ui.warn("Unable to read %s\n" % patchname)
446 err = 1
446 err = 1
447 break
447 break
448
448
449 if not message:
449 if not message:
450 message = "imported patch %s\n" % patchname
450 message = "imported patch %s\n" % patchname
451 else:
451 else:
452 if list:
452 if list:
453 message.append("\nimported patch %s" % patchname)
453 message.append("\nimported patch %s" % patchname)
454 message = '\n'.join(message)
454 message = '\n'.join(message)
455
455
456 (patcherr, files, fuzz) = self.patch(repo, pf)
456 (patcherr, files, fuzz) = self.patch(repo, pf)
457 patcherr = not patcherr
457 patcherr = not patcherr
458
458
459 if merge and files:
459 if merge and files:
460 # Mark as merged and update dirstate parent info
460 # Mark as merged and update dirstate parent info
461 repo.dirstate.update(repo.dirstate.filterfiles(files.keys()), 'm')
461 repo.dirstate.update(repo.dirstate.filterfiles(files.keys()), 'm')
462 p1, p2 = repo.dirstate.parents()
462 p1, p2 = repo.dirstate.parents()
463 repo.dirstate.setparents(p1, merge)
463 repo.dirstate.setparents(p1, merge)
464 files = patch.updatedir(self.ui, repo, files, wlock=wlock)
464 files = patch.updatedir(self.ui, repo, files, wlock=wlock)
465 n = repo.commit(files, message, user, date, force=1, lock=lock,
465 n = repo.commit(files, message, user, date, force=1, lock=lock,
466 wlock=wlock)
466 wlock=wlock)
467
467
468 if n == None:
468 if n == None:
469 raise util.Abort(_("repo commit failed"))
469 raise util.Abort(_("repo commit failed"))
470
470
471 if update_status:
471 if update_status:
472 self.applied.append(statusentry(revlog.hex(n), patchname))
472 self.applied.append(statusentry(revlog.hex(n), patchname))
473
473
474 if patcherr:
474 if patcherr:
475 if not patchfound:
475 if not patchfound:
476 self.ui.warn("patch %s is empty\n" % patchname)
476 self.ui.warn("patch %s is empty\n" % patchname)
477 err = 0
477 err = 0
478 else:
478 else:
479 self.ui.warn("patch failed, rejects left in working dir\n")
479 self.ui.warn("patch failed, rejects left in working dir\n")
480 err = 1
480 err = 1
481 break
481 break
482
482
483 if fuzz and strict:
483 if fuzz and strict:
484 self.ui.warn("fuzz found when applying patch, stopping\n")
484 self.ui.warn("fuzz found when applying patch, stopping\n")
485 err = 1
485 err = 1
486 break
486 break
487 tr.close()
487 tr.close()
488 return (err, n)
488 return (err, n)
489
489
490 def delete(self, repo, patches, opts):
490 def delete(self, repo, patches, opts):
491 realpatches = []
491 realpatches = []
492 for patch in patches:
492 for patch in patches:
493 patch = self.lookup(patch, strict=True)
493 patch = self.lookup(patch, strict=True)
494 info = self.isapplied(patch)
494 info = self.isapplied(patch)
495 if info:
495 if info:
496 raise util.Abort(_("cannot delete applied patch %s") % patch)
496 raise util.Abort(_("cannot delete applied patch %s") % patch)
497 if patch not in self.series:
497 if patch not in self.series:
498 raise util.Abort(_("patch %s not in series file") % patch)
498 raise util.Abort(_("patch %s not in series file") % patch)
499 realpatches.append(patch)
499 realpatches.append(patch)
500
500
501 appliedbase = 0
501 appliedbase = 0
502 if opts.get('rev'):
502 if opts.get('rev'):
503 if not self.applied:
503 if not self.applied:
504 raise util.Abort(_('no patches applied'))
504 raise util.Abort(_('no patches applied'))
505 revs = cmdutil.revrange(repo, opts['rev'])
505 revs = cmdutil.revrange(repo, opts['rev'])
506 if len(revs) > 1 and revs[0] > revs[1]:
506 if len(revs) > 1 and revs[0] > revs[1]:
507 revs.reverse()
507 revs.reverse()
508 for rev in revs:
508 for rev in revs:
509 if appliedbase >= len(self.applied):
509 if appliedbase >= len(self.applied):
510 raise util.Abort(_("revision %d is not managed") % rev)
510 raise util.Abort(_("revision %d is not managed") % rev)
511
511
512 base = revlog.bin(self.applied[appliedbase].rev)
512 base = revlog.bin(self.applied[appliedbase].rev)
513 node = repo.changelog.node(rev)
513 node = repo.changelog.node(rev)
514 if node != base:
514 if node != base:
515 raise util.Abort(_("cannot delete revision %d above "
515 raise util.Abort(_("cannot delete revision %d above "
516 "applied patches") % rev)
516 "applied patches") % rev)
517 realpatches.append(self.applied[appliedbase].name)
517 realpatches.append(self.applied[appliedbase].name)
518 appliedbase += 1
518 appliedbase += 1
519
519
520 if not opts.get('keep'):
520 if not opts.get('keep'):
521 r = self.qrepo()
521 r = self.qrepo()
522 if r:
522 if r:
523 r.remove(realpatches, True)
523 r.remove(realpatches, True)
524 else:
524 else:
525 for p in realpatches:
525 for p in realpatches:
526 os.unlink(self.join(p))
526 os.unlink(self.join(p))
527
527
528 if appliedbase:
528 if appliedbase:
529 del self.applied[:appliedbase]
529 del self.applied[:appliedbase]
530 self.applied_dirty = 1
530 self.applied_dirty = 1
531 indices = [self.find_series(p) for p in realpatches]
531 indices = [self.find_series(p) for p in realpatches]
532 indices.sort()
532 indices.sort()
533 for i in indices[-1::-1]:
533 for i in indices[-1::-1]:
534 del self.full_series[i]
534 del self.full_series[i]
535 self.parse_series()
535 self.parse_series()
536 self.series_dirty = 1
536 self.series_dirty = 1
537
537
538 def check_toppatch(self, repo):
538 def check_toppatch(self, repo):
539 if len(self.applied) > 0:
539 if len(self.applied) > 0:
540 top = revlog.bin(self.applied[-1].rev)
540 top = revlog.bin(self.applied[-1].rev)
541 pp = repo.dirstate.parents()
541 pp = repo.dirstate.parents()
542 if top not in pp:
542 if top not in pp:
543 raise util.Abort(_("queue top not at same revision as working directory"))
543 raise util.Abort(_("queue top not at same revision as working directory"))
544 return top
544 return top
545 return None
545 return None
546 def check_localchanges(self, repo, force=False, refresh=True):
546 def check_localchanges(self, repo, force=False, refresh=True):
547 m, a, r, d = repo.status()[:4]
547 m, a, r, d = repo.status()[:4]
548 if m or a or r or d:
548 if m or a or r or d:
549 if not force:
549 if not force:
550 if refresh:
550 if refresh:
551 raise util.Abort(_("local changes found, refresh first"))
551 raise util.Abort(_("local changes found, refresh first"))
552 else:
552 else:
553 raise util.Abort(_("local changes found"))
553 raise util.Abort(_("local changes found"))
554 return m, a, r, d
554 return m, a, r, d
555 def new(self, repo, patch, msg=None, force=None):
555 def new(self, repo, patch, msg=None, force=None):
556 if os.path.exists(self.join(patch)):
556 if os.path.exists(self.join(patch)):
557 raise util.Abort(_('patch "%s" already exists') % patch)
557 raise util.Abort(_('patch "%s" already exists') % patch)
558 m, a, r, d = self.check_localchanges(repo, force)
558 m, a, r, d = self.check_localchanges(repo, force)
559 commitfiles = m + a + r
559 commitfiles = m + a + r
560 self.check_toppatch(repo)
560 self.check_toppatch(repo)
561 wlock = repo.wlock()
561 wlock = repo.wlock()
562 insert = self.full_series_end()
562 insert = self.full_series_end()
563 if msg:
563 if msg:
564 n = repo.commit(commitfiles, "[mq]: %s" % msg, force=True,
564 n = repo.commit(commitfiles, "[mq]: %s" % msg, force=True,
565 wlock=wlock)
565 wlock=wlock)
566 else:
566 else:
567 n = repo.commit(commitfiles,
567 n = repo.commit(commitfiles,
568 "New patch: %s" % patch, force=True, wlock=wlock)
568 "New patch: %s" % patch, force=True, wlock=wlock)
569 if n == None:
569 if n == None:
570 raise util.Abort(_("repo commit failed"))
570 raise util.Abort(_("repo commit failed"))
571 self.full_series[insert:insert] = [patch]
571 self.full_series[insert:insert] = [patch]
572 self.applied.append(statusentry(revlog.hex(n), patch))
572 self.applied.append(statusentry(revlog.hex(n), patch))
573 self.parse_series()
573 self.parse_series()
574 self.series_dirty = 1
574 self.series_dirty = 1
575 self.applied_dirty = 1
575 self.applied_dirty = 1
576 p = self.opener(patch, "w")
576 p = self.opener(patch, "w")
577 if msg:
577 if msg:
578 msg = msg + "\n"
578 msg = msg + "\n"
579 p.write(msg)
579 p.write(msg)
580 p.close()
580 p.close()
581 wlock = None
581 wlock = None
582 r = self.qrepo()
582 r = self.qrepo()
583 if r: r.add([patch])
583 if r: r.add([patch])
584 if commitfiles:
584 if commitfiles:
585 self.refresh(repo, short=True)
585 self.refresh(repo, short=True)
586
586
587 def strip(self, repo, rev, update=True, backup="all", wlock=None):
587 def strip(self, repo, rev, update=True, backup="all", wlock=None):
588 def limitheads(chlog, stop):
588 def limitheads(chlog, stop):
589 """return the list of all nodes that have no children"""
589 """return the list of all nodes that have no children"""
590 p = {}
590 p = {}
591 h = []
591 h = []
592 stoprev = 0
592 stoprev = 0
593 if stop in chlog.nodemap:
593 if stop in chlog.nodemap:
594 stoprev = chlog.rev(stop)
594 stoprev = chlog.rev(stop)
595
595
596 for r in xrange(chlog.count() - 1, -1, -1):
596 for r in xrange(chlog.count() - 1, -1, -1):
597 n = chlog.node(r)
597 n = chlog.node(r)
598 if n not in p:
598 if n not in p:
599 h.append(n)
599 h.append(n)
600 if n == stop:
600 if n == stop:
601 break
601 break
602 if r < stoprev:
602 if r < stoprev:
603 break
603 break
604 for pn in chlog.parents(n):
604 for pn in chlog.parents(n):
605 p[pn] = 1
605 p[pn] = 1
606 return h
606 return h
607
607
608 def bundle(cg):
608 def bundle(cg):
609 backupdir = repo.join("strip-backup")
609 backupdir = repo.join("strip-backup")
610 if not os.path.isdir(backupdir):
610 if not os.path.isdir(backupdir):
611 os.mkdir(backupdir)
611 os.mkdir(backupdir)
612 name = os.path.join(backupdir, "%s" % revlog.short(rev))
612 name = os.path.join(backupdir, "%s" % revlog.short(rev))
613 name = savename(name)
613 name = savename(name)
614 self.ui.warn("saving bundle to %s\n" % name)
614 self.ui.warn("saving bundle to %s\n" % name)
615 return changegroup.writebundle(cg, name, "HG10BZ")
615 return changegroup.writebundle(cg, name, "HG10BZ")
616
616
617 def stripall(rev, revnum):
617 def stripall(rev, revnum):
618 cl = repo.changelog
618 cl = repo.changelog
619 c = cl.read(rev)
619 c = cl.read(rev)
620 mm = repo.manifest.read(c[0])
620 mm = repo.manifest.read(c[0])
621 seen = {}
621 seen = {}
622
622
623 for x in xrange(revnum, cl.count()):
623 for x in xrange(revnum, cl.count()):
624 c = cl.read(cl.node(x))
624 c = cl.read(cl.node(x))
625 for f in c[3]:
625 for f in c[3]:
626 if f in seen:
626 if f in seen:
627 continue
627 continue
628 seen[f] = 1
628 seen[f] = 1
629 if f in mm:
629 if f in mm:
630 filerev = mm[f]
630 filerev = mm[f]
631 else:
631 else:
632 filerev = 0
632 filerev = 0
633 seen[f] = filerev
633 seen[f] = filerev
634 # we go in two steps here so the strip loop happens in a
634 # we go in two steps here so the strip loop happens in a
635 # sensible order. When stripping many files, this helps keep
635 # sensible order. When stripping many files, this helps keep
636 # our disk access patterns under control.
636 # our disk access patterns under control.
637 seen_list = seen.keys()
637 seen_list = seen.keys()
638 seen_list.sort()
638 seen_list.sort()
639 for f in seen_list:
639 for f in seen_list:
640 ff = repo.file(f)
640 ff = repo.file(f)
641 filerev = seen[f]
641 filerev = seen[f]
642 if filerev != 0:
642 if filerev != 0:
643 if filerev in ff.nodemap:
643 if filerev in ff.nodemap:
644 filerev = ff.rev(filerev)
644 filerev = ff.rev(filerev)
645 else:
645 else:
646 filerev = 0
646 filerev = 0
647 ff.strip(filerev, revnum)
647 ff.strip(filerev, revnum)
648
648
649 if not wlock:
649 if not wlock:
650 wlock = repo.wlock()
650 wlock = repo.wlock()
651 lock = repo.lock()
651 lock = repo.lock()
652 chlog = repo.changelog
652 chlog = repo.changelog
653 # TODO delete the undo files, and handle undo of merge sets
653 # TODO delete the undo files, and handle undo of merge sets
654 pp = chlog.parents(rev)
654 pp = chlog.parents(rev)
655 revnum = chlog.rev(rev)
655 revnum = chlog.rev(rev)
656
656
657 if update:
657 if update:
658 self.check_localchanges(repo, refresh=False)
658 self.check_localchanges(repo, refresh=False)
659 urev = self.qparents(repo, rev)
659 urev = self.qparents(repo, rev)
660 hg.clean(repo, urev, wlock=wlock)
660 hg.clean(repo, urev, wlock=wlock)
661 repo.dirstate.write()
661 repo.dirstate.write()
662
662
663 # save is a list of all the branches we are truncating away
663 # save is a list of all the branches we are truncating away
664 # that we actually want to keep. changegroup will be used
664 # that we actually want to keep. changegroup will be used
665 # to preserve them and add them back after the truncate
665 # to preserve them and add them back after the truncate
666 saveheads = []
666 saveheads = []
667 savebases = {}
667 savebases = {}
668
668
669 heads = limitheads(chlog, rev)
669 heads = limitheads(chlog, rev)
670 seen = {}
670 seen = {}
671
671
672 # search through all the heads, finding those where the revision
672 # search through all the heads, finding those where the revision
673 # we want to strip away is an ancestor. Also look for merges
673 # we want to strip away is an ancestor. Also look for merges
674 # that might be turned into new heads by the strip.
674 # that might be turned into new heads by the strip.
675 while heads:
675 while heads:
676 h = heads.pop()
676 h = heads.pop()
677 n = h
677 n = h
678 while True:
678 while True:
679 seen[n] = 1
679 seen[n] = 1
680 pp = chlog.parents(n)
680 pp = chlog.parents(n)
681 if pp[1] != revlog.nullid:
681 if pp[1] != revlog.nullid:
682 for p in pp:
682 for p in pp:
683 if chlog.rev(p) > revnum and p not in seen:
683 if chlog.rev(p) > revnum and p not in seen:
684 heads.append(p)
684 heads.append(p)
685 if pp[0] == revlog.nullid:
685 if pp[0] == revlog.nullid:
686 break
686 break
687 if chlog.rev(pp[0]) < revnum:
687 if chlog.rev(pp[0]) < revnum:
688 break
688 break
689 n = pp[0]
689 n = pp[0]
690 if n == rev:
690 if n == rev:
691 break
691 break
692 r = chlog.reachable(h, rev)
692 r = chlog.reachable(h, rev)
693 if rev not in r:
693 if rev not in r:
694 saveheads.append(h)
694 saveheads.append(h)
695 for x in r:
695 for x in r:
696 if chlog.rev(x) > revnum:
696 if chlog.rev(x) > revnum:
697 savebases[x] = 1
697 savebases[x] = 1
698
698
699 # create a changegroup for all the branches we need to keep
699 # create a changegroup for all the branches we need to keep
700 if backup == "all":
700 if backup == "all":
701 backupch = repo.changegroupsubset([rev], chlog.heads(), 'strip')
701 backupch = repo.changegroupsubset([rev], chlog.heads(), 'strip')
702 bundle(backupch)
702 bundle(backupch)
703 if saveheads:
703 if saveheads:
704 backupch = repo.changegroupsubset(savebases.keys(), saveheads, 'strip')
704 backupch = repo.changegroupsubset(savebases.keys(), saveheads, 'strip')
705 chgrpfile = bundle(backupch)
705 chgrpfile = bundle(backupch)
706
706
707 stripall(rev, revnum)
707 stripall(rev, revnum)
708
708
709 change = chlog.read(rev)
709 change = chlog.read(rev)
710 chlog.strip(revnum, revnum)
710 chlog.strip(revnum, revnum)
711 repo.manifest.strip(repo.manifest.rev(change[0]), revnum)
711 repo.manifest.strip(repo.manifest.rev(change[0]), revnum)
712 if saveheads:
712 if saveheads:
713 self.ui.status("adding branch\n")
713 self.ui.status("adding branch\n")
714 commands.unbundle(self.ui, repo, "file:%s" % chgrpfile,
714 commands.unbundle(self.ui, repo, "file:%s" % chgrpfile,
715 update=False)
715 update=False)
716 if backup != "strip":
716 if backup != "strip":
717 os.unlink(chgrpfile)
717 os.unlink(chgrpfile)
718
718
719 def isapplied(self, patch):
719 def isapplied(self, patch):
720 """returns (index, rev, patch)"""
720 """returns (index, rev, patch)"""
721 for i in xrange(len(self.applied)):
721 for i in xrange(len(self.applied)):
722 a = self.applied[i]
722 a = self.applied[i]
723 if a.name == patch:
723 if a.name == patch:
724 return (i, a.rev, a.name)
724 return (i, a.rev, a.name)
725 return None
725 return None
726
726
727 # if the exact patch name does not exist, we try a few
727 # if the exact patch name does not exist, we try a few
728 # variations. If strict is passed, we try only #1
728 # variations. If strict is passed, we try only #1
729 #
729 #
730 # 1) a number to indicate an offset in the series file
730 # 1) a number to indicate an offset in the series file
731 # 2) a unique substring of the patch name was given
731 # 2) a unique substring of the patch name was given
732 # 3) patchname[-+]num to indicate an offset in the series file
732 # 3) patchname[-+]num to indicate an offset in the series file
733 def lookup(self, patch, strict=False):
733 def lookup(self, patch, strict=False):
734 patch = patch and str(patch)
734 patch = patch and str(patch)
735
735
736 def partial_name(s):
736 def partial_name(s):
737 if s in self.series:
737 if s in self.series:
738 return s
738 return s
739 matches = [x for x in self.series if s in x]
739 matches = [x for x in self.series if s in x]
740 if len(matches) > 1:
740 if len(matches) > 1:
741 self.ui.warn(_('patch name "%s" is ambiguous:\n') % s)
741 self.ui.warn(_('patch name "%s" is ambiguous:\n') % s)
742 for m in matches:
742 for m in matches:
743 self.ui.warn(' %s\n' % m)
743 self.ui.warn(' %s\n' % m)
744 return None
744 return None
745 if matches:
745 if matches:
746 return matches[0]
746 return matches[0]
747 if len(self.series) > 0 and len(self.applied) > 0:
747 if len(self.series) > 0 and len(self.applied) > 0:
748 if s == 'qtip':
748 if s == 'qtip':
749 return self.series[self.series_end(True)-1]
749 return self.series[self.series_end(True)-1]
750 if s == 'qbase':
750 if s == 'qbase':
751 return self.series[0]
751 return self.series[0]
752 return None
752 return None
753 if patch == None:
753 if patch == None:
754 return None
754 return None
755
755
756 # we don't want to return a partial match until we make
756 # we don't want to return a partial match until we make
757 # sure the file name passed in does not exist (checked below)
757 # sure the file name passed in does not exist (checked below)
758 res = partial_name(patch)
758 res = partial_name(patch)
759 if res and res == patch:
759 if res and res == patch:
760 return res
760 return res
761
761
762 if not os.path.isfile(self.join(patch)):
762 if not os.path.isfile(self.join(patch)):
763 try:
763 try:
764 sno = int(patch)
764 sno = int(patch)
765 except(ValueError, OverflowError):
765 except(ValueError, OverflowError):
766 pass
766 pass
767 else:
767 else:
768 if sno < len(self.series):
768 if sno < len(self.series):
769 return self.series[sno]
769 return self.series[sno]
770 if not strict:
770 if not strict:
771 # return any partial match made above
771 # return any partial match made above
772 if res:
772 if res:
773 return res
773 return res
774 minus = patch.rfind('-')
774 minus = patch.rfind('-')
775 if minus >= 0:
775 if minus >= 0:
776 res = partial_name(patch[:minus])
776 res = partial_name(patch[:minus])
777 if res:
777 if res:
778 i = self.series.index(res)
778 i = self.series.index(res)
779 try:
779 try:
780 off = int(patch[minus+1:] or 1)
780 off = int(patch[minus+1:] or 1)
781 except(ValueError, OverflowError):
781 except(ValueError, OverflowError):
782 pass
782 pass
783 else:
783 else:
784 if i - off >= 0:
784 if i - off >= 0:
785 return self.series[i - off]
785 return self.series[i - off]
786 plus = patch.rfind('+')
786 plus = patch.rfind('+')
787 if plus >= 0:
787 if plus >= 0:
788 res = partial_name(patch[:plus])
788 res = partial_name(patch[:plus])
789 if res:
789 if res:
790 i = self.series.index(res)
790 i = self.series.index(res)
791 try:
791 try:
792 off = int(patch[plus+1:] or 1)
792 off = int(patch[plus+1:] or 1)
793 except(ValueError, OverflowError):
793 except(ValueError, OverflowError):
794 pass
794 pass
795 else:
795 else:
796 if i + off < len(self.series):
796 if i + off < len(self.series):
797 return self.series[i + off]
797 return self.series[i + off]
798 raise util.Abort(_("patch %s not in series") % patch)
798 raise util.Abort(_("patch %s not in series") % patch)
799
799
800 def push(self, repo, patch=None, force=False, list=False,
800 def push(self, repo, patch=None, force=False, list=False,
801 mergeq=None, wlock=None):
801 mergeq=None, wlock=None):
802 if not wlock:
802 if not wlock:
803 wlock = repo.wlock()
803 wlock = repo.wlock()
804 patch = self.lookup(patch)
804 patch = self.lookup(patch)
805 if patch and self.isapplied(patch):
805 if patch and self.isapplied(patch):
806 raise util.Abort(_("patch %s is already applied") % patch)
806 raise util.Abort(_("patch %s is already applied") % patch)
807 if self.series_end() == len(self.series):
807 if self.series_end() == len(self.series):
808 raise util.Abort(_("patch series fully applied"))
808 raise util.Abort(_("patch series fully applied"))
809 if not force:
809 if not force:
810 self.check_localchanges(repo)
810 self.check_localchanges(repo)
811
811
812 self.applied_dirty = 1;
812 self.applied_dirty = 1;
813 start = self.series_end()
813 start = self.series_end()
814 if start > 0:
814 if start > 0:
815 self.check_toppatch(repo)
815 self.check_toppatch(repo)
816 if not patch:
816 if not patch:
817 patch = self.series[start]
817 patch = self.series[start]
818 end = start + 1
818 end = start + 1
819 else:
819 else:
820 end = self.series.index(patch, start) + 1
820 end = self.series.index(patch, start) + 1
821 s = self.series[start:end]
821 s = self.series[start:end]
822 if mergeq:
822 if mergeq:
823 ret = self.mergepatch(repo, mergeq, s, wlock)
823 ret = self.mergepatch(repo, mergeq, s, wlock)
824 else:
824 else:
825 ret = self.apply(repo, s, list, wlock=wlock)
825 ret = self.apply(repo, s, list, wlock=wlock)
826 top = self.applied[-1].name
826 top = self.applied[-1].name
827 if ret[0]:
827 if ret[0]:
828 self.ui.write("Errors during apply, please fix and refresh %s\n" %
828 self.ui.write("Errors during apply, please fix and refresh %s\n" %
829 top)
829 top)
830 else:
830 else:
831 self.ui.write("Now at: %s\n" % top)
831 self.ui.write("Now at: %s\n" % top)
832 return ret[0]
832 return ret[0]
833
833
834 def pop(self, repo, patch=None, force=False, update=True, all=False,
834 def pop(self, repo, patch=None, force=False, update=True, all=False,
835 wlock=None):
835 wlock=None):
836 def getfile(f, rev):
836 def getfile(f, rev):
837 t = repo.file(f).read(rev)
837 t = repo.file(f).read(rev)
838 try:
838 try:
839 repo.wfile(f, "w").write(t)
839 repo.wfile(f, "w").write(t)
840 except IOError:
840 except IOError:
841 try:
841 try:
842 os.makedirs(os.path.dirname(repo.wjoin(f)))
842 os.makedirs(os.path.dirname(repo.wjoin(f)))
843 except OSError, err:
843 except OSError, err:
844 if err.errno != errno.EEXIST: raise
844 if err.errno != errno.EEXIST: raise
845 repo.wfile(f, "w").write(t)
845 repo.wfile(f, "w").write(t)
846
846
847 if not wlock:
847 if not wlock:
848 wlock = repo.wlock()
848 wlock = repo.wlock()
849 if patch:
849 if patch:
850 # index, rev, patch
850 # index, rev, patch
851 info = self.isapplied(patch)
851 info = self.isapplied(patch)
852 if not info:
852 if not info:
853 patch = self.lookup(patch)
853 patch = self.lookup(patch)
854 info = self.isapplied(patch)
854 info = self.isapplied(patch)
855 if not info:
855 if not info:
856 raise util.Abort(_("patch %s is not applied") % patch)
856 raise util.Abort(_("patch %s is not applied") % patch)
857 if len(self.applied) == 0:
857 if len(self.applied) == 0:
858 raise util.Abort(_("no patches applied"))
858 raise util.Abort(_("no patches applied"))
859
859
860 if not update:
860 if not update:
861 parents = repo.dirstate.parents()
861 parents = repo.dirstate.parents()
862 rr = [ revlog.bin(x.rev) for x in self.applied ]
862 rr = [ revlog.bin(x.rev) for x in self.applied ]
863 for p in parents:
863 for p in parents:
864 if p in rr:
864 if p in rr:
865 self.ui.warn("qpop: forcing dirstate update\n")
865 self.ui.warn("qpop: forcing dirstate update\n")
866 update = True
866 update = True
867
867
868 if not force and update:
868 if not force and update:
869 self.check_localchanges(repo)
869 self.check_localchanges(repo)
870
870
871 self.applied_dirty = 1;
871 self.applied_dirty = 1;
872 end = len(self.applied)
872 end = len(self.applied)
873 if not patch:
873 if not patch:
874 if all:
874 if all:
875 popi = 0
875 popi = 0
876 else:
876 else:
877 popi = len(self.applied) - 1
877 popi = len(self.applied) - 1
878 else:
878 else:
879 popi = info[0] + 1
879 popi = info[0] + 1
880 if popi >= end:
880 if popi >= end:
881 self.ui.warn("qpop: %s is already at the top\n" % patch)
881 self.ui.warn("qpop: %s is already at the top\n" % patch)
882 return
882 return
883 info = [ popi ] + [self.applied[popi].rev, self.applied[popi].name]
883 info = [ popi ] + [self.applied[popi].rev, self.applied[popi].name]
884
884
885 start = info[0]
885 start = info[0]
886 rev = revlog.bin(info[1])
886 rev = revlog.bin(info[1])
887
887
888 # we know there are no local changes, so we can make a simplified
888 # we know there are no local changes, so we can make a simplified
889 # form of hg.update.
889 # form of hg.update.
890 if update:
890 if update:
891 top = self.check_toppatch(repo)
891 top = self.check_toppatch(repo)
892 qp = self.qparents(repo, rev)
892 qp = self.qparents(repo, rev)
893 changes = repo.changelog.read(qp)
893 changes = repo.changelog.read(qp)
894 mmap = repo.manifest.read(changes[0])
894 mmap = repo.manifest.read(changes[0])
895 m, a, r, d, u = repo.status(qp, top)[:5]
895 m, a, r, d, u = repo.status(qp, top)[:5]
896 if d:
896 if d:
897 raise util.Abort("deletions found between repo revs")
897 raise util.Abort("deletions found between repo revs")
898 for f in m:
898 for f in m:
899 getfile(f, mmap[f])
899 getfile(f, mmap[f])
900 for f in r:
900 for f in r:
901 getfile(f, mmap[f])
901 getfile(f, mmap[f])
902 util.set_exec(repo.wjoin(f), mmap.execf(f))
902 util.set_exec(repo.wjoin(f), mmap.execf(f))
903 repo.dirstate.update(m + r, 'n')
903 repo.dirstate.update(m + r, 'n')
904 for f in a:
904 for f in a:
905 try:
905 try:
906 os.unlink(repo.wjoin(f))
906 os.unlink(repo.wjoin(f))
907 except OSError, e:
907 except OSError, e:
908 if e.errno != errno.ENOENT:
908 if e.errno != errno.ENOENT:
909 raise
909 raise
910 try: os.removedirs(os.path.dirname(repo.wjoin(f)))
910 try: os.removedirs(os.path.dirname(repo.wjoin(f)))
911 except: pass
911 except: pass
912 if a:
912 if a:
913 repo.dirstate.forget(a)
913 repo.dirstate.forget(a)
914 repo.dirstate.setparents(qp, revlog.nullid)
914 repo.dirstate.setparents(qp, revlog.nullid)
915 self.strip(repo, rev, update=False, backup='strip', wlock=wlock)
915 self.strip(repo, rev, update=False, backup='strip', wlock=wlock)
916 del self.applied[start:end]
916 del self.applied[start:end]
917 if len(self.applied):
917 if len(self.applied):
918 self.ui.write("Now at: %s\n" % self.applied[-1].name)
918 self.ui.write("Now at: %s\n" % self.applied[-1].name)
919 else:
919 else:
920 self.ui.write("Patch queue now empty\n")
920 self.ui.write("Patch queue now empty\n")
921
921
922 def diff(self, repo, pats, opts):
922 def diff(self, repo, pats, opts):
923 top = self.check_toppatch(repo)
923 top = self.check_toppatch(repo)
924 if not top:
924 if not top:
925 self.ui.write("No patches applied\n")
925 self.ui.write("No patches applied\n")
926 return
926 return
927 qp = self.qparents(repo, top)
927 qp = self.qparents(repo, top)
928 if opts.get('git'):
928 if opts.get('git'):
929 self.diffopts().git = True
929 self.diffopts().git = True
930 self.printdiff(repo, qp, files=pats, opts=opts)
930 self.printdiff(repo, qp, files=pats, opts=opts)
931
931
932 def refresh(self, repo, pats=None, **opts):
932 def refresh(self, repo, pats=None, **opts):
933 if len(self.applied) == 0:
933 if len(self.applied) == 0:
934 self.ui.write("No patches applied\n")
934 self.ui.write("No patches applied\n")
935 return 1
935 return 1
936 wlock = repo.wlock()
936 wlock = repo.wlock()
937 self.check_toppatch(repo)
937 self.check_toppatch(repo)
938 (top, patchfn) = (self.applied[-1].rev, self.applied[-1].name)
938 (top, patchfn) = (self.applied[-1].rev, self.applied[-1].name)
939 top = revlog.bin(top)
939 top = revlog.bin(top)
940 cparents = repo.changelog.parents(top)
940 cparents = repo.changelog.parents(top)
941 patchparent = self.qparents(repo, top)
941 patchparent = self.qparents(repo, top)
942 message, comments, user, date, patchfound = self.readheaders(patchfn)
942 message, comments, user, date, patchfound = self.readheaders(patchfn)
943
943
944 patchf = self.opener(patchfn, "w")
944 patchf = self.opener(patchfn, "w")
945 msg = opts.get('msg', '').rstrip()
945 msg = opts.get('msg', '').rstrip()
946 if msg:
946 if msg:
947 if comments:
947 if comments:
948 # Remove existing message.
948 # Remove existing message.
949 ci = 0
949 ci = 0
950 for mi in xrange(len(message)):
950 for mi in xrange(len(message)):
951 while message[mi] != comments[ci]:
951 while message[mi] != comments[ci]:
952 ci += 1
952 ci += 1
953 del comments[ci]
953 del comments[ci]
954 comments.append(msg)
954 comments.append(msg)
955 if comments:
955 if comments:
956 comments = "\n".join(comments) + '\n\n'
956 comments = "\n".join(comments) + '\n\n'
957 patchf.write(comments)
957 patchf.write(comments)
958
958
959 if opts.get('git'):
959 if opts.get('git'):
960 self.diffopts().git = True
960 self.diffopts().git = True
961 fns, matchfn, anypats = cmdutil.matchpats(repo, pats, opts)
961 fns, matchfn, anypats = cmdutil.matchpats(repo, pats, opts)
962 tip = repo.changelog.tip()
962 tip = repo.changelog.tip()
963 if top == tip:
963 if top == tip:
964 # if the top of our patch queue is also the tip, there is an
964 # if the top of our patch queue is also the tip, there is an
965 # optimization here. We update the dirstate in place and strip
965 # optimization here. We update the dirstate in place and strip
966 # off the tip commit. Then just commit the current directory
966 # off the tip commit. Then just commit the current directory
967 # tree. We can also send repo.commit the list of files
967 # tree. We can also send repo.commit the list of files
968 # changed to speed up the diff
968 # changed to speed up the diff
969 #
969 #
970 # in short mode, we only diff the files included in the
970 # in short mode, we only diff the files included in the
971 # patch already
971 # patch already
972 #
972 #
973 # this should really read:
973 # this should really read:
974 # mm, dd, aa, aa2, uu = repo.status(tip, patchparent)[:5]
974 # mm, dd, aa, aa2, uu = repo.status(tip, patchparent)[:5]
975 # but we do it backwards to take advantage of manifest/chlog
975 # but we do it backwards to take advantage of manifest/chlog
976 # caching against the next repo.status call
976 # caching against the next repo.status call
977 #
977 #
978 mm, aa, dd, aa2, uu = repo.status(patchparent, tip)[:5]
978 mm, aa, dd, aa2, uu = repo.status(patchparent, tip)[:5]
979 changes = repo.changelog.read(tip)
979 changes = repo.changelog.read(tip)
980 man = repo.manifest.read(changes[0])
980 man = repo.manifest.read(changes[0])
981 aaa = aa[:]
981 aaa = aa[:]
982 if opts.get('short'):
982 if opts.get('short'):
983 filelist = mm + aa + dd
983 filelist = mm + aa + dd
984 else:
984 else:
985 filelist = None
985 filelist = None
986 m, a, r, d, u = repo.status(files=filelist)[:5]
986 m, a, r, d, u = repo.status(files=filelist)[:5]
987
987
988 # we might end up with files that were added between tip and
988 # we might end up with files that were added between tip and
989 # the dirstate parent, but then changed in the local dirstate.
989 # the dirstate parent, but then changed in the local dirstate.
990 # in this case, we want them to only show up in the added section
990 # in this case, we want them to only show up in the added section
991 for x in m:
991 for x in m:
992 if x not in aa:
992 if x not in aa:
993 mm.append(x)
993 mm.append(x)
994 # we might end up with files added by the local dirstate that
994 # we might end up with files added by the local dirstate that
995 # were deleted by the patch. In this case, they should only
995 # were deleted by the patch. In this case, they should only
996 # show up in the changed section.
996 # show up in the changed section.
997 for x in a:
997 for x in a:
998 if x in dd:
998 if x in dd:
999 del dd[dd.index(x)]
999 del dd[dd.index(x)]
1000 mm.append(x)
1000 mm.append(x)
1001 else:
1001 else:
1002 aa.append(x)
1002 aa.append(x)
1003 # make sure any files deleted in the local dirstate
1003 # make sure any files deleted in the local dirstate
1004 # are not in the add or change column of the patch
1004 # are not in the add or change column of the patch
1005 forget = []
1005 forget = []
1006 for x in d + r:
1006 for x in d + r:
1007 if x in aa:
1007 if x in aa:
1008 del aa[aa.index(x)]
1008 del aa[aa.index(x)]
1009 forget.append(x)
1009 forget.append(x)
1010 continue
1010 continue
1011 elif x in mm:
1011 elif x in mm:
1012 del mm[mm.index(x)]
1012 del mm[mm.index(x)]
1013 dd.append(x)
1013 dd.append(x)
1014
1014
1015 m = util.unique(mm)
1015 m = util.unique(mm)
1016 r = util.unique(dd)
1016 r = util.unique(dd)
1017 a = util.unique(aa)
1017 a = util.unique(aa)
1018 c = [filter(matchfn, l) for l in (m, a, r, [], u)]
1018 c = [filter(matchfn, l) for l in (m, a, r, [], u)]
1019 filelist = util.unique(c[0] + c[1] + c[2])
1019 filelist = util.unique(c[0] + c[1] + c[2])
1020 patch.diff(repo, patchparent, files=filelist, match=matchfn,
1020 patch.diff(repo, patchparent, files=filelist, match=matchfn,
1021 fp=patchf, changes=c, opts=self.diffopts())
1021 fp=patchf, changes=c, opts=self.diffopts())
1022 patchf.close()
1022 patchf.close()
1023
1023
1024 repo.dirstate.setparents(*cparents)
1024 repo.dirstate.setparents(*cparents)
1025 copies = {}
1025 copies = {}
1026 for dst in a:
1026 for dst in a:
1027 src = repo.dirstate.copied(dst)
1027 src = repo.dirstate.copied(dst)
1028 if src is None:
1028 if src is None:
1029 continue
1029 continue
1030 copies.setdefault(src, []).append(dst)
1030 copies.setdefault(src, []).append(dst)
1031 repo.dirstate.update(a, 'a')
1031 repo.dirstate.update(a, 'a')
1032 # remember the copies between patchparent and tip
1032 # remember the copies between patchparent and tip
1033 # this may be slow, so don't do it if we're not tracking copies
1033 # this may be slow, so don't do it if we're not tracking copies
1034 if self.diffopts().git:
1034 if self.diffopts().git:
1035 for dst in aaa:
1035 for dst in aaa:
1036 f = repo.file(dst)
1036 f = repo.file(dst)
1037 src = f.renamed(man[dst])
1037 src = f.renamed(man[dst])
1038 if src:
1038 if src:
1039 copies[src[0]] = copies.get(dst, [])
1039 copies[src[0]] = copies.get(dst, [])
1040 if dst in a:
1040 if dst in a:
1041 copies[src[0]].append(dst)
1041 copies[src[0]].append(dst)
1042 # we can't copy a file created by the patch itself
1042 # we can't copy a file created by the patch itself
1043 if dst in copies:
1043 if dst in copies:
1044 del copies[dst]
1044 del copies[dst]
1045 for src, dsts in copies.iteritems():
1045 for src, dsts in copies.iteritems():
1046 for dst in dsts:
1046 for dst in dsts:
1047 repo.dirstate.copy(src, dst)
1047 repo.dirstate.copy(src, dst)
1048 repo.dirstate.update(r, 'r')
1048 repo.dirstate.update(r, 'r')
1049 # if the patch excludes a modified file, mark that file with mtime=0
1049 # if the patch excludes a modified file, mark that file with mtime=0
1050 # so status can see it.
1050 # so status can see it.
1051 mm = []
1051 mm = []
1052 for i in xrange(len(m)-1, -1, -1):
1052 for i in xrange(len(m)-1, -1, -1):
1053 if not matchfn(m[i]):
1053 if not matchfn(m[i]):
1054 mm.append(m[i])
1054 mm.append(m[i])
1055 del m[i]
1055 del m[i]
1056 repo.dirstate.update(m, 'n')
1056 repo.dirstate.update(m, 'n')
1057 repo.dirstate.update(mm, 'n', st_mtime=0)
1057 repo.dirstate.update(mm, 'n', st_mtime=0)
1058 repo.dirstate.forget(forget)
1058 repo.dirstate.forget(forget)
1059
1059
1060 if not msg:
1060 if not msg:
1061 if not message:
1061 if not message:
1062 message = "patch queue: %s\n" % patchfn
1062 message = "patch queue: %s\n" % patchfn
1063 else:
1063 else:
1064 message = "\n".join(message)
1064 message = "\n".join(message)
1065 else:
1065 else:
1066 message = msg
1066 message = msg
1067
1067
1068 self.strip(repo, top, update=False, backup='strip', wlock=wlock)
1068 self.strip(repo, top, update=False, backup='strip', wlock=wlock)
1069 n = repo.commit(filelist, message, changes[1], match=matchfn,
1069 n = repo.commit(filelist, message, changes[1], match=matchfn,
1070 force=1, wlock=wlock)
1070 force=1, wlock=wlock)
1071 self.applied[-1] = statusentry(revlog.hex(n), patchfn)
1071 self.applied[-1] = statusentry(revlog.hex(n), patchfn)
1072 self.applied_dirty = 1
1072 self.applied_dirty = 1
1073 else:
1073 else:
1074 self.printdiff(repo, patchparent, fp=patchf)
1074 self.printdiff(repo, patchparent, fp=patchf)
1075 patchf.close()
1075 patchf.close()
1076 added = repo.status()[1]
1076 added = repo.status()[1]
1077 for a in added:
1077 for a in added:
1078 f = repo.wjoin(a)
1078 f = repo.wjoin(a)
1079 try:
1079 try:
1080 os.unlink(f)
1080 os.unlink(f)
1081 except OSError, e:
1081 except OSError, e:
1082 if e.errno != errno.ENOENT:
1082 if e.errno != errno.ENOENT:
1083 raise
1083 raise
1084 try: os.removedirs(os.path.dirname(f))
1084 try: os.removedirs(os.path.dirname(f))
1085 except: pass
1085 except: pass
1086 # forget the file copies in the dirstate
1086 # forget the file copies in the dirstate
1087 # push should readd the files later on
1087 # push should readd the files later on
1088 repo.dirstate.forget(added)
1088 repo.dirstate.forget(added)
1089 self.pop(repo, force=True, wlock=wlock)
1089 self.pop(repo, force=True, wlock=wlock)
1090 self.push(repo, force=True, wlock=wlock)
1090 self.push(repo, force=True, wlock=wlock)
1091
1091
1092 def init(self, repo, create=False):
1092 def init(self, repo, create=False):
1093 if os.path.isdir(self.path):
1093 if os.path.isdir(self.path):
1094 raise util.Abort(_("patch queue directory already exists"))
1094 raise util.Abort(_("patch queue directory already exists"))
1095 os.mkdir(self.path)
1095 os.mkdir(self.path)
1096 if create:
1096 if create:
1097 return self.qrepo(create=True)
1097 return self.qrepo(create=True)
1098
1098
1099 def unapplied(self, repo, patch=None):
1099 def unapplied(self, repo, patch=None):
1100 if patch and patch not in self.series:
1100 if patch and patch not in self.series:
1101 raise util.Abort(_("patch %s is not in series file") % patch)
1101 raise util.Abort(_("patch %s is not in series file") % patch)
1102 if not patch:
1102 if not patch:
1103 start = self.series_end()
1103 start = self.series_end()
1104 else:
1104 else:
1105 start = self.series.index(patch) + 1
1105 start = self.series.index(patch) + 1
1106 unapplied = []
1106 unapplied = []
1107 for i in xrange(start, len(self.series)):
1107 for i in xrange(start, len(self.series)):
1108 pushable, reason = self.pushable(i)
1108 pushable, reason = self.pushable(i)
1109 if pushable:
1109 if pushable:
1110 unapplied.append((i, self.series[i]))
1110 unapplied.append((i, self.series[i]))
1111 self.explain_pushable(i)
1111 self.explain_pushable(i)
1112 return unapplied
1112 return unapplied
1113
1113
1114 def qseries(self, repo, missing=None, start=0, length=None, status=None,
1114 def qseries(self, repo, missing=None, start=0, length=None, status=None,
1115 summary=False):
1115 summary=False):
1116 def displayname(patchname):
1116 def displayname(patchname):
1117 if summary:
1117 if summary:
1118 msg = self.readheaders(patchname)[0]
1118 msg = self.readheaders(patchname)[0]
1119 msg = msg and ': ' + msg[0] or ': '
1119 msg = msg and ': ' + msg[0] or ': '
1120 else:
1120 else:
1121 msg = ''
1121 msg = ''
1122 return '%s%s' % (patchname, msg)
1122 return '%s%s' % (patchname, msg)
1123
1123
1124 applied = dict.fromkeys([p.name for p in self.applied])
1124 applied = dict.fromkeys([p.name for p in self.applied])
1125 if length is None:
1125 if length is None:
1126 length = len(self.series) - start
1126 length = len(self.series) - start
1127 if not missing:
1127 if not missing:
1128 for i in xrange(start, start+length):
1128 for i in xrange(start, start+length):
1129 patch = self.series[i]
1129 patch = self.series[i]
1130 if patch in applied:
1130 if patch in applied:
1131 stat = 'A'
1131 stat = 'A'
1132 elif self.pushable(i)[0]:
1132 elif self.pushable(i)[0]:
1133 stat = 'U'
1133 stat = 'U'
1134 else:
1134 else:
1135 stat = 'G'
1135 stat = 'G'
1136 pfx = ''
1136 pfx = ''
1137 if self.ui.verbose:
1137 if self.ui.verbose:
1138 pfx = '%d %s ' % (i, stat)
1138 pfx = '%d %s ' % (i, stat)
1139 elif status and status != stat:
1139 elif status and status != stat:
1140 continue
1140 continue
1141 self.ui.write('%s%s\n' % (pfx, displayname(patch)))
1141 self.ui.write('%s%s\n' % (pfx, displayname(patch)))
1142 else:
1142 else:
1143 msng_list = []
1143 msng_list = []
1144 for root, dirs, files in os.walk(self.path):
1144 for root, dirs, files in os.walk(self.path):
1145 d = root[len(self.path) + 1:]
1145 d = root[len(self.path) + 1:]
1146 for f in files:
1146 for f in files:
1147 fl = os.path.join(d, f)
1147 fl = os.path.join(d, f)
1148 if (fl not in self.series and
1148 if (fl not in self.series and
1149 fl not in (self.status_path, self.series_path)
1149 fl not in (self.status_path, self.series_path,
1150 self.guards_path)
1150 and not fl.startswith('.')):
1151 and not fl.startswith('.')):
1151 msng_list.append(fl)
1152 msng_list.append(fl)
1152 msng_list.sort()
1153 msng_list.sort()
1153 for x in msng_list:
1154 for x in msng_list:
1154 pfx = self.ui.verbose and ('D ') or ''
1155 pfx = self.ui.verbose and ('D ') or ''
1155 self.ui.write("%s%s\n" % (pfx, displayname(x)))
1156 self.ui.write("%s%s\n" % (pfx, displayname(x)))
1156
1157
1157 def issaveline(self, l):
1158 def issaveline(self, l):
1158 if l.name == '.hg.patches.save.line':
1159 if l.name == '.hg.patches.save.line':
1159 return True
1160 return True
1160
1161
1161 def qrepo(self, create=False):
1162 def qrepo(self, create=False):
1162 if create or os.path.isdir(self.join(".hg")):
1163 if create or os.path.isdir(self.join(".hg")):
1163 return hg.repository(self.ui, path=self.path, create=create)
1164 return hg.repository(self.ui, path=self.path, create=create)
1164
1165
1165 def restore(self, repo, rev, delete=None, qupdate=None):
1166 def restore(self, repo, rev, delete=None, qupdate=None):
1166 c = repo.changelog.read(rev)
1167 c = repo.changelog.read(rev)
1167 desc = c[4].strip()
1168 desc = c[4].strip()
1168 lines = desc.splitlines()
1169 lines = desc.splitlines()
1169 i = 0
1170 i = 0
1170 datastart = None
1171 datastart = None
1171 series = []
1172 series = []
1172 applied = []
1173 applied = []
1173 qpp = None
1174 qpp = None
1174 for i in xrange(0, len(lines)):
1175 for i in xrange(0, len(lines)):
1175 if lines[i] == 'Patch Data:':
1176 if lines[i] == 'Patch Data:':
1176 datastart = i + 1
1177 datastart = i + 1
1177 elif lines[i].startswith('Dirstate:'):
1178 elif lines[i].startswith('Dirstate:'):
1178 l = lines[i].rstrip()
1179 l = lines[i].rstrip()
1179 l = l[10:].split(' ')
1180 l = l[10:].split(' ')
1180 qpp = [ hg.bin(x) for x in l ]
1181 qpp = [ hg.bin(x) for x in l ]
1181 elif datastart != None:
1182 elif datastart != None:
1182 l = lines[i].rstrip()
1183 l = lines[i].rstrip()
1183 se = statusentry(l)
1184 se = statusentry(l)
1184 file_ = se.name
1185 file_ = se.name
1185 if se.rev:
1186 if se.rev:
1186 applied.append(se)
1187 applied.append(se)
1187 else:
1188 else:
1188 series.append(file_)
1189 series.append(file_)
1189 if datastart == None:
1190 if datastart == None:
1190 self.ui.warn("No saved patch data found\n")
1191 self.ui.warn("No saved patch data found\n")
1191 return 1
1192 return 1
1192 self.ui.warn("restoring status: %s\n" % lines[0])
1193 self.ui.warn("restoring status: %s\n" % lines[0])
1193 self.full_series = series
1194 self.full_series = series
1194 self.applied = applied
1195 self.applied = applied
1195 self.parse_series()
1196 self.parse_series()
1196 self.series_dirty = 1
1197 self.series_dirty = 1
1197 self.applied_dirty = 1
1198 self.applied_dirty = 1
1198 heads = repo.changelog.heads()
1199 heads = repo.changelog.heads()
1199 if delete:
1200 if delete:
1200 if rev not in heads:
1201 if rev not in heads:
1201 self.ui.warn("save entry has children, leaving it alone\n")
1202 self.ui.warn("save entry has children, leaving it alone\n")
1202 else:
1203 else:
1203 self.ui.warn("removing save entry %s\n" % hg.short(rev))
1204 self.ui.warn("removing save entry %s\n" % hg.short(rev))
1204 pp = repo.dirstate.parents()
1205 pp = repo.dirstate.parents()
1205 if rev in pp:
1206 if rev in pp:
1206 update = True
1207 update = True
1207 else:
1208 else:
1208 update = False
1209 update = False
1209 self.strip(repo, rev, update=update, backup='strip')
1210 self.strip(repo, rev, update=update, backup='strip')
1210 if qpp:
1211 if qpp:
1211 self.ui.warn("saved queue repository parents: %s %s\n" %
1212 self.ui.warn("saved queue repository parents: %s %s\n" %
1212 (hg.short(qpp[0]), hg.short(qpp[1])))
1213 (hg.short(qpp[0]), hg.short(qpp[1])))
1213 if qupdate:
1214 if qupdate:
1214 print "queue directory updating"
1215 print "queue directory updating"
1215 r = self.qrepo()
1216 r = self.qrepo()
1216 if not r:
1217 if not r:
1217 self.ui.warn("Unable to load queue repository\n")
1218 self.ui.warn("Unable to load queue repository\n")
1218 return 1
1219 return 1
1219 hg.clean(r, qpp[0])
1220 hg.clean(r, qpp[0])
1220
1221
1221 def save(self, repo, msg=None):
1222 def save(self, repo, msg=None):
1222 if len(self.applied) == 0:
1223 if len(self.applied) == 0:
1223 self.ui.warn("save: no patches applied, exiting\n")
1224 self.ui.warn("save: no patches applied, exiting\n")
1224 return 1
1225 return 1
1225 if self.issaveline(self.applied[-1]):
1226 if self.issaveline(self.applied[-1]):
1226 self.ui.warn("status is already saved\n")
1227 self.ui.warn("status is already saved\n")
1227 return 1
1228 return 1
1228
1229
1229 ar = [ ':' + x for x in self.full_series ]
1230 ar = [ ':' + x for x in self.full_series ]
1230 if not msg:
1231 if not msg:
1231 msg = "hg patches saved state"
1232 msg = "hg patches saved state"
1232 else:
1233 else:
1233 msg = "hg patches: " + msg.rstrip('\r\n')
1234 msg = "hg patches: " + msg.rstrip('\r\n')
1234 r = self.qrepo()
1235 r = self.qrepo()
1235 if r:
1236 if r:
1236 pp = r.dirstate.parents()
1237 pp = r.dirstate.parents()
1237 msg += "\nDirstate: %s %s" % (hg.hex(pp[0]), hg.hex(pp[1]))
1238 msg += "\nDirstate: %s %s" % (hg.hex(pp[0]), hg.hex(pp[1]))
1238 msg += "\n\nPatch Data:\n"
1239 msg += "\n\nPatch Data:\n"
1239 text = msg + "\n".join([str(x) for x in self.applied]) + '\n' + (ar and
1240 text = msg + "\n".join([str(x) for x in self.applied]) + '\n' + (ar and
1240 "\n".join(ar) + '\n' or "")
1241 "\n".join(ar) + '\n' or "")
1241 n = repo.commit(None, text, user=None, force=1)
1242 n = repo.commit(None, text, user=None, force=1)
1242 if not n:
1243 if not n:
1243 self.ui.warn("repo commit failed\n")
1244 self.ui.warn("repo commit failed\n")
1244 return 1
1245 return 1
1245 self.applied.append(statusentry(revlog.hex(n),'.hg.patches.save.line'))
1246 self.applied.append(statusentry(revlog.hex(n),'.hg.patches.save.line'))
1246 self.applied_dirty = 1
1247 self.applied_dirty = 1
1247
1248
1248 def full_series_end(self):
1249 def full_series_end(self):
1249 if len(self.applied) > 0:
1250 if len(self.applied) > 0:
1250 p = self.applied[-1].name
1251 p = self.applied[-1].name
1251 end = self.find_series(p)
1252 end = self.find_series(p)
1252 if end == None:
1253 if end == None:
1253 return len(self.full_series)
1254 return len(self.full_series)
1254 return end + 1
1255 return end + 1
1255 return 0
1256 return 0
1256
1257
1257 def series_end(self, all_patches=False):
1258 def series_end(self, all_patches=False):
1258 end = 0
1259 end = 0
1259 def next(start):
1260 def next(start):
1260 if all_patches:
1261 if all_patches:
1261 return start
1262 return start
1262 i = start
1263 i = start
1263 while i < len(self.series):
1264 while i < len(self.series):
1264 p, reason = self.pushable(i)
1265 p, reason = self.pushable(i)
1265 if p:
1266 if p:
1266 break
1267 break
1267 self.explain_pushable(i)
1268 self.explain_pushable(i)
1268 i += 1
1269 i += 1
1269 return i
1270 return i
1270 if len(self.applied) > 0:
1271 if len(self.applied) > 0:
1271 p = self.applied[-1].name
1272 p = self.applied[-1].name
1272 try:
1273 try:
1273 end = self.series.index(p)
1274 end = self.series.index(p)
1274 except ValueError:
1275 except ValueError:
1275 return 0
1276 return 0
1276 return next(end + 1)
1277 return next(end + 1)
1277 return next(end)
1278 return next(end)
1278
1279
1279 def appliedname(self, index):
1280 def appliedname(self, index):
1280 pname = self.applied[index].name
1281 pname = self.applied[index].name
1281 if not self.ui.verbose:
1282 if not self.ui.verbose:
1282 p = pname
1283 p = pname
1283 else:
1284 else:
1284 p = str(self.series.index(pname)) + " " + pname
1285 p = str(self.series.index(pname)) + " " + pname
1285 return p
1286 return p
1286
1287
1287 def qimport(self, repo, files, patchname=None, rev=None, existing=None,
1288 def qimport(self, repo, files, patchname=None, rev=None, existing=None,
1288 force=None, git=False):
1289 force=None, git=False):
1289 def checkseries(patchname):
1290 def checkseries(patchname):
1290 if patchname in self.series:
1291 if patchname in self.series:
1291 raise util.Abort(_('patch %s is already in the series file')
1292 raise util.Abort(_('patch %s is already in the series file')
1292 % patchname)
1293 % patchname)
1293 def checkfile(patchname):
1294 def checkfile(patchname):
1294 if not force and os.path.exists(self.join(patchname)):
1295 if not force and os.path.exists(self.join(patchname)):
1295 raise util.Abort(_('patch "%s" already exists')
1296 raise util.Abort(_('patch "%s" already exists')
1296 % patchname)
1297 % patchname)
1297
1298
1298 if rev:
1299 if rev:
1299 if files:
1300 if files:
1300 raise util.Abort(_('option "-r" not valid when importing '
1301 raise util.Abort(_('option "-r" not valid when importing '
1301 'files'))
1302 'files'))
1302 rev = cmdutil.revrange(repo, rev)
1303 rev = cmdutil.revrange(repo, rev)
1303 rev.sort(lambda x, y: cmp(y, x))
1304 rev.sort(lambda x, y: cmp(y, x))
1304 if (len(files) > 1 or len(rev) > 1) and patchname:
1305 if (len(files) > 1 or len(rev) > 1) and patchname:
1305 raise util.Abort(_('option "-n" not valid when importing multiple '
1306 raise util.Abort(_('option "-n" not valid when importing multiple '
1306 'patches'))
1307 'patches'))
1307 i = 0
1308 i = 0
1308 added = []
1309 added = []
1309 if rev:
1310 if rev:
1310 # If mq patches are applied, we can only import revisions
1311 # If mq patches are applied, we can only import revisions
1311 # that form a linear path to qbase.
1312 # that form a linear path to qbase.
1312 # Otherwise, they should form a linear path to a head.
1313 # Otherwise, they should form a linear path to a head.
1313 heads = repo.changelog.heads(repo.changelog.node(rev[-1]))
1314 heads = repo.changelog.heads(repo.changelog.node(rev[-1]))
1314 if len(heads) > 1:
1315 if len(heads) > 1:
1315 raise util.Abort(_('revision %d is the root of more than one '
1316 raise util.Abort(_('revision %d is the root of more than one '
1316 'branch') % rev[-1])
1317 'branch') % rev[-1])
1317 if self.applied:
1318 if self.applied:
1318 base = revlog.hex(repo.changelog.node(rev[0]))
1319 base = revlog.hex(repo.changelog.node(rev[0]))
1319 if base in [n.rev for n in self.applied]:
1320 if base in [n.rev for n in self.applied]:
1320 raise util.Abort(_('revision %d is already managed')
1321 raise util.Abort(_('revision %d is already managed')
1321 % rev[0])
1322 % rev[0])
1322 if heads != [revlog.bin(self.applied[-1].rev)]:
1323 if heads != [revlog.bin(self.applied[-1].rev)]:
1323 raise util.Abort(_('revision %d is not the parent of '
1324 raise util.Abort(_('revision %d is not the parent of '
1324 'the queue') % rev[0])
1325 'the queue') % rev[0])
1325 base = repo.changelog.rev(revlog.bin(self.applied[0].rev))
1326 base = repo.changelog.rev(revlog.bin(self.applied[0].rev))
1326 lastparent = repo.changelog.parentrevs(base)[0]
1327 lastparent = repo.changelog.parentrevs(base)[0]
1327 else:
1328 else:
1328 if heads != [repo.changelog.node(rev[0])]:
1329 if heads != [repo.changelog.node(rev[0])]:
1329 raise util.Abort(_('revision %d has unmanaged children')
1330 raise util.Abort(_('revision %d has unmanaged children')
1330 % rev[0])
1331 % rev[0])
1331 lastparent = None
1332 lastparent = None
1332
1333
1333 if git:
1334 if git:
1334 self.diffopts().git = True
1335 self.diffopts().git = True
1335
1336
1336 for r in rev:
1337 for r in rev:
1337 p1, p2 = repo.changelog.parentrevs(r)
1338 p1, p2 = repo.changelog.parentrevs(r)
1338 n = repo.changelog.node(r)
1339 n = repo.changelog.node(r)
1339 if p2 != revlog.nullrev:
1340 if p2 != revlog.nullrev:
1340 raise util.Abort(_('cannot import merge revision %d') % r)
1341 raise util.Abort(_('cannot import merge revision %d') % r)
1341 if lastparent and lastparent != r:
1342 if lastparent and lastparent != r:
1342 raise util.Abort(_('revision %d is not the parent of %d')
1343 raise util.Abort(_('revision %d is not the parent of %d')
1343 % (r, lastparent))
1344 % (r, lastparent))
1344 lastparent = p1
1345 lastparent = p1
1345
1346
1346 if not patchname:
1347 if not patchname:
1347 patchname = '%d.diff' % r
1348 patchname = '%d.diff' % r
1348 checkseries(patchname)
1349 checkseries(patchname)
1349 checkfile(patchname)
1350 checkfile(patchname)
1350 self.full_series.insert(0, patchname)
1351 self.full_series.insert(0, patchname)
1351
1352
1352 patchf = self.opener(patchname, "w")
1353 patchf = self.opener(patchname, "w")
1353 patch.export(repo, [n], fp=patchf, opts=self.diffopts())
1354 patch.export(repo, [n], fp=patchf, opts=self.diffopts())
1354 patchf.close()
1355 patchf.close()
1355
1356
1356 se = statusentry(revlog.hex(n), patchname)
1357 se = statusentry(revlog.hex(n), patchname)
1357 self.applied.insert(0, se)
1358 self.applied.insert(0, se)
1358
1359
1359 added.append(patchname)
1360 added.append(patchname)
1360 patchname = None
1361 patchname = None
1361 self.parse_series()
1362 self.parse_series()
1362 self.applied_dirty = 1
1363 self.applied_dirty = 1
1363
1364
1364 for filename in files:
1365 for filename in files:
1365 if existing:
1366 if existing:
1366 if filename == '-':
1367 if filename == '-':
1367 raise util.Abort(_('-e is incompatible with import from -'))
1368 raise util.Abort(_('-e is incompatible with import from -'))
1368 if not patchname:
1369 if not patchname:
1369 patchname = filename
1370 patchname = filename
1370 if not os.path.isfile(self.join(patchname)):
1371 if not os.path.isfile(self.join(patchname)):
1371 raise util.Abort(_("patch %s does not exist") % patchname)
1372 raise util.Abort(_("patch %s does not exist") % patchname)
1372 else:
1373 else:
1373 try:
1374 try:
1374 if filename == '-':
1375 if filename == '-':
1375 if not patchname:
1376 if not patchname:
1376 raise util.Abort(_('need --name to import a patch from -'))
1377 raise util.Abort(_('need --name to import a patch from -'))
1377 text = sys.stdin.read()
1378 text = sys.stdin.read()
1378 else:
1379 else:
1379 text = file(filename).read()
1380 text = file(filename).read()
1380 except IOError:
1381 except IOError:
1381 raise util.Abort(_("unable to read %s") % patchname)
1382 raise util.Abort(_("unable to read %s") % patchname)
1382 if not patchname:
1383 if not patchname:
1383 patchname = os.path.basename(filename)
1384 patchname = os.path.basename(filename)
1384 checkfile(patchname)
1385 checkfile(patchname)
1385 patchf = self.opener(patchname, "w")
1386 patchf = self.opener(patchname, "w")
1386 patchf.write(text)
1387 patchf.write(text)
1387 checkseries(patchname)
1388 checkseries(patchname)
1388 index = self.full_series_end() + i
1389 index = self.full_series_end() + i
1389 self.full_series[index:index] = [patchname]
1390 self.full_series[index:index] = [patchname]
1390 self.parse_series()
1391 self.parse_series()
1391 self.ui.warn("adding %s to series file\n" % patchname)
1392 self.ui.warn("adding %s to series file\n" % patchname)
1392 i += 1
1393 i += 1
1393 added.append(patchname)
1394 added.append(patchname)
1394 patchname = None
1395 patchname = None
1395 self.series_dirty = 1
1396 self.series_dirty = 1
1396 qrepo = self.qrepo()
1397 qrepo = self.qrepo()
1397 if qrepo:
1398 if qrepo:
1398 qrepo.add(added)
1399 qrepo.add(added)
1399
1400
1400 def delete(ui, repo, *patches, **opts):
1401 def delete(ui, repo, *patches, **opts):
1401 """remove patches from queue
1402 """remove patches from queue
1402
1403
1403 With --rev, mq will stop managing the named revisions. The
1404 With --rev, mq will stop managing the named revisions. The
1404 patches must be applied and at the base of the stack. This option
1405 patches must be applied and at the base of the stack. This option
1405 is useful when the patches have been applied upstream.
1406 is useful when the patches have been applied upstream.
1406
1407
1407 Otherwise, the patches must not be applied.
1408 Otherwise, the patches must not be applied.
1408
1409
1409 With --keep, the patch files are preserved in the patch directory."""
1410 With --keep, the patch files are preserved in the patch directory."""
1410 q = repo.mq
1411 q = repo.mq
1411 q.delete(repo, patches, opts)
1412 q.delete(repo, patches, opts)
1412 q.save_dirty()
1413 q.save_dirty()
1413 return 0
1414 return 0
1414
1415
1415 def applied(ui, repo, patch=None, **opts):
1416 def applied(ui, repo, patch=None, **opts):
1416 """print the patches already applied"""
1417 """print the patches already applied"""
1417 q = repo.mq
1418 q = repo.mq
1418 if patch:
1419 if patch:
1419 if patch not in q.series:
1420 if patch not in q.series:
1420 raise util.Abort(_("patch %s is not in series file") % patch)
1421 raise util.Abort(_("patch %s is not in series file") % patch)
1421 end = q.series.index(patch) + 1
1422 end = q.series.index(patch) + 1
1422 else:
1423 else:
1423 end = q.series_end(True)
1424 end = q.series_end(True)
1424 return q.qseries(repo, length=end, status='A', summary=opts.get('summary'))
1425 return q.qseries(repo, length=end, status='A', summary=opts.get('summary'))
1425
1426
1426 def unapplied(ui, repo, patch=None, **opts):
1427 def unapplied(ui, repo, patch=None, **opts):
1427 """print the patches not yet applied"""
1428 """print the patches not yet applied"""
1428 q = repo.mq
1429 q = repo.mq
1429 if patch:
1430 if patch:
1430 if patch not in q.series:
1431 if patch not in q.series:
1431 raise util.Abort(_("patch %s is not in series file") % patch)
1432 raise util.Abort(_("patch %s is not in series file") % patch)
1432 start = q.series.index(patch) + 1
1433 start = q.series.index(patch) + 1
1433 else:
1434 else:
1434 start = q.series_end(True)
1435 start = q.series_end(True)
1435 q.qseries(repo, start=start, status='U', summary=opts.get('summary'))
1436 q.qseries(repo, start=start, status='U', summary=opts.get('summary'))
1436
1437
1437 def qimport(ui, repo, *filename, **opts):
1438 def qimport(ui, repo, *filename, **opts):
1438 """import a patch
1439 """import a patch
1439
1440
1440 The patch will have the same name as its source file unless you
1441 The patch will have the same name as its source file unless you
1441 give it a new one with --name.
1442 give it a new one with --name.
1442
1443
1443 You can register an existing patch inside the patch directory
1444 You can register an existing patch inside the patch directory
1444 with the --existing flag.
1445 with the --existing flag.
1445
1446
1446 With --force, an existing patch of the same name will be overwritten.
1447 With --force, an existing patch of the same name will be overwritten.
1447
1448
1448 An existing changeset may be placed under mq control with --rev
1449 An existing changeset may be placed under mq control with --rev
1449 (e.g. qimport --rev tip -n patch will place tip under mq control).
1450 (e.g. qimport --rev tip -n patch will place tip under mq control).
1450 With --git, patches imported with --rev will use the git diff
1451 With --git, patches imported with --rev will use the git diff
1451 format.
1452 format.
1452 """
1453 """
1453 q = repo.mq
1454 q = repo.mq
1454 q.qimport(repo, filename, patchname=opts['name'],
1455 q.qimport(repo, filename, patchname=opts['name'],
1455 existing=opts['existing'], force=opts['force'], rev=opts['rev'],
1456 existing=opts['existing'], force=opts['force'], rev=opts['rev'],
1456 git=opts['git'])
1457 git=opts['git'])
1457 q.save_dirty()
1458 q.save_dirty()
1458 return 0
1459 return 0
1459
1460
1460 def init(ui, repo, **opts):
1461 def init(ui, repo, **opts):
1461 """init a new queue repository
1462 """init a new queue repository
1462
1463
1463 The queue repository is unversioned by default. If -c is
1464 The queue repository is unversioned by default. If -c is
1464 specified, qinit will create a separate nested repository
1465 specified, qinit will create a separate nested repository
1465 for patches. Use qcommit to commit changes to this queue
1466 for patches. Use qcommit to commit changes to this queue
1466 repository."""
1467 repository."""
1467 q = repo.mq
1468 q = repo.mq
1468 r = q.init(repo, create=opts['create_repo'])
1469 r = q.init(repo, create=opts['create_repo'])
1469 q.save_dirty()
1470 q.save_dirty()
1470 if r:
1471 if r:
1471 fp = r.wopener('.hgignore', 'w')
1472 fp = r.wopener('.hgignore', 'w')
1472 print >> fp, 'syntax: glob'
1473 print >> fp, 'syntax: glob'
1473 print >> fp, 'status'
1474 print >> fp, 'status'
1474 print >> fp, 'guards'
1475 print >> fp, 'guards'
1475 fp.close()
1476 fp.close()
1476 r.wopener('series', 'w').close()
1477 r.wopener('series', 'w').close()
1477 r.add(['.hgignore', 'series'])
1478 r.add(['.hgignore', 'series'])
1478 return 0
1479 return 0
1479
1480
1480 def clone(ui, source, dest=None, **opts):
1481 def clone(ui, source, dest=None, **opts):
1481 '''clone main and patch repository at same time
1482 '''clone main and patch repository at same time
1482
1483
1483 If source is local, destination will have no patches applied. If
1484 If source is local, destination will have no patches applied. If
1484 source is remote, this command can not check if patches are
1485 source is remote, this command can not check if patches are
1485 applied in source, so cannot guarantee that patches are not
1486 applied in source, so cannot guarantee that patches are not
1486 applied in destination. If you clone remote repository, be sure
1487 applied in destination. If you clone remote repository, be sure
1487 before that it has no patches applied.
1488 before that it has no patches applied.
1488
1489
1489 Source patch repository is looked for in <src>/.hg/patches by
1490 Source patch repository is looked for in <src>/.hg/patches by
1490 default. Use -p <url> to change.
1491 default. Use -p <url> to change.
1491 '''
1492 '''
1492 commands.setremoteconfig(ui, opts)
1493 commands.setremoteconfig(ui, opts)
1493 if dest is None:
1494 if dest is None:
1494 dest = hg.defaultdest(source)
1495 dest = hg.defaultdest(source)
1495 sr = hg.repository(ui, ui.expandpath(source))
1496 sr = hg.repository(ui, ui.expandpath(source))
1496 qbase, destrev = None, None
1497 qbase, destrev = None, None
1497 if sr.local():
1498 if sr.local():
1498 if sr.mq.applied:
1499 if sr.mq.applied:
1499 qbase = revlog.bin(sr.mq.applied[0].rev)
1500 qbase = revlog.bin(sr.mq.applied[0].rev)
1500 if not hg.islocal(dest):
1501 if not hg.islocal(dest):
1501 heads = dict.fromkeys(sr.heads())
1502 heads = dict.fromkeys(sr.heads())
1502 for h in sr.heads(qbase):
1503 for h in sr.heads(qbase):
1503 del heads[h]
1504 del heads[h]
1504 destrev = heads.keys()
1505 destrev = heads.keys()
1505 destrev.append(sr.changelog.parents(qbase)[0])
1506 destrev.append(sr.changelog.parents(qbase)[0])
1506 ui.note(_('cloning main repo\n'))
1507 ui.note(_('cloning main repo\n'))
1507 sr, dr = hg.clone(ui, sr, dest,
1508 sr, dr = hg.clone(ui, sr, dest,
1508 pull=opts['pull'],
1509 pull=opts['pull'],
1509 rev=destrev,
1510 rev=destrev,
1510 update=False,
1511 update=False,
1511 stream=opts['uncompressed'])
1512 stream=opts['uncompressed'])
1512 ui.note(_('cloning patch repo\n'))
1513 ui.note(_('cloning patch repo\n'))
1513 spr, dpr = hg.clone(ui, opts['patches'] or (sr.url() + '/.hg/patches'),
1514 spr, dpr = hg.clone(ui, opts['patches'] or (sr.url() + '/.hg/patches'),
1514 dr.url() + '/.hg/patches',
1515 dr.url() + '/.hg/patches',
1515 pull=opts['pull'],
1516 pull=opts['pull'],
1516 update=not opts['noupdate'],
1517 update=not opts['noupdate'],
1517 stream=opts['uncompressed'])
1518 stream=opts['uncompressed'])
1518 if dr.local():
1519 if dr.local():
1519 if qbase:
1520 if qbase:
1520 ui.note(_('stripping applied patches from destination repo\n'))
1521 ui.note(_('stripping applied patches from destination repo\n'))
1521 dr.mq.strip(dr, qbase, update=False, backup=None)
1522 dr.mq.strip(dr, qbase, update=False, backup=None)
1522 if not opts['noupdate']:
1523 if not opts['noupdate']:
1523 ui.note(_('updating destination repo\n'))
1524 ui.note(_('updating destination repo\n'))
1524 hg.update(dr, dr.changelog.tip())
1525 hg.update(dr, dr.changelog.tip())
1525
1526
1526 def commit(ui, repo, *pats, **opts):
1527 def commit(ui, repo, *pats, **opts):
1527 """commit changes in the queue repository"""
1528 """commit changes in the queue repository"""
1528 q = repo.mq
1529 q = repo.mq
1529 r = q.qrepo()
1530 r = q.qrepo()
1530 if not r: raise util.Abort('no queue repository')
1531 if not r: raise util.Abort('no queue repository')
1531 commands.commit(r.ui, r, *pats, **opts)
1532 commands.commit(r.ui, r, *pats, **opts)
1532
1533
1533 def series(ui, repo, **opts):
1534 def series(ui, repo, **opts):
1534 """print the entire series file"""
1535 """print the entire series file"""
1535 repo.mq.qseries(repo, missing=opts['missing'], summary=opts['summary'])
1536 repo.mq.qseries(repo, missing=opts['missing'], summary=opts['summary'])
1536 return 0
1537 return 0
1537
1538
1538 def top(ui, repo, **opts):
1539 def top(ui, repo, **opts):
1539 """print the name of the current patch"""
1540 """print the name of the current patch"""
1540 q = repo.mq
1541 q = repo.mq
1541 t = len(q.applied)
1542 t = len(q.applied)
1542 if t:
1543 if t:
1543 return q.qseries(repo, start=t-1, length=1, status='A',
1544 return q.qseries(repo, start=t-1, length=1, status='A',
1544 summary=opts.get('summary'))
1545 summary=opts.get('summary'))
1545 else:
1546 else:
1546 ui.write("No patches applied\n")
1547 ui.write("No patches applied\n")
1547 return 1
1548 return 1
1548
1549
1549 def next(ui, repo, **opts):
1550 def next(ui, repo, **opts):
1550 """print the name of the next patch"""
1551 """print the name of the next patch"""
1551 q = repo.mq
1552 q = repo.mq
1552 end = q.series_end()
1553 end = q.series_end()
1553 if end == len(q.series):
1554 if end == len(q.series):
1554 ui.write("All patches applied\n")
1555 ui.write("All patches applied\n")
1555 return 1
1556 return 1
1556 return q.qseries(repo, start=end, length=1, summary=opts.get('summary'))
1557 return q.qseries(repo, start=end, length=1, summary=opts.get('summary'))
1557
1558
1558 def prev(ui, repo, **opts):
1559 def prev(ui, repo, **opts):
1559 """print the name of the previous patch"""
1560 """print the name of the previous patch"""
1560 q = repo.mq
1561 q = repo.mq
1561 l = len(q.applied)
1562 l = len(q.applied)
1562 if l == 1:
1563 if l == 1:
1563 ui.write("Only one patch applied\n")
1564 ui.write("Only one patch applied\n")
1564 return 1
1565 return 1
1565 if not l:
1566 if not l:
1566 ui.write("No patches applied\n")
1567 ui.write("No patches applied\n")
1567 return 1
1568 return 1
1568 return q.qseries(repo, start=l-2, length=1, status='A',
1569 return q.qseries(repo, start=l-2, length=1, status='A',
1569 summary=opts.get('summary'))
1570 summary=opts.get('summary'))
1570
1571
1571 def new(ui, repo, patch, **opts):
1572 def new(ui, repo, patch, **opts):
1572 """create a new patch
1573 """create a new patch
1573
1574
1574 qnew creates a new patch on top of the currently-applied patch
1575 qnew creates a new patch on top of the currently-applied patch
1575 (if any). It will refuse to run if there are any outstanding
1576 (if any). It will refuse to run if there are any outstanding
1576 changes unless -f is specified, in which case the patch will
1577 changes unless -f is specified, in which case the patch will
1577 be initialised with them.
1578 be initialised with them.
1578
1579
1579 -e, -m or -l set the patch header as well as the commit message.
1580 -e, -m or -l set the patch header as well as the commit message.
1580 If none is specified, the patch header is empty and the
1581 If none is specified, the patch header is empty and the
1581 commit message is 'New patch: PATCH'"""
1582 commit message is 'New patch: PATCH'"""
1582 q = repo.mq
1583 q = repo.mq
1583 message = commands.logmessage(opts)
1584 message = commands.logmessage(opts)
1584 if opts['edit']:
1585 if opts['edit']:
1585 message = ui.edit(message, ui.username())
1586 message = ui.edit(message, ui.username())
1586 q.new(repo, patch, msg=message, force=opts['force'])
1587 q.new(repo, patch, msg=message, force=opts['force'])
1587 q.save_dirty()
1588 q.save_dirty()
1588 return 0
1589 return 0
1589
1590
1590 def refresh(ui, repo, *pats, **opts):
1591 def refresh(ui, repo, *pats, **opts):
1591 """update the current patch
1592 """update the current patch
1592
1593
1593 If any file patterns are provided, the refreshed patch will contain only
1594 If any file patterns are provided, the refreshed patch will contain only
1594 the modifications that match those patterns; the remaining modifications
1595 the modifications that match those patterns; the remaining modifications
1595 will remain in the working directory.
1596 will remain in the working directory.
1596 """
1597 """
1597 q = repo.mq
1598 q = repo.mq
1598 message = commands.logmessage(opts)
1599 message = commands.logmessage(opts)
1599 if opts['edit']:
1600 if opts['edit']:
1600 if message:
1601 if message:
1601 raise util.Abort(_('option "-e" incompatible with "-m" or "-l"'))
1602 raise util.Abort(_('option "-e" incompatible with "-m" or "-l"'))
1602 patch = q.applied[-1].name
1603 patch = q.applied[-1].name
1603 (message, comment, user, date, hasdiff) = q.readheaders(patch)
1604 (message, comment, user, date, hasdiff) = q.readheaders(patch)
1604 message = ui.edit('\n'.join(message), user or ui.username())
1605 message = ui.edit('\n'.join(message), user or ui.username())
1605 ret = q.refresh(repo, pats, msg=message, **opts)
1606 ret = q.refresh(repo, pats, msg=message, **opts)
1606 q.save_dirty()
1607 q.save_dirty()
1607 return ret
1608 return ret
1608
1609
1609 def diff(ui, repo, *pats, **opts):
1610 def diff(ui, repo, *pats, **opts):
1610 """diff of the current patch"""
1611 """diff of the current patch"""
1611 repo.mq.diff(repo, pats, opts)
1612 repo.mq.diff(repo, pats, opts)
1612 return 0
1613 return 0
1613
1614
1614 def fold(ui, repo, *files, **opts):
1615 def fold(ui, repo, *files, **opts):
1615 """fold the named patches into the current patch
1616 """fold the named patches into the current patch
1616
1617
1617 Patches must not yet be applied. Each patch will be successively
1618 Patches must not yet be applied. Each patch will be successively
1618 applied to the current patch in the order given. If all the
1619 applied to the current patch in the order given. If all the
1619 patches apply successfully, the current patch will be refreshed
1620 patches apply successfully, the current patch will be refreshed
1620 with the new cumulative patch, and the folded patches will
1621 with the new cumulative patch, and the folded patches will
1621 be deleted. With -k/--keep, the folded patch files will not
1622 be deleted. With -k/--keep, the folded patch files will not
1622 be removed afterwards.
1623 be removed afterwards.
1623
1624
1624 The header for each folded patch will be concatenated with
1625 The header for each folded patch will be concatenated with
1625 the current patch header, separated by a line of '* * *'."""
1626 the current patch header, separated by a line of '* * *'."""
1626
1627
1627 q = repo.mq
1628 q = repo.mq
1628
1629
1629 if not files:
1630 if not files:
1630 raise util.Abort(_('qfold requires at least one patch name'))
1631 raise util.Abort(_('qfold requires at least one patch name'))
1631 if not q.check_toppatch(repo):
1632 if not q.check_toppatch(repo):
1632 raise util.Abort(_('No patches applied'))
1633 raise util.Abort(_('No patches applied'))
1633
1634
1634 message = commands.logmessage(opts)
1635 message = commands.logmessage(opts)
1635 if opts['edit']:
1636 if opts['edit']:
1636 if message:
1637 if message:
1637 raise util.Abort(_('option "-e" incompatible with "-m" or "-l"'))
1638 raise util.Abort(_('option "-e" incompatible with "-m" or "-l"'))
1638
1639
1639 parent = q.lookup('qtip')
1640 parent = q.lookup('qtip')
1640 patches = []
1641 patches = []
1641 messages = []
1642 messages = []
1642 for f in files:
1643 for f in files:
1643 p = q.lookup(f)
1644 p = q.lookup(f)
1644 if p in patches or p == parent:
1645 if p in patches or p == parent:
1645 ui.warn(_('Skipping already folded patch %s') % p)
1646 ui.warn(_('Skipping already folded patch %s') % p)
1646 if q.isapplied(p):
1647 if q.isapplied(p):
1647 raise util.Abort(_('qfold cannot fold already applied patch %s') % p)
1648 raise util.Abort(_('qfold cannot fold already applied patch %s') % p)
1648 patches.append(p)
1649 patches.append(p)
1649
1650
1650 for p in patches:
1651 for p in patches:
1651 if not message:
1652 if not message:
1652 messages.append(q.readheaders(p)[0])
1653 messages.append(q.readheaders(p)[0])
1653 pf = q.join(p)
1654 pf = q.join(p)
1654 (patchsuccess, files, fuzz) = q.patch(repo, pf)
1655 (patchsuccess, files, fuzz) = q.patch(repo, pf)
1655 if not patchsuccess:
1656 if not patchsuccess:
1656 raise util.Abort(_('Error folding patch %s') % p)
1657 raise util.Abort(_('Error folding patch %s') % p)
1657 patch.updatedir(ui, repo, files)
1658 patch.updatedir(ui, repo, files)
1658
1659
1659 if not message:
1660 if not message:
1660 message, comments, user = q.readheaders(parent)[0:3]
1661 message, comments, user = q.readheaders(parent)[0:3]
1661 for msg in messages:
1662 for msg in messages:
1662 message.append('* * *')
1663 message.append('* * *')
1663 message.extend(msg)
1664 message.extend(msg)
1664 message = '\n'.join(message)
1665 message = '\n'.join(message)
1665
1666
1666 if opts['edit']:
1667 if opts['edit']:
1667 message = ui.edit(message, user or ui.username())
1668 message = ui.edit(message, user or ui.username())
1668
1669
1669 q.refresh(repo, msg=message)
1670 q.refresh(repo, msg=message)
1670 q.delete(repo, patches, opts)
1671 q.delete(repo, patches, opts)
1671 q.save_dirty()
1672 q.save_dirty()
1672
1673
1673 def guard(ui, repo, *args, **opts):
1674 def guard(ui, repo, *args, **opts):
1674 '''set or print guards for a patch
1675 '''set or print guards for a patch
1675
1676
1676 Guards control whether a patch can be pushed. A patch with no
1677 Guards control whether a patch can be pushed. A patch with no
1677 guards is always pushed. A patch with a positive guard ("+foo") is
1678 guards is always pushed. A patch with a positive guard ("+foo") is
1678 pushed only if the qselect command has activated it. A patch with
1679 pushed only if the qselect command has activated it. A patch with
1679 a negative guard ("-foo") is never pushed if the qselect command
1680 a negative guard ("-foo") is never pushed if the qselect command
1680 has activated it.
1681 has activated it.
1681
1682
1682 With no arguments, print the currently active guards.
1683 With no arguments, print the currently active guards.
1683 With arguments, set guards for the named patch.
1684 With arguments, set guards for the named patch.
1684
1685
1685 To set a negative guard "-foo" on topmost patch ("--" is needed so
1686 To set a negative guard "-foo" on topmost patch ("--" is needed so
1686 hg will not interpret "-foo" as an option):
1687 hg will not interpret "-foo" as an option):
1687 hg qguard -- -foo
1688 hg qguard -- -foo
1688
1689
1689 To set guards on another patch:
1690 To set guards on another patch:
1690 hg qguard other.patch +2.6.17 -stable
1691 hg qguard other.patch +2.6.17 -stable
1691 '''
1692 '''
1692 def status(idx):
1693 def status(idx):
1693 guards = q.series_guards[idx] or ['unguarded']
1694 guards = q.series_guards[idx] or ['unguarded']
1694 ui.write('%s: %s\n' % (q.series[idx], ' '.join(guards)))
1695 ui.write('%s: %s\n' % (q.series[idx], ' '.join(guards)))
1695 q = repo.mq
1696 q = repo.mq
1696 patch = None
1697 patch = None
1697 args = list(args)
1698 args = list(args)
1698 if opts['list']:
1699 if opts['list']:
1699 if args or opts['none']:
1700 if args or opts['none']:
1700 raise util.Abort(_('cannot mix -l/--list with options or arguments'))
1701 raise util.Abort(_('cannot mix -l/--list with options or arguments'))
1701 for i in xrange(len(q.series)):
1702 for i in xrange(len(q.series)):
1702 status(i)
1703 status(i)
1703 return
1704 return
1704 if not args or args[0][0:1] in '-+':
1705 if not args or args[0][0:1] in '-+':
1705 if not q.applied:
1706 if not q.applied:
1706 raise util.Abort(_('no patches applied'))
1707 raise util.Abort(_('no patches applied'))
1707 patch = q.applied[-1].name
1708 patch = q.applied[-1].name
1708 if patch is None and args[0][0:1] not in '-+':
1709 if patch is None and args[0][0:1] not in '-+':
1709 patch = args.pop(0)
1710 patch = args.pop(0)
1710 if patch is None:
1711 if patch is None:
1711 raise util.Abort(_('no patch to work with'))
1712 raise util.Abort(_('no patch to work with'))
1712 if args or opts['none']:
1713 if args or opts['none']:
1713 idx = q.find_series(patch)
1714 idx = q.find_series(patch)
1714 if idx is None:
1715 if idx is None:
1715 raise util.Abort(_('no patch named %s') % patch)
1716 raise util.Abort(_('no patch named %s') % patch)
1716 q.set_guards(idx, args)
1717 q.set_guards(idx, args)
1717 q.save_dirty()
1718 q.save_dirty()
1718 else:
1719 else:
1719 status(q.series.index(q.lookup(patch)))
1720 status(q.series.index(q.lookup(patch)))
1720
1721
1721 def header(ui, repo, patch=None):
1722 def header(ui, repo, patch=None):
1722 """Print the header of the topmost or specified patch"""
1723 """Print the header of the topmost or specified patch"""
1723 q = repo.mq
1724 q = repo.mq
1724
1725
1725 if patch:
1726 if patch:
1726 patch = q.lookup(patch)
1727 patch = q.lookup(patch)
1727 else:
1728 else:
1728 if not q.applied:
1729 if not q.applied:
1729 ui.write('No patches applied\n')
1730 ui.write('No patches applied\n')
1730 return 1
1731 return 1
1731 patch = q.lookup('qtip')
1732 patch = q.lookup('qtip')
1732 message = repo.mq.readheaders(patch)[0]
1733 message = repo.mq.readheaders(patch)[0]
1733
1734
1734 ui.write('\n'.join(message) + '\n')
1735 ui.write('\n'.join(message) + '\n')
1735
1736
1736 def lastsavename(path):
1737 def lastsavename(path):
1737 (directory, base) = os.path.split(path)
1738 (directory, base) = os.path.split(path)
1738 names = os.listdir(directory)
1739 names = os.listdir(directory)
1739 namere = re.compile("%s.([0-9]+)" % base)
1740 namere = re.compile("%s.([0-9]+)" % base)
1740 maxindex = None
1741 maxindex = None
1741 maxname = None
1742 maxname = None
1742 for f in names:
1743 for f in names:
1743 m = namere.match(f)
1744 m = namere.match(f)
1744 if m:
1745 if m:
1745 index = int(m.group(1))
1746 index = int(m.group(1))
1746 if maxindex == None or index > maxindex:
1747 if maxindex == None or index > maxindex:
1747 maxindex = index
1748 maxindex = index
1748 maxname = f
1749 maxname = f
1749 if maxname:
1750 if maxname:
1750 return (os.path.join(directory, maxname), maxindex)
1751 return (os.path.join(directory, maxname), maxindex)
1751 return (None, None)
1752 return (None, None)
1752
1753
1753 def savename(path):
1754 def savename(path):
1754 (last, index) = lastsavename(path)
1755 (last, index) = lastsavename(path)
1755 if last is None:
1756 if last is None:
1756 index = 0
1757 index = 0
1757 newpath = path + ".%d" % (index + 1)
1758 newpath = path + ".%d" % (index + 1)
1758 return newpath
1759 return newpath
1759
1760
1760 def push(ui, repo, patch=None, **opts):
1761 def push(ui, repo, patch=None, **opts):
1761 """push the next patch onto the stack"""
1762 """push the next patch onto the stack"""
1762 q = repo.mq
1763 q = repo.mq
1763 mergeq = None
1764 mergeq = None
1764
1765
1765 if opts['all']:
1766 if opts['all']:
1766 if not q.series:
1767 if not q.series:
1767 raise util.Abort(_('no patches in series'))
1768 raise util.Abort(_('no patches in series'))
1768 patch = q.series[-1]
1769 patch = q.series[-1]
1769 if opts['merge']:
1770 if opts['merge']:
1770 if opts['name']:
1771 if opts['name']:
1771 newpath = opts['name']
1772 newpath = opts['name']
1772 else:
1773 else:
1773 newpath, i = lastsavename(q.path)
1774 newpath, i = lastsavename(q.path)
1774 if not newpath:
1775 if not newpath:
1775 ui.warn("no saved queues found, please use -n\n")
1776 ui.warn("no saved queues found, please use -n\n")
1776 return 1
1777 return 1
1777 mergeq = queue(ui, repo.join(""), newpath)
1778 mergeq = queue(ui, repo.join(""), newpath)
1778 ui.warn("merging with queue at: %s\n" % mergeq.path)
1779 ui.warn("merging with queue at: %s\n" % mergeq.path)
1779 ret = q.push(repo, patch, force=opts['force'], list=opts['list'],
1780 ret = q.push(repo, patch, force=opts['force'], list=opts['list'],
1780 mergeq=mergeq)
1781 mergeq=mergeq)
1781 q.save_dirty()
1782 q.save_dirty()
1782 return ret
1783 return ret
1783
1784
1784 def pop(ui, repo, patch=None, **opts):
1785 def pop(ui, repo, patch=None, **opts):
1785 """pop the current patch off the stack"""
1786 """pop the current patch off the stack"""
1786 localupdate = True
1787 localupdate = True
1787 if opts['name']:
1788 if opts['name']:
1788 q = queue(ui, repo.join(""), repo.join(opts['name']))
1789 q = queue(ui, repo.join(""), repo.join(opts['name']))
1789 ui.warn('using patch queue: %s\n' % q.path)
1790 ui.warn('using patch queue: %s\n' % q.path)
1790 localupdate = False
1791 localupdate = False
1791 else:
1792 else:
1792 q = repo.mq
1793 q = repo.mq
1793 q.pop(repo, patch, force=opts['force'], update=localupdate, all=opts['all'])
1794 q.pop(repo, patch, force=opts['force'], update=localupdate, all=opts['all'])
1794 q.save_dirty()
1795 q.save_dirty()
1795 return 0
1796 return 0
1796
1797
1797 def rename(ui, repo, patch, name=None, **opts):
1798 def rename(ui, repo, patch, name=None, **opts):
1798 """rename a patch
1799 """rename a patch
1799
1800
1800 With one argument, renames the current patch to PATCH1.
1801 With one argument, renames the current patch to PATCH1.
1801 With two arguments, renames PATCH1 to PATCH2."""
1802 With two arguments, renames PATCH1 to PATCH2."""
1802
1803
1803 q = repo.mq
1804 q = repo.mq
1804
1805
1805 if not name:
1806 if not name:
1806 name = patch
1807 name = patch
1807 patch = None
1808 patch = None
1808
1809
1809 if patch:
1810 if patch:
1810 patch = q.lookup(patch)
1811 patch = q.lookup(patch)
1811 else:
1812 else:
1812 if not q.applied:
1813 if not q.applied:
1813 ui.write(_('No patches applied\n'))
1814 ui.write(_('No patches applied\n'))
1814 return
1815 return
1815 patch = q.lookup('qtip')
1816 patch = q.lookup('qtip')
1816 absdest = q.join(name)
1817 absdest = q.join(name)
1817 if os.path.isdir(absdest):
1818 if os.path.isdir(absdest):
1818 name = os.path.join(name, os.path.basename(patch))
1819 name = os.path.join(name, os.path.basename(patch))
1819 absdest = q.join(name)
1820 absdest = q.join(name)
1820 if os.path.exists(absdest):
1821 if os.path.exists(absdest):
1821 raise util.Abort(_('%s already exists') % absdest)
1822 raise util.Abort(_('%s already exists') % absdest)
1822
1823
1823 if name in q.series:
1824 if name in q.series:
1824 raise util.Abort(_('A patch named %s already exists in the series file') % name)
1825 raise util.Abort(_('A patch named %s already exists in the series file') % name)
1825
1826
1826 if ui.verbose:
1827 if ui.verbose:
1827 ui.write('Renaming %s to %s\n' % (patch, name))
1828 ui.write('Renaming %s to %s\n' % (patch, name))
1828 i = q.find_series(patch)
1829 i = q.find_series(patch)
1829 guards = q.guard_re.findall(q.full_series[i])
1830 guards = q.guard_re.findall(q.full_series[i])
1830 q.full_series[i] = name + ''.join([' #' + g for g in guards])
1831 q.full_series[i] = name + ''.join([' #' + g for g in guards])
1831 q.parse_series()
1832 q.parse_series()
1832 q.series_dirty = 1
1833 q.series_dirty = 1
1833
1834
1834 info = q.isapplied(patch)
1835 info = q.isapplied(patch)
1835 if info:
1836 if info:
1836 q.applied[info[0]] = statusentry(info[1], name)
1837 q.applied[info[0]] = statusentry(info[1], name)
1837 q.applied_dirty = 1
1838 q.applied_dirty = 1
1838
1839
1839 util.rename(q.join(patch), absdest)
1840 util.rename(q.join(patch), absdest)
1840 r = q.qrepo()
1841 r = q.qrepo()
1841 if r:
1842 if r:
1842 wlock = r.wlock()
1843 wlock = r.wlock()
1843 if r.dirstate.state(name) == 'r':
1844 if r.dirstate.state(name) == 'r':
1844 r.undelete([name], wlock)
1845 r.undelete([name], wlock)
1845 r.copy(patch, name, wlock)
1846 r.copy(patch, name, wlock)
1846 r.remove([patch], False, wlock)
1847 r.remove([patch], False, wlock)
1847
1848
1848 q.save_dirty()
1849 q.save_dirty()
1849
1850
1850 def restore(ui, repo, rev, **opts):
1851 def restore(ui, repo, rev, **opts):
1851 """restore the queue state saved by a rev"""
1852 """restore the queue state saved by a rev"""
1852 rev = repo.lookup(rev)
1853 rev = repo.lookup(rev)
1853 q = repo.mq
1854 q = repo.mq
1854 q.restore(repo, rev, delete=opts['delete'],
1855 q.restore(repo, rev, delete=opts['delete'],
1855 qupdate=opts['update'])
1856 qupdate=opts['update'])
1856 q.save_dirty()
1857 q.save_dirty()
1857 return 0
1858 return 0
1858
1859
1859 def save(ui, repo, **opts):
1860 def save(ui, repo, **opts):
1860 """save current queue state"""
1861 """save current queue state"""
1861 q = repo.mq
1862 q = repo.mq
1862 message = commands.logmessage(opts)
1863 message = commands.logmessage(opts)
1863 ret = q.save(repo, msg=message)
1864 ret = q.save(repo, msg=message)
1864 if ret:
1865 if ret:
1865 return ret
1866 return ret
1866 q.save_dirty()
1867 q.save_dirty()
1867 if opts['copy']:
1868 if opts['copy']:
1868 path = q.path
1869 path = q.path
1869 if opts['name']:
1870 if opts['name']:
1870 newpath = os.path.join(q.basepath, opts['name'])
1871 newpath = os.path.join(q.basepath, opts['name'])
1871 if os.path.exists(newpath):
1872 if os.path.exists(newpath):
1872 if not os.path.isdir(newpath):
1873 if not os.path.isdir(newpath):
1873 raise util.Abort(_('destination %s exists and is not '
1874 raise util.Abort(_('destination %s exists and is not '
1874 'a directory') % newpath)
1875 'a directory') % newpath)
1875 if not opts['force']:
1876 if not opts['force']:
1876 raise util.Abort(_('destination %s exists, '
1877 raise util.Abort(_('destination %s exists, '
1877 'use -f to force') % newpath)
1878 'use -f to force') % newpath)
1878 else:
1879 else:
1879 newpath = savename(path)
1880 newpath = savename(path)
1880 ui.warn("copy %s to %s\n" % (path, newpath))
1881 ui.warn("copy %s to %s\n" % (path, newpath))
1881 util.copyfiles(path, newpath)
1882 util.copyfiles(path, newpath)
1882 if opts['empty']:
1883 if opts['empty']:
1883 try:
1884 try:
1884 os.unlink(q.join(q.status_path))
1885 os.unlink(q.join(q.status_path))
1885 except:
1886 except:
1886 pass
1887 pass
1887 return 0
1888 return 0
1888
1889
1889 def strip(ui, repo, rev, **opts):
1890 def strip(ui, repo, rev, **opts):
1890 """strip a revision and all later revs on the same branch"""
1891 """strip a revision and all later revs on the same branch"""
1891 rev = repo.lookup(rev)
1892 rev = repo.lookup(rev)
1892 backup = 'all'
1893 backup = 'all'
1893 if opts['backup']:
1894 if opts['backup']:
1894 backup = 'strip'
1895 backup = 'strip'
1895 elif opts['nobackup']:
1896 elif opts['nobackup']:
1896 backup = 'none'
1897 backup = 'none'
1897 update = repo.dirstate.parents()[0] != revlog.nullid
1898 update = repo.dirstate.parents()[0] != revlog.nullid
1898 repo.mq.strip(repo, rev, backup=backup, update=update)
1899 repo.mq.strip(repo, rev, backup=backup, update=update)
1899 return 0
1900 return 0
1900
1901
1901 def select(ui, repo, *args, **opts):
1902 def select(ui, repo, *args, **opts):
1902 '''set or print guarded patches to push
1903 '''set or print guarded patches to push
1903
1904
1904 Use the qguard command to set or print guards on patch, then use
1905 Use the qguard command to set or print guards on patch, then use
1905 qselect to tell mq which guards to use. A patch will be pushed if it
1906 qselect to tell mq which guards to use. A patch will be pushed if it
1906 has no guards or any positive guards match the currently selected guard,
1907 has no guards or any positive guards match the currently selected guard,
1907 but will not be pushed if any negative guards match the current guard.
1908 but will not be pushed if any negative guards match the current guard.
1908 For example:
1909 For example:
1909
1910
1910 qguard foo.patch -stable (negative guard)
1911 qguard foo.patch -stable (negative guard)
1911 qguard bar.patch +stable (positive guard)
1912 qguard bar.patch +stable (positive guard)
1912 qselect stable
1913 qselect stable
1913
1914
1914 This activates the "stable" guard. mq will skip foo.patch (because
1915 This activates the "stable" guard. mq will skip foo.patch (because
1915 it has a negative match) but push bar.patch (because it
1916 it has a negative match) but push bar.patch (because it
1916 has a positive match).
1917 has a positive match).
1917
1918
1918 With no arguments, prints the currently active guards.
1919 With no arguments, prints the currently active guards.
1919 With one argument, sets the active guard.
1920 With one argument, sets the active guard.
1920
1921
1921 Use -n/--none to deactivate guards (no other arguments needed).
1922 Use -n/--none to deactivate guards (no other arguments needed).
1922 When no guards are active, patches with positive guards are skipped
1923 When no guards are active, patches with positive guards are skipped
1923 and patches with negative guards are pushed.
1924 and patches with negative guards are pushed.
1924
1925
1925 qselect can change the guards on applied patches. It does not pop
1926 qselect can change the guards on applied patches. It does not pop
1926 guarded patches by default. Use --pop to pop back to the last applied
1927 guarded patches by default. Use --pop to pop back to the last applied
1927 patch that is not guarded. Use --reapply (which implies --pop) to push
1928 patch that is not guarded. Use --reapply (which implies --pop) to push
1928 back to the current patch afterwards, but skip guarded patches.
1929 back to the current patch afterwards, but skip guarded patches.
1929
1930
1930 Use -s/--series to print a list of all guards in the series file (no
1931 Use -s/--series to print a list of all guards in the series file (no
1931 other arguments needed). Use -v for more information.'''
1932 other arguments needed). Use -v for more information.'''
1932
1933
1933 q = repo.mq
1934 q = repo.mq
1934 guards = q.active()
1935 guards = q.active()
1935 if args or opts['none']:
1936 if args or opts['none']:
1936 old_unapplied = q.unapplied(repo)
1937 old_unapplied = q.unapplied(repo)
1937 old_guarded = [i for i in xrange(len(q.applied)) if
1938 old_guarded = [i for i in xrange(len(q.applied)) if
1938 not q.pushable(i)[0]]
1939 not q.pushable(i)[0]]
1939 q.set_active(args)
1940 q.set_active(args)
1940 q.save_dirty()
1941 q.save_dirty()
1941 if not args:
1942 if not args:
1942 ui.status(_('guards deactivated\n'))
1943 ui.status(_('guards deactivated\n'))
1943 if not opts['pop'] and not opts['reapply']:
1944 if not opts['pop'] and not opts['reapply']:
1944 unapplied = q.unapplied(repo)
1945 unapplied = q.unapplied(repo)
1945 guarded = [i for i in xrange(len(q.applied))
1946 guarded = [i for i in xrange(len(q.applied))
1946 if not q.pushable(i)[0]]
1947 if not q.pushable(i)[0]]
1947 if len(unapplied) != len(old_unapplied):
1948 if len(unapplied) != len(old_unapplied):
1948 ui.status(_('number of unguarded, unapplied patches has '
1949 ui.status(_('number of unguarded, unapplied patches has '
1949 'changed from %d to %d\n') %
1950 'changed from %d to %d\n') %
1950 (len(old_unapplied), len(unapplied)))
1951 (len(old_unapplied), len(unapplied)))
1951 if len(guarded) != len(old_guarded):
1952 if len(guarded) != len(old_guarded):
1952 ui.status(_('number of guarded, applied patches has changed '
1953 ui.status(_('number of guarded, applied patches has changed '
1953 'from %d to %d\n') %
1954 'from %d to %d\n') %
1954 (len(old_guarded), len(guarded)))
1955 (len(old_guarded), len(guarded)))
1955 elif opts['series']:
1956 elif opts['series']:
1956 guards = {}
1957 guards = {}
1957 noguards = 0
1958 noguards = 0
1958 for gs in q.series_guards:
1959 for gs in q.series_guards:
1959 if not gs:
1960 if not gs:
1960 noguards += 1
1961 noguards += 1
1961 for g in gs:
1962 for g in gs:
1962 guards.setdefault(g, 0)
1963 guards.setdefault(g, 0)
1963 guards[g] += 1
1964 guards[g] += 1
1964 if ui.verbose:
1965 if ui.verbose:
1965 guards['NONE'] = noguards
1966 guards['NONE'] = noguards
1966 guards = guards.items()
1967 guards = guards.items()
1967 guards.sort(lambda a, b: cmp(a[0][1:], b[0][1:]))
1968 guards.sort(lambda a, b: cmp(a[0][1:], b[0][1:]))
1968 if guards:
1969 if guards:
1969 ui.note(_('guards in series file:\n'))
1970 ui.note(_('guards in series file:\n'))
1970 for guard, count in guards:
1971 for guard, count in guards:
1971 ui.note('%2d ' % count)
1972 ui.note('%2d ' % count)
1972 ui.write(guard, '\n')
1973 ui.write(guard, '\n')
1973 else:
1974 else:
1974 ui.note(_('no guards in series file\n'))
1975 ui.note(_('no guards in series file\n'))
1975 else:
1976 else:
1976 if guards:
1977 if guards:
1977 ui.note(_('active guards:\n'))
1978 ui.note(_('active guards:\n'))
1978 for g in guards:
1979 for g in guards:
1979 ui.write(g, '\n')
1980 ui.write(g, '\n')
1980 else:
1981 else:
1981 ui.write(_('no active guards\n'))
1982 ui.write(_('no active guards\n'))
1982 reapply = opts['reapply'] and q.applied and q.appliedname(-1)
1983 reapply = opts['reapply'] and q.applied and q.appliedname(-1)
1983 popped = False
1984 popped = False
1984 if opts['pop'] or opts['reapply']:
1985 if opts['pop'] or opts['reapply']:
1985 for i in xrange(len(q.applied)):
1986 for i in xrange(len(q.applied)):
1986 pushable, reason = q.pushable(i)
1987 pushable, reason = q.pushable(i)
1987 if not pushable:
1988 if not pushable:
1988 ui.status(_('popping guarded patches\n'))
1989 ui.status(_('popping guarded patches\n'))
1989 popped = True
1990 popped = True
1990 if i == 0:
1991 if i == 0:
1991 q.pop(repo, all=True)
1992 q.pop(repo, all=True)
1992 else:
1993 else:
1993 q.pop(repo, i-1)
1994 q.pop(repo, i-1)
1994 break
1995 break
1995 if popped:
1996 if popped:
1996 try:
1997 try:
1997 if reapply:
1998 if reapply:
1998 ui.status(_('reapplying unguarded patches\n'))
1999 ui.status(_('reapplying unguarded patches\n'))
1999 q.push(repo, reapply)
2000 q.push(repo, reapply)
2000 finally:
2001 finally:
2001 q.save_dirty()
2002 q.save_dirty()
2002
2003
2003 def reposetup(ui, repo):
2004 def reposetup(ui, repo):
2004 class mqrepo(repo.__class__):
2005 class mqrepo(repo.__class__):
2005 def abort_if_wdir_patched(self, errmsg, force=False):
2006 def abort_if_wdir_patched(self, errmsg, force=False):
2006 if self.mq.applied and not force:
2007 if self.mq.applied and not force:
2007 parent = revlog.hex(self.dirstate.parents()[0])
2008 parent = revlog.hex(self.dirstate.parents()[0])
2008 if parent in [s.rev for s in self.mq.applied]:
2009 if parent in [s.rev for s in self.mq.applied]:
2009 raise util.Abort(errmsg)
2010 raise util.Abort(errmsg)
2010
2011
2011 def commit(self, *args, **opts):
2012 def commit(self, *args, **opts):
2012 if len(args) >= 6:
2013 if len(args) >= 6:
2013 force = args[5]
2014 force = args[5]
2014 else:
2015 else:
2015 force = opts.get('force')
2016 force = opts.get('force')
2016 self.abort_if_wdir_patched(
2017 self.abort_if_wdir_patched(
2017 _('cannot commit over an applied mq patch'),
2018 _('cannot commit over an applied mq patch'),
2018 force)
2019 force)
2019
2020
2020 return super(mqrepo, self).commit(*args, **opts)
2021 return super(mqrepo, self).commit(*args, **opts)
2021
2022
2022 def push(self, remote, force=False, revs=None):
2023 def push(self, remote, force=False, revs=None):
2023 if self.mq.applied and not force:
2024 if self.mq.applied and not force:
2024 raise util.Abort(_('source has mq patches applied'))
2025 raise util.Abort(_('source has mq patches applied'))
2025 return super(mqrepo, self).push(remote, force, revs)
2026 return super(mqrepo, self).push(remote, force, revs)
2026
2027
2027 def tags(self):
2028 def tags(self):
2028 if self.tagscache:
2029 if self.tagscache:
2029 return self.tagscache
2030 return self.tagscache
2030
2031
2031 tagscache = super(mqrepo, self).tags()
2032 tagscache = super(mqrepo, self).tags()
2032
2033
2033 q = self.mq
2034 q = self.mq
2034 if not q.applied:
2035 if not q.applied:
2035 return tagscache
2036 return tagscache
2036
2037
2037 mqtags = [(patch.rev, patch.name) for patch in q.applied]
2038 mqtags = [(patch.rev, patch.name) for patch in q.applied]
2038 mqtags.append((mqtags[-1][0], 'qtip'))
2039 mqtags.append((mqtags[-1][0], 'qtip'))
2039 mqtags.append((mqtags[0][0], 'qbase'))
2040 mqtags.append((mqtags[0][0], 'qbase'))
2040 for patch in mqtags:
2041 for patch in mqtags:
2041 if patch[1] in tagscache:
2042 if patch[1] in tagscache:
2042 self.ui.warn('Tag %s overrides mq patch of the same name\n' % patch[1])
2043 self.ui.warn('Tag %s overrides mq patch of the same name\n' % patch[1])
2043 else:
2044 else:
2044 tagscache[patch[1]] = revlog.bin(patch[0])
2045 tagscache[patch[1]] = revlog.bin(patch[0])
2045
2046
2046 return tagscache
2047 return tagscache
2047
2048
2048 def _branchtags(self):
2049 def _branchtags(self):
2049 q = self.mq
2050 q = self.mq
2050 if not q.applied:
2051 if not q.applied:
2051 return super(mqrepo, self)._branchtags()
2052 return super(mqrepo, self)._branchtags()
2052
2053
2053 self.branchcache = {} # avoid recursion in changectx
2054 self.branchcache = {} # avoid recursion in changectx
2054 cl = self.changelog
2055 cl = self.changelog
2055 partial, last, lrev = self._readbranchcache()
2056 partial, last, lrev = self._readbranchcache()
2056
2057
2057 qbase = cl.rev(revlog.bin(q.applied[0].rev))
2058 qbase = cl.rev(revlog.bin(q.applied[0].rev))
2058 start = lrev + 1
2059 start = lrev + 1
2059 if start < qbase:
2060 if start < qbase:
2060 # update the cache (excluding the patches) and save it
2061 # update the cache (excluding the patches) and save it
2061 self._updatebranchcache(partial, lrev+1, qbase)
2062 self._updatebranchcache(partial, lrev+1, qbase)
2062 self._writebranchcache(partial, cl.node(qbase-1), qbase-1)
2063 self._writebranchcache(partial, cl.node(qbase-1), qbase-1)
2063 start = qbase
2064 start = qbase
2064 # if start = qbase, the cache is as updated as it should be.
2065 # if start = qbase, the cache is as updated as it should be.
2065 # if start > qbase, the cache includes (part of) the patches.
2066 # if start > qbase, the cache includes (part of) the patches.
2066 # we might as well use it, but we won't save it.
2067 # we might as well use it, but we won't save it.
2067
2068
2068 # update the cache up to the tip
2069 # update the cache up to the tip
2069 self._updatebranchcache(partial, start, cl.count())
2070 self._updatebranchcache(partial, start, cl.count())
2070
2071
2071 return partial
2072 return partial
2072
2073
2073 if repo.local():
2074 if repo.local():
2074 repo.__class__ = mqrepo
2075 repo.__class__ = mqrepo
2075 repo.mq = queue(ui, repo.join(""))
2076 repo.mq = queue(ui, repo.join(""))
2076
2077
2077 seriesopts = [('s', 'summary', None, _('print first line of patch header'))]
2078 seriesopts = [('s', 'summary', None, _('print first line of patch header'))]
2078
2079
2079 cmdtable = {
2080 cmdtable = {
2080 "qapplied": (applied, [] + seriesopts, 'hg qapplied [-s] [PATCH]'),
2081 "qapplied": (applied, [] + seriesopts, 'hg qapplied [-s] [PATCH]'),
2081 "qclone": (clone,
2082 "qclone": (clone,
2082 [('', 'pull', None, _('use pull protocol to copy metadata')),
2083 [('', 'pull', None, _('use pull protocol to copy metadata')),
2083 ('U', 'noupdate', None, _('do not update the new working directories')),
2084 ('U', 'noupdate', None, _('do not update the new working directories')),
2084 ('', 'uncompressed', None,
2085 ('', 'uncompressed', None,
2085 _('use uncompressed transfer (fast over LAN)')),
2086 _('use uncompressed transfer (fast over LAN)')),
2086 ('e', 'ssh', '', _('specify ssh command to use')),
2087 ('e', 'ssh', '', _('specify ssh command to use')),
2087 ('p', 'patches', '', _('location of source patch repo')),
2088 ('p', 'patches', '', _('location of source patch repo')),
2088 ('', 'remotecmd', '',
2089 ('', 'remotecmd', '',
2089 _('specify hg command to run on the remote side'))],
2090 _('specify hg command to run on the remote side'))],
2090 'hg qclone [OPTION]... SOURCE [DEST]'),
2091 'hg qclone [OPTION]... SOURCE [DEST]'),
2091 "qcommit|qci":
2092 "qcommit|qci":
2092 (commit,
2093 (commit,
2093 commands.table["^commit|ci"][1],
2094 commands.table["^commit|ci"][1],
2094 'hg qcommit [OPTION]... [FILE]...'),
2095 'hg qcommit [OPTION]... [FILE]...'),
2095 "^qdiff": (diff,
2096 "^qdiff": (diff,
2096 [('g', 'git', None, _('use git extended diff format')),
2097 [('g', 'git', None, _('use git extended diff format')),
2097 ('I', 'include', [], _('include names matching the given patterns')),
2098 ('I', 'include', [], _('include names matching the given patterns')),
2098 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2099 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2099 'hg qdiff [-I] [-X] [FILE]...'),
2100 'hg qdiff [-I] [-X] [FILE]...'),
2100 "qdelete|qremove|qrm":
2101 "qdelete|qremove|qrm":
2101 (delete,
2102 (delete,
2102 [('k', 'keep', None, _('keep patch file')),
2103 [('k', 'keep', None, _('keep patch file')),
2103 ('r', 'rev', [], _('stop managing a revision'))],
2104 ('r', 'rev', [], _('stop managing a revision'))],
2104 'hg qdelete [-k] [-r REV]... PATCH...'),
2105 'hg qdelete [-k] [-r REV]... PATCH...'),
2105 'qfold':
2106 'qfold':
2106 (fold,
2107 (fold,
2107 [('e', 'edit', None, _('edit patch header')),
2108 [('e', 'edit', None, _('edit patch header')),
2108 ('k', 'keep', None, _('keep folded patch files'))
2109 ('k', 'keep', None, _('keep folded patch files'))
2109 ] + commands.commitopts,
2110 ] + commands.commitopts,
2110 'hg qfold [-e] [-m <text>] [-l <file] PATCH...'),
2111 'hg qfold [-e] [-m <text>] [-l <file] PATCH...'),
2111 'qguard': (guard, [('l', 'list', None, _('list all patches and guards')),
2112 'qguard': (guard, [('l', 'list', None, _('list all patches and guards')),
2112 ('n', 'none', None, _('drop all guards'))],
2113 ('n', 'none', None, _('drop all guards'))],
2113 'hg qguard [PATCH] [+GUARD...] [-GUARD...]'),
2114 'hg qguard [PATCH] [+GUARD...] [-GUARD...]'),
2114 'qheader': (header, [],
2115 'qheader': (header, [],
2115 _('hg qheader [PATCH]')),
2116 _('hg qheader [PATCH]')),
2116 "^qimport":
2117 "^qimport":
2117 (qimport,
2118 (qimport,
2118 [('e', 'existing', None, 'import file in patch dir'),
2119 [('e', 'existing', None, 'import file in patch dir'),
2119 ('n', 'name', '', 'patch file name'),
2120 ('n', 'name', '', 'patch file name'),
2120 ('f', 'force', None, 'overwrite existing files'),
2121 ('f', 'force', None, 'overwrite existing files'),
2121 ('r', 'rev', [], 'place existing revisions under mq control'),
2122 ('r', 'rev', [], 'place existing revisions under mq control'),
2122 ('g', 'git', None, _('use git extended diff format'))],
2123 ('g', 'git', None, _('use git extended diff format'))],
2123 'hg qimport [-e] [-n NAME] [-f] [-g] [-r REV]... FILE...'),
2124 'hg qimport [-e] [-n NAME] [-f] [-g] [-r REV]... FILE...'),
2124 "^qinit":
2125 "^qinit":
2125 (init,
2126 (init,
2126 [('c', 'create-repo', None, 'create queue repository')],
2127 [('c', 'create-repo', None, 'create queue repository')],
2127 'hg qinit [-c]'),
2128 'hg qinit [-c]'),
2128 "qnew":
2129 "qnew":
2129 (new,
2130 (new,
2130 [('e', 'edit', None, _('edit commit message')),
2131 [('e', 'edit', None, _('edit commit message')),
2131 ('f', 'force', None, _('import uncommitted changes into patch'))
2132 ('f', 'force', None, _('import uncommitted changes into patch'))
2132 ] + commands.commitopts,
2133 ] + commands.commitopts,
2133 'hg qnew [-e] [-m TEXT] [-l FILE] [-f] PATCH'),
2134 'hg qnew [-e] [-m TEXT] [-l FILE] [-f] PATCH'),
2134 "qnext": (next, [] + seriesopts, 'hg qnext [-s]'),
2135 "qnext": (next, [] + seriesopts, 'hg qnext [-s]'),
2135 "qprev": (prev, [] + seriesopts, 'hg qprev [-s]'),
2136 "qprev": (prev, [] + seriesopts, 'hg qprev [-s]'),
2136 "^qpop":
2137 "^qpop":
2137 (pop,
2138 (pop,
2138 [('a', 'all', None, 'pop all patches'),
2139 [('a', 'all', None, 'pop all patches'),
2139 ('n', 'name', '', 'queue name to pop'),
2140 ('n', 'name', '', 'queue name to pop'),
2140 ('f', 'force', None, 'forget any local changes')],
2141 ('f', 'force', None, 'forget any local changes')],
2141 'hg qpop [-a] [-n NAME] [-f] [PATCH | INDEX]'),
2142 'hg qpop [-a] [-n NAME] [-f] [PATCH | INDEX]'),
2142 "^qpush":
2143 "^qpush":
2143 (push,
2144 (push,
2144 [('f', 'force', None, 'apply if the patch has rejects'),
2145 [('f', 'force', None, 'apply if the patch has rejects'),
2145 ('l', 'list', None, 'list patch name in commit text'),
2146 ('l', 'list', None, 'list patch name in commit text'),
2146 ('a', 'all', None, 'apply all patches'),
2147 ('a', 'all', None, 'apply all patches'),
2147 ('m', 'merge', None, 'merge from another queue'),
2148 ('m', 'merge', None, 'merge from another queue'),
2148 ('n', 'name', '', 'merge queue name')],
2149 ('n', 'name', '', 'merge queue name')],
2149 'hg qpush [-f] [-l] [-a] [-m] [-n NAME] [PATCH | INDEX]'),
2150 'hg qpush [-f] [-l] [-a] [-m] [-n NAME] [PATCH | INDEX]'),
2150 "^qrefresh":
2151 "^qrefresh":
2151 (refresh,
2152 (refresh,
2152 [('e', 'edit', None, _('edit commit message')),
2153 [('e', 'edit', None, _('edit commit message')),
2153 ('g', 'git', None, _('use git extended diff format')),
2154 ('g', 'git', None, _('use git extended diff format')),
2154 ('s', 'short', None, 'refresh only files already in the patch'),
2155 ('s', 'short', None, 'refresh only files already in the patch'),
2155 ('I', 'include', [], _('include names matching the given patterns')),
2156 ('I', 'include', [], _('include names matching the given patterns')),
2156 ('X', 'exclude', [], _('exclude names matching the given patterns'))
2157 ('X', 'exclude', [], _('exclude names matching the given patterns'))
2157 ] + commands.commitopts,
2158 ] + commands.commitopts,
2158 'hg qrefresh [-I] [-X] [-e] [-m TEXT] [-l FILE] [-s] FILES...'),
2159 'hg qrefresh [-I] [-X] [-e] [-m TEXT] [-l FILE] [-s] FILES...'),
2159 'qrename|qmv':
2160 'qrename|qmv':
2160 (rename, [], 'hg qrename PATCH1 [PATCH2]'),
2161 (rename, [], 'hg qrename PATCH1 [PATCH2]'),
2161 "qrestore":
2162 "qrestore":
2162 (restore,
2163 (restore,
2163 [('d', 'delete', None, 'delete save entry'),
2164 [('d', 'delete', None, 'delete save entry'),
2164 ('u', 'update', None, 'update queue working dir')],
2165 ('u', 'update', None, 'update queue working dir')],
2165 'hg qrestore [-d] [-u] REV'),
2166 'hg qrestore [-d] [-u] REV'),
2166 "qsave":
2167 "qsave":
2167 (save,
2168 (save,
2168 [('c', 'copy', None, 'copy patch directory'),
2169 [('c', 'copy', None, 'copy patch directory'),
2169 ('n', 'name', '', 'copy directory name'),
2170 ('n', 'name', '', 'copy directory name'),
2170 ('e', 'empty', None, 'clear queue status file'),
2171 ('e', 'empty', None, 'clear queue status file'),
2171 ('f', 'force', None, 'force copy')] + commands.commitopts,
2172 ('f', 'force', None, 'force copy')] + commands.commitopts,
2172 'hg qsave [-m TEXT] [-l FILE] [-c] [-n NAME] [-e] [-f]'),
2173 'hg qsave [-m TEXT] [-l FILE] [-c] [-n NAME] [-e] [-f]'),
2173 "qselect": (select,
2174 "qselect": (select,
2174 [('n', 'none', None, _('disable all guards')),
2175 [('n', 'none', None, _('disable all guards')),
2175 ('s', 'series', None, _('list all guards in series file')),
2176 ('s', 'series', None, _('list all guards in series file')),
2176 ('', 'pop', None,
2177 ('', 'pop', None,
2177 _('pop to before first guarded applied patch')),
2178 _('pop to before first guarded applied patch')),
2178 ('', 'reapply', None, _('pop, then reapply patches'))],
2179 ('', 'reapply', None, _('pop, then reapply patches'))],
2179 'hg qselect [OPTION...] [GUARD...]'),
2180 'hg qselect [OPTION...] [GUARD...]'),
2180 "qseries":
2181 "qseries":
2181 (series,
2182 (series,
2182 [('m', 'missing', None, 'print patches not in series')] + seriesopts,
2183 [('m', 'missing', None, 'print patches not in series')] + seriesopts,
2183 'hg qseries [-ms]'),
2184 'hg qseries [-ms]'),
2184 "^strip":
2185 "^strip":
2185 (strip,
2186 (strip,
2186 [('f', 'force', None, 'force multi-head removal'),
2187 [('f', 'force', None, 'force multi-head removal'),
2187 ('b', 'backup', None, 'bundle unrelated changesets'),
2188 ('b', 'backup', None, 'bundle unrelated changesets'),
2188 ('n', 'nobackup', None, 'no backups')],
2189 ('n', 'nobackup', None, 'no backups')],
2189 'hg strip [-f] [-b] [-n] REV'),
2190 'hg strip [-f] [-b] [-n] REV'),
2190 "qtop": (top, [] + seriesopts, 'hg qtop [-s]'),
2191 "qtop": (top, [] + seriesopts, 'hg qtop [-s]'),
2191 "qunapplied": (unapplied, [] + seriesopts, 'hg qunapplied [-s] [PATCH]'),
2192 "qunapplied": (unapplied, [] + seriesopts, 'hg qunapplied [-s] [PATCH]'),
2192 }
2193 }
@@ -1,145 +1,150 b''
1 #!/bin/sh
1 #!/bin/sh
2
2
3 echo "[extensions]" >> $HGRCPATH
3 echo "[extensions]" >> $HGRCPATH
4 echo "mq=" >> $HGRCPATH
4 echo "mq=" >> $HGRCPATH
5
5
6 hg init
6 hg init
7 hg qinit
7 hg qinit
8
8
9 echo x > x
9 echo x > x
10 hg ci -Ama
10 hg ci -Ama
11
11
12 hg qnew a.patch
12 hg qnew a.patch
13 echo a > a
13 echo a > a
14 hg add a
14 hg add a
15 hg qrefresh
15 hg qrefresh
16
16
17 hg qnew b.patch
17 hg qnew b.patch
18 echo b > b
18 echo b > b
19 hg add b
19 hg add b
20 hg qrefresh
20 hg qrefresh
21
21
22 hg qnew c.patch
22 hg qnew c.patch
23 echo c > c
23 echo c > c
24 hg add c
24 hg add c
25 hg qrefresh
25 hg qrefresh
26
26
27 hg qpop -a
27 hg qpop -a
28
28
29 echo % should fail
29 echo % should fail
30 hg qguard does-not-exist.patch +bleh
30 hg qguard does-not-exist.patch +bleh
31
31
32 echo % should fail
32 echo % should fail
33 hg qguard +fail
33 hg qguard +fail
34
34
35 hg qpush
35 hg qpush
36 echo % should guard a.patch
36 echo % should guard a.patch
37 hg qguard +a
37 hg qguard +a
38 echo % should print +a
38 echo % should print +a
39 hg qguard
39 hg qguard
40 hg qpop
40 hg qpop
41
41
42 hg qguard a.patch
42 hg qguard a.patch
43 echo % should push b.patch
43 echo % should push b.patch
44 hg qpush
44 hg qpush
45
45
46 hg qpop
46 hg qpop
47 hg qselect a
47 hg qselect a
48 echo % should push a.patch
48 echo % should push a.patch
49 hg qpush
49 hg qpush
50
50
51 hg qguard c.patch -a
51 hg qguard c.patch -a
52 echo % should print -a
52 echo % should print -a
53 hg qguard c.patch
53 hg qguard c.patch
54
54
55 echo % should skip c.patch
55 echo % should skip c.patch
56 hg qpush -a
56 hg qpush -a
57
57
58 hg qguard -n c.patch
58 hg qguard -n c.patch
59 echo % should push c.patch
59 echo % should push c.patch
60 hg qpush -a
60 hg qpush -a
61
61
62 hg qpop -a
62 hg qpop -a
63 hg qselect -n
63 hg qselect -n
64 echo % should push all
64 echo % should push all
65 hg qpush -a
65 hg qpush -a
66
66
67 hg qpop -a
67 hg qpop -a
68 hg qguard a.patch +1
68 hg qguard a.patch +1
69 hg qguard b.patch +2
69 hg qguard b.patch +2
70 hg qselect 1
70 hg qselect 1
71 echo % should push a.patch, not b.patch
71 echo % should push a.patch, not b.patch
72 hg qpush
72 hg qpush
73 hg qpush
73 hg qpush
74 hg qpop -a
74 hg qpop -a
75
75
76 hg qselect 2
76 hg qselect 2
77 echo % should push b.patch
77 echo % should push b.patch
78 hg qpush
78 hg qpush
79 hg qpop -a
79 hg qpop -a
80
80
81 hg qselect 1 2
81 hg qselect 1 2
82 echo % should push a.patch, b.patch
82 echo % should push a.patch, b.patch
83 hg qpush
83 hg qpush
84 hg qpush
84 hg qpush
85 hg qpop -a
85 hg qpop -a
86
86
87 hg qguard a.patch +1 +2 -3
87 hg qguard a.patch +1 +2 -3
88 hg qselect 1 2 3
88 hg qselect 1 2 3
89 echo % list patches and guards
89 echo % list patches and guards
90 hg qguard -l
90 hg qguard -l
91 echo % list series
91 echo % list series
92 hg qseries -v
92 hg qseries -v
93 echo % list guards
93 echo % list guards
94 hg qselect
94 hg qselect
95 echo % should push b.patch
95 echo % should push b.patch
96 hg qpush
96 hg qpush
97
97
98 hg qpush -a
98 hg qpush -a
99 hg qselect -n --reapply
99 hg qselect -n --reapply
100 echo % guards in series file: +1 +2 -3
100 echo % guards in series file: +1 +2 -3
101 hg qselect -s
101 hg qselect -s
102 echo % should show c.patch
102 echo % should show c.patch
103 hg qapplied
103 hg qapplied
104
104
105 hg qrename a.patch new.patch
105 hg qrename a.patch new.patch
106 echo % should show :
106 echo % should show :
107 echo % new.patch: +1 +2 -3
107 echo % new.patch: +1 +2 -3
108 echo % b.patch: +2
108 echo % b.patch: +2
109 echo % c.patch: unguarded
109 echo % c.patch: unguarded
110 hg qguard -l
110 hg qguard -l
111
111
112 hg qnew d.patch
112 hg qnew d.patch
113 hg qpop
113 hg qpop
114 echo % should show new.patch and b.patch as Guarded, c.patch as Applied
114 echo % should show new.patch and b.patch as Guarded, c.patch as Applied
115 echo % and d.patch as Unapplied
115 echo % and d.patch as Unapplied
116 hg qseries -v
116 hg qseries -v
117
117
118 hg qguard d.patch +2
118 hg qguard d.patch +2
119 echo % new.patch, b.patch: Guarded. c.patch: Applied. d.patch: Guarded.
119 echo % new.patch, b.patch: Guarded. c.patch: Applied. d.patch: Guarded.
120 hg qseries -v
120 hg qseries -v
121
121
122 qappunappv()
122 qappunappv()
123 (
123 (
124 for command in qapplied "qapplied -v" qunapplied "qunapplied -v"; do
124 for command in qapplied "qapplied -v" qunapplied "qunapplied -v"; do
125 echo % hg $command
125 echo % hg $command
126 hg $command
126 hg $command
127 done
127 done
128 )
128 )
129
129
130 hg qpop -a
130 hg qpop -a
131 hg qguard -l
131 hg qguard -l
132 qappunappv
132 qappunappv
133 hg qselect 1
133 hg qselect 1
134 qappunappv
134 qappunappv
135 hg qpush -a
135 hg qpush -a
136 qappunappv
136 qappunappv
137 hg qselect 2
137 hg qselect 2
138 qappunappv
138 qappunappv
139
139
140 for patch in `hg qseries`; do
140 for patch in `hg qseries`; do
141 echo % hg qapplied $patch
141 echo % hg qapplied $patch
142 hg qapplied $patch
142 hg qapplied $patch
143 echo % hg qunapplied $patch
143 echo % hg qunapplied $patch
144 hg qunapplied $patch
144 hg qunapplied $patch
145 done
145 done
146
147 echo % hg qseries -m: only b.patch should be shown
148 echo the guards file was not ignored in the past
149 hg qdelete -k b.patch
150 hg qseries -m
@@ -1,176 +1,179 b''
1 adding x
1 adding x
2 Patch queue now empty
2 Patch queue now empty
3 % should fail
3 % should fail
4 abort: no patch named does-not-exist.patch
4 abort: no patch named does-not-exist.patch
5 % should fail
5 % should fail
6 abort: no patches applied
6 abort: no patches applied
7 applying a.patch
7 applying a.patch
8 Now at: a.patch
8 Now at: a.patch
9 % should guard a.patch
9 % should guard a.patch
10 % should print +a
10 % should print +a
11 a.patch: +a
11 a.patch: +a
12 Patch queue now empty
12 Patch queue now empty
13 a.patch: +a
13 a.patch: +a
14 % should push b.patch
14 % should push b.patch
15 applying b.patch
15 applying b.patch
16 Now at: b.patch
16 Now at: b.patch
17 Patch queue now empty
17 Patch queue now empty
18 number of unguarded, unapplied patches has changed from 2 to 3
18 number of unguarded, unapplied patches has changed from 2 to 3
19 % should push a.patch
19 % should push a.patch
20 applying a.patch
20 applying a.patch
21 Now at: a.patch
21 Now at: a.patch
22 % should print -a
22 % should print -a
23 c.patch: -a
23 c.patch: -a
24 % should skip c.patch
24 % should skip c.patch
25 applying b.patch
25 applying b.patch
26 skipping c.patch - guarded by '-a'
26 skipping c.patch - guarded by '-a'
27 Now at: b.patch
27 Now at: b.patch
28 % should push c.patch
28 % should push c.patch
29 applying c.patch
29 applying c.patch
30 Now at: c.patch
30 Now at: c.patch
31 Patch queue now empty
31 Patch queue now empty
32 guards deactivated
32 guards deactivated
33 number of unguarded, unapplied patches has changed from 3 to 2
33 number of unguarded, unapplied patches has changed from 3 to 2
34 % should push all
34 % should push all
35 applying b.patch
35 applying b.patch
36 applying c.patch
36 applying c.patch
37 Now at: c.patch
37 Now at: c.patch
38 Patch queue now empty
38 Patch queue now empty
39 number of unguarded, unapplied patches has changed from 1 to 2
39 number of unguarded, unapplied patches has changed from 1 to 2
40 % should push a.patch, not b.patch
40 % should push a.patch, not b.patch
41 applying a.patch
41 applying a.patch
42 Now at: a.patch
42 Now at: a.patch
43 applying c.patch
43 applying c.patch
44 Now at: c.patch
44 Now at: c.patch
45 Patch queue now empty
45 Patch queue now empty
46 % should push b.patch
46 % should push b.patch
47 applying b.patch
47 applying b.patch
48 Now at: b.patch
48 Now at: b.patch
49 Patch queue now empty
49 Patch queue now empty
50 number of unguarded, unapplied patches has changed from 2 to 3
50 number of unguarded, unapplied patches has changed from 2 to 3
51 % should push a.patch, b.patch
51 % should push a.patch, b.patch
52 applying a.patch
52 applying a.patch
53 Now at: a.patch
53 Now at: a.patch
54 applying b.patch
54 applying b.patch
55 Now at: b.patch
55 Now at: b.patch
56 Patch queue now empty
56 Patch queue now empty
57 number of unguarded, unapplied patches has changed from 3 to 2
57 number of unguarded, unapplied patches has changed from 3 to 2
58 % list patches and guards
58 % list patches and guards
59 a.patch: +1 +2 -3
59 a.patch: +1 +2 -3
60 b.patch: +2
60 b.patch: +2
61 c.patch: unguarded
61 c.patch: unguarded
62 % list series
62 % list series
63 0 G a.patch
63 0 G a.patch
64 1 U b.patch
64 1 U b.patch
65 2 U c.patch
65 2 U c.patch
66 % list guards
66 % list guards
67 1
67 1
68 2
68 2
69 3
69 3
70 % should push b.patch
70 % should push b.patch
71 applying b.patch
71 applying b.patch
72 Now at: b.patch
72 Now at: b.patch
73 applying c.patch
73 applying c.patch
74 Now at: c.patch
74 Now at: c.patch
75 guards deactivated
75 guards deactivated
76 popping guarded patches
76 popping guarded patches
77 Patch queue now empty
77 Patch queue now empty
78 reapplying unguarded patches
78 reapplying unguarded patches
79 applying c.patch
79 applying c.patch
80 Now at: c.patch
80 Now at: c.patch
81 % guards in series file: +1 +2 -3
81 % guards in series file: +1 +2 -3
82 +1
82 +1
83 +2
83 +2
84 -3
84 -3
85 % should show c.patch
85 % should show c.patch
86 c.patch
86 c.patch
87 % should show :
87 % should show :
88 % new.patch: +1 +2 -3
88 % new.patch: +1 +2 -3
89 % b.patch: +2
89 % b.patch: +2
90 % c.patch: unguarded
90 % c.patch: unguarded
91 new.patch: +1 +2 -3
91 new.patch: +1 +2 -3
92 b.patch: +2
92 b.patch: +2
93 c.patch: unguarded
93 c.patch: unguarded
94 Now at: c.patch
94 Now at: c.patch
95 % should show new.patch and b.patch as Guarded, c.patch as Applied
95 % should show new.patch and b.patch as Guarded, c.patch as Applied
96 % and d.patch as Unapplied
96 % and d.patch as Unapplied
97 0 G new.patch
97 0 G new.patch
98 1 G b.patch
98 1 G b.patch
99 2 A c.patch
99 2 A c.patch
100 3 U d.patch
100 3 U d.patch
101 % new.patch, b.patch: Guarded. c.patch: Applied. d.patch: Guarded.
101 % new.patch, b.patch: Guarded. c.patch: Applied. d.patch: Guarded.
102 0 G new.patch
102 0 G new.patch
103 1 G b.patch
103 1 G b.patch
104 2 A c.patch
104 2 A c.patch
105 3 G d.patch
105 3 G d.patch
106 Patch queue now empty
106 Patch queue now empty
107 new.patch: +1 +2 -3
107 new.patch: +1 +2 -3
108 b.patch: +2
108 b.patch: +2
109 c.patch: unguarded
109 c.patch: unguarded
110 d.patch: +2
110 d.patch: +2
111 % hg qapplied
111 % hg qapplied
112 % hg qapplied -v
112 % hg qapplied -v
113 % hg qunapplied
113 % hg qunapplied
114 c.patch
114 c.patch
115 % hg qunapplied -v
115 % hg qunapplied -v
116 0 G new.patch
116 0 G new.patch
117 1 G b.patch
117 1 G b.patch
118 2 U c.patch
118 2 U c.patch
119 3 G d.patch
119 3 G d.patch
120 number of unguarded, unapplied patches has changed from 1 to 2
120 number of unguarded, unapplied patches has changed from 1 to 2
121 % hg qapplied
121 % hg qapplied
122 % hg qapplied -v
122 % hg qapplied -v
123 % hg qunapplied
123 % hg qunapplied
124 new.patch
124 new.patch
125 c.patch
125 c.patch
126 % hg qunapplied -v
126 % hg qunapplied -v
127 0 U new.patch
127 0 U new.patch
128 1 G b.patch
128 1 G b.patch
129 2 U c.patch
129 2 U c.patch
130 3 G d.patch
130 3 G d.patch
131 applying new.patch
131 applying new.patch
132 skipping b.patch - guarded by ['+2']
132 skipping b.patch - guarded by ['+2']
133 applying c.patch
133 applying c.patch
134 skipping d.patch - guarded by ['+2']
134 skipping d.patch - guarded by ['+2']
135 Now at: c.patch
135 Now at: c.patch
136 % hg qapplied
136 % hg qapplied
137 new.patch
137 new.patch
138 c.patch
138 c.patch
139 % hg qapplied -v
139 % hg qapplied -v
140 0 A new.patch
140 0 A new.patch
141 1 G b.patch
141 1 G b.patch
142 2 A c.patch
142 2 A c.patch
143 % hg qunapplied
143 % hg qunapplied
144 % hg qunapplied -v
144 % hg qunapplied -v
145 3 G d.patch
145 3 G d.patch
146 number of unguarded, unapplied patches has changed from 0 to 1
146 number of unguarded, unapplied patches has changed from 0 to 1
147 number of guarded, applied patches has changed from 1 to 0
147 number of guarded, applied patches has changed from 1 to 0
148 % hg qapplied
148 % hg qapplied
149 new.patch
149 new.patch
150 c.patch
150 c.patch
151 % hg qapplied -v
151 % hg qapplied -v
152 0 A new.patch
152 0 A new.patch
153 1 U b.patch
153 1 U b.patch
154 2 A c.patch
154 2 A c.patch
155 % hg qunapplied
155 % hg qunapplied
156 d.patch
156 d.patch
157 % hg qunapplied -v
157 % hg qunapplied -v
158 3 U d.patch
158 3 U d.patch
159 % hg qapplied new.patch
159 % hg qapplied new.patch
160 new.patch
160 new.patch
161 % hg qunapplied new.patch
161 % hg qunapplied new.patch
162 b.patch
162 b.patch
163 d.patch
163 d.patch
164 % hg qapplied b.patch
164 % hg qapplied b.patch
165 new.patch
165 new.patch
166 % hg qunapplied b.patch
166 % hg qunapplied b.patch
167 d.patch
167 d.patch
168 % hg qapplied c.patch
168 % hg qapplied c.patch
169 new.patch
169 new.patch
170 c.patch
170 c.patch
171 % hg qunapplied c.patch
171 % hg qunapplied c.patch
172 d.patch
172 d.patch
173 % hg qapplied d.patch
173 % hg qapplied d.patch
174 new.patch
174 new.patch
175 c.patch
175 c.patch
176 % hg qunapplied d.patch
176 % hg qunapplied d.patch
177 % hg qseries -m: only b.patch should be shown
178 the guards file was not ignored in the past
179 b.patch
General Comments 0
You need to be logged in to leave comments. Login now