thread.h File Reference

#include "gw-config.h"
#include <pthread.h>

Go to the source code of this file.

Data Structures
struct	Mutex

Macros
#define	mutex_create()   gw_claim_area(mutex_create_real())
#define	mutex_init_static(mutex)   mutex_init_static_real(mutex)
#define	mutex_lock(m)   mutex_lock_real(m, __FILE__, __LINE__, __func__)
#define	mutex_unlock(m)   mutex_unlock_real(m, __FILE__, __LINE__, __func__)
#define	mutex_trylock(m)   mutex_trylock_real(m, __FILE__, __LINE__, __func__)

Functions
Mutex *	mutex_create_measured (Mutex *mutex, char *filename, int lineno)
Mutex *	mutex_create_real (void)
Mutex *	mutex_init_static_real (Mutex *mutex)
void	mutex_destroy (Mutex *mutex)
void	mutex_lock_real (Mutex *mutex, char *file, int line, const char *func)
int	mutex_unlock_real (Mutex *mutex, char *file, int line, const char *func)
int	mutex_trylock_real (Mutex *mutex, const char *file, int line, const char *func)

Macro Definition Documentation

mutex_create

#define mutex_create

(

)

gw_claim_area(mutex_create_real())

Definition at line 96 of file thread.h.

Referenced by bearerbox_address_create(), client_init(), concat_handling_init(), conn_pool_init(), conn_wrap_fd(), counter_create(), dict_create(), gw_prioqueue_create(), gw_timerset_create(), gwlist_create_real(), init_bearerbox(), main(), port_init(), proxy_init(), radius_acct_init(), server_init(), smsc_wrapper_create(), smscconn_create(), smscenter_construct(), store_file_init(), and timers_init().

mutex_init_static

#define mutex_init_static

(

mutex

)

mutex_init_static_real(mutex)

Definition at line 115 of file thread.h.

Referenced by gw_check_init_mem(), gwlib_protected_init(), and octstr_init().

mutex_lock

#define mutex_lock

(

m

)

mutex_lock_real(m, __FILE__, __LINE__, __func__)

Definition at line 130 of file thread.h.

Referenced by at2_device_thread(), bb_isolate(), bb_resume(), bb_shutdown(), bb_suspend(), cgw_open_send_connection(), cgw_sender(), cimd2_submit_msg(), client_session(), concat_handling_check_and_handle(), concat_handling_clear_old_parts(), conn_pool_get(), emi2_listener(), emi2_sender(), fake_listener(), get_next_transaction(), gwlist_lock(), handle_pdu(), http_close_proxy(), http_use_proxy(), httpsmsc_receiver(), httpsmsc_send_cb(), httpsmsc_sender(), httpsmsc_shutdown(), io_thread(), lock(), lock_in(), lock_out(), octstr_imm(), oisd_submit_msg(), open_send_connection(), pack_server_address(), port_add(), port_get_fdset(), port_get_request(), port_put_request(), port_remove(), port_set_timeout(), print_data(), print_msg(), proxy_thread(), proxy_used_for_host(), queue_lock(), radius_acct_get_msisdn(), radius_acct_shutdown(), reconnect(), shutdown_cb(), sms_receive(), smscconn_destroy(), smscconn_info(), smscconn_send(), smscconn_shutdown(), smscconn_start(), smscconn_stop(), smscenter_lock(), soap_listener(), start_client_threads(), start_server_thread(), store_file_dump(), store_file_for_each_message(), store_file_load(), store_file_save(), wap_push_ota_bb_address_set(), and wrapper_sender().

mutex_trylock

#define mutex_trylock

(

m

)

mutex_trylock_real(m, __FILE__, __LINE__, __func__)

Definition at line 144 of file thread.h.

mutex_unlock

#define mutex_unlock

(

m

)

mutex_unlock_real(m, __FILE__, __LINE__, __func__)

Definition at line 136 of file thread.h.

Referenced by at2_device_thread(), bb_isolate(), bb_resume(), bb_shutdown(), bb_suspend(), cgw_open_send_connection(), cgw_sender(), cimd2_submit_msg(), client_session(), concat_handling_check_and_handle(), concat_handling_clear_old_parts(), conn_pool_get(), emi2_listener(), emi2_sender(), fake_listener(), get_next_transaction(), gwlist_unlock(), handle_pdu(), http_close_proxy(), http_use_proxy(), httpsmsc_receiver(), httpsmsc_send_cb(), httpsmsc_sender(), httpsmsc_shutdown(), io_thread(), octstr_imm(), oisd_submit_msg(), open_send_connection(), pack_server_address(), port_add(), port_get_fdset(), port_get_request(), port_put_request(), port_remove(), port_set_timeout(), print_data(), print_msg(), proxy_thread(), proxy_used_for_host(), queue_unlock(), radius_acct_get_msisdn(), radius_acct_shutdown(), reconnect(), shutdown_cb(), sms_receive(), smscconn_destroy(), smscconn_info(), smscconn_send(), smscconn_shutdown(), smscconn_start(), smscconn_stop(), smscenter_unlock(), soap_listener(), start_client_threads(), start_server_thread(), store_file_dump(), store_file_for_each_message(), store_file_load(), store_file_save(), unlock(), unlock_in_real(), unlock_out_real(), wap_push_ota_bb_address_set(), and wrapper_sender().

