in plasma-stream/src/errors.rs [141:212]
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
match self {
Self::AlreadyReceiving(peer, objects) => {
write!(
f,
"did not request objects from {}; already receiving objects:",
peer
)?;
for oid in objects {
write!(f, "\n0x{}", hex::encode(oid))?
}
}
Self::AlreadyInStore(peer, objects) => {
write!(
f,
"did not request objects from {}; objects already in store:",
peer
)?;
for oid in objects {
write!(f, "\n0x{}", hex::encode(oid))?
}
}
Self::ObjectMetaTooLarge(peer, oid, _) => {
write!(
f,
"failed to receive objects from {}; metadata too large for 0x{}",
peer,
hex::encode(oid),
)?;
}
Self::ObjectDataTooLarge(peer, oid, _) => {
write!(
f,
"failed to receiver objects from {}; data too large for 0x{}",
peer,
hex::encode(oid),
)?;
}
Self::ZeroLengthObjectData(peer, oid) => {
write!(
f,
"failed to receiver objects from {}; zero-length data for 0x{}",
peer,
hex::encode(oid),
)?;
}
Self::PeerError(peer, response_code) => {
write!(f, "failed to receive objects from {}; ", peer)?;
match *response_code {
status_codes::OB_DELETION_SCHEDULED_ERR => write!(f, "deletion in progress")?,
status_codes::OB_META_TOO_LARGE_ERR => write!(f, "object meta too large")?,
status_codes::OB_DATA_TOO_LARGE_ERR => write!(f, "object data too large")?,
status_codes::OB_NOT_FOUND_ERR => write!(f, "not found")?,
status_codes::PLASMA_STORE_ERR => write!(f, "peer plasma store error")?,
_ => write!(f, "unknown error code: {}", response_code)?,
}
}
Self::StoreError(peer, err) => {
write!(
f,
"failed to receive objects from {}; plasma store error: {}",
peer, err,
)?;
}
Self::ConnectionError(peer, err) => match peer {
Some(peer) => write!(f, "failed to receive objects from {}: {}", peer, err)?,
None => write!(f, "failed to receive objects: {}", err)?,
},
};
Ok(())
}