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