Changeset View
Changeset View
Standalone View
Standalone View
swh/loader/git/loader.py
Show First 20 Lines • Show All 176 Lines • ▼ Show 20 Lines | ) -> FetchPackReturn: | ||||
size_limit = self.pack_size_bytes | size_limit = self.pack_size_bytes | ||||
def do_pack(data: bytes) -> None: | def do_pack(data: bytes) -> None: | ||||
cur_size = pack_buffer.tell() | cur_size = pack_buffer.tell() | ||||
would_write = len(data) | would_write = len(data) | ||||
if cur_size + would_write > size_limit: | if cur_size + would_write > size_limit: | ||||
raise IOError( | raise IOError( | ||||
f"Pack file too big for repository {origin_url}, " | f"Pack file too big for repository {origin_url}, " | ||||
"limit is {size_limit} bytes, current size is {cur_size}, " | f"limit is {size_limit} bytes, current size is {cur_size}, " | ||||
"would write {would_write}" | f"would write {would_write}" | ||||
) | ) | ||||
pack_buffer.write(data) | pack_buffer.write(data) | ||||
pack_result = client.fetch_pack( | pack_result = client.fetch_pack( | ||||
path, | path, | ||||
base_repo.determine_wants, | base_repo.determine_wants, | ||||
base_repo.graph_walker(), | base_repo.graph_walker(), | ||||
▲ Show 20 Lines • Show All 282 Lines • Show Last 20 Lines |