main.cpp 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. #include "UVCGrabber/UVCDeviceManager.h"
  2. // #include "RTSPGrabber/InfraredManager.hpp"
  3. #include "MppDecoder/MppManager.h"
  4. #include "AIManager/RKNNManager.h"
  5. #include "LogRecorder/LogOutput.h"
  6. #include "DataManager/DataManager.h"
  7. #include "DataManager/DataPackage.h"
  8. #include "ImageTest/ImageTest.h"
  9. #include <stdexcept>
  10. #include <iostream>
  11. #include <json.hpp>
  12. #define DEVICE_NUM 3
  13. int main(int argc, char **argv)
  14. {
  15. // set usbfs memory to 64MB
  16. std::system("echo 64 > /sys/module/usbcore/parameters/usbfs_memory_mb");
  17. std::system("rm ./TimeLog.txt");
  18. // use json to read config file
  19. nlohmann::json config;
  20. try {
  21. std::ifstream config_file("./configure/config.json");
  22. config_file >> config;
  23. config_file.close();
  24. } catch (std::exception &e) {
  25. std::cerr << "Error reading config file: " << e.what() << std::endl;
  26. return 1;
  27. }
  28. UsbTest::TimeRecorder::getInstance().init();
  29. UsbTest::GlobalResolutionTimer::getInstance().start();
  30. UsbTest::SimulateTrigger::getInstance().startTrigger();
  31. LogConfiguration LogConfig; // 日志结构体
  32. LogConfig.FromFile("./configure/log.json");
  33. LOG_INIT("UsbDevice", LogConfig);
  34. if (OmniLoger::CLoger::get_instance().log_sink != nullptr)
  35. {
  36. std::cout << "Log initialized successfully" << std::endl;
  37. OmniLoger::CLoger::get_instance().log_sink->error("Error occurred during initialization");
  38. }
  39. // Initialize the UVC manager
  40. UVCManager::getInstance().init();
  41. MppManager::getInstance().addMppDecode();
  42. RKNNManager::getInstance().setGrpcServerAddress(config["grpc_server_address"]);
  43. RKNNManager::getInstance().addRknnTask(config["rknn_model_path"]);
  44. // Start all streaming
  45. UVCManager::getInstance().startAllStreaming();
  46. // Wait for the user to press a key
  47. std::cin.get();
  48. RKNNManager::getInstance().StopProcessData();
  49. // Stop all streaming
  50. UVCManager::getInstance().stopAllStreaming();
  51. return 0;
  52. }