|
1
|
1 #include "stdafx.h"
|
|
|
2 #include <helpers/input_helpers.h>
|
|
|
3
|
|
|
4 class calculate_peak_process : public threaded_process_callback {
|
|
|
5 public:
|
|
|
6 calculate_peak_process(metadb_handle_list_cref items) : m_items(items), m_peak() {}
|
|
|
7 void on_init(ctx_t p_wnd) override {}
|
|
|
8 void run(threaded_process_status & p_status,abort_callback & p_abort) override {
|
|
|
9 try {
|
|
|
10 const t_uint32 decode_flags = input_flag_no_seeking | input_flag_no_looping; // tell the decoders that we won't seek and that we don't want looping on formats that support looping.
|
|
|
11 input_helper input; // this object manages lowlevel input_decoder calls for us.
|
|
|
12 for(t_size walk = 0; walk < m_items.get_size(); ++walk) {
|
|
|
13 p_abort.check(); // in case the input we're working with fails at doing this
|
|
|
14 p_status.set_progress(walk, m_items.get_size());
|
|
|
15 p_status.set_progress_secondary(0);
|
|
|
16 p_status.set_item_path( m_items[walk]->get_path() );
|
|
|
17 input.open(NULL, m_items[walk], decode_flags, p_abort);
|
|
|
18
|
|
|
19 double length;
|
|
|
20 { // fetch the track length for proper dual progress display;
|
|
|
21 file_info_impl info;
|
|
|
22 // input.open should have preloaded relevant info, no need to query the input itself again.
|
|
|
23 // Regular get_info() may not retrieve freshly loaded info yet at this point (it will start giving the new info when relevant info change callbacks are dispatched); we need to use get_info_async.
|
|
|
24 if (m_items[walk]->get_info_async(info)) length = info.get_length();
|
|
|
25 else length = 0;
|
|
|
26 }
|
|
|
27
|
|
|
28 audio_chunk_impl_temporary l_chunk;
|
|
|
29 double decoded = 0;
|
|
|
30 while(input.run(l_chunk, p_abort)) { // main decode loop
|
|
|
31 m_peak = l_chunk.get_peak(m_peak);
|
|
|
32 if (length > 0) { // don't bother for unknown length tracks
|
|
|
33 decoded += l_chunk.get_duration();
|
|
|
34 if (decoded > length) decoded = length;
|
|
|
35 p_status.set_progress_secondary_float(decoded / length);
|
|
|
36 }
|
|
|
37 p_abort.check(); // in case the input we're working with fails at doing this
|
|
|
38 }
|
|
|
39 }
|
|
|
40 } catch(std::exception const & e) {
|
|
|
41 m_failMsg = e.what();
|
|
|
42 }
|
|
|
43 }
|
|
|
44 void on_done(ctx_t p_wnd,bool p_was_aborted) override {
|
|
|
45 if (!p_was_aborted) {
|
|
|
46 if (!m_failMsg.is_empty()) {
|
|
|
47 popup_message::g_complain("Peak scan failure", m_failMsg);
|
|
|
48 } else {
|
|
|
49 pfc::string_formatter result;
|
|
|
50 result << "Value: " << m_peak << "\n\n";
|
|
|
51 result << "Scanned items:\n";
|
|
|
52 for(t_size walk = 0; walk < m_items.get_size(); ++walk) {
|
|
|
53 result << m_items[walk] << "\n";
|
|
|
54 }
|
|
|
55 popup_message::g_show(result,"Peak scan result");
|
|
|
56 }
|
|
|
57 }
|
|
|
58 }
|
|
|
59 private:
|
|
|
60 audio_sample m_peak;
|
|
|
61 pfc::string8 m_failMsg;
|
|
|
62 const metadb_handle_list m_items;
|
|
|
63 };
|
|
|
64
|
|
|
65 void RunCalculatePeak(metadb_handle_list_cref data) {
|
|
|
66 try {
|
|
|
67 if (data.get_count() == 0) throw pfc::exception_invalid_params();
|
|
|
68 service_ptr_t<threaded_process_callback> cb = new service_impl_t<calculate_peak_process>(data);
|
|
|
69 static_api_ptr_t<threaded_process>()->run_modeless(
|
|
|
70 cb,
|
|
|
71 threaded_process::flag_show_progress_dual | threaded_process::flag_show_item | threaded_process::flag_show_abort,
|
|
|
72 core_api::get_main_window(),
|
|
|
73 "Sample component: peak scan");
|
|
|
74 } catch(std::exception const & e) {
|
|
|
75 popup_message::g_complain("Could not start peak scan process", e);
|
|
|
76 }
|
|
|
77 }
|
