Method onSocketReadyRead

pj_widgets/src/RasterStreamView.cpp:76–95

}

void RasterStreamView::onSocketReadyRead() {
  while (socket_->bytesAvailable() >= pj_raster::kMessageBytes) {
    const QByteArray bytes = socket_->read(pj_raster::kMessageBytes);
    const pj_raster::Message msg = pj_raster::decodeMessage(reinterpret_cast<const uint8_t*>(bytes.constData()));
    if (msg.type == pj_raster::MsgType::kFrameReady && shm_ != nullptr) {
      if (!shm_->lock()) {
        continue;
      }
      const QImage view = imageForActiveFrame(static_cast<const unsigned char*>(shm_->constData()), shm_->size());
      frame_ = view.copy();
      shm_->unlock();
      if (!frame_.isNull()) {
        scaled_ = QImage();  // invalidate the cached scale; recomputed on next paint
        update();
      }
    } else if (msg.type == pj_raster::MsgType::kBye) {
      endSession();
    }
  }
}

void RasterStreamView::paintEvent(QPaintEvent* /*event*/) {
  QPainter painter(this);