Function Documentation

mutex_create_measured()

Mutex* mutex_create_measured	(	Mutex *	mutex,
		char *	filename,
		int	lineno
	)

mutex_create_real()

Mutex* mutex_create_real

(

void

)

Definition at line 78 of file thread.c.

References Mutex::dynamic, Mutex::mutex, mutex, and Mutex::owner.

{
    Mutex *mutex;

    mutex = gw_malloc(sizeof(Mutex));
    pthread_mutex_init(&mutex->mutex, NULL);
    mutex->owner = -1;
    mutex->dynamic = 1;
    return mutex;
}

mutex_destroy()

void mutex_destroy

(

Mutex *

mutex

)

Definition at line 97 of file thread.c.

References Mutex::dynamic, info(), Mutex::mutex, mutex, and panic.

Referenced by bearerbox_address_destroy(), client_shutdown(), concat_handling_cleanup(), conn_destroy(), conn_pool_shutdown(), counter_destroy(), dict_destroy(), gw_check_shutdown(), gw_prioqueue_destroy(), gw_timerset_destroy(), gw_timerset_elapsed_destroy(), gwlib_protected_shutdown(), gwlist_destroy(), main(), octstr_shutdown(), port_shutdown(), proxy_shutdown(), radius_acct_shutdown(), server_shutdown(), smscconn_destroy(), smscenter_destruct(), smscwrapper_destroy(), store_dumper(), and timers_shutdown().

{
    int ret;

    if (mutex == NULL)
        return;

#ifdef MUTEX_STATS
    if (mutex->locks > 0 || mutex->collisions > 0) {
        info(0, "Mutex %s:%d: %ld locks, %ld collisions.",
             mutex->filename, mutex->lineno,
             mutex->locks, mutex->collisions);
    }
#endif

    if ((ret = pthread_mutex_destroy(&mutex->mutex)) != 0)
        panic(ret, "Attempt to destroy locked mutex!");

    if (mutex->dynamic == 0)
        return;
    gw_free(mutex);
}

mutex_init_static_real()

Mutex* mutex_init_static_real

(

Mutex *

mutex

)

Definition at line 89 of file thread.c.

References Mutex::dynamic, Mutex::mutex, mutex, and Mutex::owner.

{
    pthread_mutex_init(&mutex->mutex, NULL);
    mutex->owner = -1;
    mutex->dynamic = 0;
    return mutex;
}

mutex_lock_real()

void mutex_lock_real	(	Mutex *	mutex,
		char *	file,
		int	line,
		const char *	func
	)

Definition at line 121 of file thread.c.

References file, gw_assert(), gwthread_self(), Mutex::mutex, mutex, Mutex::owner, and panic.

{
    int ret;

    gw_assert(mutex != NULL);

#ifdef MUTEX_STATS
    ret = pthread_mutex_trylock(&mutex->mutex);
    if (ret != 0) {
        ret = pthread_mutex_lock(&mutex->mutex);
        mutex->collisions++;
    }
    mutex->locks++;
#else
    ret = pthread_mutex_lock(&mutex->mutex);
#endif
    if (ret != 0)
        panic(0, "%s:%ld: %s: Mutex failure! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);
    if (mutex->owner == gwthread_self())
        panic(0, "%s:%ld: %s: Managed to lock the mutex twice! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);
    mutex->owner = gwthread_self();
}

mutex_trylock_real()

int mutex_trylock_real	(	Mutex *	mutex,
		const char *	file,
		int	line,
		const char *	func
	)

Definition at line 165 of file thread.c.

References error(), file, gwthread_self(), Mutex::mutex, mutex, Mutex::owner, and panic.

{
    int ret;

    if (mutex == NULL) {
        error(0, "%s:%ld: %s: Trying to lock a NULL mutex! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);
        return -1;
    }

    ret = pthread_mutex_trylock(&mutex->mutex);
    if (ret == 0) {
        if (mutex->owner == gwthread_self())
            panic(0, "%s:%ld: %s: Managed to lock the mutex twice! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);

        mutex->owner = gwthread_self();
    }
    else if (ret == EINVAL)
        panic(0, "%s:%ld: %s: Mutex failure! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);

    return ret;
}

mutex_unlock_real()

int mutex_unlock_real	(	Mutex *	mutex,
		char *	file,
		int	line,
		const char *	func
	)

Definition at line 146 of file thread.c.

References error(), file, gw_assert(), Mutex::mutex, mutex, Mutex::owner, and panic.

{
     int ret;
    
    if (mutex == NULL) {
        error(0, "%s:%ld: %s: Trying to unlock a NULL mutex! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);
       return -1;
    }
    gw_assert(mutex != NULL);
    mutex->owner = -1;
    ret = pthread_mutex_unlock(&mutex->mutex);
    if (ret != 0)
        panic(0, "%s:%ld: %s: Mutex failure! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);

    return ret;
}