Searched refs:raw_param (Results 1 – 2 of 2) sorted by relevance
58 pub(crate) fn build_param(raw_param: &Bytes) -> Result<Box<dyn Param + Send + Sync>> { in build_param()59 if raw_param.len() < PARAM_HEADER_LENGTH { in build_param()62 let reader = &mut raw_param.slice(..2); in build_param()65 ParamType::ForwardTsnSupp => Ok(Box::new(ParamForwardTsnSupported::unmarshal(raw_param)?)), in build_param()66 ParamType::SupportedExt => Ok(Box::new(ParamSupportedExtensions::unmarshal(raw_param)?)), in build_param()67 ParamType::Random => Ok(Box::new(ParamRandom::unmarshal(raw_param)?)), in build_param()69 ParamType::ChunkList => Ok(Box::new(ParamChunkList::unmarshal(raw_param)?)), in build_param()70 ParamType::StateCookie => Ok(Box::new(ParamStateCookie::unmarshal(raw_param)?)), in build_param()71 ParamType::HeartbeatInfo => Ok(Box::new(ParamHeartbeatInfo::unmarshal(raw_param)?)), in build_param()73 ParamType::ReconfigResp => Ok(Box::new(ParamReconfigResponse::unmarshal(raw_param)?)), in build_param()[all …]
46 let raw_param = raw.slice(PARAM_HEADER_LENGTH..PARAM_HEADER_LENGTH + header.value_length()); in unmarshal() localVariable47 let param = build_param(&raw_param)?; in unmarshal()