src/daemon/backend/murphy/mm_resource_manager_backend.c

   1 /*
   2  * Copyright (c) 2017 Samsung Electronics Co., Ltd All Rights Reserved
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  * http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 #include <signal.h>
  18
  19 #include "daemon/backend/murphy/mm_resource_manager_rset.h"
  20 #include "daemon/backend/murphy/mm_resource_manager_mloop.h"
  21 #include "daemon/mm_resource_manager_daemon_priv.h"
  22
  23
  24
  25 static mm_resource_manager_mloop_s *mrp;
  26 static mm_resource_manager_rset_s *rset[MM_RESOURCE_MANAGER_RES_TYPE_MAX];
  27
  28
  29
  30 static void __mm_resource_manager_mloop_error_cb(mm_resource_manager_mloop_s *mrp,
  31         mm_resource_manager_mloop_error_e err, void *user_data);
  32 static int __mm_resource_manager_add_resource(mm_resource_manager_res_type_e type);
  33 static void __mm_resource_manager_release_cb(mm_resource_manager_res_type_e type,
  34                 void *user_data);
  35
  36
  37
  38 int _mm_resource_manager_backend_init(void)
  39 {
  40         int ret;
  41         int i;
  42
  43         mrp = NULL;
  44         for (i = 0; i < MM_RESOURCE_MANAGER_RES_TYPE_MAX; i++)
  45                 rset[i] = NULL;
  46
  47         ret = _mm_resource_manager_mloop_create(&mrp);
  48         if (ret != MM_RESOURCE_MANAGER_ERROR_NONE)
  49                 return ret;
  50
  51         ret = _mm_resource_manager_mloop_set_error_cb(mrp,
  52                         __mm_resource_manager_mloop_error_cb, NULL);
  53         if (ret != MM_RESOURCE_MANAGER_ERROR_NONE)
  54                 return ret;
  55
  56         return MM_RESOURCE_MANAGER_ERROR_NONE;
  57 }
  58
  59 int _mm_resource_manager_backend_deinit(void)
  60 {
  61         int ret;
  62
  63         MM_RM_RETVM_IF(mrp == NULL,
  64                         MM_RESOURCE_MANAGER_ERROR_INVALID_PARAMETER, "mloop is NULL");
  65
  66         ret = _mm_resource_manager_mloop_destroy(mrp);
  67         mrp = NULL;
  68
  69         return ret;
  70 }
  71
  72 int _mm_resource_manager_backend_acquire(mm_resource_manager_res_type_e type)
  73 {
  74         gboolean is_run = FALSE;
  75         int ret = MM_RESOURCE_MANAGER_ERROR_NONE;
  76
  77         MM_RM_RETVM_IF(rset[type] != NULL,
  78                         MM_RESOURCE_MANAGER_ERROR_INVALID_OPERATION,
  79                         "%s is already acquired", _mm_resource_manager_get_res_str(type));
  80
  81         ret = _mm_resource_manager_mloop_is_run(mrp, &is_run);
  82         if (MM_RESOURCE_MANAGER_ERROR_NONE != ret) {
  83                 MM_RM_ERROR("Failed to get is_run property from mloop");
  84                 return ret;
  85         }
  86
  87         if (!is_run) {
  88                 MM_RM_ERROR("mloop is not ran");
  89                 return MM_RESOURCE_MANAGER_ERROR_INVALID_STATE;
  90         }
  91
  92         ret = __mm_resource_manager_add_resource(type);
  93         if (MM_RESOURCE_MANAGER_ERROR_NONE != ret) {
  94                 MM_RM_ERROR("Failed to add resource");
  95                 return ret;
  96         }
  97
  98         ret = _mm_resource_manager_rset_acquire(rset[type]);
  99         if (MM_RESOURCE_MANAGER_ERROR_NONE != ret) {
 100                 MM_RM_ERROR("Failed to acquire rset %p", rset[type]);
 101                 _mm_resource_manager_backend_release(type);
 102                 return ret;
 103         }
 104
 105         MM_RM_INFO("%s is acquired successfully",
 106                         _mm_resource_manager_get_res_str(type));
 107
 108         return MM_RESOURCE_MANAGER_ERROR_NONE;
 109 }
 110
 111 int _mm_resource_manager_backend_release(mm_resource_manager_res_type_e type)
 112 {
 113         gboolean is_run = FALSE;
 114         int ret = MM_RESOURCE_MANAGER_ERROR_NONE;
 115
 116         MM_RM_RETVM_IF(rset[type] == NULL,
 117                         MM_RESOURCE_MANAGER_ERROR_INVALID_OPERATION,
 118                         "%s is not acquired", _mm_resource_manager_get_res_str(type));
 119
 120         ret = _mm_resource_manager_mloop_is_run(mrp, &is_run);
 121         if (MM_RESOURCE_MANAGER_ERROR_NONE != ret) {
 122                 MM_RM_ERROR("Failed to get is_run property from mloop");
 123                 return ret;
 124         }
 125         if (!is_run) {
 126                 MM_RM_ERROR("mloop is not ran");
 127                 return MM_RESOURCE_MANAGER_ERROR_INVALID_STATE;
 128         }
 129
 130         ret = _mm_resource_manager_rset_destroy(rset[type]);
 131         /* rset is destroyed even if the function returns an error */
 132         rset[type] = NULL;
 133         if (MM_RESOURCE_MANAGER_ERROR_NONE != ret) {
 134                 MM_RM_ERROR("Failed to release rset %p", rset[type]);
 135                 return ret;
 136         }
 137
 138         MM_RM_INFO("%s is released successfully",
 139                         _mm_resource_manager_get_res_str(type));
 140
 141         return MM_RESOURCE_MANAGER_ERROR_NONE;
 142 }
 143
 144 static void __mm_resource_manager_mloop_error_cb(mm_resource_manager_mloop_s *mrp,
 145         mm_resource_manager_mloop_error_e err, void *user_data)
 146 {
 147         MM_RM_ERROR("Received error %d from mloop %p", err, mrp);
 148
 149         if (MM_RESOURCE_MANAGER_MLOOP_ERROR_CONNECTION_LOST == err)
 150                 kill(getpid(), SIGHUP);
 151 }
 152
 153 static int __mm_resource_manager_add_resource(
 154                 mm_resource_manager_res_type_e type)
 155 {
 156         int ret = MM_RESOURCE_MANAGER_ERROR_NONE;
 157
 158         ret = _mm_resource_manager_rset_create(MM_RESOURCE_MANAGER_APP_CLASS_MEDIA,
 159                         mrp, &rset[type]);
 160         if (MM_RESOURCE_MANAGER_ERROR_NONE != ret) {
 161                 MM_RM_ERROR("Failed to create new resource set for resource type %d", type);
 162                 return ret;
 163         }
 164
 165         ret = _mm_resource_manager_rset_set_release_cb(rset[type],
 166                         __mm_resource_manager_release_cb, NULL);
 167         if (MM_RESOURCE_MANAGER_ERROR_NONE != ret) {
 168                 MM_RM_ERROR("Failed to set release callback to resource set %p 0x%x", rset[type], ret);
 169                 return ret;
 170         }
 171
 172         ret = _mm_resource_manager_rset_add_resource(rset[type], type);
 173         if (MM_RESOURCE_MANAGER_ERROR_NONE != ret) {
 174                 MM_RM_ERROR("Failed to add resource to resource set 0x%x", ret);
 175                 return ret;
 176         }
 177
 178         return MM_RESOURCE_MANAGER_ERROR_NONE;
 179 }
 180
 181 static void __mm_resource_manager_release_cb(mm_resource_manager_res_type_e type,
 182                 void *user_data)
 183 {
 184         kill(getpid(), SIGHUP);
 185 }