monitor_util.c File Reference

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <assert.h>
#include <string.h>
#include <stddef.h>
#include "monitor.h"
#include "debug.h"
#include "mn.h"

Include dependency graph for monitor_util.c:

Go to the source code of this file.

Defines
#define	DEBUG_FLAG   'm'
Functions
int	next (int p)
int	prev (int p)
int	drop_worst (struct timeval *tstamp, struct monitor_interface *dev)
int	get_free_slot (struct timeval *tstamp, struct monitor_interface *dev)
monitor_interface *	monitor_get_dev (char *ifname)
void	print_entries (void)
Variables
monitor_global_data	mon_conf
	GLOBAL VARIABLES.
monitor_interface	mon_devs [MAX_INTERFACES]

---

Define Documentation

#define DEBUG_FLAG   'm'

Definition at line 23 of file monitor_util.c.

---

Function Documentation

int drop_worst	(	struct timeval *	tstamp,
		struct monitor_interface *	dev
	)

Definition at line 52 of file monitor_util.c.

References monitor_address::added, monitor_address::avg, MAX_MONITOR, monitor_interface::mon, mon_conf, monitor_global_data::worst_max_time, and monitor_global_data::worst_min_time.

Referenced by get_free_slot().

{
        int worst_avg = 1000; /* theoretical max quality is below */
        int worst_index = -2, i;

        /* (POLICY) */
        /* Find old entries */
        for (i = 0; i < MAX_MONITOR; i++) {
                /* old ghost. If MAX_TIME has passed
                 * for this entry and it still doesn't
                 * have decent values, just drop it */
                if (dev->mon[i].added.tv_sec + 
                    mon_conf.worst_max_time < tstamp->tv_sec &&
                    dev->mon[i].avg == 0)
                        return i;
        }

        /* No old entries found. Find the worst entry */
        for (i = 0; i < MAX_MONITOR; i++) {
                if ((dev->mon[i].added.tv_sec + 
                     mon_conf.worst_min_time) > tstamp->tv_sec)
                        return -1; /* new entry. Don't update faster than
                                    * in MIN_TIME interval */
                if (dev->mon[i].avg < worst_avg) {
                        worst_avg = dev->mon[i].avg;
                        worst_index = i;
                }
        }

        if (worst_index >= 0 && worst_index != mon_conf.current_fa)
                return worst_index;

        /* worst one is current FA :( */
        return -1;
}

int get_free_slot	(	struct timeval *	tstamp,
		struct monitor_interface *	dev
	)

Definition at line 89 of file monitor_util.c.

References monitor_address::active, agentadv_data::addr, monitor_address::adv, DEBUG(), DEBUG_FLAG, drop_worst(), MAX_MONITOR, and monitor_interface::mon.

{
        int i, ph;

        for (i = 0; i < MAX_MONITOR; i++) {
                if (dev->mon[i].active != 1)
                        return i;
        }

        /* no non-active entries found */
        ph = drop_worst(tstamp, dev);
        if (ph < 0) {
                DEBUG(DEBUG_FLAG, "get_free_slot: Working set is full, "
                      "worst entry just changed. Not dropped.\n");
                return -1;
        }

        DEBUG(DEBUG_FLAG, "get_free_slot: Working set is full, "
              "worst entry dropped (%s).\n",
              inet_ntoa(dev->mon[ph].adv->addr));
        return ph;
}

Here is the call graph for this function:

struct monitor_interface* monitor_get_dev

(

char *

ifname

)

Definition at line 113 of file monitor_util.c.

References DEBUG(), DEBUG_FLAG, IFNAMSIZ, monitor_interface::in_use, monitor_global_data::interfaces, MAX_INTERFACES, mon_conf, and mon_devs.

{
        int i;

        DEBUG(DEBUG_FLAG, "monitor_get_dev: %s (len %d), interfaces %d\n",
              ifname, strlen(ifname), mon_conf.interfaces);
        if (ifname == NULL) {
                DEBUG(DEBUG_FLAG, "monitor_get_dev: ifname == NULL!\n");
                return NULL;
        }

        for(i = 0; i< MAX_INTERFACES; i++) {
                if (mon_devs[i].in_use && 
                    !strncmp(ifname, mon_devs[i].ifname, IFNAMSIZ)) {
                        return &mon_devs[i];
                }
        }

        DEBUG(DEBUG_FLAG, "monitor_get_dev: interface %s not found\n",
              ifname);
        return NULL;
}

Here is the call graph for this function:

int next

(

int

p

)

Definition at line 29 of file monitor_util.c.

{
        assert(p >= 0);
        if (p == 9)
                return 0;
        return p + 1;

}

int prev

(

int

p

)

Definition at line 39 of file monitor_util.c.

Referenced by main().

{
        assert(p >= 0);
        if (p == 0)
                return 9;
        return p - 1;
}

void print_entries

(

void

)

Definition at line 137 of file monitor_util.c.

References monitor_address::adv, DEBUG(), DEBUG_FLAG, monitor_interface::in_use, MAX_INTERFACES, MAX_MONITOR, monitor_interface::mon, mon_devs, and agentadv_data::priority.

{
        int i, j;

        for (j = 0; j < MAX_INTERFACES; j++) {
                if (!mon_devs[j].in_use)
                        continue;
                for (i = 0; i < MAX_MONITOR; i++) {
                        if (mon_devs[j].mon[i].active == 1) {
                                DEBUG(DEBUG_FLAG, "%-15s: prio %d\n",
                                      inet_ntoa(mon_devs[j].mon[i].adv->addr),
                                      mon_devs[j].mon[i].adv->priority);
                        }
                }
        }
}

Here is the call graph for this function:

---

Variable Documentation

struct monitor_global_data mon_conf

GLOBAL VARIABLES.

Definition at line 144 of file monitor.c.

Referenced by drop_worst(), monitor_get_dev(), MONITOR_register_module(), and MONITOR_unregister_module().

struct monitor_interface mon_devs[MAX_INTERFACES]

Definition at line 145 of file monitor.c.

Referenced by monitor_api_get_ch(), monitor_api_set_ch(), monitor_get_dev(), monitor_poll_ap_addresses(), MONITOR_register_module(), MONITOR_unregister_module(), and print_entries().

---