(self, id, raise_full=False)
| 1725 | return self.segment, offset |
| 1726 | |
| 1727 | def write_delete(self, id, raise_full=False): |
| 1728 | fd = self.get_write_fd(want_new=(id == Manifest.MANIFEST_ID), raise_full=raise_full) |
| 1729 | header = self.header_no_crc_fmt.pack(self.HEADER_ID_SIZE, TAG_DELETE) |
| 1730 | crc = self.crc_fmt.pack(crc32(id, crc32(header)) & 0xFFFFFFFF) |
| 1731 | fd.write(b"".join((crc, header, id))) |
| 1732 | self.offset += self.HEADER_ID_SIZE |
| 1733 | return self.segment, self.HEADER_ID_SIZE |
| 1734 | |
| 1735 | def write_commit(self, intermediate=False): |
| 1736 | # Intermediate commits go directly into the current segment - this makes checking their validity more |
no test coverage detected