Read/Write Locking

Collaboration diagram for Read/Write Locking:

Functions
switch_status_t	switch_core_session_io_read_lock (switch_core_session_t *session)
switch_status_t	switch_core_session_io_write_lock (switch_core_session_t *session)
switch_status_t	switch_core_session_io_rwunlock (switch_core_session_t *session)
switch_status_t	switch_core_session_read_lock (_In_ switch_core_session_t *session)
	Acquire a read lock on the session. More...
switch_status_t	switch_core_session_read_lock_hangup (_In_ switch_core_session_t *session)
	Acquire a read lock on the session. More...
void	switch_core_session_write_lock (_In_ switch_core_session_t *session)
	Acquire a write lock on the session. More...
void	switch_core_session_rwunlock (_In_ switch_core_session_t *session)
	Unlock a read or write lock on as given session. More...

Detailed Description

Function Documentation

switch_core_session_io_read_lock()

switch_status_t switch_core_session_io_read_lock

(

switch_core_session_t *

session

)

Definition at line 39 of file switch_core_rwlock.c.

References switch_core_session::io_rwlock, SWITCH_STATUS_FALSE, SWITCH_STATUS_SUCCESS, and switch_thread_rwlock_tryrdlock().

Referenced by switch_ivr_get_file_handle().

{
        switch_status_t status = SWITCH_STATUS_FALSE;

        if (session->io_rwlock) {
                if (switch_thread_rwlock_tryrdlock(session->io_rwlock) == SWITCH_STATUS_SUCCESS) {
                        status = SWITCH_STATUS_SUCCESS;
                }
        }

        return status;
}

switch_core_session_io_rwunlock()

switch_status_t switch_core_session_io_rwunlock

(

switch_core_session_t *

session

)

Definition at line 65 of file switch_core_rwlock.c.

References switch_core_session::io_rwlock, SWITCH_DECLARE, SWITCH_STATUS_FALSE, SWITCH_STATUS_SUCCESS, and switch_thread_rwlock_unlock().

Referenced by switch_ivr_get_file_handle(), switch_ivr_play_file(), and switch_ivr_release_file_handle().

{
        switch_status_t status = SWITCH_STATUS_FALSE;

        if (session->io_rwlock) {
                switch_thread_rwlock_unlock(session->io_rwlock);
                status = SWITCH_STATUS_SUCCESS;
        }

        return status;
}

switch_core_session_io_write_lock()

switch_status_t switch_core_session_io_write_lock

(

switch_core_session_t *

session

)

Definition at line 52 of file switch_core_rwlock.c.

References switch_core_session::io_rwlock, SWITCH_STATUS_FALSE, SWITCH_STATUS_SUCCESS, and switch_thread_rwlock_wrlock().

Referenced by switch_ivr_play_file().

{
        switch_status_t status = SWITCH_STATUS_FALSE;

        if (session->io_rwlock) {
                switch_thread_rwlock_wrlock(session->io_rwlock);
                status = SWITCH_STATUS_SUCCESS;
        }

        return status;
}

switch_core_session_read_lock()

switch_status_t switch_core_session_read_lock

(

_In_ switch_core_session_t *

session

)

Acquire a read lock on the session.

Parameters

session

the session to acquire from

Returns

success if it is safe to read from the session

Referenced by audio_write_thread(), bcast_thread(), collect_thread_run(), early_thread_run(), eavesdrop_callback(), enterprise_originate_ringback_thread(), recording_thread(), speech_thread(), switch_core_service_thread(), switch_core_session_event_send(), switch_core_session_findall(), switch_core_session_findall_matching_var(), switch_core_session_hupall(), switch_core_session_hupall_endpoint(), switch_core_session_hupall_matching_vars_ans(), switch_core_session_message_send(), switch_core_session_perform_locate(), switch_core_session_receive_event(), switch_ivr_eavesdrop_pop_eavesdropper(), switch_ivr_multi_threaded_bridge(), switch_ivr_originate(), text_bridge_thread(), text_helper_thread(), video_helper_thread(), and video_write_thread().

