Index: main/cdr.c =================================================================== --- main/cdr.c (revision 63791) +++ main/cdr.c (working copy) @@ -509,10 +509,66 @@ void ast_cdr_merge(struct ast_cdr *to, struct ast_cdr *from) { - struct ast_cdr *tcdr; + struct ast_cdr *zcdr; + struct ast_cdr *lto = NULL; + struct ast_cdr *lfrom = NULL; + int discard_from = 0; if (!to || !from) return; + + /* don't merge into locked CDR's -- it's bad business */ + if (ast_test_flag(to, AST_CDR_FLAG_LOCKED)) { + zcdr = to; /* safety valve? */ + while (to->next) { + lto = to; + to = to->next; + } + + if (ast_test_flag(to, AST_CDR_FLAG_LOCKED)) { + ast_log(LOG_WARNING, "Merging into locked CDR... no choice."); + to = zcdr; /* safety-- if all there are is locked CDR's, then.... ?? */ + lto = NULL; + } + } + + if (ast_test_flag(from, AST_CDR_FLAG_LOCKED)) { + discard_from = 1; + if (lto) { + struct ast_cdr *llfrom; + /* insert the from stuff after lto */ + lto->next = from; + lfrom = from; + while (lfrom && lfrom->next) { + if (!lfrom->next->next) + llfrom = lfrom; + lfrom = lfrom->next; + } + /* rip off the last entry and put a copy of the to at the end */ + llfrom->next = to; + from = lfrom; + } else { + /* save copy of the current *to cdr */ + struct ast_cdr tcdr; + struct ast_cdr *llfrom; + memcpy(&tcdr, to, sizeof(tcdr)); + /* copy in the locked from cdr */ + memcpy(to, from, sizeof(*to)); + lfrom = from; + while (lfrom && lfrom->next) { + if (!lfrom->next->next) + llfrom = lfrom; + lfrom = lfrom->next; + } + from->next = NULL; + /* rip off the last entry and put a copy of the to at the end */ + if (llfrom == from) + to = to->next = ast_cdr_dup(&tcdr); + else + to = llfrom->next = ast_cdr_dup(&tcdr); + from = lfrom; + } + } if (!ast_tvzero(from->start)) { if (!ast_tvzero(to->start)) { @@ -582,6 +638,10 @@ ast_copy_string(to->src, from->src, sizeof(to->src)); from->src[0] = 0; /* theft */ } + if (ast_strlen_zero(to->clid) && !ast_strlen_zero(from->clid)) { + ast_copy_string(to->clid, from->clid, sizeof(to->clid)); + from->clid[0] = 0; /* theft */ + } if (ast_strlen_zero(to->dst) && !ast_strlen_zero(from->dst)) { ast_copy_string(to->dst, from->dst, sizeof(to->dst)); from->dst[0] = 0; /* theft */ @@ -615,12 +675,14 @@ /* last, but not least, we need to merge any forked CDRs to the 'to' cdr */ while (from->next) { /* just rip 'em off the 'from' and insert them on the 'to' */ - tcdr = from->next; - from->next = tcdr->next; - tcdr->next = NULL; - /* tcdr is now ripped from the current list; */ - ast_cdr_append(to, tcdr); + zcdr = from->next; + from->next = zcdr->next; + zcdr->next = NULL; + /* zcdr is now ripped from the current list; */ + ast_cdr_append(to, zcdr); } + if (discard_from) + ast_cdr_discard(from); } void ast_cdr_start(struct ast_cdr *cdr) @@ -745,7 +807,7 @@ int ast_cdr_setcid(struct ast_cdr *cdr, struct ast_channel *c) { for (; cdr; cdr = cdr->next) { - if (ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) + if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) set_one_cid(cdr, c); } return 0; Index: res/res_features.c =================================================================== --- res/res_features.c (revision 63792) +++ res/res_features.c (working copy) @@ -1705,11 +1705,14 @@ /* absorb the channel cdr */ ast_cdr_merge(bridge_cdr, chan->cdr); - ast_cdr_discard(chan->cdr); /* no posting these guys */ + if (!ast_test_flag(chan->cdr, AST_CDR_FLAG_LOCKED)) + ast_cdr_discard(chan->cdr); /* if locked cdrs are in chan, they are taken over in the merge */ /* absorb the peer cdr */ ast_cdr_merge(bridge_cdr, peer->cdr); - ast_cdr_discard(peer->cdr); /* no posting these guys */ + if (ast_test_flag(peer->cdr, AST_CDR_FLAG_LOCKED)) + ast_cdr_discard(peer->cdr); /* if locked cdrs are in peer, they are taken over in the merge */ + peer->cdr = NULL; chan->cdr = bridge_cdr; /* make this available to the rest of the world via the chan while the call is in progress */ } else if (chan->cdr) { @@ -1717,14 +1720,16 @@ ast_cdr_init(bridge_cdr,chan); /* absorb this data */ ast_cdr_merge(bridge_cdr, chan->cdr); - ast_cdr_discard(chan->cdr); /* no posting these guys */ + if (!ast_test_flag(chan->cdr, AST_CDR_FLAG_LOCKED)) + ast_cdr_discard(chan->cdr); /* if locked cdrs are in chan, they are taken over in the merge */ chan->cdr = bridge_cdr; /* make this available to the rest of the world via the chan while the call is in progress */ } else if (peer->cdr) { /* take the cdr from the peer - literally */ ast_cdr_init(bridge_cdr,peer); /* absorb this data */ ast_cdr_merge(bridge_cdr, peer->cdr); - ast_cdr_discard(peer->cdr); /* no posting these guys */ + if (!ast_test_flag(chan->cdr, AST_CDR_FLAG_LOCKED)) + ast_cdr_discard(chan->cdr); /* if locked cdrs are in chan, they are taken over in the merge */ peer->cdr = NULL; peer->cdr = bridge_cdr; /* make this available to the rest of the world via the chan while the call is in progress */ } else {