void _post_state_cb_in_idle(webrtc_s *webrtc, webrtc_state_e new_state)
{
idle_userdata_s *data;
+ g_autoptr(GMutexLocker) locker = NULL;
RET_IF(webrtc == NULL, "webrtc is NULL");
webrtc->pend_state = new_state;
- g_mutex_lock(&webrtc->event_src_mutex);
+ locker = g_mutex_locker_new(&webrtc->event_src_mutex);
webrtc->idle_cb_event_source_ids[data->type] = g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, __idle_cb, data, g_free);
- g_mutex_unlock(&webrtc->event_src_mutex);
LOG_DEBUG("state will be changed [%s] -> [%s], source id[%u]",
__state_str[webrtc->state], __state_str[new_state], webrtc->idle_cb_event_source_ids[data->type]);
void _post_error_cb_in_idle(webrtc_s *webrtc, webrtc_error_e error)
{
idle_userdata_s *data;
+ g_autoptr(GMutexLocker) locker = NULL;
RET_IF(webrtc == NULL, "webrtc is NULL");
data->type = IDLE_CB_TYPE_ERROR;
data->new.error = error;
- g_mutex_lock(&webrtc->event_src_mutex);
+ locker = g_mutex_locker_new(&webrtc->event_src_mutex);
webrtc->idle_cb_event_source_ids[data->type] = g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, __idle_cb, data, g_free);
- g_mutex_unlock(&webrtc->event_src_mutex);
LOG_DEBUG("error will occur [0x%x], source id[%u]", error, webrtc->idle_cb_event_source_ids[data->type]);
}
static void __post_peer_connection_state_change_cb_in_idle(webrtc_s *webrtc, webrtc_peer_connection_state_e state)
{
idle_userdata_s *data;
+ g_autoptr(GMutexLocker) locker = NULL;
RET_IF(webrtc == NULL, "webrtc is NULL");
data->type = IDLE_CB_TYPE_PEER_CONNECTION_STATE_CHANGE;
data->new.peer_connection_state = state;
- g_mutex_lock(&webrtc->event_src_mutex);
+ locker = g_mutex_locker_new(&webrtc->event_src_mutex);
webrtc->idle_cb_event_source_ids[data->type] = g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, __idle_cb, data, g_free);
- g_mutex_unlock(&webrtc->event_src_mutex);
LOG_DEBUG("connection state will be changed to [%u], source id[%u]", state, webrtc->idle_cb_event_source_ids[data->type]);
}
static void __post_signaling_state_change_cb_in_idle(webrtc_s *webrtc, webrtc_signaling_state_e state)
{
idle_userdata_s *data;
+ g_autoptr(GMutexLocker) locker = NULL;
RET_IF(webrtc == NULL, "webrtc is NULL");
data->type = IDLE_CB_TYPE_SIGNALING_STATE_CHANGE;
data->new.signaling_state = state;
- g_mutex_lock(&webrtc->event_src_mutex);
+ locker = g_mutex_locker_new(&webrtc->event_src_mutex);
webrtc->idle_cb_event_source_ids[data->type] = g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, __idle_cb, data, g_free);
- g_mutex_unlock(&webrtc->event_src_mutex);
LOG_DEBUG("signaling state will be changed to [%u], source id[%u]", state, webrtc->idle_cb_event_source_ids[data->type]);
}
static void __post_ice_gathering_state_change_cb_in_idle(webrtc_s *webrtc, webrtc_ice_gathering_state_e state)
{
idle_userdata_s *data;
+ g_autoptr(GMutexLocker) locker = NULL;
RET_IF(webrtc == NULL, "webrtc is NULL");
data->type = IDLE_CB_TYPE_ICE_GATHERING_STATE_CHANGE;
data->new.ice_gathering_state = state;
- g_mutex_lock(&webrtc->event_src_mutex);
+ locker = g_mutex_locker_new(&webrtc->event_src_mutex);
webrtc->idle_cb_event_source_ids[data->type] = g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, __idle_cb, data, g_free);
- g_mutex_unlock(&webrtc->event_src_mutex);
LOG_DEBUG("ICE gathering state will be changed to [%u], source id[%u]", state, webrtc->idle_cb_event_source_ids[data->type]);
}
static void __post_ice_connection_state_change_cb_in_idle(webrtc_s *webrtc, webrtc_ice_connection_state_e state)
{
idle_userdata_s *data;
+ g_autoptr(GMutexLocker) locker = NULL;
RET_IF(webrtc == NULL, "webrtc is NULL");
data->type = IDLE_CB_TYPE_ICE_CONNECTION_STATE_CHANGE;
data->new.ice_connection_state = state;
- g_mutex_lock(&webrtc->event_src_mutex);
+ locker = g_mutex_locker_new(&webrtc->event_src_mutex);
webrtc->idle_cb_event_source_ids[data->type] = g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, __idle_cb, data, g_free);
- g_mutex_unlock(&webrtc->event_src_mutex);
LOG_DEBUG("ICE connection state will be changed to [%u], source id[%u]", state, webrtc->idle_cb_event_source_ids[data->type]);
}