Show More
@@ -1892,9 +1892,10 b' class workingfilectx(committablefilectx)' | |||
|
1892 | 1892 | """wraps unlink for a repo's working directory""" |
|
1893 | 1893 | self._repo.wvfs.unlinkpath(self._path, ignoremissing=ignoremissing) |
|
1894 | 1894 | |
|
1895 | def write(self, data, flags): | |
|
1895 | def write(self, data, flags, backgroundclose=False): | |
|
1896 | 1896 | """wraps repo.wwrite""" |
|
1897 |
self._repo.wwrite(self._path, data, flags |
|
|
1897 | self._repo.wwrite(self._path, data, flags, | |
|
1898 | backgroundclose=backgroundclose) | |
|
1898 | 1899 | |
|
1899 | 1900 | def setflags(self, l, x): |
|
1900 | 1901 | self._repo.wvfs.setflags(self._path, l, x) |
@@ -1130,7 +1130,6 b' def batchget(repo, mctx, wctx, actions):' | |||
|
1130 | 1130 | """ |
|
1131 | 1131 | verbose = repo.ui.verbose |
|
1132 | 1132 | fctx = mctx.filectx |
|
1133 | wwrite = repo.wwrite | |
|
1134 | 1133 | ui = repo.ui |
|
1135 | 1134 | i = 0 |
|
1136 | 1135 | with repo.wvfs.backgroundclosing(ui, expectedcount=len(actions)): |
@@ -1151,7 +1150,7 b' def batchget(repo, mctx, wctx, actions):' | |||
|
1151 | 1150 | |
|
1152 | 1151 | if repo.wvfs.isdir(f) and not repo.wvfs.islink(f): |
|
1153 | 1152 | repo.wvfs.removedirs(f) |
|
1154 |
wwrite( |
|
|
1153 | wctx[f].write(fctx(f).data(), flags, backgroundclose=True) | |
|
1155 | 1154 | if i == 100: |
|
1156 | 1155 | yield i, f |
|
1157 | 1156 | i = 0 |
General Comments 0
You need to be logged in to leave comments.
Login now