MCPcopy Create free account
hub / github.com/MLSysU/TD-Pipe / fork

Method fork

TD_Pipe/core/block_manager.py:182–188  ·  view source on GitHub ↗
(self, parent_seq: Sequence, child_seq: Sequence)

Source from the content-addressed store, hash-verified

180 return last_block.block_number, new_block.block_number
181
182 def fork(self, parent_seq: Sequence, child_seq: Sequence) -> None:
183 # NOTE: fork does not allocate a new physical block.
184 # Thus, it is always safe from OOM.
185 src_block_table = self.block_tables[parent_seq.seq_id]
186 self.block_tables[child_seq.seq_id] = src_block_table.copy()
187 for block in src_block_table:
188 block.ref_count += 1
189
190 def _get_physical_blocks(
191 self, seq_group: SequenceGroup) -> List[PhysicalTokenBlock]:

Callers 2

fork_seqMethod · 0.45

Calls 1

copyMethod · 0.80

Tested by

no test coverage detected