summaryrefslogtreecommitdiff
path: root/AudioManagerCore/src/CAmRoutingSender.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'AudioManagerCore/src/CAmRoutingSender.cpp')
-rw-r--r--AudioManagerCore/src/CAmRoutingSender.cpp25
1 files changed, 24 insertions, 1 deletions
diff --git a/AudioManagerCore/src/CAmRoutingSender.cpp b/AudioManagerCore/src/CAmRoutingSender.cpp
index 36f5c1a..fc9f879 100644
--- a/AudioManagerCore/src/CAmRoutingSender.cpp
+++ b/AudioManagerCore/src/CAmRoutingSender.cpp
@@ -285,7 +285,7 @@ am_Error_e CAmRoutingSender::asyncConnect(am_Handle_s &handle, am_connectionID_t
tempConnection.connectionID = 0;
tempConnection.delay = -1;
- am_Error_e connError(mpDatabaseHandler->enterConnectionDB(tempConnection, connectionID));
+ am_Error_e connError(mpDatabaseHandler->enterConnectionDB(tempConnection, connectionID, false));
if (connError)
{
return(connError);
@@ -921,6 +921,29 @@ void CAmRoutingSender::setRoutingRundown()
}
}
+am_Error_e CAmRoutingSender::asyncTransferConnection(am_Handle_s &handle, am_domainID_t domainID
+ , const std::vector<std::pair<std::string, std::string>> &route, am_ConnectionState_e state)
+{
+ auto iter = mMapDomainInterface.find(domainID);
+ if (iter != mMapDomainInterface.end() && iter->second)
+ {
+ auto handleData = std::make_shared<handleTransfer>(iter->second, route, state, mpDatabaseHandler);
+ handle = createHandle(handleData, H_TRANSFERCONNECTION);
+
+ logInfo(__METHOD_NAME__, "handle=", handle);
+
+ am_Error_e success = iter->second->asyncTransferConnection(handle, domainID, route, state);
+ if (success != E_OK)
+ {
+ removeHandle(handle);
+ }
+ return success;
+ }
+
+ // given domain not found in map
+ return E_NON_EXISTENT;
+}
+
am_Error_e CAmRoutingSender::asyncSetVolumes(am_Handle_s &handle, const std::vector<am_Volumes_s> &listVolumes)
{
IAmRoutingSend *pRoutingInterface(NULL);