summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRichard Mudgett <rmudgett@digium.com>2012-05-24 00:36:19 +0000
committerRichard Mudgett <rmudgett@digium.com>2012-05-24 00:36:19 +0000
commit8de31699d89c6ffaf36c4cccb880a02429726b29 (patch)
tree15062483262abff21e0b0f229c3fab5c16893289
parente434a456cd060b287be2be78829aa15d0c140e30 (diff)
Made use IAX frame cache only for cacheable frame types.
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@367520 65c4cc65-6c06-0410-ace0-fbb531ad65f3
-rw-r--r--channels/iax2-parser.c75
1 files changed, 42 insertions, 33 deletions
diff --git a/channels/iax2-parser.c b/channels/iax2-parser.c
index 7b12badf0..304df8b2b 100644
--- a/channels/iax2-parser.c
+++ b/channels/iax2-parser.c
@@ -1168,51 +1168,60 @@ void iax_frame_wrap(struct iax_frame *fr, struct ast_frame *f)
struct iax_frame *iax_frame_new(int direction, int datalen, unsigned int cacheable)
{
- struct iax_frame *fr = NULL;
+ struct iax_frame *fr;
#if !defined(LOW_MEMORY)
- struct iax_frames *iax_frames = NULL;
- struct iax_frame *smallest = NULL;
-
- /* Attempt to get a frame from this thread's cache */
- if ((iax_frames = ast_threadstorage_get(&frame_cache, sizeof(*iax_frames)))) {
- smallest = AST_LIST_FIRST(&iax_frames->list);
- AST_LIST_TRAVERSE_SAFE_BEGIN(&iax_frames->list, fr, list) {
- if (fr->afdatalen >= datalen) {
- size_t afdatalen = fr->afdatalen;
- AST_LIST_REMOVE_CURRENT(list);
- iax_frames->size--;
- memset(fr, 0, sizeof(*fr));
- fr->afdatalen = afdatalen;
- break;
- } else if (smallest->afdatalen > fr->afdatalen) {
- smallest = fr;
+ if (cacheable) {
+ struct iax_frames *iax_frames;
+ struct iax_frame *smallest;
+
+ /* Attempt to get a frame from this thread's cache */
+ if ((iax_frames = ast_threadstorage_get(&frame_cache, sizeof(*iax_frames)))) {
+ smallest = AST_LIST_FIRST(&iax_frames->list);
+ AST_LIST_TRAVERSE_SAFE_BEGIN(&iax_frames->list, fr, list) {
+ if (fr->afdatalen >= datalen) {
+ size_t afdatalen = fr->afdatalen;
+ AST_LIST_REMOVE_CURRENT(list);
+ iax_frames->size--;
+ memset(fr, 0, sizeof(*fr));
+ fr->afdatalen = afdatalen;
+ break;
+ } else if (smallest->afdatalen > fr->afdatalen) {
+ smallest = fr;
+ }
}
- }
- AST_LIST_TRAVERSE_SAFE_END;
- }
- if (!fr) {
- if (iax_frames && iax_frames->size >= FRAME_CACHE_MAX_SIZE && smallest) {
- /* Make useless cache into something more useful */
- AST_LIST_REMOVE(&iax_frames->list, smallest, list);
- if (!(fr = ast_realloc(smallest, sizeof(*fr) + datalen))) {
- AST_LIST_INSERT_TAIL(&iax_frames->list, smallest, list);
+ AST_LIST_TRAVERSE_SAFE_END;
+ if (!fr) {
+ if (iax_frames->size >= FRAME_CACHE_MAX_SIZE && smallest) {
+ /* Make useless cache into something more useful */
+ AST_LIST_REMOVE(&iax_frames->list, smallest, list);
+ iax_frames->size--;
+ ast_free(smallest);
+ }
+ if (!(fr = ast_calloc_cache(1, sizeof(*fr) + datalen))) {
+ return NULL;
+ }
+ fr->afdatalen = datalen;
+ }
+ } else {
+ if (!(fr = ast_calloc_cache(1, sizeof(*fr) + datalen))) {
return NULL;
}
- } else if (!(fr = ast_calloc_cache(1, sizeof(*fr) + datalen)))
+ fr->afdatalen = datalen;
+ }
+ fr->cacheable = 1;
+ } else
+#endif
+ {
+ if (!(fr = ast_calloc(1, sizeof(*fr) + datalen))) {
return NULL;
+ }
fr->afdatalen = datalen;
}
-#else
- if (!(fr = ast_calloc(1, sizeof(*fr) + datalen)))
- return NULL;
- fr->afdatalen = datalen;
-#endif
fr->direction = direction;
fr->retrans = -1;
- fr->cacheable = cacheable;
if (fr->direction == DIRECTION_INGRESS)
ast_atomic_fetchadd_int(&iframes, 1);