Asterisk - The Open Source Telephony Project GIT-master-f36a736
Data Structures | Macros | Typedefs | Enumerations | Functions
audiohook.h File Reference

Audiohooks Architecture. More...

#include "asterisk/lock.h"
#include "asterisk/linkedlists.h"
#include "asterisk/slinfactory.h"
Include dependency graph for audiohook.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  ast_audiohook
 
struct  ast_audiohook_options
 

Macros

#define ast_audiohook_lock(ah)   ast_mutex_lock(&(ah)->lock)
 Lock an audiohook. More...
 
#define ast_audiohook_unlock(ah)   ast_mutex_unlock(&(ah)->lock)
 Unlock an audiohook. More...
 

Typedefs

typedef int(* ast_audiohook_manipulate_callback) (struct ast_audiohook *audiohook, struct ast_channel *chan, struct ast_frame *frame, enum ast_audiohook_direction direction)
 Callback function for manipulate audiohook type. More...
 

Enumerations

enum  ast_audiohook_direction { AST_AUDIOHOOK_DIRECTION_READ = 0 , AST_AUDIOHOOK_DIRECTION_WRITE , AST_AUDIOHOOK_DIRECTION_BOTH }
 
enum  ast_audiohook_flags {
  AST_AUDIOHOOK_TRIGGER_MODE = (3 << 0) , AST_AUDIOHOOK_TRIGGER_READ = (1 << 0) , AST_AUDIOHOOK_TRIGGER_WRITE = (2 << 0) , AST_AUDIOHOOK_WANTS_DTMF = (1 << 2) ,
  AST_AUDIOHOOK_TRIGGER_SYNC = (1 << 3) , AST_AUDIOHOOK_SMALL_QUEUE = (1 << 4) , AST_AUDIOHOOK_MUTE_READ = (1 << 5) , AST_AUDIOHOOK_MUTE_WRITE = (1 << 6) ,
  AST_AUDIOHOOK_COMPATIBLE = (1 << 7) , AST_AUDIOHOOK_SUBSTITUTE_SILENCE = (1 << 8)
}
 
enum  ast_audiohook_init_flags { AST_AUDIOHOOK_MANIPULATE_ALL_RATES = (1 << 0) }
 
enum  ast_audiohook_status { AST_AUDIOHOOK_STATUS_NEW = 0 , AST_AUDIOHOOK_STATUS_RUNNING , AST_AUDIOHOOK_STATUS_SHUTDOWN , AST_AUDIOHOOK_STATUS_DONE }
 
enum  ast_audiohook_type { AST_AUDIOHOOK_TYPE_SPY = 0 , AST_AUDIOHOOK_TYPE_WHISPER , AST_AUDIOHOOK_TYPE_MANIPULATE }
 

Functions

int ast_audiohook_attach (struct ast_channel *chan, struct ast_audiohook *audiohook)
 Attach audiohook to channel. More...
 
int ast_audiohook_destroy (struct ast_audiohook *audiohook)
 Destroys an audiohook structure. More...
 
int ast_audiohook_detach (struct ast_audiohook *audiohook)
 Detach audiohook from channel. More...
 
void ast_audiohook_detach_list (struct ast_audiohook_list *audiohook_list)
 Detach audiohooks from list and destroy said list. More...
 
int ast_audiohook_detach_source (struct ast_channel *chan, const char *source)
 Detach specified source audiohook from channel. More...
 
int ast_audiohook_init (struct ast_audiohook *audiohook, enum ast_audiohook_type type, const char *source, enum ast_audiohook_init_flags flags)
 Initialize an audiohook structure. More...
 
void ast_audiohook_move_all (struct ast_channel *old_chan, struct ast_channel *new_chan)
 Move all audiohooks from one channel to another. More...
 
void ast_audiohook_move_by_source (struct ast_channel *old_chan, struct ast_channel *new_chan, const char *source)
 Move an audiohook from one channel to a new one. More...
 
struct ast_frameast_audiohook_read_frame (struct ast_audiohook *audiohook, size_t samples, enum ast_audiohook_direction direction, struct ast_format *format)
 Reads a frame in from the audiohook structure. More...
 
struct ast_frameast_audiohook_read_frame_all (struct ast_audiohook *audiohook, size_t samples, struct ast_format *format, struct ast_frame **read_frame, struct ast_frame **write_frame)
 Reads a frame in from the audiohook structure in mixed audio mode and copies read and write frame data to provided arguments. More...
 
int ast_audiohook_remove (struct ast_channel *chan, struct ast_audiohook *audiohook)
 Remove an audiohook from a specified channel. More...
 
int ast_audiohook_set_frame_feed_direction (struct ast_audiohook *audiohook, enum ast_audiohook_direction direction)
 Sets direction on audiohook. More...
 
int ast_audiohook_set_mute (struct ast_channel *chan, const char *source, enum ast_audiohook_flags flag, int clear)
 Mute frames read from or written to a channel. More...
 
int ast_audiohook_set_mute_all (struct ast_channel *chan, const char *source, enum ast_audiohook_flags flag, int clear)
 Mute frames read from or written for all audiohooks on a channel. More...
 
void ast_audiohook_trigger_wait (struct ast_audiohook *audiohook)
 Wait for audiohook trigger to be triggered. More...
 
void ast_audiohook_update_status (struct ast_audiohook *audiohook, enum ast_audiohook_status status)
 Update audiohook's status. More...
 
int ast_audiohook_volume_adjust (struct ast_channel *chan, enum ast_audiohook_direction direction, int volume)
 Adjust the volume on frames read from or written to a channel. More...
 
int ast_audiohook_volume_get (struct ast_channel *chan, enum ast_audiohook_direction direction)
 Retrieve the volume adjustment value on frames read from or written to a channel. More...
 
int ast_audiohook_volume_set (struct ast_channel *chan, enum ast_audiohook_direction direction, int volume)
 Adjust the volume on frames read from or written to a channel. More...
 
int ast_audiohook_write_frame (struct ast_audiohook *audiohook, enum ast_audiohook_direction direction, struct ast_frame *frame)
 Writes a frame into the audiohook structure. More...
 
struct ast_frameast_audiohook_write_list (struct ast_channel *chan, struct ast_audiohook_list *audiohook_list, enum ast_audiohook_direction direction, struct ast_frame *frame)
 Pass a frame off to be handled by the audiohook core. More...
 
int ast_audiohook_write_list_empty (struct ast_audiohook_list *audiohook_list)
 Determine if a audiohook_list is empty or not. More...
 
int ast_channel_audiohook_count_by_source (struct ast_channel *chan, const char *source, enum ast_audiohook_type type)
 Find out how many audiohooks from a certain source exist on a given channel, regardless of status. More...
 
int ast_channel_audiohook_count_by_source_running (struct ast_channel *chan, const char *source, enum ast_audiohook_type type)
 Find out how many spies of a certain type exist on a given channel, and are in state running. More...
 

Detailed Description

Audiohooks Architecture.

Definition in file audiohook.h.

Macro Definition Documentation

◆ ast_audiohook_lock

#define ast_audiohook_lock (   ah)    ast_mutex_lock(&(ah)->lock)

Lock an audiohook.

Parameters
ahAudiohook structure

Definition at line 313 of file audiohook.h.

◆ ast_audiohook_unlock

#define ast_audiohook_unlock (   ah)    ast_mutex_unlock(&(ah)->lock)

Unlock an audiohook.

Parameters
ahAudiohook structure

Definition at line 318 of file audiohook.h.

Typedef Documentation

◆ ast_audiohook_manipulate_callback

typedef int(* ast_audiohook_manipulate_callback) (struct ast_audiohook *audiohook, struct ast_channel *chan, struct ast_frame *frame, enum ast_audiohook_direction direction)

Callback function for manipulate audiohook type.

