load.h File Reference

#include <time.h>

Go to the source code of this file.

Macros
#define	load_create()   load_create_real(1)
#define	load_increase(load)   load_increase_with(load, 1)

Typedefs
typedef struct load	Load

Functions
Load *	load_create_real (int heuristic)
int	load_add_interval (Load *load, int interval)
void	load_increase_with (Load *load, unsigned long value)
void	load_destroy (Load *load)
double	load_get (Load *load, int pos)
int	load_len (Load *load)

Macro Definition Documentation

load_create

#define load_create

(

)

load_create_real(1)

Definition at line 78 of file load.h.

Referenced by init_bearerbox(), and smscconn_create().

load_increase

#define load_increase

(

load

)

load_increase_with(load, 1)

Definition at line 94 of file load.h.

Referenced by at2_send_messages(), bb_smscconn_receive(), bb_smscconn_receive_internal(), bb_smscconn_sent(), and send_messages().

Typedef Documentation

Load

typedef struct load Load

load.h

Alexander Malysh <amalysh at kannel.org> 2008 for project Kannel Anonymos Load typedef.

Definition at line 71 of file load.h.

Function Documentation

load_add_interval()

int load_add_interval	(	Load *	load,
		int	interval
	)

Add load measure interval. - load object - measure interval in seconds

Returns

-1 if error occurs (e.g. interval already exists); 0 if all was fine

Definition at line 111 of file load.c.

References load_entry::curr, load_entry::dirty, load::entries, gw_rwlock_unlock(), gw_rwlock_wrlock(), load_entry::interval, interval, load_entry::last, load::len, load::lock, microtime(), and load_entry::prev.

Referenced by init_bearerbox(), smpp_create(), smsc_at2_create(), and smscconn_create().

{
    int i;
    struct load_entry *entry;
    
    if (load == NULL)
        return -1;
    
    gw_rwlock_wrlock(load->lock);
    
    /* first look if we have equal interval added already */
    for (i = 0; i < load->len; i++) {
        if (load->entries[i]->interval == interval) {
            gw_rwlock_unlock(load->lock);
            return -1;
        }
    }
    /* so no equal interval there, add new one */
    entry = gw_malloc(sizeof(struct load_entry));
    entry->prev = entry->curr = 0.0;
    entry->interval = interval;
    entry->dirty = 1;
    microtime(&entry->last);
    
    load->entries = gw_realloc(load->entries, sizeof(struct load*) * (load->len + 1));
    load->entries[load->len] = entry;
    load->len++;
    
    gw_rwlock_unlock(load->lock);
    
    return 0;
}

load_create_real()

Load* load_create_real

(

int

heuristic

)

Create new Load object. - 0 disable heuristic (means get always current load); 1 enable

Definition at line 97 of file load.c.

References load::entries, gw_rwlock_create(), load::heuristic, load::len, and load::lock.

Referenced by smpp_create(), and smsc_at2_create().

{
    struct load *load;
    
    load = gw_malloc(sizeof(*load));
    load->len = 0;
    load->entries = NULL;
    load->heuristic = heuristic;
    load->lock = gw_rwlock_create();
    
    return load;
}

load_destroy()

void load_destroy

(

Load *

load

)

Destroy load object. - load object

Definition at line 145 of file load.c.

References load::entries, gw_rwlock_destroy(), load::len, and load::lock.

Referenced by at2_device_thread(), empty_msg_lists(), smpp_destroy(), and smscconn_destroy().

{
    int i;

    if (load == NULL)
        return;

    for (i = 0; i < load->len; i++) {
        gw_free(load->entries[i]);
    }
    gw_free(load->entries);
    gw_rwlock_destroy(load->lock);
    gw_free(load);
}

load_get()

double load_get	(	Load *	load,
		int	pos
	)

Get measured load value at position .

Definition at line 191 of file load.c.

References load_entry::curr, load_entry::dirty, load::entries, gw_rwlock_rdlock(), gw_rwlock_unlock(), load::heuristic, load_entry::last, load::len, load_increase_with(), load::lock, microtime(), and load_entry::prev.

Referenced by at2_send_messages(), bb_print_status(), send_messages(), and smsc2_status().

{
    double ret;
    double now;
    struct load_entry *entry;

    if (load == NULL || pos >= load->len) {
        return -1.0;
    }

    /* first maybe rotate load */
    load_increase_with(load, 0);
    
    microtime(&now);
    gw_rwlock_rdlock(load->lock);
    entry = load->entries[pos];
    if (load->heuristic && !entry->dirty) {
        ret = entry->prev;
    } else {
        double diff = (now - entry->last);
        if (diff == 0) diff = 1;
        ret = entry->curr/diff;
        ret = (ret > entry->curr ? entry->curr : ret);
    }
    gw_rwlock_unlock(load->lock);

    return ret;
}

load_increase_with()

void load_increase_with	(	Load *	load,
		unsigned long	value
	)

Increase load values with . - load object - how much to increase

Definition at line 161 of file load.c.

References load_entry::curr, load_entry::dirty, load::entries, gw_rwlock_unlock(), gw_rwlock_wrlock(), load_entry::interval, load_entry::last, load::len, load::lock, microtime(), and load_entry::prev.

Referenced by load_get().

{
    double now;
    int i;
    
    if (load == NULL)
        return;

    gw_rwlock_wrlock(load->lock);
    microtime(&now);
    for (i = 0; i < load->len; i++) {
        struct load_entry *entry = load->entries[i];
        /* check for special case, load over whole live time */
        if((entry->interval != -1 && now >= entry->last + entry->interval)) { 
            /* rotate */
            entry->curr /= entry->interval;
            if (entry->prev > 0)
                entry->prev = (2*entry->curr + entry->prev)/3;
            else
                entry->prev = entry->curr;
            entry->last = now;
            entry->curr = 0.0;
            entry->dirty = 0;
        }
        entry->curr += value;
    }
    gw_rwlock_unlock(load->lock);
}

load_len()

int load_len

(

Load *

load

)

Get length of intervals.

Definition at line 221 of file load.c.

References gw_rwlock_rdlock(), gw_rwlock_unlock(), load::len, and load::lock.

{
    int ret;
    if (load == NULL)
        return 0;
    gw_rwlock_rdlock(load->lock);
    ret = load->len;
    gw_rwlock_unlock(load->lock);
    return ret;
}