Method worker

src/inspect/FrameCapture.cpp:211–315

}

void FrameCapture::worker() {
  std::string addr = "255.255.255.255";
  auto dataPort = TCPPortProvider::Get().getValidPort();
  if (dataPort == 0) {
    return;
  }
  const auto procname = GetProcessName();
  const auto pnsz = std::min<size_t>(strlen(procname), WelcomeMessageProgramNameSize - 1);

  while (timeBegin.load(std::memory_order_relaxed) == 0) {
    std::this_thread::sleep_for(std::chrono::milliseconds(10));
  }

  auto welcome = WelcomeMessage();
  welcome.initBegin = GetInspector().initTime;
  welcome.initEnd = timeBegin.load(std::memory_order_relaxed);

  auto listen = ListenSocket{};
  bool isListening = false;
  for (uint16_t i = 0; i < 20; ++i) {
    if (listen.listenSock(dataPort + i, 4)) {
      dataPort += i;
      isListening = true;
      break;
    }
  }
  if (!isListening) {
    while (true) {
      if (ShouldExit()) {
        shutdown.store(true, std::memory_order_relaxed);
        return;
      }
      std::this_thread::sleep_for(std::chrono::milliseconds(10));
    }
  }
  for (uint16_t i = 0; i < BroadcastCount; i++) {
    broadcast[i] = std::make_shared<UDPBroadcast>();
    if (!broadcast[i]->openConnect(addr.c_str(), BroadcastPort + i)) {
      broadcast[i].reset();
    }
  }

  size_t broadcastLen = 0;
  auto broadcastMessage =
      GetBroadcastMessage(procname, pnsz, broadcastLen, dataPort, ToolType::FrameCapture);
  long long lastBroadcast = 0;
  while (true) {
    welcome.refTime = refTimeThread;
    while (true) {
      if (ShouldExit()) {
        for (uint16_t i = 0; i < BroadcastCount; i++) {
          if (broadcast[i]) {
            broadcastMessage.activeTime = -1;
            broadcast[i]->sendData(BroadcastPort + i, &broadcastMessage, broadcastLen);
          }
        }
        return;
      }