##// END OF EJS Templates
addremove: add -s/--similarity option...
Vadim Gelfer -
r2958:ff3ea21a default
parent child Browse files
Show More
@@ -1,111 +1,145 b''
1 1 # cmdutil.py - help for command processing in mercurial
2 2 #
3 3 # Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>
4 4 #
5 5 # This software may be used and distributed according to the terms
6 6 # of the GNU General Public License, incorporated herein by reference.
7 7
8 8 from demandload import demandload
9 9 from node import *
10 10 from i18n import gettext as _
11 demandload(globals(), 'util')
11 demandload(globals(), 'mdiff util')
12 12 demandload(globals(), 'os sys')
13 13
14 14 def make_filename(repo, pat, node,
15 15 total=None, seqno=None, revwidth=None, pathname=None):
16 16 node_expander = {
17 17 'H': lambda: hex(node),
18 18 'R': lambda: str(repo.changelog.rev(node)),
19 19 'h': lambda: short(node),
20 20 }
21 21 expander = {
22 22 '%': lambda: '%',
23 23 'b': lambda: os.path.basename(repo.root),
24 24 }
25 25
26 26 try:
27 27 if node:
28 28 expander.update(node_expander)
29 29 if node and revwidth is not None:
30 30 expander['r'] = (lambda:
31 31 str(repo.changelog.rev(node)).zfill(revwidth))
32 32 if total is not None:
33 33 expander['N'] = lambda: str(total)
34 34 if seqno is not None:
35 35 expander['n'] = lambda: str(seqno)
36 36 if total is not None and seqno is not None:
37 37 expander['n'] = lambda:str(seqno).zfill(len(str(total)))
38 38 if pathname is not None:
39 39 expander['s'] = lambda: os.path.basename(pathname)
40 40 expander['d'] = lambda: os.path.dirname(pathname) or '.'
41 41 expander['p'] = lambda: pathname
42 42
43 43 newname = []
44 44 patlen = len(pat)
45 45 i = 0
46 46 while i < patlen:
47 47 c = pat[i]
48 48 if c == '%':
49 49 i += 1
50 50 c = pat[i]
51 51 c = expander[c]()
52 52 newname.append(c)
53 53 i += 1
54 54 return ''.join(newname)
55 55 except KeyError, inst:
56 56 raise util.Abort(_("invalid format spec '%%%s' in output file name"),
57 57 inst.args[0])
58 58
59 59 def make_file(repo, pat, node=None,
60 60 total=None, seqno=None, revwidth=None, mode='wb', pathname=None):
61 61 if not pat or pat == '-':
62 62 return 'w' in mode and sys.stdout or sys.stdin
63 63 if hasattr(pat, 'write') and 'w' in mode:
64 64 return pat
65 65 if hasattr(pat, 'read') and 'r' in mode:
66 66 return pat
67 67 return open(make_filename(repo, pat, node, total, seqno, revwidth,
68 68 pathname),
69 69 mode)
70 70
71 71 def matchpats(repo, pats=[], opts={}, head=''):
72 72 cwd = repo.getcwd()
73 73 if not pats and cwd:
74 74 opts['include'] = [os.path.join(cwd, i)
75 75 for i in opts.get('include', [])]
76 76 opts['exclude'] = [os.path.join(cwd, x)
77 77 for x in opts.get('exclude', [])]
78 78 cwd = ''
79 79 return util.cmdmatcher(repo.root, cwd, pats or ['.'], opts.get('include'),
80 80 opts.get('exclude'), head)
81 81
82 82 def makewalk(repo, pats=[], opts={}, node=None, head='', badmatch=None):
83 83 files, matchfn, anypats = matchpats(repo, pats, opts, head)
84 84 exact = dict(zip(files, files))
85 85 def walk():
86 86 for src, fn in repo.walk(node=node, files=files, match=matchfn,
87 87 badmatch=badmatch):
88 88 yield src, fn, util.pathto(repo.getcwd(), fn), fn in exact
89 89 return files, matchfn, walk()
90 90
91 91 def walk(repo, pats=[], opts={}, node=None, head='', badmatch=None):
92 92 files, matchfn, results = makewalk(repo, pats, opts, node, head, badmatch)
93 93 for r in results:
94 94 yield r
95 95
96 def addremove(repo, pats=[], opts={}, wlock=None, dry_run=None):
96 def findrenames(repo, added=None, removed=None, threshold=0.5):
97 if added is None or removed is None:
98 added, removed = repo.status()[1:3]
99 changes = repo.changelog.read(repo.dirstate.parents()[0])
100 mf = repo.manifest.read(changes[0])
101 for a in added:
102 aa = repo.wread(a)
103 bestscore, bestname = None, None
104 for r in removed:
105 rr = repo.file(r).read(mf[r])
106 delta = mdiff.textdiff(aa, rr)
107 if len(delta) < len(aa):
108 myscore = 1.0 - (float(len(delta)) / len(aa))
109 if bestscore is None or myscore > bestscore:
110 bestscore, bestname = myscore, r
111 if bestname and bestscore >= threshold:
112 yield bestname, a, bestscore
113
114 def addremove(repo, pats=[], opts={}, wlock=None, dry_run=None,
115 similarity=None):
97 116 if dry_run is None:
98 117 dry_run = opts.get('dry_run')
118 if similarity is None:
119 similarity = float(opts.get('similarity') or 0)
99 120 add, remove = [], []
121 mapping = {}
100 122 for src, abs, rel, exact in walk(repo, pats, opts):
101 123 if src == 'f' and repo.dirstate.state(abs) == '?':
102 124 add.append(abs)
125 mapping[abs] = rel, exact
103 126 if repo.ui.verbose or not exact:
104 127 repo.ui.status(_('adding %s\n') % ((pats and rel) or abs))
105 128 if repo.dirstate.state(abs) != 'r' and not os.path.exists(rel):
106 129 remove.append(abs)
130 mapping[abs] = rel, exact
107 131 if repo.ui.verbose or not exact:
108 132 repo.ui.status(_('removing %s\n') % ((pats and rel) or abs))
109 133 if not dry_run:
110 134 repo.add(add, wlock=wlock)
111 135 repo.remove(remove, wlock=wlock)
136 if similarity > 0:
137 for old, new, score in findrenames(repo, add, remove, similarity):
138 oldrel, oldexact = mapping[old]
139 newrel, newexact = mapping[new]
140 if repo.ui.verbose or not oldexact or not newexact:
141 repo.ui.status(_('recording removal of %s as rename to %s '
142 '(%d%% similar)\n') %
143 (oldrel, newrel, score * 100))
144 if not dry_run:
145 repo.copy(old, new, wlock=wlock)
@@ -1,3483 +1,3495 b''
1 1 # commands.py - command processing for mercurial
2 2 #
3 3 # Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>
4 4 #
5 5 # This software may be used and distributed according to the terms
6 6 # of the GNU General Public License, incorporated herein by reference.
7 7
8 8 from demandload import demandload
9 9 from node import *
10 10 from i18n import gettext as _
11 11 demandload(globals(), "os re sys signal shutil imp urllib pdb")
12 12 demandload(globals(), "fancyopts ui hg util lock revlog templater bundlerepo")
13 13 demandload(globals(), "fnmatch difflib patch random signal tempfile time")
14 14 demandload(globals(), "traceback errno socket version struct atexit sets bz2")
15 15 demandload(globals(), "archival cStringIO changegroup")
16 16 demandload(globals(), "cmdutil hgweb.server sshserver")
17 17
18 18 class UnknownCommand(Exception):
19 19 """Exception raised if command is not in the command table."""
20 20 class AmbiguousCommand(Exception):
21 21 """Exception raised if command shortcut matches more than one command."""
22 22
23 23 def bail_if_changed(repo):
24 24 modified, added, removed, deleted = repo.status()[:4]
25 25 if modified or added or removed or deleted:
26 26 raise util.Abort(_("outstanding uncommitted changes"))
27 27
28 28 def relpath(repo, args):
29 29 cwd = repo.getcwd()
30 30 if cwd:
31 31 return [util.normpath(os.path.join(cwd, x)) for x in args]
32 32 return args
33 33
34 34 def logmessage(opts):
35 35 """ get the log message according to -m and -l option """
36 36 message = opts['message']
37 37 logfile = opts['logfile']
38 38
39 39 if message and logfile:
40 40 raise util.Abort(_('options --message and --logfile are mutually '
41 41 'exclusive'))
42 42 if not message and logfile:
43 43 try:
44 44 if logfile == '-':
45 45 message = sys.stdin.read()
46 46 else:
47 47 message = open(logfile).read()
48 48 except IOError, inst:
49 49 raise util.Abort(_("can't read commit message '%s': %s") %
50 50 (logfile, inst.strerror))
51 51 return message
52 52
53 53 def walkchangerevs(ui, repo, pats, opts):
54 54 '''Iterate over files and the revs they changed in.
55 55
56 56 Callers most commonly need to iterate backwards over the history
57 57 it is interested in. Doing so has awful (quadratic-looking)
58 58 performance, so we use iterators in a "windowed" way.
59 59
60 60 We walk a window of revisions in the desired order. Within the
61 61 window, we first walk forwards to gather data, then in the desired
62 62 order (usually backwards) to display it.
63 63
64 64 This function returns an (iterator, getchange, matchfn) tuple. The
65 65 getchange function returns the changelog entry for a numeric
66 66 revision. The iterator yields 3-tuples. They will be of one of
67 67 the following forms:
68 68
69 69 "window", incrementing, lastrev: stepping through a window,
70 70 positive if walking forwards through revs, last rev in the
71 71 sequence iterated over - use to reset state for the current window
72 72
73 73 "add", rev, fns: out-of-order traversal of the given file names
74 74 fns, which changed during revision rev - use to gather data for
75 75 possible display
76 76
77 77 "iter", rev, None: in-order traversal of the revs earlier iterated
78 78 over with "add" - use to display data'''
79 79
80 80 def increasing_windows(start, end, windowsize=8, sizelimit=512):
81 81 if start < end:
82 82 while start < end:
83 83 yield start, min(windowsize, end-start)
84 84 start += windowsize
85 85 if windowsize < sizelimit:
86 86 windowsize *= 2
87 87 else:
88 88 while start > end:
89 89 yield start, min(windowsize, start-end-1)
90 90 start -= windowsize
91 91 if windowsize < sizelimit:
92 92 windowsize *= 2
93 93
94 94
95 95 files, matchfn, anypats = cmdutil.matchpats(repo, pats, opts)
96 96 follow = opts.get('follow') or opts.get('follow_first')
97 97
98 98 if repo.changelog.count() == 0:
99 99 return [], False, matchfn
100 100
101 101 if follow:
102 102 p = repo.dirstate.parents()[0]
103 103 if p == nullid:
104 104 ui.warn(_('No working directory revision; defaulting to tip\n'))
105 105 start = 'tip'
106 106 else:
107 107 start = repo.changelog.rev(p)
108 108 defrange = '%s:0' % start
109 109 else:
110 110 defrange = 'tip:0'
111 111 revs = map(int, revrange(ui, repo, opts['rev'] or [defrange]))
112 112 wanted = {}
113 113 slowpath = anypats
114 114 fncache = {}
115 115
116 116 chcache = {}
117 117 def getchange(rev):
118 118 ch = chcache.get(rev)
119 119 if ch is None:
120 120 chcache[rev] = ch = repo.changelog.read(repo.lookup(str(rev)))
121 121 return ch
122 122
123 123 if not slowpath and not files:
124 124 # No files, no patterns. Display all revs.
125 125 wanted = dict(zip(revs, revs))
126 126 copies = []
127 127 if not slowpath:
128 128 # Only files, no patterns. Check the history of each file.
129 129 def filerevgen(filelog, node):
130 130 cl_count = repo.changelog.count()
131 131 if node is None:
132 132 last = filelog.count() - 1
133 133 else:
134 134 last = filelog.rev(node)
135 135 for i, window in increasing_windows(last, -1):
136 136 revs = []
137 137 for j in xrange(i - window, i + 1):
138 138 n = filelog.node(j)
139 139 revs.append((filelog.linkrev(n),
140 140 follow and filelog.renamed(n)))
141 141 revs.reverse()
142 142 for rev in revs:
143 143 # only yield rev for which we have the changelog, it can
144 144 # happen while doing "hg log" during a pull or commit
145 145 if rev[0] < cl_count:
146 146 yield rev
147 147 def iterfiles():
148 148 for filename in files:
149 149 yield filename, None
150 150 for filename_node in copies:
151 151 yield filename_node
152 152 minrev, maxrev = min(revs), max(revs)
153 153 for file_, node in iterfiles():
154 154 filelog = repo.file(file_)
155 155 # A zero count may be a directory or deleted file, so
156 156 # try to find matching entries on the slow path.
157 157 if filelog.count() == 0:
158 158 slowpath = True
159 159 break
160 160 for rev, copied in filerevgen(filelog, node):
161 161 if rev <= maxrev:
162 162 if rev < minrev:
163 163 break
164 164 fncache.setdefault(rev, [])
165 165 fncache[rev].append(file_)
166 166 wanted[rev] = 1
167 167 if follow and copied:
168 168 copies.append(copied)
169 169 if slowpath:
170 170 if follow:
171 171 raise util.Abort(_('can only follow copies/renames for explicit '
172 172 'file names'))
173 173
174 174 # The slow path checks files modified in every changeset.
175 175 def changerevgen():
176 176 for i, window in increasing_windows(repo.changelog.count()-1, -1):
177 177 for j in xrange(i - window, i + 1):
178 178 yield j, getchange(j)[3]
179 179
180 180 for rev, changefiles in changerevgen():
181 181 matches = filter(matchfn, changefiles)
182 182 if matches:
183 183 fncache[rev] = matches
184 184 wanted[rev] = 1
185 185
186 186 class followfilter:
187 187 def __init__(self, onlyfirst=False):
188 188 self.startrev = -1
189 189 self.roots = []
190 190 self.onlyfirst = onlyfirst
191 191
192 192 def match(self, rev):
193 193 def realparents(rev):
194 194 if self.onlyfirst:
195 195 return repo.changelog.parentrevs(rev)[0:1]
196 196 else:
197 197 return filter(lambda x: x != -1, repo.changelog.parentrevs(rev))
198 198
199 199 if self.startrev == -1:
200 200 self.startrev = rev
201 201 return True
202 202
203 203 if rev > self.startrev:
204 204 # forward: all descendants
205 205 if not self.roots:
206 206 self.roots.append(self.startrev)
207 207 for parent in realparents(rev):
208 208 if parent in self.roots:
209 209 self.roots.append(rev)
210 210 return True
211 211 else:
212 212 # backwards: all parents
213 213 if not self.roots:
214 214 self.roots.extend(realparents(self.startrev))
215 215 if rev in self.roots:
216 216 self.roots.remove(rev)
217 217 self.roots.extend(realparents(rev))
218 218 return True
219 219
220 220 return False
221 221
222 222 # it might be worthwhile to do this in the iterator if the rev range
223 223 # is descending and the prune args are all within that range
224 224 for rev in opts.get('prune', ()):
225 225 rev = repo.changelog.rev(repo.lookup(rev))
226 226 ff = followfilter()
227 227 stop = min(revs[0], revs[-1])
228 228 for x in range(rev, stop-1, -1):
229 229 if ff.match(x) and wanted.has_key(x):
230 230 del wanted[x]
231 231
232 232 def iterate():
233 233 if follow and not files:
234 234 ff = followfilter(onlyfirst=opts.get('follow_first'))
235 235 def want(rev):
236 236 if ff.match(rev) and rev in wanted:
237 237 return True
238 238 return False
239 239 else:
240 240 def want(rev):
241 241 return rev in wanted
242 242
243 243 for i, window in increasing_windows(0, len(revs)):
244 244 yield 'window', revs[0] < revs[-1], revs[-1]
245 245 nrevs = [rev for rev in revs[i:i+window] if want(rev)]
246 246 srevs = list(nrevs)
247 247 srevs.sort()
248 248 for rev in srevs:
249 249 fns = fncache.get(rev) or filter(matchfn, getchange(rev)[3])
250 250 yield 'add', rev, fns
251 251 for rev in nrevs:
252 252 yield 'iter', rev, None
253 253 return iterate(), getchange, matchfn
254 254
255 255 revrangesep = ':'
256 256
257 257 def revfix(repo, val, defval):
258 258 '''turn user-level id of changeset into rev number.
259 259 user-level id can be tag, changeset, rev number, or negative rev
260 260 number relative to number of revs (-1 is tip, etc).'''
261 261 if not val:
262 262 return defval
263 263 try:
264 264 num = int(val)
265 265 if str(num) != val:
266 266 raise ValueError
267 267 if num < 0:
268 268 num += repo.changelog.count()
269 269 if num < 0:
270 270 num = 0
271 271 elif num >= repo.changelog.count():
272 272 raise ValueError
273 273 except ValueError:
274 274 try:
275 275 num = repo.changelog.rev(repo.lookup(val))
276 276 except KeyError:
277 277 raise util.Abort(_('invalid revision identifier %s'), val)
278 278 return num
279 279
280 280 def revpair(ui, repo, revs):
281 281 '''return pair of nodes, given list of revisions. second item can
282 282 be None, meaning use working dir.'''
283 283 if not revs:
284 284 return repo.dirstate.parents()[0], None
285 285 end = None
286 286 if len(revs) == 1:
287 287 start = revs[0]
288 288 if revrangesep in start:
289 289 start, end = start.split(revrangesep, 1)
290 290 start = revfix(repo, start, 0)
291 291 end = revfix(repo, end, repo.changelog.count() - 1)
292 292 else:
293 293 start = revfix(repo, start, None)
294 294 elif len(revs) == 2:
295 295 if revrangesep in revs[0] or revrangesep in revs[1]:
296 296 raise util.Abort(_('too many revisions specified'))
297 297 start = revfix(repo, revs[0], None)
298 298 end = revfix(repo, revs[1], None)
299 299 else:
300 300 raise util.Abort(_('too many revisions specified'))
301 301 if end is not None: end = repo.lookup(str(end))
302 302 return repo.lookup(str(start)), end
303 303
304 304 def revrange(ui, repo, revs):
305 305 """Yield revision as strings from a list of revision specifications."""
306 306 seen = {}
307 307 for spec in revs:
308 308 if revrangesep in spec:
309 309 start, end = spec.split(revrangesep, 1)
310 310 start = revfix(repo, start, 0)
311 311 end = revfix(repo, end, repo.changelog.count() - 1)
312 312 step = start > end and -1 or 1
313 313 for rev in xrange(start, end+step, step):
314 314 if rev in seen:
315 315 continue
316 316 seen[rev] = 1
317 317 yield str(rev)
318 318 else:
319 319 rev = revfix(repo, spec, None)
320 320 if rev in seen:
321 321 continue
322 322 seen[rev] = 1
323 323 yield str(rev)
324 324
325 325 def write_bundle(cg, filename=None, compress=True):
326 326 """Write a bundle file and return its filename.
327 327
328 328 Existing files will not be overwritten.
329 329 If no filename is specified, a temporary file is created.
330 330 bz2 compression can be turned off.
331 331 The bundle file will be deleted in case of errors.
332 332 """
333 333 class nocompress(object):
334 334 def compress(self, x):
335 335 return x
336 336 def flush(self):
337 337 return ""
338 338
339 339 fh = None
340 340 cleanup = None
341 341 try:
342 342 if filename:
343 343 if os.path.exists(filename):
344 344 raise util.Abort(_("file '%s' already exists"), filename)
345 345 fh = open(filename, "wb")
346 346 else:
347 347 fd, filename = tempfile.mkstemp(prefix="hg-bundle-", suffix=".hg")
348 348 fh = os.fdopen(fd, "wb")
349 349 cleanup = filename
350 350
351 351 if compress:
352 352 fh.write("HG10")
353 353 z = bz2.BZ2Compressor(9)
354 354 else:
355 355 fh.write("HG10UN")
356 356 z = nocompress()
357 357 # parse the changegroup data, otherwise we will block
358 358 # in case of sshrepo because we don't know the end of the stream
359 359
360 360 # an empty chunkiter is the end of the changegroup
361 361 empty = False
362 362 while not empty:
363 363 empty = True
364 364 for chunk in changegroup.chunkiter(cg):
365 365 empty = False
366 366 fh.write(z.compress(changegroup.genchunk(chunk)))
367 367 fh.write(z.compress(changegroup.closechunk()))
368 368 fh.write(z.flush())
369 369 cleanup = None
370 370 return filename
371 371 finally:
372 372 if fh is not None:
373 373 fh.close()
374 374 if cleanup is not None:
375 375 os.unlink(cleanup)
376 376
377 377 def trimuser(ui, name, rev, revcache):
378 378 """trim the name of the user who committed a change"""
379 379 user = revcache.get(rev)
380 380 if user is None:
381 381 user = revcache[rev] = ui.shortuser(name)
382 382 return user
383 383
384 384 class changeset_printer(object):
385 385 '''show changeset information when templating not requested.'''
386 386
387 387 def __init__(self, ui, repo):
388 388 self.ui = ui
389 389 self.repo = repo
390 390
391 391 def show(self, rev=0, changenode=None, brinfo=None):
392 392 '''show a single changeset or file revision'''
393 393 log = self.repo.changelog
394 394 if changenode is None:
395 395 changenode = log.node(rev)
396 396 elif not rev:
397 397 rev = log.rev(changenode)
398 398
399 399 if self.ui.quiet:
400 400 self.ui.write("%d:%s\n" % (rev, short(changenode)))
401 401 return
402 402
403 403 changes = log.read(changenode)
404 404 date = util.datestr(changes[2])
405 405
406 406 parents = [(log.rev(p), self.ui.verbose and hex(p) or short(p))
407 407 for p in log.parents(changenode)
408 408 if self.ui.debugflag or p != nullid]
409 409 if (not self.ui.debugflag and len(parents) == 1 and
410 410 parents[0][0] == rev-1):
411 411 parents = []
412 412
413 413 if self.ui.verbose:
414 414 self.ui.write(_("changeset: %d:%s\n") % (rev, hex(changenode)))
415 415 else:
416 416 self.ui.write(_("changeset: %d:%s\n") % (rev, short(changenode)))
417 417
418 418 for tag in self.repo.nodetags(changenode):
419 419 self.ui.status(_("tag: %s\n") % tag)
420 420 for parent in parents:
421 421 self.ui.write(_("parent: %d:%s\n") % parent)
422 422
423 423 if brinfo and changenode in brinfo:
424 424 br = brinfo[changenode]
425 425 self.ui.write(_("branch: %s\n") % " ".join(br))
426 426
427 427 self.ui.debug(_("manifest: %d:%s\n") %
428 428 (self.repo.manifest.rev(changes[0]), hex(changes[0])))
429 429 self.ui.status(_("user: %s\n") % changes[1])
430 430 self.ui.status(_("date: %s\n") % date)
431 431
432 432 if self.ui.debugflag:
433 433 files = self.repo.status(log.parents(changenode)[0], changenode)[:3]
434 434 for key, value in zip([_("files:"), _("files+:"), _("files-:")],
435 435 files):
436 436 if value:
437 437 self.ui.note("%-12s %s\n" % (key, " ".join(value)))
438 438 else:
439 439 self.ui.note(_("files: %s\n") % " ".join(changes[3]))
440 440
441 441 description = changes[4].strip()
442 442 if description:
443 443 if self.ui.verbose:
444 444 self.ui.status(_("description:\n"))
445 445 self.ui.status(description)
446 446 self.ui.status("\n\n")
447 447 else:
448 448 self.ui.status(_("summary: %s\n") %
449 449 description.splitlines()[0])
450 450 self.ui.status("\n")
451 451
452 452 def show_changeset(ui, repo, opts):
453 453 '''show one changeset. uses template or regular display. caller
454 454 can pass in 'style' and 'template' options in opts.'''
455 455
456 456 tmpl = opts.get('template')
457 457 if tmpl:
458 458 tmpl = templater.parsestring(tmpl, quoted=False)
459 459 else:
460 460 tmpl = ui.config('ui', 'logtemplate')
461 461 if tmpl: tmpl = templater.parsestring(tmpl)
462 462 mapfile = opts.get('style') or ui.config('ui', 'style')
463 463 if tmpl or mapfile:
464 464 if mapfile:
465 465 if not os.path.isfile(mapfile):
466 466 mapname = templater.templatepath('map-cmdline.' + mapfile)
467 467 if not mapname: mapname = templater.templatepath(mapfile)
468 468 if mapname: mapfile = mapname
469 469 try:
470 470 t = templater.changeset_templater(ui, repo, mapfile)
471 471 except SyntaxError, inst:
472 472 raise util.Abort(inst.args[0])
473 473 if tmpl: t.use_template(tmpl)
474 474 return t
475 475 return changeset_printer(ui, repo)
476 476
477 477 def setremoteconfig(ui, opts):
478 478 "copy remote options to ui tree"
479 479 if opts.get('ssh'):
480 480 ui.setconfig("ui", "ssh", opts['ssh'])
481 481 if opts.get('remotecmd'):
482 482 ui.setconfig("ui", "remotecmd", opts['remotecmd'])
483 483
484 484 def show_version(ui):
485 485 """output version and copyright information"""
486 486 ui.write(_("Mercurial Distributed SCM (version %s)\n")
487 487 % version.get_version())
488 488 ui.status(_(
489 489 "\nCopyright (C) 2005, 2006 Matt Mackall <mpm@selenic.com>\n"
490 490 "This is free software; see the source for copying conditions. "
491 491 "There is NO\nwarranty; "
492 492 "not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.\n"
493 493 ))
494 494
495 495 def help_(ui, name=None, with_version=False):
496 496 """show help for a command, extension, or list of commands
497 497
498 498 With no arguments, print a list of commands and short help.
499 499
500 500 Given a command name, print help for that command.
501 501
502 502 Given an extension name, print help for that extension, and the
503 503 commands it provides."""
504 504 option_lists = []
505 505
506 506 def helpcmd(name):
507 507 if with_version:
508 508 show_version(ui)
509 509 ui.write('\n')
510 510 aliases, i = findcmd(name)
511 511 # synopsis
512 512 ui.write("%s\n\n" % i[2])
513 513
514 514 # description
515 515 doc = i[0].__doc__
516 516 if not doc:
517 517 doc = _("(No help text available)")
518 518 if ui.quiet:
519 519 doc = doc.splitlines(0)[0]
520 520 ui.write("%s\n" % doc.rstrip())
521 521
522 522 if not ui.quiet:
523 523 # aliases
524 524 if len(aliases) > 1:
525 525 ui.write(_("\naliases: %s\n") % ', '.join(aliases[1:]))
526 526
527 527 # options
528 528 if i[1]:
529 529 option_lists.append(("options", i[1]))
530 530
531 531 def helplist(select=None):
532 532 h = {}
533 533 cmds = {}
534 534 for c, e in table.items():
535 535 f = c.split("|", 1)[0]
536 536 if select and not select(f):
537 537 continue
538 538 if name == "shortlist" and not f.startswith("^"):
539 539 continue
540 540 f = f.lstrip("^")
541 541 if not ui.debugflag and f.startswith("debug"):
542 542 continue
543 543 doc = e[0].__doc__
544 544 if not doc:
545 545 doc = _("(No help text available)")
546 546 h[f] = doc.splitlines(0)[0].rstrip()
547 547 cmds[f] = c.lstrip("^")
548 548
549 549 fns = h.keys()
550 550 fns.sort()
551 551 m = max(map(len, fns))
552 552 for f in fns:
553 553 if ui.verbose:
554 554 commands = cmds[f].replace("|",", ")
555 555 ui.write(" %s:\n %s\n"%(commands, h[f]))
556 556 else:
557 557 ui.write(' %-*s %s\n' % (m, f, h[f]))
558 558
559 559 def helpext(name):
560 560 try:
561 561 mod = findext(name)
562 562 except KeyError:
563 563 raise UnknownCommand(name)
564 564
565 565 doc = (mod.__doc__ or _('No help text available')).splitlines(0)
566 566 ui.write(_('%s extension - %s\n') % (name.split('.')[-1], doc[0]))
567 567 for d in doc[1:]:
568 568 ui.write(d, '\n')
569 569
570 570 ui.status('\n')
571 571 if ui.verbose:
572 572 ui.status(_('list of commands:\n\n'))
573 573 else:
574 574 ui.status(_('list of commands (use "hg help -v %s" '
575 575 'to show aliases and global options):\n\n') % name)
576 576
577 577 modcmds = dict.fromkeys([c.split('|', 1)[0] for c in mod.cmdtable])
578 578 helplist(modcmds.has_key)
579 579
580 580 if name and name != 'shortlist':
581 581 try:
582 582 helpcmd(name)
583 583 except UnknownCommand:
584 584 helpext(name)
585 585
586 586 else:
587 587 # program name
588 588 if ui.verbose or with_version:
589 589 show_version(ui)
590 590 else:
591 591 ui.status(_("Mercurial Distributed SCM\n"))
592 592 ui.status('\n')
593 593
594 594 # list of commands
595 595 if name == "shortlist":
596 596 ui.status(_('basic commands (use "hg help" '
597 597 'for the full list or option "-v" for details):\n\n'))
598 598 elif ui.verbose:
599 599 ui.status(_('list of commands:\n\n'))
600 600 else:
601 601 ui.status(_('list of commands (use "hg help -v" '
602 602 'to show aliases and global options):\n\n'))
603 603
604 604 helplist()
605 605
606 606 # global options
607 607 if ui.verbose:
608 608 option_lists.append(("global options", globalopts))
609 609
610 610 # list all option lists
611 611 opt_output = []
612 612 for title, options in option_lists:
613 613 opt_output.append(("\n%s:\n" % title, None))
614 614 for shortopt, longopt, default, desc in options:
615 615 opt_output.append(("%2s%s" % (shortopt and "-%s" % shortopt,
616 616 longopt and " --%s" % longopt),
617 617 "%s%s" % (desc,
618 618 default
619 619 and _(" (default: %s)") % default
620 620 or "")))
621 621
622 622 if opt_output:
623 623 opts_len = max([len(line[0]) for line in opt_output if line[1]])
624 624 for first, second in opt_output:
625 625 if second:
626 626 ui.write(" %-*s %s\n" % (opts_len, first, second))
627 627 else:
628 628 ui.write("%s\n" % first)
629 629
630 630 # Commands start here, listed alphabetically
631 631
632 632 def add(ui, repo, *pats, **opts):
633 633 """add the specified files on the next commit
634 634
635 635 Schedule files to be version controlled and added to the repository.
636 636
637 637 The files will be added to the repository at the next commit.
638 638
639 639 If no names are given, add all files in the repository.
640 640 """
641 641
642 642 names = []
643 643 for src, abs, rel, exact in cmdutil.walk(repo, pats, opts):
644 644 if exact:
645 645 if ui.verbose:
646 646 ui.status(_('adding %s\n') % rel)
647 647 names.append(abs)
648 648 elif repo.dirstate.state(abs) == '?':
649 649 ui.status(_('adding %s\n') % rel)
650 650 names.append(abs)
651 651 if not opts.get('dry_run'):
652 652 repo.add(names)
653 653
654 654 def addremove(ui, repo, *pats, **opts):
655 655 """add all new files, delete all missing files (DEPRECATED)
656 656
657 657 Add all new files and remove all missing files from the repository.
658 658
659 659 New files are ignored if they match any of the patterns in .hgignore. As
660 660 with add, these changes take effect at the next commit.
661
662 Use the -s option to detect renamed files. With a parameter > 0,
663 this compares every removed file with every added file and records
664 those similar enough as renames. This option takes a percentage
665 between 0 (disabled) and 100 (files must be identical) as its
666 parameter. Detecting renamed files this way can be expensive.
661 667 """
662 return cmdutil.addremove(repo, pats, opts)
668 sim = float(opts.get('similarity') or 0)
669 if sim < 0 or sim > 100:
670 raise util.Abort(_('similarity must be between 0 and 100'))
671 return cmdutil.addremove(repo, pats, opts, similarity=sim/100.)
663 672
664 673 def annotate(ui, repo, *pats, **opts):
665 674 """show changeset information per file line
666 675
667 676 List changes in files, showing the revision id responsible for each line
668 677
669 678 This command is useful to discover who did a change or when a change took
670 679 place.
671 680
672 681 Without the -a option, annotate will avoid processing files it
673 682 detects as binary. With -a, annotate will generate an annotation
674 683 anyway, probably with undesirable results.
675 684 """
676 685 def getnode(rev):
677 686 return short(repo.changelog.node(rev))
678 687
679 688 ucache = {}
680 689 def getname(rev):
681 690 try:
682 691 return ucache[rev]
683 692 except:
684 693 u = trimuser(ui, repo.changectx(rev).user(), rev, ucache)
685 694 ucache[rev] = u
686 695 return u
687 696
688 697 dcache = {}
689 698 def getdate(rev):
690 699 datestr = dcache.get(rev)
691 700 if datestr is None:
692 701 datestr = dcache[rev] = util.datestr(repo.changectx(rev).date())
693 702 return datestr
694 703
695 704 if not pats:
696 705 raise util.Abort(_('at least one file name or pattern required'))
697 706
698 707 opmap = [['user', getname], ['number', str], ['changeset', getnode],
699 708 ['date', getdate]]
700 709 if not opts['user'] and not opts['changeset'] and not opts['date']:
701 710 opts['number'] = 1
702 711
703 712 ctx = repo.changectx(opts['rev'] or repo.dirstate.parents()[0])
704 713
705 714 for src, abs, rel, exact in cmdutil.walk(repo, pats, opts,
706 715 node=ctx.node()):
707 716 fctx = ctx.filectx(abs)
708 717 if not opts['text'] and util.binary(fctx.data()):
709 718 ui.write(_("%s: binary file\n") % ((pats and rel) or abs))
710 719 continue
711 720
712 721 lines = fctx.annotate()
713 722 pieces = []
714 723
715 724 for o, f in opmap:
716 725 if opts[o]:
717 726 l = [f(n) for n, dummy in lines]
718 727 if l:
719 728 m = max(map(len, l))
720 729 pieces.append(["%*s" % (m, x) for x in l])
721 730
722 731 if pieces:
723 732 for p, l in zip(zip(*pieces), lines):
724 733 ui.write("%s: %s" % (" ".join(p), l[1]))
725 734
726 735 def archive(ui, repo, dest, **opts):
727 736 '''create unversioned archive of a repository revision
728 737
729 738 By default, the revision used is the parent of the working
730 739 directory; use "-r" to specify a different revision.
731 740
732 741 To specify the type of archive to create, use "-t". Valid
733 742 types are:
734 743
735 744 "files" (default): a directory full of files
736 745 "tar": tar archive, uncompressed
737 746 "tbz2": tar archive, compressed using bzip2
738 747 "tgz": tar archive, compressed using gzip
739 748 "uzip": zip archive, uncompressed
740 749 "zip": zip archive, compressed using deflate
741 750
742 751 The exact name of the destination archive or directory is given
743 752 using a format string; see "hg help export" for details.
744 753
745 754 Each member added to an archive file has a directory prefix
746 755 prepended. Use "-p" to specify a format string for the prefix.
747 756 The default is the basename of the archive, with suffixes removed.
748 757 '''
749 758
750 759 if opts['rev']:
751 760 node = repo.lookup(opts['rev'])
752 761 else:
753 762 node, p2 = repo.dirstate.parents()
754 763 if p2 != nullid:
755 764 raise util.Abort(_('uncommitted merge - please provide a '
756 765 'specific revision'))
757 766
758 767 dest = cmdutil.make_filename(repo, dest, node)
759 768 if os.path.realpath(dest) == repo.root:
760 769 raise util.Abort(_('repository root cannot be destination'))
761 770 dummy, matchfn, dummy = cmdutil.matchpats(repo, [], opts)
762 771 kind = opts.get('type') or 'files'
763 772 prefix = opts['prefix']
764 773 if dest == '-':
765 774 if kind == 'files':
766 775 raise util.Abort(_('cannot archive plain files to stdout'))
767 776 dest = sys.stdout
768 777 if not prefix: prefix = os.path.basename(repo.root) + '-%h'
769 778 prefix = cmdutil.make_filename(repo, prefix, node)
770 779 archival.archive(repo, dest, node, kind, not opts['no_decode'],
771 780 matchfn, prefix)
772 781
773 782 def backout(ui, repo, rev, **opts):
774 783 '''reverse effect of earlier changeset
775 784
776 785 Commit the backed out changes as a new changeset. The new
777 786 changeset is a child of the backed out changeset.
778 787
779 788 If you back out a changeset other than the tip, a new head is
780 789 created. This head is the parent of the working directory. If
781 790 you back out an old changeset, your working directory will appear
782 791 old after the backout. You should merge the backout changeset
783 792 with another head.
784 793
785 794 The --merge option remembers the parent of the working directory
786 795 before starting the backout, then merges the new head with that
787 796 changeset afterwards. This saves you from doing the merge by
788 797 hand. The result of this merge is not committed, as for a normal
789 798 merge.'''
790 799
791 800 bail_if_changed(repo)
792 801 op1, op2 = repo.dirstate.parents()
793 802 if op2 != nullid:
794 803 raise util.Abort(_('outstanding uncommitted merge'))
795 804 node = repo.lookup(rev)
796 805 p1, p2 = repo.changelog.parents(node)
797 806 if p1 == nullid:
798 807 raise util.Abort(_('cannot back out a change with no parents'))
799 808 if p2 != nullid:
800 809 if not opts['parent']:
801 810 raise util.Abort(_('cannot back out a merge changeset without '
802 811 '--parent'))
803 812 p = repo.lookup(opts['parent'])
804 813 if p not in (p1, p2):
805 814 raise util.Abort(_('%s is not a parent of %s' %
806 815 (short(p), short(node))))
807 816 parent = p
808 817 else:
809 818 if opts['parent']:
810 819 raise util.Abort(_('cannot use --parent on non-merge changeset'))
811 820 parent = p1
812 821 hg.clean(repo, node, show_stats=False)
813 822 revert_opts = opts.copy()
814 823 revert_opts['rev'] = hex(parent)
815 824 revert(ui, repo, **revert_opts)
816 825 commit_opts = opts.copy()
817 826 commit_opts['addremove'] = False
818 827 if not commit_opts['message'] and not commit_opts['logfile']:
819 828 commit_opts['message'] = _("Backed out changeset %s") % (hex(node))
820 829 commit_opts['force_editor'] = True
821 830 commit(ui, repo, **commit_opts)
822 831 def nice(node):
823 832 return '%d:%s' % (repo.changelog.rev(node), short(node))
824 833 ui.status(_('changeset %s backs out changeset %s\n') %
825 834 (nice(repo.changelog.tip()), nice(node)))
826 835 if op1 != node:
827 836 if opts['merge']:
828 837 ui.status(_('merging with changeset %s\n') % nice(op1))
829 838 n = _lookup(repo, hex(op1))
830 839 hg.merge(repo, n)
831 840 else:
832 841 ui.status(_('the backout changeset is a new head - '
833 842 'do not forget to merge\n'))
834 843 ui.status(_('(use "backout --merge" '
835 844 'if you want to auto-merge)\n'))
836 845
837 846 def bundle(ui, repo, fname, dest=None, **opts):
838 847 """create a changegroup file
839 848
840 849 Generate a compressed changegroup file collecting all changesets
841 850 not found in the other repository.
842 851
843 852 This file can then be transferred using conventional means and
844 853 applied to another repository with the unbundle command. This is
845 854 useful when native push and pull are not available or when
846 855 exporting an entire repository is undesirable. The standard file
847 856 extension is ".hg".
848 857
849 858 Unlike import/export, this exactly preserves all changeset
850 859 contents including permissions, rename data, and revision history.
851 860 """
852 861 dest = ui.expandpath(dest or 'default-push', dest or 'default')
853 862 other = hg.repository(ui, dest)
854 863 o = repo.findoutgoing(other, force=opts['force'])
855 864 cg = repo.changegroup(o, 'bundle')
856 865 write_bundle(cg, fname)
857 866
858 867 def cat(ui, repo, file1, *pats, **opts):
859 868 """output the latest or given revisions of files
860 869
861 870 Print the specified files as they were at the given revision.
862 871 If no revision is given then the tip is used.
863 872
864 873 Output may be to a file, in which case the name of the file is
865 874 given using a format string. The formatting rules are the same as
866 875 for the export command, with the following additions:
867 876
868 877 %s basename of file being printed
869 878 %d dirname of file being printed, or '.' if in repo root
870 879 %p root-relative path name of file being printed
871 880 """
872 881 ctx = repo.changectx(opts['rev'] or "-1")
873 882 for src, abs, rel, exact in cmdutil.walk(repo, (file1,) + pats, opts,
874 883 ctx.node()):
875 884 fp = cmdutil.make_file(repo, opts['output'], ctx.node(), pathname=abs)
876 885 fp.write(ctx.filectx(abs).data())
877 886
878 887 def clone(ui, source, dest=None, **opts):
879 888 """make a copy of an existing repository
880 889
881 890 Create a copy of an existing repository in a new directory.
882 891
883 892 If no destination directory name is specified, it defaults to the
884 893 basename of the source.
885 894
886 895 The location of the source is added to the new repository's
887 896 .hg/hgrc file, as the default to be used for future pulls.
888 897
889 898 For efficiency, hardlinks are used for cloning whenever the source
890 899 and destination are on the same filesystem (note this applies only
891 900 to the repository data, not to the checked out files). Some
892 901 filesystems, such as AFS, implement hardlinking incorrectly, but
893 902 do not report errors. In these cases, use the --pull option to
894 903 avoid hardlinking.
895 904
896 905 You can safely clone repositories and checked out files using full
897 906 hardlinks with
898 907
899 908 $ cp -al REPO REPOCLONE
900 909
901 910 which is the fastest way to clone. However, the operation is not
902 911 atomic (making sure REPO is not modified during the operation is
903 912 up to you) and you have to make sure your editor breaks hardlinks
904 913 (Emacs and most Linux Kernel tools do so).
905 914
906 915 If you use the -r option to clone up to a specific revision, no
907 916 subsequent revisions will be present in the cloned repository.
908 917 This option implies --pull, even on local repositories.
909 918
910 919 See pull for valid source format details.
911 920
912 921 It is possible to specify an ssh:// URL as the destination, but no
913 922 .hg/hgrc will be created on the remote side. Look at the help text
914 923 for the pull command for important details about ssh:// URLs.
915 924 """
916 925 setremoteconfig(ui, opts)
917 926 hg.clone(ui, ui.expandpath(source), dest,
918 927 pull=opts['pull'],
919 928 stream=opts['uncompressed'],
920 929 rev=opts['rev'],
921 930 update=not opts['noupdate'])
922 931
923 932 def commit(ui, repo, *pats, **opts):
924 933 """commit the specified files or all outstanding changes
925 934
926 935 Commit changes to the given files into the repository.
927 936
928 937 If a list of files is omitted, all changes reported by "hg status"
929 938 will be committed.
930 939
931 940 If no commit message is specified, the editor configured in your hgrc
932 941 or in the EDITOR environment variable is started to enter a message.
933 942 """
934 943 message = logmessage(opts)
935 944
936 945 if opts['addremove']:
937 946 cmdutil.addremove(repo, pats, opts)
938 947 fns, match, anypats = cmdutil.matchpats(repo, pats, opts)
939 948 if pats:
940 949 modified, added, removed = repo.status(files=fns, match=match)[:3]
941 950 files = modified + added + removed
942 951 else:
943 952 files = []
944 953 try:
945 954 repo.commit(files, message, opts['user'], opts['date'], match,
946 955 force_editor=opts.get('force_editor'))
947 956 except ValueError, inst:
948 957 raise util.Abort(str(inst))
949 958
950 959 def docopy(ui, repo, pats, opts, wlock):
951 960 # called with the repo lock held
952 961 cwd = repo.getcwd()
953 962 errors = 0
954 963 copied = []
955 964 targets = {}
956 965
957 966 def okaytocopy(abs, rel, exact):
958 967 reasons = {'?': _('is not managed'),
959 968 'a': _('has been marked for add'),
960 969 'r': _('has been marked for remove')}
961 970 state = repo.dirstate.state(abs)
962 971 reason = reasons.get(state)
963 972 if reason:
964 973 if state == 'a':
965 974 origsrc = repo.dirstate.copied(abs)
966 975 if origsrc is not None:
967 976 return origsrc
968 977 if exact:
969 978 ui.warn(_('%s: not copying - file %s\n') % (rel, reason))
970 979 else:
971 980 return abs
972 981
973 982 def copy(origsrc, abssrc, relsrc, target, exact):
974 983 abstarget = util.canonpath(repo.root, cwd, target)
975 984 reltarget = util.pathto(cwd, abstarget)
976 985 prevsrc = targets.get(abstarget)
977 986 if prevsrc is not None:
978 987 ui.warn(_('%s: not overwriting - %s collides with %s\n') %
979 988 (reltarget, abssrc, prevsrc))
980 989 return
981 990 if (not opts['after'] and os.path.exists(reltarget) or
982 991 opts['after'] and repo.dirstate.state(abstarget) not in '?r'):
983 992 if not opts['force']:
984 993 ui.warn(_('%s: not overwriting - file exists\n') %
985 994 reltarget)
986 995 return
987 996 if not opts['after'] and not opts.get('dry_run'):
988 997 os.unlink(reltarget)
989 998 if opts['after']:
990 999 if not os.path.exists(reltarget):
991 1000 return
992 1001 else:
993 1002 targetdir = os.path.dirname(reltarget) or '.'
994 1003 if not os.path.isdir(targetdir) and not opts.get('dry_run'):
995 1004 os.makedirs(targetdir)
996 1005 try:
997 1006 restore = repo.dirstate.state(abstarget) == 'r'
998 1007 if restore and not opts.get('dry_run'):
999 1008 repo.undelete([abstarget], wlock)
1000 1009 try:
1001 1010 if not opts.get('dry_run'):
1002 1011 shutil.copyfile(relsrc, reltarget)
1003 1012 shutil.copymode(relsrc, reltarget)
1004 1013 restore = False
1005 1014 finally:
1006 1015 if restore:
1007 1016 repo.remove([abstarget], wlock)
1008 1017 except shutil.Error, inst:
1009 1018 raise util.Abort(str(inst))
1010 1019 except IOError, inst:
1011 1020 if inst.errno == errno.ENOENT:
1012 1021 ui.warn(_('%s: deleted in working copy\n') % relsrc)
1013 1022 else:
1014 1023 ui.warn(_('%s: cannot copy - %s\n') %
1015 1024 (relsrc, inst.strerror))
1016 1025 errors += 1
1017 1026 return
1018 1027 if ui.verbose or not exact:
1019 1028 ui.status(_('copying %s to %s\n') % (relsrc, reltarget))
1020 1029 targets[abstarget] = abssrc
1021 1030 if abstarget != origsrc and not opts.get('dry_run'):
1022 1031 repo.copy(origsrc, abstarget, wlock)
1023 1032 copied.append((abssrc, relsrc, exact))
1024 1033
1025 1034 def targetpathfn(pat, dest, srcs):
1026 1035 if os.path.isdir(pat):
1027 1036 abspfx = util.canonpath(repo.root, cwd, pat)
1028 1037 if destdirexists:
1029 1038 striplen = len(os.path.split(abspfx)[0])
1030 1039 else:
1031 1040 striplen = len(abspfx)
1032 1041 if striplen:
1033 1042 striplen += len(os.sep)
1034 1043 res = lambda p: os.path.join(dest, p[striplen:])
1035 1044 elif destdirexists:
1036 1045 res = lambda p: os.path.join(dest, os.path.basename(p))
1037 1046 else:
1038 1047 res = lambda p: dest
1039 1048 return res
1040 1049
1041 1050 def targetpathafterfn(pat, dest, srcs):
1042 1051 if util.patkind(pat, None)[0]:
1043 1052 # a mercurial pattern
1044 1053 res = lambda p: os.path.join(dest, os.path.basename(p))
1045 1054 else:
1046 1055 abspfx = util.canonpath(repo.root, cwd, pat)
1047 1056 if len(abspfx) < len(srcs[0][0]):
1048 1057 # A directory. Either the target path contains the last
1049 1058 # component of the source path or it does not.
1050 1059 def evalpath(striplen):
1051 1060 score = 0
1052 1061 for s in srcs:
1053 1062 t = os.path.join(dest, s[0][striplen:])
1054 1063 if os.path.exists(t):
1055 1064 score += 1
1056 1065 return score
1057 1066
1058 1067 striplen = len(abspfx)
1059 1068 if striplen:
1060 1069 striplen += len(os.sep)
1061 1070 if os.path.isdir(os.path.join(dest, os.path.split(abspfx)[1])):
1062 1071 score = evalpath(striplen)
1063 1072 striplen1 = len(os.path.split(abspfx)[0])
1064 1073 if striplen1:
1065 1074 striplen1 += len(os.sep)
1066 1075 if evalpath(striplen1) > score:
1067 1076 striplen = striplen1
1068 1077 res = lambda p: os.path.join(dest, p[striplen:])
1069 1078 else:
1070 1079 # a file
1071 1080 if destdirexists:
1072 1081 res = lambda p: os.path.join(dest, os.path.basename(p))
1073 1082 else:
1074 1083 res = lambda p: dest
1075 1084 return res
1076 1085
1077 1086
1078 1087 pats = list(pats)
1079 1088 if not pats:
1080 1089 raise util.Abort(_('no source or destination specified'))
1081 1090 if len(pats) == 1:
1082 1091 raise util.Abort(_('no destination specified'))
1083 1092 dest = pats.pop()
1084 1093 destdirexists = os.path.isdir(dest)
1085 1094 if (len(pats) > 1 or util.patkind(pats[0], None)[0]) and not destdirexists:
1086 1095 raise util.Abort(_('with multiple sources, destination must be an '
1087 1096 'existing directory'))
1088 1097 if opts['after']:
1089 1098 tfn = targetpathafterfn
1090 1099 else:
1091 1100 tfn = targetpathfn
1092 1101 copylist = []
1093 1102 for pat in pats:
1094 1103 srcs = []
1095 1104 for tag, abssrc, relsrc, exact in cmdutil.walk(repo, [pat], opts):
1096 1105 origsrc = okaytocopy(abssrc, relsrc, exact)
1097 1106 if origsrc:
1098 1107 srcs.append((origsrc, abssrc, relsrc, exact))
1099 1108 if not srcs:
1100 1109 continue
1101 1110 copylist.append((tfn(pat, dest, srcs), srcs))
1102 1111 if not copylist:
1103 1112 raise util.Abort(_('no files to copy'))
1104 1113
1105 1114 for targetpath, srcs in copylist:
1106 1115 for origsrc, abssrc, relsrc, exact in srcs:
1107 1116 copy(origsrc, abssrc, relsrc, targetpath(abssrc), exact)
1108 1117
1109 1118 if errors:
1110 1119 ui.warn(_('(consider using --after)\n'))
1111 1120 return errors, copied
1112 1121
1113 1122 def copy(ui, repo, *pats, **opts):
1114 1123 """mark files as copied for the next commit
1115 1124
1116 1125 Mark dest as having copies of source files. If dest is a
1117 1126 directory, copies are put in that directory. If dest is a file,
1118 1127 there can only be one source.
1119 1128
1120 1129 By default, this command copies the contents of files as they
1121 1130 stand in the working directory. If invoked with --after, the
1122 1131 operation is recorded, but no copying is performed.
1123 1132
1124 1133 This command takes effect in the next commit.
1125 1134
1126 1135 NOTE: This command should be treated as experimental. While it
1127 1136 should properly record copied files, this information is not yet
1128 1137 fully used by merge, nor fully reported by log.
1129 1138 """
1130 1139 wlock = repo.wlock(0)
1131 1140 errs, copied = docopy(ui, repo, pats, opts, wlock)
1132 1141 return errs
1133 1142
1134 1143 def debugancestor(ui, index, rev1, rev2):
1135 1144 """find the ancestor revision of two revisions in a given index"""
1136 1145 r = revlog.revlog(util.opener(os.getcwd(), audit=False), index, "", 0)
1137 1146 a = r.ancestor(r.lookup(rev1), r.lookup(rev2))
1138 1147 ui.write("%d:%s\n" % (r.rev(a), hex(a)))
1139 1148
1140 1149 def debugcomplete(ui, cmd='', **opts):
1141 1150 """returns the completion list associated with the given command"""
1142 1151
1143 1152 if opts['options']:
1144 1153 options = []
1145 1154 otables = [globalopts]
1146 1155 if cmd:
1147 1156 aliases, entry = findcmd(cmd)
1148 1157 otables.append(entry[1])
1149 1158 for t in otables:
1150 1159 for o in t:
1151 1160 if o[0]:
1152 1161 options.append('-%s' % o[0])
1153 1162 options.append('--%s' % o[1])
1154 1163 ui.write("%s\n" % "\n".join(options))
1155 1164 return
1156 1165
1157 1166 clist = findpossible(cmd).keys()
1158 1167 clist.sort()
1159 1168 ui.write("%s\n" % "\n".join(clist))
1160 1169
1161 1170 def debugrebuildstate(ui, repo, rev=None):
1162 1171 """rebuild the dirstate as it would look like for the given revision"""
1163 1172 if not rev:
1164 1173 rev = repo.changelog.tip()
1165 1174 else:
1166 1175 rev = repo.lookup(rev)
1167 1176 change = repo.changelog.read(rev)
1168 1177 n = change[0]
1169 1178 files = repo.manifest.read(n)
1170 1179 wlock = repo.wlock()
1171 1180 repo.dirstate.rebuild(rev, files)
1172 1181
1173 1182 def debugcheckstate(ui, repo):
1174 1183 """validate the correctness of the current dirstate"""
1175 1184 parent1, parent2 = repo.dirstate.parents()
1176 1185 repo.dirstate.read()
1177 1186 dc = repo.dirstate.map
1178 1187 keys = dc.keys()
1179 1188 keys.sort()
1180 1189 m1n = repo.changelog.read(parent1)[0]
1181 1190 m2n = repo.changelog.read(parent2)[0]
1182 1191 m1 = repo.manifest.read(m1n)
1183 1192 m2 = repo.manifest.read(m2n)
1184 1193 errors = 0
1185 1194 for f in dc:
1186 1195 state = repo.dirstate.state(f)
1187 1196 if state in "nr" and f not in m1:
1188 1197 ui.warn(_("%s in state %s, but not in manifest1\n") % (f, state))
1189 1198 errors += 1
1190 1199 if state in "a" and f in m1:
1191 1200 ui.warn(_("%s in state %s, but also in manifest1\n") % (f, state))
1192 1201 errors += 1
1193 1202 if state in "m" and f not in m1 and f not in m2:
1194 1203 ui.warn(_("%s in state %s, but not in either manifest\n") %
1195 1204 (f, state))
1196 1205 errors += 1
1197 1206 for f in m1:
1198 1207 state = repo.dirstate.state(f)
1199 1208 if state not in "nrm":
1200 1209 ui.warn(_("%s in manifest1, but listed as state %s") % (f, state))
1201 1210 errors += 1
1202 1211 if errors:
1203 1212 error = _(".hg/dirstate inconsistent with current parent's manifest")
1204 1213 raise util.Abort(error)
1205 1214
1206 1215 def debugconfig(ui, repo, *values):
1207 1216 """show combined config settings from all hgrc files
1208 1217
1209 1218 With no args, print names and values of all config items.
1210 1219
1211 1220 With one arg of the form section.name, print just the value of
1212 1221 that config item.
1213 1222
1214 1223 With multiple args, print names and values of all config items
1215 1224 with matching section names."""
1216 1225
1217 1226 if values:
1218 1227 if len([v for v in values if '.' in v]) > 1:
1219 1228 raise util.Abort(_('only one config item permitted'))
1220 1229 for section, name, value in ui.walkconfig():
1221 1230 sectname = section + '.' + name
1222 1231 if values:
1223 1232 for v in values:
1224 1233 if v == section:
1225 1234 ui.write('%s=%s\n' % (sectname, value))
1226 1235 elif v == sectname:
1227 1236 ui.write(value, '\n')
1228 1237 else:
1229 1238 ui.write('%s=%s\n' % (sectname, value))
1230 1239
1231 1240 def debugsetparents(ui, repo, rev1, rev2=None):
1232 1241 """manually set the parents of the current working directory
1233 1242
1234 1243 This is useful for writing repository conversion tools, but should
1235 1244 be used with care.
1236 1245 """
1237 1246
1238 1247 if not rev2:
1239 1248 rev2 = hex(nullid)
1240 1249
1241 1250 repo.dirstate.setparents(repo.lookup(rev1), repo.lookup(rev2))
1242 1251
1243 1252 def debugstate(ui, repo):
1244 1253 """show the contents of the current dirstate"""
1245 1254 repo.dirstate.read()
1246 1255 dc = repo.dirstate.map
1247 1256 keys = dc.keys()
1248 1257 keys.sort()
1249 1258 for file_ in keys:
1250 1259 ui.write("%c %3o %10d %s %s\n"
1251 1260 % (dc[file_][0], dc[file_][1] & 0777, dc[file_][2],
1252 1261 time.strftime("%x %X",
1253 1262 time.localtime(dc[file_][3])), file_))
1254 1263 for f in repo.dirstate.copies:
1255 1264 ui.write(_("copy: %s -> %s\n") % (repo.dirstate.copies[f], f))
1256 1265
1257 1266 def debugdata(ui, file_, rev):
1258 1267 """dump the contents of an data file revision"""
1259 1268 r = revlog.revlog(util.opener(os.getcwd(), audit=False),
1260 1269 file_[:-2] + ".i", file_, 0)
1261 1270 try:
1262 1271 ui.write(r.revision(r.lookup(rev)))
1263 1272 except KeyError:
1264 1273 raise util.Abort(_('invalid revision identifier %s'), rev)
1265 1274
1266 1275 def debugindex(ui, file_):
1267 1276 """dump the contents of an index file"""
1268 1277 r = revlog.revlog(util.opener(os.getcwd(), audit=False), file_, "", 0)
1269 1278 ui.write(" rev offset length base linkrev" +
1270 1279 " nodeid p1 p2\n")
1271 1280 for i in range(r.count()):
1272 1281 node = r.node(i)
1273 1282 pp = r.parents(node)
1274 1283 ui.write("% 6d % 9d % 7d % 6d % 7d %s %s %s\n" % (
1275 1284 i, r.start(i), r.length(i), r.base(i), r.linkrev(node),
1276 1285 short(node), short(pp[0]), short(pp[1])))
1277 1286
1278 1287 def debugindexdot(ui, file_):
1279 1288 """dump an index DAG as a .dot file"""
1280 1289 r = revlog.revlog(util.opener(os.getcwd(), audit=False), file_, "", 0)
1281 1290 ui.write("digraph G {\n")
1282 1291 for i in range(r.count()):
1283 1292 node = r.node(i)
1284 1293 pp = r.parents(node)
1285 1294 ui.write("\t%d -> %d\n" % (r.rev(pp[0]), i))
1286 1295 if pp[1] != nullid:
1287 1296 ui.write("\t%d -> %d\n" % (r.rev(pp[1]), i))
1288 1297 ui.write("}\n")
1289 1298
1290 1299 def debugrename(ui, repo, file, rev=None):
1291 1300 """dump rename information"""
1292 1301 r = repo.file(relpath(repo, [file])[0])
1293 1302 if rev:
1294 1303 try:
1295 1304 # assume all revision numbers are for changesets
1296 1305 n = repo.lookup(rev)
1297 1306 change = repo.changelog.read(n)
1298 1307 m = repo.manifest.read(change[0])
1299 1308 n = m[relpath(repo, [file])[0]]
1300 1309 except (hg.RepoError, KeyError):
1301 1310 n = r.lookup(rev)
1302 1311 else:
1303 1312 n = r.tip()
1304 1313 m = r.renamed(n)
1305 1314 if m:
1306 1315 ui.write(_("renamed from %s:%s\n") % (m[0], hex(m[1])))
1307 1316 else:
1308 1317 ui.write(_("not renamed\n"))
1309 1318
1310 1319 def debugwalk(ui, repo, *pats, **opts):
1311 1320 """show how files match on given patterns"""
1312 1321 items = list(cmdutil.walk(repo, pats, opts))
1313 1322 if not items:
1314 1323 return
1315 1324 fmt = '%%s %%-%ds %%-%ds %%s' % (
1316 1325 max([len(abs) for (src, abs, rel, exact) in items]),
1317 1326 max([len(rel) for (src, abs, rel, exact) in items]))
1318 1327 for src, abs, rel, exact in items:
1319 1328 line = fmt % (src, abs, rel, exact and 'exact' or '')
1320 1329 ui.write("%s\n" % line.rstrip())
1321 1330
1322 1331 def diff(ui, repo, *pats, **opts):
1323 1332 """diff repository (or selected files)
1324 1333
1325 1334 Show differences between revisions for the specified files.
1326 1335
1327 1336 Differences between files are shown using the unified diff format.
1328 1337
1329 1338 When two revision arguments are given, then changes are shown
1330 1339 between those revisions. If only one revision is specified then
1331 1340 that revision is compared to the working directory, and, when no
1332 1341 revisions are specified, the working directory files are compared
1333 1342 to its parent.
1334 1343
1335 1344 Without the -a option, diff will avoid generating diffs of files
1336 1345 it detects as binary. With -a, diff will generate a diff anyway,
1337 1346 probably with undesirable results.
1338 1347 """
1339 1348 node1, node2 = revpair(ui, repo, opts['rev'])
1340 1349
1341 1350 fns, matchfn, anypats = cmdutil.matchpats(repo, pats, opts)
1342 1351
1343 1352 patch.diff(repo, node1, node2, fns, match=matchfn,
1344 1353 opts=patch.diffopts(ui, opts))
1345 1354
1346 1355 def export(ui, repo, *changesets, **opts):
1347 1356 """dump the header and diffs for one or more changesets
1348 1357
1349 1358 Print the changeset header and diffs for one or more revisions.
1350 1359
1351 1360 The information shown in the changeset header is: author,
1352 1361 changeset hash, parent and commit comment.
1353 1362
1354 1363 Output may be to a file, in which case the name of the file is
1355 1364 given using a format string. The formatting rules are as follows:
1356 1365
1357 1366 %% literal "%" character
1358 1367 %H changeset hash (40 bytes of hexadecimal)
1359 1368 %N number of patches being generated
1360 1369 %R changeset revision number
1361 1370 %b basename of the exporting repository
1362 1371 %h short-form changeset hash (12 bytes of hexadecimal)
1363 1372 %n zero-padded sequence number, starting at 1
1364 1373 %r zero-padded changeset revision number
1365 1374
1366 1375 Without the -a option, export will avoid generating diffs of files
1367 1376 it detects as binary. With -a, export will generate a diff anyway,
1368 1377 probably with undesirable results.
1369 1378
1370 1379 With the --switch-parent option, the diff will be against the second
1371 1380 parent. It can be useful to review a merge.
1372 1381 """
1373 1382 if not changesets:
1374 1383 raise util.Abort(_("export requires at least one changeset"))
1375 1384 revs = list(revrange(ui, repo, changesets))
1376 1385 if len(revs) > 1:
1377 1386 ui.note(_('exporting patches:\n'))
1378 1387 else:
1379 1388 ui.note(_('exporting patch:\n'))
1380 1389 patch.export(repo, map(repo.lookup, revs), template=opts['output'],
1381 1390 switch_parent=opts['switch_parent'],
1382 1391 opts=patch.diffopts(ui, opts))
1383 1392
1384 1393 def forget(ui, repo, *pats, **opts):
1385 1394 """don't add the specified files on the next commit (DEPRECATED)
1386 1395
1387 1396 (DEPRECATED)
1388 1397 Undo an 'hg add' scheduled for the next commit.
1389 1398
1390 1399 This command is now deprecated and will be removed in a future
1391 1400 release. Please use revert instead.
1392 1401 """
1393 1402 ui.warn(_("(the forget command is deprecated; use revert instead)\n"))
1394 1403 forget = []
1395 1404 for src, abs, rel, exact in cmdutil.walk(repo, pats, opts):
1396 1405 if repo.dirstate.state(abs) == 'a':
1397 1406 forget.append(abs)
1398 1407 if ui.verbose or not exact:
1399 1408 ui.status(_('forgetting %s\n') % ((pats and rel) or abs))
1400 1409 repo.forget(forget)
1401 1410
1402 1411 def grep(ui, repo, pattern, *pats, **opts):
1403 1412 """search for a pattern in specified files and revisions
1404 1413
1405 1414 Search revisions of files for a regular expression.
1406 1415
1407 1416 This command behaves differently than Unix grep. It only accepts
1408 1417 Python/Perl regexps. It searches repository history, not the
1409 1418 working directory. It always prints the revision number in which
1410 1419 a match appears.
1411 1420
1412 1421 By default, grep only prints output for the first revision of a
1413 1422 file in which it finds a match. To get it to print every revision
1414 1423 that contains a change in match status ("-" for a match that
1415 1424 becomes a non-match, or "+" for a non-match that becomes a match),
1416 1425 use the --all flag.
1417 1426 """
1418 1427 reflags = 0
1419 1428 if opts['ignore_case']:
1420 1429 reflags |= re.I
1421 1430 regexp = re.compile(pattern, reflags)
1422 1431 sep, eol = ':', '\n'
1423 1432 if opts['print0']:
1424 1433 sep = eol = '\0'
1425 1434
1426 1435 fcache = {}
1427 1436 def getfile(fn):
1428 1437 if fn not in fcache:
1429 1438 fcache[fn] = repo.file(fn)
1430 1439 return fcache[fn]
1431 1440
1432 1441 def matchlines(body):
1433 1442 begin = 0
1434 1443 linenum = 0
1435 1444 while True:
1436 1445 match = regexp.search(body, begin)
1437 1446 if not match:
1438 1447 break
1439 1448 mstart, mend = match.span()
1440 1449 linenum += body.count('\n', begin, mstart) + 1
1441 1450 lstart = body.rfind('\n', begin, mstart) + 1 or begin
1442 1451 lend = body.find('\n', mend)
1443 1452 yield linenum, mstart - lstart, mend - lstart, body[lstart:lend]
1444 1453 begin = lend + 1
1445 1454
1446 1455 class linestate(object):
1447 1456 def __init__(self, line, linenum, colstart, colend):
1448 1457 self.line = line
1449 1458 self.linenum = linenum
1450 1459 self.colstart = colstart
1451 1460 self.colend = colend
1452 1461
1453 1462 def __eq__(self, other):
1454 1463 return self.line == other.line
1455 1464
1456 1465 matches = {}
1457 1466 copies = {}
1458 1467 def grepbody(fn, rev, body):
1459 1468 matches[rev].setdefault(fn, [])
1460 1469 m = matches[rev][fn]
1461 1470 for lnum, cstart, cend, line in matchlines(body):
1462 1471 s = linestate(line, lnum, cstart, cend)
1463 1472 m.append(s)
1464 1473
1465 1474 def difflinestates(a, b):
1466 1475 sm = difflib.SequenceMatcher(None, a, b)
1467 1476 for tag, alo, ahi, blo, bhi in sm.get_opcodes():
1468 1477 if tag == 'insert':
1469 1478 for i in range(blo, bhi):
1470 1479 yield ('+', b[i])
1471 1480 elif tag == 'delete':
1472 1481 for i in range(alo, ahi):
1473 1482 yield ('-', a[i])
1474 1483 elif tag == 'replace':
1475 1484 for i in range(alo, ahi):
1476 1485 yield ('-', a[i])
1477 1486 for i in range(blo, bhi):
1478 1487 yield ('+', b[i])
1479 1488
1480 1489 prev = {}
1481 1490 ucache = {}
1482 1491 def display(fn, rev, states, prevstates):
1483 1492 counts = {'-': 0, '+': 0}
1484 1493 filerevmatches = {}
1485 1494 if incrementing or not opts['all']:
1486 1495 a, b = prevstates, states
1487 1496 else:
1488 1497 a, b = states, prevstates
1489 1498 for change, l in difflinestates(a, b):
1490 1499 if incrementing or not opts['all']:
1491 1500 r = rev
1492 1501 else:
1493 1502 r = prev[fn]
1494 1503 cols = [fn, str(r)]
1495 1504 if opts['line_number']:
1496 1505 cols.append(str(l.linenum))
1497 1506 if opts['all']:
1498 1507 cols.append(change)
1499 1508 if opts['user']:
1500 1509 cols.append(trimuser(ui, getchange(r)[1], rev,
1501 1510 ucache))
1502 1511 if opts['files_with_matches']:
1503 1512 c = (fn, rev)
1504 1513 if c in filerevmatches:
1505 1514 continue
1506 1515 filerevmatches[c] = 1
1507 1516 else:
1508 1517 cols.append(l.line)
1509 1518 ui.write(sep.join(cols), eol)
1510 1519 counts[change] += 1
1511 1520 return counts['+'], counts['-']
1512 1521
1513 1522 fstate = {}
1514 1523 skip = {}
1515 1524 changeiter, getchange, matchfn = walkchangerevs(ui, repo, pats, opts)
1516 1525 count = 0
1517 1526 incrementing = False
1518 1527 follow = opts.get('follow')
1519 1528 for st, rev, fns in changeiter:
1520 1529 if st == 'window':
1521 1530 incrementing = rev
1522 1531 matches.clear()
1523 1532 elif st == 'add':
1524 1533 change = repo.changelog.read(repo.lookup(str(rev)))
1525 1534 mf = repo.manifest.read(change[0])
1526 1535 matches[rev] = {}
1527 1536 for fn in fns:
1528 1537 if fn in skip:
1529 1538 continue
1530 1539 fstate.setdefault(fn, {})
1531 1540 try:
1532 1541 grepbody(fn, rev, getfile(fn).read(mf[fn]))
1533 1542 if follow:
1534 1543 copied = getfile(fn).renamed(mf[fn])
1535 1544 if copied:
1536 1545 copies.setdefault(rev, {})[fn] = copied[0]
1537 1546 except KeyError:
1538 1547 pass
1539 1548 elif st == 'iter':
1540 1549 states = matches[rev].items()
1541 1550 states.sort()
1542 1551 for fn, m in states:
1543 1552 copy = copies.get(rev, {}).get(fn)
1544 1553 if fn in skip:
1545 1554 if copy:
1546 1555 skip[copy] = True
1547 1556 continue
1548 1557 if incrementing or not opts['all'] or fstate[fn]:
1549 1558 pos, neg = display(fn, rev, m, fstate[fn])
1550 1559 count += pos + neg
1551 1560 if pos and not opts['all']:
1552 1561 skip[fn] = True
1553 1562 if copy:
1554 1563 skip[copy] = True
1555 1564 fstate[fn] = m
1556 1565 if copy:
1557 1566 fstate[copy] = m
1558 1567 prev[fn] = rev
1559 1568
1560 1569 if not incrementing:
1561 1570 fstate = fstate.items()
1562 1571 fstate.sort()
1563 1572 for fn, state in fstate:
1564 1573 if fn in skip:
1565 1574 continue
1566 1575 if fn not in copies.get(prev[fn], {}):
1567 1576 display(fn, rev, {}, state)
1568 1577 return (count == 0 and 1) or 0
1569 1578
1570 1579 def heads(ui, repo, **opts):
1571 1580 """show current repository heads
1572 1581
1573 1582 Show all repository head changesets.
1574 1583
1575 1584 Repository "heads" are changesets that don't have children
1576 1585 changesets. They are where development generally takes place and
1577 1586 are the usual targets for update and merge operations.
1578 1587 """
1579 1588 if opts['rev']:
1580 1589 heads = repo.heads(repo.lookup(opts['rev']))
1581 1590 else:
1582 1591 heads = repo.heads()
1583 1592 br = None
1584 1593 if opts['branches']:
1585 1594 br = repo.branchlookup(heads)
1586 1595 displayer = show_changeset(ui, repo, opts)
1587 1596 for n in heads:
1588 1597 displayer.show(changenode=n, brinfo=br)
1589 1598
1590 1599 def identify(ui, repo):
1591 1600 """print information about the working copy
1592 1601
1593 1602 Print a short summary of the current state of the repo.
1594 1603
1595 1604 This summary identifies the repository state using one or two parent
1596 1605 hash identifiers, followed by a "+" if there are uncommitted changes
1597 1606 in the working directory, followed by a list of tags for this revision.
1598 1607 """
1599 1608 parents = [p for p in repo.dirstate.parents() if p != nullid]
1600 1609 if not parents:
1601 1610 ui.write(_("unknown\n"))
1602 1611 return
1603 1612
1604 1613 hexfunc = ui.verbose and hex or short
1605 1614 modified, added, removed, deleted = repo.status()[:4]
1606 1615 output = ["%s%s" %
1607 1616 ('+'.join([hexfunc(parent) for parent in parents]),
1608 1617 (modified or added or removed or deleted) and "+" or "")]
1609 1618
1610 1619 if not ui.quiet:
1611 1620 # multiple tags for a single parent separated by '/'
1612 1621 parenttags = ['/'.join(tags)
1613 1622 for tags in map(repo.nodetags, parents) if tags]
1614 1623 # tags for multiple parents separated by ' + '
1615 1624 if parenttags:
1616 1625 output.append(' + '.join(parenttags))
1617 1626
1618 1627 ui.write("%s\n" % ' '.join(output))
1619 1628
1620 1629 def import_(ui, repo, patch1, *patches, **opts):
1621 1630 """import an ordered set of patches
1622 1631
1623 1632 Import a list of patches and commit them individually.
1624 1633
1625 1634 If there are outstanding changes in the working directory, import
1626 1635 will abort unless given the -f flag.
1627 1636
1628 1637 You can import a patch straight from a mail message. Even patches
1629 1638 as attachments work (body part must be type text/plain or
1630 1639 text/x-patch to be used). From and Subject headers of email
1631 1640 message are used as default committer and commit message. All
1632 1641 text/plain body parts before first diff are added to commit
1633 1642 message.
1634 1643
1635 1644 If imported patch was generated by hg export, user and description
1636 1645 from patch override values from message headers and body. Values
1637 1646 given on command line with -m and -u override these.
1638 1647
1639 1648 To read a patch from standard input, use patch name "-".
1640 1649 """
1641 1650 patches = (patch1,) + patches
1642 1651
1643 1652 if not opts['force']:
1644 1653 bail_if_changed(repo)
1645 1654
1646 1655 d = opts["base"]
1647 1656 strip = opts["strip"]
1648 1657
1649 1658 wlock = repo.wlock()
1650 1659 lock = repo.lock()
1651 1660
1652 1661 for p in patches:
1653 1662 pf = os.path.join(d, p)
1654 1663
1655 1664 if pf == '-':
1656 1665 ui.status(_("applying patch from stdin\n"))
1657 1666 tmpname, message, user, date = patch.extract(ui, sys.stdin)
1658 1667 else:
1659 1668 ui.status(_("applying %s\n") % p)
1660 1669 tmpname, message, user, date = patch.extract(ui, file(pf))
1661 1670
1662 1671 if tmpname is None:
1663 1672 raise util.Abort(_('no diffs found'))
1664 1673
1665 1674 try:
1666 1675 if opts['message']:
1667 1676 # pickup the cmdline msg
1668 1677 message = opts['message']
1669 1678 elif message:
1670 1679 # pickup the patch msg
1671 1680 message = message.strip()
1672 1681 else:
1673 1682 # launch the editor
1674 1683 message = None
1675 1684 ui.debug(_('message:\n%s\n') % message)
1676 1685
1677 1686 files, fuzz = patch.patch(tmpname, ui, strip=strip, cwd=repo.root)
1678 1687 files = patch.updatedir(ui, repo, files, wlock=wlock)
1679 1688 repo.commit(files, message, user, date, wlock=wlock, lock=lock)
1680 1689 finally:
1681 1690 os.unlink(tmpname)
1682 1691
1683 1692 def incoming(ui, repo, source="default", **opts):
1684 1693 """show new changesets found in source
1685 1694
1686 1695 Show new changesets found in the specified path/URL or the default
1687 1696 pull location. These are the changesets that would be pulled if a pull
1688 1697 was requested.
1689 1698
1690 1699 For remote repository, using --bundle avoids downloading the changesets
1691 1700 twice if the incoming is followed by a pull.
1692 1701
1693 1702 See pull for valid source format details.
1694 1703 """
1695 1704 source = ui.expandpath(source)
1696 1705 setremoteconfig(ui, opts)
1697 1706
1698 1707 other = hg.repository(ui, source)
1699 1708 incoming = repo.findincoming(other, force=opts["force"])
1700 1709 if not incoming:
1701 1710 ui.status(_("no changes found\n"))
1702 1711 return
1703 1712
1704 1713 cleanup = None
1705 1714 try:
1706 1715 fname = opts["bundle"]
1707 1716 if fname or not other.local():
1708 1717 # create a bundle (uncompressed if other repo is not local)
1709 1718 cg = other.changegroup(incoming, "incoming")
1710 1719 fname = cleanup = write_bundle(cg, fname, compress=other.local())
1711 1720 # keep written bundle?
1712 1721 if opts["bundle"]:
1713 1722 cleanup = None
1714 1723 if not other.local():
1715 1724 # use the created uncompressed bundlerepo
1716 1725 other = bundlerepo.bundlerepository(ui, repo.root, fname)
1717 1726
1718 1727 revs = None
1719 1728 if opts['rev']:
1720 1729 revs = [other.lookup(rev) for rev in opts['rev']]
1721 1730 o = other.changelog.nodesbetween(incoming, revs)[0]
1722 1731 if opts['newest_first']:
1723 1732 o.reverse()
1724 1733 displayer = show_changeset(ui, other, opts)
1725 1734 for n in o:
1726 1735 parents = [p for p in other.changelog.parents(n) if p != nullid]
1727 1736 if opts['no_merges'] and len(parents) == 2:
1728 1737 continue
1729 1738 displayer.show(changenode=n)
1730 1739 if opts['patch']:
1731 1740 prev = (parents and parents[0]) or nullid
1732 1741 patch.diff(repo, other, prev, n)
1733 1742 ui.write("\n")
1734 1743 finally:
1735 1744 if hasattr(other, 'close'):
1736 1745 other.close()
1737 1746 if cleanup:
1738 1747 os.unlink(cleanup)
1739 1748
1740 1749 def init(ui, dest=".", **opts):
1741 1750 """create a new repository in the given directory
1742 1751
1743 1752 Initialize a new repository in the given directory. If the given
1744 1753 directory does not exist, it is created.
1745 1754
1746 1755 If no directory is given, the current directory is used.
1747 1756
1748 1757 It is possible to specify an ssh:// URL as the destination.
1749 1758 Look at the help text for the pull command for important details
1750 1759 about ssh:// URLs.
1751 1760 """
1752 1761 setremoteconfig(ui, opts)
1753 1762 hg.repository(ui, dest, create=1)
1754 1763
1755 1764 def locate(ui, repo, *pats, **opts):
1756 1765 """locate files matching specific patterns
1757 1766
1758 1767 Print all files under Mercurial control whose names match the
1759 1768 given patterns.
1760 1769
1761 1770 This command searches the current directory and its
1762 1771 subdirectories. To search an entire repository, move to the root
1763 1772 of the repository.
1764 1773
1765 1774 If no patterns are given to match, this command prints all file
1766 1775 names.
1767 1776
1768 1777 If you want to feed the output of this command into the "xargs"
1769 1778 command, use the "-0" option to both this command and "xargs".
1770 1779 This will avoid the problem of "xargs" treating single filenames
1771 1780 that contain white space as multiple filenames.
1772 1781 """
1773 1782 end = opts['print0'] and '\0' or '\n'
1774 1783 rev = opts['rev']
1775 1784 if rev:
1776 1785 node = repo.lookup(rev)
1777 1786 else:
1778 1787 node = None
1779 1788
1780 1789 for src, abs, rel, exact in cmdutil.walk(repo, pats, opts, node=node,
1781 1790 head='(?:.*/|)'):
1782 1791 if not node and repo.dirstate.state(abs) == '?':
1783 1792 continue
1784 1793 if opts['fullpath']:
1785 1794 ui.write(os.path.join(repo.root, abs), end)
1786 1795 else:
1787 1796 ui.write(((pats and rel) or abs), end)
1788 1797
1789 1798 def log(ui, repo, *pats, **opts):
1790 1799 """show revision history of entire repository or files
1791 1800
1792 1801 Print the revision history of the specified files or the entire
1793 1802 project.
1794 1803
1795 1804 File history is shown without following rename or copy history of
1796 1805 files. Use -f/--follow with a file name to follow history across
1797 1806 renames and copies. --follow without a file name will only show
1798 1807 ancestors or descendants of the starting revision. --follow-first
1799 1808 only follows the first parent of merge revisions.
1800 1809
1801 1810 If no revision range is specified, the default is tip:0 unless
1802 1811 --follow is set, in which case the working directory parent is
1803 1812 used as the starting revision.
1804 1813
1805 1814 By default this command outputs: changeset id and hash, tags,
1806 1815 non-trivial parents, user, date and time, and a summary for each
1807 1816 commit. When the -v/--verbose switch is used, the list of changed
1808 1817 files and full commit message is shown.
1809 1818 """
1810 1819 class dui(object):
1811 1820 # Implement and delegate some ui protocol. Save hunks of
1812 1821 # output for later display in the desired order.
1813 1822 def __init__(self, ui):
1814 1823 self.ui = ui
1815 1824 self.hunk = {}
1816 1825 self.header = {}
1817 1826 def bump(self, rev):
1818 1827 self.rev = rev
1819 1828 self.hunk[rev] = []
1820 1829 self.header[rev] = []
1821 1830 def note(self, *args):
1822 1831 if self.verbose:
1823 1832 self.write(*args)
1824 1833 def status(self, *args):
1825 1834 if not self.quiet:
1826 1835 self.write(*args)
1827 1836 def write(self, *args):
1828 1837 self.hunk[self.rev].append(args)
1829 1838 def write_header(self, *args):
1830 1839 self.header[self.rev].append(args)
1831 1840 def debug(self, *args):
1832 1841 if self.debugflag:
1833 1842 self.write(*args)
1834 1843 def __getattr__(self, key):
1835 1844 return getattr(self.ui, key)
1836 1845
1837 1846 changeiter, getchange, matchfn = walkchangerevs(ui, repo, pats, opts)
1838 1847
1839 1848 if opts['limit']:
1840 1849 try:
1841 1850 limit = int(opts['limit'])
1842 1851 except ValueError:
1843 1852 raise util.Abort(_('limit must be a positive integer'))
1844 1853 if limit <= 0: raise util.Abort(_('limit must be positive'))
1845 1854 else:
1846 1855 limit = sys.maxint
1847 1856 count = 0
1848 1857
1849 1858 displayer = show_changeset(ui, repo, opts)
1850 1859 for st, rev, fns in changeiter:
1851 1860 if st == 'window':
1852 1861 du = dui(ui)
1853 1862 displayer.ui = du
1854 1863 elif st == 'add':
1855 1864 du.bump(rev)
1856 1865 changenode = repo.changelog.node(rev)
1857 1866 parents = [p for p in repo.changelog.parents(changenode)
1858 1867 if p != nullid]
1859 1868 if opts['no_merges'] and len(parents) == 2:
1860 1869 continue
1861 1870 if opts['only_merges'] and len(parents) != 2:
1862 1871 continue
1863 1872
1864 1873 if opts['keyword']:
1865 1874 changes = getchange(rev)
1866 1875 miss = 0
1867 1876 for k in [kw.lower() for kw in opts['keyword']]:
1868 1877 if not (k in changes[1].lower() or
1869 1878 k in changes[4].lower() or
1870 1879 k in " ".join(changes[3][:20]).lower()):
1871 1880 miss = 1
1872 1881 break
1873 1882 if miss:
1874 1883 continue
1875 1884
1876 1885 br = None
1877 1886 if opts['branches']:
1878 1887 br = repo.branchlookup([repo.changelog.node(rev)])
1879 1888
1880 1889 displayer.show(rev, brinfo=br)
1881 1890 if opts['patch']:
1882 1891 prev = (parents and parents[0]) or nullid
1883 1892 patch.diff(repo, prev, changenode, match=matchfn, fp=du)
1884 1893 du.write("\n\n")
1885 1894 elif st == 'iter':
1886 1895 if count == limit: break
1887 1896 if du.header[rev]:
1888 1897 for args in du.header[rev]:
1889 1898 ui.write_header(*args)
1890 1899 if du.hunk[rev]:
1891 1900 count += 1
1892 1901 for args in du.hunk[rev]:
1893 1902 ui.write(*args)
1894 1903
1895 1904 def manifest(ui, repo, rev=None):
1896 1905 """output the latest or given revision of the project manifest
1897 1906
1898 1907 Print a list of version controlled files for the given revision.
1899 1908
1900 1909 The manifest is the list of files being version controlled. If no revision
1901 1910 is given then the tip is used.
1902 1911 """
1903 1912 if rev:
1904 1913 try:
1905 1914 # assume all revision numbers are for changesets
1906 1915 n = repo.lookup(rev)
1907 1916 change = repo.changelog.read(n)
1908 1917 n = change[0]
1909 1918 except hg.RepoError:
1910 1919 n = repo.manifest.lookup(rev)
1911 1920 else:
1912 1921 n = repo.manifest.tip()
1913 1922 m = repo.manifest.read(n)
1914 1923 files = m.keys()
1915 1924 files.sort()
1916 1925
1917 1926 for f in files:
1918 1927 ui.write("%40s %3s %s\n" % (hex(m[f]),
1919 1928 m.execf(f) and "755" or "644", f))
1920 1929
1921 1930 def merge(ui, repo, node=None, force=None, branch=None):
1922 1931 """Merge working directory with another revision
1923 1932
1924 1933 Merge the contents of the current working directory and the
1925 1934 requested revision. Files that changed between either parent are
1926 1935 marked as changed for the next commit and a commit must be
1927 1936 performed before any further updates are allowed.
1928 1937
1929 1938 If no revision is specified, the working directory's parent is a
1930 1939 head revision, and the repository contains exactly one other head,
1931 1940 the other head is merged with by default. Otherwise, an explicit
1932 1941 revision to merge with must be provided.
1933 1942 """
1934 1943
1935 1944 if node:
1936 1945 node = _lookup(repo, node, branch)
1937 1946 else:
1938 1947 heads = repo.heads()
1939 1948 if len(heads) > 2:
1940 1949 raise util.Abort(_('repo has %d heads - '
1941 1950 'please merge with an explicit rev') %
1942 1951 len(heads))
1943 1952 if len(heads) == 1:
1944 1953 raise util.Abort(_('there is nothing to merge - '
1945 1954 'use "hg update" instead'))
1946 1955 parent = repo.dirstate.parents()[0]
1947 1956 if parent not in heads:
1948 1957 raise util.Abort(_('working dir not at a head rev - '
1949 1958 'use "hg update" or merge with an explicit rev'))
1950 1959 node = parent == heads[0] and heads[-1] or heads[0]
1951 1960 return hg.merge(repo, node, force=force)
1952 1961
1953 1962 def outgoing(ui, repo, dest=None, **opts):
1954 1963 """show changesets not found in destination
1955 1964
1956 1965 Show changesets not found in the specified destination repository or
1957 1966 the default push location. These are the changesets that would be pushed
1958 1967 if a push was requested.
1959 1968
1960 1969 See pull for valid destination format details.
1961 1970 """
1962 1971 dest = ui.expandpath(dest or 'default-push', dest or 'default')
1963 1972 setremoteconfig(ui, opts)
1964 1973 revs = None
1965 1974 if opts['rev']:
1966 1975 revs = [repo.lookup(rev) for rev in opts['rev']]
1967 1976
1968 1977 other = hg.repository(ui, dest)
1969 1978 o = repo.findoutgoing(other, force=opts['force'])
1970 1979 if not o:
1971 1980 ui.status(_("no changes found\n"))
1972 1981 return
1973 1982 o = repo.changelog.nodesbetween(o, revs)[0]
1974 1983 if opts['newest_first']:
1975 1984 o.reverse()
1976 1985 displayer = show_changeset(ui, repo, opts)
1977 1986 for n in o:
1978 1987 parents = [p for p in repo.changelog.parents(n) if p != nullid]
1979 1988 if opts['no_merges'] and len(parents) == 2:
1980 1989 continue
1981 1990 displayer.show(changenode=n)
1982 1991 if opts['patch']:
1983 1992 prev = (parents and parents[0]) or nullid
1984 1993 patch.diff(repo, prev, n)
1985 1994 ui.write("\n")
1986 1995
1987 1996 def parents(ui, repo, file_=None, rev=None, branches=None, **opts):
1988 1997 """show the parents of the working dir or revision
1989 1998
1990 1999 Print the working directory's parent revisions.
1991 2000 """
1992 2001 # legacy
1993 2002 if file_ and not rev:
1994 2003 try:
1995 2004 rev = repo.lookup(file_)
1996 2005 file_ = None
1997 2006 except hg.RepoError:
1998 2007 pass
1999 2008 else:
2000 2009 ui.warn(_("'hg parent REV' is deprecated, "
2001 2010 "please use 'hg parents -r REV instead\n"))
2002 2011
2003 2012 if rev:
2004 2013 if file_:
2005 2014 ctx = repo.filectx(file_, changeid=rev)
2006 2015 else:
2007 2016 ctx = repo.changectx(rev)
2008 2017 p = [cp.node() for cp in ctx.parents()]
2009 2018 else:
2010 2019 p = repo.dirstate.parents()
2011 2020
2012 2021 br = None
2013 2022 if branches is not None:
2014 2023 br = repo.branchlookup(p)
2015 2024 displayer = show_changeset(ui, repo, opts)
2016 2025 for n in p:
2017 2026 if n != nullid:
2018 2027 displayer.show(changenode=n, brinfo=br)
2019 2028
2020 2029 def paths(ui, repo, search=None):
2021 2030 """show definition of symbolic path names
2022 2031
2023 2032 Show definition of symbolic path name NAME. If no name is given, show
2024 2033 definition of available names.
2025 2034
2026 2035 Path names are defined in the [paths] section of /etc/mercurial/hgrc
2027 2036 and $HOME/.hgrc. If run inside a repository, .hg/hgrc is used, too.
2028 2037 """
2029 2038 if search:
2030 2039 for name, path in ui.configitems("paths"):
2031 2040 if name == search:
2032 2041 ui.write("%s\n" % path)
2033 2042 return
2034 2043 ui.warn(_("not found!\n"))
2035 2044 return 1
2036 2045 else:
2037 2046 for name, path in ui.configitems("paths"):
2038 2047 ui.write("%s = %s\n" % (name, path))
2039 2048
2040 2049 def postincoming(ui, repo, modheads, optupdate):
2041 2050 if modheads == 0:
2042 2051 return
2043 2052 if optupdate:
2044 2053 if modheads == 1:
2045 2054 return hg.update(repo, repo.changelog.tip()) # update
2046 2055 else:
2047 2056 ui.status(_("not updating, since new heads added\n"))
2048 2057 if modheads > 1:
2049 2058 ui.status(_("(run 'hg heads' to see heads, 'hg merge' to merge)\n"))
2050 2059 else:
2051 2060 ui.status(_("(run 'hg update' to get a working copy)\n"))
2052 2061
2053 2062 def pull(ui, repo, source="default", **opts):
2054 2063 """pull changes from the specified source
2055 2064
2056 2065 Pull changes from a remote repository to a local one.
2057 2066
2058 2067 This finds all changes from the repository at the specified path
2059 2068 or URL and adds them to the local repository. By default, this
2060 2069 does not update the copy of the project in the working directory.
2061 2070
2062 2071 Valid URLs are of the form:
2063 2072
2064 2073 local/filesystem/path
2065 2074 http://[user@]host[:port]/[path]
2066 2075 https://[user@]host[:port]/[path]
2067 2076 ssh://[user@]host[:port]/[path]
2068 2077
2069 2078 Some notes about using SSH with Mercurial:
2070 2079 - SSH requires an accessible shell account on the destination machine
2071 2080 and a copy of hg in the remote path or specified with as remotecmd.
2072 2081 - path is relative to the remote user's home directory by default.
2073 2082 Use an extra slash at the start of a path to specify an absolute path:
2074 2083 ssh://example.com//tmp/repository
2075 2084 - Mercurial doesn't use its own compression via SSH; the right thing
2076 2085 to do is to configure it in your ~/.ssh/ssh_config, e.g.:
2077 2086 Host *.mylocalnetwork.example.com
2078 2087 Compression off
2079 2088 Host *
2080 2089 Compression on
2081 2090 Alternatively specify "ssh -C" as your ssh command in your hgrc or
2082 2091 with the --ssh command line option.
2083 2092 """
2084 2093 source = ui.expandpath(source)
2085 2094 setremoteconfig(ui, opts)
2086 2095
2087 2096 other = hg.repository(ui, source)
2088 2097 ui.status(_('pulling from %s\n') % (source))
2089 2098 revs = None
2090 2099 if opts['rev'] and not other.local():
2091 2100 raise util.Abort(_("pull -r doesn't work for remote repositories yet"))
2092 2101 elif opts['rev']:
2093 2102 revs = [other.lookup(rev) for rev in opts['rev']]
2094 2103 modheads = repo.pull(other, heads=revs, force=opts['force'])
2095 2104 return postincoming(ui, repo, modheads, opts['update'])
2096 2105
2097 2106 def push(ui, repo, dest=None, **opts):
2098 2107 """push changes to the specified destination
2099 2108
2100 2109 Push changes from the local repository to the given destination.
2101 2110
2102 2111 This is the symmetrical operation for pull. It helps to move
2103 2112 changes from the current repository to a different one. If the
2104 2113 destination is local this is identical to a pull in that directory
2105 2114 from the current one.
2106 2115
2107 2116 By default, push will refuse to run if it detects the result would
2108 2117 increase the number of remote heads. This generally indicates the
2109 2118 the client has forgotten to sync and merge before pushing.
2110 2119
2111 2120 Valid URLs are of the form:
2112 2121
2113 2122 local/filesystem/path
2114 2123 ssh://[user@]host[:port]/[path]
2115 2124
2116 2125 Look at the help text for the pull command for important details
2117 2126 about ssh:// URLs.
2118 2127
2119 2128 Pushing to http:// and https:// URLs is possible, too, if this
2120 2129 feature is enabled on the remote Mercurial server.
2121 2130 """
2122 2131 dest = ui.expandpath(dest or 'default-push', dest or 'default')
2123 2132 setremoteconfig(ui, opts)
2124 2133
2125 2134 other = hg.repository(ui, dest)
2126 2135 ui.status('pushing to %s\n' % (dest))
2127 2136 revs = None
2128 2137 if opts['rev']:
2129 2138 revs = [repo.lookup(rev) for rev in opts['rev']]
2130 2139 r = repo.push(other, opts['force'], revs=revs)
2131 2140 return r == 0
2132 2141
2133 2142 def rawcommit(ui, repo, *flist, **rc):
2134 2143 """raw commit interface (DEPRECATED)
2135 2144
2136 2145 (DEPRECATED)
2137 2146 Lowlevel commit, for use in helper scripts.
2138 2147
2139 2148 This command is not intended to be used by normal users, as it is
2140 2149 primarily useful for importing from other SCMs.
2141 2150
2142 2151 This command is now deprecated and will be removed in a future
2143 2152 release, please use debugsetparents and commit instead.
2144 2153 """
2145 2154
2146 2155 ui.warn(_("(the rawcommit command is deprecated)\n"))
2147 2156
2148 2157 message = rc['message']
2149 2158 if not message and rc['logfile']:
2150 2159 try:
2151 2160 message = open(rc['logfile']).read()
2152 2161 except IOError:
2153 2162 pass
2154 2163 if not message and not rc['logfile']:
2155 2164 raise util.Abort(_("missing commit message"))
2156 2165
2157 2166 files = relpath(repo, list(flist))
2158 2167 if rc['files']:
2159 2168 files += open(rc['files']).read().splitlines()
2160 2169
2161 2170 rc['parent'] = map(repo.lookup, rc['parent'])
2162 2171
2163 2172 try:
2164 2173 repo.rawcommit(files, message, rc['user'], rc['date'], *rc['parent'])
2165 2174 except ValueError, inst:
2166 2175 raise util.Abort(str(inst))
2167 2176
2168 2177 def recover(ui, repo):
2169 2178 """roll back an interrupted transaction
2170 2179
2171 2180 Recover from an interrupted commit or pull.
2172 2181
2173 2182 This command tries to fix the repository status after an interrupted
2174 2183 operation. It should only be necessary when Mercurial suggests it.
2175 2184 """
2176 2185 if repo.recover():
2177 2186 return hg.verify(repo)
2178 2187 return 1
2179 2188
2180 2189 def remove(ui, repo, *pats, **opts):
2181 2190 """remove the specified files on the next commit
2182 2191
2183 2192 Schedule the indicated files for removal from the repository.
2184 2193
2185 2194 This command schedules the files to be removed at the next commit.
2186 2195 This only removes files from the current branch, not from the
2187 2196 entire project history. If the files still exist in the working
2188 2197 directory, they will be deleted from it. If invoked with --after,
2189 2198 files that have been manually deleted are marked as removed.
2190 2199
2191 2200 Modified files and added files are not removed by default. To
2192 2201 remove them, use the -f/--force option.
2193 2202 """
2194 2203 names = []
2195 2204 if not opts['after'] and not pats:
2196 2205 raise util.Abort(_('no files specified'))
2197 2206 files, matchfn, anypats = cmdutil.matchpats(repo, pats, opts)
2198 2207 exact = dict.fromkeys(files)
2199 2208 mardu = map(dict.fromkeys, repo.status(files=files, match=matchfn))[:5]
2200 2209 modified, added, removed, deleted, unknown = mardu
2201 2210 remove, forget = [], []
2202 2211 for src, abs, rel, exact in cmdutil.walk(repo, pats, opts):
2203 2212 reason = None
2204 2213 if abs not in deleted and opts['after']:
2205 2214 reason = _('is still present')
2206 2215 elif abs in modified and not opts['force']:
2207 2216 reason = _('is modified (use -f to force removal)')
2208 2217 elif abs in added:
2209 2218 if opts['force']:
2210 2219 forget.append(abs)
2211 2220 continue
2212 2221 reason = _('has been marked for add (use -f to force removal)')
2213 2222 elif abs in unknown:
2214 2223 reason = _('is not managed')
2215 2224 elif abs in removed:
2216 2225 continue
2217 2226 if reason:
2218 2227 if exact:
2219 2228 ui.warn(_('not removing %s: file %s\n') % (rel, reason))
2220 2229 else:
2221 2230 if ui.verbose or not exact:
2222 2231 ui.status(_('removing %s\n') % rel)
2223 2232 remove.append(abs)
2224 2233 repo.forget(forget)
2225 2234 repo.remove(remove, unlink=not opts['after'])
2226 2235
2227 2236 def rename(ui, repo, *pats, **opts):
2228 2237 """rename files; equivalent of copy + remove
2229 2238
2230 2239 Mark dest as copies of sources; mark sources for deletion. If
2231 2240 dest is a directory, copies are put in that directory. If dest is
2232 2241 a file, there can only be one source.
2233 2242
2234 2243 By default, this command copies the contents of files as they
2235 2244 stand in the working directory. If invoked with --after, the
2236 2245 operation is recorded, but no copying is performed.
2237 2246
2238 2247 This command takes effect in the next commit.
2239 2248
2240 2249 NOTE: This command should be treated as experimental. While it
2241 2250 should properly record rename files, this information is not yet
2242 2251 fully used by merge, nor fully reported by log.
2243 2252 """
2244 2253 wlock = repo.wlock(0)
2245 2254 errs, copied = docopy(ui, repo, pats, opts, wlock)
2246 2255 names = []
2247 2256 for abs, rel, exact in copied:
2248 2257 if ui.verbose or not exact:
2249 2258 ui.status(_('removing %s\n') % rel)
2250 2259 names.append(abs)
2251 2260 if not opts.get('dry_run'):
2252 2261 repo.remove(names, True, wlock)
2253 2262 return errs
2254 2263
2255 2264 def revert(ui, repo, *pats, **opts):
2256 2265 """revert files or dirs to their states as of some revision
2257 2266
2258 2267 With no revision specified, revert the named files or directories
2259 2268 to the contents they had in the parent of the working directory.
2260 2269 This restores the contents of the affected files to an unmodified
2261 2270 state. If the working directory has two parents, you must
2262 2271 explicitly specify the revision to revert to.
2263 2272
2264 2273 Modified files are saved with a .orig suffix before reverting.
2265 2274 To disable these backups, use --no-backup.
2266 2275
2267 2276 Using the -r option, revert the given files or directories to
2268 2277 their contents as of a specific revision. This can be helpful to"roll
2269 2278 back" some or all of a change that should not have been committed.
2270 2279
2271 2280 Revert modifies the working directory. It does not commit any
2272 2281 changes, or change the parent of the working directory. If you
2273 2282 revert to a revision other than the parent of the working
2274 2283 directory, the reverted files will thus appear modified
2275 2284 afterwards.
2276 2285
2277 2286 If a file has been deleted, it is recreated. If the executable
2278 2287 mode of a file was changed, it is reset.
2279 2288
2280 2289 If names are given, all files matching the names are reverted.
2281 2290
2282 2291 If no arguments are given, all files in the repository are reverted.
2283 2292 """
2284 2293 parent, p2 = repo.dirstate.parents()
2285 2294 if opts['rev']:
2286 2295 node = repo.lookup(opts['rev'])
2287 2296 elif p2 != nullid:
2288 2297 raise util.Abort(_('working dir has two parents; '
2289 2298 'you must specify the revision to revert to'))
2290 2299 else:
2291 2300 node = parent
2292 2301 mf = repo.manifest.read(repo.changelog.read(node)[0])
2293 2302 if node == parent:
2294 2303 pmf = mf
2295 2304 else:
2296 2305 pmf = None
2297 2306
2298 2307 wlock = repo.wlock()
2299 2308
2300 2309 # need all matching names in dirstate and manifest of target rev,
2301 2310 # so have to walk both. do not print errors if files exist in one
2302 2311 # but not other.
2303 2312
2304 2313 names = {}
2305 2314 target_only = {}
2306 2315
2307 2316 # walk dirstate.
2308 2317
2309 2318 for src, abs, rel, exact in cmdutil.walk(repo, pats, opts,
2310 2319 badmatch=mf.has_key):
2311 2320 names[abs] = (rel, exact)
2312 2321 if src == 'b':
2313 2322 target_only[abs] = True
2314 2323
2315 2324 # walk target manifest.
2316 2325
2317 2326 for src, abs, rel, exact in cmdutil.walk(repo, pats, opts, node=node,
2318 2327 badmatch=names.has_key):
2319 2328 if abs in names: continue
2320 2329 names[abs] = (rel, exact)
2321 2330 target_only[abs] = True
2322 2331
2323 2332 changes = repo.status(match=names.has_key, wlock=wlock)[:5]
2324 2333 modified, added, removed, deleted, unknown = map(dict.fromkeys, changes)
2325 2334
2326 2335 revert = ([], _('reverting %s\n'))
2327 2336 add = ([], _('adding %s\n'))
2328 2337 remove = ([], _('removing %s\n'))
2329 2338 forget = ([], _('forgetting %s\n'))
2330 2339 undelete = ([], _('undeleting %s\n'))
2331 2340 update = {}
2332 2341
2333 2342 disptable = (
2334 2343 # dispatch table:
2335 2344 # file state
2336 2345 # action if in target manifest
2337 2346 # action if not in target manifest
2338 2347 # make backup if in target manifest
2339 2348 # make backup if not in target manifest
2340 2349 (modified, revert, remove, True, True),
2341 2350 (added, revert, forget, True, False),
2342 2351 (removed, undelete, None, False, False),
2343 2352 (deleted, revert, remove, False, False),
2344 2353 (unknown, add, None, True, False),
2345 2354 (target_only, add, None, False, False),
2346 2355 )
2347 2356
2348 2357 entries = names.items()
2349 2358 entries.sort()
2350 2359
2351 2360 for abs, (rel, exact) in entries:
2352 2361 mfentry = mf.get(abs)
2353 2362 def handle(xlist, dobackup):
2354 2363 xlist[0].append(abs)
2355 2364 update[abs] = 1
2356 2365 if dobackup and not opts['no_backup'] and os.path.exists(rel):
2357 2366 bakname = "%s.orig" % rel
2358 2367 ui.note(_('saving current version of %s as %s\n') %
2359 2368 (rel, bakname))
2360 2369 if not opts.get('dry_run'):
2361 2370 shutil.copyfile(rel, bakname)
2362 2371 shutil.copymode(rel, bakname)
2363 2372 if ui.verbose or not exact:
2364 2373 ui.status(xlist[1] % rel)
2365 2374 for table, hitlist, misslist, backuphit, backupmiss in disptable:
2366 2375 if abs not in table: continue
2367 2376 # file has changed in dirstate
2368 2377 if mfentry:
2369 2378 handle(hitlist, backuphit)
2370 2379 elif misslist is not None:
2371 2380 handle(misslist, backupmiss)
2372 2381 else:
2373 2382 if exact: ui.warn(_('file not managed: %s\n' % rel))
2374 2383 break
2375 2384 else:
2376 2385 # file has not changed in dirstate
2377 2386 if node == parent:
2378 2387 if exact: ui.warn(_('no changes needed to %s\n' % rel))
2379 2388 continue
2380 2389 if pmf is None:
2381 2390 # only need parent manifest in this unlikely case,
2382 2391 # so do not read by default
2383 2392 pmf = repo.manifest.read(repo.changelog.read(parent)[0])
2384 2393 if abs in pmf:
2385 2394 if mfentry:
2386 2395 # if version of file is same in parent and target
2387 2396 # manifests, do nothing
2388 2397 if pmf[abs] != mfentry:
2389 2398 handle(revert, False)
2390 2399 else:
2391 2400 handle(remove, False)
2392 2401
2393 2402 if not opts.get('dry_run'):
2394 2403 repo.dirstate.forget(forget[0])
2395 2404 r = hg.revert(repo, node, update.has_key, wlock)
2396 2405 repo.dirstate.update(add[0], 'a')
2397 2406 repo.dirstate.update(undelete[0], 'n')
2398 2407 repo.dirstate.update(remove[0], 'r')
2399 2408 return r
2400 2409
2401 2410 def rollback(ui, repo):
2402 2411 """roll back the last transaction in this repository
2403 2412
2404 2413 Roll back the last transaction in this repository, restoring the
2405 2414 project to its state prior to the transaction.
2406 2415
2407 2416 Transactions are used to encapsulate the effects of all commands
2408 2417 that create new changesets or propagate existing changesets into a
2409 2418 repository. For example, the following commands are transactional,
2410 2419 and their effects can be rolled back:
2411 2420
2412 2421 commit
2413 2422 import
2414 2423 pull
2415 2424 push (with this repository as destination)
2416 2425 unbundle
2417 2426
2418 2427 This command should be used with care. There is only one level of
2419 2428 rollback, and there is no way to undo a rollback.
2420 2429
2421 2430 This command is not intended for use on public repositories. Once
2422 2431 changes are visible for pull by other users, rolling a transaction
2423 2432 back locally is ineffective (someone else may already have pulled
2424 2433 the changes). Furthermore, a race is possible with readers of the
2425 2434 repository; for example an in-progress pull from the repository
2426 2435 may fail if a rollback is performed.
2427 2436 """
2428 2437 repo.rollback()
2429 2438
2430 2439 def root(ui, repo):
2431 2440 """print the root (top) of the current working dir
2432 2441
2433 2442 Print the root directory of the current repository.
2434 2443 """
2435 2444 ui.write(repo.root + "\n")
2436 2445
2437 2446 def serve(ui, repo, **opts):
2438 2447 """export the repository via HTTP
2439 2448
2440 2449 Start a local HTTP repository browser and pull server.
2441 2450
2442 2451 By default, the server logs accesses to stdout and errors to
2443 2452 stderr. Use the "-A" and "-E" options to log to files.
2444 2453 """
2445 2454
2446 2455 if opts["stdio"]:
2447 2456 if repo is None:
2448 2457 raise hg.RepoError(_('no repo found'))
2449 2458 s = sshserver.sshserver(ui, repo)
2450 2459 s.serve_forever()
2451 2460
2452 2461 optlist = ("name templates style address port ipv6"
2453 2462 " accesslog errorlog webdir_conf")
2454 2463 for o in optlist.split():
2455 2464 if opts[o]:
2456 2465 ui.setconfig("web", o, opts[o])
2457 2466
2458 2467 if repo is None and not ui.config("web", "webdir_conf"):
2459 2468 raise hg.RepoError(_('no repo found'))
2460 2469
2461 2470 if opts['daemon'] and not opts['daemon_pipefds']:
2462 2471 rfd, wfd = os.pipe()
2463 2472 args = sys.argv[:]
2464 2473 args.append('--daemon-pipefds=%d,%d' % (rfd, wfd))
2465 2474 pid = os.spawnvp(os.P_NOWAIT | getattr(os, 'P_DETACH', 0),
2466 2475 args[0], args)
2467 2476 os.close(wfd)
2468 2477 os.read(rfd, 1)
2469 2478 os._exit(0)
2470 2479
2471 2480 try:
2472 2481 httpd = hgweb.server.create_server(ui, repo)
2473 2482 except socket.error, inst:
2474 2483 raise util.Abort(_('cannot start server: ') + inst.args[1])
2475 2484
2476 2485 if ui.verbose:
2477 2486 addr, port = httpd.socket.getsockname()
2478 2487 if addr == '0.0.0.0':
2479 2488 addr = socket.gethostname()
2480 2489 else:
2481 2490 try:
2482 2491 addr = socket.gethostbyaddr(addr)[0]
2483 2492 except socket.error:
2484 2493 pass
2485 2494 if port != 80:
2486 2495 ui.status(_('listening at http://%s:%d/\n') % (addr, port))
2487 2496 else:
2488 2497 ui.status(_('listening at http://%s/\n') % addr)
2489 2498
2490 2499 if opts['pid_file']:
2491 2500 fp = open(opts['pid_file'], 'w')
2492 2501 fp.write(str(os.getpid()) + '\n')
2493 2502 fp.close()
2494 2503
2495 2504 if opts['daemon_pipefds']:
2496 2505 rfd, wfd = [int(x) for x in opts['daemon_pipefds'].split(',')]
2497 2506 os.close(rfd)
2498 2507 os.write(wfd, 'y')
2499 2508 os.close(wfd)
2500 2509 sys.stdout.flush()
2501 2510 sys.stderr.flush()
2502 2511 fd = os.open(util.nulldev, os.O_RDWR)
2503 2512 if fd != 0: os.dup2(fd, 0)
2504 2513 if fd != 1: os.dup2(fd, 1)
2505 2514 if fd != 2: os.dup2(fd, 2)
2506 2515 if fd not in (0, 1, 2): os.close(fd)
2507 2516
2508 2517 httpd.serve_forever()
2509 2518
2510 2519 def status(ui, repo, *pats, **opts):
2511 2520 """show changed files in the working directory
2512 2521
2513 2522 Show status of files in the repository. If names are given, only
2514 2523 files that match are shown. Files that are clean or ignored, are
2515 2524 not listed unless -c (clean), -i (ignored) or -A is given.
2516 2525
2517 2526 The codes used to show the status of files are:
2518 2527 M = modified
2519 2528 A = added
2520 2529 R = removed
2521 2530 C = clean
2522 2531 ! = deleted, but still tracked
2523 2532 ? = not tracked
2524 2533 I = ignored (not shown by default)
2525 2534 = the previous added file was copied from here
2526 2535 """
2527 2536
2528 2537 all = opts['all']
2529 2538
2530 2539 files, matchfn, anypats = cmdutil.matchpats(repo, pats, opts)
2531 2540 cwd = (pats and repo.getcwd()) or ''
2532 2541 modified, added, removed, deleted, unknown, ignored, clean = [
2533 2542 [util.pathto(cwd, x) for x in n]
2534 2543 for n in repo.status(files=files, match=matchfn,
2535 2544 list_ignored=all or opts['ignored'],
2536 2545 list_clean=all or opts['clean'])]
2537 2546
2538 2547 changetypes = (('modified', 'M', modified),
2539 2548 ('added', 'A', added),
2540 2549 ('removed', 'R', removed),
2541 2550 ('deleted', '!', deleted),
2542 2551 ('unknown', '?', unknown),
2543 2552 ('ignored', 'I', ignored))
2544 2553
2545 2554 explicit_changetypes = changetypes + (('clean', 'C', clean),)
2546 2555
2547 2556 end = opts['print0'] and '\0' or '\n'
2548 2557
2549 2558 for opt, char, changes in ([ct for ct in explicit_changetypes
2550 2559 if all or opts[ct[0]]]
2551 2560 or changetypes):
2552 2561 if opts['no_status']:
2553 2562 format = "%%s%s" % end
2554 2563 else:
2555 2564 format = "%s %%s%s" % (char, end)
2556 2565
2557 2566 for f in changes:
2558 2567 ui.write(format % f)
2559 2568 if ((all or opts.get('copies')) and not opts.get('no_status')
2560 2569 and opt == 'added' and repo.dirstate.copies.has_key(f)):
2561 2570 ui.write(' %s%s' % (repo.dirstate.copies[f], end))
2562 2571
2563 2572 def tag(ui, repo, name, rev_=None, **opts):
2564 2573 """add a tag for the current tip or a given revision
2565 2574
2566 2575 Name a particular revision using <name>.
2567 2576
2568 2577 Tags are used to name particular revisions of the repository and are
2569 2578 very useful to compare different revision, to go back to significant
2570 2579 earlier versions or to mark branch points as releases, etc.
2571 2580
2572 2581 If no revision is given, the parent of the working directory is used.
2573 2582
2574 2583 To facilitate version control, distribution, and merging of tags,
2575 2584 they are stored as a file named ".hgtags" which is managed
2576 2585 similarly to other project files and can be hand-edited if
2577 2586 necessary. The file '.hg/localtags' is used for local tags (not
2578 2587 shared among repositories).
2579 2588 """
2580 2589 if name in ['tip', '.']:
2581 2590 raise util.Abort(_("the name '%s' is reserved") % name)
2582 2591 if rev_ is not None:
2583 2592 ui.warn(_("use of 'hg tag NAME [REV]' is deprecated, "
2584 2593 "please use 'hg tag [-r REV] NAME' instead\n"))
2585 2594 if opts['rev']:
2586 2595 raise util.Abort(_("use only one form to specify the revision"))
2587 2596 if opts['rev']:
2588 2597 rev_ = opts['rev']
2589 2598 if rev_:
2590 2599 r = hex(repo.lookup(rev_))
2591 2600 else:
2592 2601 p1, p2 = repo.dirstate.parents()
2593 2602 if p1 == nullid:
2594 2603 raise util.Abort(_('no revision to tag'))
2595 2604 if p2 != nullid:
2596 2605 raise util.Abort(_('outstanding uncommitted merges'))
2597 2606 r = hex(p1)
2598 2607
2599 2608 repo.tag(name, r, opts['local'], opts['message'], opts['user'],
2600 2609 opts['date'])
2601 2610
2602 2611 def tags(ui, repo):
2603 2612 """list repository tags
2604 2613
2605 2614 List the repository tags.
2606 2615
2607 2616 This lists both regular and local tags.
2608 2617 """
2609 2618
2610 2619 l = repo.tagslist()
2611 2620 l.reverse()
2612 2621 for t, n in l:
2613 2622 try:
2614 2623 r = "%5d:%s" % (repo.changelog.rev(n), hex(n))
2615 2624 except KeyError:
2616 2625 r = " ?:?"
2617 2626 if ui.quiet:
2618 2627 ui.write("%s\n" % t)
2619 2628 else:
2620 2629 ui.write("%-30s %s\n" % (t, r))
2621 2630
2622 2631 def tip(ui, repo, **opts):
2623 2632 """show the tip revision
2624 2633
2625 2634 Show the tip revision.
2626 2635 """
2627 2636 n = repo.changelog.tip()
2628 2637 br = None
2629 2638 if opts['branches']:
2630 2639 br = repo.branchlookup([n])
2631 2640 show_changeset(ui, repo, opts).show(changenode=n, brinfo=br)
2632 2641 if opts['patch']:
2633 2642 patch.diff(repo, repo.changelog.parents(n)[0], n)
2634 2643
2635 2644 def unbundle(ui, repo, fname, **opts):
2636 2645 """apply a changegroup file
2637 2646
2638 2647 Apply a compressed changegroup file generated by the bundle
2639 2648 command.
2640 2649 """
2641 2650 f = urllib.urlopen(fname)
2642 2651
2643 2652 header = f.read(6)
2644 2653 if not header.startswith("HG"):
2645 2654 raise util.Abort(_("%s: not a Mercurial bundle file") % fname)
2646 2655 elif not header.startswith("HG10"):
2647 2656 raise util.Abort(_("%s: unknown bundle version") % fname)
2648 2657 elif header == "HG10BZ":
2649 2658 def generator(f):
2650 2659 zd = bz2.BZ2Decompressor()
2651 2660 zd.decompress("BZ")
2652 2661 for chunk in f:
2653 2662 yield zd.decompress(chunk)
2654 2663 elif header == "HG10UN":
2655 2664 def generator(f):
2656 2665 for chunk in f:
2657 2666 yield chunk
2658 2667 else:
2659 2668 raise util.Abort(_("%s: unknown bundle compression type")
2660 2669 % fname)
2661 2670 gen = generator(util.filechunkiter(f, 4096))
2662 2671 modheads = repo.addchangegroup(util.chunkbuffer(gen), 'unbundle',
2663 2672 'bundle:' + fname)
2664 2673 return postincoming(ui, repo, modheads, opts['update'])
2665 2674
2666 2675 def undo(ui, repo):
2667 2676 """undo the last commit or pull (DEPRECATED)
2668 2677
2669 2678 (DEPRECATED)
2670 2679 This command is now deprecated and will be removed in a future
2671 2680 release. Please use the rollback command instead. For usage
2672 2681 instructions, see the rollback command.
2673 2682 """
2674 2683 ui.warn(_('(the undo command is deprecated; use rollback instead)\n'))
2675 2684 repo.rollback()
2676 2685
2677 2686 def update(ui, repo, node=None, merge=False, clean=False, force=None,
2678 2687 branch=None):
2679 2688 """update or merge working directory
2680 2689
2681 2690 Update the working directory to the specified revision.
2682 2691
2683 2692 If there are no outstanding changes in the working directory and
2684 2693 there is a linear relationship between the current version and the
2685 2694 requested version, the result is the requested version.
2686 2695
2687 2696 To merge the working directory with another revision, use the
2688 2697 merge command.
2689 2698
2690 2699 By default, update will refuse to run if doing so would require
2691 2700 merging or discarding local changes.
2692 2701 """
2693 2702 node = _lookup(repo, node, branch)
2694 2703 if merge:
2695 2704 ui.warn(_('(the -m/--merge option is deprecated; '
2696 2705 'use the merge command instead)\n'))
2697 2706 return hg.merge(repo, node, force=force)
2698 2707 elif clean:
2699 2708 return hg.clean(repo, node)
2700 2709 else:
2701 2710 return hg.update(repo, node)
2702 2711
2703 2712 def _lookup(repo, node, branch=None):
2704 2713 if branch:
2705 2714 br = repo.branchlookup(branch=branch)
2706 2715 found = []
2707 2716 for x in br:
2708 2717 if branch in br[x]:
2709 2718 found.append(x)
2710 2719 if len(found) > 1:
2711 2720 repo.ui.warn(_("Found multiple heads for %s\n") % branch)
2712 2721 for x in found:
2713 2722 show_changeset(ui, repo, {}).show(changenode=x, brinfo=br)
2714 2723 raise util.Abort("")
2715 2724 if len(found) == 1:
2716 2725 node = found[0]
2717 2726 repo.ui.warn(_("Using head %s for branch %s\n")
2718 2727 % (short(node), branch))
2719 2728 else:
2720 2729 raise util.Abort(_("branch %s not found\n") % (branch))
2721 2730 else:
2722 2731 node = node and repo.lookup(node) or repo.changelog.tip()
2723 2732 return node
2724 2733
2725 2734 def verify(ui, repo):
2726 2735 """verify the integrity of the repository
2727 2736
2728 2737 Verify the integrity of the current repository.
2729 2738
2730 2739 This will perform an extensive check of the repository's
2731 2740 integrity, validating the hashes and checksums of each entry in
2732 2741 the changelog, manifest, and tracked files, as well as the
2733 2742 integrity of their crosslinks and indices.
2734 2743 """
2735 2744 return hg.verify(repo)
2736 2745
2737 2746 # Command options and aliases are listed here, alphabetically
2738 2747
2739 2748 table = {
2740 2749 "^add":
2741 2750 (add,
2742 2751 [('I', 'include', [], _('include names matching the given patterns')),
2743 2752 ('X', 'exclude', [], _('exclude names matching the given patterns')),
2744 2753 ('n', 'dry-run', None, _('do not perform actions, just print output'))],
2745 2754 _('hg add [OPTION]... [FILE]...')),
2746 2755 "addremove":
2747 2756 (addremove,
2748 2757 [('I', 'include', [], _('include names matching the given patterns')),
2749 2758 ('X', 'exclude', [], _('exclude names matching the given patterns')),
2750 ('n', 'dry-run', None, _('do not perform actions, just print output'))],
2759 ('n', 'dry-run', None,
2760 _('do not perform actions, just print output')),
2761 ('s', 'similarity', '',
2762 _('guess renamed files by similarity (0<=s<=1)'))],
2751 2763 _('hg addremove [OPTION]... [FILE]...')),
2752 2764 "^annotate":
2753 2765 (annotate,
2754 2766 [('r', 'rev', '', _('annotate the specified revision')),
2755 2767 ('a', 'text', None, _('treat all files as text')),
2756 2768 ('u', 'user', None, _('list the author')),
2757 2769 ('d', 'date', None, _('list the date')),
2758 2770 ('n', 'number', None, _('list the revision number (default)')),
2759 2771 ('c', 'changeset', None, _('list the changeset')),
2760 2772 ('I', 'include', [], _('include names matching the given patterns')),
2761 2773 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2762 2774 _('hg annotate [-r REV] [-a] [-u] [-d] [-n] [-c] FILE...')),
2763 2775 "archive":
2764 2776 (archive,
2765 2777 [('', 'no-decode', None, _('do not pass files through decoders')),
2766 2778 ('p', 'prefix', '', _('directory prefix for files in archive')),
2767 2779 ('r', 'rev', '', _('revision to distribute')),
2768 2780 ('t', 'type', '', _('type of distribution to create')),
2769 2781 ('I', 'include', [], _('include names matching the given patterns')),
2770 2782 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2771 2783 _('hg archive [OPTION]... DEST')),
2772 2784 "backout":
2773 2785 (backout,
2774 2786 [('', 'merge', None,
2775 2787 _('merge with old dirstate parent after backout')),
2776 2788 ('m', 'message', '', _('use <text> as commit message')),
2777 2789 ('l', 'logfile', '', _('read commit message from <file>')),
2778 2790 ('d', 'date', '', _('record datecode as commit date')),
2779 2791 ('', 'parent', '', _('parent to choose when backing out merge')),
2780 2792 ('u', 'user', '', _('record user as committer')),
2781 2793 ('I', 'include', [], _('include names matching the given patterns')),
2782 2794 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2783 2795 _('hg backout [OPTION]... REV')),
2784 2796 "bundle":
2785 2797 (bundle,
2786 2798 [('f', 'force', None,
2787 2799 _('run even when remote repository is unrelated'))],
2788 2800 _('hg bundle FILE DEST')),
2789 2801 "cat":
2790 2802 (cat,
2791 2803 [('o', 'output', '', _('print output to file with formatted name')),
2792 2804 ('r', 'rev', '', _('print the given revision')),
2793 2805 ('I', 'include', [], _('include names matching the given patterns')),
2794 2806 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2795 2807 _('hg cat [OPTION]... FILE...')),
2796 2808 "^clone":
2797 2809 (clone,
2798 2810 [('U', 'noupdate', None, _('do not update the new working directory')),
2799 2811 ('r', 'rev', [],
2800 2812 _('a changeset you would like to have after cloning')),
2801 2813 ('', 'pull', None, _('use pull protocol to copy metadata')),
2802 2814 ('', 'uncompressed', None,
2803 2815 _('use uncompressed transfer (fast over LAN)')),
2804 2816 ('e', 'ssh', '', _('specify ssh command to use')),
2805 2817 ('', 'remotecmd', '',
2806 2818 _('specify hg command to run on the remote side'))],
2807 2819 _('hg clone [OPTION]... SOURCE [DEST]')),
2808 2820 "^commit|ci":
2809 2821 (commit,
2810 2822 [('A', 'addremove', None,
2811 2823 _('mark new/missing files as added/removed before committing')),
2812 2824 ('m', 'message', '', _('use <text> as commit message')),
2813 2825 ('l', 'logfile', '', _('read the commit message from <file>')),
2814 2826 ('d', 'date', '', _('record datecode as commit date')),
2815 2827 ('u', 'user', '', _('record user as commiter')),
2816 2828 ('I', 'include', [], _('include names matching the given patterns')),
2817 2829 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2818 2830 _('hg commit [OPTION]... [FILE]...')),
2819 2831 "copy|cp":
2820 2832 (copy,
2821 2833 [('A', 'after', None, _('record a copy that has already occurred')),
2822 2834 ('f', 'force', None,
2823 2835 _('forcibly copy over an existing managed file')),
2824 2836 ('I', 'include', [], _('include names matching the given patterns')),
2825 2837 ('X', 'exclude', [], _('exclude names matching the given patterns')),
2826 2838 ('n', 'dry-run', None, _('do not perform actions, just print output'))],
2827 2839 _('hg copy [OPTION]... [SOURCE]... DEST')),
2828 2840 "debugancestor": (debugancestor, [], _('debugancestor INDEX REV1 REV2')),
2829 2841 "debugcomplete":
2830 2842 (debugcomplete,
2831 2843 [('o', 'options', None, _('show the command options'))],
2832 2844 _('debugcomplete [-o] CMD')),
2833 2845 "debugrebuildstate":
2834 2846 (debugrebuildstate,
2835 2847 [('r', 'rev', '', _('revision to rebuild to'))],
2836 2848 _('debugrebuildstate [-r REV] [REV]')),
2837 2849 "debugcheckstate": (debugcheckstate, [], _('debugcheckstate')),
2838 2850 "debugconfig": (debugconfig, [], _('debugconfig [NAME]...')),
2839 2851 "debugsetparents": (debugsetparents, [], _('debugsetparents REV1 [REV2]')),
2840 2852 "debugstate": (debugstate, [], _('debugstate')),
2841 2853 "debugdata": (debugdata, [], _('debugdata FILE REV')),
2842 2854 "debugindex": (debugindex, [], _('debugindex FILE')),
2843 2855 "debugindexdot": (debugindexdot, [], _('debugindexdot FILE')),
2844 2856 "debugrename": (debugrename, [], _('debugrename FILE [REV]')),
2845 2857 "debugwalk":
2846 2858 (debugwalk,
2847 2859 [('I', 'include', [], _('include names matching the given patterns')),
2848 2860 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2849 2861 _('debugwalk [OPTION]... [FILE]...')),
2850 2862 "^diff":
2851 2863 (diff,
2852 2864 [('r', 'rev', [], _('revision')),
2853 2865 ('a', 'text', None, _('treat all files as text')),
2854 2866 ('p', 'show-function', None,
2855 2867 _('show which function each change is in')),
2856 2868 ('g', 'git', None, _('use git extended diff format')),
2857 2869 ('w', 'ignore-all-space', None,
2858 2870 _('ignore white space when comparing lines')),
2859 2871 ('b', 'ignore-space-change', None,
2860 2872 _('ignore changes in the amount of white space')),
2861 2873 ('B', 'ignore-blank-lines', None,
2862 2874 _('ignore changes whose lines are all blank')),
2863 2875 ('I', 'include', [], _('include names matching the given patterns')),
2864 2876 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2865 2877 _('hg diff [-a] [-I] [-X] [-r REV1 [-r REV2]] [FILE]...')),
2866 2878 "^export":
2867 2879 (export,
2868 2880 [('o', 'output', '', _('print output to file with formatted name')),
2869 2881 ('a', 'text', None, _('treat all files as text')),
2870 2882 ('', 'switch-parent', None, _('diff against the second parent'))],
2871 2883 _('hg export [-a] [-o OUTFILESPEC] REV...')),
2872 2884 "debugforget|forget":
2873 2885 (forget,
2874 2886 [('I', 'include', [], _('include names matching the given patterns')),
2875 2887 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2876 2888 _('hg forget [OPTION]... FILE...')),
2877 2889 "grep":
2878 2890 (grep,
2879 2891 [('0', 'print0', None, _('end fields with NUL')),
2880 2892 ('', 'all', None, _('print all revisions that match')),
2881 2893 ('f', 'follow', None,
2882 2894 _('follow changeset history, or file history across copies and renames')),
2883 2895 ('i', 'ignore-case', None, _('ignore case when matching')),
2884 2896 ('l', 'files-with-matches', None,
2885 2897 _('print only filenames and revs that match')),
2886 2898 ('n', 'line-number', None, _('print matching line numbers')),
2887 2899 ('r', 'rev', [], _('search in given revision range')),
2888 2900 ('u', 'user', None, _('print user who committed change')),
2889 2901 ('I', 'include', [], _('include names matching the given patterns')),
2890 2902 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2891 2903 _('hg grep [OPTION]... PATTERN [FILE]...')),
2892 2904 "heads":
2893 2905 (heads,
2894 2906 [('b', 'branches', None, _('show branches')),
2895 2907 ('', 'style', '', _('display using template map file')),
2896 2908 ('r', 'rev', '', _('show only heads which are descendants of rev')),
2897 2909 ('', 'template', '', _('display with template'))],
2898 2910 _('hg heads [-b] [-r <rev>]')),
2899 2911 "help": (help_, [], _('hg help [COMMAND]')),
2900 2912 "identify|id": (identify, [], _('hg identify')),
2901 2913 "import|patch":
2902 2914 (import_,
2903 2915 [('p', 'strip', 1,
2904 2916 _('directory strip option for patch. This has the same\n'
2905 2917 'meaning as the corresponding patch option')),
2906 2918 ('m', 'message', '', _('use <text> as commit message')),
2907 2919 ('b', 'base', '', _('base path')),
2908 2920 ('f', 'force', None,
2909 2921 _('skip check for outstanding uncommitted changes'))],
2910 2922 _('hg import [-p NUM] [-b BASE] [-m MESSAGE] [-f] PATCH...')),
2911 2923 "incoming|in": (incoming,
2912 2924 [('M', 'no-merges', None, _('do not show merges')),
2913 2925 ('f', 'force', None,
2914 2926 _('run even when remote repository is unrelated')),
2915 2927 ('', 'style', '', _('display using template map file')),
2916 2928 ('n', 'newest-first', None, _('show newest record first')),
2917 2929 ('', 'bundle', '', _('file to store the bundles into')),
2918 2930 ('p', 'patch', None, _('show patch')),
2919 2931 ('r', 'rev', [], _('a specific revision up to which you would like to pull')),
2920 2932 ('', 'template', '', _('display with template')),
2921 2933 ('e', 'ssh', '', _('specify ssh command to use')),
2922 2934 ('', 'remotecmd', '',
2923 2935 _('specify hg command to run on the remote side'))],
2924 2936 _('hg incoming [-p] [-n] [-M] [-r REV]...'
2925 2937 ' [--bundle FILENAME] [SOURCE]')),
2926 2938 "^init":
2927 2939 (init,
2928 2940 [('e', 'ssh', '', _('specify ssh command to use')),
2929 2941 ('', 'remotecmd', '',
2930 2942 _('specify hg command to run on the remote side'))],
2931 2943 _('hg init [-e FILE] [--remotecmd FILE] [DEST]')),
2932 2944 "locate":
2933 2945 (locate,
2934 2946 [('r', 'rev', '', _('search the repository as it stood at rev')),
2935 2947 ('0', 'print0', None,
2936 2948 _('end filenames with NUL, for use with xargs')),
2937 2949 ('f', 'fullpath', None,
2938 2950 _('print complete paths from the filesystem root')),
2939 2951 ('I', 'include', [], _('include names matching the given patterns')),
2940 2952 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2941 2953 _('hg locate [OPTION]... [PATTERN]...')),
2942 2954 "^log|history":
2943 2955 (log,
2944 2956 [('b', 'branches', None, _('show branches')),
2945 2957 ('f', 'follow', None,
2946 2958 _('follow changeset history, or file history across copies and renames')),
2947 2959 ('', 'follow-first', None,
2948 2960 _('only follow the first parent of merge changesets')),
2949 2961 ('k', 'keyword', [], _('search for a keyword')),
2950 2962 ('l', 'limit', '', _('limit number of changes displayed')),
2951 2963 ('r', 'rev', [], _('show the specified revision or range')),
2952 2964 ('M', 'no-merges', None, _('do not show merges')),
2953 2965 ('', 'style', '', _('display using template map file')),
2954 2966 ('m', 'only-merges', None, _('show only merges')),
2955 2967 ('p', 'patch', None, _('show patch')),
2956 2968 ('P', 'prune', [], _('do not display revision or any of its ancestors')),
2957 2969 ('', 'template', '', _('display with template')),
2958 2970 ('I', 'include', [], _('include names matching the given patterns')),
2959 2971 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
2960 2972 _('hg log [OPTION]... [FILE]')),
2961 2973 "manifest": (manifest, [], _('hg manifest [REV]')),
2962 2974 "merge":
2963 2975 (merge,
2964 2976 [('b', 'branch', '', _('merge with head of a specific branch')),
2965 2977 ('f', 'force', None, _('force a merge with outstanding changes'))],
2966 2978 _('hg merge [-b TAG] [-f] [REV]')),
2967 2979 "outgoing|out": (outgoing,
2968 2980 [('M', 'no-merges', None, _('do not show merges')),
2969 2981 ('f', 'force', None,
2970 2982 _('run even when remote repository is unrelated')),
2971 2983 ('p', 'patch', None, _('show patch')),
2972 2984 ('', 'style', '', _('display using template map file')),
2973 2985 ('r', 'rev', [], _('a specific revision you would like to push')),
2974 2986 ('n', 'newest-first', None, _('show newest record first')),
2975 2987 ('', 'template', '', _('display with template')),
2976 2988 ('e', 'ssh', '', _('specify ssh command to use')),
2977 2989 ('', 'remotecmd', '',
2978 2990 _('specify hg command to run on the remote side'))],
2979 2991 _('hg outgoing [-M] [-p] [-n] [-r REV]... [DEST]')),
2980 2992 "^parents":
2981 2993 (parents,
2982 2994 [('b', 'branches', None, _('show branches')),
2983 2995 ('r', 'rev', '', _('show parents from the specified rev')),
2984 2996 ('', 'style', '', _('display using template map file')),
2985 2997 ('', 'template', '', _('display with template'))],
2986 2998 _('hg parents [-b] [-r REV] [FILE]')),
2987 2999 "paths": (paths, [], _('hg paths [NAME]')),
2988 3000 "^pull":
2989 3001 (pull,
2990 3002 [('u', 'update', None,
2991 3003 _('update the working directory to tip after pull')),
2992 3004 ('e', 'ssh', '', _('specify ssh command to use')),
2993 3005 ('f', 'force', None,
2994 3006 _('run even when remote repository is unrelated')),
2995 3007 ('r', 'rev', [], _('a specific revision up to which you would like to pull')),
2996 3008 ('', 'remotecmd', '',
2997 3009 _('specify hg command to run on the remote side'))],
2998 3010 _('hg pull [-u] [-r REV]... [-e FILE] [--remotecmd FILE] [SOURCE]')),
2999 3011 "^push":
3000 3012 (push,
3001 3013 [('f', 'force', None, _('force push')),
3002 3014 ('e', 'ssh', '', _('specify ssh command to use')),
3003 3015 ('r', 'rev', [], _('a specific revision you would like to push')),
3004 3016 ('', 'remotecmd', '',
3005 3017 _('specify hg command to run on the remote side'))],
3006 3018 _('hg push [-f] [-r REV]... [-e FILE] [--remotecmd FILE] [DEST]')),
3007 3019 "debugrawcommit|rawcommit":
3008 3020 (rawcommit,
3009 3021 [('p', 'parent', [], _('parent')),
3010 3022 ('d', 'date', '', _('date code')),
3011 3023 ('u', 'user', '', _('user')),
3012 3024 ('F', 'files', '', _('file list')),
3013 3025 ('m', 'message', '', _('commit message')),
3014 3026 ('l', 'logfile', '', _('commit message file'))],
3015 3027 _('hg debugrawcommit [OPTION]... [FILE]...')),
3016 3028 "recover": (recover, [], _('hg recover')),
3017 3029 "^remove|rm":
3018 3030 (remove,
3019 3031 [('A', 'after', None, _('record remove that has already occurred')),
3020 3032 ('f', 'force', None, _('remove file even if modified')),
3021 3033 ('I', 'include', [], _('include names matching the given patterns')),
3022 3034 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
3023 3035 _('hg remove [OPTION]... FILE...')),
3024 3036 "rename|mv":
3025 3037 (rename,
3026 3038 [('A', 'after', None, _('record a rename that has already occurred')),
3027 3039 ('f', 'force', None,
3028 3040 _('forcibly copy over an existing managed file')),
3029 3041 ('I', 'include', [], _('include names matching the given patterns')),
3030 3042 ('X', 'exclude', [], _('exclude names matching the given patterns')),
3031 3043 ('n', 'dry-run', None, _('do not perform actions, just print output'))],
3032 3044 _('hg rename [OPTION]... SOURCE... DEST')),
3033 3045 "^revert":
3034 3046 (revert,
3035 3047 [('r', 'rev', '', _('revision to revert to')),
3036 3048 ('', 'no-backup', None, _('do not save backup copies of files')),
3037 3049 ('I', 'include', [], _('include names matching given patterns')),
3038 3050 ('X', 'exclude', [], _('exclude names matching given patterns')),
3039 3051 ('n', 'dry-run', None, _('do not perform actions, just print output'))],
3040 3052 _('hg revert [-r REV] [NAME]...')),
3041 3053 "rollback": (rollback, [], _('hg rollback')),
3042 3054 "root": (root, [], _('hg root')),
3043 3055 "^serve":
3044 3056 (serve,
3045 3057 [('A', 'accesslog', '', _('name of access log file to write to')),
3046 3058 ('d', 'daemon', None, _('run server in background')),
3047 3059 ('', 'daemon-pipefds', '', _('used internally by daemon mode')),
3048 3060 ('E', 'errorlog', '', _('name of error log file to write to')),
3049 3061 ('p', 'port', 0, _('port to use (default: 8000)')),
3050 3062 ('a', 'address', '', _('address to use')),
3051 3063 ('n', 'name', '',
3052 3064 _('name to show in web pages (default: working dir)')),
3053 3065 ('', 'webdir-conf', '', _('name of the webdir config file'
3054 3066 ' (serve more than one repo)')),
3055 3067 ('', 'pid-file', '', _('name of file to write process ID to')),
3056 3068 ('', 'stdio', None, _('for remote clients')),
3057 3069 ('t', 'templates', '', _('web templates to use')),
3058 3070 ('', 'style', '', _('template style to use')),
3059 3071 ('6', 'ipv6', None, _('use IPv6 in addition to IPv4'))],
3060 3072 _('hg serve [OPTION]...')),
3061 3073 "^status|st":
3062 3074 (status,
3063 3075 [('A', 'all', None, _('show status of all files')),
3064 3076 ('m', 'modified', None, _('show only modified files')),
3065 3077 ('a', 'added', None, _('show only added files')),
3066 3078 ('r', 'removed', None, _('show only removed files')),
3067 3079 ('d', 'deleted', None, _('show only deleted (but tracked) files')),
3068 3080 ('c', 'clean', None, _('show only files without changes')),
3069 3081 ('u', 'unknown', None, _('show only unknown (not tracked) files')),
3070 3082 ('i', 'ignored', None, _('show ignored files')),
3071 3083 ('n', 'no-status', None, _('hide status prefix')),
3072 3084 ('C', 'copies', None, _('show source of copied files')),
3073 3085 ('0', 'print0', None,
3074 3086 _('end filenames with NUL, for use with xargs')),
3075 3087 ('I', 'include', [], _('include names matching the given patterns')),
3076 3088 ('X', 'exclude', [], _('exclude names matching the given patterns'))],
3077 3089 _('hg status [OPTION]... [FILE]...')),
3078 3090 "tag":
3079 3091 (tag,
3080 3092 [('l', 'local', None, _('make the tag local')),
3081 3093 ('m', 'message', '', _('message for tag commit log entry')),
3082 3094 ('d', 'date', '', _('record datecode as commit date')),
3083 3095 ('u', 'user', '', _('record user as commiter')),
3084 3096 ('r', 'rev', '', _('revision to tag'))],
3085 3097 _('hg tag [-l] [-m TEXT] [-d DATE] [-u USER] [-r REV] NAME')),
3086 3098 "tags": (tags, [], _('hg tags')),
3087 3099 "tip":
3088 3100 (tip,
3089 3101 [('b', 'branches', None, _('show branches')),
3090 3102 ('', 'style', '', _('display using template map file')),
3091 3103 ('p', 'patch', None, _('show patch')),
3092 3104 ('', 'template', '', _('display with template'))],
3093 3105 _('hg tip [-b] [-p]')),
3094 3106 "unbundle":
3095 3107 (unbundle,
3096 3108 [('u', 'update', None,
3097 3109 _('update the working directory to tip after unbundle'))],
3098 3110 _('hg unbundle [-u] FILE')),
3099 3111 "debugundo|undo": (undo, [], _('hg undo')),
3100 3112 "^update|up|checkout|co":
3101 3113 (update,
3102 3114 [('b', 'branch', '', _('checkout the head of a specific branch')),
3103 3115 ('m', 'merge', None, _('allow merging of branches (DEPRECATED)')),
3104 3116 ('C', 'clean', None, _('overwrite locally modified files')),
3105 3117 ('f', 'force', None, _('force a merge with outstanding changes'))],
3106 3118 _('hg update [-b TAG] [-m] [-C] [-f] [REV]')),
3107 3119 "verify": (verify, [], _('hg verify')),
3108 3120 "version": (show_version, [], _('hg version')),
3109 3121 }
3110 3122
3111 3123 globalopts = [
3112 3124 ('R', 'repository', '',
3113 3125 _('repository root directory or symbolic path name')),
3114 3126 ('', 'cwd', '', _('change working directory')),
3115 3127 ('y', 'noninteractive', None,
3116 3128 _('do not prompt, assume \'yes\' for any required answers')),
3117 3129 ('q', 'quiet', None, _('suppress output')),
3118 3130 ('v', 'verbose', None, _('enable additional output')),
3119 3131 ('', 'config', [], _('set/override config option')),
3120 3132 ('', 'debug', None, _('enable debugging output')),
3121 3133 ('', 'debugger', None, _('start debugger')),
3122 3134 ('', 'lsprof', None, _('print improved command execution profile')),
3123 3135 ('', 'traceback', None, _('print traceback on exception')),
3124 3136 ('', 'time', None, _('time how long the command takes')),
3125 3137 ('', 'profile', None, _('print command execution profile')),
3126 3138 ('', 'version', None, _('output version information and exit')),
3127 3139 ('h', 'help', None, _('display help and exit')),
3128 3140 ]
3129 3141
3130 3142 norepo = ("clone init version help debugancestor debugcomplete debugdata"
3131 3143 " debugindex debugindexdot")
3132 3144 optionalrepo = ("paths serve debugconfig")
3133 3145
3134 3146 def findpossible(cmd):
3135 3147 """
3136 3148 Return cmd -> (aliases, command table entry)
3137 3149 for each matching command.
3138 3150 Return debug commands (or their aliases) only if no normal command matches.
3139 3151 """
3140 3152 choice = {}
3141 3153 debugchoice = {}
3142 3154 for e in table.keys():
3143 3155 aliases = e.lstrip("^").split("|")
3144 3156 found = None
3145 3157 if cmd in aliases:
3146 3158 found = cmd
3147 3159 else:
3148 3160 for a in aliases:
3149 3161 if a.startswith(cmd):
3150 3162 found = a
3151 3163 break
3152 3164 if found is not None:
3153 3165 if aliases[0].startswith("debug"):
3154 3166 debugchoice[found] = (aliases, table[e])
3155 3167 else:
3156 3168 choice[found] = (aliases, table[e])
3157 3169
3158 3170 if not choice and debugchoice:
3159 3171 choice = debugchoice
3160 3172
3161 3173 return choice
3162 3174
3163 3175 def findcmd(cmd):
3164 3176 """Return (aliases, command table entry) for command string."""
3165 3177 choice = findpossible(cmd)
3166 3178
3167 3179 if choice.has_key(cmd):
3168 3180 return choice[cmd]
3169 3181
3170 3182 if len(choice) > 1:
3171 3183 clist = choice.keys()
3172 3184 clist.sort()
3173 3185 raise AmbiguousCommand(cmd, clist)
3174 3186
3175 3187 if choice:
3176 3188 return choice.values()[0]
3177 3189
3178 3190 raise UnknownCommand(cmd)
3179 3191
3180 3192 def catchterm(*args):
3181 3193 raise util.SignalInterrupt
3182 3194
3183 3195 def run():
3184 3196 sys.exit(dispatch(sys.argv[1:]))
3185 3197
3186 3198 class ParseError(Exception):
3187 3199 """Exception raised on errors in parsing the command line."""
3188 3200
3189 3201 def parse(ui, args):
3190 3202 options = {}
3191 3203 cmdoptions = {}
3192 3204
3193 3205 try:
3194 3206 args = fancyopts.fancyopts(args, globalopts, options)
3195 3207 except fancyopts.getopt.GetoptError, inst:
3196 3208 raise ParseError(None, inst)
3197 3209
3198 3210 if args:
3199 3211 cmd, args = args[0], args[1:]
3200 3212 aliases, i = findcmd(cmd)
3201 3213 cmd = aliases[0]
3202 3214 defaults = ui.config("defaults", cmd)
3203 3215 if defaults:
3204 3216 args = defaults.split() + args
3205 3217 c = list(i[1])
3206 3218 else:
3207 3219 cmd = None
3208 3220 c = []
3209 3221
3210 3222 # combine global options into local
3211 3223 for o in globalopts:
3212 3224 c.append((o[0], o[1], options[o[1]], o[3]))
3213 3225
3214 3226 try:
3215 3227 args = fancyopts.fancyopts(args, c, cmdoptions)
3216 3228 except fancyopts.getopt.GetoptError, inst:
3217 3229 raise ParseError(cmd, inst)
3218 3230
3219 3231 # separate global options back out
3220 3232 for o in globalopts:
3221 3233 n = o[1]
3222 3234 options[n] = cmdoptions[n]
3223 3235 del cmdoptions[n]
3224 3236
3225 3237 return (cmd, cmd and i[0] or None, args, options, cmdoptions)
3226 3238
3227 3239 external = {}
3228 3240
3229 3241 def findext(name):
3230 3242 '''return module with given extension name'''
3231 3243 try:
3232 3244 return sys.modules[external[name]]
3233 3245 except KeyError:
3234 3246 for k, v in external.iteritems():
3235 3247 if k.endswith('.' + name) or k.endswith('/' + name) or v == name:
3236 3248 return sys.modules[v]
3237 3249 raise KeyError(name)
3238 3250
3239 3251 def load_extensions(ui):
3240 3252 added = []
3241 3253 for ext_name, load_from_name in ui.extensions():
3242 3254 if ext_name in external:
3243 3255 continue
3244 3256 try:
3245 3257 if load_from_name:
3246 3258 # the module will be loaded in sys.modules
3247 3259 # choose an unique name so that it doesn't
3248 3260 # conflicts with other modules
3249 3261 module_name = "hgext_%s" % ext_name.replace('.', '_')
3250 3262 mod = imp.load_source(module_name, load_from_name)
3251 3263 else:
3252 3264 def importh(name):
3253 3265 mod = __import__(name)
3254 3266 components = name.split('.')
3255 3267 for comp in components[1:]:
3256 3268 mod = getattr(mod, comp)
3257 3269 return mod
3258 3270 try:
3259 3271 mod = importh("hgext.%s" % ext_name)
3260 3272 except ImportError:
3261 3273 mod = importh(ext_name)
3262 3274 external[ext_name] = mod.__name__
3263 3275 added.append((mod, ext_name))
3264 3276 except (util.SignalInterrupt, KeyboardInterrupt):
3265 3277 raise
3266 3278 except Exception, inst:
3267 3279 ui.warn(_("*** failed to import extension %s: %s\n") %
3268 3280 (ext_name, inst))
3269 3281 if ui.print_exc():
3270 3282 return 1
3271 3283
3272 3284 for mod, name in added:
3273 3285 uisetup = getattr(mod, 'uisetup', None)
3274 3286 if uisetup:
3275 3287 uisetup(ui)
3276 3288 cmdtable = getattr(mod, 'cmdtable', {})
3277 3289 for t in cmdtable:
3278 3290 if t in table:
3279 3291 ui.warn(_("module %s overrides %s\n") % (name, t))
3280 3292 table.update(cmdtable)
3281 3293
3282 3294 def dispatch(args):
3283 3295 for name in 'SIGBREAK', 'SIGHUP', 'SIGTERM':
3284 3296 num = getattr(signal, name, None)
3285 3297 if num: signal.signal(num, catchterm)
3286 3298
3287 3299 try:
3288 3300 u = ui.ui(traceback='--traceback' in sys.argv[1:],
3289 3301 readhooks=[load_extensions])
3290 3302 except util.Abort, inst:
3291 3303 sys.stderr.write(_("abort: %s\n") % inst)
3292 3304 return -1
3293 3305
3294 3306 try:
3295 3307 cmd, func, args, options, cmdoptions = parse(u, args)
3296 3308 if options["time"]:
3297 3309 def get_times():
3298 3310 t = os.times()
3299 3311 if t[4] == 0.0: # Windows leaves this as zero, so use time.clock()
3300 3312 t = (t[0], t[1], t[2], t[3], time.clock())
3301 3313 return t
3302 3314 s = get_times()
3303 3315 def print_time():
3304 3316 t = get_times()
3305 3317 u.warn(_("Time: real %.3f secs (user %.3f+%.3f sys %.3f+%.3f)\n") %
3306 3318 (t[4]-s[4], t[0]-s[0], t[2]-s[2], t[1]-s[1], t[3]-s[3]))
3307 3319 atexit.register(print_time)
3308 3320
3309 3321 u.updateopts(options["verbose"], options["debug"], options["quiet"],
3310 3322 not options["noninteractive"], options["traceback"],
3311 3323 options["config"])
3312 3324
3313 3325 # enter the debugger before command execution
3314 3326 if options['debugger']:
3315 3327 pdb.set_trace()
3316 3328
3317 3329 try:
3318 3330 if options['cwd']:
3319 3331 try:
3320 3332 os.chdir(options['cwd'])
3321 3333 except OSError, inst:
3322 3334 raise util.Abort('%s: %s' %
3323 3335 (options['cwd'], inst.strerror))
3324 3336
3325 3337 path = u.expandpath(options["repository"]) or ""
3326 3338 repo = path and hg.repository(u, path=path) or None
3327 3339
3328 3340 if options['help']:
3329 3341 return help_(u, cmd, options['version'])
3330 3342 elif options['version']:
3331 3343 return show_version(u)
3332 3344 elif not cmd:
3333 3345 return help_(u, 'shortlist')
3334 3346
3335 3347 if cmd not in norepo.split():
3336 3348 try:
3337 3349 if not repo:
3338 3350 repo = hg.repository(u, path=path)
3339 3351 u = repo.ui
3340 3352 for name in external.itervalues():
3341 3353 mod = sys.modules[name]
3342 3354 if hasattr(mod, 'reposetup'):
3343 3355 mod.reposetup(u, repo)
3344 3356 hg.repo_setup_hooks.append(mod.reposetup)
3345 3357 except hg.RepoError:
3346 3358 if cmd not in optionalrepo.split():
3347 3359 raise
3348 3360 d = lambda: func(u, repo, *args, **cmdoptions)
3349 3361 else:
3350 3362 d = lambda: func(u, *args, **cmdoptions)
3351 3363
3352 3364 # reupdate the options, repo/.hg/hgrc may have changed them
3353 3365 u.updateopts(options["verbose"], options["debug"], options["quiet"],
3354 3366 not options["noninteractive"], options["traceback"],
3355 3367 options["config"])
3356 3368
3357 3369 try:
3358 3370 if options['profile']:
3359 3371 import hotshot, hotshot.stats
3360 3372 prof = hotshot.Profile("hg.prof")
3361 3373 try:
3362 3374 try:
3363 3375 return prof.runcall(d)
3364 3376 except:
3365 3377 try:
3366 3378 u.warn(_('exception raised - generating '
3367 3379 'profile anyway\n'))
3368 3380 except:
3369 3381 pass
3370 3382 raise
3371 3383 finally:
3372 3384 prof.close()
3373 3385 stats = hotshot.stats.load("hg.prof")
3374 3386 stats.strip_dirs()
3375 3387 stats.sort_stats('time', 'calls')
3376 3388 stats.print_stats(40)
3377 3389 elif options['lsprof']:
3378 3390 try:
3379 3391 from mercurial import lsprof
3380 3392 except ImportError:
3381 3393 raise util.Abort(_(
3382 3394 'lsprof not available - install from '
3383 3395 'http://codespeak.net/svn/user/arigo/hack/misc/lsprof/'))
3384 3396 p = lsprof.Profiler()
3385 3397 p.enable(subcalls=True)
3386 3398 try:
3387 3399 return d()
3388 3400 finally:
3389 3401 p.disable()
3390 3402 stats = lsprof.Stats(p.getstats())
3391 3403 stats.sort()
3392 3404 stats.pprint(top=10, file=sys.stderr, climit=5)
3393 3405 else:
3394 3406 return d()
3395 3407 finally:
3396 3408 u.flush()
3397 3409 except:
3398 3410 # enter the debugger when we hit an exception
3399 3411 if options['debugger']:
3400 3412 pdb.post_mortem(sys.exc_info()[2])
3401 3413 u.print_exc()
3402 3414 raise
3403 3415 except ParseError, inst:
3404 3416 if inst.args[0]:
3405 3417 u.warn(_("hg %s: %s\n") % (inst.args[0], inst.args[1]))
3406 3418 help_(u, inst.args[0])
3407 3419 else:
3408 3420 u.warn(_("hg: %s\n") % inst.args[1])
3409 3421 help_(u, 'shortlist')
3410 3422 except AmbiguousCommand, inst:
3411 3423 u.warn(_("hg: command '%s' is ambiguous:\n %s\n") %
3412 3424 (inst.args[0], " ".join(inst.args[1])))
3413 3425 except UnknownCommand, inst:
3414 3426 u.warn(_("hg: unknown command '%s'\n") % inst.args[0])
3415 3427 help_(u, 'shortlist')
3416 3428 except hg.RepoError, inst:
3417 3429 u.warn(_("abort: %s!\n") % inst)
3418 3430 except lock.LockHeld, inst:
3419 3431 if inst.errno == errno.ETIMEDOUT:
3420 3432 reason = _('timed out waiting for lock held by %s') % inst.locker
3421 3433 else:
3422 3434 reason = _('lock held by %s') % inst.locker
3423 3435 u.warn(_("abort: %s: %s\n") % (inst.desc or inst.filename, reason))
3424 3436 except lock.LockUnavailable, inst:
3425 3437 u.warn(_("abort: could not lock %s: %s\n") %
3426 3438 (inst.desc or inst.filename, inst.strerror))
3427 3439 except revlog.RevlogError, inst:
3428 3440 u.warn(_("abort: "), inst, "!\n")
3429 3441 except util.SignalInterrupt:
3430 3442 u.warn(_("killed!\n"))
3431 3443 except KeyboardInterrupt:
3432 3444 try:
3433 3445 u.warn(_("interrupted!\n"))
3434 3446 except IOError, inst:
3435 3447 if inst.errno == errno.EPIPE:
3436 3448 if u.debugflag:
3437 3449 u.warn(_("\nbroken pipe\n"))
3438 3450 else:
3439 3451 raise
3440 3452 except IOError, inst:
3441 3453 if hasattr(inst, "code"):
3442 3454 u.warn(_("abort: %s\n") % inst)
3443 3455 elif hasattr(inst, "reason"):
3444 3456 u.warn(_("abort: error: %s\n") % inst.reason[1])
3445 3457 elif hasattr(inst, "args") and inst[0] == errno.EPIPE:
3446 3458 if u.debugflag:
3447 3459 u.warn(_("broken pipe\n"))
3448 3460 elif getattr(inst, "strerror", None):
3449 3461 if getattr(inst, "filename", None):
3450 3462 u.warn(_("abort: %s - %s\n") % (inst.strerror, inst.filename))
3451 3463 else:
3452 3464 u.warn(_("abort: %s\n") % inst.strerror)
3453 3465 else:
3454 3466 raise
3455 3467 except OSError, inst:
3456 3468 if hasattr(inst, "filename"):
3457 3469 u.warn(_("abort: %s: %s\n") % (inst.strerror, inst.filename))
3458 3470 else:
3459 3471 u.warn(_("abort: %s\n") % inst.strerror)
3460 3472 except util.Abort, inst:
3461 3473 u.warn(_('abort: '), inst.args[0] % inst.args[1:], '\n')
3462 3474 except TypeError, inst:
3463 3475 # was this an argument error?
3464 3476 tb = traceback.extract_tb(sys.exc_info()[2])
3465 3477 if len(tb) > 2: # no
3466 3478 raise
3467 3479 u.debug(inst, "\n")
3468 3480 u.warn(_("%s: invalid arguments\n") % cmd)
3469 3481 help_(u, cmd)
3470 3482 except SystemExit, inst:
3471 3483 # Commands shouldn't sys.exit directly, but give a return code.
3472 3484 # Just in case catch this and and pass exit code to caller.
3473 3485 return inst.code
3474 3486 except:
3475 3487 u.warn(_("** unknown exception encountered, details follow\n"))
3476 3488 u.warn(_("** report bug details to "
3477 3489 "http://www.selenic.com/mercurial/bts\n"))
3478 3490 u.warn(_("** or mercurial@selenic.com\n"))
3479 3491 u.warn(_("** Mercurial Distributed SCM (version %s)\n")
3480 3492 % version.get_version())
3481 3493 raise
3482 3494
3483 3495 return -1
@@ -1,12 +1,26 b''
1 1 #!/bin/sh
2 2
3 3 hg init rep
4 4 cd rep
5 5 mkdir dir
6 6 touch foo dir/bar
7 7 hg -v addremove
8 8 hg -v commit -m "add 1" -d "1000000 0"
9 9 cd dir/
10 10 touch ../foo_2 bar_2
11 11 hg -v addremove
12 12 hg -v commit -m "add 2" -d "1000000 0"
13
14 cd ..
15 hg init sim
16 cd sim
17 echo a > a
18 echo a >> a
19 echo a >> a
20 echo c > c
21 hg commit -Ama
22 mv a b
23 rm c
24 echo d > d
25 hg addremove -s 0.5
26 hg commit -mb
@@ -1,8 +1,15 b''
1 1 adding dir/bar
2 2 adding foo
3 3 dir/bar
4 4 foo
5 5 adding dir/bar_2
6 6 adding foo_2
7 7 dir/bar_2
8 8 foo_2
9 adding a
10 adding c
11 adding b
12 adding d
13 removing a
14 removing c
15 recording removal of a as rename to b (100% similar)
General Comments 0
You need to be logged in to leave comments. Login now