Запись пользовательского DirectShow Исходного фильтра нажатия RTSP/RTP - устанавливающие метку времени данные, прибывающие из живых источников

Я пишу пользовательский исходный фильтр нажатия DirectShow, который, как предполагается, получает данные RTP из видеосервера и продвигает их к рендереру. Я записал класс CVideoPushPin, который наследовался классу CSourceStream и CVideoReceiverThread, который является оберткой для потока, которые получают пакеты RTP от видеосервера. Поток получателя по существу делает три вещи:

• получает необработанные пакеты RTP и собирает некоторые данные, которые необходимы для Отчетов о Получателе

• собирает кадры, копирует их в буфер и хранит информацию о них в 256 очередей элемента, которые определяются следующим образом:

  struct queue_elem {
     char *start; // Pointer to a frame in a buffer
     int length; // Lenght of data
     REFERENCE_TIME recvTime; // Timestamp when the frame was received (stream time)
  };
  
  struct data {
     struct queue_elem queue[QUEUE_LENGTH];
     int qWrIdx;
     int qRdIdx;
  HANDLE mutex;
  };
  

• к каждому полученному кадру добавляют метку времени с текущим потоковым временем

  p->StreamTime(refTime);
  REFERENCE_TIME rt = refTime.GetUnits();
  

Проблемы состоят в том, что я не уверен, как я должен установить метки времени для каждого MediaSample в методе FillBuffer. Я попробовал несколько путей, но воспроизведение или остановки или это являются слишком медленными. В настоящее время метод FillBuffer похож на это:

   REFERENCE_TIME thisFrameStartTime, thisFrameEndTime;
// Make sure if there are at least 4 frames in the buffer
    if(noOfFrames >= 4)
    {   
        currentQe = m_myData.queue[m_myData.qRdIdx++]; //Take current frame description     
        if(m_myData.qRdIdx >= QUEUE_LENGTH)
        {
            m_myData.qRdIdx = 0;
        }           
        nextQe = m_myData.queue[m_myData.qRdIdx]; //Take next frame description
        if(currentQe.length > 0)
        {
            memcpy(pData, currentQe.start, currentQe.length);               

             pSample->SetActualDataLength(currentQe.length);                
            CRefTime refTime;
            m_pFilter->StreamTime(refTime);
            REFERENCE_TIME rt;
            rt = refTime.GetUnits();
            pSample->GetTime(&thisFrameStartTime, &thisFrameEndTime);
            thisFrameEndTime = thisFrameStartTime + (nextQe.recvTime - currentQe.recvTime);
            pSample->SetTime(&thisFrameStartTime, &thisFrameEndTime);   
        }
    }
    else 
    {
        pSample->SetActualDataLength(0);
    }

В этом случае я заметил, что количество объектов в очереди увеличивается очень быстро (по некоторым причинам, метод FillBuffer не может вытащить данные достаточно быстро), и результат увеличивает задержку при проигрывании видео. У кого-либо есть идея, как я должен сделать добавление метки времени при получении данных из живых источников?