Parameters
audiohook
chan
frameFrame of audio to manipulate
directionDirection frame came from
Return values
0on success
-1on failure
Note
An audiohook does not have any reference to a private data structure for manipulate types. It is up to the manipulate callback to store this data via it's own method. An example would be datastores.
The input frame should never be freed or corrupted during a manipulate callback. If the callback has the potential to corrupt the frame's data during manipulation, local data should be used for the manipulation and only copied to the frame on success.
A failure return value indicates that the frame was not manipulated and that is being returned in its original state.

Definition at line 97 of file audiohook.h.

Enumeration Type Documentation

◆ ast_audiohook_direction

Enumerator
AST_AUDIOHOOK_DIRECTION_READ 

Reading audio in

AST_AUDIOHOOK_DIRECTION_WRITE 

Writing audio out

AST_AUDIOHOOK_DIRECTION_BOTH 

Both reading audio in and writing audio out

Definition at line 48 of file audiohook.h.

48 {
49 AST_AUDIOHOOK_DIRECTION_READ = 0, /*!< Reading audio in */
50 AST_AUDIOHOOK_DIRECTION_WRITE, /*!< Writing audio out */
51 AST_AUDIOHOOK_DIRECTION_BOTH, /*!< Both reading audio in and writing audio out */
52};
@ AST_AUDIOHOOK_DIRECTION_READ
Definition: audiohook.h:49
@ AST_AUDIOHOOK_DIRECTION_WRITE
Definition: audiohook.h:50
@ AST_AUDIOHOOK_DIRECTION_BOTH
Definition: audiohook.h:51

◆ ast_audiohook_flags

Enumerator
AST_AUDIOHOOK_TRIGGER_MODE 

When audiohook should be triggered to do something

AST_AUDIOHOOK_TRIGGER_READ 

Audiohook wants to be triggered when reading audio in

AST_AUDIOHOOK_TRIGGER_WRITE 

Audiohook wants to be triggered when writing audio out

AST_AUDIOHOOK_WANTS_DTMF 

Audiohook also wants to receive DTMF frames

AST_AUDIOHOOK_TRIGGER_SYNC 

Audiohook wants to be triggered when both sides have combined audio available

AST_AUDIOHOOK_SMALL_QUEUE 

Audiohooks with this flag set will not allow for a large amount of samples to build up on its slinfactories. We will flush the factories if they contain too many samples.

AST_AUDIOHOOK_MUTE_READ 

audiohook should be mute frames read

AST_AUDIOHOOK_MUTE_WRITE 

audiohook should be mute frames written

AST_AUDIOHOOK_COMPATIBLE 

is the audiohook native slin compatible

AST_AUDIOHOOK_SUBSTITUTE_SILENCE 

Substitute silence for missing audio

Definition at line 54 of file audiohook.h.

54 {
55 AST_AUDIOHOOK_TRIGGER_MODE = (3 << 0), /*!< When audiohook should be triggered to do something */
56 AST_AUDIOHOOK_TRIGGER_READ = (1 << 0), /*!< Audiohook wants to be triggered when reading audio in */
57 AST_AUDIOHOOK_TRIGGER_WRITE = (2 << 0), /*!< Audiohook wants to be triggered when writing audio out */
58 AST_AUDIOHOOK_WANTS_DTMF = (1 << 2), /*!< Audiohook also wants to receive DTMF frames */
59 AST_AUDIOHOOK_TRIGGER_SYNC = (1 << 3), /*!< Audiohook wants to be triggered when both sides have combined audio available */
60 /*! Audiohooks with this flag set will not allow for a large amount of samples to build up on its
61 * slinfactories. We will flush the factories if they contain too many samples.
62 */
64 AST_AUDIOHOOK_MUTE_READ = (1 << 5), /*!< audiohook should be mute frames read */
65 AST_AUDIOHOOK_MUTE_WRITE = (1 << 6), /*!< audiohook should be mute frames written */
66 AST_AUDIOHOOK_COMPATIBLE = (1 << 7), /*!< is the audiohook native slin compatible */
67
68 AST_AUDIOHOOK_SUBSTITUTE_SILENCE = (1 << 8), /*!< Substitute silence for missing audio */
69};
@ AST_AUDIOHOOK_COMPATIBLE
Definition: audiohook.h:66
@ AST_AUDIOHOOK_WANTS_DTMF
Definition: audiohook.h:58
@ AST_AUDIOHOOK_TRIGGER_MODE
Definition: audiohook.h:55
@ AST_AUDIOHOOK_MUTE_READ
Definition: audiohook.h:64
@ AST_AUDIOHOOK_MUTE_WRITE
Definition: audiohook.h:65
@ AST_AUDIOHOOK_SUBSTITUTE_SILENCE
Definition: audiohook.h:68
@ AST_AUDIOHOOK_SMALL_QUEUE
Definition: audiohook.h:63
@ AST_AUDIOHOOK_TRIGGER_READ
Definition: audiohook.h:56
@ AST_AUDIOHOOK_TRIGGER_WRITE
Definition: audiohook.h:57
@ AST_AUDIOHOOK_TRIGGER_SYNC
Definition: audiohook.h:59

◆ ast_audiohook_init_flags

Enumerator
AST_AUDIOHOOK_MANIPULATE_ALL_RATES 

Audiohook manipulate callback is capable of handling slinear at any sample rate. Without enabling this flag on initialization the manipulation callback is guaranteed 8khz audio only.

Definition at line 71 of file audiohook.h.

71 {
72 /*! Audiohook manipulate callback is capable of handling slinear at any sample rate.
73 * Without enabling this flag on initialization the manipulation callback is guaranteed
74 * 8khz audio only. */
76};
@ AST_AUDIOHOOK_MANIPULATE_ALL_RATES
Definition: audiohook.h:75

◆ ast_audiohook_status

Enumerator
AST_AUDIOHOOK_STATUS_NEW 

Audiohook was just created, not in use yet

AST_AUDIOHOOK_STATUS_RUNNING 

Audiohook is running on a channel

AST_AUDIOHOOK_STATUS_SHUTDOWN 

Audiohook is being shutdown

AST_AUDIOHOOK_STATUS_DONE 

Audiohook has shutdown and is not running on a channel any longer

Definition at line 41 of file audiohook.h.

41 {
42 AST_AUDIOHOOK_STATUS_NEW = 0, /*!< Audiohook was just created, not in use yet */
43 AST_AUDIOHOOK_STATUS_RUNNING, /*!< Audiohook is running on a channel */
44 AST_AUDIOHOOK_STATUS_SHUTDOWN, /*!< Audiohook is being shutdown */
45 AST_AUDIOHOOK_STATUS_DONE, /*!< Audiohook has shutdown and is not running on a channel any longer */
46};
@ AST_AUDIOHOOK_STATUS_DONE
Definition: audiohook.h:45
@ AST_AUDIOHOOK_STATUS_NEW
Definition: audiohook.h:42
@ AST_AUDIOHOOK_STATUS_RUNNING
Definition: audiohook.h:43
@ AST_AUDIOHOOK_STATUS_SHUTDOWN
Definition: audiohook.h:44

◆ ast_audiohook_type

Enumerator
AST_AUDIOHOOK_TYPE_SPY 

Audiohook wants to receive audio

AST_AUDIOHOOK_TYPE_WHISPER 

Audiohook wants to provide audio to be mixed with existing audio

AST_AUDIOHOOK_TYPE_MANIPULATE 

Audiohook wants to manipulate the audio

Definition at line 35 of file audiohook.h.

35 {
36 AST_AUDIOHOOK_TYPE_SPY = 0, /*!< Audiohook wants to receive audio */
37 AST_AUDIOHOOK_TYPE_WHISPER, /*!< Audiohook wants to provide audio to be mixed with existing audio */
38 AST_AUDIOHOOK_TYPE_MANIPULATE, /*!< Audiohook wants to manipulate the audio */
39};
@ AST_AUDIOHOOK_TYPE_MANIPULATE
Definition: audiohook.h:38
@ AST_AUDIOHOOK_TYPE_SPY
Definition: audiohook.h:36
@ AST_AUDIOHOOK_TYPE_WHISPER
Definition: audiohook.h:37

