X-Git-Url: https://git.nihav.org/?p=nihav-tool.git;a=blobdiff_plain;f=src%2Fmain.rs;h=76e720ef3e46ed304522f592c918f07ef88e6c92;hp=59c18788c78ff3a8b7485fd71478eae3c4584e75;hb=fabefb1bbbe0989b89e588a9409679cf3096d2d8;hpb=2299da077b933c0930c2b0edf2b4288a2d77741b

diff --git a/src/main.rs b/src/main.rs
index 59c1878..76e720e 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -1,4 +1,5 @@
 extern crate nihav_core;
+extern crate nihav_codec_support;
 extern crate nihav_registry;
 extern crate nihav_allstuff;
 
@@ -9,13 +10,11 @@ use nihav_core::io::byteio::{FileReader, ByteReader};
 use nihav_core::frame::*;
 use nihav_core::codecs::*;
 use nihav_core::demuxers::*;
+use nihav_codec_support::imgwrite::*;
 use nihav_registry::detect;
 use nihav_allstuff::*;
 use std::env;
 
-mod frmwriter;
-use crate::frmwriter::*;
-
 mod wavwriter;
 use crate::wavwriter::WavWriter;
 
@@ -41,15 +40,8 @@ impl FrameOutput {
                     NumberMode::PktPTS  => { pkt.get_pts().unwrap() },
                     NumberMode::FrmPTS  => { if let Some(pt) = frm.get_pts() { pt } else { pkt.get_pts().unwrap() } },
                 };
-            let vinfo = frm.get_buffer().get_video_info().unwrap();
-            if vinfo.get_format().is_paletted() {
-                write_palppm(&self.prefix, self.streamno, pts, frm);
-            } else if vinfo.get_format().get_model().is_yuv() {
-                write_pgmyuv(&self.prefix, self.streamno, pts, frm);
-            } else if vinfo.get_format().get_model().is_rgb() {
-                write_ppm(&self.prefix, self.streamno, pts, frm);
-            } else {
-panic!(" unknown format");
+            if let Err(_) = write_pnm(&self.prefix, self.streamno, pts, frm) {
+                println!("error writing output picture");
             }
         }
         self.frameno += 1;
@@ -85,13 +77,14 @@ fn main() {
         println!("usage: nihav-tool [-noout] [-vn] [-an] input [lastpts]");
         return;
     }
-    let mut lastpts: Option<u64> = None;
+    let mut lastpts = NATimePoint::None;
     let mut cur_arg: usize = 1;
     let mut noout = false;
     let mut decode_video = true;
     let mut decode_audio = true;
     let mut nmode = NumberMode::FrmPTS;
-    let mut seek_time = 0u64;
+    let mut smode = FrameSkipMode::None;
+    let mut seek_time = NATimePoint::None;
     let mut vpfx: Option<String> = None;
     let mut apfx: Option<&str> = None;
     let mut ignore_errors = false;
@@ -106,13 +99,15 @@ fn main() {
             "-nm=count"  => { nmode = NumberMode::Counter; },
             "-nm=pktpts" => { nmode = NumberMode::PktPTS; },
             "-nm=frmpts" => { nmode = NumberMode::FrmPTS; },
+            "-skip=key"   => { smode = FrameSkipMode::KeyframesOnly; },
+            "-skip=intra" => { smode = FrameSkipMode::IntraOnly; },
             "-seek"     => {
                 cur_arg += 1;
                 if cur_arg == args.len() {
                     println!("seek time missing");
                     return;
                 }
-                let ret = args[cur_arg].parse::<u64>();
+                let ret = args[cur_arg].parse::<NATimePoint>();
                 if ret.is_err() {
                     println!("wrong seek time");
                     return;
@@ -144,7 +139,12 @@ fn main() {
     let name = args[cur_arg].as_str();
     cur_arg += 1;
     if cur_arg < args.len() {
-        lastpts = Some(u64::from_str_radix(args[cur_arg].as_str(), 10).unwrap());
+        let ret = args[cur_arg].parse::<NATimePoint>();
+        if ret.is_err() {
+            println!("cannot parse end time");
+            return;
+        }
+        lastpts = ret.unwrap();
     }
 
     let path = Path::new(name);
@@ -169,7 +169,7 @@ println!("trying demuxer {} on {}", dmx_name, name);
     br.seek(SeekFrom::Start(0)).unwrap();
     let mut dmx = create_demuxer(dmx_fact, &mut br).unwrap();
 
-    if seek_time > 0 {
+    if seek_time != NATimePoint::None {
         let ret = dmx.seek(seek_time);
         if ret.is_err() {
 println!(" seek error {:?}", ret.err().unwrap());
@@ -179,6 +179,7 @@ println!(" seek error {:?}", ret.err().unwrap());
     let mut decs: Vec<Option<(Box<NADecoderSupport>, Box<dyn NADecoder>)>> = Vec::new();
     let mut sids: Vec<u32> = Vec::new();
     let mut writers: Vec<Outputter> = Vec::new();
+    let dec_opts = [NAOption{name: FRAME_SKIP_OPTION, value: NAValue::String(smode.to_string())}];
     for i in 0..dmx.get_num_streams() {
         let s = dmx.get_stream(i).unwrap();
         let info = s.get_info();
@@ -196,6 +197,7 @@ println!("stream {} - {} {}", i, s, info.get_name());
                 let mut dec = (decfunc.unwrap())();
                 let mut dsupp = Box::new(NADecoderSupport::new());
                 dec.init(&mut dsupp, info).unwrap();
+                dec.set_options(&dec_opts);
                 decs.push(Some((dsupp, dec)));
                 if !noout {
                     writers.push(Outputter::Video(FrameOutput{prefix: if let Some(ref str) = vpfx { str.clone() } else { "out".to_string() }, streamno: i, frameno: 1, nmode}));
@@ -228,7 +230,6 @@ println!("stream {} - {} {}", i, s, info.get_name());
             }
         } else {
             decs.push(None);
-panic!("decoder {} not found", info.get_name());
         }
         if !has_out {
             writers.push(Outputter::None);
@@ -262,7 +263,7 @@ panic!("decoder {} not found", info.get_name());
                         };
                     }
                 },
-                Err(DecoderError::MissingReference) if seek_time > 0 => {
+                Err(DecoderError::MissingReference) if seek_time != NATimePoint::None => {
                     println!("ignoring missing ref");
                 },
                 Err(reason) => {
@@ -272,7 +273,7 @@ panic!("decoder {} not found", info.get_name());
                     }
                 },
             };
-            if pkt.get_pts() != None && lastpts.is_some() && pkt.get_pts() >= lastpts { break; }
+            if pkt.get_pts() != None && lastpts != NATimePoint::None && !pkt.ts.less_than(lastpts) { break; }
         }
     }
 //panic!("end");