Commit cc4d6a3a authored by Arnaldo Carvalho de Melo's avatar Arnaldo Carvalho de Melo Committed by David S. Miller

loss_interval: Nuke dccp_li_hist

It had just a slab cache, so, for the sake of simplicity just make
dccp_trfc_lib module init routine create the slab cache, no need for users of
the lib to create a private loss_interval object.
Signed-off-by: default avatarArnaldo Carvalho de Melo <acme@redhat.com>
parent c70b729e
...@@ -49,7 +49,6 @@ static int ccid3_debug; ...@@ -49,7 +49,6 @@ static int ccid3_debug;
static struct dccp_tx_hist *ccid3_tx_hist; static struct dccp_tx_hist *ccid3_tx_hist;
static struct dccp_rx_hist *ccid3_rx_hist; static struct dccp_rx_hist *ccid3_rx_hist;
static struct dccp_li_hist *ccid3_li_hist;
/* /*
* Transmitter Half-Connection Routines * Transmitter Half-Connection Routines
...@@ -844,7 +843,7 @@ static int ccid3_hc_rx_detect_loss(struct sock *sk, ...@@ -844,7 +843,7 @@ static int ccid3_hc_rx_detect_loss(struct sock *sk,
while (dccp_delta_seqno(hcrx->ccid3hcrx_seqno_nonloss, seqno) while (dccp_delta_seqno(hcrx->ccid3hcrx_seqno_nonloss, seqno)
> TFRC_RECV_NUM_LATE_LOSS) { > TFRC_RECV_NUM_LATE_LOSS) {
loss = 1; loss = 1;
dccp_li_update_li(sk, ccid3_li_hist, dccp_li_update_li(sk,
&hcrx->ccid3hcrx_li_hist, &hcrx->ccid3hcrx_li_hist,
&hcrx->ccid3hcrx_hist, &hcrx->ccid3hcrx_hist,
&hcrx->ccid3hcrx_tstamp_last_feedback, &hcrx->ccid3hcrx_tstamp_last_feedback,
...@@ -1011,7 +1010,7 @@ static void ccid3_hc_rx_exit(struct sock *sk) ...@@ -1011,7 +1010,7 @@ static void ccid3_hc_rx_exit(struct sock *sk)
dccp_rx_hist_purge(ccid3_rx_hist, &hcrx->ccid3hcrx_hist); dccp_rx_hist_purge(ccid3_rx_hist, &hcrx->ccid3hcrx_hist);
/* Empty loss interval history */ /* Empty loss interval history */
dccp_li_hist_purge(ccid3_li_hist, &hcrx->ccid3hcrx_li_hist); dccp_li_hist_purge(&hcrx->ccid3hcrx_li_hist);
} }
static void ccid3_hc_rx_get_info(struct sock *sk, struct tcp_info *info) static void ccid3_hc_rx_get_info(struct sock *sk, struct tcp_info *info)
...@@ -1095,19 +1094,12 @@ static __init int ccid3_module_init(void) ...@@ -1095,19 +1094,12 @@ static __init int ccid3_module_init(void)
if (ccid3_tx_hist == NULL) if (ccid3_tx_hist == NULL)
goto out_free_rx; goto out_free_rx;
ccid3_li_hist = dccp_li_hist_new("ccid3");
if (ccid3_li_hist == NULL)
goto out_free_tx;
rc = ccid_register(&ccid3); rc = ccid_register(&ccid3);
if (rc != 0) if (rc != 0)
goto out_free_loss_interval_history; goto out_free_tx;
out: out:
return rc; return rc;
out_free_loss_interval_history:
dccp_li_hist_delete(ccid3_li_hist);
ccid3_li_hist = NULL;
out_free_tx: out_free_tx:
dccp_tx_hist_delete(ccid3_tx_hist); dccp_tx_hist_delete(ccid3_tx_hist);
ccid3_tx_hist = NULL; ccid3_tx_hist = NULL;
...@@ -1130,10 +1122,6 @@ static __exit void ccid3_module_exit(void) ...@@ -1130,10 +1122,6 @@ static __exit void ccid3_module_exit(void)
dccp_rx_hist_delete(ccid3_rx_hist); dccp_rx_hist_delete(ccid3_rx_hist);
ccid3_rx_hist = NULL; ccid3_rx_hist = NULL;
} }
if (ccid3_li_hist != NULL) {
dccp_li_hist_delete(ccid3_li_hist);
ccid3_li_hist = NULL;
}
} }
module_exit(ccid3_module_exit); module_exit(ccid3_module_exit);
......
...@@ -18,71 +18,26 @@ ...@@ -18,71 +18,26 @@
#include "packet_history.h" #include "packet_history.h"
#include "tfrc.h" #include "tfrc.h"
struct dccp_li_hist *dccp_li_hist_new(const char *name) struct kmem_cache *dccp_li_cachep __read_mostly;
{
struct dccp_li_hist *hist = kmalloc(sizeof(*hist), GFP_ATOMIC);
static const char dccp_li_hist_mask[] = "li_hist_%s";
char *slab_name;
if (hist == NULL)
goto out;
slab_name = kmalloc(strlen(name) + sizeof(dccp_li_hist_mask) - 1,
GFP_ATOMIC);
if (slab_name == NULL)
goto out_free_hist;
sprintf(slab_name, dccp_li_hist_mask, name);
hist->dccplih_slab = kmem_cache_create(slab_name,
sizeof(struct dccp_li_hist_entry),
0, SLAB_HWCACHE_ALIGN,
NULL, NULL);
if (hist->dccplih_slab == NULL)
goto out_free_slab_name;
out:
return hist;
out_free_slab_name:
kfree(slab_name);
out_free_hist:
kfree(hist);
hist = NULL;
goto out;
}
EXPORT_SYMBOL_GPL(dccp_li_hist_new);
void dccp_li_hist_delete(struct dccp_li_hist *hist)
{
const char* name = kmem_cache_name(hist->dccplih_slab);
kmem_cache_destroy(hist->dccplih_slab);
kfree(name);
kfree(hist);
}
EXPORT_SYMBOL_GPL(dccp_li_hist_delete);
static inline struct dccp_li_hist_entry * static inline struct dccp_li_hist_entry *dccp_li_hist_entry_new(const gfp_t prio)
dccp_li_hist_entry_new(struct dccp_li_hist *hist,
const gfp_t prio)
{ {
return kmem_cache_alloc(hist->dccplih_slab, prio); return kmem_cache_alloc(dccp_li_cachep, prio);
} }
static inline void dccp_li_hist_entry_delete(struct dccp_li_hist *hist, static inline void dccp_li_hist_entry_delete(struct dccp_li_hist_entry *entry)
struct dccp_li_hist_entry *entry)
{ {
if (entry != NULL) if (entry != NULL)
kmem_cache_free(hist->dccplih_slab, entry); kmem_cache_free(dccp_li_cachep, entry);
} }
void dccp_li_hist_purge(struct dccp_li_hist *hist, struct list_head *list) void dccp_li_hist_purge(struct list_head *list)
{ {
struct dccp_li_hist_entry *entry, *next; struct dccp_li_hist_entry *entry, *next;
list_for_each_entry_safe(entry, next, list, dccplih_node) { list_for_each_entry_safe(entry, next, list, dccplih_node) {
list_del_init(&entry->dccplih_node); list_del_init(&entry->dccplih_node);
kmem_cache_free(hist->dccplih_slab, entry); kmem_cache_free(dccp_li_cachep, entry);
} }
} }
...@@ -134,17 +89,16 @@ u32 dccp_li_hist_calc_i_mean(struct list_head *list) ...@@ -134,17 +89,16 @@ u32 dccp_li_hist_calc_i_mean(struct list_head *list)
EXPORT_SYMBOL_GPL(dccp_li_hist_calc_i_mean); EXPORT_SYMBOL_GPL(dccp_li_hist_calc_i_mean);
static int dccp_li_hist_interval_new(struct dccp_li_hist *hist, static int dccp_li_hist_interval_new(struct list_head *list,
struct list_head *list,
const u64 seq_loss, const u8 win_loss) const u64 seq_loss, const u8 win_loss)
{ {
struct dccp_li_hist_entry *entry; struct dccp_li_hist_entry *entry;
int i; int i;
for (i = 0; i < DCCP_LI_HIST_IVAL_F_LENGTH; i++) { for (i = 0; i < DCCP_LI_HIST_IVAL_F_LENGTH; i++) {
entry = dccp_li_hist_entry_new(hist, GFP_ATOMIC); entry = dccp_li_hist_entry_new(GFP_ATOMIC);
if (entry == NULL) { if (entry == NULL) {
dccp_li_hist_purge(hist, list); dccp_li_hist_purge(list);
DCCP_BUG("loss interval list entry is NULL"); DCCP_BUG("loss interval list entry is NULL");
return 0; return 0;
} }
...@@ -260,7 +214,7 @@ static u32 dccp_li_calc_first_li(struct sock *sk, ...@@ -260,7 +214,7 @@ static u32 dccp_li_calc_first_li(struct sock *sk,
return 1000000 / p; return 1000000 / p;
} }
void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist, void dccp_li_update_li(struct sock *sk,
struct list_head *li_hist_list, struct list_head *li_hist_list,
struct list_head *hist_list, struct list_head *hist_list,
struct timeval *last_feedback, u16 s, u32 bytes_recv, struct timeval *last_feedback, u16 s, u32 bytes_recv,
...@@ -270,8 +224,8 @@ void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist, ...@@ -270,8 +224,8 @@ void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist,
u64 seq_temp; u64 seq_temp;
if (list_empty(li_hist_list)) { if (list_empty(li_hist_list)) {
if (!dccp_li_hist_interval_new(li_hist, li_hist_list, if (!dccp_li_hist_interval_new(li_hist_list, seq_loss,
seq_loss, win_loss)) win_loss))
return; return;
head = list_entry(li_hist_list->next, struct dccp_li_hist_entry, head = list_entry(li_hist_list->next, struct dccp_li_hist_entry,
...@@ -293,7 +247,7 @@ void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist, ...@@ -293,7 +247,7 @@ void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist,
/* new loss event detected */ /* new loss event detected */
/* calculate last interval length */ /* calculate last interval length */
seq_temp = dccp_delta_seqno(head->dccplih_seqno, seq_loss); seq_temp = dccp_delta_seqno(head->dccplih_seqno, seq_loss);
entry = dccp_li_hist_entry_new(li_hist, GFP_ATOMIC); entry = dccp_li_hist_entry_new(GFP_ATOMIC);
if (entry == NULL) { if (entry == NULL) {
DCCP_BUG("out of memory - can not allocate entry"); DCCP_BUG("out of memory - can not allocate entry");
...@@ -304,7 +258,7 @@ void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist, ...@@ -304,7 +258,7 @@ void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist,
tail = li_hist_list->prev; tail = li_hist_list->prev;
list_del(tail); list_del(tail);
kmem_cache_free(li_hist->dccplih_slab, tail); kmem_cache_free(dccp_li_cachep, tail);
/* Create the newest interval */ /* Create the newest interval */
entry->dccplih_seqno = seq_loss; entry->dccplih_seqno = seq_loss;
...@@ -314,3 +268,19 @@ void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist, ...@@ -314,3 +268,19 @@ void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist,
} }
EXPORT_SYMBOL_GPL(dccp_li_update_li); EXPORT_SYMBOL_GPL(dccp_li_update_li);
static __init int dccp_li_init(void)
{
dccp_li_cachep = kmem_cache_create("dccp_li_hist",
sizeof(struct dccp_li_hist_entry),
0, SLAB_HWCACHE_ALIGN, NULL, NULL);
return dccp_li_cachep == NULL ? -ENOBUFS : 0;
}
static __exit void dccp_li_exit(void)
{
kmem_cache_destroy(dccp_li_cachep);
}
module_init(dccp_li_init);
module_exit(dccp_li_exit);
...@@ -19,13 +19,6 @@ ...@@ -19,13 +19,6 @@
#define DCCP_LI_HIST_IVAL_F_LENGTH 8 #define DCCP_LI_HIST_IVAL_F_LENGTH 8
struct dccp_li_hist {
struct kmem_cache *dccplih_slab;
};
extern struct dccp_li_hist *dccp_li_hist_new(const char *name);
extern void dccp_li_hist_delete(struct dccp_li_hist *hist);
struct dccp_li_hist_entry { struct dccp_li_hist_entry {
struct list_head dccplih_node; struct list_head dccplih_node;
u64 dccplih_seqno:48, u64 dccplih_seqno:48,
...@@ -33,12 +26,11 @@ struct dccp_li_hist_entry { ...@@ -33,12 +26,11 @@ struct dccp_li_hist_entry {
u32 dccplih_interval; u32 dccplih_interval;
}; };
extern void dccp_li_hist_purge(struct dccp_li_hist *hist, extern void dccp_li_hist_purge(struct list_head *list);
struct list_head *list);
extern u32 dccp_li_hist_calc_i_mean(struct list_head *list); extern u32 dccp_li_hist_calc_i_mean(struct list_head *list);
extern void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist, extern void dccp_li_update_li(struct sock *sk,
struct list_head *li_hist_list, struct list_head *li_hist_list,
struct list_head *hist_list, struct list_head *hist_list,
struct timeval *last_feedback, u16 s, struct timeval *last_feedback, u16 s,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment