Merge "Revert "Add API for channel frame deferral.""
This commit is contained in:
commit
5cd03f6a7d
3 changed files with 0 additions and 89 deletions
|
@ -967,11 +967,6 @@ enum {
|
||||||
* The channel is executing a subroutine or macro
|
* The channel is executing a subroutine or macro
|
||||||
*/
|
*/
|
||||||
AST_FLAG_SUBROUTINE_EXEC = (1 << 27),
|
AST_FLAG_SUBROUTINE_EXEC = (1 << 27),
|
||||||
/*!
|
|
||||||
* The channel is currently in an operation where
|
|
||||||
* frames should be deferred.
|
|
||||||
*/
|
|
||||||
AST_FLAG_DEFER_FRAMES = (1 << 28),
|
|
||||||
};
|
};
|
||||||
|
|
||||||
/*! \brief ast_bridge_config flags */
|
/*! \brief ast_bridge_config flags */
|
||||||
|
@ -4676,37 +4671,4 @@ enum ast_channel_error {
|
||||||
*/
|
*/
|
||||||
enum ast_channel_error ast_channel_errno(void);
|
enum ast_channel_error ast_channel_errno(void);
|
||||||
|
|
||||||
/*!
|
|
||||||
* \brief Retrieve the deferred read queue.
|
|
||||||
*/
|
|
||||||
struct ast_readq_list *ast_channel_deferred_readq(struct ast_channel *chan);
|
|
||||||
|
|
||||||
/*!
|
|
||||||
* \brief Start deferring deferrable frames on this channel
|
|
||||||
*
|
|
||||||
* Sometimes, a channel gets entered into a mode where a "main" application
|
|
||||||
* is tasked with servicing frames on the channel, but that application does
|
|
||||||
* not need to act on those frames. However, it would be imprudent to simply
|
|
||||||
* drop important frames. This function can be called so that important frames
|
|
||||||
* will be deferred, rather than placed in the channel frame queue as normal.
|
|
||||||
*
|
|
||||||
* \pre chan MUST be locked before calling
|
|
||||||
*
|
|
||||||
* \param chan The channel on which frames should be deferred
|
|
||||||
*/
|
|
||||||
void ast_channel_start_defer_frames(struct ast_channel *chan);
|
|
||||||
|
|
||||||
/*!
|
|
||||||
* \brief Stop deferring deferrable frames on this channel
|
|
||||||
*
|
|
||||||
* When it is time to stop deferring frames on the channel, all deferred frames
|
|
||||||
* will be queued onto the channel's read queue so that the next servicer of
|
|
||||||
* the channel can handle those frames as necessary.
|
|
||||||
*
|
|
||||||
* \pre chan MUST be locked before calling
|
|
||||||
*
|
|
||||||
* \param chan The channel on which to stop deferring frames.
|
|
||||||
*/
|
|
||||||
void ast_channel_stop_defer_frames(struct ast_channel *chan);
|
|
||||||
|
|
||||||
#endif /* _ASTERISK_CHANNEL_H */
|
#endif /* _ASTERISK_CHANNEL_H */
|
||||||
|
|
|
@ -1062,25 +1062,6 @@ struct ast_channel *__ast_dummy_channel_alloc(const char *file, int line, const
|
||||||
return tmp;
|
return tmp;
|
||||||
}
|
}
|
||||||
|
|
||||||
void ast_channel_start_defer_frames(struct ast_channel *chan)
|
|
||||||
{
|
|
||||||
ast_set_flag(ast_channel_flags(chan), AST_FLAG_DEFER_FRAMES);
|
|
||||||
}
|
|
||||||
|
|
||||||
void ast_channel_stop_defer_frames(struct ast_channel *chan)
|
|
||||||
{
|
|
||||||
ast_clear_flag(ast_channel_flags(chan), AST_FLAG_DEFER_FRAMES);
|
|
||||||
|
|
||||||
/* Move the deferred frames onto the channel read queue, ahead of other queued frames */
|
|
||||||
ast_queue_frame_head(chan, AST_LIST_FIRST(ast_channel_deferred_readq(chan)));
|
|
||||||
/* ast_frfree will mosey down the list and free them all */
|
|
||||||
if (!AST_LIST_EMPTY(ast_channel_deferred_readq(chan))) {
|
|
||||||
ast_frfree(AST_LIST_FIRST(ast_channel_deferred_readq(chan)));
|
|
||||||
}
|
|
||||||
/* Reset the list to be empty */
|
|
||||||
AST_LIST_HEAD_INIT_NOLOCK(ast_channel_deferred_readq(chan));
|
|
||||||
}
|
|
||||||
|
|
||||||
static int __ast_queue_frame(struct ast_channel *chan, struct ast_frame *fin, int head, struct ast_frame *after)
|
static int __ast_queue_frame(struct ast_channel *chan, struct ast_frame *fin, int head, struct ast_frame *after)
|
||||||
{
|
{
|
||||||
struct ast_frame *f;
|
struct ast_frame *f;
|
||||||
|
@ -3902,32 +3883,6 @@ static struct ast_frame *__ast_read(struct ast_channel *chan, int dropaudio)
|
||||||
if (!AST_LIST_EMPTY(ast_channel_readq(chan))) {
|
if (!AST_LIST_EMPTY(ast_channel_readq(chan))) {
|
||||||
int skip_dtmf = should_skip_dtmf(chan);
|
int skip_dtmf = should_skip_dtmf(chan);
|
||||||
|
|
||||||
if (ast_test_flag(ast_channel_flags(chan), AST_FLAG_DEFER_FRAMES)) {
|
|
||||||
AST_LIST_TRAVERSE_SAFE_BEGIN(ast_channel_readq(chan), f, frame_list) {
|
|
||||||
if (ast_is_deferrable_frame(f)) {
|
|
||||||
if (f->frametype == AST_FRAME_CONTROL && f->subclass.integer == AST_CONTROL_HANGUP) {
|
|
||||||
struct ast_frame *dup;
|
|
||||||
|
|
||||||
/* Hangup is a special case. We want to defer the frame, but we also do not
|
|
||||||
* want to remove it from the frame queue. So rather than just moving the frame
|
|
||||||
* over, we duplicate it and move the copy to the deferred readq.
|
|
||||||
*
|
|
||||||
* The reason for this? This way, whoever calls ast_read() will get a NULL return
|
|
||||||
* immediately and can tell the channel has hung up and do what it needs to. Also,
|
|
||||||
* when frame deferral finishes, then whoever calls ast_read() next will also get
|
|
||||||
* the hangup.
|
|
||||||
*/
|
|
||||||
dup = ast_frdup(f);
|
|
||||||
AST_LIST_INSERT_TAIL(ast_channel_deferred_readq(chan), dup, frame_list);
|
|
||||||
} else {
|
|
||||||
AST_LIST_INSERT_TAIL(ast_channel_deferred_readq(chan), f, frame_list);
|
|
||||||
AST_LIST_REMOVE_CURRENT(frame_list);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
AST_LIST_TRAVERSE_SAFE_END;
|
|
||||||
}
|
|
||||||
|
|
||||||
AST_LIST_TRAVERSE_SAFE_BEGIN(ast_channel_readq(chan), f, frame_list) {
|
AST_LIST_TRAVERSE_SAFE_BEGIN(ast_channel_readq(chan), f, frame_list) {
|
||||||
/* We have to be picky about which frame we pull off of the readq because
|
/* We have to be picky about which frame we pull off of the readq because
|
||||||
* there are cases where we want to leave DTMF frames on the queue until
|
* there are cases where we want to leave DTMF frames on the queue until
|
||||||
|
|
|
@ -221,7 +221,6 @@ struct ast_channel {
|
||||||
struct stasis_cp_single *topics; /*!< Topic for all channel's events */
|
struct stasis_cp_single *topics; /*!< Topic for all channel's events */
|
||||||
struct stasis_forward *endpoint_forward; /*!< Subscription for event forwarding to endpoint's topic */
|
struct stasis_forward *endpoint_forward; /*!< Subscription for event forwarding to endpoint's topic */
|
||||||
struct stasis_forward *endpoint_cache_forward; /*!< Subscription for cache updates to endpoint's topic */
|
struct stasis_forward *endpoint_cache_forward; /*!< Subscription for cache updates to endpoint's topic */
|
||||||
struct ast_readq_list deferred_readq;
|
|
||||||
};
|
};
|
||||||
|
|
||||||
/*! \brief The monotonically increasing integer counter for channel uniqueids */
|
/*! \brief The monotonically increasing integer counter for channel uniqueids */
|
||||||
|
@ -1682,8 +1681,3 @@ enum ast_channel_error ast_channel_internal_errno(void)
|
||||||
|
|
||||||
return *error_code;
|
return *error_code;
|
||||||
}
|
}
|
||||||
|
|
||||||
struct ast_readq_list *ast_channel_deferred_readq(struct ast_channel *chan)
|
|
||||||
{
|
|
||||||
return &chan->deferred_readq;
|
|
||||||
}
|
|
||||||
|
|
Loading…
Reference in a new issue