mirror of
				https://github.com/f4exb/sdrangel.git
				synced 2025-10-31 04:50:29 -04:00 
			
		
		
		
	SDRdaemonSink: fixed remote address in case FEC is activated
This commit is contained in:
		
							parent
							
								
									a86819ea70
								
							
						
					
					
						commit
						34b1910cd0
					
				| @ -550,18 +550,23 @@ void SDRdaemonSinkGui::tick() | ||||
|                     int samplesCorr = 0; | ||||
|                     bool quickStart = false; | ||||
| 
 | ||||
|                     if (queueLength == 0) | ||||
|                     if (queueLength < 2) | ||||
|                     { | ||||
|                         samplesCorr = 127*8; | ||||
|                         quickStart = true; | ||||
|                     } | ||||
|                     else if (queueLength < 5) | ||||
|                     else if (queueLength < 8) | ||||
|                     { | ||||
|                         samplesCorr = ((5 - queueLength)*16)/m_nbSinceLastFlowCheck; | ||||
|                         samplesCorr = ((8 - queueLength)*16)/m_nbSinceLastFlowCheck; | ||||
|                     } | ||||
|                     else if (queueLength > 5) | ||||
|                     else if (queueLength > 8) | ||||
|                     { | ||||
|                         samplesCorr = ((5 - queueLength)*16)/m_nbSinceLastFlowCheck; | ||||
|                         samplesCorr = ((8 - queueLength)*16)/m_nbSinceLastFlowCheck; | ||||
|                     } | ||||
|                     else if (queueLength > 16) | ||||
|                     { | ||||
|                         samplesCorr = -127*16; | ||||
|                         quickStart = true; | ||||
|                     } | ||||
| 
 | ||||
|                     if (samplesCorr != 0) | ||||
|  | ||||
| @ -330,7 +330,7 @@ void UDPSinkFECWorker::encodeAndTransmit(UDPSinkFEC::SuperBlock *txBlockx, uint1 | ||||
| //
 | ||||
| //            std::cerr << std::endl;
 | ||||
| 
 | ||||
|             m_socket.SendDataGram((const void *) &txBlockx[i], (int) UDPSinkFEC::m_udpSize, "127.0.0.1", (uint32_t) m_remotePort); | ||||
|             m_socket.SendDataGram((const void *) &txBlockx[i], (int) UDPSinkFEC::m_udpSize, m_remoteAddress.toStdString(), (uint32_t) m_remotePort); | ||||
|             //m_udpSocket->writeDatagram((const char *) &txBlockx[i], (int) UDPSinkFEC::m_udpSize, m_remoteAddress, m_remotePort);
 | ||||
|             usleep(txDelay); | ||||
|         } | ||||
|  | ||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user