From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from firstgate.proxmox.com (firstgate.proxmox.com [212.224.123.68]) (using TLSv1.3 with cipher TLS_AES_256_GCM_SHA384 (256/256 bits) key-exchange X25519 server-signature RSA-PSS (2048 bits)) (No client certificate requested) by lists.proxmox.com (Postfix) with ESMTPS id 24E2DB8A9C for ; Wed, 6 Dec 2023 09:17:56 +0100 (CET) Received: from firstgate.proxmox.com (localhost [127.0.0.1]) by firstgate.proxmox.com (Proxmox) with ESMTP id 074A935CD5 for ; Wed, 6 Dec 2023 09:17:56 +0100 (CET) Received: from bookworm-dev.localdomain (unknown [94.136.29.99]) by firstgate.proxmox.com (Proxmox) with ESMTP for ; Wed, 6 Dec 2023 09:17:55 +0100 (CET) Received: by bookworm-dev.localdomain (Postfix, from userid 1000) id 38A61607AF; Wed, 6 Dec 2023 09:17:54 +0100 (CET) From: Dominik Csapak To: pbs-devel@lists.proxmox.com Date: Wed, 6 Dec 2023 09:17:54 +0100 Message-Id: <20231206081754.45388-1-d.csapak@proxmox.com> X-Mailer: git-send-email 2.39.2 MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-SPAM-LEVEL: Spam detection results: 0 AWL -0.379 Adjusted score from AWL reputation of From: address BAYES_00 -1.9 Bayes spam probability is 0 to 1% DMARC_MISSING 0.1 Missing DMARC policy KAM_DMARC_STATUS 0.01 Test Rule for DKIM or SPF Failure with Strict Alignment RDNS_NONE 0.793 Delivered to internal network by a host with no rDNS SPF_HELO_NONE 0.001 SPF: HELO does not publish an SPF Record SPF_PASS -0.001 SPF: sender matches SPF record T_SCC_BODY_TEXT_LINE -0.01 - URIBL_BLOCKED 0.001 ADMINISTRATOR NOTICE: The query to URIBL was blocked. See http://wiki.apache.org/spamassassin/DnsBlocklists#dnsbl-block for more information. [proxmox.com] Subject: [pbs-devel] [PATCH proxmox-backup] tape: improve error on decode element status page X-BeenThere: pbs-devel@lists.proxmox.com X-Mailman-Version: 2.1.29 Precedence: list List-Id: Proxmox Backup Server development discussion List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Wed, 06 Dec 2023 08:17:56 -0000 instead of wrapping the function body in a 'try_block', simply move the map_err to the only call site, where we can even add more context than in the function itself. aside from better error output, no functional change intended this could help in debugging cases like this issue reported in the forum: https://forum.proxmox.com/threads/137391/ Signed-off-by: Dominik Csapak --- since most of this is just removing a level of indentation, best viewed with '-w' pbs-tape/src/sg_pt_changer.rs | 227 +++++++++++++++++----------------- 1 file changed, 113 insertions(+), 114 deletions(-) diff --git a/pbs-tape/src/sg_pt_changer.rs b/pbs-tape/src/sg_pt_changer.rs index 6cb3a044..4c7b666e 100644 --- a/pbs-tape/src/sg_pt_changer.rs +++ b/pbs-tape/src/sg_pt_changer.rs @@ -326,7 +326,9 @@ fn get_element( let data = execute_scsi_command(sg_raw, &cmd, "read element status (B8h)", retry)?; - let page = decode_element_status_page(&data, start_element_address)?; + let page = decode_element_status_page(&data, start_element_address).map_err(|err| { + format_err!("decode element status for {element_type:?} on {start_element_address} failed - {err}") + })?; retry = false; // only retry the first command @@ -679,149 +681,146 @@ fn decode_element_status_page( data: &[u8], start_element_address: u16, ) -> Result { - proxmox_lang::try_block!({ - let mut result = DecodedStatusPage { - last_element_address: None, - transports: Vec::new(), - drives: Vec::new(), - storage_slots: Vec::new(), - import_export_slots: Vec::new(), - }; + let mut result = DecodedStatusPage { + last_element_address: None, + transports: Vec::new(), + drives: Vec::new(), + storage_slots: Vec::new(), + import_export_slots: Vec::new(), + }; - let mut reader = data; + let mut reader = data; - let head: ElementStatusHeader = unsafe { reader.read_be_value()? }; + let head: ElementStatusHeader = unsafe { reader.read_be_value()? }; - if head.number_of_elements_available == 0 { - return Ok(result); - } + if head.number_of_elements_available == 0 { + return Ok(result); + } - if head.first_element_address_reported < start_element_address { - bail!("got wrong first_element_address_reported"); // sanity check + if head.first_element_address_reported < start_element_address { + bail!("got wrong first_element_address_reported"); // sanity check + } + + let len = head.byte_count_of_report_available; + let len = ((len[0] as usize) << 16) + ((len[1] as usize) << 8) + (len[2] as usize); + + use std::cmp::Ordering; + match len.cmp(&reader.len()) { + Ordering::Less => reader = &reader[..len], + Ordering::Greater => bail!( + "wrong amount of data: expected {}, got {}", + len, + reader.len() + ), + _ => (), + } + + loop { + if reader.is_empty() { + break; } - let len = head.byte_count_of_report_available; - let len = ((len[0] as usize) << 16) + ((len[1] as usize) << 8) + (len[2] as usize); - - use std::cmp::Ordering; - match len.cmp(&reader.len()) { - Ordering::Less => reader = &reader[..len], - Ordering::Greater => bail!( - "wrong amount of data: expected {}, got {}", - len, - reader.len() - ), - _ => (), + let subhead: SubHeader = unsafe { reader.read_be_value()? }; + + let len = subhead.byte_count_of_descriptor_data_available; + let mut len = ((len[0] as usize) << 16) + ((len[1] as usize) << 8) + (len[2] as usize); + if len > reader.len() { + len = reader.len(); } - loop { - if reader.is_empty() { - break; - } + let descr_data = reader.read_exact_allocated(len)?; - let subhead: SubHeader = unsafe { reader.read_be_value()? }; + let descr_len = subhead.descriptor_length as usize; - let len = subhead.byte_count_of_descriptor_data_available; - let mut len = ((len[0] as usize) << 16) + ((len[1] as usize) << 8) + (len[2] as usize); - if len > reader.len() { - len = reader.len(); - } + if descr_len == 0 { + bail!("got elements, but descriptor length 0"); + } - let descr_data = reader.read_exact_allocated(len)?; + for descriptor in descr_data.chunks_exact(descr_len) { + let mut reader = descriptor; - let descr_len = subhead.descriptor_length as usize; + match subhead.element_type_code { + 1 => { + let desc: TransportDescriptor = unsafe { reader.read_be_value()? }; - if descr_len == 0 { - bail!("got elements, but descriptor length 0"); - } + let full = (desc.flags1 & 1) != 0; + let volume_tag = subhead.parse_optional_volume_tag(&mut reader, full)?; - for descriptor in descr_data.chunks_exact(descr_len) { - let mut reader = descriptor; + subhead.skip_alternate_volume_tag(&mut reader)?; - match subhead.element_type_code { - 1 => { - let desc: TransportDescriptor = unsafe { reader.read_be_value()? }; + result.last_element_address = Some(desc.element_address); + + let status = TransportElementStatus { + status: create_element_status(full, volume_tag), + element_address: desc.element_address, + }; + result.transports.push(status); + } + 2 | 3 => { + let desc: StorageDescriptor = unsafe { reader.read_be_value()? }; - let full = (desc.flags1 & 1) != 0; - let volume_tag = subhead.parse_optional_volume_tag(&mut reader, full)?; + let full = (desc.flags1 & 1) != 0; + let volume_tag = subhead.parse_optional_volume_tag(&mut reader, full)?; - subhead.skip_alternate_volume_tag(&mut reader)?; + subhead.skip_alternate_volume_tag(&mut reader)?; - result.last_element_address = Some(desc.element_address); + result.last_element_address = Some(desc.element_address); - let status = TransportElementStatus { + if subhead.element_type_code == 3 { + let status = StorageElementStatus { + import_export: true, status: create_element_status(full, volume_tag), element_address: desc.element_address, }; - result.transports.push(status); - } - 2 | 3 => { - let desc: StorageDescriptor = unsafe { reader.read_be_value()? }; - - let full = (desc.flags1 & 1) != 0; - let volume_tag = subhead.parse_optional_volume_tag(&mut reader, full)?; - - subhead.skip_alternate_volume_tag(&mut reader)?; - - result.last_element_address = Some(desc.element_address); - - if subhead.element_type_code == 3 { - let status = StorageElementStatus { - import_export: true, - status: create_element_status(full, volume_tag), - element_address: desc.element_address, - }; - result.import_export_slots.push(status); - } else { - let status = StorageElementStatus { - import_export: false, - status: create_element_status(full, volume_tag), - element_address: desc.element_address, - }; - result.storage_slots.push(status); - } - } - 4 => { - let desc: TransferDescriptor = unsafe { reader.read_be_value()? }; - - let loaded_slot = if (desc.flags2 & 128) != 0 { - // SValid - Some(desc.source_storage_element_address as u64) - } else { - None - }; - - let full = (desc.flags1 & 1) != 0; - let volume_tag = subhead.parse_optional_volume_tag(&mut reader, full)?; - - subhead.skip_alternate_volume_tag(&mut reader)?; - - let dvcid = decode_dvcid_info(&mut reader).unwrap_or(DvcidInfo { - vendor: None, - model: None, - serial: None, - }); - - result.last_element_address = Some(desc.element_address); - - let drive = DriveStatus { - loaded_slot, + result.import_export_slots.push(status); + } else { + let status = StorageElementStatus { + import_export: false, status: create_element_status(full, volume_tag), - drive_serial_number: dvcid.serial, - vendor: dvcid.vendor, - model: dvcid.model, element_address: desc.element_address, }; - result.drives.push(drive); + result.storage_slots.push(status); } - code => bail!("got unknown element type code {}", code), } + 4 => { + let desc: TransferDescriptor = unsafe { reader.read_be_value()? }; + + let loaded_slot = if (desc.flags2 & 128) != 0 { + // SValid + Some(desc.source_storage_element_address as u64) + } else { + None + }; + + let full = (desc.flags1 & 1) != 0; + let volume_tag = subhead.parse_optional_volume_tag(&mut reader, full)?; + + subhead.skip_alternate_volume_tag(&mut reader)?; + + let dvcid = decode_dvcid_info(&mut reader).unwrap_or(DvcidInfo { + vendor: None, + model: None, + serial: None, + }); + + result.last_element_address = Some(desc.element_address); + + let drive = DriveStatus { + loaded_slot, + status: create_element_status(full, volume_tag), + drive_serial_number: dvcid.serial, + vendor: dvcid.vendor, + model: dvcid.model, + element_address: desc.element_address, + }; + result.drives.push(drive); + } + code => bail!("got unknown element type code {}", code), } } + } - Ok(result) - }) - .map_err(|err: Error| format_err!("decode element status failed - {}", err)) + Ok(result) } /// Open the device for read/write, returns the file handle -- 2.39.2