| pulkit |
| hg-reviewers |
If we want to use this in a loop, we need to be able to pass argument.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| if not o: | if not o: | ||||
| scmutil.nochangesfound(repo.ui, repo, outgoing.excluded) | scmutil.nochangesfound(repo.ui, repo, outgoing.excluded) | ||||
| return o, other | return o, other | ||||
| except: # re-raises | except: # re-raises | ||||
| other.close() | other.close() | ||||
| raise | raise | ||||
| def outgoing(ui, repo, dest, opts): | def _outgoing_recurse(ui, repo, dest, opts): | ||||
| def recurse(): | |||||
| ret = 1 | ret = 1 | ||||
| if opts.get(b'subrepos'): | if opts.get(b'subrepos'): | ||||
| ctx = repo[None] | ctx = repo[None] | ||||
| for subpath in sorted(ctx.substate): | for subpath in sorted(ctx.substate): | ||||
| sub = ctx.sub(subpath) | sub = ctx.sub(subpath) | ||||
| ret = min(ret, sub.outgoing(ui, dest, opts)) | ret = min(ret, sub.outgoing(ui, dest, opts)) | ||||
| return ret | return ret | ||||
| def outgoing(ui, repo, dest, opts): | |||||
| limit = logcmdutil.getlimit(opts) | limit = logcmdutil.getlimit(opts) | ||||
| o, other = _outgoing(ui, repo, dest, opts) | o, other = _outgoing(ui, repo, dest, opts) | ||||
| ret = 1 | ret = 1 | ||||
| try: | try: | ||||
| if o: | if o: | ||||
| ret = 0 | ret = 0 | ||||
| if opts.get(b'newest_first'): | if opts.get(b'newest_first'): | ||||
| o.reverse() | o.reverse() | ||||
| ui.pager(b'outgoing') | ui.pager(b'outgoing') | ||||
| displayer = logcmdutil.changesetdisplayer(ui, repo, opts) | displayer = logcmdutil.changesetdisplayer(ui, repo, opts) | ||||
| count = 0 | count = 0 | ||||
| for n in o: | for n in o: | ||||
| if limit is not None and count >= limit: | if limit is not None and count >= limit: | ||||
| break | break | ||||
| parents = [p for p in repo.changelog.parents(n) if p != nullid] | parents = [p for p in repo.changelog.parents(n) if p != nullid] | ||||
| if opts.get(b'no_merges') and len(parents) == 2: | if opts.get(b'no_merges') and len(parents) == 2: | ||||
| continue | continue | ||||
| count += 1 | count += 1 | ||||
| displayer.show(repo[n]) | displayer.show(repo[n]) | ||||
| displayer.close() | displayer.close() | ||||
| cmdutil.outgoinghooks(ui, repo, other, opts, o) | cmdutil.outgoinghooks(ui, repo, other, opts, o) | ||||
| ret = min(ret, recurse()) | ret = min(ret, _outgoing_recurse(ui, repo, dest, opts)) | ||||
| return ret # exit code is zero since we found outgoing changes | return ret # exit code is zero since we found outgoing changes | ||||
| finally: | finally: | ||||
| other.close() | other.close() | ||||
| def verify(repo, level=None): | def verify(repo, level=None): | ||||
| """verify the consistency of a repository""" | """verify the consistency of a repository""" | ||||
| ret = verifymod.verify(repo, level=level) | ret = verifymod.verify(repo, level=level) | ||||