410 

   411 def incoming(ui, repo, source, opts):

   412     limit = cmdutil.loglimit(opts)

   413     source, branches = parseurl(ui.expandpath(source), opts.get('branch'))

   414     other = repository(remoteui(repo, opts), source)

   415     ui.status(_('comparing with %s\n') % url.hidepassword(source))

   416     revs, checkout = addbranchrevs(repo, other, branches, opts.get('rev'))

   417     if revs:

   418         revs = [other.lookup(rev) for rev in revs]

   419 

   420     tmp = discovery.findcommonincoming(repo, other, heads=revs,

   421                                        force=opts.get('force'))

   422     common, incoming, rheads = tmp

   423     if not incoming:

   424         try:

   425             os.unlink(opts["bundle"])

   426         except:

   427             pass

   428         ui.status(_("no changes found\n"))

   429         return 1

   430 

   431     cleanup = None

   432     try:

   433         fname = opts["bundle"]

   434         if fname or not other.local():

   435             # create a bundle (uncompressed if other repo is not local)

   436 

   437             if revs is None and other.capable('changegroupsubset'):

   438                 revs = rheads

   439 

   440             if revs is None:

   441                 cg = other.changegroup(incoming, "incoming")

   442             else:

   443                 cg = other.changegroupsubset(incoming, revs, 'incoming')

   444             bundletype = other.local() and "HG10BZ" or "HG10UN"

   445             fname = cleanup = changegroup.writebundle(cg, fname, bundletype)

   446             # keep written bundle?

   447             if opts["bundle"]:

   448                 cleanup = None

   449             if not other.local():

   450                 # use the created uncompressed bundlerepo

   451                 other = bundlerepo.bundlerepository(ui, repo.root, fname)

   452 

   453         o = other.changelog.nodesbetween(incoming, revs)[0]

   454         if opts.get('newest_first'):

   455             o.reverse()

   456         displayer = cmdutil.show_changeset(ui, other, opts)

   457         count = 0

   458         for n in o:

   459             if limit is not None and count >= limit:

   460                 break

   461             parents = [p for p in other.changelog.parents(n) if p != nullid]

   462             if opts.get('no_merges') and len(parents) == 2:

   463                 continue

   464             count += 1

   465             displayer.show(other[n])

   466         displayer.close()

   467     finally:

   468         if hasattr(other, 'close'):

   469             other.close()

   470         if cleanup:

   471             os.unlink(cleanup)