diff --git a/CHANGES b/CHANGES index 869f2d0e41..cf8c59be7c 100644 --- a/CHANGES +++ b/CHANGES @@ -70,6 +70,7 @@ CDR -------------------------- * The filter option in cdr_adaptive_odbc now supports negating the argument, thus allowing records which do NOT match the specified filter. + * Added ability to log CONGESTION calls to CDR CODECS -------------------------- diff --git a/include/asterisk/cdr.h b/include/asterisk/cdr.h index 5442fdb0cf..2134e0ffbb 100644 --- a/include/asterisk/cdr.h +++ b/include/asterisk/cdr.h @@ -58,6 +58,7 @@ enum { AST_CDR_FAILED = (1 << 1), AST_CDR_BUSY = (1 << 2), AST_CDR_ANSWERED = (1 << 3), + AST_CDR_CONGESTION = (1 << 4), }; /*! @@ -266,6 +267,15 @@ void ast_cdr_answer(struct ast_cdr *cdr); */ extern void ast_cdr_noanswer(struct ast_cdr *cdr); +/*! + * \brief A call was set to congestion + * \param cdr the cdr you wish to associate with the call + * Markst he channel disposition as "CONGESTION" + * Will skip CDR's in chain with ANS_LOCK bit set. (see + * forkCDR() application + */ +extern void ast_cdr_congestion(struct ast_cdr *cdr); + /*! * \brief Busy a call * \param cdr the cdr you wish to associate with the call diff --git a/main/cdr.c b/main/cdr.c index 85c513e16d..5d77ea2228 100644 --- a/main/cdr.c +++ b/main/cdr.c @@ -776,6 +776,26 @@ void ast_cdr_noanswer(struct ast_cdr *cdr) } } +void ast_cdr_congestion(struct ast_cdr *cdr) +{ + char *chan; + + while (cdr) { + if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) { + chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : ""; + + if (ast_test_flag(cdr, AST_CDR_FLAG_POSTED)) { + ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan); + } + + if (cdr->disposition < AST_CDR_CONGESTION) { + cdr->disposition = AST_CDR_CONGESTION; + } + } + cdr = cdr->next; + } +} + /* everywhere ast_cdr_disposition is called, it will call ast_cdr_failed() if ast_cdr_disposition returns a non-zero value */ @@ -792,6 +812,9 @@ int ast_cdr_disposition(struct ast_cdr *cdr, int cause) case AST_CAUSE_NO_ANSWER: ast_cdr_noanswer(cdr); break; + case AST_CAUSE_NORMAL_CIRCUIT_CONGESTION: + ast_cdr_congestion(cdr); + break; case AST_CAUSE_NORMAL: break; default: @@ -961,6 +984,8 @@ char *ast_cdr_disp2str(int disposition) return "BUSY"; case AST_CDR_ANSWERED: return "ANSWERED"; + case AST_CDR_CONGESTION: + return "CONGESTION"; } return "UNKNOWN"; } diff --git a/main/pbx.c b/main/pbx.c index a2054646db..7ac3326350 100644 --- a/main/pbx.c +++ b/main/pbx.c @@ -9321,8 +9321,10 @@ static int pbx_builtin_congestion(struct ast_channel *chan, const char *data) ast_indicate(chan, AST_CONTROL_CONGESTION); /* Don't change state of an UP channel, just indicate congestion in audio */ - if (chan->_state != AST_STATE_UP) + if (chan->_state != AST_STATE_UP) { ast_setstate(chan, AST_STATE_BUSY); + ast_cdr_congestion(chan->cdr); + } wait_for_hangup(chan, data); return -1; }