/* * Copyright (C) 2016 "IoT.bzh" * Author Fulup Ar Foll * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * * reference: * amixer contents; amixer controls; * http://www.tldp.org/HOWTO/Alsa-sound-6.html */ #define _GNU_SOURCE // needed for vasprintf #include #include #include #include #include #include #include #include #include #include "hal-interface.h" typedef struct { int index; int numid; } shareHallMap_T; static shareHallMap_T *shareHallMap; static alsaHalMapT *halCtls; // Force specific HAL to depend on ShareHalLib PUBLIC char* SharedHalLibVersion="1.0"; // Subscribe to AudioBinding events STATIC void halSubscribe(afb_req request) { const char *devid = afb_req_value(request, "devid"); if (devid == NULL) { afb_req_fail_f(request, "devid-missing", "devid=hw:xxx missing"); } } // Call when all bindings are loaded and ready to accept request STATIC void halGetVol(afb_req request) { // Should call here Hardware Alsa Abstraction Layer for corresponding Sound Card afb_req_success(request, NULL, NULL); return; } STATIC void halSetVol(afb_req request) { const char *arg; const char *pcm; arg = afb_req_value(request, "vol"); if (arg == NULL) { afb_req_fail_f(request, "argument-missing", "vol=[0,100] missing"); goto OnErrorExit; } pcm = afb_req_value(request, "pcm"); if (pcm == NULL) pcm = "Master"; // Should call here Hardware Alsa Abstraction Layer for corresponding Sound Card afb_req_success(request, NULL, NULL); return; OnErrorExit: return; } // AudioLogic expect volume values to be 0-100% STATIC int NormaliseValue(const alsaHalCtlMapT *halCtls, int valuein) { int valueout; if (valuein > halCtls->maxval) valuein= halCtls->maxval; if (valuein < halCtls->minval) valuein= halCtls->minval; // volume are ajusted to 100% any else is ignored switch (halCtls->group) { case OUTVOL: case PCMVOL: case INVOL: valueout = (valuein * 100) / (halCtls->maxval - halCtls->minval); break; default: valueout = valuein; } return (valueout); } // receive controls for LowLevel remap them to hight level before returning them STATIC void halGetControlCB(void *handle, int iserror, struct json_object *result) { struct json_object *response; // retrieve request and check for errors afb_req request = afb_req_unstore(handle); if (!cbCheckResponse(request, iserror, result)) goto OnExit; // Get response from object json_object_object_get_ex(result, "response", &response); if (!response) { afb_req_fail_f(request, "response-notfound", "No Controls return from alsa/getcontrol result=[%s]", json_object_get_string(result)); goto OnExit; } // extract sounds controls information from received Object struct json_object *ctls; json_object_object_get_ex(result, "ctls", &ctls); if (!ctls) { afb_req_fail_f(request, "ctls-notfound", "No Controls return from alsa/getcontrol response=[%s]", json_object_get_string(response)); goto OnExit; } // make sure return controls have a valid type if (json_object_get_type(ctls) != json_type_array) { afb_req_fail_f(request, "ctls-notarray", "Invalid Controls return from alsa/getcontrol response=[%s]", json_object_get_string(response)); goto OnExit; } // loop on array and store values into client context for (int idx = 0; idx < json_object_array_length(ctls); idx++) { struct json_object *ctl; int rawvalue, numid; ctl = json_object_array_get_idx(ctls, idx); if (json_object_array_length(ctl) != 2) { afb_req_fail_f(request, "ctl-invalid", "Invalid Control return from alsa/getcontrol ctl=[%s]", json_object_get_string(ctl)); goto OnExit; } // As HAL and Business logic use the same AlsaMixerHal.h direct conversion is not an issue numid = (halCtlsEnumT) json_object_get_int(json_object_array_get_idx(ctl, 0)); rawvalue = json_object_get_int(json_object_array_get_idx(ctl, 1)); for (int idx = 0; halCtls[idx].alsa.numid != 0; idx++) { if (halCtls[idx].alsa.numid == numid) { struct json_object *ctlAndValue = json_object_new_array(); json_object_array_add(ctlAndValue, json_object_new_int(idx)); // idx == high level control json_object_array_add(ctlAndValue, json_object_new_int(NormaliseValue(&halCtls[idx].alsa, rawvalue))); break; } } if (shareHallMap[idx].numid == 0) { afb_req_fail_f(request, "ctl-invalid", "Invalid Control numid from alsa/getcontrol ctl=[%s]", json_object_get_string(ctl)); goto OnExit; } } OnExit: return; } // Translate high level control to low level and call lower layer STATIC void halGetCtls(afb_req request) { struct json_object *queryin, *queryout, *ctlsin, *devid; struct json_object *ctlsout = json_object_new_array(); // get query from request queryin = afb_req_json(request); // check devid was given if (!json_object_object_get_ex (queryin, "devid", &devid)) { afb_req_fail_f(request, "devid-notfound", "No DevID given query=[%s]", json_object_get_string(queryin)); goto OnExit; } // loop on requested controls if (!json_object_object_get_ex(queryin, "ctls", &ctlsin) || json_object_array_length(ctlsin) <= 0) { afb_req_fail_f(request, "ctlsin-notfound", "No Controls given query=[%s]", json_object_get_string(queryin)); goto OnExit; } // loop on controls for (int idx = 0; idx < json_object_array_length(ctlsin); idx++) { struct json_object *ctl; halCtlsEnumT control; // each control should be halCtlsEnumT ctl = json_object_array_get_idx(ctlsin, idx); control = (halCtlsEnumT) json_object_get_int(ctl); if (control >= EndHalCrlTag || control <= StartHalCrlTag) { afb_req_fail_f(request, "ctl-invalid", "Invalid Control devid=%s ctl=[%s] should be [%d-%d]" , json_object_get_string(devid), json_object_get_string(ctl), StartHalCrlTag, EndHalCrlTag); goto OnExit; } // add corresponding lowlevel numid to querylist json_object_array_add(ctlsout, json_object_new_int(shareHallMap[control].numid)); } // register HAL with Alsa Low Level Binder devid=hw:0&numid=1&quiet=0 queryout = json_object_new_object(); json_object_object_add(queryout, "devid", devid); json_object_object_add(queryout, "ctls", ctlsout); // Fulup afb_service_call("alsacore", "getctl", queryout, halGetControlCB, handle); OnExit: // Under normal situation success/failure is set from callback return; }; // This receive all event this binding subscribe to PUBLIC void halServiceEvent(const char *evtname, struct json_object *object) { AFB_NOTICE("afbBindingV1ServiceEvent evtname=%s [msg=%s]", evtname, json_object_to_json_string(object)); } // this is call when after all bindings are loaded PUBLIC int halServiceInit (const char *apiPrefix, alsaHalSndCardT *alsaHalSndCard) { int ok, err; struct json_object *queryurl, *responseJ, *devidJ, *tmpJ; halCtls = alsaHalSndCard->ctls; // Get sndcard specific HAL control mapping err= afb_daemon_require_api("alsacore", 1); if (err) { AFB_ERROR ("AlsaCore missing cannot use AlsaHAL"); goto OnErrorExit; } // register HAL with Alsa Low Level Binder queryurl = json_object_new_object(); json_object_object_add(queryurl, "prefix", json_object_new_string(apiPrefix)); json_object_object_add(queryurl, "sndname", json_object_new_string(alsaHalSndCard->name)); ok= afb_service_call_sync ("alsacore", "registerHal", queryurl, &responseJ); json_object_put(queryurl); if (!ok) { NOTICE ("Fail to register HAL to ALSA lowlevel binding Response=[%s]", json_object_to_json_string(responseJ)); goto OnErrorExit; } // extract sound devid from HAL registration if (!json_object_object_get_ex(responseJ, "response", &tmpJ) || !json_object_object_get_ex(tmpJ, "devid", &devidJ)) { AFB_ERROR ("Ooops: Internal error no devid return from HAL registration Response=[%s]", json_object_to_json_string(responseJ)); goto OnErrorExit; } // for each Non Alsa Control callback create a custom control for (int idx = 0; halCtls[idx].alsa.numid != 0; idx++) { if (halCtls[idx].cb.callback != NULL) { queryurl = json_object_new_object(); json_object_object_add(queryurl, "devid",devidJ); tmpJ = json_object_new_object(); if (halCtls[idx].alsa.name) json_object_object_add(tmpJ, "name" , json_object_new_string(halCtls[idx].alsa.name)); if (halCtls[idx].alsa.numid) json_object_object_add(tmpJ, "numid" , json_object_new_int(halCtls[idx].alsa.numid)); if (halCtls[idx].alsa.minval) json_object_object_add(tmpJ, "minval", json_object_new_int(halCtls[idx].alsa.minval)); if (halCtls[idx].alsa.maxval) json_object_object_add(tmpJ, "maxval", json_object_new_int(halCtls[idx].alsa.maxval)); if (halCtls[idx].alsa.step) json_object_object_add(tmpJ, "step" , json_object_new_int(halCtls[idx].alsa.step)); if (halCtls[idx].alsa.type) json_object_object_add(tmpJ, "type" , json_object_new_int(halCtls[idx].alsa.type)); json_object_object_add(queryurl, "ctls",tmpJ); AFB_NOTICE("QUERY=%s", json_object_to_json_string(queryurl)); ok= afb_service_call_sync ("alsacore", "addcustomctl", queryurl, &responseJ); if (!ok) { AFB_ERROR ("Fail to add Customer Sound Control for ctrl=[%s] Response=[%s]", halCtls[idx].alsa.name, json_object_to_json_string(responseJ)); goto OnErrorExit; } } } // finally register for alsa lowlevel event err= afb_service_call_sync ("alsacore", "subscribe", queryurl, &responseJ); if (err) { AFB_ERROR ("Fail subscribing to ALSA lowlevel events"); goto OnErrorExit; } return (0); OnErrorExit: return (1); }; // Every HAL export the same API & Interface Mapping from SndCard to AudioLogic is done through alsaHalSndCardT PUBLIC afb_verb_v2 halServiceApi[] = { /* VERB'S NAME FUNCTION TO CALL SHORT DESCRIPTION */ { .verb = "ping", .callback = pingtest}, { .verb = "getctls", .callback = halGetCtls}, { .verb = "setvol", .callback = halSetVol}, { .verb = "getvol", .callback = halGetVol}, { .verb = "subscribe", .callback = halSubscribe}, { .verb = NULL} /* marker for end of the array */ };