| hg-reviewers |
An upcoming commit will introduce another caller.
| Lint Skipped |
| Unit Tests Skipped |
| # "empty" files and return an error. | # "empty" files and return an error. | ||||
| fl = repo.file(path) | fl = repo.file(path) | ||||
| if not len(fl): | if not len(fl): | ||||
| raise FileAccessError(path, 'unknown file: %s', (path,)) | raise FileAccessError(path, 'unknown file: %s', (path,)) | ||||
| return fl | return fl | ||||
| def emitfilerevisions(revisions, fields): | |||||
| for revision in revisions: | |||||
| d = { | |||||
| b'node': revision.node, | |||||
| } | |||||
| if b'parents' in fields: | |||||
| d[b'parents'] = [revision.p1node, revision.p2node] | |||||
| followingmeta = [] | |||||
| followingdata = [] | |||||
| if b'revision' in fields: | |||||
| if revision.revision is not None: | |||||
| followingmeta.append((b'revision', len(revision.revision))) | |||||
| followingdata.append(revision.revision) | |||||
| else: | |||||
| d[b'deltabasenode'] = revision.basenode | |||||
| followingmeta.append((b'delta', len(revision.delta))) | |||||
| followingdata.append(revision.delta) | |||||
| if followingmeta: | |||||
| d[b'fieldsfollowing'] = followingmeta | |||||
| yield d | |||||
| for extra in followingdata: | |||||
| yield extra | |||||
| @wireprotocommand( | @wireprotocommand( | ||||
| 'filedata', | 'filedata', | ||||
| args={ | args={ | ||||
| 'haveparents': { | 'haveparents': { | ||||
| 'type': 'bool', | 'type': 'bool', | ||||
| 'default': lambda: False, | 'default': lambda: False, | ||||
| 'example': True, | 'example': True, | ||||
| }, | }, | ||||
| revisions = store.emitrevisions(nodes, | revisions = store.emitrevisions(nodes, | ||||
| revisiondata=b'revision' in fields, | revisiondata=b'revision' in fields, | ||||
| assumehaveparentrevisions=haveparents) | assumehaveparentrevisions=haveparents) | ||||
| yield { | yield { | ||||
| b'totalitems': len(nodes), | b'totalitems': len(nodes), | ||||
| } | } | ||||
| for revision in revisions: | for o in emitfilerevisions(revisions, fields): | ||||
| d = { | yield o | ||||
| b'node': revision.node, | |||||
| } | |||||
| if b'parents' in fields: | |||||
| d[b'parents'] = [revision.p1node, revision.p2node] | |||||
| followingmeta = [] | |||||
| followingdata = [] | |||||
| if b'revision' in fields: | |||||
| if revision.revision is not None: | |||||
| followingmeta.append((b'revision', len(revision.revision))) | |||||
| followingdata.append(revision.revision) | |||||
| else: | |||||
| d[b'deltabasenode'] = revision.basenode | |||||
| followingmeta.append((b'delta', len(revision.delta))) | |||||
| followingdata.append(revision.delta) | |||||
| if followingmeta: | |||||
| d[b'fieldsfollowing'] = followingmeta | |||||
| yield d | |||||
| for extra in followingdata: | |||||
| yield extra | |||||
| @wireprotocommand( | @wireprotocommand( | ||||
| 'heads', | 'heads', | ||||
| args={ | args={ | ||||
| 'publiconly': { | 'publiconly': { | ||||
| 'type': 'bool', | 'type': 'bool', | ||||
| 'default': lambda: False, | 'default': lambda: False, | ||||
| 'example': False, | 'example': False, | ||||