meta-agl - meta-agl layer (core AGL)

Age	Commit message (Expand)	Author	Files	Lines
2018-02-13	Integrate parts of meta-intel-iot-security	José Bollo	4	-0/+29

/* * Copyright (C) 2016 "IoT.bzh" * Author Fulup Ar Foll <fulup@iot.bzh> * * 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 <stdio.h> #include <string.h> #include <unistd.h> #include <errno.h> #include <netdb.h> #include <fcntl.h> #include <math.h> #include <sys/time.h> #include <sys/types.h> #include "hal-interface.h" typedef struct { int index; int numid; } shareHallMap_T; static shareHallMap_T *shareHallMap; // Force specific HAL to depend on ShareHalLib PUBLIC char* SharedHalLibVersion="1.0"; // This callback when api/alsacore/subscribe returns STATIC void alsaSubcribeCB(void *handle, int iserror, struct json_object *result) { afb_req request = afb_req_unstore(handle); struct json_object *x, *resp = NULL; const char *info = NULL; if (result) { INFO( "result=[%s]\n", json_object_to_json_string(result)); if (json_object_object_get_ex(result, "request", &x) && json_object_object_get_ex(x, "info", &x)) info = json_object_get_string(x); if (!json_object_object_get_ex(result, "response", &resp)) resp = NULL; } // push message respond if (iserror) afb_req_fail_f(request, "Fail", info); else afb_req_success(request, resp, info); // free calling request afb_req_unref(request); } // 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) { alsaHalMapT *halCtls = alsaHalSndCard.ctls; 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 sndcard=%s ctl=[%s] should be [%d-%d]" , json_object_get_string(devid), alsaHalSndCard.name, 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 afbServiceEvent(const char *evtname, struct json_object *object) { NOTICE("afbBindingV1ServiceEvent evtname=%s [msg=%s]", evtname, json_object_to_json_string(object)); } // this is call when after all bindings are loaded STATIC int afbServiceInit() { int rc=0, err; struct json_object *queryurl, *jResponse; alsaHalMapT *halCtls = alsaHalSndCard.ctls; // Get sndcard specific HAL control mapping if (alsaHalSndCard.initCB) { rc= (alsaHalSndCard.initCB)(); if (rc != 0) goto OnErrorExit; } err= afb_daemon_require_api("alsacore", 1); // register HAL with Alsa Low Level Binder queryurl = json_object_new_object(); json_object_object_add(queryurl, "prefix", json_object_new_string(sndCardApiPrefix)); json_object_object_add(queryurl, "name", json_object_new_string(alsaHalSndCard.name)); afb_service_call_sync("alsacore", "registerHal", queryurl, &jResponse); err= afb_service_call_sync ("alsacore", "registerHal", queryurl, &jResponse); if (err) { ERROR ("Fail to register HAL to ALSA lowlevel binding"); goto OnErrorExit; } json_object_put(queryurl); // 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(); if (halCtls[idx].alsa.name) json_object_object_add(queryurl, "name" , json_object_new_string(halCtls[idx].alsa.name)); if (halCtls[idx].alsa.numid) json_object_object_add(queryurl, "numid" , json_object_new_int(halCtls[idx].alsa.numid)); if (halCtls[idx].alsa.minval) json_object_object_add(queryurl, "minval", json_object_new_int(halCtls[idx].alsa.minval)); if (halCtls[idx].alsa.maxval) json_object_object_add(queryurl, "maxval", json_object_new_int(halCtls[idx].alsa.maxval)); if (halCtls[idx].alsa.step) json_object_object_add(queryurl, "step" , json_object_new_int(halCtls[idx].alsa.step)); if (halCtls[idx].alsa.type) json_object_object_add(queryurl, "type" , json_object_new_int(halCtls[idx].alsa.type)); err= afb_service_call_sync ("alsacore", "addUserCtl", queryurl, &jResponse); if (err) { ERROR ("Fail to register Callback for ctrl=[%s]", halCtls[idx].alsa.name); goto OnErrorExit; } } } // finally register for alsa lowlevel event err= afb_service_call_sync ("alsacore", "subscribe", queryurl, &jResponse); if (err) { 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 STATIC afb_verb_v2 halSharedApi[] = { /* 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 = "monitor", .callback = halMonitor}, { .verb = NULL} /* marker for end of the array */ }; PUBLIC const struct afb_binding_v2 afbBindingV2 = { .api = sndCardApiPrefix, .specification = NULL, .verbs = halSharedApi, .preinit = NULL, .init = afbServiceInit, .onevent = afbServiceEvent, .noconcurrency = 0 };