|
Packit |
61cb5a |
/*
|
|
Packit |
61cb5a |
* Copyright (c) 2011, Red Hat, Inc.
|
|
Packit |
61cb5a |
*
|
|
Packit |
61cb5a |
* Permission to use, copy, modify, and/or distribute this software for any
|
|
Packit |
61cb5a |
* purpose with or without fee is hereby granted, provided that the above
|
|
Packit |
61cb5a |
* copyright notice and this permission notice appear in all copies.
|
|
Packit |
61cb5a |
*
|
|
Packit |
61cb5a |
* THE SOFTWARE IS PROVIDED "AS IS" AND RED HAT, INC. DISCLAIMS ALL WARRANTIES
|
|
Packit |
61cb5a |
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES
|
|
Packit |
61cb5a |
* OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL RED HAT, INC. BE LIABLE
|
|
Packit |
61cb5a |
* FOR ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
Packit |
61cb5a |
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION
|
|
Packit |
61cb5a |
* OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN
|
|
Packit |
61cb5a |
* CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
Packit |
61cb5a |
*/
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
/*
|
|
Packit |
61cb5a |
* Author: Jan Friesse <jfriesse@redhat.com>
|
|
Packit |
61cb5a |
*/
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
#include <sys/time.h>
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
#include <inttypes.h>
|
|
Packit |
61cb5a |
#include <string.h>
|
|
Packit |
61cb5a |
#include <time.h>
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
#include "gcra.h"
|
|
Packit |
61cb5a |
#include "util.h"
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
/*
|
|
Packit |
61cb5a |
* item is gcra_item to be initialized. Interval is interval in ms in which packet
|
|
Packit |
61cb5a |
* will arrive (max), and burst is number of packets which may arrive sooner.
|
|
Packit |
61cb5a |
*/
|
|
Packit |
61cb5a |
void
|
|
Packit |
61cb5a |
gcra_init(struct gcra_item *item, unsigned int interval, unsigned int burst)
|
|
Packit |
61cb5a |
{
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
memset(item, 0, sizeof(*item));
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
item->tau = burst * interval;
|
|
Packit |
61cb5a |
item->interval = interval;
|
|
Packit |
61cb5a |
}
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
/*
|
|
Packit |
61cb5a |
* item is gcra item and tv is time of packet arrival.
|
|
Packit |
61cb5a |
* Returns 0 if packet is non conforming and should be discarded/put to queue, ..., and 1 if packet
|
|
Packit |
61cb5a |
* is conforming.
|
|
Packit |
61cb5a |
*/
|
|
Packit |
61cb5a |
int
|
|
Packit |
61cb5a |
gcra_rl(struct gcra_item *item, struct timeval tv)
|
|
Packit |
61cb5a |
{
|
|
Packit |
61cb5a |
uint64_t tv_u64;
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
tv_u64 = util_tv_to_ms(tv);
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
if (item->tat >= item->tau && tv_u64 < item->tat - item->tau) {
|
|
Packit |
61cb5a |
return (0);
|
|
Packit |
61cb5a |
} else {
|
|
Packit |
61cb5a |
item->tat = ((tv_u64 > item->tat) ? tv_u64 : item->tat) + item->interval;
|
|
Packit |
61cb5a |
|
|
Packit |
61cb5a |
return (1);
|
|
Packit |
61cb5a |
}
|
|
Packit |
61cb5a |
}
|