counter.c File Reference

#include <limits.h>
#include "gwlib.h"

Include dependency graph for counter.c:

Go to the source code of this file.

Data Structures
struct	Counter
Defines
#define	lock(c)   pthread_spin_lock(&c->lock)
#define	unlock(c)   pthread_spin_unlock(&c->lock)
Functions
Counter *	counter_create (void)
void	counter_destroy (Counter *counter)
unsigned long	counter_increase (Counter *counter)
unsigned long	counter_increase_with (Counter *counter, unsigned long value)
unsigned long	counter_value (Counter *counter)
unsigned long	counter_decrease (Counter *counter)
unsigned long	counter_set (Counter *counter, unsigned long n)

---

Define Documentation

#define lock (  c   )     pthread_spin_lock(&c->lock)

Definition at line 86 of file counter.c. Referenced by counter_decrease(), counter_increase(), counter_increase_with(), counter_set(), counter_value(), dict_get(), dict_key_count(), dict_keys(), dict_put(), dict_put_true(), dict_remove(), gw_check_area_size(), gw_check_check_leaks(), gw_check_claim_area(), gw_check_free(), gw_check_is_allocated(), gw_check_malloc(), gw_check_realloc(), gw_gmtime(), gw_localtime(), gw_mktime(), gw_rand(), gw_rwlock_destroy(), gw_rwlock_init_static(), gw_rwlock_rdlock(), gw_rwlock_unlock(), gw_rwlock_wrlock(), gw_strftime(), gwlist_add_producer(), gwlist_append(), gwlist_append_unique(), gwlist_consume(), gwlist_delete(), gwlist_delete_equal(), gwlist_delete_matching(), gwlist_extract_first(), gwlist_extract_matching(), gwlist_get(), gwlist_insert(), gwlist_len(), gwlist_producer_count(), gwlist_remove_producer(), gwlist_search(), gwlist_search_all(), gwlist_sort(), gwlist_timed_consume(), gwlist_wait_until_nonempty(), gwthread_join(), gwthread_join_every(), gwthread_shutdown(), gwthread_wakeup(), gwtimer_start(), gwtimer_stop(), new_thread(), spawn_thread(), and watch_timers().

#define unlock (  c   )     pthread_spin_unlock(&c->lock)

Definition at line 87 of file counter.c. Referenced by counter_decrease(), counter_increase(), counter_increase_with(), counter_set(), counter_value(), dict_get(), dict_key_count(), dict_keys(), dict_put(), dict_put_true(), dict_remove(), gw_check_area_size(), gw_check_check_leaks(), gw_check_claim_area(), gw_check_free(), gw_check_is_allocated(), gw_check_malloc(), gw_check_realloc(), gw_gmtime(), gw_localtime(), gw_mktime(), gw_rand(), gw_strftime(), gwlist_add_producer(), gwlist_append(), gwlist_append_unique(), gwlist_consume(), gwlist_delete(), gwlist_delete_equal(), gwlist_delete_matching(), gwlist_extract_first(), gwlist_extract_matching(), gwlist_get(), gwlist_insert(), gwlist_len(), gwlist_producer_count(), gwlist_remove_producer(), gwlist_search(), gwlist_search_all(), gwlist_sort(), gwlist_timed_consume(), gwlist_wait_until_nonempty(), gwthread_join(), gwthread_join_every(), gwthread_shutdown(), gwthread_wakeup(), gwtimer_start(), gwtimer_stop(), new_thread(), spawn_thread(), and watch_timers().

---

Function Documentation

Counter* counter_create (  void   )

Definition at line 94 of file counter.c. References Counter::lock, mutex_create, and Counter::n. Referenced by client_thread(), eq_init(), init_bearerbox(), main(), port_add(), smasi_create(), smpp_create(), smsbox_start(), smsc2_start(), smsc_emu_init(), smscconn_create(), smscconn_send(), store_spool_init(), wap_appl_init(), wap_push_ppg_init(), wapbox_start(), wsp_push_client_init(), wsp_session_init(), wtp_initiator_init(), and wtp_resp_init(). { Counter *counter; counter = gw_malloc(sizeof(Counter)); #ifdef HAVE_PTHREAD_SPINLOCK_T pthread_spin_init(&counter->lock, 0); #else counter->lock = mutex_create(); #endif counter->n = 0; return counter; }

unsigned long counter_decrease (  Counter *  counter  )

Definition at line 155 of file counter.c. References lock, Counter::n, and unlock. Referenced by get_receiver(), handle_split(), port_get_request(), return_reply(), and store_spool_save(). { unsigned long ret; lock(counter); ret = counter->n; if (counter->n > 0) --counter->n; unlock(counter); return ret; }

void counter_destroy (  Counter *  counter  )

Definition at line 110 of file counter.c. References Counter::lock, and mutex_destroy(). Referenced by boxc_cleanup(), client_thread(), empty_msg_lists(), eq_shutdown(), handle_split(), main(), port_remove(), smasi_destroy(), smpp_destroy(), smsc2_cleanup(), smsc_emu_shutdown(), smscconn_destroy(), smscconn_send(), store_spool_shutdown(), wap_appl_shutdown(), wap_push_ppg_shutdown(), wsp_push_client_shutdown(), wsp_session_shutdown(), wtp_initiator_shutdown(), and wtp_resp_shutdown(). { if (counter == NULL) return; #ifdef HAVE_PTHREAD_SPINLOCK_T pthread_spin_destroy(&counter->lock); #else mutex_destroy(counter->lock); #endif gw_free(counter); }

Here is the call graph for this function:

unsigned long counter_increase (  Counter *  counter  )

Definition at line 123 of file counter.c. References lock, Counter::n, and unlock. Referenced by bb_smscconn_receive(), bb_smscconn_send_failed(), bb_smscconn_sent(), boxc_create(), check(), client_thread(), dispatch(), dispatch_datagram(), eq_create_event(), handle_submit_sm(), init_machine_create(), msg_to_pdu(), next_wsp_session_id(), open_connection(), open_receiver(), open_transceiver(), open_transmitter(), port_get_request(), push_client_machine_create(), push_machine_create(), push_thread(), remember_receiver(), resp_machine_create(), send_enquire_link(), send_logoff(), send_message(), send_smpp_thread(), send_unbind(), smpp_create(), smpp_emu_writer(), smsbox_thread(), smscconn_send(), start_fetch(), store_spool_save(), udp_receiver(), and udp_sender(). { unsigned long ret; lock(counter); ret = counter->n; ++counter->n; unlock(counter); return ret; }

unsigned long counter_increase_with (  Counter *  counter, unsigned long  value )

Definition at line 134 of file counter.c. References lock, Counter::n, and unlock. Referenced by smscconn_send(). { unsigned long ret; lock(counter); ret = counter->n; counter->n += value; unlock(counter); return ret; }

unsigned long counter_set (  Counter *  counter, unsigned long  n )

Definition at line 167 of file counter.c. References lock, Counter::n, and unlock. Referenced by smscconn_send(). { unsigned long ret; lock(counter); ret = counter->n; counter->n = n; unlock(counter); return ret; }

unsigned long counter_value (  Counter *  counter  )

Definition at line 145 of file counter.c. References lock, Counter::n, and unlock. Referenced by bb_print_status(), empty_msg_lists(), main(), outstanding_requests(), port_remove(), send_smpp_thread(), smscconn_info(), store_spool_load(), store_spool_messages(), and wap_appl_get_load(). { unsigned long ret; lock(counter); ret = counter->n; unlock(counter); return ret; }

See file LICENSE for details about the license agreement for using, modifying, copying or deriving work from this software.