switch_core_session_read_lock_hangup()

switch_status_t switch_core_session_read_lock_hangup

(

_In_ switch_core_session_t *

session

)

Acquire a read lock on the session.

Parameters

session

the session to acquire from

Returns

success if it is safe to read from the session

Referenced by CoreSession::CoreSession(), and switch_core_session_perform_receive_message().

switch_core_session_rwunlock()

void switch_core_session_rwunlock

(

_In_ switch_core_session_t *

session

)

Unlock a read or write lock on as given session.

Parameters

session

the session

Referenced by audio_bridge_thread(), audio_write_thread(), bcast_thread(), check_channel_status(), check_stream_changes(), cleanup_proxy_mode_a(), collect_thread_run(), CoreSession::destroy(), dtls_state_ready(), early_thread_run(), eavesdrop_callback(), enterprise_originate_ringback_thread(), enterprise_originate_thread(), fs_core_session_locate(), fs_switch_ivr_originate(), msrp_worker(), recording_thread(), rtp_common_read(), rtp_common_write(), sb_on_dtmf(), signal_bridge_on_hangup(), signal_bridge_on_hibernate(), speech_thread(), switch_channel_clear_flag_partner(), switch_channel_get_hold_music_partner(), switch_channel_get_private_partner(), switch_channel_get_variable_partner(), switch_channel_mark_hold(), switch_channel_perform_mark_answered(), switch_channel_perform_mark_pre_answered(), switch_channel_perform_mark_ring_ready_value(), switch_channel_set_flag_partner(), switch_channel_set_variable_partner_var_check(), switch_channel_test_cap_partner(), switch_channel_test_flag_partner(), switch_core_media_gen_local_sdp(), switch_core_media_negotiate_sdp(), switch_core_media_receive_message(), switch_core_media_set_rmode(), switch_core_media_set_smode(), switch_core_media_toggle_hold(), switch_core_service_thread(), switch_core_session_event_send(), switch_core_session_findall(), switch_core_session_findall_matching_var(), switch_core_session_hupall(), switch_core_session_hupall_endpoint(), switch_core_session_hupall_matching_vars_ans(), switch_core_session_message_send(), switch_core_session_outgoing_channel(), switch_core_session_pass_indication(), switch_core_session_perform_receive_message(), switch_core_session_read_frame(), switch_core_session_receive_event(), switch_core_session_thread(), switch_core_session_write_frame(), switch_core_standard_on_execute(), switch_core_standard_on_reset(), switch_ivr_3p_media(), switch_ivr_3p_nomedia(), switch_ivr_blind_transfer_ack(), switch_ivr_broadcast(), switch_ivr_eavesdrop_session(), switch_ivr_enterprise_orig_and_bridge(), switch_ivr_find_bridged_uuid(), switch_ivr_hold_toggle_uuid(), switch_ivr_hold_uuid(), switch_ivr_intercept_session(), switch_ivr_kill_uuid(), switch_ivr_media(), switch_ivr_multi_threaded_bridge(), switch_ivr_nomedia(), switch_ivr_orig_and_bridge(), switch_ivr_originate(), switch_ivr_parse_event(), switch_ivr_record_session_event(), switch_ivr_session_transfer(), switch_ivr_soft_hold(), switch_ivr_unhold(), switch_ivr_unhold_uuid(), switch_ivr_uuid_bridge(), switch_ivr_uuid_exists(), switch_ivr_uuid_force_exists(), switch_log_node_to_json(), SWITCH_STANDARD_API(), SWITCH_STANDARD_SCHED_FUNC(), text_bridge_thread(), text_helper_thread(), uuid_bridge_on_soft_execute(), video_helper_thread(), and video_write_thread().

switch_core_session_write_lock()

void switch_core_session_write_lock

(

_In_ switch_core_session_t *

session

)

Acquire a write lock on the session.

Parameters

session

the session to acquire from

Referenced by switch_core_session_thread().