equal
deleted
inserted
replaced
237 tr.addabort(callback_id, abortck) |
237 tr.addabort(callback_id, abortck) |
238 with revlog.opener(datafile, b'w+') as fd: |
238 with revlog.opener(datafile, b'w+') as fd: |
239 fd.write(data) |
239 fd.write(data) |
240 if feed_data: |
240 if feed_data: |
241 if use_mmap: |
241 if use_mmap: |
242 new_data = data |
|
243 else: |
|
244 fd.flush() |
242 fd.flush() |
245 new_data = util.buffer(util.mmapread(fd, len(data))) |
243 new_data = util.buffer(util.mmapread(fd, len(data))) |
|
244 else: |
|
245 new_data = data |
246 target_docket.data_length = len(data) |
246 target_docket.data_length = len(data) |
247 target_docket.tip_rev = revlog.tiprev() |
247 target_docket.tip_rev = revlog.tiprev() |
248 target_docket.tip_node = revlog.node(target_docket.tip_rev) |
248 target_docket.tip_node = revlog.node(target_docket.tip_rev) |
249 # EXP-TODO: if this is a cache, this should use a cache vfs, not a |
249 # EXP-TODO: if this is a cache, this should use a cache vfs, not a |
250 # store vfs |
250 # store vfs |