diff --git a/src/ITANetAudioStreamingServer.cpp b/src/ITANetAudioStreamingServer.cpp index 463d1d59e9fd5b2f3d11d07559d9ee01211dfa4f..ea5c2add747ad90f13d1cabeccdb664be97363a1 100644 --- a/src/ITANetAudioStreamingServer.cpp +++ b/src/ITANetAudioStreamingServer.cpp @@ -1,38 +1,38 @@ -#include -#include - -// ITA includes -#include -#include -#include - -// Vista includes -#include -#include -#include -#include -#include -#include - -// STL -#include -#include - -CITANetAudioStreamingServer::CITANetAudioStreamingServer() - : m_pInputStream( NULL ) - , m_iUpdateStrategy( AUTO ) - , m_pSocket( NULL ) -{ - m_pNetAudioServer = new CITANetAudioServer(); - // TODO: Init members -} - -bool CITANetAudioStreamingServer::Start(const std::string& sAddress, int iPort) -{ - // TODO: vorrückgabe noch anfangen zu senden (Samples) - if (m_pNetAudioServer->Start(sAddress, iPort)) - { - m_pSocket = m_pNetAudioServer->GetSocket(); +#include +#include + +// ITA includes +#include +#include +#include + +// Vista includes +#include +#include +#include +#include +#include +#include + +// STL +#include +#include + +CITANetAudioStreamingServer::CITANetAudioStreamingServer() + : m_pInputStream( NULL ) + , m_iUpdateStrategy( AUTO ) + , m_pSocket( NULL ) +{ + m_pNetAudioServer = new CITANetAudioServer(); + // TODO: Init members +} + +bool CITANetAudioStreamingServer::Start(const std::string& sAddress, int iPort) +{ + // TODO: vorrückgabe noch anfangen zu senden (Samples) + if (m_pNetAudioServer->Start(sAddress, iPort)) + { + m_pSocket = m_pNetAudioServer->GetSocket(); // TODO: Init neu mit Netmessage long nIncomingBytes = m_pSocket->WaitForIncomingData(0); int iBytesReceived = m_pSocket->ReceiveRaw(&m_initData, sizeof( InitData )); @@ -43,63 +43,63 @@ bool CITANetAudioStreamingServer::Start(const std::string& sAddress, int iPort) Run(); - return true; - return true; - } - return false; -} - -bool CITANetAudioStreamingServer::IsClientConnected() const -{ - return m_pNetAudioServer->IsConnected(); -} - -std::string CITANetAudioStreamingServer::GetNetworkAddress() const -{ - return m_pNetAudioServer->GetServerAddress(); -} - -int CITANetAudioStreamingServer::GetNetworkPort() const -{ - return m_pNetAudioServer->GetNetworkPort(); -} - -void CITANetAudioStreamingServer::Stop() -{ - m_pNetAudioServer->Disconnect(); -} - -void CITANetAudioStreamingServer::SetInputStream( ITADatasource* pInStream ) -{ - m_pInputStream = pInStream; -} - -int CITANetAudioStreamingServer::GetNetStreamBlocklength() const -{ - return m_sfTempTransmitBuffer.GetLength(); -} - -int CITANetAudioStreamingServer::GetNetStreamNumberOfChannels() const -{ - return m_sfTempTransmitBuffer.channels(); -} - -double CITANetAudioStreamingServer::GetNetStreamSampleRate() const -{ - return m_dClientSampleRate; -} - -void CITANetAudioStreamingServer::SetAutomaticUpdateRate() -{ - m_iUpdateStrategy = AUTO; -} - -ITADatasource* CITANetAudioStreamingServer::GetInputStream() const -{ - return m_pInputStream; -} - -int CITANetAudioStreamingServer::Transmit(const ITASampleFrame& sfNewSamples, int iNumSamples) -{ - return 0; -} + return true; + return true; + } + return false; +} + +bool CITANetAudioStreamingServer::IsClientConnected() const +{ + return m_pNetAudioServer->IsConnected(); +} + +std::string CITANetAudioStreamingServer::GetNetworkAddress() const +{ + return m_pNetAudioServer->GetServerAddress(); +} + +int CITANetAudioStreamingServer::GetNetworkPort() const +{ + return m_pNetAudioServer->GetNetworkPort(); +} + +void CITANetAudioStreamingServer::Stop() +{ + m_pNetAudioServer->Disconnect(); +} + +void CITANetAudioStreamingServer::SetInputStream( ITADatasource* pInStream ) +{ + m_pInputStream = pInStream; +} + +int CITANetAudioStreamingServer::GetNetStreamBlocklength() const +{ + return m_sfTempTransmitBuffer.GetLength(); +} + +int CITANetAudioStreamingServer::GetNetStreamNumberOfChannels() const +{ + return m_sfTempTransmitBuffer.channels(); +} + +double CITANetAudioStreamingServer::GetNetStreamSampleRate() const +{ + return m_initData.dClientSampleRate; +} + +void CITANetAudioStreamingServer::SetAutomaticUpdateRate() +{ + m_iUpdateStrategy = AUTO; +} + +ITADatasource* CITANetAudioStreamingServer::GetInputStream() const +{ + return m_pInputStream; +} + +int CITANetAudioStreamingServer::Transmit(const ITASampleFrame& sfNewSamples, int iNumSamples) +{ + return 0; +}