|
|
|
@ -1314,6 +1314,8 @@ impl SstFileWriter { |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
#[derive(thiserror::Error)] |
|
|
|
|
#[error("{}", self.message())] |
|
|
|
|
struct ErrorStatus(rocksdb_status_t); |
|
|
|
|
|
|
|
|
|
unsafe impl Send for ErrorStatus {} |
|
|
|
@ -1352,14 +1354,6 @@ impl fmt::Debug for ErrorStatus { |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
impl fmt::Display for ErrorStatus { |
|
|
|
|
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { |
|
|
|
|
f.write_str(self.message()) |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
impl Error for ErrorStatus {} |
|
|
|
|
|
|
|
|
|
impl From<ErrorStatus> for StorageError { |
|
|
|
|
fn from(status: ErrorStatus) -> Self { |
|
|
|
|
if status.0.code == rocksdb_status_code_t_rocksdb_status_code_io_error { |
|
|
|
|