Method process

src/vt_rgb_packet_processor.cpp:121–177

}

void VTRgbPacketProcessor::process(const RgbPacket &packet)
{
  if (listener_ != 0) {
    impl_->startTiming();

    CMBlockBufferRef blockBuffer;
    CMBlockBufferCreateWithMemoryBlock(
        NULL,
        packet.jpeg_buffer,
        packet.jpeg_buffer_length,
        kCFAllocatorNull,
        NULL,
        0,
        packet.jpeg_buffer_length,
        0,
        &blockBuffer
    );

    CMSampleBufferRef sampleBuffer;
    CMSampleBufferCreate(
        NULL,
        blockBuffer,
        true,
        NULL,
        NULL,
        impl_->format,
        1,
        0,
        NULL,
        0,
        NULL,
        &sampleBuffer
    );

    CVPixelBufferRef pixelBuffer = NULL;
    VTDecompressionSessionDecodeFrame(impl_->decoder, sampleBuffer, 0, &pixelBuffer, NULL);

    Frame *frame = new VTFrame(1920, 1080, 4, pixelBuffer);
    frame->format = Frame::BGRX;

    frame->timestamp = packet.timestamp;
    frame->sequence = packet.sequence;
    frame->exposure = packet.exposure;
    frame->gain = packet.gain;
    frame->gamma = packet.gamma;

    if (!listener_->onNewFrame(Frame::Color, frame)) {
        // The listener didn't take ownership of the frame, so we delete it
        delete frame;
    }

    CFRelease(sampleBuffer);
    CFRelease(blockBuffer);

    impl_->stopTiming(LOG_INFO);
  }
}