Function Documentation

◆ ast_audiohook_attach()

int ast_audiohook_attach ( struct ast_channel chan,
struct ast_audiohook audiohook 
)

Attach audiohook to channel.

Parameters
chan
audiohook
Returns
0 on success
Return values
-1on failure

Definition at line 512 of file audiohook.c.

513{
514 ast_channel_lock(chan);
515
516 /* Don't allow an audiohook to be attached to a channel that is already hung up.
517 * The hang up process is what actually notifies the audiohook that it should
518 * stop.
519 */
521 ast_channel_unlock(chan);
522 return -1;
523 }
524
525 if (!ast_channel_audiohooks(chan)) {
526 struct ast_audiohook_list *ahlist;
527 /* Whoops... allocate a new structure */
528 if (!(ahlist = ast_calloc(1, sizeof(*ahlist)))) {
529 ast_channel_unlock(chan);
530 return -1;
531 }
532 ast_channel_audiohooks_set(chan, ahlist);
536 /* This sample rate will adjust as necessary when writing to the list. */
538 }
539
540 /* Drop into respective list */
541 if (audiohook->type == AST_AUDIOHOOK_TYPE_SPY) {
542 AST_LIST_INSERT_TAIL(&ast_channel_audiohooks(chan)->spy_list, audiohook, list);
543 } else if (audiohook->type == AST_AUDIOHOOK_TYPE_WHISPER) {
545 } else if (audiohook->type == AST_AUDIOHOOK_TYPE_MANIPULATE) {
547 }
548
549 /*
550 * Initialize the audiohook's rate to the default. If it needs to be,
551 * it will get updated later.
552 */
555
556 /* Change status over to running since it is now attached */
558
559 if (ast_channel_is_bridged(chan)) {
561 }
562
563 ast_channel_unlock(chan);
564
565 return 0;
566}
#define ast_calloc(num, len)
A wrapper for calloc()
Definition: astmm.h:202
static void audiohook_list_set_samplerate_compatibility(struct ast_audiohook_list *audiohook_list)
Definition: audiohook.c:484
void ast_audiohook_update_status(struct ast_audiohook *audiohook, enum ast_audiohook_status status)
Update audiohook's status.
Definition: audiohook.c:568
static int audiohook_set_internal_rate(struct ast_audiohook *audiohook, int rate, int reset)
Definition: audiohook.c:70
#define DEFAULT_INTERNAL_SAMPLE_RATE
Definition: audiohook.c:48
void ast_channel_set_unbridged_nolock(struct ast_channel *chan, int value)
Variant of ast_channel_set_unbridged. Use this if the channel is already locked prior to calling.
#define ast_channel_lock(chan)
Definition: channel.h:2968
struct ast_flags * ast_channel_flags(struct ast_channel *chan)
void ast_channel_audiohooks_set(struct ast_channel *chan, struct ast_audiohook_list *value)
struct ast_audiohook_list * ast_channel_audiohooks(const struct ast_channel *chan)
int ast_channel_is_bridged(const struct ast_channel *chan)
Determine if a channel is in a bridge.
Definition: channel.c:10567
@ AST_FLAG_ZOMBIE
Definition: channel.h:1007
#define ast_channel_unlock(chan)
Definition: channel.h:2969
#define AST_LIST_HEAD_INIT_NOLOCK(head)
Initializes a list head structure.
Definition: linkedlists.h:681
#define AST_LIST_INSERT_TAIL(head, elm, field)
Appends a list entry to the tail of a list.
Definition: linkedlists.h:731
int list_internal_samp_rate
Definition: audiohook.c:61
struct ast_audiohook_list::@302 spy_list
struct ast_audiohook_list::@304 manipulate_list
struct ast_audiohook_list::@303 whisper_list
enum ast_audiohook_type type
Definition: audiohook.h:107
#define ast_test_flag(p, flag)
Definition: utils.h:63

References AST_AUDIOHOOK_STATUS_RUNNING, AST_AUDIOHOOK_TYPE_MANIPULATE, AST_AUDIOHOOK_TYPE_SPY, AST_AUDIOHOOK_TYPE_WHISPER, ast_audiohook_update_status(), ast_calloc, ast_channel_audiohooks(), ast_channel_audiohooks_set(), ast_channel_flags(), ast_channel_is_bridged(), ast_channel_lock, ast_channel_set_unbridged_nolock(), ast_channel_unlock, AST_FLAG_ZOMBIE, AST_LIST_HEAD_INIT_NOLOCK, AST_LIST_INSERT_TAIL, ast_test_flag, audiohook_list_set_samplerate_compatibility(), audiohook_set_internal_rate(), DEFAULT_INTERNAL_SAMPLE_RATE, ast_audiohook_list::list_internal_samp_rate, ast_audiohook_list::manipulate_list, ast_audiohook_list::spy_list, ast_audiohook::type, and ast_audiohook_list::whisper_list.

Referenced by audiohook_move(), audiohook_volume_get(), detect_write(), enable_jack_hook(), init_hook(), pitchshift_helper(), scramble_write(), set_talk_detect(), snoop_setup_audiohook(), speex_write(), start_spying(), start_whispering(), startmon(), and volume_write().

◆ ast_audiohook_destroy()

int ast_audiohook_destroy ( struct ast_audiohook audiohook)

Destroys an audiohook structure.

Parameters
audiohook
Return values
0on success
-1on failure

Definition at line 124 of file audiohook.c.

125{
126 /* Drop the factories used by this audiohook type */
127 switch (audiohook->type) {
132 break;
133 default:
134 break;
135 }
136
137 /* Destroy translation path if present */
138 if (audiohook->trans_pvt)
140
141 ao2_cleanup(audiohook->format);
142
143 /* Lock and trigger be gone! */
144 ast_cond_destroy(&audiohook->trigger);
145 ast_mutex_destroy(&audiohook->lock);
146
147 return 0;
148}
#define ao2_cleanup(obj)
Definition: astobj2.h:1934
#define ast_cond_destroy(cond)
Definition: lock.h:202
#define ast_mutex_destroy(a)
Definition: lock.h:188
void ast_slinfactory_destroy(struct ast_slinfactory *sf)
Destroy the contents of a slinfactory.
Definition: slinfactory.c:58
ast_cond_t trigger
Definition: audiohook.h:106
struct ast_slinfactory read_factory
Definition: audiohook.h:112
struct ast_trans_pvt * trans_pvt
Definition: audiohook.h:117
struct ast_format * format
Definition: audiohook.h:116
ast_mutex_t lock
Definition: audiohook.h:105
struct ast_slinfactory write_factory
Definition: audiohook.h:113
void ast_translator_free_path(struct ast_trans_pvt *tr)
Frees a translator path Frees the given translator path structure.
Definition: translate.c:476

References ao2_cleanup, AST_AUDIOHOOK_TYPE_SPY, AST_AUDIOHOOK_TYPE_WHISPER, ast_cond_destroy, ast_mutex_destroy, ast_slinfactory_destroy(), ast_translator_free_path(), ast_audiohook::format, ast_audiohook::lock, ast_audiohook::read_factory, ast_audiohook::trans_pvt, ast_audiohook::trigger, ast_audiohook::type, and ast_audiohook::write_factory.

Referenced by audiohook_volume_destroy(), channel_spy(), datastore_destroy_cb(), destroy_callback(), destroy_jack_data(), destroy_monitor_audiohook(), hook_datastore_destroy_callback(), launch_monitor_thread(), multi_autochan_free(), and snoop_destroy().

◆ ast_audiohook_detach()

int ast_audiohook_detach ( struct ast_audiohook audiohook)

Detach audiohook from channel.

