Lines Matching refs:raw

84     pub(crate) fn unmarshal(raw: &Bytes) -> Result<Self> {  in unmarshal()
85 if raw.len() < PACKET_HEADER_SIZE { in unmarshal()
89 let reader = &mut raw.clone(); in unmarshal()
99 let our_checksum = generate_packet_checksum(raw); in unmarshal()
110 if offset == raw.len() { in unmarshal()
112 } else if offset + CHUNK_HEADER_SIZE > raw.len() { in unmarshal()
116 let ct = ChunkType(raw[offset]); in unmarshal()
118 CT_INIT => Box::new(ChunkInit::unmarshal(&raw.slice(offset..))?), in unmarshal()
119 CT_INIT_ACK => Box::new(ChunkInit::unmarshal(&raw.slice(offset..))?), in unmarshal()
120 CT_ABORT => Box::new(ChunkAbort::unmarshal(&raw.slice(offset..))?), in unmarshal()
121 CT_COOKIE_ECHO => Box::new(ChunkCookieEcho::unmarshal(&raw.slice(offset..))?), in unmarshal()
122 CT_COOKIE_ACK => Box::new(ChunkCookieAck::unmarshal(&raw.slice(offset..))?), in unmarshal()
123 CT_HEARTBEAT => Box::new(ChunkHeartbeat::unmarshal(&raw.slice(offset..))?), in unmarshal()
124 CT_PAYLOAD_DATA => Box::new(ChunkPayloadData::unmarshal(&raw.slice(offset..))?), in unmarshal()
125 CT_SACK => Box::new(ChunkSelectiveAck::unmarshal(&raw.slice(offset..))?), in unmarshal()
126 CT_RECONFIG => Box::new(ChunkReconfig::unmarshal(&raw.slice(offset..))?), in unmarshal()
127 CT_FORWARD_TSN => Box::new(ChunkForwardTsn::unmarshal(&raw.slice(offset..))?), in unmarshal()
128 CT_ERROR => Box::new(ChunkError::unmarshal(&raw.slice(offset..))?), in unmarshal()
129 CT_SHUTDOWN => Box::new(ChunkShutdown::unmarshal(&raw.slice(offset..))?), in unmarshal()
130 CT_SHUTDOWN_ACK => Box::new(ChunkShutdownAck::unmarshal(&raw.slice(offset..))?), in unmarshal()
132 Box::new(ChunkShutdownComplete::unmarshal(&raw.slice(offset..))?) in unmarshal()
134 _ => Box::new(ChunkUnknown::unmarshal(&raw.slice(offset..))?), in unmarshal()