1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
/**
* SPDX license identifier: MPL-2.0
*
* Copyright (C) 2012, BMW AG
*
* This file is part of GENIVI Project AudioManager.
*
* Contributions are licensed to the GENIVI Alliance under one or more
* Contribution License Agreements.
*
* \copyright
* This Source Code Form is subject to the terms of the
* Mozilla Public License, v. 2.0. If a copy of the MPL was not distributed with
* this file, You can obtain one at http://mozilla.org/MPL/2.0/.
*
*
* \author Christian Linke, christian.linke@bmw.de BMW 2011,2012
*
* \file CAmRoutingReceiver.h
* For further information see http://www.genivi.org/.
*
*/
#ifndef ROUTINGRECEIVER_H_
#define ROUTINGRECEIVER_H_
#include "IAmRouting.h"
namespace am
{
class CAmSocketHandler;
class CAmDbusWrapper;
class IAmDatabaseHandler;
class CAmRoutingSender;
class CAmControlSender;
/**
* Implements the Receiving side of the RoutingPlugins.
*/
class CAmRoutingReceiver: public IAmRoutingReceive
{
public:
CAmRoutingReceiver(IAmDatabaseHandler *iDatabaseHandler, CAmRoutingSender *iRoutingSender, CAmControlSender *iControlSender, CAmSocketHandler *iSocketHandler);
CAmRoutingReceiver(IAmDatabaseHandler *iDatabaseHandler, CAmRoutingSender *iRoutingSender, CAmControlSender *iControlSender, CAmSocketHandler *iSocketHandler, CAmDbusWrapper *iDBusWrapper);
~CAmRoutingReceiver();
void ackConnect(const am_Handle_s handle, const am_connectionID_t connectionID, const am_Error_e error);
void ackDisconnect(const am_Handle_s handle, const am_connectionID_t connectionID, const am_Error_e error);
void ackSetSinkVolumeChange(const am_Handle_s handle, const am_volume_t volume, const am_Error_e error);
void ackSetSourceVolumeChange(const am_Handle_s handle, const am_volume_t volume, const am_Error_e error);
void ackSetSourceState(const am_Handle_s handle, const am_Error_e error);
void ackSetSinkSoundProperties(const am_Handle_s handle, const am_Error_e error);
void ackSetSinkSoundProperty(const am_Handle_s handle, const am_Error_e error);
void ackSetSourceSoundProperties(const am_Handle_s handle, const am_Error_e error);
void ackSetSourceSoundProperty(const am_Handle_s handle, const am_Error_e error);
void ackCrossFading(const am_Handle_s handle, const am_HotSink_e hotSink, const am_Error_e error);
void ackSourceVolumeTick(const am_Handle_s handle, const am_sourceID_t sourceID, const am_volume_t volume);
void ackSinkVolumeTick(const am_Handle_s handle, const am_sinkID_t sinkID, const am_volume_t volume);
am_Error_e peekDomain(const std::string& name, am_domainID_t& domainID);
am_Error_e registerDomain(const am_Domain_s& domainData, am_domainID_t& domainID);
am_Error_e deregisterDomain(const am_domainID_t domainID);
am_Error_e registerGateway(const am_Gateway_s& gatewayData, am_gatewayID_t& gatewayID);
am_Error_e registerConverter(const am_Converter_s& converterData, am_converterID_t& converterID);
am_Error_e deregisterGateway(const am_gatewayID_t gatewayID);
am_Error_e deregisterConverter(const am_converterID_t converterID);
am_Error_e peekSink(const std::string& name, am_sinkID_t& sinkID);
am_Error_e registerSink(const am_Sink_s& sinkData, am_sinkID_t& sinkID);
am_Error_e deregisterSink(const am_sinkID_t sinkID);
am_Error_e peekSource(const std::string& name, am_sourceID_t& sourceID);
am_Error_e registerSource(const am_Source_s& sourceData, am_sourceID_t& sourceID);
am_Error_e deregisterSource(const am_sourceID_t sourceID);
am_Error_e registerCrossfader(const am_Crossfader_s& crossfaderData, am_crossfaderID_t& crossfaderID);
am_Error_e deregisterCrossfader(const am_crossfaderID_t crossfaderID);
am_Error_e peekSourceClassID(const std::string& name, am_sourceClass_t& sourceClassID);
am_Error_e peekSinkClassID(const std::string& name, am_sinkClass_t& sinkClassID);
void hookInterruptStatusChange(const am_sourceID_t sourceID, const am_InterruptState_e interruptState);
void hookDomainRegistrationComplete(const am_domainID_t domainID);
void hookSinkAvailablityStatusChange(const am_sinkID_t sinkID, const am_Availability_s& availability);
void hookSourceAvailablityStatusChange(const am_sourceID_t sourceID, const am_Availability_s& availability);
void hookDomainStateChange(const am_domainID_t domainID, const am_DomainState_e domainState);
void hookTimingInformationChanged(const am_connectionID_t connectionID, const am_timeSync_t delay);
void sendChangedData(const std::vector<am_EarlyData_s>& earlyData);
am_Error_e getDBusConnectionWrapper(CAmDbusWrapper*& dbusConnectionWrapper) const;
am_Error_e getSocketHandler(CAmSocketHandler*& socketHandler) const;
void getInterfaceVersion(std::string& version) const;
void confirmRoutingReady(const uint16_t handle, const am_Error_e error);
void confirmRoutingRundown(const uint16_t handle, const am_Error_e error);
am_Error_e updateGateway(const am_gatewayID_t gatewayID, const std::vector<am_CustomConnectionFormat_t>& listSourceFormats, const std::vector<am_CustomConnectionFormat_t>& listSinkFormats, const std::vector<bool>& convertionMatrix) ;
am_Error_e updateConverter(const am_converterID_t converterID, const std::vector<am_CustomConnectionFormat_t>& listSourceFormats, const std::vector<am_CustomConnectionFormat_t>& listSinkFormats, const std::vector<bool>& convertionMatrix);
am_Error_e updateSink(const am_sinkID_t sinkID, const am_sinkClass_t sinkClassID, const std::vector<am_SoundProperty_s>& listSoundProperties, const std::vector<am_CustomConnectionFormat_t>& listConnectionFormats, const std::vector<am_MainSoundProperty_s>& listMainSoundProperties) ;
am_Error_e updateSource(const am_sourceID_t sourceID, const am_sourceClass_t sourceClassID, const std::vector<am_SoundProperty_s>& listSoundProperties, const std::vector<am_CustomConnectionFormat_t>& listConnectionFormats, const std::vector<am_MainSoundProperty_s>& listMainSoundProperties) ;
void ackSetVolumes(const am_Handle_s handle, const std::vector<am_Volumes_s>& listvolumes, const am_Error_e error) ;
void ackSinkNotificationConfiguration(const am_Handle_s handle, const am_Error_e error) ;
void ackSourceNotificationConfiguration(const am_Handle_s handle, const am_Error_e error) ;
void hookSinkNotificationDataChange(const am_sinkID_t sinkID, const am_NotificationPayload_s& payload) ;
void hookSourceNotificationDataChange(const am_sourceID_t sourceID, const am_NotificationPayload_s& payload) ;
am_Error_e getDomainOfSink(const am_sinkID_t sinkID, am_domainID_t& domainID) const;
am_Error_e getDomainOfSource(const am_sourceID_t sourceID, am_domainID_t& domainID) const;
am_Error_e getDomainOfCrossfader(const am_crossfaderID_t crossfader, am_domainID_t& domainID) const;
uint16_t getStartupHandle(); //!< returns a startup handle
uint16_t getRundownHandle(); //!< returns a rundown handle
void waitOnStartup(bool startup); //!< tells the RoutingReceiver to start waiting for all handles to be confirmed
void waitOnRundown(bool rundown); //!< tells the RoutingReceiver to start waiting for all handles to be confirmed
private:
void handleCallback(const am_Handle_s handle, const am_Error_e error);
IAmDatabaseHandler *mpDatabaseHandler; //!< pointer to the databaseHandler
CAmRoutingSender *mpRoutingSender; //!< pointer to the routingSender
CAmControlSender *mpControlSender; //!< pointer to the controlSender
CAmSocketHandler *mpSocketHandler; //!< pointer to sockethandler
CAmDbusWrapper *mpDBusWrapper; //!< pointer to dbuswrapper
std::vector<uint16_t> mListStartupHandles; //!< list of handles that wait for a confirm
std::vector<uint16_t> mListRundownHandles; //!< list of handles that wait for a confirm
uint16_t handleCount; //!< counts all handles
bool mWaitStartup; //!< if true confirmation will be sent if list of handles = 0
bool mWaitRundown; //!< if true confirmation will be sent if list of handles = 0
am_Error_e mLastStartupError;
am_Error_e mLastRundownError;
};
}
#endif /* ROUTINGRECEIVER_H_ */
|
