summaryrefslogtreecommitdiff
path: root/AudioManagerDaemon/src
diff options
context:
space:
mode:
authorchristian mueller <christian.ei.mueller@bmw.de>2012-02-29 13:27:27 +0100
committerchristian mueller <christian.ei.mueller@bmw.de>2012-02-29 13:27:27 +0100
commitd3ccf97331935b181041394b80be20dca282ea71 (patch)
treef85e7b649c8a6d58c11e9728b2442cdcff53826d /AudioManagerDaemon/src
parentaa93713377d28a8ce7821466ef828f79a18e982d (diff)
downloadaudiomanager-d3ccf97331935b181041394b80be20dca282ea71.tar.gz
* [ performance] for classes that do not need to be derived from, removed virtual desctructor
* implemented confirmation of routing ready in RoutingReceiver * [Sockethandler] automatically set gDispatchDone to 0 when starting mainloop * fixed unit text to work with latest changes (expect Dbus command interface) * [GAM-4] added way to do synchronous calling on interfaces with the help of CAmSerializer.h * reworked AsyncRoutingPlugin to work with CAmSerializer.h * reworked AsyncRoutingPlugin to register elemtes in thread using CAmSerializer.h * reworked AsncPlugin Tests to work with remodelled Plugin
Diffstat (limited to 'AudioManagerDaemon/src')
-rw-r--r--AudioManagerDaemon/src/CommandReceiver.cpp5
-rw-r--r--AudioManagerDaemon/src/RoutingReceiver.cpp19
-rw-r--r--AudioManagerDaemon/src/RoutingSender.cpp8
-rw-r--r--AudioManagerDaemon/src/SocketHandler.cpp1
4 files changed, 19 insertions, 14 deletions
diff --git a/AudioManagerDaemon/src/CommandReceiver.cpp b/AudioManagerDaemon/src/CommandReceiver.cpp
index 74b819b..21e19d9 100644
--- a/AudioManagerDaemon/src/CommandReceiver.cpp
+++ b/AudioManagerDaemon/src/CommandReceiver.cpp
@@ -27,7 +27,6 @@
#include "ControlSender.h"
#include "DLTWrapper.h"
#include <SocketHandler.h>
-#include <config.h>
#include <cassert>
#include <algorithm>
@@ -211,12 +210,12 @@ uint16_t CommandReceiver::getRundownHandle()
return handle;
}
-void am::CommandReceiver::waitOnStartup(bool startup)
+void CommandReceiver::waitOnStartup(bool startup)
{
mWaitStartup = startup;
}
-void am::CommandReceiver::waitOnRundown(bool rundown)
+void CommandReceiver::waitOnRundown(bool rundown)
{
mWaitRundown = rundown;
}
diff --git a/AudioManagerDaemon/src/RoutingReceiver.cpp b/AudioManagerDaemon/src/RoutingReceiver.cpp
index fb160b0..715fa36 100644
--- a/AudioManagerDaemon/src/RoutingReceiver.cpp
+++ b/AudioManagerDaemon/src/RoutingReceiver.cpp
@@ -24,14 +24,14 @@
*/
#include "RoutingReceiver.h"
-#include <SocketHandler.h>
-#ifdef WITH_DBUS_WRAPPER
-#include <dbus/DBusWrapper.h>
-#endif
#include "DatabaseHandler.h"
#include "RoutingSender.h"
#include "ControlSender.h"
+#include "DLTWrapper.h"
+#include <SocketHandler.h>
#include <cassert>
+#include <algorithm>
+
using namespace am;
@@ -342,13 +342,18 @@ void RoutingReceiver::getInterfaceVersion(std::string & version) const
version = RoutingReceiveVersion;
}
-void RoutingReceiver::confirmRoutingReady(const uint16_t handle) const
+void RoutingReceiver::confirmRoutingReady(const uint16_t handle)
{
-
+ mListStartupHandles.erase(std::remove(mListStartupHandles.begin(), mListStartupHandles.end(), handle), mListStartupHandles.end());
+ if (mWaitStartup && mListStartupHandles.empty())
+ mControlSender->confirmRoutingReady();
}
-void RoutingReceiver::confirmRoutingRundown(const uint16_t handle) const
+void RoutingReceiver::confirmRoutingRundown(const uint16_t handle)
{
+ mListRundownHandles.erase(std::remove(mListRundownHandles.begin(), mListRundownHandles.end(), handle), mListRundownHandles.end());
+ if (mWaitRundown && mListRundownHandles.empty())
+ mControlSender->confirmCommandRundown();
}
uint16_t am::RoutingReceiver::getStartupHandle()
diff --git a/AudioManagerDaemon/src/RoutingSender.cpp b/AudioManagerDaemon/src/RoutingSender.cpp
index 76c671d..c59641d 100644
--- a/AudioManagerDaemon/src/RoutingSender.cpp
+++ b/AudioManagerDaemon/src/RoutingSender.cpp
@@ -300,7 +300,7 @@ am_Error_e RoutingSender::asyncSetSourceSoundProperty(am_Handle_s& handle, const
return (E_NON_EXISTENT);
}
-am_Error_e am::RoutingSender::asyncSetSourceSoundProperties(am_Handle_s& handle, const std::vector<am_SoundProperty_s> & listSoundProperties, const am_sourceID_t sourceID)
+am_Error_e RoutingSender::asyncSetSourceSoundProperties(am_Handle_s& handle, const std::vector<am_SoundProperty_s> & listSoundProperties, const am_sourceID_t sourceID)
{
am_handleData_c handleData;
SourceInterfaceMap::iterator iter = mMapSourceInterface.begin();
@@ -314,7 +314,7 @@ am_Error_e am::RoutingSender::asyncSetSourceSoundProperties(am_Handle_s& handle,
return (E_NON_EXISTENT);
}
-am_Error_e am::RoutingSender::asyncSetSinkSoundProperties(am_Handle_s& handle, const std::vector<am_SoundProperty_s> & listSoundProperties, const am_sinkID_t sinkID)
+am_Error_e RoutingSender::asyncSetSinkSoundProperties(am_Handle_s& handle, const std::vector<am_SoundProperty_s> & listSoundProperties, const am_sinkID_t sinkID)
{
am_handleData_c handleData;
SinkInterfaceMap::iterator iter = mMapSinkInterface.begin();
@@ -493,7 +493,7 @@ RoutingSender::am_handleData_c RoutingSender::returnHandleData(const am_Handle_s
return (it->second);
}
-void am::RoutingSender::setRoutingReady()
+void RoutingSender::setRoutingReady()
{
mRoutingReceiver->waitOnStartup(false);
std::vector<InterfaceNamePairs>::iterator iter = mListInterfaces.begin();
@@ -505,7 +505,7 @@ void am::RoutingSender::setRoutingReady()
mRoutingReceiver->waitOnStartup(true);
}
-void am::RoutingSender::setRoutingRundown()
+void RoutingSender::setRoutingRundown()
{
mRoutingReceiver->waitOnRundown(false);
std::vector<InterfaceNamePairs>::iterator iter = mListInterfaces.begin();
diff --git a/AudioManagerDaemon/src/SocketHandler.cpp b/AudioManagerDaemon/src/SocketHandler.cpp
index d9fdc3a..444289f 100644
--- a/AudioManagerDaemon/src/SocketHandler.cpp
+++ b/AudioManagerDaemon/src/SocketHandler.cpp
@@ -64,6 +64,7 @@ SocketHandler::~SocketHandler()
*/
void SocketHandler::start_listenting()
{
+ gDispatchDone=0;
int16_t pollStatus;
std::list<int16_t> hitList;