in mtrl/replay_buffer.py [0:0]
def _save_all(self, save_dir, size_per_chunk: int):
if self.idx == self.last_save:
return
if self.last_save == self.capacity:
self.last_save = 0
if self.idx > self.last_save:
self._save_payload(
save_dir=save_dir,
start_idx=self.last_save,
end_idx=self.idx,
size_per_chunk=size_per_chunk,
)
else:
self._save_payload(
save_dir=save_dir,
start_idx=self.last_save,
end_idx=self.capacity,
size_per_chunk=size_per_chunk,
)
self._save_payload(
save_dir=save_dir,
start_idx=0,
end_idx=self.idx,
size_per_chunk=size_per_chunk,
)
self.last_save = self.idx