newtx/scanner/async_scanner.h

68 lines
2.5 KiB
C++

#pragma once
#include <stdint.h>
#include <thread>
#include <functional>
#include <algorithm>
#include <memory>
#include <vector>
#include <base/utils.h>
#include <base/data.h>
class async_usb_gadget;
class device_option;
class image_capture;
class img_processor;
class gb_json;
class scanner_const_opts;
class scanner_hw;
class user_priv;
class imgproc_mgr;
class async_scanner : public refer
{
async_usb_gadget *usb_ = nullptr;
device_option *cfg_mgr_ = nullptr;
scanner_const_opts *const_opts_ = nullptr;
scanner_hw *cis_ = nullptr;
user_priv *user_ = nullptr;
imgproc_mgr *img_prcr_ = nullptr;
MUTEX locker_;
volatile bool connected_ = false;
uint32_t img_cnt_;
uint32_t scan_id_;
uint32_t scan_err_;
volatile bool reply_start_;
int last_err_ = 0;
MUTEX fsender_;
std::vector<file_reader*> send_files_;
dyn_mem_ptr handle_bulk_cmd(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
void init(void);
bool on_energy_conservation(bool normal/*true - working status; false - go to sleep*/); // return true to enable get into 'normal' status
dyn_mem_ptr handle_simple_roger(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
dyn_mem_ptr handle_get_opt_value(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
dyn_mem_ptr handle_get_opt_all(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
dyn_mem_ptr handle_set_opt(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
dyn_mem_ptr handle_file_receive(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
dyn_mem_ptr handle_file_send(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
dyn_mem_ptr handle_file_send_roger(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
dyn_mem_ptr handle_scan_start(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
dyn_mem_ptr handle_scan_stop(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
dyn_mem_ptr handle_process_cmd(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
public:
async_scanner();
protected:
~async_scanner();
public:
uint32_t stop(void);
int last_error(void);
};