switch_core_rwlock.c File Reference

#include <switch.h>
#include "private/switch_core_pvt.h"

Include dependency graph for switch_core_rwlock.c:

Go to the source code of this file.

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 (switch_core_session_t *session)
switch_status_t	switch_core_session_read_lock_hangup (switch_core_session_t *session)
void	switch_core_session_write_lock (switch_core_session_t *session)
void	switch_core_session_rwunlock (switch_core_session_t *session)

Function Documentation

switch_status_t switch_core_session_read_lock

(

switch_core_session_t *

session

)

Definition at line 82 of file switch_core_rwlock.c.

References CF_THREAD_SLEEPING, SSF_DESTROYED, switch_channel_down_nosig, switch_channel_get_name(), SWITCH_CHANNEL_ID_LOG, switch_channel_test_flag(), switch_core_session_get_uuid(), switch_core_session_wake_session_thread(), SWITCH_LOG_ERROR, switch_log_printf(), SWITCH_STATUS_FALSE, SWITCH_STATUS_SUCCESS, switch_test_flag, switch_thread_rwlock_tryrdlock(), and switch_thread_rwlock_unlock().

{
        switch_status_t status = SWITCH_STATUS_FALSE;

        if (session->rwlock) {
                if (switch_test_flag(session, SSF_DESTROYED) || switch_channel_down_nosig(session->channel)) {
                        status = SWITCH_STATUS_FALSE;
                        if (switch_thread_rwlock_tryrdlock(session->rwlock) == SWITCH_STATUS_SUCCESS) {
                                if (switch_channel_test_flag(session->channel, CF_THREAD_SLEEPING)) {
#ifdef SWITCH_DEBUG_RWLOCKS
                                        switch_log_printf(SWITCH_CHANNEL_ID_LOG, file, func, line, switch_core_session_get_uuid(session), SWITCH_LOG_ERROR, "%s %s Ping thread\n",
                                                                          switch_core_session_get_uuid(session), switch_channel_get_name(session->channel));
#endif
                                        switch_core_session_wake_session_thread(session);
                                }
                                switch_thread_rwlock_unlock(session->rwlock);
                        }
#ifdef SWITCH_DEBUG_RWLOCKS
                        switch_log_printf(SWITCH_CHANNEL_ID_LOG, file, func, line, switch_core_session_get_uuid(session), SWITCH_LOG_ERROR, "%s %s Read lock FAIL\n",
                                                          switch_core_session_get_uuid(session), switch_channel_get_name(session->channel));
#endif
                } else {
                        status = (switch_status_t) switch_thread_rwlock_tryrdlock(session->rwlock);
#ifdef SWITCH_DEBUG_RWLOCKS
                        switch_log_printf(SWITCH_CHANNEL_ID_LOG, file, func, line, switch_core_session_get_uuid(session), SWITCH_LOG_ERROR, "%s %s Read lock ACQUIRED\n",
                                                          switch_core_session_get_uuid(session), switch_channel_get_name(session->channel));
#endif
                }
        }

        return status;
}

switch_status_t switch_core_session_read_lock_hangup

(

switch_core_session_t *

session

)

Definition at line 120 of file switch_core_rwlock.c.

References CS_DESTROY, SSF_DESTROYED, switch_channel_get_name(), switch_channel_get_state(), SWITCH_CHANNEL_ID_LOG, switch_core_session_get_uuid(), SWITCH_LOG_ERROR, switch_log_printf(), SWITCH_STATUS_FALSE, switch_test_flag, and switch_thread_rwlock_tryrdlock().

{
        switch_status_t status = SWITCH_STATUS_FALSE;

        if (session->rwlock) {
                if (switch_test_flag(session, SSF_DESTROYED) || switch_channel_get_state(session->channel) >= CS_DESTROY) {
                        status = SWITCH_STATUS_FALSE;
#ifdef SWITCH_DEBUG_RWLOCKS
                        switch_log_printf(SWITCH_CHANNEL_ID_LOG, file, func, line, switch_core_session_get_uuid(session), SWITCH_LOG_ERROR, "%s %s Read lock FAIL\n",
                                                          switch_core_session_get_uuid(session), switch_channel_get_name(session->channel));
#endif
                } else {
                        status = (switch_status_t) switch_thread_rwlock_tryrdlock(session->rwlock);
#ifdef SWITCH_DEBUG_RWLOCKS
                        switch_log_printf(SWITCH_CHANNEL_ID_LOG, file, func, line, switch_core_session_get_uuid(session), SWITCH_LOG_ERROR, "%s %s Read lock ACQUIRED\n",
                                                          switch_core_session_get_uuid(session), switch_channel_get_name(session->channel));
#endif
                }
        }

        return status;
}

void switch_core_session_rwunlock

(

switch_core_session_t *

session

)

Definition at line 163 of file switch_core_rwlock.c.

References switch_thread_rwlock_unlock().

{
#endif
        switch_thread_rwlock_unlock(session->rwlock);

}

void switch_core_session_write_lock

(

switch_core_session_t *

session

)

Definition at line 151 of file switch_core_rwlock.c.

References switch_thread_rwlock_wrlock().

{
#endif
        switch_thread_rwlock_wrlock(session->rwlock);
}