diff --git a/plugins/samplesource/soapysdrinput/soapysdrinputthread.cpp b/plugins/samplesource/soapysdrinput/soapysdrinputthread.cpp
index 5c58301c6..298d91f6d 100644
--- a/plugins/samplesource/soapysdrinput/soapysdrinputthread.cpp
+++ b/plugins/samplesource/soapysdrinput/soapysdrinputthread.cpp
@@ -160,24 +160,24 @@ void SoapySDRInputThread::run()
             {
                 if (m_nbChannels > 1)
                 {
-                    callbackMIIQ(buffs, numElems*2); // size given in number of I or Q samples (2 items per sample)
+                    callbackMIIQ(buffs, ret*2); // size given in number of I or Q samples (2 items per sample)
                 }
                 else
                 {
                     switch (m_decimatorType)
                     {
                     case Decimator8:
-                        callbackSI8IQ((const qint8*) buffs[0], numElems*2);
+                        callbackSI8IQ((const qint8*) buffs[0], ret*2);
                         break;
                     case Decimator12:
-                        callbackSI12IQ((const qint16*) buffs[0], numElems*2);
+                        callbackSI12IQ((const qint16*) buffs[0], ret*2);
                         break;
                     case Decimator16:
-                        callbackSI16IQ((const qint16*) buffs[0], numElems*2);
+                        callbackSI16IQ((const qint16*) buffs[0], ret*2);
                         break;
                     case DecimatorFloat:
                     default:
-                        callbackSIFIQ((const float*) buffs[0], numElems*2);
+                        callbackSIFIQ((const float*) buffs[0], ret*2);
                     }
                 }
             }
@@ -185,24 +185,24 @@ void SoapySDRInputThread::run()
             {
                 if (m_nbChannels > 1)
                 {
-                    callbackMIQI(buffs, numElems*2); // size given in number of I or Q samples (2 items per sample)
+                    callbackMIQI(buffs, ret*2); // size given in number of I or Q samples (2 items per sample)
                 }
                 else
                 {
                     switch (m_decimatorType)
                     {
                     case Decimator8:
-                        callbackSI8QI((const qint8*) buffs[0], numElems*2);
+                        callbackSI8QI((const qint8*) buffs[0], ret*2);
                         break;
                     case Decimator12:
-                        callbackSI12QI((const qint16*) buffs[0], numElems*2);
+                        callbackSI12QI((const qint16*) buffs[0], ret*2);
                         break;
                     case Decimator16:
-                        callbackSI16QI((const qint16*) buffs[0], numElems*2);
+                        callbackSI16QI((const qint16*) buffs[0], ret*2);
                         break;
                     case DecimatorFloat:
                     default:
-                        callbackSIFQI((const float*) buffs[0], numElems*2);
+                        callbackSIFQI((const float*) buffs[0], ret*2);
                     }
                 }
             }