#include <murphy/common/glib-glue.h>
-/*---------------------------------------------------------------------------------------
-| GLOBAL VARIABLE DEFINITIONS for internal |
----------------------------------------------------------------------------------------*/
-struct sigaction mm_camcorder_int_old_action;
-struct sigaction mm_camcorder_abrt_old_action;
-struct sigaction mm_camcorder_segv_old_action;
-struct sigaction mm_camcorder_term_old_action;
-struct sigaction mm_camcorder_sys_old_action;
/*---------------------------------------------------------------------------------------
| LOCAL VARIABLE DEFINITIONS for internal |
#define __MMCAMCORDER_SOUND_WAIT_TIMEOUT 3
#define __MMCAMCORDER_FOCUS_CHANGE_REASON_LEN 64
+#define DPM_ALLOWED 1
+#define DPM_DISALLOWED 0
+
/*---------------------------------------------------------------------------------------
| LOCAL FUNCTION PROTOTYPES: |
static gboolean __mmcamcorder_set_attr_to_camsensor_cb(gpointer data);
#endif /* _MMCAMCORDER_USE_SET_ATTR_CB */
-static void __mm_camcorder_signal_handler(int signo);
-static void _mmcamcorder_constructor() __attribute__((constructor));
-
/*=======================================================================================
| FUNCTION DEFINITIONS |
=======================================================================================*/
| GLOBAL FUNCTION DEFINITIONS: |
---------------------------------------------------------------------------------------*/
-
-static void __mm_camcorder_signal_handler(int signo)
-{
- pid_t my_pid = getpid();
-
- _mmcam_dbg_warn("start - signo [%d], pid [%d]", signo, my_pid);
-
- /* call old signal handler */
- switch (signo) {
- case SIGINT:
- sigaction(SIGINT, &mm_camcorder_int_old_action, NULL);
- raise(signo);
- break;
- case SIGABRT:
- sigaction(SIGABRT, &mm_camcorder_abrt_old_action, NULL);
- raise(signo);
- break;
- case SIGSEGV:
- sigaction(SIGSEGV, &mm_camcorder_segv_old_action, NULL);
- raise(signo);
- break;
- case SIGTERM:
- sigaction(SIGTERM, &mm_camcorder_term_old_action, NULL);
- raise(signo);
- break;
- case SIGSYS:
- sigaction(SIGSYS, &mm_camcorder_sys_old_action, NULL);
- raise(signo);
- break;
- default:
- break;
- }
-
- _mmcam_dbg_warn("done");
-
- return;
-}
-
-
-static void _mmcamcorder_constructor()
-{
- struct sigaction mm_camcorder_action;
- mm_camcorder_action.sa_handler = __mm_camcorder_signal_handler;
- mm_camcorder_action.sa_flags = SA_NOCLDSTOP;
-
- _mmcam_dbg_warn("start");
-
- sigemptyset(&mm_camcorder_action.sa_mask);
-
- sigaction(SIGINT, &mm_camcorder_action, &mm_camcorder_int_old_action);
- sigaction(SIGABRT, &mm_camcorder_action, &mm_camcorder_abrt_old_action);
- sigaction(SIGSEGV, &mm_camcorder_action, &mm_camcorder_segv_old_action);
- sigaction(SIGTERM, &mm_camcorder_action, &mm_camcorder_term_old_action);
- sigaction(SIGSYS, &mm_camcorder_action, &mm_camcorder_sys_old_action);
-
- _mmcam_dbg_warn("done");
-
- return;
-}
-
/* Internal command functions {*/
int _mmcamcorder_create(MMHandleType *handle, MMCamPreset *info)
{
g_mutex_init(&(hcamcorder->mtsafe).lock);
g_cond_init(&(hcamcorder->mtsafe).cond);
g_mutex_init(&(hcamcorder->mtsafe).cmd_lock);
+ g_cond_init(&(hcamcorder->mtsafe).cmd_cond);
g_mutex_init(&(hcamcorder->mtsafe).asm_lock);
g_mutex_init(&(hcamcorder->mtsafe).state_lock);
g_mutex_init(&(hcamcorder->mtsafe).gst_state_lock);
goto _ERR_DEFAULT_VALUE_INIT;
}
+ /* get DPM context for camera/microphone restriction */
+ hcamcorder->dpm_context = dpm_context_create();
+ if (hcamcorder->dpm_context) {
+ hcamcorder->dpm_policy = dpm_context_acquire_restriction_policy(hcamcorder->dpm_context);
+ if (hcamcorder->dpm_policy == NULL) {
+ _mmcam_dbg_err("dpm_context_acquire_restriction_policy failed");
+ dpm_context_destroy(hcamcorder->dpm_context);
+ hcamcorder->dpm_context = NULL;
+ }
+ }
+
+ _mmcam_dbg_warn("DPM context %p, policy %p", hcamcorder->dpm_context, hcamcorder->dpm_policy);
+
if (info->videodev_type != MM_VIDEO_DEVICE_NONE) {
_mmcamcorder_conf_get_value_int((MMHandleType)hcamcorder, hcamcorder->conf_main,
CONFIGURE_CATEGORY_MAIN_VIDEO_INPUT,
_mmcam_dbg_log( "Disable Configure Control system." );
hcamcorder->conf_ctrl = NULL;
}
+
+ /* add DPM camera policy changed callback */
+ if (hcamcorder->dpm_context) {
+ if (dpm_context_add_policy_changed_cb(hcamcorder->dpm_context,
+ "camera", _mmcamcorder_dpm_camera_policy_changed_cb,
+ (void *)hcamcorder, &hcamcorder->dpm_camera_cb_id) != DPM_ERROR_NONE) {
+ _mmcam_dbg_err("add DPM changed cb failed, keep going...");
+ hcamcorder->dpm_camera_cb_id = 0;
+ }
+
+ _mmcam_dbg_log("DPM camera changed cb id %d", hcamcorder->dpm_camera_cb_id);
+ }
} else {
_mmcamcorder_conf_get_value_int((MMHandleType)hcamcorder, hcamcorder->conf_main,
CONFIGURE_CATEGORY_MAIN_VIDEO_INPUT,
ret = _mmcamcorder_init_attr_from_configure((MMHandleType)hcamcorder, MM_CAMCONVERT_CATEGORY_AUDIO);
if (ret != MM_ERROR_NONE) {
- _mmcam_dbg_warn("init attribute from configure error : 0x%x", ret);
- ret = MM_ERROR_CAMCORDER_INTERNAL;
+ _mmcam_dbg_err("there is no audio device");
+ ret = MM_ERROR_CAMCORDER_NOT_SUPPORTED;
goto _ERR_DEFAULT_VALUE_INIT;
}
}
return MM_ERROR_NONE;
_ERR_DEFAULT_VALUE_INIT:
+ /* de-initialize resource manager */
+ _mmcamcorder_resource_manager_deinit(&hcamcorder->resource_manager);
+
/* unregister sound focus */
if (hcamcorder->sound_focus_register && hcamcorder->sound_focus_id > 0) {
if (MM_ERROR_NONE != mm_sound_unregister_focus(hcamcorder->sound_focus_id)) {
hcamcorder->sound_focus_register, hcamcorder->sound_focus_id);
}
+ /* release DPM related handle */
+ if (hcamcorder->dpm_context) {
+ _mmcam_dbg_log("release DPM context %p, camera changed cb id %d",
+ hcamcorder->dpm_context, hcamcorder->dpm_camera_cb_id);
+
+ /* remove camera policy changed callback */
+ if (hcamcorder->dpm_camera_cb_id > 0) {
+ dpm_context_remove_policy_changed_cb(hcamcorder->dpm_context, hcamcorder->dpm_camera_cb_id);
+ hcamcorder->dpm_camera_cb_id = 0;
+ } else {
+ _mmcam_dbg_warn("invalid dpm camera cb id %d", hcamcorder->dpm_camera_cb_id);
+ }
+
+ if (hcamcorder->dpm_policy) {
+ dpm_context_release_restriction_policy(hcamcorder->dpm_context, hcamcorder->dpm_policy);
+ hcamcorder->dpm_policy = NULL;
+ }
+
+ dpm_context_destroy(hcamcorder->dpm_context);
+ hcamcorder->dpm_context = NULL;
+ }
+
/* Remove attributes */
if (hcamcorder->attributes) {
_mmcamcorder_dealloc_attribute((MMHandleType)hcamcorder, hcamcorder->attributes);
g_mutex_clear(&(hcamcorder->mtsafe).lock);
g_cond_clear(&(hcamcorder->mtsafe).cond);
g_mutex_clear(&(hcamcorder->mtsafe).cmd_lock);
+ g_cond_clear(&(hcamcorder->mtsafe).cmd_cond);
g_mutex_clear(&(hcamcorder->mtsafe).asm_lock);
g_mutex_clear(&(hcamcorder->mtsafe).state_lock);
g_mutex_clear(&(hcamcorder->mtsafe).gst_state_lock);
g_mutex_clear(&hcamcorder->restart_preview_lock);
if (hcamcorder->conf_ctrl) {
- _mmcamcorder_conf_release_info(handle, &hcamcorder->conf_ctrl);
+ _mmcamcorder_conf_release_info((MMHandleType)hcamcorder, &hcamcorder->conf_ctrl);
}
if (hcamcorder->conf_main) {
- _mmcamcorder_conf_release_info(handle, &hcamcorder->conf_main);
+ _mmcamcorder_conf_release_info((MMHandleType)hcamcorder, &hcamcorder->conf_main);
}
if (hcamcorder->model_name) {
hcamcorder->software_version = NULL;
}
+ /* release DPM related handle */
+ if (hcamcorder->dpm_context) {
+ _mmcam_dbg_log("release DPM context %p, camera changed cb id %d",
+ hcamcorder->dpm_context, hcamcorder->dpm_camera_cb_id);
+
+ /* remove camera policy changed callback */
+ if (hcamcorder->dpm_camera_cb_id > 0) {
+ dpm_context_remove_policy_changed_cb(hcamcorder->dpm_context, hcamcorder->dpm_camera_cb_id);
+ hcamcorder->dpm_camera_cb_id = 0;
+ } else {
+ _mmcam_dbg_warn("invalid dpm camera cb id %d", hcamcorder->dpm_camera_cb_id);
+ }
+
+ if (hcamcorder->dpm_policy) {
+ dpm_context_release_restriction_policy(hcamcorder->dpm_context, hcamcorder->dpm_policy);
+ hcamcorder->dpm_policy = NULL;
+ }
+
+ dpm_context_destroy(hcamcorder->dpm_context);
+ hcamcorder->dpm_context = NULL;
+ }
+
/* join task thread */
_mmcam_dbg_log("task thread join");
g_thread_join(hcamcorder->task_thread);
g_mutex_clear(&(hcamcorder->mtsafe).lock);
g_cond_clear(&(hcamcorder->mtsafe).cond);
g_mutex_clear(&(hcamcorder->mtsafe).cmd_lock);
+ g_cond_clear(&(hcamcorder->mtsafe).cmd_cond);
g_mutex_clear(&(hcamcorder->mtsafe).asm_lock);
g_mutex_clear(&(hcamcorder->mtsafe).state_lock);
g_mutex_clear(&(hcamcorder->mtsafe).gst_state_lock);
_mmcam_dbg_log("Support sensor encoded capture : %d", hcamcorder->sub_context->SensorEncodedCapture);
if (hcamcorder->type == MM_CAMCORDER_MODE_VIDEO_CAPTURE) {
+ int dpm_camera_state = DPM_ALLOWED;
+
+ /* check camera policy from DPM */
+ if (hcamcorder->dpm_policy) {
+ if (dpm_restriction_get_camera_state(hcamcorder->dpm_policy, &dpm_camera_state) == DPM_ERROR_NONE) {
+ _mmcam_dbg_log("DPM camera state %d", dpm_camera_state);
+ if (dpm_camera_state == DPM_DISALLOWED) {
+ _mmcam_dbg_err("CAMERA DISALLOWED by DPM");
+ ret = MM_ERROR_COMMON_INVALID_PERMISSION;
+ goto _ERR_CAMCORDER_CMD_PRECON_AFTER_LOCK;
+ }
+ } else {
+ _mmcam_dbg_err("get DPM camera state failed, keep going...");
+ }
+ } else {
+ _mmcam_dbg_warn("NULL dpm_policy");
+ }
+
/* prepare resource manager for camera */
- if((_mmcamcorder_resource_manager_prepare(&hcamcorder->resource_manager, RESOURCE_TYPE_CAMERA))) {
+ ret = _mmcamcorder_resource_manager_prepare(&hcamcorder->resource_manager, MM_CAMCORDER_RESOURCE_TYPE_CAMERA);
+ if (ret != MM_ERROR_NONE) {
_mmcam_dbg_err("could not prepare for camera resource");
ret = MM_ERROR_CAMCORDER_INTERNAL;
goto _ERR_CAMCORDER_CMD_PRECON_AFTER_LOCK;
/* prepare resource manager for "video_overlay only if display surface is X" */
mm_camcorder_get_attributes(handle, NULL,
- MMCAM_DISPLAY_SURFACE, &display_surface_type,
- NULL);
- if(display_surface_type == MM_DISPLAY_SURFACE_OVERLAY) {
- if((_mmcamcorder_resource_manager_prepare(&hcamcorder->resource_manager, RESOURCE_TYPE_VIDEO_OVERLAY))) {
+ MMCAM_DISPLAY_SURFACE, &display_surface_type,
+ NULL);
+
+ if (display_surface_type == MM_DISPLAY_SURFACE_OVERLAY) {
+ ret = _mmcamcorder_resource_manager_prepare(&hcamcorder->resource_manager, MM_CAMCORDER_RESOURCE_TYPE_VIDEO_OVERLAY);
+ if(ret != MM_ERROR_NONE) {
_mmcam_dbg_err("could not prepare for video overlay resource");
ret = MM_ERROR_CAMCORDER_INTERNAL;
goto _ERR_CAMCORDER_CMD_PRECON_AFTER_LOCK;
}
}
+
/* acquire resources */
- if((hcamcorder->resource_manager.rset && _mmcamcorder_resource_manager_acquire(&hcamcorder->resource_manager))) {
+ if (hcamcorder->resource_manager.rset && _mmcamcorder_resource_manager_acquire(&hcamcorder->resource_manager)) {
_mmcam_dbg_err("could not acquire resources");
_mmcamcorder_resource_manager_unprepare(&hcamcorder->resource_manager);
goto _ERR_CAMCORDER_CMD_PRECON_AFTER_LOCK;
}
if (hcamcorder->type == MM_CAMCORDER_MODE_VIDEO_CAPTURE) {
+ /* release resource */
ret = _mmcamcorder_resource_manager_release(&hcamcorder->resource_manager);
if (ret == MM_ERROR_RESOURCE_INVALID_STATE) {
_mmcam_dbg_warn("it could be in the middle of resource callback or there's no acquired resource");
int state_FROM1 = MM_CAMCORDER_STATE_PREPARE;
int state_FROM2 = MM_CAMCORDER_STATE_PAUSED;
int state_TO = MM_CAMCORDER_STATE_RECORDING;
+ int dpm_mic_state = DPM_ALLOWED;
mmf_camcorder_t *hcamcorder = MMF_CAMCORDER(handle);
/* initialize error code */
hcamcorder->error_code = MM_ERROR_NONE;
+ /* check mic policy from DPM */
+ if (hcamcorder->dpm_policy) {
+ if (dpm_restriction_get_microphone_state(hcamcorder->dpm_policy, &dpm_mic_state) == DPM_ERROR_NONE) {
+ _mmcam_dbg_log("DPM mic state %d", dpm_mic_state);
+ if (dpm_mic_state == DPM_DISALLOWED) {
+ _mmcam_dbg_err("MIC DISALLOWED by DPM");
+ ret = MM_ERROR_COMMON_INVALID_PERMISSION;
+ goto _ERR_CAMCORDER_CMD_PRECON_AFTER_LOCK;
+ }
+ } else {
+ _mmcam_dbg_err("get DPM mic state failed, keep going...");
+ }
+ } else {
+ _mmcam_dbg_warn("NULL dpm_policy");
+ }
+
ret = hcamcorder->command((MMHandleType)hcamcorder, _MMCamcorder_CMD_RECORD);
if (ret != MM_ERROR_NONE) {
/* check internal error of gstreamer */
msg.id = MM_MESSAGE_CAMCORDER_STATE_CHANGED_BY_RM;
msg.param.state.code = MM_ERROR_NONE;
break;
+ case _MMCAMCORDER_STATE_CHANGE_BY_DPM:
+ msg.id = MM_MESSAGE_CAMCORDER_STATE_CHANGED_BY_SECURITY;
+ msg.param.state.code = MM_ERROR_NONE;
+ break;
case _MMCAMCORDER_STATE_CHANGE_NORMAL:
default:
msg.id = MM_MESSAGE_CAMCORDER_STATE_CHANGED;
}
case GST_MESSAGE_ERROR:
{
- GError *err;
- gchar *debug;
- gst_message_parse_error(message, &err, &debug);
+ GError *err = NULL;
+ gchar *debug = NULL;
- _mmcam_dbg_err ("GSTERR: %s", err->message);
- _mmcam_dbg_err ("Error Debug: %s", debug);
+ gst_message_parse_error(message, &err, &debug);
__mmcamcorder_handle_gst_error((MMHandleType)hcamcorder, message, err);
- g_error_free (err);
- g_free (debug);
+ if (err) {
+ _mmcam_dbg_err("GSTERR: %s", err->message);
+ g_error_free(err);
+ err = NULL;
+ }
+
+ if (debug) {
+ _mmcam_dbg_err("Error Debug: %s", debug);
+ g_free(debug);
+ debug = NULL;
+ }
break;
}
case GST_MESSAGE_WARNING:
if (err->domain == GST_RESOURCE_ERROR &&
GST_ELEMENT_CAST(message->src) == element) {
_MMCamcorderMsgItem msg;
+
switch (err->code) {
case GST_RESOURCE_ERROR_OPEN_READ_WRITE:
case GST_RESOURCE_ERROR_OPEN_WRITE:
_mmcam_dbg_err("audio device [open failed]");
- hcamcorder->error_code = MM_ERROR_COMMON_INVALID_PERMISSION;
+
/* post error to application */
hcamcorder->error_occurs = TRUE;
+ hcamcorder->error_code = MM_ERROR_COMMON_INVALID_PERMISSION;
+
msg.id = MM_MESSAGE_CAMCORDER_ERROR;
msg.param.code = hcamcorder->error_code;
+
+ _mmcamcorder_send_message((MMHandleType)hcamcorder, &msg);
+
_mmcam_dbg_err(" error : sc->error_occurs %d", hcamcorder->error_occurs);
+
g_error_free(err);
- _mmcamcorder_send_message((MMHandleType)hcamcorder, &msg);
gst_message_unref(message);
message = NULL;
+
return GST_BUS_DROP;
default:
break;
}
g_error_free(err);
-
}
return GST_BUS_PASS;
mmf_camcorder_t *hcamcorder = MMF_CAMCORDER(user_data);
int current_state = MM_CAMCORDER_STATE_NONE;
- mmf_return_if_fail((MMHandleType)hcamcorder);
+ mmf_return_if_fail(hcamcorder);
current_state = _mmcamcorder_get_state((MMHandleType)hcamcorder);
if (current_state <= MM_CAMCORDER_STATE_NONE ||
}
+void _mmcamcorder_dpm_camera_policy_changed_cb(const char *name, const char *value, void *user_data)
+{
+ mmf_camcorder_t *hcamcorder = MMF_CAMCORDER(user_data);
+ int current_state = MM_CAMCORDER_STATE_NONE;
+
+ mmf_return_if_fail(hcamcorder);
+ mmf_return_if_fail(value);
+
+ current_state = _mmcamcorder_get_state((MMHandleType)hcamcorder);
+ if (current_state <= MM_CAMCORDER_STATE_NONE ||
+ current_state >= MM_CAMCORDER_STATE_NUM) {
+ _mmcam_dbg_err("Abnormal state. Or null handle. (%p, %d)", hcamcorder, current_state);
+ return;
+ }
+
+ _mmcam_dbg_warn("camera policy [%s], current state [%d]", value, current_state);
+
+ if (!strcmp(value, "disallowed")) {
+ _MMCAMCORDER_LOCK_ASM(hcamcorder);
+
+ /* set value to inform a status is changed by DPM */
+ hcamcorder->state_change_by_system = _MMCAMCORDER_STATE_CHANGE_BY_DPM;
+
+ __mmcamcorder_force_stop(hcamcorder);
+
+ /* restore value */
+ hcamcorder->state_change_by_system = _MMCAMCORDER_STATE_CHANGE_NORMAL;
+
+ _MMCAMCORDER_UNLOCK_ASM(hcamcorder);
+ }
+
+ _mmcam_dbg_warn("done");
+
+ return;
+}
+
+
int _mmcamcorder_create_pipeline(MMHandleType handle, int type)
{
int ret = MM_ERROR_NONE;
{
mmf_camcorder_t *hcamcorder = MMF_CAMCORDER(handle);
_MMCamcorderMsgItem msg;
- gchar *msg_src_element;
+ gchar *msg_src_element = NULL;
_MMCamcorderSubContext *sc = NULL;
return_val_if_fail(hcamcorder, FALSE);
}
#endif /* _MMCAMCORDER_SKIP_GST_FLOW_ERROR */
- /* post error to application */
- hcamcorder->error_occurs = TRUE;
- msg.id = MM_MESSAGE_CAMCORDER_ERROR;
- _mmcamcorder_send_message(handle, &msg);
+ /* post error to application except RESTRICTED case */
+ if (msg.param.code != MM_ERROR_POLICY_RESTRICTED) {
+ hcamcorder->error_occurs = TRUE;
+ msg.id = MM_MESSAGE_CAMCORDER_ERROR;
+ _mmcamcorder_send_message(handle, &msg);
+ }
return TRUE;
}
}
}
+ /* audiosrc */
+ element = GST_ELEMENT_CAST(sc->encode_element[_MMCAMCORDER_AUDIOSRC_SRC].gst);
+ if (GST_ELEMENT_CAST(message->src) == element) {
+ if (code == GST_RESOURCE_ERROR_FAILED) {
+ int ret = MM_ERROR_NONE;
+ int current_state = MM_CAMCORDER_STATE_NONE;
+
+ _mmcam_dbg_err("DPM mic DISALLOWED - current state %d", current_state);
+
+ _MMCAMCORDER_LOCK_ASM(hcamcorder);
+
+ current_state = _mmcamcorder_get_state((MMHandleType)hcamcorder);
+ if (current_state >= MM_CAMCORDER_STATE_RECORDING) {
+ /* set value to inform a status is changed by DPM */
+ hcamcorder->state_change_by_system = _MMCAMCORDER_STATE_CHANGE_BY_DPM;
+
+ ret = _mmcamcorder_commit((MMHandleType)hcamcorder);
+ _mmcam_dbg_log("commit result : 0x%x", ret);
+
+ if (ret != MM_ERROR_NONE) {
+ _mmcam_dbg_err("commit failed, cancel it");
+ ret = _mmcamcorder_cancel((MMHandleType)hcamcorder);
+ }
+ }
+
+ /* restore value */
+ hcamcorder->state_change_by_system = _MMCAMCORDER_STATE_CHANGE_NORMAL;
+
+ _MMCAMCORDER_UNLOCK_ASM(hcamcorder);
+
+ return MM_ERROR_POLICY_RESTRICTED;
+ }
+ }
+
/* encodebin */
element = GST_ELEMENT_CAST(sc->encode_element[_MMCAMCORDER_ENCSINK_VENC].gst);
if (GST_ELEMENT_CAST(message->src) == element) {
projects / platform / core / multimedia / libmm-camcorder.git / blobdiff