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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
|
/**
* 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 Aleksandar Donchev, aleksander.donchev@partner.bmw.de BMW 2013
*
* \file CAmDatabaseHandlerMap.h
* For further information see http://www.genivi.org/.
*
*/
#ifndef MAPHANDLER_H_
#define MAPHANDLER_H_
#include <stdint.h>
#include <limits.h>
#include <sstream>
#include <iostream>
#include <unordered_map>
#include <algorithm>
#include <assert.h>
#include <vector>
#include "IAmDatabaseHandler.h"
namespace am
{
#ifndef AM_MAP_CAPACITY
#define AM_MAP_CAPACITY 0
#endif
#ifndef AM_MAX_CONNECTIONS
#define AM_MAX_CONNECTIONS 0x1000
#endif
#ifndef AM_MAX_MAIN_CONNECTIONS
#define AM_MAX_MAIN_CONNECTIONS SHRT_MAX
#endif
//todo: check the enum values before entering & changing in the database.
//todo: change asserts for dynamic boundary checks into failure answers.#
//todo: check autoincrement boundary and set to 16bit limits
//todo: If the sink is part of a gateway, the listconnectionFormats is copied to the gatewayInformation. Check this statement for sinks & sources
//todo: exchange last_insert_row id to be more safe
//todo: create test to ensure uniqueness of names throughout the database
//todo: enforce the uniqueness of names
/**
* This class handles and abstracts the database
*/
class CAmDatabaseHandlerMap : public IAmDatabaseHandler
{
bool mFirstStaticSink; //!< bool for dynamic range handling
bool mFirstStaticSource; //!< bool for dynamic range handling
bool mFirstStaticGateway; //!< bool for dynamic range handling
bool mFirstStaticConverter; //!< bool for dynamic range handling
bool mFirstStaticSinkClass; //!< bool for dynamic range handling
bool mFirstStaticSourceClass; //!< bool for dynamic range handling
bool mFirstStaticCrossfader; //!< bool for dynamic range handling
public:
CAmDatabaseHandlerMap();
virtual ~CAmDatabaseHandlerMap();
/**
* Database observer.
*/
struct AmDatabaseObserverCallbacks: public IAmDatabaseObserver
{
protected:
std::function<void()> dboNumberOfSinkClassesChanged;
std::function<void()> dboNumberOfSourceClassesChanged;
std::function<void(const am_Sink_s&)> dboNewSink;
std::function<void(const am_Source_s&)> dboNewSource;
std::function<void(const am_Domain_s& )> dboNewDomain;
std::function<void (const am_Gateway_s& )> dboNewGateway;
std::function<void (const am_Converter_s& )> dboNewConverter;
std::function<void (const am_Crossfader_s& )> dboNewCrossfader;
std::function<void (const am_MainConnectionType_s& )> dboNewMainConnection;
std::function<void (const am_mainConnectionID_t )> dboRemovedMainConnection;
std::function<void (const am_sinkID_t , const bool )> dboRemovedSink;
std::function<void (const am_sourceID_t , const bool )> dboRemovedSource;
std::function<void (const am_domainID_t )> dboRemoveDomain;
std::function<void (const am_gatewayID_t )> dboRemoveGateway;
std::function<void (const am_converterID_t )> dboRemoveConverter;
std::function<void (const am_crossfaderID_t )> dboRemoveCrossfader;
std::function<void (const am_mainConnectionID_t , const am_ConnectionState_e )> dboMainConnectionStateChanged;
std::function<void (const am_sinkID_t , const am_MainSoundProperty_s& )> dboMainSinkSoundPropertyChanged;
std::function<void (const am_sourceID_t , const am_MainSoundProperty_s& )> dboMainSourceSoundPropertyChanged;
std::function<void (const am_sinkID_t , const am_Availability_s& )> dboSinkAvailabilityChanged;
std::function<void (const am_sourceID_t , const am_Availability_s& )> dboSourceAvailabilityChanged;
std::function<void (const am_sinkID_t , const am_mainVolume_t )> dboVolumeChanged;
std::function<void (const am_sinkID_t , const am_MuteState_e )> dboSinkMuteStateChanged;
std::function<void (const am_SystemProperty_s& )>dboSystemPropertyChanged;
std::function<void (const am_mainConnectionID_t , const am_timeSync_t )>dboTimingInformationChanged;
std::function<void (const am_sinkID_t , const am_sinkClass_t , const std::vector<am_MainSoundProperty_s>& , const bool )>dboSinkUpdated;
std::function<void (const am_sourceID_t , const am_sourceClass_t , const std::vector<am_MainSoundProperty_s>& , const bool )>dboSourceUpdated;
std::function<void (const am_sinkID_t , const am_NotificationConfiguration_s )> dboSinkMainNotificationConfigurationChanged;
std::function<void (const am_sourceID_t , const am_NotificationConfiguration_s )> dboSourceMainNotificationConfigurationChanged;
public:
friend class CAmDatabaseHandlerMap;
AmDatabaseObserverCallbacks():IAmDatabaseObserver(), mpDatabaseHandler(nullptr) {}
virtual ~AmDatabaseObserverCallbacks(){ if(mpDatabaseHandler) mpDatabaseHandler->unregisterObserver(this);}
protected:
CAmDatabaseHandlerMap *mpDatabaseHandler;
};
am_Error_e enterDomainDB(const am_Domain_s& domainData, am_domainID_t& domainID);
am_Error_e enterMainConnectionDB(const am_MainConnection_s& mainConnectionData, am_mainConnectionID_t& connectionID);
am_Error_e enterSinkDB(const am_Sink_s& sinkData, am_sinkID_t& sinkID);
am_Error_e enterCrossfaderDB(const am_Crossfader_s& crossfaderData, am_crossfaderID_t& crossfaderID);
am_Error_e enterGatewayDB(const am_Gateway_s& gatewayData, am_gatewayID_t& gatewayID);
am_Error_e enterConverterDB(const am_Converter_s & converterData, am_converterID_t & converterID);
am_Error_e enterSourceDB(const am_Source_s& sourceData, am_sourceID_t& sourceID);
am_Error_e enterConnectionDB(const am_Connection_s& connection, am_connectionID_t& connectionID);
am_Error_e enterSinkClassDB(const am_SinkClass_s& sinkClass, am_sinkClass_t& sinkClassID);
am_Error_e enterSourceClassDB(am_sourceClass_t& sourceClassID, const am_SourceClass_s& sourceClass);
am_Error_e enterSystemProperties(const std::vector<am_SystemProperty_s>& listSystemProperties);
am_Error_e changeMainConnectionRouteDB(const am_mainConnectionID_t mainconnectionID, const std::vector<am_connectionID_t>& listConnectionID);
am_Error_e changeMainConnectionStateDB(const am_mainConnectionID_t mainconnectionID, const am_ConnectionState_e connectionState);
am_Error_e changeSinkMainVolumeDB(const am_mainVolume_t mainVolume, const am_sinkID_t sinkID);
am_Error_e changeSinkAvailabilityDB(const am_Availability_s& availability, const am_sinkID_t sinkID);
am_Error_e changeDomainStateDB(const am_DomainState_e domainState, const am_domainID_t domainID);
am_Error_e changeSinkMuteStateDB(const am_MuteState_e muteState, const am_sinkID_t sinkID);
am_Error_e changeMainSinkSoundPropertyDB(const am_MainSoundProperty_s& soundProperty, const am_sinkID_t sinkID);
am_Error_e changeMainSourceSoundPropertyDB(const am_MainSoundProperty_s& soundProperty, const am_sourceID_t sourceID);
am_Error_e changeSourceSoundPropertyDB(const am_SoundProperty_s& soundProperty, const am_sourceID_t sourceID);
am_Error_e changeSinkSoundPropertyDB(const am_SoundProperty_s& soundProperty, const am_sinkID_t sinkID);
am_Error_e changeSourceAvailabilityDB(const am_Availability_s& availability, const am_sourceID_t sourceID);
am_Error_e changeSystemPropertyDB(const am_SystemProperty_s& property);
am_Error_e changeDelayMainConnection(const am_timeSync_t & delay, const am_mainConnectionID_t & connectionID);
am_Error_e changeSinkClassInfoDB(const am_SinkClass_s& sinkClass);
am_Error_e changeSourceClassInfoDB(const am_SourceClass_s& sourceClass);
am_Error_e changeConnectionTimingInformation(const am_connectionID_t connectionID, const am_timeSync_t delay);
am_Error_e changeConnectionFinal(const am_connectionID_t connectionID);
am_Error_e changeSourceState(const am_sourceID_t sourceID, const am_SourceState_e sourceState);
am_Error_e changeSourceInterruptState(const am_sourceID_t sourceID, const am_InterruptState_e interruptState);
am_Error_e changeSinkVolume(const am_sinkID_t sinkID, const am_volume_t volume);
am_Error_e changeSourceVolume(const am_sourceID_t sourceID, const am_volume_t volume);
am_Error_e changeCrossFaderHotSink(const am_crossfaderID_t crossfaderID, const am_HotSink_e hotsink);
am_Error_e removeMainConnectionDB(const am_mainConnectionID_t mainConnectionID);
am_Error_e removeSinkDB(const am_sinkID_t sinkID);
am_Error_e removeSourceDB(const am_sourceID_t sourceID);
am_Error_e removeGatewayDB(const am_gatewayID_t gatewayID);
am_Error_e removeConverterDB(const am_converterID_t converterID);
am_Error_e removeCrossfaderDB(const am_crossfaderID_t crossfaderID);
am_Error_e removeDomainDB(const am_domainID_t domainID);
am_Error_e removeSinkClassDB(const am_sinkClass_t sinkClassID);
am_Error_e removeSourceClassDB(const am_sourceClass_t sourceClassID);
am_Error_e removeConnection(const am_connectionID_t connectionID);
am_Error_e getSourceClassInfoDB(const am_sourceID_t sourceID, am_SourceClass_s& classInfo) const;
am_Error_e getSinkClassInfoDB(const am_sinkID_t sinkID, am_SinkClass_s& sinkClass) const;
am_Error_e getGatewayInfoDB(const am_gatewayID_t gatewayID, am_Gateway_s& gatewayData) const;
am_Error_e getConverterInfoDB(const am_converterID_t converterID, am_Converter_s& converterData) const;
am_Error_e getSinkInfoDB(const am_sinkID_t sinkID, am_Sink_s& sinkData) const;
am_Error_e getSourceInfoDB(const am_sourceID_t sourceID, am_Source_s& sourceData) const;
am_Error_e getCrossfaderInfoDB(const am_crossfaderID_t crossfaderID, am_Crossfader_s& crossfaderData) const;
am_Error_e getMainConnectionInfoDB(const am_mainConnectionID_t mainConnectionID, am_MainConnection_s& mainConnectionData) const;
am_Error_e getSinkMainVolume(const am_sinkID_t sinkID, am_mainVolume_t& mainVolume) const;
am_Error_e getSinkVolume(const am_sinkID_t sinkID, am_volume_t& volume) const;
am_Error_e getSourceVolume(const am_sourceID_t sourceID, am_volume_t& volume) const;
am_Error_e getSinkSoundPropertyValue(const am_sinkID_t sinkID, const am_CustomSoundPropertyType_t propertyType, int16_t& value) const;
am_Error_e getSourceSoundPropertyValue(const am_sourceID_t sourceID, const am_CustomSoundPropertyType_t propertyType, int16_t& value) const;
am_Error_e getMainSinkSoundPropertyValue(const am_sinkID_t sinkID, const am_CustomMainSoundPropertyType_t propertyType, int16_t& value) const;
am_Error_e getMainSourceSoundPropertyValue(const am_sourceID_t sourceID, const am_CustomMainSoundPropertyType_t propertyType, int16_t& value) const;
am_Error_e getListSinkSoundProperties(const am_sinkID_t sinkID, std::vector<am_SoundProperty_s>& listSoundproperties) const;
am_Error_e getListSourceSoundProperties(const am_sourceID_t sourceID, std::vector<am_SoundProperty_s>& listSoundproperties) const;
am_Error_e getListSinksOfDomain(const am_domainID_t domainID, std::vector<am_sinkID_t>& listSinkID) const;
am_Error_e getListSourcesOfDomain(const am_domainID_t domainID, std::vector<am_sourceID_t>& listSourceID) const;
am_Error_e getListCrossfadersOfDomain(const am_domainID_t domainID, std::vector<am_crossfaderID_t>& listGatewaysID) const;
am_Error_e getListGatewaysOfDomain(const am_domainID_t domainID, std::vector<am_gatewayID_t>& listGatewaysID) const;
am_Error_e getListConvertersOfDomain(const am_domainID_t domainID, std::vector<am_converterID_t>& listConvertersID) const;
am_Error_e getListMainConnections(std::vector<am_MainConnection_s>& listMainConnections) const;
am_Error_e getListDomains(std::vector<am_Domain_s>& listDomains) const;
am_Error_e getListConnections(std::vector<am_Connection_s>& listConnections) const;
am_Error_e getListConnectionsReserved(std::vector<am_Connection_s>& listConnections) const;
am_Error_e getListSinks(std::vector<am_Sink_s>& listSinks) const;
am_Error_e getListSources(std::vector<am_Source_s>& lisSources) const;
am_Error_e getListSourceClasses(std::vector<am_SourceClass_s>& listSourceClasses) const;
am_Error_e getListCrossfaders(std::vector<am_Crossfader_s>& listCrossfaders) const;
am_Error_e getListGateways(std::vector<am_Gateway_s>& listGateways) const;
am_Error_e getListConverters(std::vector<am_Converter_s> & listConverters) const;
am_Error_e getListSinkClasses(std::vector<am_SinkClass_s>& listSinkClasses) const;
am_Error_e getListVisibleMainConnections(std::vector<am_MainConnectionType_s>& listConnections) const;
am_Error_e getListMainSinks(std::vector<am_SinkType_s>& listMainSinks) const;
am_Error_e getListMainSources(std::vector<am_SourceType_s>& listMainSources) const;
am_Error_e getListMainSinkSoundProperties(const am_sinkID_t sinkID, std::vector<am_MainSoundProperty_s>& listSoundProperties) const;
am_Error_e getListMainSourceSoundProperties(const am_sourceID_t sourceID, std::vector<am_MainSoundProperty_s>& listSourceProperties) const;
am_Error_e getListSystemProperties(std::vector<am_SystemProperty_s>& listSystemProperties) const;
am_Error_e getListSinkConnectionFormats(const am_sinkID_t sinkID, std::vector<am_CustomAvailabilityReason_t> & listConnectionFormats) const;
am_Error_e getListSourceConnectionFormats(const am_sourceID_t sourceID, std::vector<am_CustomAvailabilityReason_t> & listConnectionFormats) const;
am_Error_e getListGatewayConnectionFormats(const am_gatewayID_t gatewayID, std::vector<bool> & listConnectionFormat) const;
am_Error_e getTimingInformation(const am_mainConnectionID_t mainConnectionID, am_timeSync_t& delay) const;
am_Error_e getDomainOfSource(const am_sourceID_t sourceID, am_domainID_t& domainID) const;
am_Error_e getDomainOfSink(const am_sinkID_t sinkID, am_domainID_t& domainID) const;
am_Error_e getDomainOfCrossfader(const am_converterID_t crossfader, am_domainID_t& domainID) const;
am_Error_e getSoureState(const am_sourceID_t sourceID, am_SourceState_e& sourceState) const;
am_Error_e getDomainState(const am_domainID_t domainID, am_DomainState_e& state) const;
am_Error_e peekDomain(const std::string& name, am_domainID_t& domainID);
am_Error_e peekSink(const std::string& name, am_sinkID_t& sinkID);
am_Error_e peekSource(const std::string& name, am_sourceID_t& sourceID);
am_Error_e peekSinkClassID(const std::string& name, am_sinkClass_t& sinkClassID);
am_Error_e peekSourceClassID(const std::string& name, am_sourceClass_t& sourceClassID);
am_Error_e changeSourceDB(const am_sourceID_t sourceID, const am_sourceClass_t sourceClassID, const std::vector<am_SoundProperty_s>& listSoundProperties, const std::vector<am_CustomAvailabilityReason_t>& listConnectionFormats, const std::vector<am_MainSoundProperty_s>& listMainSoundProperties);
am_Error_e changeSinkDB(const am_sinkID_t sinkID, const am_sinkClass_t sinkClassID, const std::vector<am_SoundProperty_s>& listSoundProperties, const std::vector<am_CustomAvailabilityReason_t>& listConnectionFormats, const std::vector<am_MainSoundProperty_s>& listMainSoundProperties);
am_Error_e getListMainSinkNotificationConfigurations(const am_sinkID_t sinkID, std::vector<am_NotificationConfiguration_s>& listMainNotificationConfigurations);
am_Error_e getListMainSourceNotificationConfigurations(const am_sourceID_t sourceID, std::vector<am_NotificationConfiguration_s>& listMainNotificationConfigurations);
am_Error_e changeMainSinkNotificationConfigurationDB(const am_sinkID_t sinkID, const am_NotificationConfiguration_s mainNotificationConfiguration);
am_Error_e changeMainSourceNotificationConfigurationDB(const am_sourceID_t sourceID, const am_NotificationConfiguration_s mainNotificationConfiguration);
am_Error_e changeGatewayDB(const am_gatewayID_t gatewayID, const std::vector<am_CustomAvailabilityReason_t>& listSourceConnectionFormats, const std::vector<am_CustomAvailabilityReason_t>& listSinkConnectionFormats, const std::vector<bool>& convertionMatrix);
am_Error_e changeConverterDB(const am_converterID_t converterID, const std::vector<am_CustomConnectionFormat_t>& listSourceConnectionFormats, const std::vector<am_CustomConnectionFormat_t>& listSinkConnectionFormats, const std::vector<bool>& convertionMatrix);
am_Error_e changeSinkNotificationConfigurationDB(const am_sinkID_t sinkID,const am_NotificationConfiguration_s notificationConfiguration);
am_Error_e changeSourceNotificationConfigurationDB(const am_sourceID_t sourceID,const am_NotificationConfiguration_s notificationConfiguration);
bool existMainConnection(const am_mainConnectionID_t mainConnectionID) const;
bool existCrossFader(const am_crossfaderID_t crossfaderID) const;
bool existConnection(const am_Connection_s & connection) const;
bool existConnectionID(const am_connectionID_t connectionID) const;
bool existSource(const am_sourceID_t sourceID) const;
bool existSourceNameOrID(const am_sourceID_t sourceID, const std::string& name) const;
bool existSourceName(const std::string& name) const;
bool existSink(const am_sinkID_t sinkID) const;
bool existSinkNameOrID(const am_sinkID_t sinkID, const std::string& name) const;
bool existSinkName(const std::string& name) const;
bool existDomain(const am_domainID_t domainID) const;
bool existGateway(const am_gatewayID_t gatewayID) const;
bool existConverter(const am_converterID_t converterID) const;
bool existSinkClass(const am_sinkClass_t sinkClassID) const;
bool existSourceClass(const am_sourceClass_t sourceClassID) const;
bool sourceVisible(const am_sourceID_t sourceID) const;
bool sinkVisible(const am_sinkID_t sinkID) const;
bool isComponentConnected(const am_Gateway_s & gateway) const;
bool isComponentConnected(const am_Converter_s & converter) const;
void dump( std::ostream & output ) const;
am_Error_e enumerateSources(std::function<void(const am_Source_s & element)> cb) const;
am_Error_e enumerateSinks(std::function<void(const am_Sink_s & element)> cb) const;
am_Error_e enumerateGateways(std::function<void(const am_Gateway_s & element)> cb) const;
am_Error_e enumerateConverters(std::function<void(const am_Converter_s & element)> cb) const;
bool registerObserver(IAmDatabaseObserver * iObserver);
bool unregisterObserver(IAmDatabaseObserver * iObserver);
unsigned countObservers();
/**
* The following structures extend the base structures with the field 'reserved'.
*/
#define AM_SUBCLASS(TYPE, SUBCLASS, CLASS, MEMBER, ASSIGN) \
typedef struct SUBCLASS : public CLASS \
{ \
MEMBER \
bool reserved; \
SUBCLASS() : CLASS(), reserved(false) {} \
SUBCLASS & operator=(const SUBCLASS &anObject) \
{ \
if (this != &anObject) \
{ \
CLASS::operator=(anObject); \
reserved = anObject.reserved; \
ASSIGN \
} \
return *this; \
} \
SUBCLASS & operator=(const CLASS & anObject) \
{ \
if (this != &anObject) { \
CLASS::operator=(anObject);} \
return *this; \
} \
void getDescription(std::string & outString) const; \
} TYPE \
#define AM_SUBLCASS_ADD_MAP_TYPE(TYPE, NAME) std::unordered_map<TYPE, int16_t> NAME;
#define AM_SUBLCASS_ADD_ASSIGNMENT(NAME) NAME = anObject.NAME;
private:
AM_SUBCLASS(AmDomain, am_Domain_Database_s, am_Domain_s, , );
AM_SUBCLASS(AmSink, am_Sink_Database_s, am_Sink_s, \
void getSinkType(am_SinkType_s & sinkType) const; \
AM_SUBLCASS_ADD_MAP_TYPE(am_CustomSoundPropertyType_t, cacheSoundProperties) \
AM_SUBLCASS_ADD_MAP_TYPE(am_CustomMainSoundPropertyType_t, cacheMainSoundProperties), \
AM_SUBLCASS_ADD_ASSIGNMENT(cacheSoundProperties) \
AM_SUBLCASS_ADD_ASSIGNMENT(cacheMainSoundProperties) );
AM_SUBCLASS(AmSource, am_Source_Database_s, am_Source_s,
void getSourceType(am_SourceType_s & sourceType) const; \
AM_SUBLCASS_ADD_MAP_TYPE(am_CustomSoundPropertyType_t, cacheSoundProperties) \
AM_SUBLCASS_ADD_MAP_TYPE(am_CustomMainSoundPropertyType_t, cacheMainSoundProperties), \
AM_SUBLCASS_ADD_ASSIGNMENT(cacheSoundProperties) \
AM_SUBLCASS_ADD_ASSIGNMENT(cacheMainSoundProperties) );
AM_SUBCLASS(AmConnection, am_Connection_Database_s, am_Connection_s, , );
AM_SUBCLASS(AmMainConnection, am_MainConnection_Database_s, am_MainConnection_s,
void getMainConnectionType(am_MainConnectionType_s & connectionType) const;, );
AM_SUBCLASS(AmSourceClass, am_SourceClass_Database_s, am_SourceClass_s, , );
AM_SUBCLASS(AmSinkClass, am_SinkClass_Database_s, am_SinkClass_s, , );
AM_SUBCLASS(AmGateway, am_Gateway_Database_s, am_Gateway_s, , );
AM_SUBCLASS(AmConverter, am_Converter_Database_s, am_Converter_s, , );
AM_SUBCLASS(AmCrossfader, am_Crossfader_Database_s, am_Crossfader_s, , );
typedef std::unordered_map<am_domainID_t, AmDomain> AmMapDomain;
typedef std::unordered_map<am_sourceClass_t, AmSourceClass> AmMapSourceClass;
typedef std::unordered_map<am_sinkClass_t, AmSinkClass> AmMapSinkClass;
typedef std::unordered_map<am_sinkID_t, AmSink> AmMapSink;
typedef std::unordered_map<am_sourceID_t, AmSource> AmMapSource;
typedef std::unordered_map<am_gatewayID_t, AmGateway> AmMapGateway;
typedef std::unordered_map<am_converterID_t, AmConverter> AmMapConverter;
typedef std::unordered_map<am_crossfaderID_t, AmCrossfader> AmMapCrossfader;
typedef std::unordered_map<am_connectionID_t, AmConnection> AmMapConnection;
typedef std::unordered_map<am_mainConnectionID_t, AmMainConnection> AmMapMainConnection;
typedef std::vector<am_SystemProperty_s> AmVectorSystemProperties;
/**
* The following structure groups the map objects needed for the implementation.
* Every map object is coupled with an identifier, which hold the current value.
* DYNAMIC_ID_BOUNDARY is used as initial value everywhere a dynamic id is considered .
* The IDs can be increased through the method increaseID(...), which follows the AudioManager logic.
* For more information about the static and dynamic IDs, please see the documentation.
*/
struct AmMappedData
{
/**
* The structure encapsulates the id boundary and the current id value.
* It defines a range within the id can vary.
*/
struct AmIdentifier
{
int16_t mMin; //!< min possible value
int16_t mMax; //!< max possible value
int16_t mCurrentValue; //!< current value
AmIdentifier():mMin(DYNAMIC_ID_BOUNDARY), mMax(SHRT_MAX), mCurrentValue(mMin){};
AmIdentifier(const int16_t & min, const int16_t & max):mMin(min), mMax(max), mCurrentValue(mMin){assert(min<max);};
};
AmIdentifier mCurrentDomainID; //!< domain ID
AmIdentifier mCurrentSourceClassesID; //!< source classes ID
AmIdentifier mCurrentSinkClassesID; //!< sink classes ID
AmIdentifier mCurrentSinkID; //!< sink ID
AmIdentifier mCurrentSourceID; //!< source ID
AmIdentifier mCurrentGatewayID; //!< gateway ID
AmIdentifier mCurrentConverterID; //!< converter ID
AmIdentifier mCurrentCrossfaderID; //!< crossfader ID
AmIdentifier mCurrentConnectionID; //!< connection ID
AmIdentifier mCurrentMainConnectionID; //!< mainconnection ID
AmVectorSystemProperties mSystemProperties; //!< vector with system properties
AmMapDomain mDomainMap; //!< map for domain structures
AmMapSourceClass mSourceClassesMap; //!< map for source classes structures
AmMapSinkClass mSinkClassesMap; //!< map for sink classes structures
AmMapSink mSinkMap; //!< map for sink structures
AmMapSource mSourceMap; //!< map for source structures
AmMapGateway mGatewayMap; //!< map for gateway structures
AmMapConverter mConverterMap; //!< map for converter structures
AmMapCrossfader mCrossfaderMap; //!< map for crossfader structures
AmMapConnection mConnectionMap; //!< map for connection structures
AmMapMainConnection mMainConnectionMap; //!< map for main connection structures
AmMappedData(): //For Domain, MainConnections, Connections we don't have static IDs.
mCurrentDomainID(DYNAMIC_ID_BOUNDARY, SHRT_MAX),
mCurrentSourceClassesID(DYNAMIC_ID_BOUNDARY, SHRT_MAX),
mCurrentSinkClassesID(DYNAMIC_ID_BOUNDARY, SHRT_MAX),
mCurrentSinkID(DYNAMIC_ID_BOUNDARY, SHRT_MAX),
mCurrentSourceID(DYNAMIC_ID_BOUNDARY, SHRT_MAX),
mCurrentGatewayID(DYNAMIC_ID_BOUNDARY, SHRT_MAX),
mCurrentConverterID(DYNAMIC_ID_BOUNDARY, SHRT_MAX),
mCurrentCrossfaderID(DYNAMIC_ID_BOUNDARY, SHRT_MAX),
mCurrentConnectionID(1, AM_MAX_CONNECTIONS),
mCurrentMainConnectionID(1, AM_MAX_MAIN_CONNECTIONS),
mSystemProperties(),
mDomainMap(),mSourceClassesMap(), mSinkClassesMap(), mSinkMap(AM_MAP_CAPACITY), mSourceMap(AM_MAP_CAPACITY),
mGatewayMap(), mConverterMap(), mCrossfaderMap(), mConnectionMap(), mMainConnectionMap()
{};
/**
* \brief Increases a given map ID.
*
* A common method implementing the logic for static and dynamic IDs except main connection ID.
*
* @param resultID Pointer to an output variable.
* @param elementID Pointer to ID, which will be manipulated.
* @param desiredStaticID Not 0 for static IDs and 0 for dynamic IDs.
* Usually the static IDs are in interval [1 , DYNAMIC_ID_BOUNDARY-1]. Default is 0.
* @return TRUE on successfully changed ID.
*/
bool increaseID(int16_t & resultID, AmIdentifier & elementID, int16_t const desiredStaticID);
/**
* \brief Increases the main connection ID.
*
* @param resultID Pointer to an output variable.
* @return TRUE on successfully changed ID.
*/
bool increaseMainConnectionID(int16_t & resultID);
/**
* \brief Increases the connection ID.
*
* @param resultID Pointer to an output variable.
* @return TRUE on successfully changed ID.
*/
bool increaseConnectionID(int16_t & resultID);
template <class TPrintObject> static void print (const TPrintObject & t, std::ostream & output)
{
std::string description;
t.getDescription( description );
output << description;
}
template <typename TPrintMapKey,class TPrintMapObject> static void printMap (const std::unordered_map<TPrintMapKey, TPrintMapObject> & t, std::ostream & output)
{
typename std::unordered_map<TPrintMapKey, TPrintMapObject>::const_iterator iter = t.begin();
for(; iter!=t.end(); iter++)
AmMappedData::print(iter->second, output);
}
private:
template <typename TMapKey,class TMapObject> bool getNextConnectionID(int16_t & resultID, AmIdentifier & connID,
const std::unordered_map<TMapKey, TMapObject> & map);
};
/*
* Helper methods.
*/
am_timeSync_t calculateMainConnectionDelay(const am_mainConnectionID_t mainConnectionID) const; //!< calculates a new main connection delay
int16_t calculateDelayForRoute(const std::vector<am_connectionID_t>& listConnectionID);
bool insertSinkDB(const am_Sink_s & sinkData, am_sinkID_t & sinkID);
bool insertCrossfaderDB(const am_Crossfader_s & crossfaderData, am_crossfaderID_t & crossfaderID);
bool insertGatewayDB(const am_Gateway_s & gatewayData, am_gatewayID_t & gatewayID);
bool insertConverterDB(const am_Converter_s & converteData, am_converterID_t & converterID);
bool insertSourceDB(const am_Source_s & sourceData, am_sourceID_t & sourceID);
bool insertSinkClassDB(const am_SinkClass_s & sinkClass, am_sinkClass_t & sinkClassID);
bool insertSourceClassDB(am_sourceClass_t & sourceClassID, const am_SourceClass_s & sourceClass);
const am_Sink_Database_s * sinkWithNameOrID(const am_sinkID_t sinkID, const std::string & name) const;
const am_Source_Database_s * sourceWithNameOrID(const am_sourceID_t sourceID, const std::string & name) const;
template <class Component> bool isConnected(const Component & comp) const
{
return std::find_if(mMappedData.mConnectionMap.begin(), mMappedData.mConnectionMap.end(),[&](const std::pair<am_connectionID_t, am_Connection_Database_s>& rConnection){
return (rConnection.second.sinkID == comp.sinkID ||rConnection.second.sourceID ==comp.sourceID);})!=mMappedData.mConnectionMap.end();
}
void filterDuplicateNotificationConfigurationTypes(std::vector<am_NotificationConfiguration_s> & list)
{
std::vector<am_NotificationConfiguration_s> oldList(list);
list.clear();
std::for_each(oldList.begin(), oldList.end(), [&](am_NotificationConfiguration_s & provided) {
std::vector<am_NotificationConfiguration_s>::iterator found =
std::find_if(list.begin(), list.end(), [&](am_NotificationConfiguration_s & stored) {
if (provided.type == stored.type) {
stored = provided;
return true;
}
return false;
} );
if (found == list.end())
list.push_back(provided);
} );
}
ListConnectionFormat mListConnectionFormat; //!< list of connection formats
AmMappedData mMappedData; //!< Internal structure encapsulating all the maps used in this class
std::vector<AmDatabaseObserverCallbacks*> mDatabaseObservers;
#ifdef UNIT_TEST
public:
void setConnectionIDRange(const int16_t & min, const int16_t & max)
{
mMappedData.mCurrentConnectionID.mMin = min;
mMappedData.mCurrentConnectionID.mMax = max;
}
void setMainConnectionIDRange(const int16_t & min, const int16_t & max)
{
mMappedData.mCurrentMainConnectionID.mMin = min;
mMappedData.mCurrentMainConnectionID.mMax = max;
}
void setSinkIDRange(const int16_t & min, const int16_t & max)
{
mMappedData.mCurrentSinkID.mMin = min;
mMappedData.mCurrentSinkID.mMax = max;
}
#endif
};
}
#endif /* MAPHANDLER_H_ */
|
