140 

   140 

   141 class pushres(object):

   141 class pushres(object):

   142     def __init__(self, res):

   142     def __init__(self, res):

   143         self.res = res

   143         self.res = res

   144 

   144 

   145 def dispatch(repo, proto, command):

   149 def dispatch(repo, proto, command):

   146     func, spec = commands[command]

   150     func, spec = commands[command]

   147     args = proto.getargs(spec)

   151     args = proto.getargs(spec)

   148     return func(repo, proto, *args)

   152     return func(repo, proto, *args)

   149 

   153 

   283 

   287 

   284     proto.redirect()

   288     proto.redirect()

   285 

   289 

   286     # fail early if possible

   290     # fail early if possible

   287     if not check_heads():

   291     if not check_heads():

   289 

   293 

   290     # write bundle data to temporary file because it can be big

   294     # write bundle data to temporary file because it can be big

   291     fd, tempname = tempfile.mkstemp(prefix='hg-unbundle-')

   295     fd, tempname = tempfile.mkstemp(prefix='hg-unbundle-')

   292     fp = os.fdopen(fd, 'wb+')

   296     fp = os.fdopen(fd, 'wb+')

   293     r = 0

   297     r = 0

   296         lock = repo.lock()

   300         lock = repo.lock()

   297         try:

   301         try:

   298             if not check_heads():

   302             if not check_heads():

   299                 # someone else committed/pushed/unbundled while we

   303                 # someone else committed/pushed/unbundled while we

   300                 # were transferring data

   304                 # were transferring data

   302 

   306 

   303             # push can proceed

   307             # push can proceed

   304             fp.seek(0)

   308             fp.seek(0)

   305             gen = changegroupmod.readbundle(fp, None)

   309             gen = changegroupmod.readbundle(fp, None)

   306 

   310