Parameters
audiohook
Returns
Returns 0 on success, -1 on failure

Definition at line 578 of file audiohook.c.

579{
580 if (audiohook->status == AST_AUDIOHOOK_STATUS_NEW || audiohook->status == AST_AUDIOHOOK_STATUS_DONE) {
581 return 0;
582 }
583
585
586 while (audiohook->status != AST_AUDIOHOOK_STATUS_DONE) {
588 }
589
590 return 0;
591}
void ast_audiohook_trigger_wait(struct ast_audiohook *audiohook)
Wait for audiohook trigger to be triggered.
Definition: audiohook.c:1122
enum ast_audiohook_status status
Definition: audiohook.h:108

References AST_AUDIOHOOK_STATUS_DONE, AST_AUDIOHOOK_STATUS_NEW, AST_AUDIOHOOK_STATUS_SHUTDOWN, ast_audiohook_trigger_wait(), ast_audiohook_update_status(), and ast_audiohook::status.

Referenced by channel_spy(), destroy_callback(), destroy_monitor_audiohook(), disable_jack_hook(), hook_datastore_destroy_callback(), multi_autochan_free(), snoop_hangup(), and speex_write().

◆ ast_audiohook_detach_list()

void ast_audiohook_detach_list ( struct ast_audiohook_list audiohook_list)

Detach audiohooks from list and destroy said list.

Parameters
audiohook_listList of audiohooks (NULL tolerant)

Definition at line 593 of file audiohook.c.

594{
595 int i;
596 struct ast_audiohook *audiohook;
597
598 if (!audiohook_list) {
599 return;
600 }
601
602 /* Drop any spies */
603 while ((audiohook = AST_LIST_REMOVE_HEAD(&audiohook_list->spy_list, list))) {
605 }
606
607 /* Drop any whispering sources */
608 while ((audiohook = AST_LIST_REMOVE_HEAD(&audiohook_list->whisper_list, list))) {
610 }
611
612 /* Drop any manipulators */
613 while ((audiohook = AST_LIST_REMOVE_HEAD(&audiohook_list->manipulate_list, list))) {
615 audiohook->manipulate_callback(audiohook, NULL, NULL, 0);
616 }
617
618 /* Drop translation paths if present */
619 for (i = 0; i < 2; i++) {
620 if (audiohook_list->in_translate[i].trans_pvt) {
622 ao2_cleanup(audiohook_list->in_translate[i].format);
623 }
624 if (audiohook_list->out_translate[i].trans_pvt) {
626 ao2_cleanup(audiohook_list->in_translate[i].format);
627 }
628 }
629
630 /* Free ourselves */
631 ast_free(audiohook_list);
632}
#define ast_free(a)
Definition: astmm.h:180
#define AST_LIST_REMOVE_HEAD(head, field)
Removes and returns the head entry from a list.
Definition: linkedlists.h:833
#define NULL
Definition: resample.c:96
struct ast_audiohook_translate out_translate[2]
Definition: audiohook.c:64
struct ast_audiohook_translate in_translate[2]
Definition: audiohook.c:63
struct ast_trans_pvt * trans_pvt
Definition: audiohook.c:51
struct ast_format * format
Definition: audiohook.c:52
ast_audiohook_manipulate_callback manipulate_callback
Definition: audiohook.h:118
struct ast_audiohook::@187 list

References ao2_cleanup, AST_AUDIOHOOK_STATUS_DONE, ast_audiohook_update_status(), ast_free, AST_LIST_REMOVE_HEAD, ast_translator_free_path(), ast_audiohook_translate::format, ast_audiohook_list::in_translate, ast_audiohook::list, ast_audiohook::manipulate_callback, ast_audiohook_list::manipulate_list, NULL, ast_audiohook_list::out_translate, ast_audiohook_list::spy_list, ast_audiohook_translate::trans_pvt, and ast_audiohook_list::whisper_list.

Referenced by __ast_read(), ast_write_stream(), and destroy_hooks().

◆ ast_audiohook_detach_source()

int ast_audiohook_detach_source ( struct ast_channel chan,
const char *  source 
)

Detach specified source audiohook from channel.

Parameters
chanChannel to detach from
sourceName of source to detach
Return values
0on success
-1on failure
Note
The channel does not need to be locked before calling this function.

Definition at line 726 of file audiohook.c.

727{
728 struct ast_audiohook *audiohook = NULL;
729
730 ast_channel_lock(chan);
731
732 /* Ensure the channel has audiohooks on it */
733 if (!ast_channel_audiohooks(chan)) {
734 ast_channel_unlock(chan);
735 return -1;
736 }
737
739
740 ast_channel_unlock(chan);
741
742 if (audiohook && audiohook->status != AST_AUDIOHOOK_STATUS_DONE) {
744 }
745
746 return (audiohook ? 0 : -1);
747}
static struct ast_audiohook * find_audiohook_by_source(struct ast_audiohook_list *audiohook_list, const char *source)
find an audiohook based on its source
Definition: audiohook.c:640
const char * source
Definition: audiohook.h:110

References AST_AUDIOHOOK_STATUS_DONE, AST_AUDIOHOOK_STATUS_SHUTDOWN, ast_audiohook_update_status(), ast_channel_audiohooks(), ast_channel_lock, ast_channel_unlock, find_audiohook_by_source(), NULL, ast_audiohook::source, and ast_audiohook::status.

◆ ast_audiohook_init()

int ast_audiohook_init ( struct ast_audiohook audiohook,
enum ast_audiohook_type  type,
const char *  source,
enum ast_audiohook_init_flags  flags 
)

Initialize an audiohook structure.

Parameters
audiohook
typeType of audiohook to initialize this as
sourceWho is initializing this audiohook
flags
Return values
0on success
-1on failure

Definition at line 100 of file audiohook.c.

101{
102 /* Need to keep the type and source */
103 audiohook->type = type;
104 audiohook->source = source;
105
106 /* Initialize lock that protects our audiohook */
107 ast_mutex_init(&audiohook->lock);
108 ast_cond_init(&audiohook->trigger, NULL);
109
110 audiohook->init_flags = init_flags;
111
112 /* Set direction to BOTH so that we feed frames in both directions */
114
115 /* initialize internal rate at 8khz, this will adjust if necessary */
117
118 /* Since we are just starting out... this audiohook is new */
120
121 return 0;
122}
static const char type[]
Definition: chan_ooh323.c:109
#define ast_cond_init(cond, attr)
Definition: lock.h:201
#define ast_mutex_init(pmutex)
Definition: lock.h:186
enum ast_audiohook_init_flags init_flags
Definition: audiohook.h:109
enum ast_audiohook_direction direction
Definition: audiohook.h:121

References AST_AUDIOHOOK_DIRECTION_BOTH, AST_AUDIOHOOK_STATUS_NEW, ast_audiohook_update_status(), ast_cond_init, ast_mutex_init, audiohook_set_internal_rate(), DEFAULT_INTERNAL_SAMPLE_RATE, ast_audiohook::direction, ast_audiohook::init_flags, ast_audiohook::lock, NULL, ast_audiohook::source, ast_audiohook::trigger, type, and ast_audiohook::type.

Referenced by attach_barge(), audiohook_volume_get(), channel_spy(), detect_write(), do_broadcast(), enable_jack_hook(), hook_state_alloc(), launch_monitor_thread(), pitchshift_helper(), scramble_write(), set_talk_detect(), snoop_setup_audiohook(), speex_write(), and volume_write().

◆ ast_audiohook_move_all()

void ast_audiohook_move_all ( struct ast_channel old_chan,
struct ast_channel new_chan 
)

Move all audiohooks from one channel to another.

Note
It is required that both old_chan and new_chan are locked prior to calling this function. Besides needing to protect the data within the channels, not locking these channels can lead to a potential deadlock.
Parameters
old_chanThe source of the audiohooks being moved
new_chanThe destination channel for the audiohooks to be moved to

