[TFRC]: Cache allocation of entries
This updates and simplifies the allocation of kmem_cache entries with regard
to the new structure.
Main changes:
1. On-demand allocation: no memory consumption when running over loss-free links.
2. Since cache allocation is local to the module, the cache constructor/destructor
have been integrated into the module initialisation/cleanup routines.
Signed-off-by: Gerrit Renker <gerrit@xxxxxxxxxxxxxx>
---
net/dccp/ccids/ccid3.c | 23 +-------
net/dccp/ccids/lib/loss_interval.c | 103 +++++++++----------------------------
net/dccp/ccids/lib/loss_interval.h | 24 --------
net/dccp/ccids/lib/tfrc_module.c | 8 ++
4 files changed, 38 insertions(+), 120 deletions(-)
--- a/net/dccp/ccids/lib/tfrc_module.c
+++ b/net/dccp/ccids/lib/tfrc_module.c
@@ -6,12 +6,17 @@
#include "tfrc.h"
/* Initialisation / Clean-up routines */
+extern int li_init(void);
+extern void li_cleanup(void);
extern int packet_history_init(void);
extern void packet_history_cleanup(void);
static int __init tfrc_module_init(void)
{
- int rc = packet_history_init();
+ int rc = li_init();
+
+ if (rc == 0)
+ rc = packet_history_init();
return rc;
}
@@ -19,6 +24,7 @@ static int __init tfrc_module_init(void)
static void __exit tfrc_module_exit(void)
{
packet_history_cleanup();
+ li_cleanup();
}
module_init(tfrc_module_init);
--- a/net/dccp/ccids/lib/loss_interval.h
+++ b/net/dccp/ccids/lib/loss_interval.h
@@ -40,9 +40,6 @@ struct tfrc_loss_interval {
u32 li_length;
};
-extern struct dccp_li_hist *dccp_li_hist_new(const char *name);
-extern void dccp_li_hist_delete(struct dccp_li_hist *hist);
-
/**
* tfrc_loss_hist - Loss record database
* @ring: Circular queue managed in LIFO manner
@@ -68,27 +65,8 @@ static inline u8 tfrc_lh_length(struct t
return min(lh->counter, (u8)LIH_SIZE);
}
-#if 0 /*XXX next patch */
-static inline struct dccp_li_hist_entry *
- dccp_li_hist_entry_new(struct dccp_li_hist *hist,
- const gfp_t prio)
-{
- return kmem_cache_alloc(hist->dccplih_slab, prio);
-}
-#endif
-
-static inline void dccp_li_hist_entry_delete(struct dccp_li_hist *hist,
- struct dccp_li_hist_entry *entry)
-{
- if (entry != NULL)
- kmem_cache_free(hist->dccplih_slab, entry);
-}
-
-extern void dccp_li_hist_purge(struct dccp_li_hist *hist,
- struct list_head *list);
+extern void tfrc_lh_cleanup(struct tfrc_loss_hist *lh);
extern u32 dccp_li_hist_calc_i_mean(struct list_head *list);
-extern int dccp_li_hist_interval_new(struct dccp_li_hist *hist,
- struct list_head *list, const u64 seq_loss, const u8 win_loss);
#endif /* _DCCP_LI_HIST_ */
--- a/net/dccp/ccids/lib/loss_interval.c
+++ b/net/dccp/ccids/lib/loss_interval.c
@@ -16,6 +16,8 @@
#include "../../dccp.h"
#include "loss_interval.h"
+static struct kmem_cache *tfrc_lh_slab;
+
/*
* Access macros: These require that at least one entry is present in lh,
* and implement array semantics (0 is first, n-1 is the last of n entries).
@@ -37,68 +39,26 @@ static inline struct tfrc_loss_interval
return lh->counter ? __curr_entry(lh) : NULL;
}
-struct dccp_li_hist *dccp_li_hist_new(const char *name)
-{
-#if 0 /* XXX also subsequent patch */
- return NULL;
- 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;
-#endif
-}
-
-EXPORT_SYMBOL_GPL(dccp_li_hist_new);
-
-void dccp_li_hist_delete(struct dccp_li_hist *hist)
+/*
+ * On-demand allocation and de-allocation of entries
+ */
+static struct tfrc_loss_interval *tfrc_lh_demand_next(struct tfrc_loss_hist *lh)
{
-#if 0 /* XXX next patch */
- const char* name = kmem_cache_name(hist->dccplih_slab);
+ if (__next_entry(lh) == NULL)
+ __next_entry(lh) = kmem_cache_alloc(tfrc_lh_slab, GFP_ATOMIC);
- kmem_cache_destroy(hist->dccplih_slab);
- kfree(name);
- kfree(hist);
-#endif
+ return __next_entry(lh);
}
-EXPORT_SYMBOL_GPL(dccp_li_hist_delete);
-
-#if 0 /* XXX subsequent patch */
-void dccp_li_hist_purge(struct dccp_li_hist *hist, struct list_head *list)
+void tfrc_lh_cleanup(struct tfrc_loss_hist *lh)
{
- struct dccp_li_hist_entry *entry, *next;
-
- list_for_each_entry_safe(entry, next, list, dccplih_node) {
- list_del_init(&entry->dccplih_node);
- kmem_cache_free(hist->dccplih_slab, entry);
- }
+ if (tfrc_lh_is_initialised(lh))
+ for (lh->counter = 0; lh->counter < LIH_SIZE; lh->counter++)
+ if (__next_entry(lh) != NULL)
+ kmem_cache_free(tfrc_lh_slab, __next_entry(lh));
}
-#endif
-EXPORT_SYMBOL_GPL(dccp_li_hist_purge);
+EXPORT_SYMBOL_GPL(tfrc_lh_cleanup);
/* Weights used to calculate loss event rate */
/*
@@ -148,28 +108,17 @@ u32 dccp_li_hist_calc_i_mean(struct list
EXPORT_SYMBOL_GPL(dccp_li_hist_calc_i_mean);
-/* XXX next patch
-int dccp_li_hist_interval_new(struct dccp_li_hist *hist,
- struct list_head *list, const u64 seq_loss, const u8 win_loss)
-{
- struct dccp_li_hist_entry *entry;
- int i;
-
- for (i = 0; i < DCCP_LI_HIST_IVAL_F_LENGTH; i++) {
- entry = dccp_li_hist_entry_new(hist, GFP_ATOMIC);
- if (entry == NULL) {
- dccp_li_hist_purge(hist, list);
- DCCP_BUG("loss interval list entry is NULL");
- return 0;
- }
- entry->dccplih_interval = ~0;
- list_add(&entry->dccplih_node, list);
- }
+int __init li_init(void)
+{
+ tfrc_lh_slab = kmem_cache_create("tfrc_loss_history",
+ sizeof(struct tfrc_loss_interval),
+ 0, SLAB_HWCACHE_ALIGN, NULL, NULL);
- entry->dccplih_seqno = seq_loss;
- entry->dccplih_win_count = win_loss;
- return 1;
+ return tfrc_lh_slab == NULL? -ENOBUFS : 0;
}
-EXPORT_SYMBOL_GPL(dccp_li_hist_interval_new);
-*/
+void __exit li_cleanup(void)
+{
+ if (tfrc_lh_slab != NULL)
+ kmem_cache_destroy(tfrc_lh_slab);
+}
--- a/net/dccp/ccids/ccid3.c
+++ b/net/dccp/ccids/ccid3.c
@@ -46,7 +46,6 @@ static int ccid3_debug;
#endif
static struct dccp_tx_hist *ccid3_tx_hist;
-static struct dccp_li_hist *ccid3_li_hist;
/*
* Transmitter Half-Connection Routines
@@ -1088,23 +1087,13 @@ static __init int ccid3_module_init(void
if (ccid3_tx_hist == NULL)
goto out;
- ccid3_li_hist = dccp_li_hist_new("ccid3");
- if (ccid3_li_hist == NULL)
- goto out_free_tx;
-
rc = ccid_register(&ccid3);
- if (rc != 0)
- goto out_free_loss_interval_history;
+ if (rc != 0) {
+ dccp_tx_hist_delete(ccid3_tx_hist);
+ ccid3_tx_hist = NULL;
+ }
out:
return rc;
-
-out_free_loss_interval_history:
- dccp_li_hist_delete(ccid3_li_hist);
- ccid3_li_hist = NULL;
-out_free_tx:
- dccp_tx_hist_delete(ccid3_tx_hist);
- ccid3_tx_hist = NULL;
- goto out;
}
module_init(ccid3_module_init);
@@ -1116,10 +1105,6 @@ static __exit void ccid3_module_exit(voi
dccp_tx_hist_delete(ccid3_tx_hist);
ccid3_tx_hist = NULL;
}
- if (ccid3_li_hist != NULL) {
- dccp_li_hist_delete(ccid3_li_hist);
- ccid3_li_hist = NULL;
- }
}
module_exit(ccid3_module_exit);
-
To unsubscribe from this list: send the line "unsubscribe dccp" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html
