sender.cpp

#include "sender.h"
#include <QSharedMemory>

const bool RESIZE = false;

Sender::Sender(std::string ip1):
  ack(0),
  porta(port3),
  portb(port4),
  ep1(boost::asio::ip::address::from_string(ip1), port1),
  // ep2(ip::address::from_string(ip1), port2),
  recvSocket(sender_ioc, boost::asio::ip::udp::endpoint(boost::asio::ip::udp::v4(), port3)),
  sendSocket(sender_ioc, boost::asio::ip::udp::endpoint(boost::asio::ip::udp::v4(), port4))  {
    memset(recv_data, 0, sizeof(recv_data));
}

int Sender::get_frame_rate() {
//    return 3;
    QString sharedMessage;
    QSharedMemory* sharedMemory = new QSharedMemory("frame_rate");
    sharedMemory->attach();
    sharedMemory->lock();
    QByteArray sharedData(sharedMemory->size(), '\0');

    memcpy(sharedData.data(), sharedMemory->data(), sharedMemory->size());
    sharedMemory->unlock();

    sharedMessage = QString::fromLatin1(sharedData);
//    qDebug() << "get: " << sharedMessage;
    sharedMemory->detach();
    if(sharedMessage == "") return 12;
    return sharedMessage.toInt();
}

void Sender::send() {
//  print("sender start");
  std::cout << "sender start" << std::endl;

  cv::Mat frame, frame2;
  cv::VideoCapture cap;

  int deviceID = 0;             // 0 = open default camera
  int apiID = cv::CAP_ANY;      // 0 = autodetect default API
  // open selected camera using selected API
  cap.open(deviceID, apiID);
  // check if we succeeded
  if (!cap.isOpened()) {
      std::cerr << "ERROR! Unable to open camera\n";
      return;
  }
  //--- GRAB AND WRITE LOOP
  std::cout << "Start grabbing" << std::endl
      << "Press any key to terminate" << std::endl;

  // print("input frame rate"); 
  // cin >> frame_24_fractor; 
//  int tmp_rate = 3;
  int frame_24_fractor = 12;
  int cnt = 0;
  while(true) {
    cnt++;
    if(cnt % 24 == 0) {
      frame_24_fractor = get_frame_rate();
      qDebug() << frame_24_fractor << "per s";
    }

    // video
    ack = 1;
    if(ack) {
      cap.read(frame);
      if (frame.empty()) {
        std::cerr << "ERROR! blank frame grabbed\n";
        break;
      }
      // resize(frame, frame2, Size(), 0.01, 0.01);
      // cout << frame2 << endl;
      if(RESIZE)
        resize(frame, frame2, cv::Size(), 0.25, 0.25);
      else {
        resize(frame, frame2, cv::Size(), 1, 1);
      }

      // imshow("Live", frame);
      // char buf[65535];
      // cout << sizeof(frame) << "--" << sizeof(buf);
      // cout << frame;
      // break;
      // frame2 = frame;
      int shrinksize = (frame2.dataend - frame2.datastart);
      if(RESIZE)
        sendSocket.send_to(boost::asio::buffer((char*)frame2.data, shrinksize), ep1);
      else {
          int ack = 31415926; 
          sendSocket.send_to(boost::asio::buffer(&ack, sizeof(ack)), ep1);
          int shrinksize_seg  = shrinksize / 16;
          char buf[65000]; 
          for(int i = 0;i < 16; ++i) {
            memset(&buf, 0, sizeof(buf));
            memcpy(buf, &i, sizeof(int)); 
            memcpy(buf + sizeof(int), (char*)(frame2.data + i * shrinksize_seg ), shrinksize_seg + sizeof(int)); 
            sendSocket.send_to(boost::asio::buffer(buf), ep1);
//            Sleep(1000 / (frame_24_fractor * 16));
            usleep(1000000 / (frame_24_fractor * 16));
//            Sleep(tmp_rate);
            // sendSocket.send_to(boost::asio::buffer((char*)(frame2.data + i * shrinksize_seg), shrinksize_seg), ep1);
          }
          if(rate_ok.load() == false) {
//              tmp_rate++;
//              qDebug() << "tmp_rate: " << tmp_rate;
          }
      }
      // cout << shrinksize << "-=-=";
      // break;
//      imshow("sender", frame2);
      // print("ok_sender");
//        if (waitKey(20) == 27) { break; }
      ack = 0;
      // break;
      // sleep(1);
//        boost::this_thread::sleep(boost::posix_time::millisec(1000 / 24));
    }

    // only text
    // if(ack) {
    //   print("receive,\n cin");
    //   char buf[maxn];
    //   cin >> buf;
    //   sendSocket.send_to(buffer(buf), ep1);
    //   // sendSocket.send_to(buffer(recv_data), ep2);
    //   ack = 0;
    // }
  }
}
void Sender::recv() {
//  print("receiver start");
  while(1) {
    recvSocket.receive_from(boost::asio::buffer(&ack, sizeof(ack)), ep2);
  }
}