Definition at line 700 of file audiohook.c.

701{
702 struct ast_audiohook *audiohook;
703 struct ast_audiohook_list *audiohook_list;
704
705 audiohook_list = ast_channel_audiohooks(old_chan);
706 if (!audiohook_list) {
707 return;
708 }
709
710 AST_LIST_TRAVERSE_SAFE_BEGIN(&audiohook_list->spy_list, audiohook, list) {
711 audiohook_move(old_chan, new_chan, audiohook);
712 }
714
715 AST_LIST_TRAVERSE_SAFE_BEGIN(&audiohook_list->whisper_list, audiohook, list) {
716 audiohook_move(old_chan, new_chan, audiohook);
717 }
719
720 AST_LIST_TRAVERSE_SAFE_BEGIN(&audiohook_list->manipulate_list, audiohook, list) {
721 audiohook_move(old_chan, new_chan, audiohook);
722 }
724}
static void audiohook_move(struct ast_channel *old_chan, struct ast_channel *new_chan, struct ast_audiohook *audiohook)
Definition: audiohook.c:665
#define AST_LIST_TRAVERSE_SAFE_END
Closes a safe loop traversal block.
Definition: linkedlists.h:615
#define AST_LIST_TRAVERSE_SAFE_BEGIN(head, var, field)
Loops safely over (traverses) the entries in a list.
Definition: linkedlists.h:529

References ast_channel_audiohooks(), AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, audiohook_move(), ast_audiohook_list::manipulate_list, ast_audiohook_list::spy_list, and ast_audiohook_list::whisper_list.

Referenced by channel_do_masquerade().

◆ ast_audiohook_move_by_source()

void ast_audiohook_move_by_source ( struct ast_channel old_chan,
struct ast_channel new_chan,
const char *  source 
)

Move an audiohook from one channel to a new one.

Todo:
Currently only the first audiohook of a specific source found will be moved. We should add the capability to move multiple audiohooks from a single source as well.
Note
It is required that both old_chan and new_chan are locked prior to calling this function. Besides needing to protect the data within the channels, not locking these channels can lead to a potential deadlock
Parameters
old_chanThe source of the audiohook to move
new_chanThe destination to which we want the audiohook to move
sourceThe source of the audiohook we want to move

Definition at line 684 of file audiohook.c.

685{
686 struct ast_audiohook *audiohook;
687
688 if (!ast_channel_audiohooks(old_chan)) {
689 return;
690 }
691
693 if (!audiohook) {
694 return;
695 }
696
697 audiohook_move(old_chan, new_chan, audiohook);
698}

References ast_channel_audiohooks(), audiohook_move(), find_audiohook_by_source(), and ast_audiohook::source.

◆ ast_audiohook_read_frame()

struct ast_frame * ast_audiohook_read_frame ( struct ast_audiohook audiohook,
size_t  samples,
enum ast_audiohook_direction  direction,
struct ast_format format 
)

Reads a frame in from the audiohook structure.

Parameters
audiohook
samplesNumber of samples wanted
directionDirection the audio frame came from
formatFormat of frame remote side wants back
Returns
frame on success
Return values
NULLon failure

Definition at line 474 of file audiohook.c.

475{
476 return audiohook_read_frame_helper(audiohook, samples, direction, format, NULL, NULL);
477}
static struct ast_frame * audiohook_read_frame_helper(struct ast_audiohook *audiohook, size_t samples, enum ast_audiohook_direction direction, struct ast_format *format, struct ast_frame **read_reference, struct ast_frame **write_reference)
Definition: audiohook.c:412
direction

References audiohook_read_frame_helper(), NULL, and ast_frame::samples.

Referenced by snoop_read(), and spy_generate().

◆ ast_audiohook_read_frame_all()

struct ast_frame * ast_audiohook_read_frame_all ( struct ast_audiohook audiohook,
size_t  samples,
struct ast_format format,
struct ast_frame **  read_frame,
struct ast_frame **  write_frame 
)

Reads a frame in from the audiohook structure in mixed audio mode and copies read and write frame data to provided arguments.

Parameters
audiohook
samplesNumber of samples wanted
formatFormat of frame remote side wants back
read_frameif available, we'll copy the read buffer to this.
write_frameif available, we'll copy the write buffer to this.
Returns
frame on success
Return values
NULLon failure

Definition at line 479 of file audiohook.c.

480{
481 return audiohook_read_frame_helper(audiohook, samples, AST_AUDIOHOOK_DIRECTION_BOTH, format, read_frame, write_frame);
482}
static struct ast_frame * read_frame(struct ast_filestream *s, int *whennext)
Definition: file.c:911

References AST_AUDIOHOOK_DIRECTION_BOTH, audiohook_read_frame_helper(), read_frame(), and ast_frame::samples.

Referenced by mixmonitor_thread(), and spy_generate().

◆ ast_audiohook_remove()

int ast_audiohook_remove ( struct ast_channel chan,
struct ast_audiohook audiohook 
)

Remove an audiohook from a specified channel.

Parameters
chanChannel to remove from
audiohookAudiohook to remove
Return values
0on success
-1on failure
Note
The channel does not need to be locked before calling this function

Definition at line 749 of file audiohook.c.

750{
751 ast_channel_lock(chan);
752
753 if (!ast_channel_audiohooks(chan)) {
754 ast_channel_unlock(chan);
755 return -1;
756 }
757
758 if (audiohook->type == AST_AUDIOHOOK_TYPE_SPY) {
759 AST_LIST_REMOVE(&ast_channel_audiohooks(chan)->spy_list, audiohook, list);
760 } else if (audiohook->type == AST_AUDIOHOOK_TYPE_WHISPER) {
761 AST_LIST_REMOVE(&ast_channel_audiohooks(chan)->whisper_list, audiohook, list);
762 } else if (audiohook->type == AST_AUDIOHOOK_TYPE_MANIPULATE) {
763 AST_LIST_REMOVE(&ast_channel_audiohooks(chan)->manipulate_list, audiohook, list);
764 }
765
768
769 if (ast_channel_is_bridged(chan)) {
771 }
772
773 ast_channel_unlock(chan);
774
775 return 0;
776}
#define AST_LIST_REMOVE(head, elm, field)
Removes a specific entry from a list.
Definition: linkedlists.h:856

References AST_AUDIOHOOK_STATUS_DONE, AST_AUDIOHOOK_TYPE_MANIPULATE, AST_AUDIOHOOK_TYPE_SPY, AST_AUDIOHOOK_TYPE_WHISPER, ast_audiohook_update_status(), ast_channel_audiohooks(), ast_channel_is_bridged(), ast_channel_lock, ast_channel_set_unbridged_nolock(), ast_channel_unlock, AST_LIST_REMOVE, audiohook_list_set_samplerate_compatibility(), ast_audiohook::list, and ast_audiohook::type.

Referenced by audiohook_move(), remove_detect(), remove_scrambler(), remove_talk_detect(), and speex_write().

◆ ast_audiohook_set_frame_feed_direction()

int ast_audiohook_set_frame_feed_direction ( struct ast_audiohook audiohook,
enum ast_audiohook_direction  direction 
)

Sets direction on audiohook.

Parameters
audiohook
directionIn which direction should the audiohook feed frames, ie if we are snooping 'in', set direction to READ so that only the 'in' frames are fed to the slin factory
Return values
0on success
-1on failure due to audiohook already in use or in shutdown. Can only set direction on NEW audiohooks

Definition at line 150 of file audiohook.c.

151{
152 /* Only set the direction on new audiohooks */
153 if (audiohook->status != AST_AUDIOHOOK_STATUS_NEW) {
154 ast_debug(3, "Can not set direction on attached Audiohook %p\n", audiohook);
155 return -1;
156 }
157
158 audiohook->direction = direction;
159 return 0;
160}
#define ast_debug(level,...)
Log a DEBUG message.

