Ettus UHD (USRP Hardware Driver). Работа с кольцевым буфером

using sample_t = std::complex<float>;
using Partition = std::pair<std::vector<sample_t *, size_t>;
 
// определенние количества приемных каналов устройства
size_t num = m_device->get_rx_num_channels();
// задаем максимальное (для данного устройства) количество сэмплов (частоту дискртизации)
size_t sample_rate = m_device->get_master_clock_rate(); // == 153600000;
 
// инициализация приемного потока устройства
/* здесь задаются параметры потока, в данном случае не суть какие */
uhd::streamargs_t sargs = ...;
// получаем поток 
uhd::rx_streamer::sptr stream = m_device->get_rx_stream(sargs);
 
// выделяем память под приемный буфер
/* здесь покажу проще: не буду строить весь колцевой буфер, покажу только одно его звено,
также в реальном коде используется numa.h и память выделяется 
в соотвествии с ядром на котором крутится поток чтения с устройства.*/
std::vector<sample_t> data(sample_rate * num);
 
// далее разбираем буфер на указатели так, как их принимает recv:
/*recv принимает массив указателей на начало буферов для каждого канала устройства
в моем случае у устройства может быть открыто до 4-х каналов*/
std::vector<sample_t *> buffs;
for (size_t i = 0; i < num; ++i) {
    buffs.push_back(&data[i * sample_rate]);
}
 
// далее разбираем буферы на партиции 
/* размер партиции соотвествует максимальному количеству cэмплов на пакет
и определяется драйвером */
size_t psize = stream->get_max_num_samps();
size_t sr = sample_rate;
 
std::vector<Partition> partitions;
while (sr) {
    Partition part{};
    for (size_t chan = 0; chan < num; ++i) {
        part.first.push_back(buffs[chan] + sample_rate - sr);
    }
 
    if (sr >= psize) {
        part.second = psize;
        sr -= psize;
    } else {
        part.second = sr;
        sr = 0;
    }
 
    partitions.pus_back(part);
}
 
/* дальнейший код выполняется в выделенном потоке чтения
и фиксирован на одном ядре*/
 
uhd::rx_metadata_t err;
// вариант 1: вычитываем с устройства все сэмплы за раз
size_t readed = 0;
readed = streamer->recv(buffs, sample_rate, err);
// в этом случае recv возвращает меньше чем запрошено через sample_rate,
// а в err записывается ERROR_CODE_OVERFLOW, то есть сервер не успевает
// вычитать все данные с устройства
 
// вариант 2:
readed = 0;
for (size_t i = 0; i < partitions.size() && readed < sample_rate && err.error_code != uhd::rx_metadata_t::ERROR_CODE_NONE; ++i) {
    readed += stream->recv(partitions[i].first, partitions[i].second, err);
}
// результат аналогичен первому варианту
 
// вариант 3:
for (size_t i = 0; i < partitions.size() && readed < sample_rate && err.error_code != uhd::rx_metadata_t::ERROR_CODE_NONE; ++i) {
    readed += stream->recv(partitions[i % 16].first, partitions[i % 16].second, err);
}
// в этом случае все работает идеально readed == sample_rate, err.error_code() == ERROR_CODE_NONE
// но за исключением того факта что данные перетираются в начале буфера, то есть в конце концов
// имеем в начале буфера 16 последних полученных партиций