tape: add pmt weof

src/bin/pmt.rs

@@ -18,10 +18,20 @@ use proxmox::{
     api::{
         api,
         cli::*,
+        schema::{
+            Schema,
+            IntegerSchema,
+        },
         RpcEnvironment,
     },
 };
 
+pub const FILE_MARK_COUNT_SCHEMA: Schema =
+    IntegerSchema::new("File mark count.")
+    .minimum(1)
+    .minimum(i32::MAX as isize)
+    .schema();
+
 use proxmox_backup::{
     config::{
         self,
@@ -36,6 +46,7 @@ use proxmox_backup::{
         complete_drive_path,
         linux_tape_device_list,
         drive::{
+            linux_mtio::MTCmd,
             TapeDriver,
             LinuxTapeHandle,
             open_linux_tape_device,
@@ -99,11 +110,9 @@ fn get_tape_handle(param: &Value) -> Result<LinuxTapeHandle, Error> {
                 optional: true,
             },
             count: {
-                description: "File mark count.",
+                schema: FILE_MARK_COUNT_SCHEMA,
-                type: i32,
-                minimum: 1
             },
-        },
+       },
     },
 )]
 /// Backward space count files (position before file mark).
@@ -258,9 +267,7 @@ fn erase(fast: Option<bool>, param: Value) -> Result<(), Error> {
                 optional: true,
             },
             count: {
-                description: "File mark count.",
+                schema: FILE_MARK_COUNT_SCHEMA,
-                type: i32,
-                minimum: 1
             },
         },
     },
@@ -462,6 +469,33 @@ fn volume_statistics(param: Value) -> Result<(), Error> {
     Ok(())
 }
 
+#[api(
+   input: {
+        properties: {
+            drive: {
+                schema: DRIVE_NAME_SCHEMA,
+                optional: true,
+            },
+            device: {
+                schema: LINUX_DRIVE_PATH_SCHEMA,
+                optional: true,
+            },
+            count: {
+                schema: FILE_MARK_COUNT_SCHEMA,
+                optional: true,
+             },
+        },
+    },
+)]
+/// Write count (default 1) EOF marks at current position.
+fn weof(count: Option<i32>, param: Value) -> Result<(), Error> {
+
+    let mut handle = get_tape_handle(&param)?;
+    handle.mtop(MTCmd::MTWEOF, count.unwrap_or(1), "write EOF mark")?;
+
+    Ok(())
+}
+
 fn main() -> Result<(), Error> {
 
     let uid = nix::unistd::Uid::current();
@@ -489,6 +523,7 @@ fn main() -> Result<(), Error> {
         .insert("scan", CliCommand::new(&API_METHOD_SCAN))
         .insert("status", std_cmd(&API_METHOD_STATUS))
         .insert("volume-statistics", std_cmd(&API_METHOD_VOLUME_STATISTICS))
+        .insert("weof", std_cmd(&API_METHOD_WEOF))
         ;
 
     let mut rpcenv = CliEnvironment::new();

src/tape/drive/linux_tape.rs

@@ -193,6 +193,16 @@ impl LinuxTapeHandle {
         Ok(())
     }
 
+    pub fn mtop(&mut self, mt_op: MTCmd, mt_count: i32, msg: &str) -> Result<(), Error> {
+        let cmd = mtop { mt_op, mt_count };
+
+        unsafe {
+            mtioctop(self.file.as_raw_fd(), &cmd)
+        }.map_err(|err| format_err!("{} failed (count {}) - {}", msg, mt_count, err))?;
+
+        Ok(())
+    }
+
     pub fn mtload(&mut self) -> Result<(), Error> {
 
         let cmd = mtop { mt_op: MTCmd::MTLOAD, mt_count: 1, };

src/tape/drive/mod.rs

@@ -1,7 +1,8 @@
 //! Tape drivers
 
 mod virtual_tape;
-mod linux_mtio;
+
+pub mod linux_mtio;
 
 mod tape_alert_flags;
 pub use tape_alert_flags::*;