References AST_AUDIOHOOK_STATUS_NEW, ast_debug, ast_audiohook::direction, and ast_audiohook::status.

Referenced by snoop_setup_audiohook(), and start_spying().

◆ ast_audiohook_set_mute()

int ast_audiohook_set_mute ( struct ast_channel chan,
const char *  source,
enum ast_audiohook_flags  flag,
int  clear 
)

Mute frames read from or written to a channel.

Parameters
chanChannel to muck with
sourceType of audiohook
flagwhich direction to set / clear
clearset or clear muted frames on direction based on flag parameter
Return values
0success
-1failure

Definition at line 1381 of file audiohook.c.

1382{
1383 struct ast_audiohook *audiohook = NULL;
1384
1385 ast_channel_lock(chan);
1386
1387 /* Ensure the channel has audiohooks on it */
1388 if (!ast_channel_audiohooks(chan)) {
1389 ast_channel_unlock(chan);
1390 return -1;
1391 }
1392
1394
1395 if (audiohook) {
1396 if (clear) {
1397 ast_clear_flag(audiohook, flag);
1398 } else {
1399 ast_set_flag(audiohook, flag);
1400 }
1401 }
1402
1403 ast_channel_unlock(chan);
1404
1405 return (audiohook ? 0 : -1);
1406}
long int flag
Definition: f2c.h:83
#define ast_clear_flag(p, flag)
Definition: utils.h:77
#define ast_set_flag(p, flag)
Definition: utils.h:70

References ast_channel_audiohooks(), ast_channel_lock, ast_channel_unlock, ast_clear_flag, ast_set_flag, find_audiohook_by_source(), NULL, and ast_audiohook::source.

◆ ast_audiohook_set_mute_all()

int ast_audiohook_set_mute_all ( struct ast_channel chan,
const char *  source,
enum ast_audiohook_flags  flag,
int  clear 
)

Mute frames read from or written for all audiohooks on a channel.

Parameters
chanChannel to muck with
sourceType of audiohooks
flagwhich direction to set / clear
clearset or clear muted frames on direction based on flag parameter
Return values
>=0number of muted audiohooks
-1failure

Definition at line 1408 of file audiohook.c.

1409{
1410 struct ast_audiohook *audiohook = NULL;
1411 int count = 0;
1412
1413 ast_channel_lock(chan);
1414
1415 if (!ast_channel_audiohooks(chan)) {
1416 ast_channel_unlock(chan);
1417 return -1;
1418 }
1419
1420 AST_LIST_TRAVERSE(&ast_channel_audiohooks(chan)->spy_list, audiohook, list) {
1421 if (!strcasecmp(audiohook->source, source)) {
1422 count++;
1423 if (clearmute) {
1424 ast_clear_flag(audiohook, flag);
1425 } else {
1426 ast_set_flag(audiohook, flag);
1427 }
1428 }
1429 }
1430
1431 ast_test_suite_event_notify("AUDIOHOOK_GROUP_MUTE_TOGGLE", "Channel: %s\r\nSource: %s\r\nCount: %d\r\n",
1432 ast_channel_name(chan), source, count);
1433
1434 ast_channel_unlock(chan);
1435
1436 return count;
1437}
const char * ast_channel_name(const struct ast_channel *chan)
#define AST_LIST_TRAVERSE(head, var, field)
Loops over (traverses) the entries in a list.
Definition: linkedlists.h:491
#define ast_test_suite_event_notify(s, f,...)
Definition: test.h:189

References ast_channel_audiohooks(), ast_channel_lock, ast_channel_name(), ast_channel_unlock, ast_clear_flag, AST_LIST_TRAVERSE, ast_set_flag, ast_test_suite_event_notify, ast_audiohook::list, NULL, and ast_audiohook::source.

Referenced by manager_mute_mixmonitor().

◆ ast_audiohook_trigger_wait()

void ast_audiohook_trigger_wait ( struct ast_audiohook audiohook)

Wait for audiohook trigger to be triggered.

Parameters
audiohookAudiohook to wait on

Definition at line 1122 of file audiohook.c.

1123{
1124 struct timeval wait;
1125 struct timespec ts;
1126
1127 wait = ast_tvadd(ast_tvnow(), ast_samp2tv(50000, 1000));
1128 ts.tv_sec = wait.tv_sec;
1129 ts.tv_nsec = wait.tv_usec * 1000;
1130
1131 ast_cond_timedwait(&audiohook->trigger, &audiohook->lock, &ts);
1132
1133 return;
1134}
#define ast_cond_timedwait(cond, mutex, time)
Definition: lock.h:206
struct timeval ast_samp2tv(unsigned int _nsamp, unsigned int _rate)
Returns a timeval corresponding to the duration of n samples at rate r. Useful to convert samples to ...
Definition: time.h:282
struct timeval ast_tvadd(struct timeval a, struct timeval b)
Returns the sum of two timevals a + b.
Definition: extconf.c:2282
struct timeval ast_tvnow(void)
Returns current timeval. Meant to replace calls to gettimeofday().
Definition: time.h:159

References ast_cond_timedwait, ast_samp2tv(), ast_tvadd(), ast_tvnow(), ast_audiohook::lock, and ast_audiohook::trigger.

Referenced by ast_audiohook_detach(), and mixmonitor_thread().

◆ ast_audiohook_update_status()

void ast_audiohook_update_status ( struct ast_audiohook audiohook,
enum ast_audiohook_status  status 
)

Update audiohook's status.

Parameters
audiohook
status
Note
once status is updated to DONE, this function can not be used to set the status back to any other setting. Setting DONE effectively locks the status as such.

Definition at line 568 of file audiohook.c.

569{
570 ast_audiohook_lock(audiohook);
571 if (audiohook->status != AST_AUDIOHOOK_STATUS_DONE) {
572 audiohook->status = status;
573 ast_cond_signal(&audiohook->trigger);
574 }
575 ast_audiohook_unlock(audiohook);
576}
jack_status_t status
Definition: app_jack.c:146
#define ast_audiohook_lock(ah)
Lock an audiohook.
Definition: audiohook.h:313
#define ast_audiohook_unlock(ah)
Unlock an audiohook.
Definition: audiohook.h:318
#define ast_cond_signal(cond)
Definition: lock.h:203

References ast_audiohook_lock, AST_AUDIOHOOK_STATUS_DONE, ast_audiohook_unlock, ast_cond_signal, status, ast_audiohook::status, and ast_audiohook::trigger.

Referenced by ast_audiohook_attach(), ast_audiohook_detach(), ast_audiohook_detach_list(), ast_audiohook_detach_source(), ast_audiohook_init(), ast_audiohook_remove(), audio_audiohook_write_list(), dtmf_audiohook_write_list(), and stop_mixmonitor_full().

◆ ast_audiohook_volume_adjust()

int ast_audiohook_volume_adjust ( struct ast_channel chan,
enum ast_audiohook_direction  direction,
int  volume 
)

Adjust the volume on frames read from or written to a channel.

Parameters
chanChannel to muck with
directionDirection to increase
volumeValue to adjust the adjustment by
Return values
0on success
-1on failure
Since
1.6.1

Definition at line 1361 of file audiohook.c.

1362{
1364
1365 /* Attempt to find the audiohook volume information, and create an audiohook if none exists */
1366 if (!(audiohook_volume = audiohook_volume_get(chan, 1))) {
1367 return -1;
1368 }
1369
1370 /* Based on the direction change the specific adjustment value */
1373 }
1376 }
1377
1378 return 0;
1379}
static struct audiohook_volume * audiohook_volume_get(struct ast_channel *chan, int create)
Helper function which finds and optionally creates an audiohook_volume_datastore datastore on a chann...
Definition: audiohook.c:1286
Audiohook volume adjustment structure.
Definition: audiohook.c:1211

