--- a/mercurial/wireproto.py Fri Apr 04 17:15:25 2014 -0700
+++ b/mercurial/wireproto.py Fri Apr 04 17:28:59 2014 -0700
@@ -765,21 +765,10 @@
r = 0
try:
proto.getfile(fp)
- lock = repo.lock()
- try:
- exchange.check_heads(repo, their_heads, 'uploading changes')
-
- # push can proceed
- fp.seek(0)
- gen = changegroupmod.readbundle(fp, None)
-
- try:
- r = changegroupmod.addchangegroup(repo, gen, 'serve',
- proto._client())
- except util.Abort, inst:
- sys.stderr.write("abort: %s\n" % inst)
- finally:
- lock.release()
+ fp.seek(0)
+ gen = changegroupmod.readbundle(fp, None)
+ r = exchange.unbundle(repo, gen, their_heads, 'serve',
+ proto._client())
return pushres(r)
finally: