equal
deleted
inserted
replaced
115 heads = map(hex, repo.heads()) |
115 heads = map(hex, repo.heads()) |
116 return their_heads == [hex('force')] or their_heads == heads |
116 return their_heads == [hex('force')] or their_heads == heads |
117 |
117 |
118 # fail early if possible |
118 # fail early if possible |
119 if not check_heads(): |
119 if not check_heads(): |
120 length = int(req.env.get('CONTENT_LENGTH', 0)) |
120 req.drain() |
121 for s in util.filechunkiter(req, limit=length): |
|
122 # drain incoming bundle, else client will not see |
|
123 # response when run outside cgi script |
|
124 pass |
|
125 raise ErrorResponse(HTTP_OK, 'unsynced changes') |
121 raise ErrorResponse(HTTP_OK, 'unsynced changes') |
126 |
122 |
127 # do not lock repo until all changegroup data is |
123 # do not lock repo until all changegroup data is |
128 # streamed. save to temporary file. |
124 # streamed. save to temporary file. |
129 |
125 |