minke.yu/sglang
1
0
Fork 0
Code Issues Pull Requests Actions 12 Packages Projects Releases Wiki Activity

refactor(disagg): drop dead placeholder overrides in Common KV sender/receiver (#35950)

Browse Source
This commit is contained in:
Shangming Cai
2026-08-22 15:45:18 +08:00
committed by GitHub
parent 15a4398320
commit 5c03069d4b
1 changed files with 0 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/sglang/srt/disaggregation/common/conn.py
-9
View File
@@ -1298,12 +1298,6 @@ class CommonKVSender(BaseKVSender):
self.kv_mgr.update_status(self.bootstrap_room, KVPoll.Failed) self.kv_mgr.update_status(self.bootstrap_room, KVPoll.Failed)
return KVPoll.Failed return KVPoll.Failed
def poll(self) -> KVPoll:
pass
def failure_exception(self):
raise Exception("Fake KVReceiver Exception")
def clear(self) -> None: def clear(self) -> None:
self.kv_mgr.request_status.pop(self.bootstrap_room, None) self.kv_mgr.request_status.pop(self.bootstrap_room, None)
if hasattr(self.kv_mgr, "req_to_decode_prefix_len"): if hasattr(self.kv_mgr, "req_to_decode_prefix_len"):
@@ -1562,9 +1556,6 @@ class CommonKVReceiver(BaseKVReceiver):
self.abort_notified = True self.abort_notified = True
return KVPoll.Failed return KVPoll.Failed
def failure_exception(self):
raise Exception("Fake KVReceiver Exception")
def clear(self) -> None: def clear(self) -> None:
self.kv_mgr.request_status.pop(self.bootstrap_room, None) self.kv_mgr.request_status.pop(self.bootstrap_room, None)
self.kv_mgr.required_prefill_response_num_table.pop(self.bootstrap_room, None) self.kv_mgr.required_prefill_response_num_table.pop(self.bootstrap_room, None)