src/afb-common.c

   1 /*
   2  * Copyright (C) 2015, 2016 "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 <errno.h>
  21 #include <systemd/sd-event.h>
  22 #include <systemd/sd-bus.h>
  23
  24 #include "afb-common.h"
  25
  26 /*
  27 struct sd_event *afb_common_get_thread_event_loop()
  28 {
  29         sd_event *result;
  30         int rc = sd_event_default(&result);
  31         if (rc != 0) {
  32                 errno = -rc;
  33                 result = NULL;
  34         }
  35         return result;
  36 }
  37 */
  38
  39 static void *sdopen(void **p, int (*f)(void **))
  40 {
  41         if (*p == NULL) {
  42                 int rc = f(p);
  43                 if (rc < 0) {
  44                         errno = -rc;
  45                         *p = NULL;
  46                 }
  47         }
  48         return *p;
  49 }
  50
  51 static struct sd_bus *sdbusopen(struct sd_bus **p, int (*f)(struct sd_bus **))
  52 {
  53         if (*p == NULL) {
  54                 int rc = f(p);
  55                 if (rc < 0) {
  56                         errno = -rc;
  57                         *p = NULL;
  58                 } else {
  59                         rc = sd_bus_attach_event(*p, afb_common_get_event_loop(), 0);
  60                         if (rc < 0) {
  61                                 sd_bus_unref(*p);
  62                                 errno = -rc;
  63                                 *p = NULL;
  64                         }
  65                 }
  66         }
  67         return *p;
  68 }
  69
  70 struct sd_event *afb_common_get_event_loop()
  71 {
  72         static struct sd_event *result = NULL;
  73         return sdopen((void*)&result, (void*)sd_event_new);
  74 }
  75
  76 struct sd_bus *afb_common_get_user_bus()
  77 {
  78         static struct sd_bus *result = NULL;
  79         return sdbusopen((void*)&result, (void*)sd_bus_open_user);
  80 }
  81
  82 struct sd_bus *afb_common_get_system_bus()
  83 {
  84         static struct sd_bus *result = NULL;
  85         return sdbusopen((void*)&result, (void*)sd_bus_open_system);
  86 }
  87
  88
  89