counter.c File Reference

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

Go to the source code of this file.

Data Structures
struct	Counter

Macros
#define	lock(c)   mutex_lock(c->lock)
#define	unlock(c)   mutex_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)

Macro Definition Documentation

lock

#define lock

(

c

)

mutex_lock(c->lock)

Definition at line 89 of file counter.c.

Referenced by counter_decrease(), counter_increase(), counter_increase_with(), counter_set(), counter_value(), gw_rwlock_destroy(), gw_rwlock_init_static(), gw_rwlock_rdlock(), gw_rwlock_unlock(), and gw_rwlock_wrlock().

unlock

#define unlock

(

c

)

mutex_unlock(c->lock)

Definition at line 90 of file counter.c.

Referenced by counter_decrease(), counter_increase(), counter_increase_with(), counter_set(), and counter_value().

Function Documentation

counter_create()

Counter* counter_create

(

void

)

Definition at line 94 of file counter.c.

References counter, Counter::lock, mutex_create, and Counter::n.

Referenced by boxc_create(), client_thread(), dlr_init_spool(), eq_init(), init_batch(), init_bearerbox(), init_smppbox(), main(), port_add(), smasi_create(), smpp_create(), smsbox_start(), smsc2_start(), smsc_emu_init(), smsc_http_create(), 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;
}

counter_decrease()

unsigned long counter_decrease

(

Counter *

counter

)

Definition at line 155 of file counter.c.

References counter, lock, Counter::n, and unlock.

Referenced by dlr_spool_remove(), get_receiver(), handle_split(), httpsmsc_send_cb(), httpsmsc_sender(), 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;
}

counter_destroy()

void counter_destroy

(

Counter *

counter

)

Definition at line 110 of file counter.c.

References counter, Counter::lock, and mutex_destroy().

Referenced by boxc_cleanup(), boxc_destroy(), client_thread(), conndata_destroy(), dlr_spool_shutdown(), 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);
}

counter_increase()

unsigned long counter_increase

(

Counter *

counter

)

Definition at line 123 of file counter.c.

References counter, lock, Counter::n, and unlock.

Referenced by bb_smscconn_receive(), bb_smscconn_receive_internal(), bb_smscconn_send_failed(), bb_smscconn_sent(), boxc_create(), check(), client_thread(), count_file(), dispatch(), dispatch_datagram(), dlr_spool_add(), eq_create_event(), handle_submit_sm(), httpsmsc_sender(), init_machine_create(), msg_to_pdu(), next_wsp_session_id(), non_verified_file(), open_connection(), open_receiver(), open_transceiver(), open_transmitter(), port_get_request(), push_client_machine_create(), push_machine_create(), push_thread(), read_messages_from_bearerbox(), 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;
}

counter_increase_with()

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

Definition at line 134 of file counter.c.

References counter, lock, Counter::n, and unlock.

Referenced by smscconn_send().

{
    unsigned long ret;

    lock(counter);
    ret = counter->n;
    counter->n += value;
    unlock(counter);
    return ret;
}

counter_set()

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

Definition at line 167 of file counter.c.

References counter, lock, Counter::n, and unlock.

Referenced by dlr_spool_flush(), main(), and smscconn_send().

{
    unsigned long ret;

    lock(counter);
    ret = counter->n;
    counter->n = n;
    unlock(counter);
    return ret;
}

counter_value()

unsigned long counter_value

(

Counter *

counter

)

Definition at line 145 of file counter.c.

References counter, lock, Counter::n, and unlock.

Referenced by bb_print_status(), dlr_spool_messages(), empty_msg_lists(), httpsmsc_receiver(), httpsmsc_send_cb(), httpsmsc_sender(), 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;
}