if (module->ch[MUSE_CHANNEL_MSG].p_gthread)
g_thread_unref(module->ch[MUSE_CHANNEL_MSG].p_gthread);
+ memset(module, 0, sizeof(muse_module_t));
+
MUSE_FREE(module);
muse_core_tool_recursive_rmdir(MUSE_DATA_ROOT_PATH);
g_return_if_fail(get_path);
g_return_if_fail(g_muse_core_conf == NULL);
- g_muse_core_conf = calloc(1, sizeof(*g_muse_core_conf));
+ g_muse_core_conf = calloc(1, sizeof(muse_core_config_t));
g_return_if_fail(g_muse_core_conf);
g_muse_core_conf->free = free;
g_queue_push_tail(g_muse_core_ipc->module_queue, data);
- LOGD("g_queue_get_length : %d [%p]", g_queue_get_length(g_muse_core_ipc->module_queue), data);
+ LOGW("g_queue_get_length : %d [%p]", g_queue_get_length(g_muse_core_ipc->module_queue), data);
g_mutex_unlock(&g_muse_core_ipc->g_muse_ipc_queue_lock);
g_return_if_fail(free);
g_return_if_fail(g_muse_core_ipc == NULL);
- g_muse_core_ipc = calloc(1, sizeof(*g_muse_core_ipc));
+ g_muse_core_ipc = calloc(1, sizeof(muse_core_ipc_t));
g_return_if_fail(g_muse_core_ipc);
g_muse_core_ipc->table = g_hash_table_new(g_direct_hash, g_direct_equal);
int muse_core_ipc_set_handle(muse_module_h module, intptr_t handle)
{
g_return_val_if_fail(module, MM_ERROR_INVALID_ARGUMENT);
- g_return_val_if_fail(handle, MM_ERROR_INVALID_HANDLE);
module->handle = handle;
return MM_ERROR_NONE;
g_return_if_fail(fatal);
g_return_if_fail(g_muse_core_log == NULL);
- g_muse_core_log = calloc(1, sizeof(*g_muse_core_log));
+ g_muse_core_log = calloc(1, sizeof(muse_core_log_t));
g_return_if_fail(g_muse_core_log);
g_muse_core_log->log = log;
g_return_if_fail(g_muse_core_module == NULL);
- g_muse_core_module = calloc(1, sizeof(*g_muse_core_module));
+ g_muse_core_module = calloc(1, sizeof(muse_core_module_t));
g_return_if_fail(g_muse_core_module);
g_muse_core_module->load = load;
{
g_return_if_fail(g_muse_core_msg == NULL);
- g_muse_core_msg = calloc(1, sizeof(*g_muse_core_msg));
+ g_muse_core_msg = calloc(1, sizeof(muse_core_msg_t));
g_return_if_fail(g_muse_core_msg);
g_muse_core_msg->jobj_new = jobj_new;
g_return_if_fail(new);
g_return_if_fail(free);
- g_muse_core_security = calloc(1, sizeof(*g_muse_core_security));
+ g_muse_core_security = calloc(1, sizeof(muse_core_security_t));
g_return_if_fail(g_muse_core_security);
g_muse_core_security->new = new;
{
GError *error = NULL;
- g_muse_core_system = calloc(1, sizeof(*g_muse_core_system));
+ g_muse_core_system = calloc(1, sizeof(muse_core_system_t));
g_return_if_fail(g_muse_core_system);
g_return_if_fail(get_gdbus);
g_return_if_fail(subscribe_poweroff_state_change);
if (numWorkers < 1)
numWorkers = 1;
- memset(g_workqueue, 0, sizeof(*g_workqueue));
+ memset(g_workqueue, 0, sizeof(muse_core_workqueue_workqueue_t));
memcpy(&g_workqueue->jobs_mutex, &blank_mutex, sizeof(g_workqueue->jobs_mutex));
memcpy(&g_workqueue->jobs_cond, &blank_cond, sizeof(g_workqueue->jobs_cond));
for (i = 0; i < numWorkers; i++) {
worker = malloc(sizeof(muse_core_workqueue_worker_t));
g_return_val_if_fail(worker, MM_ERROR_INVALID_ARGUMENT);
- memset(worker, 0, sizeof(*worker));
+ memset(worker, 0, sizeof(muse_core_workqueue_worker_t));
worker->workqueue = g_workqueue;
if (pthread_create(&worker->thread, NULL, _muse_core_workqueue_worker_function, (void *)worker)) {
LOGE("Failed to start all worker threads");