| pulkit |
| hg-reviewers |
This move code dedicated to a single purpose together and make the main code
simpler. Right when we are getting ready to make it more complex :-D
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| 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_filter(repo, revs, opts): | |||||
| """apply revision filtering/ordering option for outgoing""" | |||||
| limit = logcmdutil.getlimit(opts) | |||||
| no_merges = opts.get(b'no_merges') | |||||
| if opts.get(b'newest_first'): | |||||
| revs.reverse() | |||||
| if limit is None and not no_merges: | |||||
| for r in revs: | |||||
| yield r | |||||
| return | |||||
| count = 0 | |||||
| cl = repo.changelog | |||||
| for n in revs: | |||||
| if limit is not None and count >= limit: | |||||
| break | |||||
| parents = [p for p in cl.parents(n) if p != nullid] | |||||
| if no_merges and len(parents) == 2: | |||||
| continue | |||||
| count += 1 | |||||
| yield n | |||||
| def outgoing(ui, repo, dest, opts): | def outgoing(ui, repo, dest, 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'): | |||||
| o.reverse() | |||||
| ui.pager(b'outgoing') | ui.pager(b'outgoing') | ||||
| displayer = logcmdutil.changesetdisplayer(ui, repo, opts) | displayer = logcmdutil.changesetdisplayer(ui, repo, opts) | ||||
| count = 0 | for n in _outgoing_filter(repo, o, opts): | ||||
| for n in o: | |||||
| if limit is not None and count >= limit: | |||||
| break | |||||
| parents = [p for p in repo.changelog.parents(n) if p != nullid] | |||||
| if opts.get(b'no_merges') and len(parents) == 2: | |||||
| continue | |||||
| 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, _outgoing_recurse(ui, repo, dest, opts)) | 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() | ||||