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_core_session_read_lock()

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, switch_core_session::channel, switch_core_session::rwlock, 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_DECLARE, 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 ((status = switch_thread_rwlock_tryrdlock(session->rwlock)) == SWITCH_STATUS_SUCCESS) {
                        if (switch_test_flag(session, SSF_DESTROYED) || switch_channel_down_nosig(session->channel)) {
                                status = SWITCH_STATUS_FALSE;
                                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);
                                }

#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
                                switch_thread_rwlock_unlock(session->rwlock);
                        } else {
#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_core_session_read_lock_hangup()

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 switch_core_session::channel, CS_DESTROY, switch_core_session::rwlock, SSF_DESTROYED, switch_channel_get_name(), switch_channel_get_state(), SWITCH_CHANNEL_ID_LOG, switch_core_session_get_uuid(), SWITCH_DECLARE, 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 ((status = switch_thread_rwlock_tryrdlock(session->rwlock)) == SWITCH_STATUS_SUCCESS) {
                        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
                                switch_thread_rwlock_unlock(session->rwlock);
                        } else {
#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_core_session_rwunlock()

void switch_core_session_rwunlock

(

switch_core_session_t *

session

)

Definition at line 165 of file switch_core_rwlock.c.

References switch_core_session::rwlock, and switch_thread_rwlock_unlock().

{
#endif
        switch_thread_rwlock_unlock(session->rwlock);

}

switch_core_session_write_lock()

void switch_core_session_write_lock

(

switch_core_session_t *

session

)

Definition at line 153 of file switch_core_rwlock.c.

References switch_core_session::channel, switch_core_session::rwlock, switch_channel_get_name(), SWITCH_CHANNEL_ID_LOG, switch_core_session_get_uuid(), SWITCH_DECLARE, SWITCH_LOG_ERROR, switch_log_printf(), and switch_thread_rwlock_wrlock().

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