IAudioPolicyService.cpp revision 09e621a7b1b417b47618e7d8bd71ebade73b9089
1/*
2**
3** Copyright 2009, The Android Open Source Project
4**
5** Licensed under the Apache License, Version 2.0 (the "License");
6** you may not use this file except in compliance with the License.
7** You may obtain a copy of the License at
8**
9**     http://www.apache.org/licenses/LICENSE-2.0
10**
11** Unless required by applicable law or agreed to in writing, software
12** distributed under the License is distributed on an "AS IS" BASIS,
13** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14** See the License for the specific language governing permissions and
15** limitations under the License.
16*/
17
18#define LOG_TAG "IAudioPolicyService"
19#include <utils/Log.h>
20
21#include <stdint.h>
22#include <math.h>
23#include <sys/types.h>
24
25#include <binder/IPCThreadState.h>
26#include <binder/Parcel.h>
27
28#include <media/AudioEffect.h>
29#include <media/IAudioPolicyService.h>
30#include <media/TimeCheck.h>
31#include <private/android_filesystem_config.h>
32#include <system/audio.h>
33
34namespace android {
35
36enum {
37    SET_DEVICE_CONNECTION_STATE = IBinder::FIRST_CALL_TRANSACTION,
38    GET_DEVICE_CONNECTION_STATE,
39    HANDLE_DEVICE_CONFIG_CHANGE,
40    SET_PHONE_STATE,
41    SET_RINGER_MODE,    // reserved, no longer used
42    SET_FORCE_USE,
43    GET_FORCE_USE,
44    GET_OUTPUT,
45    START_OUTPUT,
46    STOP_OUTPUT,
47    RELEASE_OUTPUT,
48    GET_INPUT_FOR_ATTR,
49    START_INPUT,
50    STOP_INPUT,
51    RELEASE_INPUT,
52    INIT_STREAM_VOLUME,
53    SET_STREAM_VOLUME,
54    GET_STREAM_VOLUME,
55    GET_STRATEGY_FOR_STREAM,
56    GET_OUTPUT_FOR_EFFECT,
57    REGISTER_EFFECT,
58    UNREGISTER_EFFECT,
59    IS_STREAM_ACTIVE,
60    IS_SOURCE_ACTIVE,
61    GET_DEVICES_FOR_STREAM,
62    QUERY_DEFAULT_PRE_PROCESSING,
63    SET_EFFECT_ENABLED,
64    IS_STREAM_ACTIVE_REMOTELY,
65    IS_OFFLOAD_SUPPORTED,
66    LIST_AUDIO_PORTS,
67    GET_AUDIO_PORT,
68    CREATE_AUDIO_PATCH,
69    RELEASE_AUDIO_PATCH,
70    LIST_AUDIO_PATCHES,
71    SET_AUDIO_PORT_CONFIG,
72    REGISTER_CLIENT,
73    GET_OUTPUT_FOR_ATTR,
74    ACQUIRE_SOUNDTRIGGER_SESSION,
75    RELEASE_SOUNDTRIGGER_SESSION,
76    GET_PHONE_STATE,
77    REGISTER_POLICY_MIXES,
78    START_AUDIO_SOURCE,
79    STOP_AUDIO_SOURCE,
80    SET_AUDIO_PORT_CALLBACK_ENABLED,
81    SET_MASTER_MONO,
82    GET_MASTER_MONO,
83    GET_STREAM_VOLUME_DB
84};
85
86#define MAX_ITEMS_PER_LIST 1024
87
88class BpAudioPolicyService : public BpInterface<IAudioPolicyService>
89{
90public:
91    explicit BpAudioPolicyService(const sp<IBinder>& impl)
92        : BpInterface<IAudioPolicyService>(impl)
93    {
94    }
95
96    virtual status_t setDeviceConnectionState(
97                                    audio_devices_t device,
98                                    audio_policy_dev_state_t state,
99                                    const char *device_address,
100                                    const char *device_name)
101    {
102        Parcel data, reply;
103        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
104        data.writeInt32(static_cast <uint32_t>(device));
105        data.writeInt32(static_cast <uint32_t>(state));
106        data.writeCString(device_address);
107        data.writeCString(device_name);
108        remote()->transact(SET_DEVICE_CONNECTION_STATE, data, &reply);
109        return static_cast <status_t> (reply.readInt32());
110    }
111
112    virtual audio_policy_dev_state_t getDeviceConnectionState(
113                                    audio_devices_t device,
114                                    const char *device_address)
115    {
116        Parcel data, reply;
117        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
118        data.writeInt32(static_cast <uint32_t>(device));
119        data.writeCString(device_address);
120        remote()->transact(GET_DEVICE_CONNECTION_STATE, data, &reply);
121        return static_cast <audio_policy_dev_state_t>(reply.readInt32());
122    }
123
124    virtual status_t handleDeviceConfigChange(audio_devices_t device,
125                                              const char *device_address,
126                                              const char *device_name)
127    {
128        Parcel data, reply;
129        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
130        data.writeInt32(static_cast <uint32_t>(device));
131        data.writeCString(device_address);
132        data.writeCString(device_name);
133        remote()->transact(HANDLE_DEVICE_CONFIG_CHANGE, data, &reply);
134        return static_cast <status_t> (reply.readInt32());
135    }
136
137    virtual status_t setPhoneState(audio_mode_t state)
138    {
139        Parcel data, reply;
140        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
141        data.writeInt32(state);
142        remote()->transact(SET_PHONE_STATE, data, &reply);
143        return static_cast <status_t> (reply.readInt32());
144    }
145
146    virtual status_t setForceUse(audio_policy_force_use_t usage, audio_policy_forced_cfg_t config)
147    {
148        Parcel data, reply;
149        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
150        data.writeInt32(static_cast <uint32_t>(usage));
151        data.writeInt32(static_cast <uint32_t>(config));
152        remote()->transact(SET_FORCE_USE, data, &reply);
153        return static_cast <status_t> (reply.readInt32());
154    }
155
156    virtual audio_policy_forced_cfg_t getForceUse(audio_policy_force_use_t usage)
157    {
158        Parcel data, reply;
159        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
160        data.writeInt32(static_cast <uint32_t>(usage));
161        remote()->transact(GET_FORCE_USE, data, &reply);
162        return static_cast <audio_policy_forced_cfg_t> (reply.readInt32());
163    }
164
165    virtual audio_io_handle_t getOutput(audio_stream_type_t stream)
166    {
167        Parcel data, reply;
168        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
169        data.writeInt32(static_cast <uint32_t>(stream));
170        remote()->transact(GET_OUTPUT, data, &reply);
171        return static_cast <audio_io_handle_t> (reply.readInt32());
172    }
173
174    virtual status_t getOutputForAttr(const audio_attributes_t *attr,
175                                        audio_io_handle_t *output,
176                                        audio_session_t session,
177                                        audio_stream_type_t *stream,
178                                        pid_t pid,
179                                        uid_t uid,
180                                        const audio_config_t *config,
181                                        audio_output_flags_t flags,
182                                        audio_port_handle_t *selectedDeviceId,
183                                        audio_port_handle_t *portId)
184        {
185            Parcel data, reply;
186            data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
187            if (attr == NULL) {
188                if (stream == NULL) {
189                    ALOGE("getOutputForAttr(): NULL audio attributes and stream type");
190                    return BAD_VALUE;
191                }
192                if (*stream == AUDIO_STREAM_DEFAULT) {
193                    ALOGE("getOutputForAttr unspecified stream type");
194                    return BAD_VALUE;
195                }
196            }
197            if (output == NULL) {
198                ALOGE("getOutputForAttr NULL output - shouldn't happen");
199                return BAD_VALUE;
200            }
201            if (selectedDeviceId == NULL) {
202                ALOGE("getOutputForAttr NULL selectedDeviceId - shouldn't happen");
203                return BAD_VALUE;
204            }
205            if (portId == NULL) {
206                ALOGE("getOutputForAttr NULL portId - shouldn't happen");
207                return BAD_VALUE;
208            }
209            if (attr == NULL) {
210                data.writeInt32(0);
211            } else {
212                data.writeInt32(1);
213                data.write(attr, sizeof(audio_attributes_t));
214            }
215            data.writeInt32(session);
216            if (stream == NULL) {
217                data.writeInt32(0);
218            } else {
219                data.writeInt32(1);
220                data.writeInt32(*stream);
221            }
222            data.writeInt32(pid);
223            data.writeInt32(uid);
224            data.write(config, sizeof(audio_config_t));
225            data.writeInt32(static_cast <uint32_t>(flags));
226            data.writeInt32(*selectedDeviceId);
227            data.writeInt32(*portId);
228            status_t status = remote()->transact(GET_OUTPUT_FOR_ATTR, data, &reply);
229            if (status != NO_ERROR) {
230                return status;
231            }
232            status = (status_t)reply.readInt32();
233            if (status != NO_ERROR) {
234                return status;
235            }
236            *output = (audio_io_handle_t)reply.readInt32();
237            audio_stream_type_t lStream = (audio_stream_type_t)reply.readInt32();
238            if (stream != NULL) {
239                *stream = lStream;
240            }
241            *selectedDeviceId = (audio_port_handle_t)reply.readInt32();
242            *portId = (audio_port_handle_t)reply.readInt32();
243            return status;
244        }
245
246    virtual status_t startOutput(audio_io_handle_t output,
247                                 audio_stream_type_t stream,
248                                 audio_session_t session)
249    {
250        Parcel data, reply;
251        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
252        data.writeInt32(output);
253        data.writeInt32((int32_t) stream);
254        data.writeInt32((int32_t) session);
255        remote()->transact(START_OUTPUT, data, &reply);
256        return static_cast <status_t> (reply.readInt32());
257    }
258
259    virtual status_t stopOutput(audio_io_handle_t output,
260                                audio_stream_type_t stream,
261                                audio_session_t session)
262    {
263        Parcel data, reply;
264        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
265        data.writeInt32(output);
266        data.writeInt32((int32_t) stream);
267        data.writeInt32((int32_t) session);
268        remote()->transact(STOP_OUTPUT, data, &reply);
269        return static_cast <status_t> (reply.readInt32());
270    }
271
272    virtual void releaseOutput(audio_io_handle_t output,
273                               audio_stream_type_t stream,
274                               audio_session_t session)
275    {
276        Parcel data, reply;
277        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
278        data.writeInt32(output);
279        data.writeInt32((int32_t)stream);
280        data.writeInt32((int32_t)session);
281        remote()->transact(RELEASE_OUTPUT, data, &reply);
282    }
283
284    virtual status_t getInputForAttr(const audio_attributes_t *attr,
285                                     audio_io_handle_t *input,
286                                     audio_session_t session,
287                                     pid_t pid,
288                                     uid_t uid,
289                                     const String16& opPackageName,
290                                     const audio_config_base_t *config,
291                                     audio_input_flags_t flags,
292                                     audio_port_handle_t *selectedDeviceId,
293                                     audio_port_handle_t *portId)
294    {
295        Parcel data, reply;
296        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
297        if (attr == NULL) {
298            ALOGE("getInputForAttr NULL attr - shouldn't happen");
299            return BAD_VALUE;
300        }
301        if (input == NULL) {
302            ALOGE("getInputForAttr NULL input - shouldn't happen");
303            return BAD_VALUE;
304        }
305        if (selectedDeviceId == NULL) {
306            ALOGE("getInputForAttr NULL selectedDeviceId - shouldn't happen");
307            return BAD_VALUE;
308        }
309        if (portId == NULL) {
310            ALOGE("getInputForAttr NULL portId - shouldn't happen");
311            return BAD_VALUE;
312        }
313        data.write(attr, sizeof(audio_attributes_t));
314        data.writeInt32(*input);
315        data.writeInt32(session);
316        data.writeInt32(pid);
317        data.writeInt32(uid);
318        data.writeString16(opPackageName);
319        data.write(config, sizeof(audio_config_base_t));
320        data.writeInt32(flags);
321        data.writeInt32(*selectedDeviceId);
322        data.writeInt32(*portId);
323        status_t status = remote()->transact(GET_INPUT_FOR_ATTR, data, &reply);
324        if (status != NO_ERROR) {
325            return status;
326        }
327        status = reply.readInt32();
328        if (status != NO_ERROR) {
329            return status;
330        }
331        *input = (audio_io_handle_t)reply.readInt32();
332        *selectedDeviceId = (audio_port_handle_t)reply.readInt32();
333        *portId = (audio_port_handle_t)reply.readInt32();
334        return NO_ERROR;
335    }
336
337    virtual status_t startInput(audio_port_handle_t portId,
338                                bool *silenced)
339    {
340        Parcel data, reply;
341        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
342        data.writeInt32(portId);
343        data.writeInt32(*silenced ? 1 : 0);
344        remote()->transact(START_INPUT, data, &reply);
345        status_t status = static_cast <status_t> (reply.readInt32());
346        *silenced = reply.readInt32() == 1;
347        return status;
348    }
349
350    virtual status_t stopInput(audio_port_handle_t portId)
351    {
352        Parcel data, reply;
353        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
354        data.writeInt32(portId);
355        remote()->transact(STOP_INPUT, data, &reply);
356        return static_cast <status_t> (reply.readInt32());
357    }
358
359    virtual void releaseInput(audio_port_handle_t portId)
360    {
361        Parcel data, reply;
362        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
363        data.writeInt32(portId);
364        remote()->transact(RELEASE_INPUT, data, &reply);
365    }
366
367    virtual status_t initStreamVolume(audio_stream_type_t stream,
368                                    int indexMin,
369                                    int indexMax)
370    {
371        Parcel data, reply;
372        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
373        data.writeInt32(static_cast <uint32_t>(stream));
374        data.writeInt32(indexMin);
375        data.writeInt32(indexMax);
376        remote()->transact(INIT_STREAM_VOLUME, data, &reply);
377        return static_cast <status_t> (reply.readInt32());
378    }
379
380    virtual status_t setStreamVolumeIndex(audio_stream_type_t stream,
381                                          int index,
382                                          audio_devices_t device)
383    {
384        Parcel data, reply;
385        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
386        data.writeInt32(static_cast <uint32_t>(stream));
387        data.writeInt32(index);
388        data.writeInt32(static_cast <uint32_t>(device));
389        remote()->transact(SET_STREAM_VOLUME, data, &reply);
390        return static_cast <status_t> (reply.readInt32());
391    }
392
393    virtual status_t getStreamVolumeIndex(audio_stream_type_t stream,
394                                          int *index,
395                                          audio_devices_t device)
396    {
397        Parcel data, reply;
398        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
399        data.writeInt32(static_cast <uint32_t>(stream));
400        data.writeInt32(static_cast <uint32_t>(device));
401
402        remote()->transact(GET_STREAM_VOLUME, data, &reply);
403        int lIndex = reply.readInt32();
404        if (index) *index = lIndex;
405        return static_cast <status_t> (reply.readInt32());
406    }
407
408    virtual uint32_t getStrategyForStream(audio_stream_type_t stream)
409    {
410        Parcel data, reply;
411        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
412        data.writeInt32(static_cast <uint32_t>(stream));
413        remote()->transact(GET_STRATEGY_FOR_STREAM, data, &reply);
414        return reply.readInt32();
415    }
416
417    virtual audio_devices_t getDevicesForStream(audio_stream_type_t stream)
418    {
419        Parcel data, reply;
420        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
421        data.writeInt32(static_cast <uint32_t>(stream));
422        remote()->transact(GET_DEVICES_FOR_STREAM, data, &reply);
423        return (audio_devices_t) reply.readInt32();
424    }
425
426    virtual audio_io_handle_t getOutputForEffect(const effect_descriptor_t *desc)
427    {
428        Parcel data, reply;
429        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
430        data.write(desc, sizeof(effect_descriptor_t));
431        remote()->transact(GET_OUTPUT_FOR_EFFECT, data, &reply);
432        return static_cast <audio_io_handle_t> (reply.readInt32());
433    }
434
435    virtual status_t registerEffect(const effect_descriptor_t *desc,
436                                        audio_io_handle_t io,
437                                        uint32_t strategy,
438                                        audio_session_t session,
439                                        int id)
440    {
441        Parcel data, reply;
442        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
443        data.write(desc, sizeof(effect_descriptor_t));
444        data.writeInt32(io);
445        data.writeInt32(strategy);
446        data.writeInt32(session);
447        data.writeInt32(id);
448        remote()->transact(REGISTER_EFFECT, data, &reply);
449        return static_cast <status_t> (reply.readInt32());
450    }
451
452    virtual status_t unregisterEffect(int id)
453    {
454        Parcel data, reply;
455        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
456        data.writeInt32(id);
457        remote()->transact(UNREGISTER_EFFECT, data, &reply);
458        return static_cast <status_t> (reply.readInt32());
459    }
460
461    virtual status_t setEffectEnabled(int id, bool enabled)
462    {
463        Parcel data, reply;
464        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
465        data.writeInt32(id);
466        data.writeInt32(enabled);
467        remote()->transact(SET_EFFECT_ENABLED, data, &reply);
468        return static_cast <status_t> (reply.readInt32());
469    }
470
471    virtual bool isStreamActive(audio_stream_type_t stream, uint32_t inPastMs) const
472    {
473        Parcel data, reply;
474        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
475        data.writeInt32((int32_t) stream);
476        data.writeInt32(inPastMs);
477        remote()->transact(IS_STREAM_ACTIVE, data, &reply);
478        return reply.readInt32();
479    }
480
481    virtual bool isStreamActiveRemotely(audio_stream_type_t stream, uint32_t inPastMs) const
482    {
483        Parcel data, reply;
484        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
485        data.writeInt32((int32_t) stream);
486        data.writeInt32(inPastMs);
487        remote()->transact(IS_STREAM_ACTIVE_REMOTELY, data, &reply);
488        return reply.readInt32();
489    }
490
491    virtual bool isSourceActive(audio_source_t source) const
492    {
493        Parcel data, reply;
494        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
495        data.writeInt32((int32_t) source);
496        remote()->transact(IS_SOURCE_ACTIVE, data, &reply);
497        return reply.readInt32();
498    }
499
500    virtual status_t queryDefaultPreProcessing(audio_session_t audioSession,
501                                               effect_descriptor_t *descriptors,
502                                               uint32_t *count)
503    {
504        if (descriptors == NULL || count == NULL) {
505            return BAD_VALUE;
506        }
507        Parcel data, reply;
508        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
509        data.writeInt32(audioSession);
510        data.writeInt32(*count);
511        status_t status = remote()->transact(QUERY_DEFAULT_PRE_PROCESSING, data, &reply);
512        if (status != NO_ERROR) {
513            return status;
514        }
515        status = static_cast <status_t> (reply.readInt32());
516        uint32_t retCount = reply.readInt32();
517        if (retCount != 0) {
518            uint32_t numDesc = (retCount < *count) ? retCount : *count;
519            reply.read(descriptors, sizeof(effect_descriptor_t) * numDesc);
520        }
521        *count = retCount;
522        return status;
523    }
524
525    virtual bool isOffloadSupported(const audio_offload_info_t& info)
526    {
527        Parcel data, reply;
528        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
529        data.write(&info, sizeof(audio_offload_info_t));
530        remote()->transact(IS_OFFLOAD_SUPPORTED, data, &reply);
531        return reply.readInt32();
532    }
533
534    virtual status_t listAudioPorts(audio_port_role_t role,
535                                    audio_port_type_t type,
536                                    unsigned int *num_ports,
537                                    struct audio_port *ports,
538                                    unsigned int *generation)
539    {
540        if (num_ports == NULL || (*num_ports != 0 && ports == NULL) ||
541                generation == NULL) {
542            return BAD_VALUE;
543        }
544        Parcel data, reply;
545        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
546        unsigned int numPortsReq = (ports == NULL) ? 0 : *num_ports;
547        data.writeInt32(role);
548        data.writeInt32(type);
549        data.writeInt32(numPortsReq);
550        status_t status = remote()->transact(LIST_AUDIO_PORTS, data, &reply);
551        if (status == NO_ERROR) {
552            status = (status_t)reply.readInt32();
553            *num_ports = (unsigned int)reply.readInt32();
554        }
555        if (status == NO_ERROR) {
556            if (numPortsReq > *num_ports) {
557                numPortsReq = *num_ports;
558            }
559            if (numPortsReq > 0) {
560                reply.read(ports, numPortsReq * sizeof(struct audio_port));
561            }
562            *generation = reply.readInt32();
563        }
564        return status;
565    }
566
567    virtual status_t getAudioPort(struct audio_port *port)
568    {
569        if (port == NULL) {
570            return BAD_VALUE;
571        }
572        Parcel data, reply;
573        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
574        data.write(port, sizeof(struct audio_port));
575        status_t status = remote()->transact(GET_AUDIO_PORT, data, &reply);
576        if (status != NO_ERROR ||
577                (status = (status_t)reply.readInt32()) != NO_ERROR) {
578            return status;
579        }
580        reply.read(port, sizeof(struct audio_port));
581        return status;
582    }
583
584    virtual status_t createAudioPatch(const struct audio_patch *patch,
585                                       audio_patch_handle_t *handle)
586    {
587        if (patch == NULL || handle == NULL) {
588            return BAD_VALUE;
589        }
590        Parcel data, reply;
591        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
592        data.write(patch, sizeof(struct audio_patch));
593        data.write(handle, sizeof(audio_patch_handle_t));
594        status_t status = remote()->transact(CREATE_AUDIO_PATCH, data, &reply);
595        if (status != NO_ERROR ||
596                (status = (status_t)reply.readInt32()) != NO_ERROR) {
597            return status;
598        }
599        reply.read(handle, sizeof(audio_patch_handle_t));
600        return status;
601    }
602
603    virtual status_t releaseAudioPatch(audio_patch_handle_t handle)
604    {
605        Parcel data, reply;
606        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
607        data.write(&handle, sizeof(audio_patch_handle_t));
608        status_t status = remote()->transact(RELEASE_AUDIO_PATCH, data, &reply);
609        if (status != NO_ERROR) {
610            status = (status_t)reply.readInt32();
611        }
612        return status;
613    }
614
615    virtual status_t listAudioPatches(unsigned int *num_patches,
616                                      struct audio_patch *patches,
617                                      unsigned int *generation)
618    {
619        if (num_patches == NULL || (*num_patches != 0 && patches == NULL) ||
620                generation == NULL) {
621            return BAD_VALUE;
622        }
623        Parcel data, reply;
624        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
625        unsigned int numPatchesReq = (patches == NULL) ? 0 : *num_patches;
626        data.writeInt32(numPatchesReq);
627        status_t status = remote()->transact(LIST_AUDIO_PATCHES, data, &reply);
628        if (status == NO_ERROR) {
629            status = (status_t)reply.readInt32();
630            *num_patches = (unsigned int)reply.readInt32();
631        }
632        if (status == NO_ERROR) {
633            if (numPatchesReq > *num_patches) {
634                numPatchesReq = *num_patches;
635            }
636            if (numPatchesReq > 0) {
637                reply.read(patches, numPatchesReq * sizeof(struct audio_patch));
638            }
639            *generation = reply.readInt32();
640        }
641        return status;
642    }
643
644    virtual status_t setAudioPortConfig(const struct audio_port_config *config)
645    {
646        if (config == NULL) {
647            return BAD_VALUE;
648        }
649        Parcel data, reply;
650        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
651        data.write(config, sizeof(struct audio_port_config));
652        status_t status = remote()->transact(SET_AUDIO_PORT_CONFIG, data, &reply);
653        if (status != NO_ERROR) {
654            status = (status_t)reply.readInt32();
655        }
656        return status;
657    }
658
659    virtual void registerClient(const sp<IAudioPolicyServiceClient>& client)
660    {
661        Parcel data, reply;
662        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
663        data.writeStrongBinder(IInterface::asBinder(client));
664        remote()->transact(REGISTER_CLIENT, data, &reply);
665    }
666
667    virtual void setAudioPortCallbacksEnabled(bool enabled)
668    {
669        Parcel data, reply;
670        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
671        data.writeInt32(enabled ? 1 : 0);
672        remote()->transact(SET_AUDIO_PORT_CALLBACK_ENABLED, data, &reply);
673    }
674
675    virtual status_t acquireSoundTriggerSession(audio_session_t *session,
676                                            audio_io_handle_t *ioHandle,
677                                            audio_devices_t *device)
678    {
679        if (session == NULL || ioHandle == NULL || device == NULL) {
680            return BAD_VALUE;
681        }
682        Parcel data, reply;
683        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
684        status_t status = remote()->transact(ACQUIRE_SOUNDTRIGGER_SESSION, data, &reply);
685        if (status != NO_ERROR) {
686            return status;
687        }
688        status = (status_t)reply.readInt32();
689        if (status == NO_ERROR) {
690            *session = (audio_session_t)reply.readInt32();
691            *ioHandle = (audio_io_handle_t)reply.readInt32();
692            *device = (audio_devices_t)reply.readInt32();
693        }
694        return status;
695    }
696
697    virtual status_t releaseSoundTriggerSession(audio_session_t session)
698    {
699        Parcel data, reply;
700        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
701        data.writeInt32(session);
702        status_t status = remote()->transact(RELEASE_SOUNDTRIGGER_SESSION, data, &reply);
703        if (status != NO_ERROR) {
704            return status;
705        }
706        return (status_t)reply.readInt32();
707    }
708
709    virtual audio_mode_t getPhoneState()
710    {
711        Parcel data, reply;
712        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
713        status_t status = remote()->transact(GET_PHONE_STATE, data, &reply);
714        if (status != NO_ERROR) {
715            return AUDIO_MODE_INVALID;
716        }
717        return (audio_mode_t)reply.readInt32();
718    }
719
720    virtual status_t registerPolicyMixes(const Vector<AudioMix>& mixes, bool registration)
721    {
722        Parcel data, reply;
723        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
724        data.writeInt32(registration ? 1 : 0);
725        size_t size = mixes.size();
726        if (size > MAX_MIXES_PER_POLICY) {
727            size = MAX_MIXES_PER_POLICY;
728        }
729        size_t sizePosition = data.dataPosition();
730        data.writeInt32(size);
731        size_t finalSize = size;
732        for (size_t i = 0; i < size; i++) {
733            size_t position = data.dataPosition();
734            if (mixes[i].writeToParcel(&data) != NO_ERROR) {
735                data.setDataPosition(position);
736                finalSize--;
737            }
738        }
739        if (size != finalSize) {
740            size_t position = data.dataPosition();
741            data.setDataPosition(sizePosition);
742            data.writeInt32(finalSize);
743            data.setDataPosition(position);
744        }
745        status_t status = remote()->transact(REGISTER_POLICY_MIXES, data, &reply);
746        if (status == NO_ERROR) {
747            status = (status_t)reply.readInt32();
748        }
749        return status;
750    }
751
752    virtual status_t startAudioSource(const struct audio_port_config *source,
753                                      const audio_attributes_t *attributes,
754                                      audio_patch_handle_t *handle)
755    {
756        Parcel data, reply;
757        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
758        if (source == NULL || attributes == NULL || handle == NULL) {
759            return BAD_VALUE;
760        }
761        data.write(source, sizeof(struct audio_port_config));
762        data.write(attributes, sizeof(audio_attributes_t));
763        status_t status = remote()->transact(START_AUDIO_SOURCE, data, &reply);
764        if (status != NO_ERROR) {
765            return status;
766        }
767        status = (status_t)reply.readInt32();
768        if (status != NO_ERROR) {
769            return status;
770        }
771        *handle = (audio_patch_handle_t)reply.readInt32();
772        return status;
773    }
774
775    virtual status_t stopAudioSource(audio_patch_handle_t handle)
776    {
777        Parcel data, reply;
778        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
779        data.writeInt32(handle);
780        status_t status = remote()->transact(STOP_AUDIO_SOURCE, data, &reply);
781        if (status != NO_ERROR) {
782            return status;
783        }
784        status = (status_t)reply.readInt32();
785        return status;
786    }
787
788    virtual status_t setMasterMono(bool mono)
789    {
790        Parcel data, reply;
791        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
792        data.writeInt32(static_cast<int32_t>(mono));
793        status_t status = remote()->transact(SET_MASTER_MONO, data, &reply);
794        if (status != NO_ERROR) {
795            return status;
796        }
797        return static_cast<status_t>(reply.readInt32());
798    }
799
800    virtual status_t getMasterMono(bool *mono)
801    {
802        if (mono == nullptr) {
803            return BAD_VALUE;
804        }
805        Parcel data, reply;
806        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
807
808        status_t status = remote()->transact(GET_MASTER_MONO, data, &reply);
809        if (status != NO_ERROR) {
810            return status;
811        }
812        status = static_cast<status_t>(reply.readInt32());
813        if (status == NO_ERROR) {
814            *mono = static_cast<bool>(reply.readInt32());
815        }
816        return status;
817    }
818
819    virtual float getStreamVolumeDB(audio_stream_type_t stream, int index, audio_devices_t device)
820    {
821        Parcel data, reply;
822        data.writeInterfaceToken(IAudioPolicyService::getInterfaceDescriptor());
823        data.writeInt32(static_cast <int32_t>(stream));
824        data.writeInt32(static_cast <int32_t>(index));
825        data.writeUint32(static_cast <uint32_t>(device));
826        status_t status = remote()->transact(GET_STREAM_VOLUME_DB, data, &reply);
827        if (status != NO_ERROR) {
828            return NAN;
829        }
830        return reply.readFloat();
831    }
832};
833
834IMPLEMENT_META_INTERFACE(AudioPolicyService, "android.media.IAudioPolicyService");
835
836// ----------------------------------------------------------------------
837
838status_t BnAudioPolicyService::onTransact(
839    uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags)
840{
841    // make sure transactions reserved to AudioFlinger do not come from other processes
842    switch (code) {
843        case START_OUTPUT:
844        case STOP_OUTPUT:
845        case RELEASE_OUTPUT:
846        case GET_INPUT_FOR_ATTR:
847        case START_INPUT:
848        case STOP_INPUT:
849        case RELEASE_INPUT:
850        case GET_STRATEGY_FOR_STREAM:
851        case GET_OUTPUT_FOR_EFFECT:
852        case REGISTER_EFFECT:
853        case UNREGISTER_EFFECT:
854        case SET_EFFECT_ENABLED:
855        case GET_OUTPUT_FOR_ATTR:
856        case ACQUIRE_SOUNDTRIGGER_SESSION:
857        case RELEASE_SOUNDTRIGGER_SESSION:
858            ALOGW("%s: transaction %d received from PID %d",
859                  __func__, code, IPCThreadState::self()->getCallingPid());
860            return INVALID_OPERATION;
861        default:
862            break;
863    }
864
865    // make sure the following transactions come from system components
866    switch (code) {
867        case SET_DEVICE_CONNECTION_STATE:
868        case HANDLE_DEVICE_CONFIG_CHANGE:
869        case SET_PHONE_STATE:
870        case SET_RINGER_MODE:
871        case SET_FORCE_USE:
872        case INIT_STREAM_VOLUME:
873        case SET_STREAM_VOLUME:
874        case REGISTER_POLICY_MIXES:
875        case SET_MASTER_MONO:
876            if (IPCThreadState::self()->getCallingUid() >= AID_APP_START) {
877                ALOGW("%s: transaction %d received from PID %d unauthorized UID %d",
878                      __func__, code, IPCThreadState::self()->getCallingPid(),
879                      IPCThreadState::self()->getCallingUid());
880                return INVALID_OPERATION;
881            }
882        default:
883            break;
884    }
885
886    // FIXME: extend timeout for SET_DEVICE_CONNECTION_STATE and HANDLE_DEVICE_CONFIG_CHANGE
887    // while we investigate why BT A2DP device connection/disconnection can sometimes
888    // take more than 5 seconds
889    uint32_t timeoutMs = TimeCheck::kDefaultTimeOutMs;
890    switch (code) {
891        case SET_DEVICE_CONNECTION_STATE:
892        case HANDLE_DEVICE_CONFIG_CHANGE:
893            timeoutMs *= 2;
894            break;
895        default:
896            break;
897    }
898
899    TimeCheck check("IAudioPolicyService", timeoutMs);
900
901    switch (code) {
902        case SET_DEVICE_CONNECTION_STATE: {
903            CHECK_INTERFACE(IAudioPolicyService, data, reply);
904            audio_devices_t device =
905                    static_cast <audio_devices_t>(data.readInt32());
906            audio_policy_dev_state_t state =
907                    static_cast <audio_policy_dev_state_t>(data.readInt32());
908            const char *device_address = data.readCString();
909            const char *device_name = data.readCString();
910            if (device_address == nullptr || device_name == nullptr) {
911                ALOGE("Bad Binder transaction: SET_DEVICE_CONNECTION_STATE for device %u", device);
912                reply->writeInt32(static_cast<int32_t> (BAD_VALUE));
913            } else {
914                reply->writeInt32(static_cast<uint32_t> (setDeviceConnectionState(device,
915                                                                                  state,
916                                                                                  device_address,
917                                                                                  device_name)));
918            }
919            return NO_ERROR;
920        } break;
921
922        case GET_DEVICE_CONNECTION_STATE: {
923            CHECK_INTERFACE(IAudioPolicyService, data, reply);
924            audio_devices_t device =
925                    static_cast<audio_devices_t> (data.readInt32());
926            const char *device_address = data.readCString();
927            if (device_address == nullptr) {
928                ALOGE("Bad Binder transaction: GET_DEVICE_CONNECTION_STATE for device %u", device);
929                reply->writeInt32(static_cast<int32_t> (AUDIO_POLICY_DEVICE_STATE_UNAVAILABLE));
930            } else {
931                reply->writeInt32(static_cast<uint32_t> (getDeviceConnectionState(device,
932                                                                                  device_address)));
933            }
934            return NO_ERROR;
935        } break;
936
937        case HANDLE_DEVICE_CONFIG_CHANGE: {
938            CHECK_INTERFACE(IAudioPolicyService, data, reply);
939            audio_devices_t device =
940                    static_cast <audio_devices_t>(data.readInt32());
941            const char *device_address = data.readCString();
942            const char *device_name = data.readCString();
943            if (device_address == nullptr || device_name == nullptr) {
944                ALOGE("Bad Binder transaction: HANDLE_DEVICE_CONFIG_CHANGE for device %u", device);
945                reply->writeInt32(static_cast<int32_t> (BAD_VALUE));
946            } else {
947                reply->writeInt32(static_cast<uint32_t> (handleDeviceConfigChange(device,
948                                                                                  device_address,
949                                                                                  device_name)));
950            }
951            return NO_ERROR;
952        } break;
953
954        case SET_PHONE_STATE: {
955            CHECK_INTERFACE(IAudioPolicyService, data, reply);
956            reply->writeInt32(static_cast <uint32_t>(setPhoneState(
957                    (audio_mode_t) data.readInt32())));
958            return NO_ERROR;
959        } break;
960
961        case SET_FORCE_USE: {
962            CHECK_INTERFACE(IAudioPolicyService, data, reply);
963            audio_policy_force_use_t usage = static_cast <audio_policy_force_use_t>(
964                    data.readInt32());
965            audio_policy_forced_cfg_t config =
966                    static_cast <audio_policy_forced_cfg_t>(data.readInt32());
967            reply->writeInt32(static_cast <uint32_t>(setForceUse(usage, config)));
968            return NO_ERROR;
969        } break;
970
971        case GET_FORCE_USE: {
972            CHECK_INTERFACE(IAudioPolicyService, data, reply);
973            audio_policy_force_use_t usage = static_cast <audio_policy_force_use_t>(
974                    data.readInt32());
975            reply->writeInt32(static_cast <uint32_t>(getForceUse(usage)));
976            return NO_ERROR;
977        } break;
978
979        case GET_OUTPUT: {
980            CHECK_INTERFACE(IAudioPolicyService, data, reply);
981            audio_stream_type_t stream =
982                    static_cast <audio_stream_type_t>(data.readInt32());
983            audio_io_handle_t output = getOutput(stream);
984            reply->writeInt32(static_cast <int>(output));
985            return NO_ERROR;
986        } break;
987
988        case GET_OUTPUT_FOR_ATTR: {
989            CHECK_INTERFACE(IAudioPolicyService, data, reply);
990            audio_attributes_t attr;
991            bool hasAttributes = data.readInt32() != 0;
992            if (hasAttributes) {
993                data.read(&attr, sizeof(audio_attributes_t));
994                sanetizeAudioAttributes(&attr);
995            }
996            audio_session_t session = (audio_session_t)data.readInt32();
997            audio_stream_type_t stream = AUDIO_STREAM_DEFAULT;
998            bool hasStream = data.readInt32() != 0;
999            if (hasStream) {
1000                stream = (audio_stream_type_t)data.readInt32();
1001            }
1002            pid_t pid = (pid_t)data.readInt32();
1003            uid_t uid = (uid_t)data.readInt32();
1004            audio_config_t config;
1005            memset(&config, 0, sizeof(audio_config_t));
1006            data.read(&config, sizeof(audio_config_t));
1007            audio_output_flags_t flags =
1008                    static_cast <audio_output_flags_t>(data.readInt32());
1009            audio_port_handle_t selectedDeviceId = data.readInt32();
1010            audio_port_handle_t portId = (audio_port_handle_t)data.readInt32();
1011            audio_io_handle_t output = 0;
1012            status_t status = getOutputForAttr(hasAttributes ? &attr : NULL,
1013                    &output, session, &stream, pid, uid,
1014                    &config,
1015                    flags, &selectedDeviceId, &portId);
1016            reply->writeInt32(status);
1017            reply->writeInt32(output);
1018            reply->writeInt32(stream);
1019            reply->writeInt32(selectedDeviceId);
1020            reply->writeInt32(portId);
1021            return NO_ERROR;
1022        } break;
1023
1024        case START_OUTPUT: {
1025            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1026            audio_io_handle_t output = static_cast <audio_io_handle_t>(data.readInt32());
1027            audio_stream_type_t stream =
1028                                static_cast <audio_stream_type_t>(data.readInt32());
1029            audio_session_t session = (audio_session_t)data.readInt32();
1030            reply->writeInt32(static_cast <uint32_t>(startOutput(output,
1031                                                                 stream,
1032                                                                 session)));
1033            return NO_ERROR;
1034        } break;
1035
1036        case STOP_OUTPUT: {
1037            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1038            audio_io_handle_t output = static_cast <audio_io_handle_t>(data.readInt32());
1039            audio_stream_type_t stream =
1040                                static_cast <audio_stream_type_t>(data.readInt32());
1041            audio_session_t session = (audio_session_t)data.readInt32();
1042            reply->writeInt32(static_cast <uint32_t>(stopOutput(output,
1043                                                                stream,
1044                                                                session)));
1045            return NO_ERROR;
1046        } break;
1047
1048        case RELEASE_OUTPUT: {
1049            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1050            audio_io_handle_t output = static_cast <audio_io_handle_t>(data.readInt32());
1051            audio_stream_type_t stream = (audio_stream_type_t)data.readInt32();
1052            audio_session_t session = (audio_session_t)data.readInt32();
1053            releaseOutput(output, stream, session);
1054            return NO_ERROR;
1055        } break;
1056
1057        case GET_INPUT_FOR_ATTR: {
1058            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1059            audio_attributes_t attr;
1060            data.read(&attr, sizeof(audio_attributes_t));
1061            sanetizeAudioAttributes(&attr);
1062            audio_io_handle_t input = (audio_io_handle_t)data.readInt32();
1063            audio_session_t session = (audio_session_t)data.readInt32();
1064            pid_t pid = (pid_t)data.readInt32();
1065            uid_t uid = (uid_t)data.readInt32();
1066            const String16 opPackageName = data.readString16();
1067            audio_config_base_t config;
1068            memset(&config, 0, sizeof(audio_config_base_t));
1069            data.read(&config, sizeof(audio_config_base_t));
1070            audio_input_flags_t flags = (audio_input_flags_t) data.readInt32();
1071            audio_port_handle_t selectedDeviceId = (audio_port_handle_t) data.readInt32();
1072            audio_port_handle_t portId = (audio_port_handle_t)data.readInt32();
1073            status_t status = getInputForAttr(&attr, &input, session, pid, uid,
1074                                              opPackageName, &config,
1075                                              flags, &selectedDeviceId, &portId);
1076            reply->writeInt32(status);
1077            if (status == NO_ERROR) {
1078                reply->writeInt32(input);
1079                reply->writeInt32(selectedDeviceId);
1080                reply->writeInt32(portId);
1081            }
1082            return NO_ERROR;
1083        } break;
1084
1085        case START_INPUT: {
1086            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1087            audio_port_handle_t portId = static_cast <audio_port_handle_t>(data.readInt32());
1088            bool silenced = data.readInt32() == 1;
1089            status_t status = startInput(portId, &silenced);
1090            reply->writeInt32(static_cast <uint32_t>(status));
1091            reply->writeInt32(silenced ? 1 : 0);
1092            return NO_ERROR;
1093        } break;
1094
1095        case STOP_INPUT: {
1096            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1097            audio_port_handle_t portId = static_cast <audio_port_handle_t>(data.readInt32());
1098            reply->writeInt32(static_cast <uint32_t>(stopInput(portId)));
1099            return NO_ERROR;
1100        } break;
1101
1102        case RELEASE_INPUT: {
1103            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1104            audio_port_handle_t portId = static_cast <audio_port_handle_t>(data.readInt32());
1105            releaseInput(portId);
1106            return NO_ERROR;
1107        } break;
1108
1109        case INIT_STREAM_VOLUME: {
1110            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1111            audio_stream_type_t stream =
1112                    static_cast <audio_stream_type_t>(data.readInt32());
1113            int indexMin = data.readInt32();
1114            int indexMax = data.readInt32();
1115            reply->writeInt32(static_cast <uint32_t>(initStreamVolume(stream, indexMin,indexMax)));
1116            return NO_ERROR;
1117        } break;
1118
1119        case SET_STREAM_VOLUME: {
1120            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1121            audio_stream_type_t stream =
1122                    static_cast <audio_stream_type_t>(data.readInt32());
1123            int index = data.readInt32();
1124            audio_devices_t device = static_cast <audio_devices_t>(data.readInt32());
1125            reply->writeInt32(static_cast <uint32_t>(setStreamVolumeIndex(stream,
1126                                                                          index,
1127                                                                          device)));
1128            return NO_ERROR;
1129        } break;
1130
1131        case GET_STREAM_VOLUME: {
1132            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1133            audio_stream_type_t stream =
1134                    static_cast <audio_stream_type_t>(data.readInt32());
1135            audio_devices_t device = static_cast <audio_devices_t>(data.readInt32());
1136            int index = 0;
1137            status_t status = getStreamVolumeIndex(stream, &index, device);
1138            reply->writeInt32(index);
1139            reply->writeInt32(static_cast <uint32_t>(status));
1140            return NO_ERROR;
1141        } break;
1142
1143        case GET_STRATEGY_FOR_STREAM: {
1144            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1145            audio_stream_type_t stream =
1146                    static_cast <audio_stream_type_t>(data.readInt32());
1147            reply->writeInt32(getStrategyForStream(stream));
1148            return NO_ERROR;
1149        } break;
1150
1151        case GET_DEVICES_FOR_STREAM: {
1152            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1153            audio_stream_type_t stream =
1154                    static_cast <audio_stream_type_t>(data.readInt32());
1155            reply->writeInt32(static_cast <int>(getDevicesForStream(stream)));
1156            return NO_ERROR;
1157        } break;
1158
1159        case GET_OUTPUT_FOR_EFFECT: {
1160            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1161            effect_descriptor_t desc;
1162            data.read(&desc, sizeof(effect_descriptor_t));
1163            audio_io_handle_t output = getOutputForEffect(&desc);
1164            reply->writeInt32(static_cast <int>(output));
1165            return NO_ERROR;
1166        } break;
1167
1168        case REGISTER_EFFECT: {
1169            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1170            effect_descriptor_t desc;
1171            data.read(&desc, sizeof(effect_descriptor_t));
1172            audio_io_handle_t io = data.readInt32();
1173            uint32_t strategy = data.readInt32();
1174            audio_session_t session = (audio_session_t) data.readInt32();
1175            int id = data.readInt32();
1176            reply->writeInt32(static_cast <int32_t>(registerEffect(&desc,
1177                                                                   io,
1178                                                                   strategy,
1179                                                                   session,
1180                                                                   id)));
1181            return NO_ERROR;
1182        } break;
1183
1184        case UNREGISTER_EFFECT: {
1185            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1186            int id = data.readInt32();
1187            reply->writeInt32(static_cast <int32_t>(unregisterEffect(id)));
1188            return NO_ERROR;
1189        } break;
1190
1191        case SET_EFFECT_ENABLED: {
1192            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1193            int id = data.readInt32();
1194            bool enabled = static_cast <bool>(data.readInt32());
1195            reply->writeInt32(static_cast <int32_t>(setEffectEnabled(id, enabled)));
1196            return NO_ERROR;
1197        } break;
1198
1199        case IS_STREAM_ACTIVE: {
1200            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1201            audio_stream_type_t stream = (audio_stream_type_t) data.readInt32();
1202            uint32_t inPastMs = (uint32_t)data.readInt32();
1203            reply->writeInt32( isStreamActive(stream, inPastMs) );
1204            return NO_ERROR;
1205        } break;
1206
1207        case IS_STREAM_ACTIVE_REMOTELY: {
1208            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1209            audio_stream_type_t stream = (audio_stream_type_t) data.readInt32();
1210            uint32_t inPastMs = (uint32_t)data.readInt32();
1211            reply->writeInt32( isStreamActiveRemotely(stream, inPastMs) );
1212            return NO_ERROR;
1213        } break;
1214
1215        case IS_SOURCE_ACTIVE: {
1216            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1217            audio_source_t source = (audio_source_t) data.readInt32();
1218            reply->writeInt32( isSourceActive(source));
1219            return NO_ERROR;
1220        }
1221
1222        case QUERY_DEFAULT_PRE_PROCESSING: {
1223            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1224            audio_session_t audioSession = (audio_session_t) data.readInt32();
1225            uint32_t count = data.readInt32();
1226            if (count > AudioEffect::kMaxPreProcessing) {
1227                count = AudioEffect::kMaxPreProcessing;
1228            }
1229            uint32_t retCount = count;
1230            effect_descriptor_t *descriptors = new effect_descriptor_t[count];
1231            status_t status = queryDefaultPreProcessing(audioSession, descriptors, &retCount);
1232            reply->writeInt32(status);
1233            if (status != NO_ERROR && status != NO_MEMORY) {
1234                retCount = 0;
1235            }
1236            reply->writeInt32(retCount);
1237            if (retCount != 0) {
1238                if (retCount < count) {
1239                    count = retCount;
1240                }
1241                reply->write(descriptors, sizeof(effect_descriptor_t) * count);
1242            }
1243            delete[] descriptors;
1244            return status;
1245        }
1246
1247        case IS_OFFLOAD_SUPPORTED: {
1248            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1249            audio_offload_info_t info;
1250            data.read(&info, sizeof(audio_offload_info_t));
1251            bool isSupported = isOffloadSupported(info);
1252            reply->writeInt32(isSupported);
1253            return NO_ERROR;
1254        }
1255
1256        case LIST_AUDIO_PORTS: {
1257            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1258            audio_port_role_t role = (audio_port_role_t)data.readInt32();
1259            audio_port_type_t type = (audio_port_type_t)data.readInt32();
1260            unsigned int numPortsReq = data.readInt32();
1261            if (numPortsReq > MAX_ITEMS_PER_LIST) {
1262                numPortsReq = MAX_ITEMS_PER_LIST;
1263            }
1264            unsigned int numPorts = numPortsReq;
1265            struct audio_port *ports =
1266                    (struct audio_port *)calloc(numPortsReq, sizeof(struct audio_port));
1267            if (ports == NULL) {
1268                reply->writeInt32(NO_MEMORY);
1269                reply->writeInt32(0);
1270                return NO_ERROR;
1271            }
1272            unsigned int generation;
1273            status_t status = listAudioPorts(role, type, &numPorts, ports, &generation);
1274            reply->writeInt32(status);
1275            reply->writeInt32(numPorts);
1276
1277            if (status == NO_ERROR) {
1278                if (numPortsReq > numPorts) {
1279                    numPortsReq = numPorts;
1280                }
1281                reply->write(ports, numPortsReq * sizeof(struct audio_port));
1282                reply->writeInt32(generation);
1283            }
1284            free(ports);
1285            return NO_ERROR;
1286        }
1287
1288        case GET_AUDIO_PORT: {
1289            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1290            struct audio_port port = {};
1291            if (data.read(&port, sizeof(struct audio_port)) != NO_ERROR) {
1292                ALOGE("b/23912202");
1293            }
1294            status_t status = getAudioPort(&port);
1295            reply->writeInt32(status);
1296            if (status == NO_ERROR) {
1297                reply->write(&port, sizeof(struct audio_port));
1298            }
1299            return NO_ERROR;
1300        }
1301
1302        case CREATE_AUDIO_PATCH: {
1303            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1304            struct audio_patch patch;
1305            data.read(&patch, sizeof(struct audio_patch));
1306            audio_patch_handle_t handle = AUDIO_PATCH_HANDLE_NONE;
1307            if (data.read(&handle, sizeof(audio_patch_handle_t)) != NO_ERROR) {
1308                ALOGE("b/23912202");
1309            }
1310            status_t status = createAudioPatch(&patch, &handle);
1311            reply->writeInt32(status);
1312            if (status == NO_ERROR) {
1313                reply->write(&handle, sizeof(audio_patch_handle_t));
1314            }
1315            return NO_ERROR;
1316        }
1317
1318        case RELEASE_AUDIO_PATCH: {
1319            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1320            audio_patch_handle_t handle;
1321            data.read(&handle, sizeof(audio_patch_handle_t));
1322            status_t status = releaseAudioPatch(handle);
1323            reply->writeInt32(status);
1324            return NO_ERROR;
1325        }
1326
1327        case LIST_AUDIO_PATCHES: {
1328            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1329            unsigned int numPatchesReq = data.readInt32();
1330            if (numPatchesReq > MAX_ITEMS_PER_LIST) {
1331                numPatchesReq = MAX_ITEMS_PER_LIST;
1332            }
1333            unsigned int numPatches = numPatchesReq;
1334            struct audio_patch *patches =
1335                    (struct audio_patch *)calloc(numPatchesReq,
1336                                                 sizeof(struct audio_patch));
1337            if (patches == NULL) {
1338                reply->writeInt32(NO_MEMORY);
1339                reply->writeInt32(0);
1340                return NO_ERROR;
1341            }
1342            unsigned int generation;
1343            status_t status = listAudioPatches(&numPatches, patches, &generation);
1344            reply->writeInt32(status);
1345            reply->writeInt32(numPatches);
1346            if (status == NO_ERROR) {
1347                if (numPatchesReq > numPatches) {
1348                    numPatchesReq = numPatches;
1349                }
1350                reply->write(patches, numPatchesReq * sizeof(struct audio_patch));
1351                reply->writeInt32(generation);
1352            }
1353            free(patches);
1354            return NO_ERROR;
1355        }
1356
1357        case SET_AUDIO_PORT_CONFIG: {
1358            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1359            struct audio_port_config config;
1360            data.read(&config, sizeof(struct audio_port_config));
1361            status_t status = setAudioPortConfig(&config);
1362            reply->writeInt32(status);
1363            return NO_ERROR;
1364        }
1365
1366        case REGISTER_CLIENT: {
1367            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1368            sp<IAudioPolicyServiceClient> client = interface_cast<IAudioPolicyServiceClient>(
1369                    data.readStrongBinder());
1370            registerClient(client);
1371            return NO_ERROR;
1372        } break;
1373
1374        case SET_AUDIO_PORT_CALLBACK_ENABLED: {
1375            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1376            setAudioPortCallbacksEnabled(data.readInt32() == 1);
1377            return NO_ERROR;
1378        } break;
1379
1380        case ACQUIRE_SOUNDTRIGGER_SESSION: {
1381            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1382            sp<IAudioPolicyServiceClient> client = interface_cast<IAudioPolicyServiceClient>(
1383                    data.readStrongBinder());
1384            audio_session_t session = AUDIO_SESSION_NONE;
1385            audio_io_handle_t ioHandle = AUDIO_IO_HANDLE_NONE;
1386            audio_devices_t device = AUDIO_DEVICE_NONE;
1387            status_t status = acquireSoundTriggerSession(&session, &ioHandle, &device);
1388            reply->writeInt32(status);
1389            if (status == NO_ERROR) {
1390                reply->writeInt32(session);
1391                reply->writeInt32(ioHandle);
1392                reply->writeInt32(device);
1393            }
1394            return NO_ERROR;
1395        } break;
1396
1397        case RELEASE_SOUNDTRIGGER_SESSION: {
1398            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1399            sp<IAudioPolicyServiceClient> client = interface_cast<IAudioPolicyServiceClient>(
1400                    data.readStrongBinder());
1401            audio_session_t session = (audio_session_t)data.readInt32();
1402            status_t status = releaseSoundTriggerSession(session);
1403            reply->writeInt32(status);
1404            return NO_ERROR;
1405        } break;
1406
1407        case GET_PHONE_STATE: {
1408            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1409            reply->writeInt32((int32_t)getPhoneState());
1410            return NO_ERROR;
1411        } break;
1412
1413        case REGISTER_POLICY_MIXES: {
1414            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1415            bool registration = data.readInt32() == 1;
1416            Vector<AudioMix> mixes;
1417            size_t size = (size_t)data.readInt32();
1418            if (size > MAX_MIXES_PER_POLICY) {
1419                size = MAX_MIXES_PER_POLICY;
1420            }
1421            for (size_t i = 0; i < size; i++) {
1422                AudioMix mix;
1423                if (mix.readFromParcel((Parcel*)&data) == NO_ERROR) {
1424                    mixes.add(mix);
1425                }
1426            }
1427            status_t status = registerPolicyMixes(mixes, registration);
1428            reply->writeInt32(status);
1429            return NO_ERROR;
1430        } break;
1431
1432        case START_AUDIO_SOURCE: {
1433            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1434            struct audio_port_config source;
1435            data.read(&source, sizeof(struct audio_port_config));
1436            audio_attributes_t attributes;
1437            data.read(&attributes, sizeof(audio_attributes_t));
1438            sanetizeAudioAttributes(&attributes);
1439            audio_patch_handle_t handle = AUDIO_PATCH_HANDLE_NONE;
1440            status_t status = startAudioSource(&source, &attributes, &handle);
1441            reply->writeInt32(status);
1442            reply->writeInt32(handle);
1443            return NO_ERROR;
1444        } break;
1445
1446        case STOP_AUDIO_SOURCE: {
1447            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1448            audio_patch_handle_t handle = (audio_patch_handle_t) data.readInt32();
1449            status_t status = stopAudioSource(handle);
1450            reply->writeInt32(status);
1451            return NO_ERROR;
1452        } break;
1453
1454        case SET_MASTER_MONO: {
1455            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1456            bool mono = static_cast<bool>(data.readInt32());
1457            status_t status = setMasterMono(mono);
1458            reply->writeInt32(status);
1459            return NO_ERROR;
1460        } break;
1461
1462        case GET_MASTER_MONO: {
1463            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1464            bool mono;
1465            status_t status = getMasterMono(&mono);
1466            reply->writeInt32(status);
1467            if (status == NO_ERROR) {
1468                reply->writeInt32(static_cast<int32_t>(mono));
1469            }
1470            return NO_ERROR;
1471        } break;
1472
1473        case GET_STREAM_VOLUME_DB: {
1474            CHECK_INTERFACE(IAudioPolicyService, data, reply);
1475            audio_stream_type_t stream =
1476                    static_cast <audio_stream_type_t>(data.readInt32());
1477            int index = static_cast <int>(data.readInt32());
1478            audio_devices_t device =
1479                    static_cast <audio_devices_t>(data.readUint32());
1480            reply->writeFloat(getStreamVolumeDB(stream, index, device));
1481            return NO_ERROR;
1482        }
1483
1484        default:
1485            return BBinder::onTransact(code, data, reply, flags);
1486    }
1487}
1488
1489void BnAudioPolicyService::sanetizeAudioAttributes(audio_attributes_t* attr)
1490{
1491    const size_t tagsMaxSize = AUDIO_ATTRIBUTES_TAGS_MAX_SIZE;
1492    if (strnlen(attr->tags, tagsMaxSize) >= tagsMaxSize) {
1493        android_errorWriteLog(0x534e4554, "68953950"); // SafetyNet logging
1494    }
1495    attr->tags[tagsMaxSize - 1] = '\0';
1496}
1497
1498// ----------------------------------------------------------------------------
1499
1500} // namespace android
1501