References AST_AUDIOHOOK_DIRECTION_BOTH, AST_AUDIOHOOK_DIRECTION_READ, AST_AUDIOHOOK_DIRECTION_WRITE, audiohook_volume_get(), NULL, audiohook_volume::read_adjustment, and audiohook_volume::write_adjustment.

Referenced by execute_menu_entry().

◆ ast_audiohook_volume_get()

int ast_audiohook_volume_get ( struct ast_channel chan,
enum ast_audiohook_direction  direction 
)

Retrieve the volume adjustment value on frames read from or written to a channel.

Parameters
chanChannel to retrieve volume adjustment from
directionDirection to retrieve
Returns
adjustment value
Since
1.6.1

Definition at line 1341 of file audiohook.c.

1342{
1344 int adjustment = 0;
1345
1346 /* Attempt to find the audiohook volume information, but do not create it as we only want to look at the values */
1347 if (!(audiohook_volume = audiohook_volume_get(chan, 0))) {
1348 return 0;
1349 }
1350
1351 /* Grab the adjustment value based on direction given */
1353 adjustment = audiohook_volume->read_adjustment;
1355 adjustment = audiohook_volume->write_adjustment;
1356 }
1357
1358 return adjustment;
1359}

References AST_AUDIOHOOK_DIRECTION_READ, AST_AUDIOHOOK_DIRECTION_WRITE, audiohook_volume_get(), NULL, audiohook_volume::read_adjustment, and audiohook_volume::write_adjustment.

Referenced by confbridge_exec().

◆ ast_audiohook_volume_set()

int ast_audiohook_volume_set ( struct ast_channel chan,
enum ast_audiohook_direction  direction,
int  volume 
)

Adjust the volume on frames read from or written to a channel.

Parameters
chanChannel to muck with
directionDirection to set on
volumeValue to adjust the volume by
Return values
0on success
-1on failure
Since
1.6.1

Definition at line 1321 of file audiohook.c.

1322{
1324
1325 /* Attempt to find the audiohook volume information, but only create it if we are not setting the adjustment value to zero */
1326 if (!(audiohook_volume = audiohook_volume_get(chan, (volume ? 1 : 0)))) {
1327 return -1;
1328 }
1329
1330 /* Now based on the direction set the proper value */
1333 }
1336 }
1337
1338 return 0;
1339}

References AST_AUDIOHOOK_DIRECTION_BOTH, AST_AUDIOHOOK_DIRECTION_READ, AST_AUDIOHOOK_DIRECTION_WRITE, audiohook_volume_get(), NULL, audiohook_volume::read_adjustment, and audiohook_volume::write_adjustment.

Referenced by confbridge_exec(), and execute_menu_entry().

◆ ast_audiohook_write_frame()

int ast_audiohook_write_frame ( struct ast_audiohook audiohook,
enum ast_audiohook_direction  direction,
struct ast_frame frame 
)

Writes a frame into the audiohook structure.

Parameters
audiohook
directionDirection the audio frame came from
frameFrame to write in
Return values
0on success
-1on failure

Definition at line 167 of file audiohook.c.

168{
169 struct ast_slinfactory *factory = (direction == AST_AUDIOHOOK_DIRECTION_READ ? &audiohook->read_factory : &audiohook->write_factory);
170 struct ast_slinfactory *other_factory = (direction == AST_AUDIOHOOK_DIRECTION_READ ? &audiohook->write_factory : &audiohook->read_factory);
171 struct timeval *rwtime = (direction == AST_AUDIOHOOK_DIRECTION_READ ? &audiohook->read_time : &audiohook->write_time), previous_time = *rwtime;
172 int our_factory_samples;
173 int our_factory_ms;
174 int other_factory_samples;
175 int other_factory_ms;
176
177 /* Don't feed the frame if we are set to read and this is a write frame or if set to
178 write and this is a read frame as we don't want it. Plus, it can cause mis-resampling
179 if the READ and WRITE frames have different bitrates */
180 if (audiohook->direction != AST_AUDIOHOOK_DIRECTION_BOTH && audiohook->direction != direction) {
181 return 0;
182 }
183
184 /* Update last feeding time to be current */
185 *rwtime = ast_tvnow();
186
187 our_factory_samples = ast_slinfactory_available(factory);
188 our_factory_ms = ast_tvdiff_ms(*rwtime, previous_time) + (our_factory_samples / (audiohook->hook_internal_samp_rate / 1000));
189 other_factory_samples = ast_slinfactory_available(other_factory);
190 other_factory_ms = other_factory_samples / (audiohook->hook_internal_samp_rate / 1000);
191
192 if (ast_test_flag(audiohook, AST_AUDIOHOOK_TRIGGER_SYNC) && (our_factory_ms - other_factory_ms > AST_AUDIOHOOK_SYNC_TOLERANCE)) {
193 ast_debug(4, "Flushing audiohook %p so it remains in sync\n", audiohook);
194 ast_slinfactory_flush(factory);
195 ast_slinfactory_flush(other_factory);
196 }
197
198 if (ast_test_flag(audiohook, AST_AUDIOHOOK_SMALL_QUEUE) && ((our_factory_ms > AST_AUDIOHOOK_SMALL_QUEUE_TOLERANCE) || (other_factory_ms > AST_AUDIOHOOK_SMALL_QUEUE_TOLERANCE))) {
199 ast_debug(4, "Audiohook %p has stale audio in its factories. Flushing them both\n", audiohook);
200 ast_slinfactory_flush(factory);
201 ast_slinfactory_flush(other_factory);
202 } else if ((our_factory_ms > AST_AUDIOHOOK_LONG_QUEUE_TOLERANCE) || (other_factory_ms > AST_AUDIOHOOK_LONG_QUEUE_TOLERANCE)) {
203 ast_debug(4, "Audiohook %p has stale audio in its factories. Flushing them both\n", audiohook);
204 ast_slinfactory_flush(factory);
205 ast_slinfactory_flush(other_factory);
206 }
207
208 /* Write frame out to respective factory */
209 ast_slinfactory_feed(factory, frame);
210
211 /* If we need to notify the respective handler of this audiohook, do so */
213 ast_cond_signal(&audiohook->trigger);
215 ast_cond_signal(&audiohook->trigger);
216 } else if (ast_test_flag(audiohook, AST_AUDIOHOOK_TRIGGER_SYNC)) {
217 ast_cond_signal(&audiohook->trigger);
218 }
219
220 return 0;
221}
#define AST_AUDIOHOOK_LONG_QUEUE_TOLERANCE
Definition: audiohook.c:46
#define AST_AUDIOHOOK_SYNC_TOLERANCE
Definition: audiohook.c:44
#define AST_AUDIOHOOK_SMALL_QUEUE_TOLERANCE
Definition: audiohook.c:45
unsigned int ast_slinfactory_available(const struct ast_slinfactory *sf)
Retrieve number of samples currently in a slinfactory.
Definition: slinfactory.c:199
void ast_slinfactory_flush(struct ast_slinfactory *sf)
Flush the contents of a slinfactory.
Definition: slinfactory.c:204
int ast_slinfactory_feed(struct ast_slinfactory *sf, struct ast_frame *f)
Feed audio into a slinfactory.
Definition: slinfactory.c:77
struct timeval write_time
Definition: audiohook.h:115
struct timeval read_time
Definition: audiohook.h:114
unsigned int hook_internal_samp_rate
Definition: audiohook.h:120
int64_t ast_tvdiff_ms(struct timeval end, struct timeval start)
Computes the difference (in milliseconds) between two struct timeval instances.
Definition: time.h:107

