src/afb-common.c

   1 /*
   2  * Copyright (C) 2015, 2016, 2017 "IoT.bzh"
   3  * Author José Bollo <jose.bollo@iot.bzh>
   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 _GNU_SOURCE
  19
  20 #include <sys/types.h>
  21 #include <sys/stat.h>
  22 #include <fcntl.h>
  23 #include <unistd.h>
  24 #include <errno.h>
  25 #include <systemd/sd-event.h>
  26 #include <systemd/sd-bus.h>
  27
  28 #include "afb-common.h"
  29 #include "locale-root.h"
  30 #include "jobs.h"
  31
  32 static const char *default_locale = NULL;
  33 static struct locale_root *rootdir = NULL;
  34
  35 /*
  36 struct sd_event *afb_common_get_thread_event_loop()
  37 {
  38         sd_event *result;
  39         int rc = sd_event_default(&result);
  40         if (rc != 0) {
  41                 errno = -rc;
  42                 result = NULL;
  43         }
  44         return result;
  45 }
  46
  47 static void *sdopen(void **p, int (*f)(void **))
  48 {
  49         if (*p == NULL) {
  50                 int rc = f(p);
  51                 if (rc < 0) {
  52                         errno = -rc;
  53                         *p = NULL;
  54                 }
  55         }
  56         return *p;
  57 }
  58 */
  59
  60 static struct sd_bus *sdbusopen(struct sd_bus **p, int (*f)(struct sd_bus **))
  61 {
  62         if (*p == NULL) {
  63                 int rc = f(p);
  64                 if (rc < 0) {
  65                         errno = -rc;
  66                         *p = NULL;
  67                 } else {
  68                         rc = sd_bus_attach_event(*p, afb_common_get_event_loop(), 0);
  69                         if (rc < 0) {
  70                                 sd_bus_unref(*p);
  71                                 errno = -rc;
  72                                 *p = NULL;
  73                         }
  74                 }
  75         }
  76         return *p;
  77 }
  78
  79 struct sd_event *afb_common_get_event_loop()
  80 {
  81         return jobs_get_sd_event();
  82 }
  83
  84 struct sd_bus *afb_common_get_user_bus()
  85 {
  86         static struct sd_bus *result = NULL;
  87         return sdbusopen((void*)&result, (void*)sd_bus_open_user);
  88 }
  89
  90 struct sd_bus *afb_common_get_system_bus()
  91 {
  92         static struct sd_bus *result = NULL;
  93         return sdbusopen((void*)&result, (void*)sd_bus_open_system);
  94 }
  95
  96 void afb_common_default_locale_set(const char *locale)
  97 {
  98         default_locale = locale;
  99 }
 100
 101 const char *afb_common_default_locale_get()
 102 {
 103         return default_locale;
 104 }
 105
 106 int afb_common_rootdir_set(const char *dirname)
 107 {
 108         int dirfd, rc;
 109         struct locale_root *root;
 110         struct locale_search *search;
 111
 112         rc = -1;
 113         dirfd = openat(AT_FDCWD, dirname, O_PATH|O_DIRECTORY);
 114         if (dirfd < 0) {
 115                 /* TODO message */
 116         } else {
 117                 root = locale_root_create(dirfd);
 118                 if (root == NULL) {
 119                         /* TODO message */
 120                         close(dirfd);
 121                 } else {
 122                         rc = 0;
 123                         if (default_locale != NULL) {
 124                                 search = locale_root_search(root, default_locale, 0);
 125                                 if (search == NULL) {
 126                                         /* TODO message */
 127                                 } else {
 128                                         locale_root_set_default_search(root, search);
 129                                         locale_search_unref(search);
 130                                 }
 131                         }
 132                         locale_root_unref(rootdir);
 133                         rootdir = root;
 134                 }
 135         }
 136         return rc;
 137 }
 138
 139 int afb_common_rootdir_get_fd()
 140 {
 141         return locale_root_get_dirfd(rootdir);
 142 }
 143
 144 int afb_common_rootdir_open_locale(const char *filename, int flags, const char *locale)
 145 {
 146         return locale_root_open(rootdir, filename, flags, locale);
 147 }
 148
 149