Co-authored-by: Claude Opus 5 (1M context) <noreply@anthropic.com>
219 lines
7.3 KiB
Python
219 lines
7.3 KiB
Python
# Copyright 2025 SGLang Team
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
# ==============================================================================
|
|
"""Common utilities."""
|
|
|
|
import hashlib
|
|
from typing import Any, Callable, List, Optional, Tuple
|
|
|
|
from sglang.kernels.ops.kvcache.mla_buffer import (
|
|
get_mla_kv_buffer_kernel as get_mla_kv_buffer_kernel,
|
|
)
|
|
from sglang.kernels.ops.kvcache.mla_buffer import (
|
|
get_mla_kv_buffer_triton as get_mla_kv_buffer_triton,
|
|
)
|
|
from sglang.kernels.ops.kvcache.mla_buffer import (
|
|
set_mla_kv_buffer_dcp_sharded_triton as set_mla_kv_buffer_dcp_sharded_triton,
|
|
)
|
|
from sglang.kernels.ops.kvcache.mla_buffer import (
|
|
set_mla_kv_buffer_fp8_quant_kernel as set_mla_kv_buffer_fp8_quant_kernel,
|
|
)
|
|
from sglang.kernels.ops.kvcache.mla_buffer import (
|
|
set_mla_kv_buffer_kernel as set_mla_kv_buffer_kernel,
|
|
)
|
|
from sglang.kernels.ops.kvcache.mla_buffer import (
|
|
set_mla_kv_buffer_triton as set_mla_kv_buffer_triton,
|
|
)
|
|
from sglang.kernels.ops.kvcache.mla_buffer import (
|
|
set_mla_kv_buffer_triton_fp8_quant as set_mla_kv_buffer_triton_fp8_quant,
|
|
)
|
|
from sglang.kernels.ops.kvcache.mla_buffer import (
|
|
set_mla_kv_scale_buffer_kernel as set_mla_kv_scale_buffer_kernel,
|
|
)
|
|
from sglang.kernels.ops.kvcache.mla_buffer import (
|
|
set_mla_kv_scale_buffer_triton as set_mla_kv_scale_buffer_triton,
|
|
)
|
|
from sglang.srt.environ import envs
|
|
from sglang.srt.mem_cache.cpp_utils.native_hash import get_native_hash
|
|
from sglang.srt.mem_cache.evict_policy import (
|
|
EvictionStrategy,
|
|
FIFOStrategy,
|
|
FILOStrategy,
|
|
LFUStrategy,
|
|
LRUStrategy,
|
|
MRUStrategy,
|
|
PriorityStrategy,
|
|
SLRUStrategy,
|
|
)
|
|
|
|
_EVICTION_POLICY_FACTORIES: dict[str, Callable[..., EvictionStrategy]] = {
|
|
"lru": LRUStrategy,
|
|
"lfu": LFUStrategy,
|
|
"fifo": FIFOStrategy,
|
|
"mru": MRUStrategy,
|
|
"filo": FILOStrategy,
|
|
"priority": PriorityStrategy,
|
|
"slru": SLRUStrategy,
|
|
}
|
|
|
|
|
|
def get_eviction_strategy(
|
|
eviction_policy: str, config: Optional[dict[str, Any]] = None
|
|
) -> EvictionStrategy:
|
|
"""Build the eviction strategy; ``config`` is passed to it as keyword arguments."""
|
|
policy = eviction_policy.lower()
|
|
try:
|
|
factory = _EVICTION_POLICY_FACTORIES[policy]
|
|
except KeyError:
|
|
supported = "', '".join(_EVICTION_POLICY_FACTORIES)
|
|
raise ValueError(
|
|
f"Unknown eviction policy: {policy}. Supported policies: '{supported}'."
|
|
) from None
|
|
return factory(**config) if config else factory()
|
|
|
|
|
|
def maybe_init_custom_mem_pool(
|
|
device: str,
|
|
) -> Tuple[bool, Optional[Any], Optional[str]]:
|
|
"""
|
|
Initialize custom memory pool based on environment variable.
|
|
|
|
This function can be modified to support more features that require a custom memory pool.
|
|
|
|
Args:
|
|
device: The device to allocate memory on
|
|
|
|
Returns:
|
|
Tuple of (enable_custom_mem_pool, custom_mem_pool, custom_mem_pool_type)
|
|
"""
|
|
enable_custom_mem_pool = (
|
|
True if envs.SGLANG_MOONCAKE_CUSTOM_MEM_POOL.get() is not None else False
|
|
)
|
|
|
|
if enable_custom_mem_pool:
|
|
# Currently, only mooncake requires a custom mem pool for MNNVL/Barex PD disaggregation
|
|
from sglang.srt.disaggregation.mooncake.utils import (
|
|
init_mooncake_custom_mem_pool,
|
|
)
|
|
|
|
return init_mooncake_custom_mem_pool(device)
|
|
else:
|
|
return False, None, None
|
|
|
|
|
|
def get_hash_str(
|
|
token_ids: List[int],
|
|
prior_hash: Optional[str] = None,
|
|
page_size: Optional[int] = None,
|
|
) -> str | List[str]:
|
|
prior_digest = bytes.fromhex(prior_hash) if prior_hash else None
|
|
return get_native_hash(token_ids, prior_digest, page_size)
|
|
|
|
|
|
def hash_str_to_int64(hash_str: str) -> int:
|
|
"""Convert SHA256 hex string to signed 64-bit integer for events.
|
|
|
|
Takes first 16 hex characters (64 bits) and converts to signed int64 range.
|
|
"""
|
|
uint64_val = int(hash_str[:16], 16)
|
|
if uint64_val >= 2**63:
|
|
return uint64_val - 2**64
|
|
return uint64_val
|
|
|
|
|
|
def compute_node_hash_values(node: Any, page_size: int) -> List[str]:
|
|
"""Compute SHA256-based hash values for position-aware KV block IDs."""
|
|
parent_hash = None
|
|
if node.parent is not None and node.parent.hash_value is not None:
|
|
if len(node.parent.key) > 0 and len(node.parent.hash_value) > 0:
|
|
parent_hash = node.parent.hash_value[-1]
|
|
|
|
hash_values = get_hash_str(node.key, parent_hash, page_size=page_size)
|
|
assert isinstance(hash_values, list)
|
|
return hash_values
|
|
|
|
|
|
def compute_node_event_hash_values(node: Any, page_size: int) -> List[str]:
|
|
"""Compute and memoize namespace-aware external KV-event hashes."""
|
|
cache_salt = node.key.cache_salt
|
|
if cache_salt is None:
|
|
return compute_node_hash_values(node, page_size)
|
|
|
|
if node.event_hash_value is not None:
|
|
return node.event_hash_value
|
|
|
|
missing_nodes = []
|
|
current = node
|
|
while (
|
|
current is not None
|
|
and current.key is not None
|
|
and len(current.key) > 0
|
|
and current.event_hash_value is None
|
|
):
|
|
if current.key.cache_salt != cache_salt:
|
|
raise ValueError("Radix path contains mismatched cache_salt values")
|
|
missing_nodes.append(current)
|
|
current = current.parent
|
|
|
|
if (
|
|
current is not None
|
|
and current.key is not None
|
|
and len(current.key) > 0
|
|
and current.key.cache_salt != cache_salt
|
|
):
|
|
raise ValueError("Radix path contains mismatched cache_salt values")
|
|
|
|
if current is not None and current.event_hash_value:
|
|
parent_hash = current.event_hash_value[-1]
|
|
else:
|
|
parent_hash = hashlib.sha256(
|
|
b"sglang-cache-salt-v1\0" + cache_salt.encode("utf-8")
|
|
).hexdigest()
|
|
|
|
for missing_node in reversed(missing_nodes):
|
|
hash_values = get_hash_str(missing_node.key, parent_hash, page_size=page_size)
|
|
assert isinstance(hash_values, list)
|
|
missing_node.event_hash_value = hash_values
|
|
if hash_values:
|
|
parent_hash = hash_values[-1]
|
|
|
|
assert node.event_hash_value is not None
|
|
return node.event_hash_value
|
|
|
|
|
|
def split_node_hash_value(
|
|
child_hash_value: Optional[List[str]], split_len: int, page_size: int
|
|
) -> tuple[Optional[List[str]], Optional[List[str]]]:
|
|
"""Split hash_value between parent and child nodes during node splitting.
|
|
|
|
Args:
|
|
child_hash_value: The hash_value list from the child node being split
|
|
split_len: The length at which to split (in tokens)
|
|
page_size: The page size for calculating number of pages
|
|
|
|
Returns:
|
|
Tuple of (new_node_hash_value, updated_child_hash_value)
|
|
"""
|
|
if child_hash_value is None:
|
|
return None, None
|
|
|
|
if page_size == 1:
|
|
split_pages = split_len
|
|
else:
|
|
split_pages = split_len // page_size
|
|
|
|
new_node_hash = child_hash_value[:split_pages]
|
|
child_hash = child_hash_value[split_pages:]
|
|
|
|
return new_node_hash, child_hash
|