Index: apps/app_forkcdr.c =================================================================== --- apps/app_forkcdr.c (revision 81858) +++ apps/app_forkcdr.c (working copy) @@ -64,7 +64,11 @@ if (!(newcdr = ast_cdr_dup(cdr))) return; - + + /* Original CDR will be locked and wont be updated anymore. + So we need to close it before lock */ + ast_cdr_end(cdr); + ast_cdr_append(cdr, newcdr); ast_cdr_reset(newcdr, &flags); Index: main/cdr.c =================================================================== --- main/cdr.c (revision 81858) +++ main/cdr.c (working copy) @@ -311,20 +311,22 @@ } for (; cdr; cdr = recur ? cdr->next : NULL) { - headp = &cdr->varshead; - AST_LIST_TRAVERSE_SAFE_BEGIN(headp, newvariable, entries) { - if (!strcasecmp(ast_var_name(newvariable), name)) { - /* there is already such a variable, delete it */ - AST_LIST_REMOVE_CURRENT(headp, entries); - ast_var_delete(newvariable); - break; + if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) { + headp = &cdr->varshead; + AST_LIST_TRAVERSE_SAFE_BEGIN(headp, newvariable, entries) { + if (!strcasecmp(ast_var_name(newvariable), name)) { + /* there is already such a variable, delete it */ + AST_LIST_REMOVE_CURRENT(headp, entries); + ast_var_delete(newvariable); + break; + } } - } - AST_LIST_TRAVERSE_SAFE_END; + AST_LIST_TRAVERSE_SAFE_END; - if (value) { - newvariable = ast_var_assign(name, value); - AST_LIST_INSERT_HEAD(headp, newvariable, entries); + if (value) { + newvariable = ast_var_assign(name, value); + AST_LIST_INSERT_HEAD(headp, newvariable, entries); + } } } @@ -693,11 +695,13 @@ { for (; cdr; cdr = cdr->next) { - check_post(cdr); - if (cdr->disposition < AST_CDR_ANSWERED) - cdr->disposition = AST_CDR_ANSWERED; - if (ast_tvzero(cdr->answer)) - cdr->answer = ast_tvnow(); + if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) { + check_post(cdr); + if (cdr->disposition < AST_CDR_ANSWERED) + cdr->disposition = AST_CDR_ANSWERED; + if (ast_tvzero(cdr->answer)) + cdr->answer = ast_tvnow(); + } } } @@ -842,15 +846,17 @@ void ast_cdr_end(struct ast_cdr *cdr) { for ( ; cdr ; cdr = cdr->next) { - check_post(cdr); - if (ast_tvzero(cdr->end)) - cdr->end = ast_tvnow(); - if (ast_tvzero(cdr->start)) { - ast_log(LOG_WARNING, "CDR on channel '%s' has not started\n", S_OR(cdr->channel, "")); - cdr->disposition = AST_CDR_FAILED; - } else - cdr->duration = cdr->end.tv_sec - cdr->start.tv_sec; - cdr->billsec = ast_tvzero(cdr->answer) ? 0 : cdr->end.tv_sec - cdr->answer.tv_sec; + if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) { + check_post(cdr); + if (ast_tvzero(cdr->end)) + cdr->end = ast_tvnow(); + if (ast_tvzero(cdr->start)) { + ast_log(LOG_WARNING, "CDR on channel '%s' has not started\n", S_OR(cdr->channel, "")); + cdr->disposition = AST_CDR_FAILED; + } else + cdr->duration = cdr->end.tv_sec - cdr->start.tv_sec; + cdr->billsec = ast_tvzero(cdr->answer) ? 0 : cdr->end.tv_sec - cdr->answer.tv_sec; + } } }