References AST_AUDIOHOOK_DIRECTION_BOTH, AST_AUDIOHOOK_DIRECTION_READ, AST_AUDIOHOOK_DIRECTION_WRITE, AST_AUDIOHOOK_LONG_QUEUE_TOLERANCE, AST_AUDIOHOOK_SMALL_QUEUE, AST_AUDIOHOOK_SMALL_QUEUE_TOLERANCE, AST_AUDIOHOOK_SYNC_TOLERANCE, AST_AUDIOHOOK_TRIGGER_MODE, AST_AUDIOHOOK_TRIGGER_READ, AST_AUDIOHOOK_TRIGGER_SYNC, AST_AUDIOHOOK_TRIGGER_WRITE, ast_cond_signal, ast_debug, ast_slinfactory_available(), ast_slinfactory_feed(), ast_slinfactory_flush(), ast_test_flag, ast_tvdiff_ms(), ast_tvnow(), ast_audiohook::direction, ast_audiohook::hook_internal_samp_rate, ast_audiohook::read_factory, ast_audiohook::read_time, ast_audiohook::trigger, ast_audiohook::write_factory, and ast_audiohook::write_time.

Referenced by audio_audiohook_write_list(), channel_spy(), do_broadcast(), and snoop_write().

◆ ast_audiohook_write_list()

struct ast_frame * ast_audiohook_write_list ( struct ast_channel chan,
struct ast_audiohook_list audiohook_list,
enum ast_audiohook_direction  direction,
struct ast_frame frame 
)

Pass a frame off to be handled by the audiohook core.

Parameters
chanChannel that the list is coming off of
audiohook_listList of audiohooks
directionDirection frame is coming in from
frameThe frame itself
Returns
frame on success
Return values
NULLon failure

Definition at line 1107 of file audiohook.c.

1108{
1109 /* Pass off frame to it's respective list write function */
1110 if (frame->frametype == AST_FRAME_VOICE) {
1111 return audio_audiohook_write_list(chan, audiohook_list, direction, frame);
1112 } else if (frame->frametype == AST_FRAME_DTMF) {
1113 return dtmf_audiohook_write_list(chan, audiohook_list, direction, frame);
1114 } else {
1115 return frame;
1116 }
1117}
static struct ast_frame * audio_audiohook_write_list(struct ast_channel *chan, struct ast_audiohook_list *audiohook_list, enum ast_audiohook_direction direction, struct ast_frame *frame)
Pass an AUDIO frame off to be handled by the audiohook core.
Definition: audiohook.c:942
static struct ast_frame * dtmf_audiohook_write_list(struct ast_channel *chan, struct ast_audiohook_list *audiohook_list, enum ast_audiohook_direction direction, struct ast_frame *frame)
Pass a DTMF frame off to be handled by the audiohook core.
Definition: audiohook.c:786
#define AST_FRAME_DTMF
@ AST_FRAME_VOICE
enum ast_frame_type frametype

References AST_FRAME_DTMF, AST_FRAME_VOICE, audio_audiohook_write_list(), dtmf_audiohook_write_list(), and ast_frame::frametype.

Referenced by __ast_read(), and ast_write_stream().

◆ ast_audiohook_write_list_empty()

int ast_audiohook_write_list_empty ( struct ast_audiohook_list audiohook_list)

Determine if a audiohook_list is empty or not.

Parameters
audiohook_listAudiohook to check. (NULL also means empty)
Return values
0false
1true

Definition at line 1099 of file audiohook.c.

1100{
1101 return !audiohook_list
1102 || (AST_LIST_EMPTY(&audiohook_list->spy_list)
1103 && AST_LIST_EMPTY(&audiohook_list->whisper_list)
1104 && AST_LIST_EMPTY(&audiohook_list->manipulate_list));
1105}
#define AST_LIST_EMPTY(head)
Checks whether the specified list contains any entries.
Definition: linkedlists.h:450

References AST_LIST_EMPTY, ast_audiohook_list::manipulate_list, ast_audiohook_list::spy_list, and ast_audiohook_list::whisper_list.

Referenced by __ast_read(), ast_channel_has_audio_frame_or_monitor(), ast_channel_has_hook_requiring_audio(), and ast_write_stream().

◆ ast_channel_audiohook_count_by_source()

int ast_channel_audiohook_count_by_source ( struct ast_channel chan,
const char *  source,
enum ast_audiohook_type  type 
)

Find out how many audiohooks from a certain source exist on a given channel, regardless of status.

Parameters
chanThe channel on which to find the spies
sourceThe audiohook's source
typeThe type of audiohook
Returns
number of audiohooks which are from the source specified

Note: Function performs nlocking.

Definition at line 1137 of file audiohook.c.

1138{
1139 int count = 0;
1140 struct ast_audiohook *ah = NULL;
1141
1142 if (!ast_channel_audiohooks(chan)) {
1143 return -1;
1144 }
1145
1146 switch (type) {
1148 AST_LIST_TRAVERSE(&ast_channel_audiohooks(chan)->spy_list, ah, list) {
1149 if (!strcmp(ah->source, source)) {
1150 count++;
1151 }
1152 }
1153 break;
1155 AST_LIST_TRAVERSE(&ast_channel_audiohooks(chan)->whisper_list, ah, list) {
1156 if (!strcmp(ah->source, source)) {
1157 count++;
1158 }
1159 }
1160 break;
1162 AST_LIST_TRAVERSE(&ast_channel_audiohooks(chan)->manipulate_list, ah, list) {
1163 if (!strcmp(ah->source, source)) {
1164 count++;
1165 }
1166 }
1167 break;
1168 default:
1169 ast_debug(1, "Invalid audiohook type supplied, (%u)\n", type);
1170 return -1;
1171 }
1172
1173 return count;
1174}

References AST_AUDIOHOOK_TYPE_MANIPULATE, AST_AUDIOHOOK_TYPE_SPY, AST_AUDIOHOOK_TYPE_WHISPER, ast_channel_audiohooks(), ast_debug, AST_LIST_TRAVERSE, ast_audiohook::list, NULL, ast_audiohook::source, and type.

Referenced by feature_automixmonitor().

◆ ast_channel_audiohook_count_by_source_running()

int ast_channel_audiohook_count_by_source_running ( struct ast_channel chan,
const char *  source,
enum ast_audiohook_type  type 
)

Find out how many spies of a certain type exist on a given channel, and are in state running.

Parameters
chanThe channel on which to find the spies
sourceThe source of the audiohook
typeThe type of spy to look for
Returns
number of running audiohooks which are from the source specified

Note: Function performs no locking.

Definition at line 1177 of file audiohook.c.

1178{
1179 int count = 0;
1180 struct ast_audiohook *ah = NULL;
1181 if (!ast_channel_audiohooks(chan))
1182 return -1;
1183
1184 switch (type) {
1186 AST_LIST_TRAVERSE(&ast_channel_audiohooks(chan)->spy_list, ah, list) {
1187 if ((!strcmp(ah->source, source)) && (ah->status == AST_AUDIOHOOK_STATUS_RUNNING))
1188 count++;
1189 }
1190 break;
1192 AST_LIST_TRAVERSE(&ast_channel_audiohooks(chan)->whisper_list, ah, list) {
1193 if ((!strcmp(ah->source, source)) && (ah->status == AST_AUDIOHOOK_STATUS_RUNNING))
1194 count++;
1195 }
1196 break;
1198 AST_LIST_TRAVERSE(&ast_channel_audiohooks(chan)->manipulate_list, ah, list) {
1199 if ((!strcmp(ah->source, source)) && (ah->status == AST_AUDIOHOOK_STATUS_RUNNING))
1200 count++;
1201 }
1202 break;
1203 default:
1204 ast_debug(1, "Invalid audiohook type supplied, (%u)\n", type);
1205 return -1;
1206 }
1207 return count;
1208}

References AST_AUDIOHOOK_STATUS_RUNNING, AST_AUDIOHOOK_TYPE_MANIPULATE, AST_AUDIOHOOK_TYPE_SPY, AST_AUDIOHOOK_TYPE_WHISPER, ast_channel_audiohooks(), ast_debug, AST_LIST_TRAVERSE, ast_audiohook::list, NULL, ast_audiohook::source, ast_audiohook::status, and type.