equal
deleted
inserted
replaced
1017 except IOError: |
1017 except IOError: |
1018 repo.ui.debug('pullbundle "%s" not accessible\n' % path) |
1018 repo.ui.debug('pullbundle "%s" not accessible\n' % path) |
1019 continue |
1019 continue |
1020 return None |
1020 return None |
1021 |
1021 |
1022 @wireprotocommand('getbundle', '*', permission='pull') |
1022 @wireprotocommand('getbundle', '*', permission='pull', |
|
1023 transportpolicy=POLICY_V1_ONLY) |
1023 def getbundle(repo, proto, others): |
1024 def getbundle(repo, proto, others): |
1024 opts = options('getbundle', gboptsmap.keys(), others) |
1025 opts = options('getbundle', gboptsmap.keys(), others) |
1025 for k, v in opts.iteritems(): |
1026 for k, v in opts.iteritems(): |
1026 keytype = gboptsmap[k] |
1027 keytype = gboptsmap[k] |
1027 if keytype == 'nodes': |
1028 if keytype == 'nodes': |
1176 it is serving. Client checks to see if it understands the format. |
1177 it is serving. Client checks to see if it understands the format. |
1177 ''' |
1178 ''' |
1178 return wireprototypes.streamreslegacy( |
1179 return wireprototypes.streamreslegacy( |
1179 streamclone.generatev1wireproto(repo)) |
1180 streamclone.generatev1wireproto(repo)) |
1180 |
1181 |
1181 @wireprotocommand('unbundle', 'heads', permission='push') |
1182 @wireprotocommand('unbundle', 'heads', permission='push', |
|
1183 transportpolicy=POLICY_V1_ONLY) |
1182 def unbundle(repo, proto, heads): |
1184 def unbundle(repo, proto, heads): |
1183 their_heads = decodelist(heads) |
1185 their_heads = decodelist(heads) |
1184 |
1186 |
1185 with proto.mayberedirectstdio() as output: |
1187 with proto.mayberedirectstdio() as output: |
1186 try: |
1188 try: |