diff options
author | Arnaldo Carvalho de Melo <acme@redhat.com> | 2007-05-28 17:53:08 -0400 |
---|---|---|
committer | David S. Miller <davem@sunset.davemloft.net> | 2007-07-11 01:15:23 -0400 |
commit | cc4d6a3a34ce3976d7d01d044f3093cddc2921c2 (patch) | |
tree | ddf0a5d4aaac4661f3bb1fadd60082febc21b9ef /net | |
parent | c70b729e662a1b3ee2ef5370c1e4c9bc3ddc239f (diff) |
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: Arnaldo Carvalho de Melo <acme@redhat.com>
Diffstat (limited to 'net')
-rw-r--r-- | net/dccp/ccids/ccid3.c | 18 | ||||
-rw-r--r-- | net/dccp/ccids/lib/loss_interval.c | 92 | ||||
-rw-r--r-- | net/dccp/ccids/lib/loss_interval.h | 12 |
3 files changed, 36 insertions, 86 deletions
diff --git a/net/dccp/ccids/ccid3.c b/net/dccp/ccids/ccid3.c index 9d2e2c193cc6..407f10c742ae 100644 --- a/net/dccp/ccids/ccid3.c +++ b/net/dccp/ccids/ccid3.c | |||
@@ -49,7 +49,6 @@ static int ccid3_debug; | |||
49 | 49 | ||
50 | static struct dccp_tx_hist *ccid3_tx_hist; | 50 | static struct dccp_tx_hist *ccid3_tx_hist; |
51 | static struct dccp_rx_hist *ccid3_rx_hist; | 51 | static struct dccp_rx_hist *ccid3_rx_hist; |
52 | static struct dccp_li_hist *ccid3_li_hist; | ||
53 | 52 | ||
54 | /* | 53 | /* |
55 | * Transmitter Half-Connection Routines | 54 | * Transmitter Half-Connection Routines |
@@ -844,7 +843,7 @@ static int ccid3_hc_rx_detect_loss(struct sock *sk, | |||
844 | while (dccp_delta_seqno(hcrx->ccid3hcrx_seqno_nonloss, seqno) | 843 | while (dccp_delta_seqno(hcrx->ccid3hcrx_seqno_nonloss, seqno) |
845 | > TFRC_RECV_NUM_LATE_LOSS) { | 844 | > TFRC_RECV_NUM_LATE_LOSS) { |
846 | loss = 1; | 845 | loss = 1; |
847 | dccp_li_update_li(sk, ccid3_li_hist, | 846 | dccp_li_update_li(sk, |
848 | &hcrx->ccid3hcrx_li_hist, | 847 | &hcrx->ccid3hcrx_li_hist, |
849 | &hcrx->ccid3hcrx_hist, | 848 | &hcrx->ccid3hcrx_hist, |
850 | &hcrx->ccid3hcrx_tstamp_last_feedback, | 849 | &hcrx->ccid3hcrx_tstamp_last_feedback, |
@@ -1011,7 +1010,7 @@ static void ccid3_hc_rx_exit(struct sock *sk) | |||
1011 | dccp_rx_hist_purge(ccid3_rx_hist, &hcrx->ccid3hcrx_hist); | 1010 | dccp_rx_hist_purge(ccid3_rx_hist, &hcrx->ccid3hcrx_hist); |
1012 | 1011 | ||
1013 | /* Empty loss interval history */ | 1012 | /* Empty loss interval history */ |
1014 | dccp_li_hist_purge(ccid3_li_hist, &hcrx->ccid3hcrx_li_hist); | 1013 | dccp_li_hist_purge(&hcrx->ccid3hcrx_li_hist); |
1015 | } | 1014 | } |
1016 | 1015 | ||
1017 | static void ccid3_hc_rx_get_info(struct sock *sk, struct tcp_info *info) | 1016 | 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 | if (ccid3_tx_hist == NULL) | 1094 | if (ccid3_tx_hist == NULL) |
1096 | goto out_free_rx; | 1095 | goto out_free_rx; |
1097 | 1096 | ||
1098 | ccid3_li_hist = dccp_li_hist_new("ccid3"); | ||
1099 | if (ccid3_li_hist == NULL) | ||
1100 | goto out_free_tx; | ||
1101 | |||
1102 | rc = ccid_register(&ccid3); | 1097 | rc = ccid_register(&ccid3); |
1103 | if (rc != 0) | 1098 | if (rc != 0) |
1104 | goto out_free_loss_interval_history; | 1099 | goto out_free_tx; |
1105 | out: | 1100 | out: |
1106 | return rc; | 1101 | return rc; |
1107 | 1102 | ||
1108 | out_free_loss_interval_history: | ||
1109 | dccp_li_hist_delete(ccid3_li_hist); | ||
1110 | ccid3_li_hist = NULL; | ||
1111 | out_free_tx: | 1103 | out_free_tx: |
1112 | dccp_tx_hist_delete(ccid3_tx_hist); | 1104 | dccp_tx_hist_delete(ccid3_tx_hist); |
1113 | ccid3_tx_hist = NULL; | 1105 | ccid3_tx_hist = NULL; |
@@ -1130,10 +1122,6 @@ static __exit void ccid3_module_exit(void) | |||
1130 | dccp_rx_hist_delete(ccid3_rx_hist); | 1122 | dccp_rx_hist_delete(ccid3_rx_hist); |
1131 | ccid3_rx_hist = NULL; | 1123 | ccid3_rx_hist = NULL; |
1132 | } | 1124 | } |
1133 | if (ccid3_li_hist != NULL) { | ||
1134 | dccp_li_hist_delete(ccid3_li_hist); | ||
1135 | ccid3_li_hist = NULL; | ||
1136 | } | ||
1137 | } | 1125 | } |
1138 | module_exit(ccid3_module_exit); | 1126 | module_exit(ccid3_module_exit); |
1139 | 1127 | ||
diff --git a/net/dccp/ccids/lib/loss_interval.c b/net/dccp/ccids/lib/loss_interval.c index 28eac9be6634..e6b1f0c913ec 100644 --- a/net/dccp/ccids/lib/loss_interval.c +++ b/net/dccp/ccids/lib/loss_interval.c | |||
@@ -18,71 +18,26 @@ | |||
18 | #include "packet_history.h" | 18 | #include "packet_history.h" |
19 | #include "tfrc.h" | 19 | #include "tfrc.h" |
20 | 20 | ||
21 | struct dccp_li_hist *dccp_li_hist_new(const char *name) | 21 | struct kmem_cache *dccp_li_cachep __read_mostly; |
22 | { | ||
23 | struct dccp_li_hist *hist = kmalloc(sizeof(*hist), GFP_ATOMIC); | ||
24 | static const char dccp_li_hist_mask[] = "li_hist_%s"; | ||
25 | char *slab_name; | ||
26 | |||
27 | if (hist == NULL) | ||
28 | goto out; | ||
29 | |||
30 | slab_name = kmalloc(strlen(name) + sizeof(dccp_li_hist_mask) - 1, | ||
31 | GFP_ATOMIC); | ||
32 | if (slab_name == NULL) | ||
33 | goto out_free_hist; | ||
34 | |||
35 | sprintf(slab_name, dccp_li_hist_mask, name); | ||
36 | hist->dccplih_slab = kmem_cache_create(slab_name, | ||
37 | sizeof(struct dccp_li_hist_entry), | ||
38 | 0, SLAB_HWCACHE_ALIGN, | ||
39 | NULL, NULL); | ||
40 | if (hist->dccplih_slab == NULL) | ||
41 | goto out_free_slab_name; | ||
42 | out: | ||
43 | return hist; | ||
44 | out_free_slab_name: | ||
45 | kfree(slab_name); | ||
46 | out_free_hist: | ||
47 | kfree(hist); | ||
48 | hist = NULL; | ||
49 | goto out; | ||
50 | } | ||
51 | |||
52 | EXPORT_SYMBOL_GPL(dccp_li_hist_new); | ||
53 | |||
54 | void dccp_li_hist_delete(struct dccp_li_hist *hist) | ||
55 | { | ||
56 | const char* name = kmem_cache_name(hist->dccplih_slab); | ||
57 | |||
58 | kmem_cache_destroy(hist->dccplih_slab); | ||
59 | kfree(name); | ||
60 | kfree(hist); | ||
61 | } | ||
62 | |||
63 | EXPORT_SYMBOL_GPL(dccp_li_hist_delete); | ||
64 | 22 | ||
65 | static inline struct dccp_li_hist_entry * | 23 | static inline struct dccp_li_hist_entry *dccp_li_hist_entry_new(const gfp_t prio) |
66 | dccp_li_hist_entry_new(struct dccp_li_hist *hist, | ||
67 | const gfp_t prio) | ||
68 | { | 24 | { |
69 | return kmem_cache_alloc(hist->dccplih_slab, prio); | 25 | return kmem_cache_alloc(dccp_li_cachep, prio); |
70 | } | 26 | } |
71 | 27 | ||
72 | static inline void dccp_li_hist_entry_delete(struct dccp_li_hist *hist, | 28 | static inline void dccp_li_hist_entry_delete(struct dccp_li_hist_entry *entry) |
73 | struct dccp_li_hist_entry *entry) | ||
74 | { | 29 | { |
75 | if (entry != NULL) | 30 | if (entry != NULL) |
76 | kmem_cache_free(hist->dccplih_slab, entry); | 31 | kmem_cache_free(dccp_li_cachep, entry); |
77 | } | 32 | } |
78 | 33 | ||
79 | void dccp_li_hist_purge(struct dccp_li_hist *hist, struct list_head *list) | 34 | void dccp_li_hist_purge(struct list_head *list) |
80 | { | 35 | { |
81 | struct dccp_li_hist_entry *entry, *next; | 36 | struct dccp_li_hist_entry *entry, *next; |
82 | 37 | ||
83 | list_for_each_entry_safe(entry, next, list, dccplih_node) { | 38 | list_for_each_entry_safe(entry, next, list, dccplih_node) { |
84 | list_del_init(&entry->dccplih_node); | 39 | list_del_init(&entry->dccplih_node); |
85 | kmem_cache_free(hist->dccplih_slab, entry); | 40 | kmem_cache_free(dccp_li_cachep, entry); |
86 | } | 41 | } |
87 | } | 42 | } |
88 | 43 | ||
@@ -134,17 +89,16 @@ u32 dccp_li_hist_calc_i_mean(struct list_head *list) | |||
134 | 89 | ||
135 | EXPORT_SYMBOL_GPL(dccp_li_hist_calc_i_mean); | 90 | EXPORT_SYMBOL_GPL(dccp_li_hist_calc_i_mean); |
136 | 91 | ||
137 | static int dccp_li_hist_interval_new(struct dccp_li_hist *hist, | 92 | static int dccp_li_hist_interval_new(struct list_head *list, |
138 | struct list_head *list, | ||
139 | const u64 seq_loss, const u8 win_loss) | 93 | const u64 seq_loss, const u8 win_loss) |
140 | { | 94 | { |
141 | struct dccp_li_hist_entry *entry; | 95 | struct dccp_li_hist_entry *entry; |
142 | int i; | 96 | int i; |
143 | 97 | ||
144 | for (i = 0; i < DCCP_LI_HIST_IVAL_F_LENGTH; i++) { | 98 | for (i = 0; i < DCCP_LI_HIST_IVAL_F_LENGTH; i++) { |
145 | entry = dccp_li_hist_entry_new(hist, GFP_ATOMIC); | 99 | entry = dccp_li_hist_entry_new(GFP_ATOMIC); |
146 | if (entry == NULL) { | 100 | if (entry == NULL) { |
147 | dccp_li_hist_purge(hist, list); | 101 | dccp_li_hist_purge(list); |
148 | DCCP_BUG("loss interval list entry is NULL"); | 102 | DCCP_BUG("loss interval list entry is NULL"); |
149 | return 0; | 103 | return 0; |
150 | } | 104 | } |
@@ -260,7 +214,7 @@ found: | |||
260 | return 1000000 / p; | 214 | return 1000000 / p; |
261 | } | 215 | } |
262 | 216 | ||
263 | void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist, | 217 | void dccp_li_update_li(struct sock *sk, |
264 | struct list_head *li_hist_list, | 218 | struct list_head *li_hist_list, |
265 | struct list_head *hist_list, | 219 | struct list_head *hist_list, |
266 | struct timeval *last_feedback, u16 s, u32 bytes_recv, | 220 | 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 | u64 seq_temp; | 224 | u64 seq_temp; |
271 | 225 | ||
272 | if (list_empty(li_hist_list)) { | 226 | if (list_empty(li_hist_list)) { |
273 | if (!dccp_li_hist_interval_new(li_hist, li_hist_list, | 227 | if (!dccp_li_hist_interval_new(li_hist_list, seq_loss, |
274 | seq_loss, win_loss)) | 228 | win_loss)) |
275 | return; | 229 | return; |
276 | 230 | ||
277 | head = list_entry(li_hist_list->next, struct dccp_li_hist_entry, | 231 | 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 | /* new loss event detected */ | 247 | /* new loss event detected */ |
294 | /* calculate last interval length */ | 248 | /* calculate last interval length */ |
295 | seq_temp = dccp_delta_seqno(head->dccplih_seqno, seq_loss); | 249 | seq_temp = dccp_delta_seqno(head->dccplih_seqno, seq_loss); |
296 | entry = dccp_li_hist_entry_new(li_hist, GFP_ATOMIC); | 250 | entry = dccp_li_hist_entry_new(GFP_ATOMIC); |
297 | 251 | ||
298 | if (entry == NULL) { | 252 | if (entry == NULL) { |
299 | DCCP_BUG("out of memory - can not allocate entry"); | 253 | 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 | 258 | ||
305 | tail = li_hist_list->prev; | 259 | tail = li_hist_list->prev; |
306 | list_del(tail); | 260 | list_del(tail); |
307 | kmem_cache_free(li_hist->dccplih_slab, tail); | 261 | kmem_cache_free(dccp_li_cachep, tail); |
308 | 262 | ||
309 | /* Create the newest interval */ | 263 | /* Create the newest interval */ |
310 | entry->dccplih_seqno = seq_loss; | 264 | entry->dccplih_seqno = seq_loss; |
@@ -314,3 +268,19 @@ void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist, | |||
314 | } | 268 | } |
315 | 269 | ||
316 | EXPORT_SYMBOL_GPL(dccp_li_update_li); | 270 | EXPORT_SYMBOL_GPL(dccp_li_update_li); |
271 | |||
272 | static __init int dccp_li_init(void) | ||
273 | { | ||
274 | dccp_li_cachep = kmem_cache_create("dccp_li_hist", | ||
275 | sizeof(struct dccp_li_hist_entry), | ||
276 | 0, SLAB_HWCACHE_ALIGN, NULL, NULL); | ||
277 | return dccp_li_cachep == NULL ? -ENOBUFS : 0; | ||
278 | } | ||
279 | |||
280 | static __exit void dccp_li_exit(void) | ||
281 | { | ||
282 | kmem_cache_destroy(dccp_li_cachep); | ||
283 | } | ||
284 | |||
285 | module_init(dccp_li_init); | ||
286 | module_exit(dccp_li_exit); | ||
diff --git a/net/dccp/ccids/lib/loss_interval.h b/net/dccp/ccids/lib/loss_interval.h index 8d3c9bfa4915..f35c11100fc6 100644 --- a/net/dccp/ccids/lib/loss_interval.h +++ b/net/dccp/ccids/lib/loss_interval.h | |||
@@ -19,13 +19,6 @@ | |||
19 | 19 | ||
20 | #define DCCP_LI_HIST_IVAL_F_LENGTH 8 | 20 | #define DCCP_LI_HIST_IVAL_F_LENGTH 8 |
21 | 21 | ||
22 | struct dccp_li_hist { | ||
23 | struct kmem_cache *dccplih_slab; | ||
24 | }; | ||
25 | |||
26 | extern struct dccp_li_hist *dccp_li_hist_new(const char *name); | ||
27 | extern void dccp_li_hist_delete(struct dccp_li_hist *hist); | ||
28 | |||
29 | struct dccp_li_hist_entry { | 22 | struct dccp_li_hist_entry { |
30 | struct list_head dccplih_node; | 23 | struct list_head dccplih_node; |
31 | u64 dccplih_seqno:48, | 24 | u64 dccplih_seqno:48, |
@@ -33,12 +26,11 @@ struct dccp_li_hist_entry { | |||
33 | u32 dccplih_interval; | 26 | u32 dccplih_interval; |
34 | }; | 27 | }; |
35 | 28 | ||
36 | extern void dccp_li_hist_purge(struct dccp_li_hist *hist, | 29 | extern void dccp_li_hist_purge(struct list_head *list); |
37 | struct list_head *list); | ||
38 | 30 | ||
39 | extern u32 dccp_li_hist_calc_i_mean(struct list_head *list); | 31 | extern u32 dccp_li_hist_calc_i_mean(struct list_head *list); |
40 | 32 | ||
41 | extern void dccp_li_update_li(struct sock *sk, struct dccp_li_hist *li_hist, | 33 | extern void dccp_li_update_li(struct sock *sk, |
42 | struct list_head *li_hist_list, | 34 | struct list_head *li_hist_list, |
43 | struct list_head *hist_list, | 35 | struct list_head *hist_list, |
44 | struct timeval *last_feedback, u16 s, | 36 | struct timeval *last_feedback, u16 s, |