CHANGES: Update changes log to include r403414 entry
[asterisk/asterisk.git] / apps / app_meetme.c
1 /*
2  * Asterisk -- An open source telephony toolkit.
3  *
4  * Copyright (C) 1999 - 2007, Digium, Inc.
5  *
6  * Mark Spencer <markster@digium.com>
7  *
8  * SLA Implementation by:
9  * Russell Bryant <russell@digium.com>
10  *
11  * See http://www.asterisk.org for more information about
12  * the Asterisk project. Please do not directly contact
13  * any of the maintainers of this project for assistance;
14  * the project provides a web site, mailing lists and IRC
15  * channels for your use.
16  *
17  * This program is free software, distributed under the terms of
18  * the GNU General Public License Version 2. See the LICENSE file
19  * at the top of the source tree.
20  */
21
22 /*! \file
23  *
24  * \brief Meet me conference bridge and Shared Line Appearances
25  *
26  * \author Mark Spencer <markster@digium.com>
27  * \author (SLA) Russell Bryant <russell@digium.com>
28  * 
29  * \ingroup applications
30  */
31
32 /*! \li \ref app_meetme.c uses configuration file \ref meetme.conf
33  * \addtogroup configuration_file Configuration Files
34  */
35
36 /*! 
37  * \page meetme.conf meetme.conf
38  * \verbinclude meetme.conf.sample
39  */
40
41 /*** MODULEINFO
42         <depend>dahdi</depend>
43         <defaultenabled>no</defaultenabled>
44         <support_level>extended</support_level>
45         <replacement>app_confbridge</replacement>
46  ***/
47
48 #include "asterisk.h"
49
50 ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
51
52 #include <dahdi/user.h>
53
54 #include "asterisk/lock.h"
55 #include "asterisk/file.h"
56 #include "asterisk/channel.h"
57 #include "asterisk/pbx.h"
58 #include "asterisk/module.h"
59 #include "asterisk/config.h"
60 #include "asterisk/app.h"
61 #include "asterisk/dsp.h"
62 #include "asterisk/musiconhold.h"
63 #include "asterisk/manager.h"
64 #include "asterisk/cli.h"
65 #include "asterisk/say.h"
66 #include "asterisk/utils.h"
67 #include "asterisk/translate.h"
68 #include "asterisk/ulaw.h"
69 #include "asterisk/astobj2.h"
70 #include "asterisk/devicestate.h"
71 #include "asterisk/dial.h"
72 #include "asterisk/causes.h"
73 #include "asterisk/paths.h"
74 #include "asterisk/data.h"
75 #include "asterisk/test.h"
76 #include "asterisk/stasis.h"
77 #include "asterisk/stasis_channels.h"
78 #include "asterisk/stasis_message_router.h"
79 #include "asterisk/json.h"
80
81 #include "enter.h"
82 #include "leave.h"
83
84 /*** DOCUMENTATION
85         <application name="MeetMe" language="en_US">
86                 <synopsis>
87                         MeetMe conference bridge.
88                 </synopsis>
89                 <syntax>
90                         <parameter name="confno">
91                                 <para>The conference number</para>
92                         </parameter>
93                         <parameter name="options">
94                                 <optionlist>
95                                         <option name="a">
96                                                 <para>Set admin mode.</para>
97                                         </option>
98                                         <option name="A">
99                                                 <para>Set marked mode.</para>
100                                         </option>
101                                         <option name="b">
102                                                 <para>Run AGI script specified in <variable>MEETME_AGI_BACKGROUND</variable>
103                                                 Default: <literal>conf-background.agi</literal>.</para>
104                                                 <note><para>This does not work with non-DAHDI channels in the same
105                                                 conference).</para></note>
106                                         </option>
107                                         <option name="c">
108                                                 <para>Announce user(s) count on joining a conference.</para>
109                                         </option>
110                                         <option name="C">
111                                                 <para>Continue in dialplan when kicked out of conference.</para>
112                                         </option>
113                                         <option name="d">
114                                                 <para>Dynamically add conference.</para>
115                                         </option>
116                                         <option name="D">
117                                                 <para>Dynamically add conference, prompting for a PIN.</para>
118                                         </option>
119                                         <option name="e">
120                                                 <para>Select an empty conference.</para>
121                                         </option>
122                                         <option name="E">
123                                                 <para>Select an empty pinless conference.</para>
124                                         </option>
125                                         <option name="F">
126                                                 <para>Pass DTMF through the conference.</para>
127                                         </option>
128                                         <option name="G">
129                                                 <argument name="x" required="true">
130                                                         <para>The file to playback</para>
131                                                 </argument>
132                                                 <para>Play an intro announcement in conference.</para>
133                                         </option>
134                                         <option name="i">
135                                                 <para>Announce user join/leave with review.</para>
136                                         </option>
137                                         <option name="I">
138                                                 <para>Announce user join/leave without review.</para>
139                                         </option>
140                                         <option name="k">
141                                                 <para>Close the conference if there's only one active participant left at exit.</para>
142                                         </option>
143                                         <option name="l">
144                                                 <para>Set listen only mode (Listen only, no talking).</para>
145                                         </option>
146                                         <option name="m">
147                                                 <para>Set initially muted.</para>
148                                         </option>
149                                         <option name="M" hasparams="optional">
150                                                 <para>Enable music on hold when the conference has a single caller. Optionally,
151                                                 specify a musiconhold class to use. If one is not provided, it will use the
152                                                 channel's currently set music class, or <literal>default</literal>.</para>
153                                                 <argument name="class" required="true" />
154                                         </option>
155                                         <option name="n">
156                                                 <para>Disable the denoiser. By default, if <literal>func_speex</literal> is loaded, Asterisk
157                                                 will apply a denoiser to channels in the MeetMe conference. However, channel
158                                                 drivers that present audio with a varying rate will experience degraded
159                                                 performance with a denoiser attached. This parameter allows a channel joining
160                                                 the conference to choose not to have a denoiser attached without having to
161                                                 unload <literal>func_speex</literal>.</para>
162                                         </option>
163                                         <option name="o">
164                                                 <para>Set talker optimization - treats talkers who aren't speaking as
165                                                 being muted, meaning (a) No encode is done on transmission and (b)
166                                                 Received audio that is not registered as talking is omitted causing no
167                                                 buildup in background noise.</para>
168                                         </option>
169                                         <option name="p" hasparams="optional">
170                                                 <para>Allow user to exit the conference by pressing <literal>#</literal> (default)
171                                                 or any of the defined keys. Dial plan execution will continue at the next
172                                                 priority following MeetMe. The key used is set to channel variable
173                                                 <variable>MEETME_EXIT_KEY</variable>.</para>
174                                                 <argument name="keys" required="true" />
175                                                 <note>
176                                                         <para>Option <literal>s</literal> has priority for <literal>*</literal>
177                                                         since it cannot change its activation code.</para>
178                                                 </note>
179                                         </option>
180                                         <option name="P">
181                                                 <para>Always prompt for the pin even if it is specified.</para>
182                                         </option>
183                                         <option name="q">
184                                                 <para>Quiet mode (don't play enter/leave sounds).</para>
185                                         </option>
186                                         <option name="r">
187                                                 <para>Record conference (records as <variable>MEETME_RECORDINGFILE</variable>
188                                                 using format <variable>MEETME_RECORDINGFORMAT</variable>. Default filename is
189                                                 <literal>meetme-conf-rec-${CONFNO}-${UNIQUEID}</literal> and the default format is
190                                                 wav.</para>
191                                         </option>
192                                         <option name="s">
193                                                 <para>Present menu (user or admin) when <literal>*</literal> is received
194                                                 (send to menu).</para>
195                                         </option>
196                                         <option name="t">
197                                                 <para>Set talk only mode. (Talk only, no listening).</para>
198                                         </option>
199                                         <option name="T">
200                                                 <para>Set talker detection (sent to manager interface and meetme list).</para>
201                                         </option>
202                                         <option name="v" hasparams="optional">
203                                                 <para>Announce when a user is joining or leaving the conference.  Use the voicemail greeting as the announcement.
204                                                  If the i or I options are set, the application will fall back to them if no voicemail greeting can be found.</para>
205                                                 <argument name="mailbox@[context]" required="true">
206                                                         <para>The mailbox and voicemail context to play from.  If no context provided, assumed context is default.</para>
207                                                 </argument>
208                                         </option>
209                                         <option name="w" hasparams="optional">
210                                                 <para>Wait until the marked user enters the conference.</para>
211                                                 <argument name="secs" required="true" />
212                                         </option>
213                                         <option name="x">
214                                                 <para>Leave the conference when the last marked user leaves.</para>
215                                         </option>
216                                         <option name="X">
217                                                 <para>Allow user to exit the conference by entering a valid single digit
218                                                 extension <variable>MEETME_EXIT_CONTEXT</variable> or the current context
219                                                 if that variable is not defined.</para>
220                                                 <note>
221                                                         <para>Option <literal>s</literal> has priority for <literal>*</literal>
222                                                         since it cannot change its activation code.</para>
223                                                 </note>
224                                         </option>
225                                         <option name="1">
226                                                 <para>Do not play message when first person enters</para>
227                                         </option>
228                                         <option name="S">
229                                                 <para>Kick the user <replaceable>x</replaceable> seconds <emphasis>after</emphasis> he entered into
230                                                 the conference.</para>
231                                                 <argument name="x" required="true" />
232                                         </option>
233                                         <option name="L" argsep=":">
234                                                 <para>Limit the conference to <replaceable>x</replaceable> ms. Play a warning when
235                                                 <replaceable>y</replaceable> ms are left. Repeat the warning every <replaceable>z</replaceable> ms.
236                                                 The following special variables can be used with this option:</para>
237                                                 <variablelist>
238                                                         <variable name="CONF_LIMIT_TIMEOUT_FILE">
239                                                                 <para>File to play when time is up.</para>
240                                                         </variable>
241                                                         <variable name="CONF_LIMIT_WARNING_FILE">
242                                                                 <para>File to play as warning if <replaceable>y</replaceable> is defined. The
243                                                                 default is to say the time remaining.</para>
244                                                         </variable>
245                                                 </variablelist>
246                                                 <argument name="x" />
247                                                 <argument name="y" />
248                                                 <argument name="z" />
249                                         </option>
250                                 </optionlist>
251                         </parameter>
252                         <parameter name="pin" />
253                 </syntax>
254                 <description>
255                         <para>Enters the user into a specified MeetMe conference.  If the <replaceable>confno</replaceable>
256                         is omitted, the user will be prompted to enter one.  User can exit the conference by hangup, or
257                         if the <literal>p</literal> option is specified, by pressing <literal>#</literal>.</para>
258                         <note><para>The DAHDI kernel modules and a functional DAHDI timing source (see dahdi_test)
259                         must be present for conferencing to operate properly. In addition, the chan_dahdi channel driver
260                         must be loaded for the <literal>i</literal> and <literal>r</literal> options to operate at
261                         all.</para></note>
262                 </description>
263                 <see-also>
264                         <ref type="application">MeetMeCount</ref>
265                         <ref type="application">MeetMeAdmin</ref>
266                         <ref type="application">MeetMeChannelAdmin</ref>
267                 </see-also>
268         </application>
269         <application name="MeetMeCount" language="en_US">
270                 <synopsis>
271                         MeetMe participant count.
272                 </synopsis>
273                 <syntax>
274                         <parameter name="confno" required="true">
275                                 <para>Conference number.</para>
276                         </parameter>
277                         <parameter name="var" />
278                 </syntax>
279                 <description>
280                         <para>Plays back the number of users in the specified MeetMe conference.
281                         If <replaceable>var</replaceable> is specified, playback will be skipped and the value
282                         will be returned in the variable. Upon application completion, MeetMeCount will hangup
283                         the channel, unless priority <literal>n+1</literal> exists, in which case priority progress will
284                         continue.</para>
285                 </description>
286                 <see-also>
287                         <ref type="application">MeetMe</ref>
288                 </see-also>
289         </application>
290         <application name="MeetMeAdmin" language="en_US">
291                 <synopsis>
292                         MeetMe conference administration.
293                 </synopsis>
294                 <syntax>
295                         <parameter name="confno" required="true" />
296                         <parameter name="command" required="true">
297                                 <optionlist>
298                                         <option name="e">
299                                                 <para>Eject last user that joined.</para>
300                                         </option>
301                                         <option name="E">
302                                                 <para>Extend conference end time, if scheduled.</para>
303                                         </option>
304                                         <option name="k">
305                                                 <para>Kick one user out of conference.</para>
306                                         </option>
307                                         <option name="K">
308                                                 <para>Kick all users out of conference.</para>
309                                         </option>
310                                         <option name="l">
311                                                 <para>Unlock conference.</para>
312                                         </option>
313                                         <option name="L">
314                                                 <para>Lock conference.</para>
315                                         </option>
316                                         <option name="m">
317                                                 <para>Unmute one user.</para>
318                                         </option>
319                                         <option name="M">
320                                                 <para>Mute one user.</para>
321                                         </option>
322                                         <option name="n">
323                                                 <para>Unmute all users in the conference.</para>
324                                         </option>
325                                         <option name="N">
326                                                 <para>Mute all non-admin users in the conference.</para>
327                                         </option>
328                                         <option name="r">
329                                                 <para>Reset one user's volume settings.</para>
330                                         </option>
331                                         <option name="R">
332                                                 <para>Reset all users volume settings.</para>
333                                         </option>
334                                         <option name="s">
335                                                 <para>Lower entire conference speaking volume.</para>
336                                         </option>
337                                         <option name="S">
338                                                 <para>Raise entire conference speaking volume.</para>
339                                         </option>
340                                         <option name="t">
341                                                 <para>Lower one user's talk volume.</para>
342                                         </option>
343                                         <option name="T">
344                                                 <para>Raise one user's talk volume.</para>
345                                         </option>
346                                         <option name="u">
347                                                 <para>Lower one user's listen volume.</para>
348                                         </option>
349                                         <option name="U">
350                                                 <para>Raise one user's listen volume.</para>
351                                         </option>
352                                         <option name="v">
353                                                 <para>Lower entire conference listening volume.</para>
354                                         </option>
355                                         <option name="V">
356                                                 <para>Raise entire conference listening volume.</para>
357                                         </option>
358                                 </optionlist>
359                         </parameter>
360                         <parameter name="user" />
361                 </syntax>
362                 <description>
363                         <para>Run admin <replaceable>command</replaceable> for conference <replaceable>confno</replaceable>.</para>
364                         <para>Will additionally set the variable <variable>MEETMEADMINSTATUS</variable> with one of
365                         the following values:</para>
366                         <variablelist>
367                                 <variable name="MEETMEADMINSTATUS">
368                                         <value name="NOPARSE">
369                                                 Invalid arguments.
370                                         </value>
371                                         <value name="NOTFOUND">
372                                                 User specified was not found.
373                                         </value>
374                                         <value name="FAILED">
375                                                 Another failure occurred.
376                                         </value>
377                                         <value name="OK">
378                                                 The operation was completed successfully.
379                                         </value>
380                                 </variable>
381                         </variablelist>
382                 </description>
383                 <see-also>
384                         <ref type="application">MeetMe</ref>
385                 </see-also>
386         </application>
387         <application name="MeetMeChannelAdmin" language="en_US">
388                 <synopsis>
389                         MeetMe conference Administration (channel specific).
390                 </synopsis>
391                 <syntax>
392                         <parameter name="channel" required="true" />
393                         <parameter name="command" required="true">
394                                 <optionlist>
395                                         <option name="k">
396                                                 <para>Kick the specified user out of the conference he is in.</para>
397                                         </option>
398                                         <option name="m">
399                                                 <para>Unmute the specified user.</para>
400                                         </option>
401                                         <option name="M">
402                                                 <para>Mute the specified user.</para>
403                                         </option>
404                                 </optionlist>
405                         </parameter>
406                 </syntax>
407                 <description>
408                         <para>Run admin <replaceable>command</replaceable> for a specific
409                         <replaceable>channel</replaceable> in any conference.</para>
410                 </description>
411         </application>
412         <application name="SLAStation" language="en_US">
413                 <synopsis>
414                         Shared Line Appearance Station.
415                 </synopsis>
416                 <syntax>
417                         <parameter name="station" required="true">
418                                 <para>Station name</para>
419                         </parameter>
420                 </syntax>
421                 <description>
422                         <para>This application should be executed by an SLA station. The argument depends
423                         on how the call was initiated. If the phone was just taken off hook, then the argument
424                         <replaceable>station</replaceable> should be just the station name. If the call was
425                         initiated by pressing a line key, then the station name should be preceded by an underscore
426                         and the trunk name associated with that line button.</para>
427                         <para>For example: <literal>station1_line1</literal></para>
428                         <para>On exit, this application will set the variable <variable>SLASTATION_STATUS</variable> to
429                         one of the following values:</para>
430                         <variablelist>
431                                 <variable name="SLASTATION_STATUS">
432                                         <value name="FAILURE" />
433                                         <value name="CONGESTION" />
434                                         <value name="SUCCESS" />
435                                 </variable>
436                         </variablelist>
437                 </description>
438         </application>
439         <application name="SLATrunk" language="en_US">
440                 <synopsis>
441                         Shared Line Appearance Trunk.
442                 </synopsis>
443                 <syntax>
444                         <parameter name="trunk" required="true">
445                                 <para>Trunk name</para>
446                         </parameter>
447                         <parameter name="options">
448                                 <optionlist>
449                                         <option name="M" hasparams="optional">
450                                                 <para>Play back the specified MOH <replaceable>class</replaceable>
451                                                 instead of ringing</para>
452                                                 <argument name="class" required="true" />
453                                         </option>
454                                 </optionlist>
455                         </parameter>
456                 </syntax>
457                 <description>
458                         <para>This application should be executed by an SLA trunk on an inbound call. The channel calling
459                         this application should correspond to the SLA trunk with the name <replaceable>trunk</replaceable>
460                         that is being passed as an argument.</para>
461                         <para>On exit, this application will set the variable <variable>SLATRUNK_STATUS</variable> to
462                         one of the following values:</para>
463                         <variablelist>
464                                 <variable name="SLATRUNK_STATUS">
465                                         <value name="FAILURE" />
466                                         <value name="SUCCESS" />
467                                         <value name="UNANSWERED" />
468                                         <value name="RINGTIMEOUT" />
469                                 </variable>
470                         </variablelist>
471                 </description>
472         </application>
473         <function name="MEETME_INFO" language="en_US">
474                 <synopsis>
475                         Query a given conference of various properties.
476                 </synopsis>
477                 <syntax>
478                         <parameter name="keyword" required="true">
479                                 <para>Options:</para>
480                                 <enumlist>
481                                         <enum name="lock">
482                                                 <para>Boolean of whether the corresponding conference is locked.</para>
483                                         </enum>
484                                         <enum name="parties">
485                                                 <para>Number of parties in a given conference</para>
486                                         </enum>
487                                         <enum name="activity">
488                                                 <para>Duration of conference in seconds.</para>
489                                         </enum>
490                                         <enum name="dynamic">
491                                                 <para>Boolean of whether the corresponding conference is dynamic.</para>
492                                         </enum>
493                                 </enumlist>
494                         </parameter>
495                         <parameter name="confno" required="true">
496                                 <para>Conference number to retrieve information from.</para>
497                         </parameter>
498                 </syntax>
499                 <description />
500                 <see-also>
501                         <ref type="application">MeetMe</ref>
502                         <ref type="application">MeetMeCount</ref>
503                         <ref type="application">MeetMeAdmin</ref>
504                         <ref type="application">MeetMeChannelAdmin</ref>
505                 </see-also>
506         </function>
507         <manager name="MeetmeMute" language="en_US">
508                 <synopsis>
509                         Mute a Meetme user.
510                 </synopsis>
511                 <syntax>
512                         <xi:include xpointer="xpointer(/docs/manager[@name='Login']/syntax/parameter[@name='ActionID'])" />
513                         <parameter name="Meetme" required="true" />
514                         <parameter name="Usernum" required="true" />
515                 </syntax>
516                 <description>
517                 </description>
518         </manager>
519         <manager name="MeetmeUnmute" language="en_US">
520                 <synopsis>
521                         Unmute a Meetme user.
522                 </synopsis>
523                 <syntax>
524                         <xi:include xpointer="xpointer(/docs/manager[@name='Login']/syntax/parameter[@name='ActionID'])" />
525                         <parameter name="Meetme" required="true" />
526                         <parameter name="Usernum" required="true" />
527                 </syntax>
528                 <description>
529                 </description>
530         </manager>
531         <manager name="MeetmeList" language="en_US">
532                 <synopsis>
533                         List participants in a conference.
534                 </synopsis>
535                 <syntax>
536                         <xi:include xpointer="xpointer(/docs/manager[@name='Login']/syntax/parameter[@name='ActionID'])" />
537                         <parameter name="Conference" required="false">
538                                 <para>Conference number.</para>
539                         </parameter>
540                 </syntax>
541                 <description>
542                         <para>Lists all users in a particular MeetMe conference.
543                         MeetmeList will follow as separate events, followed by a final event called
544                         MeetmeListComplete.</para>
545                 </description>
546         </manager>
547         <manager name="MeetmeListRooms" language="en_US">
548                 <synopsis>
549                         List active conferences.
550                 </synopsis>
551                 <syntax>
552                         <xi:include xpointer="xpointer(/docs/manager[@name='Login']/syntax/parameter[@name='ActionID'])" />
553                 </syntax>
554                 <description>
555                         <para>Lists data about all active conferences.
556                                 MeetmeListRooms will follow as separate events, followed by a final event called
557                                 MeetmeListRoomsComplete.</para>
558                 </description>
559         </manager>
560         <managerEvent language="en_US" name="MeetmeJoin">
561                 <managerEventInstance class="EVENT_FLAG_CALL">
562                         <synopsis>Raised when a user joins a MeetMe conference.</synopsis>
563                         <syntax>
564                                 <parameter name="Meetme">
565                                         <para>The identifier for the MeetMe conference.</para>
566                                 </parameter>
567                                 <parameter name="Usernum">
568                                         <para>The identifier of the MeetMe user who joined.</para>
569                                 </parameter>
570                                 <channel_snapshot/>
571                         </syntax>
572                         <see-also>
573                                 <ref type="managerEvent">MeetmeLeave</ref>
574                                 <ref type="application">MeetMe</ref>
575                         </see-also>
576                 </managerEventInstance>
577         </managerEvent>
578         <managerEvent language="en_US" name="MeetmeLeave">
579                 <managerEventInstance class="EVENT_FLAG_CALL">
580                         <synopsis>Raised when a user leaves a MeetMe conference.</synopsis>
581                         <syntax>
582                                 <xi:include xpointer="xpointer(/docs/managerEvent[@name='MeetmeJoin']/managerEventInstance/syntax/parameter)" />
583                                 <channel_snapshot/>
584                                 <parameter name="Duration">
585                                         <para>The length of time in seconds that the Meetme user was in the conference.</para>
586                                 </parameter>
587                         </syntax>
588                         <see-also>
589                                 <ref type="managerEvent">MeetmeJoin</ref>
590                         </see-also>
591                 </managerEventInstance>
592         </managerEvent>
593         <managerEvent language="en_US" name="MeetmeEnd">
594                 <managerEventInstance class="EVENT_FLAG_CALL">
595                         <synopsis>Raised when a MeetMe conference ends.</synopsis>
596                         <syntax>
597                                 <xi:include xpointer="xpointer(/docs/managerEvent[@name='MeetmeJoin']/managerEventInstance/syntax/parameter[@name='Meetme'])" />
598                         </syntax>
599                         <see-also>
600                                 <ref type="managerEvent">MeetmeJoin</ref>
601                         </see-also>
602                 </managerEventInstance>
603         </managerEvent>
604         <managerEvent language="en_US" name="MeetmeTalkRequest">
605                 <managerEventInstance class="EVENT_FLAG_CALL">
606                         <synopsis>Raised when a MeetMe user has started talking.</synopsis>
607                         <syntax>
608                                 <xi:include xpointer="xpointer(/docs/managerEvent[@name='MeetmeJoin']/managerEventInstance/syntax/parameter)" />
609                                 <channel_snapshot/>
610                                 <parameter name="Duration">
611                                         <para>The length of time in seconds that the Meetme user has been in the conference at the time of this event.</para>
612                                 </parameter>
613                                 <parameter name="Status">
614                                         <enumlist>
615                                                 <enum name="on"/>
616                                                 <enum name="off"/>
617                                         </enumlist>
618                                 </parameter>
619                         </syntax>
620                 </managerEventInstance>
621         </managerEvent>
622         <managerEvent language="en_US" name="MeetmeTalking">
623                 <managerEventInstance class="EVENT_FLAG_CALL">
624                         <synopsis>Raised when a MeetMe user begins or ends talking.</synopsis>
625                         <syntax>
626                                 <xi:include xpointer="xpointer(/docs/managerEvent[@name='MeetmeJoin']/managerEventInstance/syntax/parameter)" />
627                                 <channel_snapshot/>
628                                 <xi:include xpointer="xpointer(/docs/managerEvent[@name='MeetmeTalkRequest']/managerEventInstance/syntax/parameter)" />
629                         </syntax>
630                 </managerEventInstance>
631         </managerEvent>
632         <managerEvent language="en_US" name="MeetmeMute">
633                 <managerEventInstance class="EVENT_FLAG_CALL">
634                         <synopsis>Raised when a MeetMe user is muted or unmuted.</synopsis>
635                         <syntax>
636                                 <xi:include xpointer="xpointer(/docs/managerEvent[@name='MeetmeJoin']/managerEventInstance/syntax/parameter)" />
637                                 <channel_snapshot/>
638                                 <xi:include xpointer="xpointer(/docs/managerEvent[@name='MeetmeTalkRequest']/managerEventInstance/syntax/parameter)" />
639                         </syntax>
640                 </managerEventInstance>
641         </managerEvent>
642  ***/
643
644 #define CONFIG_FILE_NAME        "meetme.conf"
645 #define SLA_CONFIG_FILE         "sla.conf"
646 #define STR_CONCISE                     "concise"
647
648 /*! each buffer is 20ms, so this is 640ms total */
649 #define DEFAULT_AUDIO_BUFFERS  32
650
651 /*! String format for scheduled conferences */
652 #define DATE_FORMAT "%Y-%m-%d %H:%M:%S"
653
654 enum {
655         ADMINFLAG_MUTED =     (1 << 1), /*!< User is muted */
656         ADMINFLAG_SELFMUTED = (1 << 2), /*!< User muted self */
657         ADMINFLAG_KICKME =    (1 << 3),  /*!< User has been kicked */
658         /*! User has requested to speak */
659         ADMINFLAG_T_REQUEST = (1 << 4),
660         ADMINFLAG_HANGUP = (1 << 5),    /*!< User will be leaving the conference */
661 };
662
663 #define MEETME_DELAYDETECTTALK     300
664 #define MEETME_DELAYDETECTENDTALK  1000
665
666 #define AST_FRAME_BITS  32
667
668 enum volume_action {
669         VOL_UP,
670         VOL_DOWN
671 };
672
673 enum entrance_sound {
674         ENTER,
675         LEAVE
676 };
677
678 enum recording_state {
679         MEETME_RECORD_OFF,
680         MEETME_RECORD_STARTED,
681         MEETME_RECORD_ACTIVE,
682         MEETME_RECORD_TERMINATE
683 };
684
685 #define CONF_SIZE  320
686
687 enum {
688         /*! user has admin access on the conference */
689         CONFFLAG_ADMIN = (1 << 0),
690         /*! If set the user can only receive audio from the conference */
691         CONFFLAG_MONITOR = (1 << 1),
692         /*! If set asterisk will exit conference when key defined in p() option is pressed */
693         CONFFLAG_KEYEXIT = (1 << 2),
694         /*! If set asterisk will provide a menu to the user when '*' is pressed */
695         CONFFLAG_STARMENU = (1 << 3),
696         /*! If set the use can only send audio to the conference */
697         CONFFLAG_TALKER = (1 << 4),
698         /*! If set there will be no enter or leave sounds */
699         CONFFLAG_QUIET = (1 << 5),
700         /*! If set, when user joins the conference, they will be told the number 
701          *  of users that are already in */
702         CONFFLAG_ANNOUNCEUSERCOUNT = (1 << 6),
703         /*! Set to run AGI Script in Background */
704         CONFFLAG_AGI = (1 << 7),
705         /*! Set to have music on hold when user is alone in conference */
706         CONFFLAG_MOH = (1 << 8),
707         /*! If set, the channel will leave the conference if all marked users leave */
708         CONFFLAG_MARKEDEXIT = (1 << 9),
709         /*! If set, the MeetMe will wait until a marked user enters */
710         CONFFLAG_WAITMARKED = (1 << 10),
711         /*! If set, the MeetMe will exit to the specified context */
712         CONFFLAG_EXIT_CONTEXT = (1 << 11),
713         /*! If set, the user will be marked */
714         CONFFLAG_MARKEDUSER = (1 << 12),
715         /*! If set, user will be ask record name on entry of conference */
716         CONFFLAG_INTROUSER = (1 << 13),
717         /*! If set, the MeetMe will be recorded */
718         CONFFLAG_RECORDCONF = (1<< 14),
719         /*! If set, the user will be monitored if the user is talking or not */
720         CONFFLAG_MONITORTALKER = (1 << 15),
721         CONFFLAG_DYNAMIC = (1 << 16),
722         CONFFLAG_DYNAMICPIN = (1 << 17),
723         CONFFLAG_EMPTY = (1 << 18),
724         CONFFLAG_EMPTYNOPIN = (1 << 19),
725         CONFFLAG_ALWAYSPROMPT = (1 << 20),
726         /*! If set, treat talking users as muted users */
727         CONFFLAG_OPTIMIZETALKER = (1 << 21),
728         /*! If set, won't speak the extra prompt when the first person 
729          *  enters the conference */
730         CONFFLAG_NOONLYPERSON = (1 << 22),
731         /*! If set, user will be asked to record name on entry of conference 
732          *  without review */
733         CONFFLAG_INTROUSERNOREVIEW = (1 << 23),
734         /*! If set, the user will be initially self-muted */
735         CONFFLAG_STARTMUTED = (1 << 24),
736         /*! Pass DTMF through the conference */
737         CONFFLAG_PASS_DTMF = (1 << 25),
738         CONFFLAG_SLA_STATION = (1 << 26),
739         CONFFLAG_SLA_TRUNK = (1 << 27),
740         /*! If set, the user should continue in the dialplan if kicked out */
741         CONFFLAG_KICK_CONTINUE = (1 << 28),
742         CONFFLAG_DURATION_STOP = (1 << 29),
743         CONFFLAG_DURATION_LIMIT = (1 << 30),
744 };
745
746 /* These flags are defined separately because we ran out of bits that an enum can be used to represent. 
747    If you add new flags, be sure to do it in the same way that these are. */
748 /*! Do not write any audio to this channel until the state is up. */
749 #define CONFFLAG_NO_AUDIO_UNTIL_UP  (1ULL << 31)
750 #define CONFFLAG_INTROMSG           (1ULL << 32) /*!< If set play an intro announcement at start of conference */
751 #define CONFFLAG_INTROUSER_VMREC    (1ULL << 33)
752 /*! If there's only one person left in a conference when someone leaves, kill the conference */
753 #define CONFFLAG_KILL_LAST_MAN_STANDING (1ULL << 34)
754 /*! If set, don't enable a denoiser for the channel */
755 #define CONFFLAG_DONT_DENOISE       (1ULL << 35)
756
757 enum {
758         OPT_ARG_WAITMARKED = 0,
759         OPT_ARG_EXITKEYS   = 1,
760         OPT_ARG_DURATION_STOP = 2,
761         OPT_ARG_DURATION_LIMIT = 3,
762         OPT_ARG_MOH_CLASS = 4,
763         OPT_ARG_INTROMSG = 5,
764         OPT_ARG_INTROUSER_VMREC = 6,
765         OPT_ARG_ARRAY_SIZE = 7,
766 };
767
768 AST_APP_OPTIONS(meetme_opts, BEGIN_OPTIONS
769         AST_APP_OPTION('A', CONFFLAG_MARKEDUSER ),
770         AST_APP_OPTION('a', CONFFLAG_ADMIN ),
771         AST_APP_OPTION('b', CONFFLAG_AGI ),
772         AST_APP_OPTION('c', CONFFLAG_ANNOUNCEUSERCOUNT ),
773         AST_APP_OPTION('C', CONFFLAG_KICK_CONTINUE),
774         AST_APP_OPTION('D', CONFFLAG_DYNAMICPIN ),
775         AST_APP_OPTION('d', CONFFLAG_DYNAMIC ),
776         AST_APP_OPTION('E', CONFFLAG_EMPTYNOPIN ),
777         AST_APP_OPTION('e', CONFFLAG_EMPTY ),
778         AST_APP_OPTION('F', CONFFLAG_PASS_DTMF ),
779         AST_APP_OPTION_ARG('G', CONFFLAG_INTROMSG, OPT_ARG_INTROMSG ),
780         AST_APP_OPTION_ARG('v', CONFFLAG_INTROUSER_VMREC , OPT_ARG_INTROUSER_VMREC),
781         AST_APP_OPTION('i', CONFFLAG_INTROUSER ),
782         AST_APP_OPTION('I', CONFFLAG_INTROUSERNOREVIEW ),
783         AST_APP_OPTION('k', CONFFLAG_KILL_LAST_MAN_STANDING ),
784         AST_APP_OPTION_ARG('M', CONFFLAG_MOH, OPT_ARG_MOH_CLASS ),
785         AST_APP_OPTION('m', CONFFLAG_STARTMUTED ),
786         AST_APP_OPTION('n', CONFFLAG_DONT_DENOISE ),
787         AST_APP_OPTION('o', CONFFLAG_OPTIMIZETALKER ),
788         AST_APP_OPTION('P', CONFFLAG_ALWAYSPROMPT ),
789         AST_APP_OPTION_ARG('p', CONFFLAG_KEYEXIT, OPT_ARG_EXITKEYS ),
790         AST_APP_OPTION('q', CONFFLAG_QUIET ),
791         AST_APP_OPTION('r', CONFFLAG_RECORDCONF ),
792         AST_APP_OPTION('s', CONFFLAG_STARMENU ),
793         AST_APP_OPTION('T', CONFFLAG_MONITORTALKER ),
794         AST_APP_OPTION('l', CONFFLAG_MONITOR ),
795         AST_APP_OPTION('t', CONFFLAG_TALKER ),
796         AST_APP_OPTION_ARG('w', CONFFLAG_WAITMARKED, OPT_ARG_WAITMARKED ),
797         AST_APP_OPTION('X', CONFFLAG_EXIT_CONTEXT ),
798         AST_APP_OPTION('x', CONFFLAG_MARKEDEXIT ),
799         AST_APP_OPTION('1', CONFFLAG_NOONLYPERSON ),
800         AST_APP_OPTION_ARG('S', CONFFLAG_DURATION_STOP, OPT_ARG_DURATION_STOP),
801         AST_APP_OPTION_ARG('L', CONFFLAG_DURATION_LIMIT, OPT_ARG_DURATION_LIMIT),
802 END_OPTIONS );
803
804 static const char * const app = "MeetMe";
805 static const char * const app2 = "MeetMeCount";
806 static const char * const app3 = "MeetMeAdmin";
807 static const char * const app4 = "MeetMeChannelAdmin";
808 static const char * const slastation_app = "SLAStation";
809 static const char * const slatrunk_app = "SLATrunk";
810
811 /* Lookup RealTime conferences based on confno and current time */
812 static int rt_schedule;
813 static int fuzzystart;
814 static int earlyalert;
815 static int endalert;
816 static int extendby;
817
818 /*! Log participant count to the RealTime backend */
819 static int rt_log_members;
820
821 #define MAX_CONFNUM 80
822 #define MAX_PIN     80
823 #define OPTIONS_LEN 100
824
825 /* Enough space for "<conference #>,<pin>,<admin pin>" followed by a 0 byte. */
826 #define MAX_SETTINGS (MAX_CONFNUM + MAX_PIN + MAX_PIN + 3)
827
828 enum announcetypes {
829         CONF_HASJOIN,
830         CONF_HASLEFT
831 };
832
833 struct announce_listitem {
834         AST_LIST_ENTRY(announce_listitem) entry;
835         char namerecloc[PATH_MAX];                              /*!< Name Recorded file Location */
836         char language[MAX_LANGUAGE];
837         struct ast_channel *confchan;
838         int confusers;
839         int vmrec;
840         enum announcetypes announcetype;
841 };
842
843 /*! \brief The MeetMe Conference object */
844 struct ast_conference {
845         ast_mutex_t playlock;                   /*!< Conference specific lock (players) */
846         ast_mutex_t listenlock;                 /*!< Conference specific lock (listeners) */
847         char confno[MAX_CONFNUM];               /*!< Conference */
848         struct ast_channel *chan;               /*!< Announcements channel */
849         struct ast_channel *lchan;              /*!< Listen/Record channel */
850         int fd;                                 /*!< Announcements fd */
851         int dahdiconf;                            /*!< DAHDI Conf # */
852         int users;                              /*!< Number of active users */
853         int markedusers;                        /*!< Number of marked users */
854         int maxusers;                           /*!< Participant limit if scheduled */
855         int endalert;                           /*!< When to play conf ending message */
856         time_t start;                           /*!< Start time (s) */
857         int refcount;                           /*!< reference count of usage */
858         enum recording_state recording:2;       /*!< recording status */
859         unsigned int isdynamic:1;               /*!< Created on the fly? */
860         unsigned int locked:1;                  /*!< Is the conference locked? */
861         unsigned int gmuted:1;                  /*!< Is the conference globally muted? (all non-admins) */
862         pthread_t recordthread;                 /*!< thread for recording */
863         ast_mutex_t recordthreadlock;           /*!< control threads trying to start recordthread */
864         pthread_attr_t attr;                    /*!< thread attribute */
865         char *recordingfilename;                /*!< Filename to record the Conference into */
866         char *recordingformat;                  /*!< Format to record the Conference in */
867         char pin[MAX_PIN];                      /*!< If protected by a PIN */
868         char pinadmin[MAX_PIN];                 /*!< If protected by a admin PIN */
869         char uniqueid[32];
870         long endtime;                           /*!< When to end the conf if scheduled */
871         const char *useropts;                   /*!< RealTime user flags */
872         const char *adminopts;                  /*!< RealTime moderator flags */
873         const char *bookid;                     /*!< RealTime conference id */
874         struct ast_frame *transframe[32];
875         struct ast_frame *origframe;
876         struct ast_trans_pvt *transpath[32];
877         struct ao2_container *usercontainer;
878         AST_LIST_ENTRY(ast_conference) list;
879         /* announce_thread related data */
880         pthread_t announcethread;
881         ast_mutex_t announcethreadlock;
882         unsigned int announcethread_stop:1;
883         ast_cond_t announcelist_addition;
884         AST_LIST_HEAD_NOLOCK(, announce_listitem) announcelist;
885         ast_mutex_t announcelistlock;
886 };
887
888 static AST_LIST_HEAD_STATIC(confs, ast_conference);
889
890 static unsigned int conf_map[1024] = {0, };
891
892 struct volume {
893         int desired;                            /*!< Desired volume adjustment */
894         int actual;                             /*!< Actual volume adjustment (for channels that can't adjust) */
895 };
896
897 /*! \brief The MeetMe User object */
898 struct ast_conf_user {
899         int user_no;                            /*!< User Number */
900         struct ast_flags64 userflags;           /*!< Flags as set in the conference */
901         int adminflags;                         /*!< Flags set by the Admin */
902         struct ast_channel *chan;               /*!< Connected channel */
903         int talking;                            /*!< Is user talking */
904         int dahdichannel;                       /*!< Is a DAHDI channel */
905         char usrvalue[50];                      /*!< Custom User Value */
906         char namerecloc[PATH_MAX];              /*!< Name Recorded file Location */
907         time_t jointime;                        /*!< Time the user joined the conference */
908         time_t kicktime;                        /*!< Time the user will be kicked from the conference */
909         struct timeval start_time;              /*!< Time the user entered into the conference */
910         long timelimit;                         /*!< Time limit for the user to be in the conference L(x:y:z) */
911         long play_warning;                      /*!< Play a warning when 'y' ms are left */
912         long warning_freq;                      /*!< Repeat the warning every 'z' ms */
913         const char *warning_sound;              /*!< File to play as warning if 'y' is defined */
914         const char *end_sound;                  /*!< File to play when time is up. */
915         struct volume talk;
916         struct volume listen;
917         AST_LIST_ENTRY(ast_conf_user) list;
918 };
919
920 enum sla_which_trunk_refs {
921         ALL_TRUNK_REFS,
922         INACTIVE_TRUNK_REFS,
923 };
924
925 enum sla_trunk_state {
926         SLA_TRUNK_STATE_IDLE,
927         SLA_TRUNK_STATE_RINGING,
928         SLA_TRUNK_STATE_UP,
929         SLA_TRUNK_STATE_ONHOLD,
930         SLA_TRUNK_STATE_ONHOLD_BYME,
931 };
932
933 enum sla_hold_access {
934         /*! This means that any station can put it on hold, and any station
935          * can retrieve the call from hold. */
936         SLA_HOLD_OPEN,
937         /*! This means that only the station that put the call on hold may
938          * retrieve it from hold. */
939         SLA_HOLD_PRIVATE,
940 };
941
942 struct sla_trunk_ref;
943
944 struct sla_station {
945         AST_RWLIST_ENTRY(sla_station) entry;
946         AST_DECLARE_STRING_FIELDS(
947                 AST_STRING_FIELD(name); 
948                 AST_STRING_FIELD(device);       
949                 AST_STRING_FIELD(autocontext);  
950         );
951         AST_LIST_HEAD_NOLOCK(, sla_trunk_ref) trunks;
952         struct ast_dial *dial;
953         /*! Ring timeout for this station, for any trunk.  If a ring timeout
954          *  is set for a specific trunk on this station, that will take
955          *  priority over this value. */
956         unsigned int ring_timeout;
957         /*! Ring delay for this station, for any trunk.  If a ring delay
958          *  is set for a specific trunk on this station, that will take
959          *  priority over this value. */
960         unsigned int ring_delay;
961         /*! This option uses the values in the sla_hold_access enum and sets the
962          * access control type for hold on this station. */
963         unsigned int hold_access:1;
964         /*! Mark used during reload processing */
965         unsigned int mark:1;
966 };
967
968 /*!
969  * \brief A reference to a station
970  *
971  * This struct looks near useless at first glance.  However, its existence
972  * in the list of stations in sla_trunk means that this station references
973  * that trunk.  We use the mark to keep track of whether it needs to be
974  * removed from the sla_trunk's list of stations during a reload.
975  */
976 struct sla_station_ref {
977         AST_LIST_ENTRY(sla_station_ref) entry;
978         struct sla_station *station;
979         /*! Mark used during reload processing */
980         unsigned int mark:1;
981 };
982
983 struct sla_trunk {
984         AST_DECLARE_STRING_FIELDS(
985                 AST_STRING_FIELD(name);
986                 AST_STRING_FIELD(device);
987                 AST_STRING_FIELD(autocontext);  
988         );
989         AST_LIST_HEAD_NOLOCK(, sla_station_ref) stations;
990         /*! Number of stations that use this trunk */
991         unsigned int num_stations;
992         /*! Number of stations currently on a call with this trunk */
993         unsigned int active_stations;
994         /*! Number of stations that have this trunk on hold. */
995         unsigned int hold_stations;
996         struct ast_channel *chan;
997         unsigned int ring_timeout;
998         /*! If set to 1, no station will be able to join an active call with
999          *  this trunk. */
1000         unsigned int barge_disabled:1;
1001         /*! This option uses the values in the sla_hold_access enum and sets the
1002          * access control type for hold on this trunk. */
1003         unsigned int hold_access:1;
1004         /*! Whether this trunk is currently on hold, meaning that once a station
1005          *  connects to it, the trunk channel needs to have UNHOLD indicated to it. */
1006         unsigned int on_hold:1;
1007         /*! Mark used during reload processing */
1008         unsigned int mark:1;
1009 };
1010
1011 /*!
1012  * \brief A station's reference to a trunk
1013  *
1014  * An sla_station keeps a list of trunk_refs.  This holds metadata about the
1015  * stations usage of the trunk.
1016  */
1017 struct sla_trunk_ref {
1018         AST_LIST_ENTRY(sla_trunk_ref) entry;
1019         struct sla_trunk *trunk;
1020         enum sla_trunk_state state;
1021         struct ast_channel *chan;
1022         /*! Ring timeout to use when this trunk is ringing on this specific
1023          *  station.  This takes higher priority than a ring timeout set at
1024          *  the station level. */
1025         unsigned int ring_timeout;
1026         /*! Ring delay to use when this trunk is ringing on this specific
1027          *  station.  This takes higher priority than a ring delay set at
1028          *  the station level. */
1029         unsigned int ring_delay;
1030         /*! Mark used during reload processing */
1031         unsigned int mark:1;
1032 };
1033
1034 static struct ao2_container *sla_stations;
1035 static struct ao2_container *sla_trunks;
1036
1037 static const char sla_registrar[] = "SLA";
1038
1039 /*! \brief Event types that can be queued up for the SLA thread */
1040 enum sla_event_type {
1041         /*! A station has put the call on hold */
1042         SLA_EVENT_HOLD,
1043         /*! The state of a dial has changed */
1044         SLA_EVENT_DIAL_STATE,
1045         /*! The state of a ringing trunk has changed */
1046         SLA_EVENT_RINGING_TRUNK,
1047 };
1048
1049 struct sla_event {
1050         enum sla_event_type type;
1051         struct sla_station *station;
1052         struct sla_trunk_ref *trunk_ref;
1053         AST_LIST_ENTRY(sla_event) entry;
1054 };
1055
1056 /*! \brief A station that failed to be dialed 
1057  * \note Only used by the SLA thread. */
1058 struct sla_failed_station {
1059         struct sla_station *station;
1060         struct timeval last_try;
1061         AST_LIST_ENTRY(sla_failed_station) entry;
1062 };
1063
1064 /*! \brief A trunk that is ringing */
1065 struct sla_ringing_trunk {
1066         struct sla_trunk *trunk;
1067         /*! The time that this trunk started ringing */
1068         struct timeval ring_begin;
1069         AST_LIST_HEAD_NOLOCK(, sla_station_ref) timed_out_stations;
1070         AST_LIST_ENTRY(sla_ringing_trunk) entry;
1071 };
1072
1073 enum sla_station_hangup {
1074         SLA_STATION_HANGUP_NORMAL,
1075         SLA_STATION_HANGUP_TIMEOUT,
1076 };
1077
1078 /*! \brief A station that is ringing */
1079 struct sla_ringing_station {
1080         struct sla_station *station;
1081         /*! The time that this station started ringing */
1082         struct timeval ring_begin;
1083         AST_LIST_ENTRY(sla_ringing_station) entry;
1084 };
1085
1086 /*!
1087  * \brief A structure for data used by the sla thread
1088  */
1089 static struct {
1090         /*! The SLA thread ID */
1091         pthread_t thread;
1092         ast_cond_t cond;
1093         ast_mutex_t lock;
1094         AST_LIST_HEAD_NOLOCK(, sla_ringing_trunk) ringing_trunks;
1095         AST_LIST_HEAD_NOLOCK(, sla_ringing_station) ringing_stations;
1096         AST_LIST_HEAD_NOLOCK(, sla_failed_station) failed_stations;
1097         AST_LIST_HEAD_NOLOCK(, sla_event) event_q;
1098         unsigned int stop:1;
1099         /*! Attempt to handle CallerID, even though it is known not to work
1100          *  properly in some situations. */
1101         unsigned int attempt_callerid:1;
1102 } sla = {
1103         .thread = AST_PTHREADT_NULL,
1104 };
1105
1106 /*! \brief The number of audio buffers to be allocated on pseudo channels
1107  *  when in a conference */
1108 static int audio_buffers;
1109
1110 /*! \brief Map 'volume' levels from -5 through +5 into decibel (dB) 
1111  *    settings for channel drivers.
1112  *
1113  *  \note these are not a straight linear-to-dB
1114  *  conversion... the numbers have been modified
1115  *  to give the user a better level of adjustability.
1116  */
1117 static const char gain_map[] = {
1118         -15,
1119         -13,
1120         -10,
1121         -6,
1122         0,
1123         0,
1124         0,
1125         6,
1126         10,
1127         13,
1128         15,
1129 };
1130
1131 /* Routes the various meetme message types to the meetme stasis callback function to turn them into events */
1132 static struct stasis_message_router *meetme_event_message_router;
1133
1134 STASIS_MESSAGE_TYPE_DEFN_LOCAL(meetme_join_type);
1135 STASIS_MESSAGE_TYPE_DEFN_LOCAL(meetme_leave_type);
1136 STASIS_MESSAGE_TYPE_DEFN_LOCAL(meetme_end_type);
1137 STASIS_MESSAGE_TYPE_DEFN_LOCAL(meetme_mute_type);
1138 STASIS_MESSAGE_TYPE_DEFN_LOCAL(meetme_talking_type);
1139 STASIS_MESSAGE_TYPE_DEFN_LOCAL(meetme_talk_request_type);
1140
1141 static void meetme_stasis_cb(void *data, struct stasis_subscription *sub,
1142         struct stasis_message *message);
1143
1144 static void meetme_stasis_cleanup(void)
1145 {
1146         if (meetme_event_message_router) {
1147                 stasis_message_router_unsubscribe(meetme_event_message_router);
1148                 meetme_event_message_router = NULL;
1149         }
1150
1151         STASIS_MESSAGE_TYPE_CLEANUP(meetme_join_type);
1152         STASIS_MESSAGE_TYPE_CLEANUP(meetme_leave_type);
1153         STASIS_MESSAGE_TYPE_CLEANUP(meetme_end_type);
1154         STASIS_MESSAGE_TYPE_CLEANUP(meetme_mute_type);
1155         STASIS_MESSAGE_TYPE_CLEANUP(meetme_talking_type);
1156         STASIS_MESSAGE_TYPE_CLEANUP(meetme_talk_request_type);
1157 }
1158
1159 static int meetme_stasis_init(void)
1160 {
1161
1162         STASIS_MESSAGE_TYPE_INIT(meetme_join_type);
1163         STASIS_MESSAGE_TYPE_INIT(meetme_leave_type);
1164         STASIS_MESSAGE_TYPE_INIT(meetme_end_type);
1165         STASIS_MESSAGE_TYPE_INIT(meetme_mute_type);
1166         STASIS_MESSAGE_TYPE_INIT(meetme_talking_type);
1167         STASIS_MESSAGE_TYPE_INIT(meetme_talk_request_type);
1168
1169         meetme_event_message_router = stasis_message_router_create(
1170                 ast_channel_topic_all_cached());
1171
1172         if (!meetme_event_message_router) {
1173                 meetme_stasis_cleanup();
1174                 return -1;
1175         }
1176
1177         if (stasis_message_router_add(meetme_event_message_router,
1178                         meetme_join_type(),
1179                         meetme_stasis_cb,
1180                         NULL)) {
1181                 meetme_stasis_cleanup();
1182                 return -1;
1183         }
1184
1185         if (stasis_message_router_add(meetme_event_message_router,
1186                         meetme_leave_type(),
1187                         meetme_stasis_cb,
1188                         NULL)) {
1189                 meetme_stasis_cleanup();
1190                 return -1;
1191         }
1192
1193         if (stasis_message_router_add(meetme_event_message_router,
1194                         meetme_end_type(),
1195                         meetme_stasis_cb,
1196                         NULL)) {
1197                 meetme_stasis_cleanup();
1198                 return -1;
1199         }
1200
1201         if (stasis_message_router_add(meetme_event_message_router,
1202                         meetme_mute_type(),
1203                         meetme_stasis_cb,
1204                         NULL)) {
1205                 meetme_stasis_cleanup();
1206                 return -1;
1207         }
1208
1209         if (stasis_message_router_add(meetme_event_message_router,
1210                         meetme_talking_type(),
1211                         meetme_stasis_cb,
1212                         NULL)) {
1213                 meetme_stasis_cleanup();
1214                 return -1;
1215         }
1216
1217         if (stasis_message_router_add(meetme_event_message_router,
1218                         meetme_talk_request_type(),
1219                         meetme_stasis_cb,
1220                         NULL)) {
1221                 meetme_stasis_cleanup();
1222                 return -1;
1223         }
1224
1225         return 0;
1226 }
1227
1228 static void meetme_stasis_cb(void *data, struct stasis_subscription *sub,
1229         struct stasis_message *message)
1230 {
1231         struct ast_channel_blob *channel_blob = stasis_message_data(message);
1232         struct stasis_message_type *message_type;
1233         const char *event;
1234         const char *conference_num;
1235         const char *status;
1236         struct ast_json *json_cur;
1237         RAII_VAR(struct ast_str *, channel_text, NULL, ast_free);
1238         RAII_VAR(struct ast_str *, extra_text, NULL, ast_free);
1239
1240         if (!channel_blob) {
1241                 ast_assert(0);
1242                 return;
1243         }
1244
1245         message_type = stasis_message_type(message);
1246
1247         if (!message_type) {
1248                 ast_assert(0);
1249                 return;
1250         }
1251
1252         if (message_type == meetme_join_type()) {
1253                 event = "MeetmeJoin";
1254         } else if (message_type == meetme_leave_type()) {
1255                 event = "MeetmeLeave";
1256         } else if (message_type == meetme_end_type()) {
1257                 event = "MeetmeEnd";
1258         } else if (message_type == meetme_mute_type()) {
1259                 event = "MeetmeMute";
1260         } else if (message_type == meetme_talking_type()) {
1261                 event = "MeetmeTalking";
1262         } else if (message_type == meetme_talk_request_type()) {
1263                 event = "MeetmeTalkRequest";
1264         } else {
1265                 ast_assert(0);
1266                 return;
1267         }
1268
1269         if (!event) {
1270                 ast_assert(0);
1271                 return;
1272         }
1273
1274         conference_num = ast_json_string_get(ast_json_object_get(channel_blob->blob, "Meetme"));
1275         if (!conference_num) {
1276                 ast_assert(0);
1277                 return;
1278         }
1279
1280         status = ast_json_string_get(ast_json_object_get(channel_blob->blob, "status"));
1281         if (status) {
1282                 ast_str_append_event_header(&extra_text, "Status", status);
1283         }
1284
1285         if (channel_blob->snapshot) {
1286                 channel_text = ast_manager_build_channel_state_string(channel_blob->snapshot);
1287         }
1288
1289         if ((json_cur = ast_json_object_get(channel_blob->blob, "user"))) {
1290                 int user_number = ast_json_integer_get(json_cur);
1291                 RAII_VAR(struct ast_str *, user_prop_str, ast_str_create(32), ast_free);
1292                 if (!user_prop_str) {
1293                         return;
1294                 }
1295
1296                 ast_str_set(&user_prop_str, 0, "%d", user_number);
1297                 ast_str_append_event_header(&extra_text, "User", ast_str_buffer(user_prop_str));
1298
1299                 if ((json_cur = ast_json_object_get(channel_blob->blob, "duration"))) {
1300                         int duration = ast_json_integer_get(json_cur);
1301                         ast_str_set(&user_prop_str, 0, "%d", duration);
1302                         ast_str_append_event_header(&extra_text, "Duration", ast_str_buffer(user_prop_str));
1303                 }
1304
1305                 json_cur = NULL;
1306         }
1307
1308         manager_event(EVENT_FLAG_CALL, event,
1309                 "Meetme: %s\r\n"
1310                 "%s"
1311                 "%s",
1312                 conference_num,
1313                 channel_text ? ast_str_buffer(channel_text) : "",
1314                 extra_text ? ast_str_buffer(extra_text) : "");
1315 }
1316
1317 /*!
1318  * \internal
1319  * \brief Build a json object from a status value for inclusion in json extras for meetme_stasis_generate_msg
1320  * \since 12.0.0
1321  *
1322  * \param on if true, then status is on. Otherwise status is off
1323  * \retval NULL on failure to allocate the JSON blob.
1324  * \retval pointer to the JSON blob if successful.
1325  */
1326 static struct ast_json *status_to_json(int on)
1327 {
1328         struct ast_json *json_object = ast_json_pack("{s: s}",
1329                 "status", on ? "on" : "off");
1330
1331         return json_object;
1332 }
1333
1334 /*!
1335  * \internal
1336  * \brief Generate a stasis message associated with a meetme event
1337  * \since 12.0.0
1338  *
1339  * \param meetme_confere The conference responsible for generating this message
1340  * \param chan The channel involved in the message (NULL allowed)
1341  * \param user The conference user involved in the message (NULL allowed)
1342  * \param message_type the type the stasis message being generated
1343  * \param extras Additional json fields desired for inclusion
1344  */
1345 static void meetme_stasis_generate_msg(struct ast_conference *meetme_conference, struct ast_channel *chan,
1346         struct ast_conf_user *user, struct stasis_message_type *message_type, struct ast_json *extras)
1347 {
1348         RAII_VAR(struct stasis_message *, msg, NULL, ao2_cleanup);
1349         RAII_VAR(struct ast_json *, json_object, NULL, ast_json_unref);
1350
1351         json_object = ast_json_pack("{s: s}",
1352                 "Meetme", meetme_conference->confno);
1353
1354         if (!json_object) {
1355                 return;
1356         }
1357
1358         if (extras) {
1359                 ast_json_object_update(json_object, extras);
1360         }
1361
1362         if (user) {
1363                 struct timeval now = ast_tvnow();
1364                 long duration = (long)(now.tv_sec - user->jointime);
1365                 RAII_VAR(struct ast_json *, json_user, ast_json_integer_create(user->user_no), ast_json_unref);
1366                 RAII_VAR(struct ast_json *, json_user_duration, NULL, ast_json_unref);
1367
1368                 if (ast_json_object_set(json_object, "user", json_user)) {
1369                         return;
1370                 }
1371                 json_user = NULL;
1372
1373                 if (duration > 0) {
1374                         json_user_duration = ast_json_integer_create(duration);
1375
1376                         if (!json_user_duration) {
1377                                 return;
1378                         }
1379
1380                         if (ast_json_object_set(json_object, "duration", json_user_duration)) {
1381                                 return;
1382                         }
1383                         json_user_duration = NULL;
1384                 }
1385         }
1386
1387         ast_channel_lock(chan);
1388         msg = ast_channel_blob_create(chan, message_type, json_object);
1389         ast_channel_unlock(chan);
1390
1391         if (!msg) {
1392                 return;
1393         }
1394
1395         stasis_publish(ast_channel_topic(chan), msg);
1396 }
1397
1398 static int admin_exec(struct ast_channel *chan, const char *data);
1399 static void *recordthread(void *args);
1400
1401 static const char *istalking(int x)
1402 {
1403         if (x > 0)
1404                 return "(talking)";
1405         else if (x < 0)
1406                 return "(unmonitored)";
1407         else 
1408                 return "(not talking)";
1409 }
1410
1411 static int careful_write(int fd, unsigned char *data, int len, int block)
1412 {
1413         int res;
1414         int x;
1415
1416         while (len) {
1417                 if (block) {
1418                         x = DAHDI_IOMUX_WRITE | DAHDI_IOMUX_SIGEVENT;
1419                         res = ioctl(fd, DAHDI_IOMUX, &x);
1420                 } else
1421                         res = 0;
1422                 if (res >= 0)
1423                         res = write(fd, data, len);
1424                 if (res < 1) {
1425                         if (errno != EAGAIN) {
1426                                 ast_log(LOG_WARNING, "Failed to write audio data to conference: %s\n", strerror(errno));
1427                                 return -1;
1428                         } else
1429                                 return 0;
1430                 }
1431                 len -= res;
1432                 data += res;
1433         }
1434
1435         return 0;
1436 }
1437
1438 static int set_talk_volume(struct ast_conf_user *user, int volume)
1439 {
1440         char gain_adjust;
1441
1442         /* attempt to make the adjustment in the channel driver;
1443            if successful, don't adjust in the frame reading routine
1444         */
1445         gain_adjust = gain_map[volume + 5];
1446
1447         return ast_channel_setoption(user->chan, AST_OPTION_RXGAIN, &gain_adjust, sizeof(gain_adjust), 0);
1448 }
1449
1450 static int set_listen_volume(struct ast_conf_user *user, int volume)
1451 {
1452         char gain_adjust;
1453
1454         /* attempt to make the adjustment in the channel driver;
1455            if successful, don't adjust in the frame reading routine
1456         */
1457         gain_adjust = gain_map[volume + 5];
1458
1459         return ast_channel_setoption(user->chan, AST_OPTION_TXGAIN, &gain_adjust, sizeof(gain_adjust), 0);
1460 }
1461
1462 static void tweak_volume(struct volume *vol, enum volume_action action)
1463 {
1464         switch (action) {
1465         case VOL_UP:
1466                 switch (vol->desired) { 
1467                 case 5:
1468                         break;
1469                 case 0:
1470                         vol->desired = 2;
1471                         break;
1472                 case -2:
1473                         vol->desired = 0;
1474                         break;
1475                 default:
1476                         vol->desired++;
1477                         break;
1478                 }
1479                 break;
1480         case VOL_DOWN:
1481                 switch (vol->desired) {
1482                 case -5:
1483                         break;
1484                 case 2:
1485                         vol->desired = 0;
1486                         break;
1487                 case 0:
1488                         vol->desired = -2;
1489                         break;
1490                 default:
1491                         vol->desired--;
1492                         break;
1493                 }
1494         }
1495 }
1496
1497 static void tweak_talk_volume(struct ast_conf_user *user, enum volume_action action)
1498 {
1499         tweak_volume(&user->talk, action);
1500         /* attempt to make the adjustment in the channel driver;
1501            if successful, don't adjust in the frame reading routine
1502         */
1503         if (!set_talk_volume(user, user->talk.desired))
1504                 user->talk.actual = 0;
1505         else
1506                 user->talk.actual = user->talk.desired;
1507 }
1508
1509 static void tweak_listen_volume(struct ast_conf_user *user, enum volume_action action)
1510 {
1511         tweak_volume(&user->listen, action);
1512         /* attempt to make the adjustment in the channel driver;
1513            if successful, don't adjust in the frame reading routine
1514         */
1515         if (!set_listen_volume(user, user->listen.desired))
1516                 user->listen.actual = 0;
1517         else
1518                 user->listen.actual = user->listen.desired;
1519 }
1520
1521 static void reset_volumes(struct ast_conf_user *user)
1522 {
1523         signed char zero_volume = 0;
1524
1525         ast_channel_setoption(user->chan, AST_OPTION_TXGAIN, &zero_volume, sizeof(zero_volume), 0);
1526         ast_channel_setoption(user->chan, AST_OPTION_RXGAIN, &zero_volume, sizeof(zero_volume), 0);
1527 }
1528
1529 static void conf_play(struct ast_channel *chan, struct ast_conference *conf, enum entrance_sound sound)
1530 {
1531         unsigned char *data;
1532         int len;
1533         int res = -1;
1534
1535         ast_test_suite_event_notify("CONFPLAY", "Channel: %s\r\n"
1536                 "Conference: %s\r\n"
1537                 "Marked: %d",
1538                 ast_channel_name(chan),
1539                 conf->confno,
1540                 conf->markedusers);
1541
1542         if (!ast_check_hangup(chan))
1543                 res = ast_autoservice_start(chan);
1544
1545         AST_LIST_LOCK(&confs);
1546
1547         switch(sound) {
1548         case ENTER:
1549                 data = enter;
1550                 len = sizeof(enter);
1551                 break;
1552         case LEAVE:
1553                 data = leave;
1554                 len = sizeof(leave);
1555                 break;
1556         default:
1557                 data = NULL;
1558                 len = 0;
1559         }
1560         if (data) {
1561                 careful_write(conf->fd, data, len, 1);
1562         }
1563
1564         AST_LIST_UNLOCK(&confs);
1565
1566         if (!res) 
1567                 ast_autoservice_stop(chan);
1568 }
1569
1570 static int user_no_cmp(void *obj, void *arg, int flags)
1571 {
1572         struct ast_conf_user *user = obj;
1573         int *user_no = arg;
1574
1575         if (user->user_no == *user_no) {
1576                 return (CMP_MATCH | CMP_STOP);
1577         }
1578
1579         return 0;
1580 }
1581
1582 static int user_max_cmp(void *obj, void *arg, int flags)
1583 {
1584         struct ast_conf_user *user = obj;
1585         int *max_no = arg;
1586
1587         if (user->user_no > *max_no) {
1588                 *max_no = user->user_no;
1589         }
1590
1591         return 0;
1592 }
1593
1594 /*!
1595  * \brief Find or create a conference
1596  *
1597  * \param confno The conference name/number
1598  * \param pin The regular user pin
1599  * \param pinadmin The admin pin
1600  * \param make Make the conf if it doesn't exist
1601  * \param dynamic Mark the newly created conference as dynamic
1602  * \param refcount How many references to mark on the conference
1603  * \param chan The asterisk channel
1604  * \param test
1605  *
1606  * \return A pointer to the conference struct, or NULL if it wasn't found and
1607  *         make or dynamic were not set.
1608  */
1609 static struct ast_conference *build_conf(const char *confno, const char *pin,
1610         const char *pinadmin, int make, int dynamic, int refcount,
1611         const struct ast_channel *chan, struct ast_test *test)
1612 {
1613         struct ast_conference *cnf;
1614         struct dahdi_confinfo dahdic = { 0, };
1615         int confno_int = 0;
1616         struct ast_format_cap *cap_slin = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_NOLOCK);
1617         struct ast_format tmp_fmt;
1618
1619         AST_LIST_LOCK(&confs);
1620
1621         AST_LIST_TRAVERSE(&confs, cnf, list) {
1622                 if (!strcmp(confno, cnf->confno)) 
1623                         break;
1624         }
1625
1626         if (cnf || (!make && !dynamic) || !cap_slin)
1627                 goto cnfout;
1628
1629         ast_format_cap_add(cap_slin, ast_format_set(&tmp_fmt, AST_FORMAT_SLINEAR, 0));
1630         /* Make a new one */
1631         if (!(cnf = ast_calloc(1, sizeof(*cnf))) ||
1632                 !(cnf->usercontainer = ao2_container_alloc(1, NULL, user_no_cmp))) {
1633                 goto cnfout;
1634         }
1635
1636         ast_mutex_init(&cnf->playlock);
1637         ast_mutex_init(&cnf->listenlock);
1638         cnf->recordthread = AST_PTHREADT_NULL;
1639         ast_mutex_init(&cnf->recordthreadlock);
1640         cnf->announcethread = AST_PTHREADT_NULL;
1641         ast_mutex_init(&cnf->announcethreadlock);
1642         ast_copy_string(cnf->confno, confno, sizeof(cnf->confno));
1643         ast_copy_string(cnf->pin, pin, sizeof(cnf->pin));
1644         ast_copy_string(cnf->pinadmin, pinadmin, sizeof(cnf->pinadmin));
1645         ast_copy_string(cnf->uniqueid, ast_channel_uniqueid(chan), sizeof(cnf->uniqueid));
1646
1647         /* Setup a new dahdi conference */
1648         dahdic.confno = -1;
1649         dahdic.confmode = DAHDI_CONF_CONFANN | DAHDI_CONF_CONFANNMON;
1650         cnf->fd = open("/dev/dahdi/pseudo", O_RDWR);
1651         if (cnf->fd < 0 || ioctl(cnf->fd, DAHDI_SETCONF, &dahdic)) {
1652                 if (test) {
1653                         /* if we are creating a conference for a unit test, it is not neccesary
1654                          * to open a pseudo channel, so, if we fail continue creating
1655                          * the conference. */
1656                         ast_test_status_update(test, "Unable to open DAHDI pseudo device\n");
1657                 } else {
1658                         ast_log(LOG_WARNING, "Unable to open DAHDI pseudo device\n");
1659                         if (cnf->fd >= 0)
1660                                 close(cnf->fd);
1661                         ao2_ref(cnf->usercontainer, -1);
1662                         ast_mutex_destroy(&cnf->playlock);
1663                         ast_mutex_destroy(&cnf->listenlock);
1664                         ast_mutex_destroy(&cnf->recordthreadlock);
1665                         ast_mutex_destroy(&cnf->announcethreadlock);
1666                         ast_free(cnf);
1667                         cnf = NULL;
1668                         goto cnfout;
1669                 }
1670         }
1671
1672         cnf->dahdiconf = dahdic.confno;
1673
1674         /* Setup a new channel for playback of audio files */
1675         cnf->chan = ast_request("DAHDI", cap_slin, chan, "pseudo", NULL);
1676         if (cnf->chan) {
1677                 ast_set_read_format_by_id(cnf->chan, AST_FORMAT_SLINEAR);
1678                 ast_set_write_format_by_id(cnf->chan, AST_FORMAT_SLINEAR);
1679                 dahdic.chan = 0;
1680                 dahdic.confno = cnf->dahdiconf;
1681                 dahdic.confmode = DAHDI_CONF_CONFANN | DAHDI_CONF_CONFANNMON;
1682                 if (ioctl(ast_channel_fd(cnf->chan, 0), DAHDI_SETCONF, &dahdic)) {
1683                         if (test) {
1684                                 ast_test_status_update(test, "Error setting conference on pseudo channel\n");
1685                         }
1686                         ast_log(LOG_WARNING, "Error setting conference\n");
1687                         if (cnf->chan)
1688                                 ast_hangup(cnf->chan);
1689                         else
1690                                 close(cnf->fd);
1691                         ao2_ref(cnf->usercontainer, -1);
1692                         ast_mutex_destroy(&cnf->playlock);
1693                         ast_mutex_destroy(&cnf->listenlock);
1694                         ast_mutex_destroy(&cnf->recordthreadlock);
1695                         ast_mutex_destroy(&cnf->announcethreadlock);
1696                         ast_free(cnf);
1697                         cnf = NULL;
1698                         goto cnfout;
1699                 }
1700         }
1701
1702         /* Fill the conference struct */
1703         cnf->start = time(NULL);
1704         cnf->maxusers = 0x7fffffff;
1705         cnf->isdynamic = dynamic ? 1 : 0;
1706         ast_verb(3, "Created MeetMe conference %d for conference '%s'\n", cnf->dahdiconf, cnf->confno);
1707         AST_LIST_INSERT_HEAD(&confs, cnf, list);
1708
1709         /* Reserve conference number in map */
1710         if ((sscanf(cnf->confno, "%30d", &confno_int) == 1) && (confno_int >= 0 && confno_int < 1024))
1711                 conf_map[confno_int] = 1;
1712         
1713 cnfout:
1714         cap_slin = ast_format_cap_destroy(cap_slin);
1715         if (cnf)
1716                 ast_atomic_fetchadd_int(&cnf->refcount, refcount);
1717
1718         AST_LIST_UNLOCK(&confs);
1719
1720         return cnf;
1721 }
1722
1723 static char *complete_confno(const char *word, int state)
1724 {
1725         struct ast_conference *cnf;
1726         char *ret = NULL;
1727         int which = 0;
1728         int len = strlen(word);
1729
1730         AST_LIST_LOCK(&confs);
1731         AST_LIST_TRAVERSE(&confs, cnf, list) {
1732                 if (!strncmp(word, cnf->confno, len) && ++which > state) {
1733                         /* dup before releasing the lock */
1734                         ret = ast_strdup(cnf->confno);
1735                         break;
1736                 }
1737         }
1738         AST_LIST_UNLOCK(&confs);
1739         return ret;
1740 }
1741
1742 static char *complete_userno(struct ast_conference *cnf, const char *word, int state)
1743 {
1744         char usrno[50];
1745         struct ao2_iterator iter;
1746         struct ast_conf_user *usr;
1747         char *ret = NULL;
1748         int which = 0;
1749         int len = strlen(word);
1750
1751         iter = ao2_iterator_init(cnf->usercontainer, 0);
1752         for (; (usr = ao2_iterator_next(&iter)); ao2_ref(usr, -1)) {
1753                 snprintf(usrno, sizeof(usrno), "%d", usr->user_no);
1754                 if (!strncmp(word, usrno, len) && ++which > state) {
1755                         ao2_ref(usr, -1);
1756                         ret = ast_strdup(usrno);
1757                         break;
1758                 }
1759         }
1760         ao2_iterator_destroy(&iter);
1761         return ret;
1762 }
1763
1764 static char *complete_meetmecmd_mute_kick(const char *line, const char *word, int pos, int state)
1765 {
1766         if (pos == 2) {
1767                 return complete_confno(word, state);
1768         }
1769         if (pos == 3) {
1770                 int len = strlen(word);
1771                 char *ret = NULL;
1772                 char *saved = NULL;
1773                 char *myline;
1774                 char *confno;
1775                 struct ast_conference *cnf;
1776
1777                 if (!strncasecmp(word, "all", len)) {
1778                         if (state == 0) {
1779                                 return ast_strdup("all");
1780                         }
1781                         --state;
1782                 }
1783
1784                 /* Extract the confno from the command line. */
1785                 myline = ast_strdupa(line);
1786                 strtok_r(myline, " ", &saved);
1787                 strtok_r(NULL, " ", &saved);
1788                 confno = strtok_r(NULL, " ", &saved);
1789
1790                 AST_LIST_LOCK(&confs);
1791                 AST_LIST_TRAVERSE(&confs, cnf, list) {
1792                         if (!strcmp(confno, cnf->confno)) {
1793                                 ret = complete_userno(cnf, word, state);
1794                                 break;
1795                         }
1796                 }
1797                 AST_LIST_UNLOCK(&confs);
1798
1799                 return ret;
1800         }
1801         return NULL;
1802 }
1803
1804 static char *complete_meetmecmd_lock(const char *word, int pos, int state)
1805 {
1806         if (pos == 2) {
1807                 return complete_confno(word, state);
1808         }
1809         return NULL;
1810 }
1811
1812 static char *complete_meetmecmd_list(const char *line, const char *word, int pos, int state)
1813 {
1814         int len;
1815
1816         if (pos == 2) {
1817                 len = strlen(word);
1818                 if (!strncasecmp(word, STR_CONCISE, len)) {
1819                         if (state == 0) {
1820                                 return ast_strdup(STR_CONCISE);
1821                         }
1822                         --state;
1823                 }
1824
1825                 return complete_confno(word, state);
1826         }
1827         if (pos == 3 && state == 0) {
1828                 char *saved = NULL;
1829                 char *myline;
1830                 char *confno;
1831
1832                 /* Extract the confno from the command line. */
1833                 myline = ast_strdupa(line);
1834                 strtok_r(myline, " ", &saved);
1835                 strtok_r(NULL, " ", &saved);
1836                 confno = strtok_r(NULL, " ", &saved);
1837
1838                 if (!strcasecmp(confno, STR_CONCISE)) {
1839                         /* There is nothing valid in this position now. */
1840                         return NULL;
1841                 }
1842
1843                 len = strlen(word);
1844                 if (!strncasecmp(word, STR_CONCISE, len)) {
1845                         return ast_strdup(STR_CONCISE);
1846                 }
1847         }
1848         return NULL;
1849 }
1850
1851 static char *meetme_show_cmd(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
1852 {
1853         /* Process the command */
1854         struct ast_conf_user *user;
1855         struct ast_conference *cnf;
1856         int hr, min, sec;
1857         int total = 0;
1858         time_t now;
1859 #define MC_HEADER_FORMAT "%-14s %-14s %-10s %-8s  %-8s  %-6s\n"
1860 #define MC_DATA_FORMAT "%-12.12s   %4.4d              %4.4s       %02d:%02d:%02d  %-8s  %-6s\n"
1861
1862         switch (cmd) {
1863         case CLI_INIT:
1864                 e->command = "meetme list";
1865                 e->usage =
1866                         "Usage: meetme list [<confno>] [" STR_CONCISE "]\n"
1867                         "       List all conferences or a specific conference.\n";
1868                 return NULL;
1869         case CLI_GENERATE:
1870                 return complete_meetmecmd_list(a->line, a->word, a->pos, a->n);
1871         }
1872
1873         if (a->argc == 2 || (a->argc == 3 && !strcasecmp(a->argv[2], STR_CONCISE))) {
1874                 /* List all the conferences */
1875                 int concise = (a->argc == 3);
1876                 struct ast_str *marked_users;
1877
1878                 if (!(marked_users = ast_str_create(30))) {
1879                         return CLI_FAILURE;
1880                 }
1881
1882                 now = time(NULL);
1883                 AST_LIST_LOCK(&confs);
1884                 if (AST_LIST_EMPTY(&confs)) {
1885                         if (!concise) {
1886                                 ast_cli(a->fd, "No active MeetMe conferences.\n");
1887                         }
1888                         AST_LIST_UNLOCK(&confs);
1889                         ast_free(marked_users);
1890                         return CLI_SUCCESS;
1891                 }
1892                 if (!concise) {
1893                         ast_cli(a->fd, MC_HEADER_FORMAT, "Conf Num", "Parties", "Marked", "Activity", "Creation", "Locked");
1894                 }
1895                 AST_LIST_TRAVERSE(&confs, cnf, list) {
1896                         hr = (now - cnf->start) / 3600;
1897                         min = ((now - cnf->start) % 3600) / 60;
1898                         sec = (now - cnf->start) % 60;
1899                         if (!concise) {
1900                                 if (cnf->markedusers == 0) {
1901                                         ast_str_set(&marked_users, 0, "N/A ");
1902                                 } else {
1903                                         ast_str_set(&marked_users, 0, "%4.4d", cnf->markedusers);
1904                                 }
1905                                 ast_cli(a->fd, MC_DATA_FORMAT, cnf->confno, cnf->users,
1906                                         ast_str_buffer(marked_users), hr, min, sec,
1907                                         cnf->isdynamic ? "Dynamic" : "Static", cnf->locked ? "Yes" : "No");
1908                         } else {
1909                                 ast_cli(a->fd, "%s!%d!%d!%02d:%02d:%02d!%d!%d\n",
1910                                         cnf->confno,
1911                                         cnf->users,
1912                                         cnf->markedusers,
1913                                         hr, min, sec,
1914                                         cnf->isdynamic,
1915                                         cnf->locked);
1916                         }
1917
1918                         total += cnf->users;
1919                 }
1920                 AST_LIST_UNLOCK(&confs);
1921                 if (!concise) {
1922                         ast_cli(a->fd, "* Total number of MeetMe users: %d\n", total);
1923                 }
1924                 ast_free(marked_users);
1925                 return CLI_SUCCESS;
1926         }
1927         if (a->argc == 3 || (a->argc == 4 && !strcasecmp(a->argv[3], STR_CONCISE))) {
1928                 struct ao2_iterator user_iter;
1929                 int concise = (a->argc == 4);
1930
1931                 /* List all the users in a conference */
1932                 if (AST_LIST_EMPTY(&confs)) {
1933                         if (!concise) {
1934                                 ast_cli(a->fd, "No active MeetMe conferences.\n");
1935                         }
1936                         return CLI_SUCCESS;
1937                 }
1938                 /* Find the right conference */
1939                 AST_LIST_LOCK(&confs);
1940                 AST_LIST_TRAVERSE(&confs, cnf, list) {
1941                         if (strcmp(cnf->confno, a->argv[2]) == 0) {
1942                                 break;
1943                         }
1944                 }
1945                 if (!cnf) {
1946                         if (!concise)
1947                                 ast_cli(a->fd, "No such conference: %s.\n", a->argv[2]);
1948                         AST_LIST_UNLOCK(&confs);
1949                         return CLI_SUCCESS;
1950                 }
1951                 /* Show all the users */
1952                 time(&now);
1953                 user_iter = ao2_iterator_init(cnf->usercontainer, 0);
1954                 while((user = ao2_iterator_next(&user_iter))) {
1955                         hr = (now - user->jointime) / 3600;
1956                         min = ((now - user->jointime) % 3600) / 60;
1957                         sec = (now - user->jointime) % 60;
1958                         if (!concise) {
1959                                 ast_cli(a->fd, "User #: %-2.2d %12.12s %-20.20s Channel: %s %s %s %s %s %s %02d:%02d:%02d\n",
1960                                         user->user_no,
1961                                         S_COR(ast_channel_caller(user->chan)->id.number.valid, ast_channel_caller(user->chan)->id.number.str, "<unknown>"),
1962                                         S_COR(ast_channel_caller(user->chan)->id.name.valid, ast_channel_caller(user->chan)->id.name.str, "<no name>"),
1963                                         ast_channel_name(user->chan),
1964                                         ast_test_flag64(&user->userflags, CONFFLAG_ADMIN) ? "(Admin)" : "",
1965                                         ast_test_flag64(&user->userflags, CONFFLAG_MONITOR) ? "(Listen only)" : "",
1966                                         user->adminflags & ADMINFLAG_MUTED ? "(Admin Muted)" : user->adminflags & ADMINFLAG_SELFMUTED ? "(Muted)" : "",
1967                                         user->adminflags & ADMINFLAG_T_REQUEST ? "(Request to Talk)" : "",
1968                                         istalking(user->talking), hr, min, sec); 
1969                         } else {
1970                                 ast_cli(a->fd, "%d!%s!%s!%s!%s!%s!%s!%s!%d!%02d:%02d:%02d\n",
1971                                         user->user_no,
1972                                         S_COR(ast_channel_caller(user->chan)->id.number.valid, ast_channel_caller(user->chan)->id.number.str, ""),
1973                                         S_COR(ast_channel_caller(user->chan)->id.name.valid, ast_channel_caller(user->chan)->id.name.str, ""),
1974                                         ast_channel_name(user->chan),
1975                                         ast_test_flag64(&user->userflags, CONFFLAG_ADMIN) ? "1" : "",
1976                                         ast_test_flag64(&user->userflags, CONFFLAG_MONITOR) ? "1" : "",
1977                                         user->adminflags & (ADMINFLAG_MUTED | ADMINFLAG_SELFMUTED) ? "1" : "",
1978                                         user->adminflags & ADMINFLAG_T_REQUEST ? "1" : "",
1979                                         user->talking, hr, min, sec);
1980                         }
1981                         ao2_ref(user, -1);
1982                 }
1983                 ao2_iterator_destroy(&user_iter);
1984                 if (!concise) {
1985                         ast_cli(a->fd, "%d users in that conference.\n", cnf->users);
1986                 }
1987                 AST_LIST_UNLOCK(&confs);
1988                 return CLI_SUCCESS;
1989         }
1990         return CLI_SHOWUSAGE;
1991 }
1992
1993
1994 static char *meetme_cmd_helper(struct ast_cli_args *a)
1995 {
1996         /* Process the command */
1997         struct ast_str *cmdline;
1998
1999         /* Max confno length */
2000         if (!(cmdline = ast_str_create(MAX_CONFNUM))) {
2001                 return CLI_FAILURE;
2002         }
2003
2004         ast_str_set(&cmdline, 0, "%s", a->argv[2]);     /* Argv 2: conference number */
2005         if (strcasestr(a->argv[1], "lock")) {
2006                 if (strcasecmp(a->argv[1], "lock") == 0) {
2007                         /* Lock */
2008                         ast_str_append(&cmdline, 0, ",L");
2009                 } else {
2010                         /* Unlock */
2011                         ast_str_append(&cmdline, 0, ",l");
2012                 }
2013         } else if (strcasestr(a->argv[1], "mute")) { 
2014                 if (strcasecmp(a->argv[1], "mute") == 0) {
2015                         /* Mute */
2016                         if (strcasecmp(a->argv[3], "all") == 0) {
2017                                 ast_str_append(&cmdline, 0, ",N");
2018                         } else {
2019                                 ast_str_append(&cmdline, 0, ",M,%s", a->argv[3]);       
2020                         }
2021                 } else {
2022                         /* Unmute */
2023                         if (strcasecmp(a->argv[3], "all") == 0) {
2024                                 ast_str_append(&cmdline, 0, ",n");
2025                         } else {
2026                                 ast_str_append(&cmdline, 0, ",m,%s", a->argv[3]);
2027                         }
2028                 }
2029         } else if (strcasecmp(a->argv[1], "kick") == 0) {
2030                 if (strcasecmp(a->argv[3], "all") == 0) {
2031                         /* Kick all */
2032                         ast_str_append(&cmdline, 0, ",K");
2033                 } else {
2034                         /* Kick a single user */
2035                         ast_str_append(&cmdline, 0, ",k,%s", a->argv[3]);
2036                 }
2037         } else {
2038                 /*
2039                  * Should never get here because it is already filtered by the
2040                  * callers.
2041                  */
2042                 ast_free(cmdline);
2043                 return CLI_SHOWUSAGE;
2044         }
2045
2046         ast_debug(1, "Cmdline: %s\n", ast_str_buffer(cmdline));
2047
2048         admin_exec(NULL, ast_str_buffer(cmdline));
2049         ast_free(cmdline);
2050
2051         return CLI_SUCCESS;
2052 }
2053
2054 static char *meetme_lock_cmd(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
2055 {
2056         switch (cmd) {
2057         case CLI_INIT:
2058                 e->command = "meetme {lock|unlock}";
2059                 e->usage =
2060                         "Usage: meetme lock|unlock <confno>\n"
2061                         "       Lock or unlock a conference to new users.\n";
2062                 return NULL;
2063         case CLI_GENERATE:
2064                 return complete_meetmecmd_lock(a->word, a->pos, a->n);
2065         }
2066
2067         if (a->argc != 3) {
2068                 return CLI_SHOWUSAGE;
2069         }
2070
2071         return meetme_cmd_helper(a);
2072 }
2073
2074 static char *meetme_kick_cmd(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
2075 {
2076         switch (cmd) {
2077         case CLI_INIT:
2078                 e->command = "meetme kick";
2079                 e->usage =
2080                         "Usage: meetme kick <confno> all|<userno>\n"
2081                         "       Kick a conference or a user in a conference.\n";
2082                 return NULL;
2083         case CLI_GENERATE:
2084                 return complete_meetmecmd_mute_kick(a->line, a->word, a->pos, a->n);
2085         }
2086
2087         if (a->argc != 4) {
2088                 return CLI_SHOWUSAGE;
2089         }
2090
2091         return meetme_cmd_helper(a);
2092 }
2093
2094 static char *meetme_mute_cmd(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
2095 {
2096         switch (cmd) {
2097         case CLI_INIT:
2098                 e->command = "meetme {mute|unmute}";
2099                 e->usage =
2100                         "Usage: meetme mute|unmute <confno> all|<userno>\n"
2101                         "       Mute or unmute a conference or a user in a conference.\n";
2102                 return NULL;
2103         case CLI_GENERATE:
2104                 return complete_meetmecmd_mute_kick(a->line, a->word, a->pos, a->n);
2105         }
2106
2107         if (a->argc != 4) {
2108                 return CLI_SHOWUSAGE;
2109         }
2110
2111         return meetme_cmd_helper(a);
2112 }
2113
2114 static const char *sla_hold_str(unsigned int hold_access)
2115 {
2116         const char *hold = "Unknown";
2117
2118         switch (hold_access) {
2119         case SLA_HOLD_OPEN:
2120                 hold = "Open";
2121                 break;
2122         case SLA_HOLD_PRIVATE:
2123                 hold = "Private";
2124         default:
2125                 break;
2126         }
2127
2128         return hold;
2129 }
2130
2131 static char *sla_show_trunks(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
2132 {
2133         struct ao2_iterator i;
2134         struct sla_trunk *trunk;
2135
2136         switch (cmd) {
2137         case CLI_INIT:
2138                 e->command = "sla show trunks";
2139                 e->usage =
2140                         "Usage: sla show trunks\n"
2141                         "       This will list all trunks defined in sla.conf\n";
2142                 return NULL;
2143         case CLI_GENERATE:
2144                 return NULL;
2145         }
2146
2147         ast_cli(a->fd, "\n"
2148                     "=============================================================\n"
2149                     "=== Configured SLA Trunks ===================================\n"
2150                     "=============================================================\n"
2151                     "===\n");
2152         i = ao2_iterator_init(sla_trunks, 0);
2153         for (; (trunk = ao2_iterator_next(&i)); ao2_ref(trunk, -1)) {
2154                 struct sla_station_ref *station_ref;
2155                 char ring_timeout[16] = "(none)";
2156
2157                 ao2_lock(trunk);
2158
2159                 if (trunk->ring_timeout) {
2160                         snprintf(ring_timeout, sizeof(ring_timeout), "%u Seconds", trunk->ring_timeout);
2161                 }
2162
2163                 ast_cli(a->fd, "=== ---------------------------------------------------------\n"
2164                             "=== Trunk Name:       %s\n"
2165                             "=== ==> Device:       %s\n"
2166                             "=== ==> AutoContext:  %s\n"
2167                             "=== ==> RingTimeout:  %s\n"
2168                             "=== ==> BargeAllowed: %s\n"
2169                             "=== ==> HoldAccess:   %s\n"
2170                             "=== ==> Stations ...\n",
2171                             trunk->name, trunk->device, 
2172                             S_OR(trunk->autocontext, "(none)"), 
2173                             ring_timeout,
2174                             trunk->barge_disabled ? "No" : "Yes",
2175                             sla_hold_str(trunk->hold_access));
2176
2177                 AST_LIST_TRAVERSE(&trunk->stations, station_ref, entry) {
2178                         ast_cli(a->fd, "===    ==> Station name: %s\n", station_ref->station->name);
2179                 }
2180
2181                 ast_cli(a->fd, "=== ---------------------------------------------------------\n===\n");
2182
2183                 ao2_unlock(trunk);
2184         }
2185         ao2_iterator_destroy(&i);
2186         ast_cli(a->fd, "=============================================================\n\n");
2187
2188         return CLI_SUCCESS;
2189 }
2190
2191 static const char *trunkstate2str(enum sla_trunk_state state)
2192 {
2193 #define S(e) case e: return # e;
2194         switch (state) {
2195         S(SLA_TRUNK_STATE_IDLE)
2196         S(SLA_TRUNK_STATE_RINGING)
2197         S(SLA_TRUNK_STATE_UP)
2198         S(SLA_TRUNK_STATE_ONHOLD)
2199         S(SLA_TRUNK_STATE_ONHOLD_BYME)
2200         }
2201         return "Uknown State";
2202 #undef S
2203 }
2204
2205 static char *sla_show_stations(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
2206 {
2207         struct ao2_iterator i;
2208         struct sla_station *station;
2209
2210         switch (cmd) {
2211         case CLI_INIT:
2212                 e->command = "sla show stations";
2213                 e->usage =
2214                         "Usage: sla show stations\n"
2215                         "       This will list all stations defined in sla.conf\n";
2216                 return NULL;
2217         case CLI_GENERATE:
2218                 return NULL;
2219         }
2220
2221         ast_cli(a->fd, "\n" 
2222                     "=============================================================\n"
2223                     "=== Configured SLA Stations =================================\n"
2224                     "=============================================================\n"
2225                     "===\n");
2226         i = ao2_iterator_init(sla_stations, 0);
2227         for (; (station = ao2_iterator_next(&i)); ao2_ref(station, -1)) {
2228                 struct sla_trunk_ref *trunk_ref;
2229                 char ring_timeout[16] = "(none)";
2230                 char ring_delay[16] = "(none)";
2231
2232                 ao2_lock(station);
2233
2234                 if (station->ring_timeout) {
2235                         snprintf(ring_timeout, sizeof(ring_timeout), 
2236                                 "%u", station->ring_timeout);
2237                 }
2238                 if (station->ring_delay) {
2239                         snprintf(ring_delay, sizeof(ring_delay), 
2240                                 "%u", station->ring_delay);
2241                 }
2242                 ast_cli(a->fd, "=== ---------------------------------------------------------\n"
2243                             "=== Station Name:    %s\n"
2244                             "=== ==> Device:      %s\n"
2245                             "=== ==> AutoContext: %s\n"
2246                             "=== ==> RingTimeout: %s\n"
2247                             "=== ==> RingDelay:   %s\n"
2248                             "=== ==> HoldAccess:  %s\n"
2249                             "=== ==> Trunks ...\n",
2250                             station->name, station->device,
2251                             S_OR(station->autocontext, "(none)"), 
2252                             ring_timeout, ring_delay,
2253                             sla_hold_str(station->hold_access));
2254                 AST_LIST_TRAVERSE(&station->trunks, trunk_ref, entry) {
2255                         if (trunk_ref->ring_timeout) {
2256                                 snprintf(ring_timeout, sizeof(ring_timeout),
2257                                         "%u", trunk_ref->ring_timeout);
2258                         } else
2259                                 strcpy(ring_timeout, "(none)");
2260                         if (trunk_ref->ring_delay) {
2261                                 snprintf(ring_delay, sizeof(ring_delay),
2262                                         "%u", trunk_ref->ring_delay);
2263                         } else
2264                                 strcpy(ring_delay, "(none)");
2265                                 ast_cli(a->fd, "===    ==> Trunk Name: %s\n"
2266                                     "===       ==> State:       %s\n"
2267                                     "===       ==> RingTimeout: %s\n"
2268                                     "===       ==> RingDelay:   %s\n",
2269                                     trunk_ref->trunk->name,
2270                                     trunkstate2str(trunk_ref->state),
2271                                     ring_timeout, ring_delay);
2272                 }
2273                 ast_cli(a->fd, "=== ---------------------------------------------------------\n"
2274                             "===\n");
2275
2276                 ao2_unlock(station);
2277         }
2278         ao2_iterator_destroy(&i);
2279         ast_cli(a->fd, "============================================================\n"
2280                     "\n");
2281
2282         return CLI_SUCCESS;
2283 }
2284
2285 static struct ast_cli_entry cli_meetme[] = {
2286         AST_CLI_DEFINE(meetme_kick_cmd, "Kick a conference or a user in a conference."),
2287         AST_CLI_DEFINE(meetme_show_cmd, "List all conferences or a specific conference."),
2288         AST_CLI_DEFINE(meetme_lock_cmd, "Lock or unlock a conference to new users."),
2289         AST_CLI_DEFINE(meetme_mute_cmd, "Mute or unmute a conference or a user in a conference."),
2290         AST_CLI_DEFINE(sla_show_trunks, "Show SLA Trunks"),
2291         AST_CLI_DEFINE(sla_show_stations, "Show SLA Stations"),
2292 };
2293
2294 static void conf_flush(int fd, struct ast_channel *chan)
2295 {
2296         int x;
2297
2298         /* read any frames that may be waiting on the channel
2299            and throw them away
2300         */
2301         if (chan) {
2302                 struct ast_frame *f;
2303
2304                 /* when no frames are available, this will wait
2305                    for 1 millisecond maximum
2306                 */
2307                 while (ast_waitfor(chan, 1) > 0) {
2308                         f = ast_read(chan);
2309                         if (f)
2310                                 ast_frfree(f);
2311                         else /* channel was hung up or something else happened */
2312                                 break;
2313                 }
2314         }
2315
2316         /* flush any data sitting in the pseudo channel */
2317         x = DAHDI_FLUSH_ALL;
2318         if (ioctl(fd, DAHDI_FLUSH, &x))
2319                 ast_log(LOG_WARNING, "Error flushing channel\n");
2320
2321 }
2322
2323 /*! \brief Remove the conference from the list and free it.
2324
2325    We assume that this was called while holding conflock. */
2326 static int conf_free(struct ast_conference *conf)
2327 {
2328         int x;
2329         struct announce_listitem *item;
2330
2331         AST_LIST_REMOVE(&confs, conf, list);
2332
2333         meetme_stasis_generate_msg(conf, NULL, NULL, meetme_end_type(), NULL);
2334
2335         if (conf->recording == MEETME_RECORD_ACTIVE) {
2336                 conf->recording = MEETME_RECORD_TERMINATE;
2337                 AST_LIST_UNLOCK(&confs);
2338                 while (1) {
2339                         usleep(1);
2340                         AST_LIST_LOCK(&confs);
2341                         if (conf->recording == MEETME_RECORD_OFF)
2342                                 break;
2343                         AST_LIST_UNLOCK(&confs);
2344                 }
2345         }
2346
2347         for (x = 0; x < AST_FRAME_BITS; x++) {
2348                 if (conf->transframe[x])
2349                         ast_frfree(conf->transframe[x]);
2350                 if (conf->transpath[x])
2351                         ast_translator_free_path(conf->transpath[x]);
2352         }
2353         if (conf->announcethread != AST_PTHREADT_NULL) {
2354                 ast_mutex_lock(&conf->announcelistlock);
2355                 conf->announcethread_stop = 1;
2356                 ast_softhangup(conf->chan, AST_SOFTHANGUP_EXPLICIT);
2357                 ast_cond_signal(&conf->announcelist_addition);
2358                 ast_mutex_unlock(&conf->announcelistlock);
2359                 pthread_join(conf->announcethread, NULL);
2360         
2361                 while ((item = AST_LIST_REMOVE_HEAD(&conf->announcelist, entry))) {
2362                         /* If it's a voicemail greeting file we don't want to remove it */
2363                         if (!item->vmrec){
2364                                 ast_filedelete(item->namerecloc, NULL);
2365                         }
2366                         ao2_ref(item, -1);
2367                 }
2368                 ast_mutex_destroy(&conf->announcelistlock);
2369         }
2370
2371         if (conf->origframe)
2372                 ast_frfree(conf->origframe);
2373         ast_hangup(conf->lchan);
2374         ast_hangup(conf->chan);
2375         if (conf->fd >= 0)
2376                 close(conf->fd);
2377         if (conf->recordingfilename) {
2378                 ast_free(conf->recordingfilename);
2379         }
2380         if (conf->usercontainer) {
2381                 ao2_ref(conf->usercontainer, -1);
2382         }
2383         if (conf->recordingformat) {
2384                 ast_free(conf->recordingformat);
2385         }
2386         ast_mutex_destroy(&conf->playlock);
2387         ast_mutex_destroy(&conf->listenlock);
2388         ast_mutex_destroy(&conf->recordthreadlock);
2389         ast_mutex_destroy(&conf->announcethreadlock);
2390         ast_free(conf);
2391
2392         return 0;
2393 }
2394
2395 static void conf_queue_dtmf(const struct ast_conference *conf,
2396         const struct ast_conf_user *sender, struct ast_frame *f)
2397 {
2398         struct ast_conf_user *user;
2399         struct ao2_iterator user_iter;
2400
2401         user_iter = ao2_iterator_init(conf->usercontainer, 0);
2402         while ((user = ao2_iterator_next(&user_iter))) {
2403                 if (user == sender) {
2404                         ao2_ref(user, -1);
2405                         continue;
2406                 }
2407                 if (ast_write(user->chan, f) < 0)
2408                         ast_log(LOG_WARNING, "Error writing frame to channel %s\n", ast_channel_name(user->chan));
2409                 ao2_ref(user, -1);
2410         }
2411         ao2_iterator_destroy(&user_iter);
2412 }
2413
2414 static void sla_queue_event_full(enum sla_event_type type, 
2415         struct sla_trunk_ref *trunk_ref, struct sla_station *station, int lock)
2416 {
2417         struct sla_event *event;
2418
2419         if (sla.thread == AST_PTHREADT_NULL) {
2420                 ao2_ref(station, -1);
2421                 ao2_ref(trunk_ref, -1);
2422                 return;
2423         }
2424
2425         if (!(event = ast_calloc(1, sizeof(*event)))) {
2426                 ao2_ref(station, -1);
2427                 ao2_ref(trunk_ref, -1);
2428                 return;
2429         }
2430
2431         event->type = type;
2432         event->trunk_ref = trunk_ref;
2433         event->station = station;
2434
2435         if (!lock) {
2436                 AST_LIST_INSERT_TAIL(&sla.event_q, event, entry);
2437                 return;
2438         }
2439
2440         ast_mutex_lock(&sla.lock);
2441         AST_LIST_INSERT_TAIL(&sla.event_q, event, entry);
2442         ast_cond_signal(&sla.cond);
2443         ast_mutex_unlock(&sla.lock);
2444 }
2445
2446 static void sla_queue_event_nolock(enum sla_event_type type)
2447 {
2448         sla_queue_event_full(type, NULL, NULL, 0);
2449 }
2450
2451 static void sla_queue_event(enum sla_event_type type)
2452 {
2453         sla_queue_event_full(type, NULL, NULL, 1);
2454 }
2455
2456 /*! \brief Queue a SLA event from the conference */
2457 static void sla_queue_event_conf(enum sla_event_type type, struct ast_channel *chan,
2458         struct ast_conference *conf)
2459 {
2460         struct sla_station *station;
2461         struct sla_trunk_ref *trunk_ref = NULL;
2462         char *trunk_name;
2463         struct ao2_iterator i;
2464
2465         trunk_name = ast_strdupa(conf->confno);
2466         strsep(&trunk_name, "_");
2467         if (ast_strlen_zero(trunk_name)) {
2468                 ast_log(LOG_ERROR, "Invalid conference name for SLA - '%s'!\n", conf->confno);
2469                 return;
2470         }
2471
2472         i = ao2_iterator_init(sla_stations, 0);
2473         while ((station = ao2_iterator_next(&i))) {
2474                 ao2_lock(station);
2475                 AST_LIST_TRAVERSE(&station->trunks, trunk_ref, entry) {
2476                         if (trunk_ref->chan == chan && !strcmp(trunk_ref->trunk->name, trunk_name)) {
2477                                 ao2_ref(trunk_ref, 1);
2478                                 break;
2479                         }
2480                 }
2481                 ao2_unlock(station);
2482                 if (trunk_ref) {
2483                         /* station reference given to sla_queue_event_full() */
2484                         break;
2485                 }
2486                 ao2_ref(station, -1);
2487         }
2488         ao2_iterator_destroy(&i);
2489
2490         if (!trunk_ref) {
2491                 ast_debug(1, "Trunk not found for event!\n");
2492                 return;
2493         }
2494
2495         sla_queue_event_full(type, trunk_ref, station, 1);
2496 }
2497
2498 /*! \brief Decrement reference counts, as incremented by find_conf() */
2499 static int dispose_conf(struct ast_conference *conf)
2500 {
2501         int res = 0;
2502         int confno_int = 0;
2503
2504         AST_LIST_LOCK(&confs);
2505         if (ast_atomic_dec_and_test(&conf->refcount)) {
2506                 /* Take the conference room number out of an inuse state */
2507                 if ((sscanf(conf->confno, "%4d", &confno_int) == 1) && (confno_int >= 0 && confno_int < 1024)) {
2508                         conf_map[confno_int] = 0;
2509                 }
2510                 conf_free(conf);
2511                 res = 1;
2512         }
2513         AST_LIST_UNLOCK(&confs);
2514
2515         return res;
2516 }
2517
2518 static int rt_extend_conf(const char *confno)
2519 {
2520         char currenttime[32];
2521         char endtime[32];
2522         struct timeval now;
2523         struct ast_tm tm;
2524         struct ast_variable *var, *orig_var;
2525         char bookid[51];
2526
2527         if (!extendby) {
2528                 return 0;
2529         }
2530
2531         now = ast_tvnow();
2532
2533         ast_localtime(&now, &tm, NULL);
2534         ast_strftime(currenttime, sizeof(currenttime), DATE_FORMAT, &tm);
2535
2536         var = ast_load_realtime("meetme", "confno",
2537                 confno, "startTime<= ", currenttime,
2538                 "endtime>= ", currenttime, NULL);
2539
2540         orig_var = var;
2541
2542         /* Identify the specific RealTime conference */
2543         while (var) {
2544                 if (!strcasecmp(var->name, "bookid")) {
2545                         ast_copy_string(bookid, var->value, sizeof(bookid));
2546                 }
2547                 if (!strcasecmp(var->name, "endtime")) {
2548                         ast_copy_string(endtime, var->value, sizeof(endtime));
2549                 }
2550
2551                 var = var->next;
2552         }
2553         ast_variables_destroy(orig_var);
2554
2555         ast_strptime(endtime, DATE_FORMAT, &tm);
2556         now = ast_mktime(&tm, NULL);
2557
2558         now.tv_sec += extendby;
2559
2560         ast_localtime(&now, &tm, NULL);
2561         ast_strftime(currenttime, sizeof(currenttime), DATE_FORMAT, &tm);
2562         strcat(currenttime, "0"); /* Seconds needs to be 00 */
2563
2564         var = ast_load_realtime("meetme", "confno",
2565                 confno, "startTime<= ", currenttime,
2566                 "endtime>= ", currenttime, NULL);
2567
2568         /* If there is no conflict with extending the conference, update the DB */
2569         if (!var) {
2570                 ast_debug(3, "Trying to update the endtime of Conference %s to %s\n", confno, currenttime);
2571                 ast_update_realtime("meetme", "bookid", bookid, "endtime", currenttime, NULL);
2572                 return 0;
2573
2574         }
2575
2576         ast_variables_destroy(var);
2577         return -1;
2578 }
2579
2580 static void conf_start_moh(struct ast_channel *chan, const char *musicclass)
2581 {
2582         char *original_moh;
2583
2584         ast_channel_lock(chan);
2585         original_moh = ast_strdupa(ast_channel_musicclass(chan));
2586         ast_channel_musicclass_set(chan, musicclass);
2587         ast_channel_unlock(chan);
2588
2589         ast_moh_start(chan, original_moh, NULL);
2590
2591         ast_channel_lock(chan);
2592         ast_channel_musicclass_set(chan, original_moh);
2593         ast_channel_unlock(chan);
2594 }
2595
2596 static const char *get_announce_filename(enum announcetypes type)
2597 {
2598         switch (type) {
2599         case CONF_HASLEFT:
2600                 return "conf-hasleft";
2601                 break;
2602         case CONF_HASJOIN:
2603                 return "conf-hasjoin";
2604                 break;
2605         default:
2606                 return "";
2607         }
2608 }
2609
2610 static void *announce_thread(void *data)
2611 {
2612         struct announce_listitem *current;
2613         struct ast_conference *conf = data;
2614         int res;
2615         char filename[PATH_MAX] = "";
2616         AST_LIST_HEAD_NOLOCK(, announce_listitem) local_list;
2617         AST_LIST_HEAD_INIT_NOLOCK(&local_list);
2618
2619         while (!conf->announcethread_stop) {
2620                 ast_mutex_lock(&conf->announcelistlock);
2621                 if (conf->announcethread_stop) {
2622                         ast_mutex_unlock(&conf->announcelistlock);
2623                         break;
2624                 }
2625                 if (AST_LIST_EMPTY(&conf->announcelist))
2626                         ast_cond_wait(&conf->announcelist_addition, &conf->announcelistlock);
2627
2628                 AST_LIST_APPEND_LIST(&local_list, &conf->announcelist, entry);
2629                 AST_LIST_HEAD_INIT_NOLOCK(&conf->announcelist);
2630
2631                 ast_mutex_unlock(&conf->announcelistlock);
2632                 if (conf->announcethread_stop) {
2633                         break;
2634                 }
2635
2636                 for (res = 1; !conf->announcethread_stop && (current = AST_LIST_REMOVE_HEAD(&local_list, entry)); ao2_ref(current, -1)) {
2637                         ast_debug(1, "About to play %s\n", current->namerecloc);
2638                         if (!ast_fileexists(current->namerecloc, NULL, NULL))
2639                                 continue;
2640                         if ((current->confchan) && (current->confusers > 1) && !ast_check_hangup(current->confchan)) {
2641                                 if (!ast_streamfile(current->confchan, current->namerecloc, current->language))
2642                                         res = ast_waitstream(current->confchan, "");
2643                                 if (!res) {
2644                                         ast_copy_string(filename, get_announce_filename(current->announcetype), sizeof(filename));
2645                                         if (!ast_streamfile(current->confchan, filename, current->language))
2646                                                 ast_waitstream(current->confchan, "");
2647                                 }
2648                         }
2649                         if (current->announcetype == CONF_HASLEFT && current->announcetype && !current->vmrec) {
2650                                 /* only remove it if it isn't a VM recording file */
2651                                 ast_filedelete(current->namerecloc, NULL);
2652                         }
2653                 }
2654         }
2655
2656         /* thread marked to stop, clean up */
2657         while ((current = AST_LIST_REMOVE_HEAD(&local_list, entry))) {
2658                 /* only delete if it's a vm rec */
2659                 if (!current->vmrec) {
2660                         ast_filedelete(current->namerecloc, NULL);
2661                 }
2662                 ao2_ref(current, -1);
2663         }
2664         return NULL;
2665 }
2666
2667 static int can_write(struct ast_channel *chan, struct ast_flags64 *confflags)
2668 {
2669         if (!ast_test_flag64(confflags, CONFFLAG_NO_AUDIO_UNTIL_UP)) {
2670                 return 1;
2671         }
2672
2673         return (ast_channel_state(chan) == AST_STATE_UP);
2674 }
2675
2676 static void send_talking_event(struct ast_channel *chan, struct ast_conference *conf, struct ast_conf_user *user, int talking)
2677 {
2678         RAII_VAR(struct ast_json *, status_blob, status_to_json(talking), ast_json_unref);
2679         meetme_stasis_generate_msg(conf, chan, user, meetme_talking_type(), status_blob);
2680 }
2681
2682 static void set_user_talking(struct ast_channel *chan, struct ast_conference *conf, struct ast_conf_user *user, int talking, int monitor)
2683 {
2684         int last_talking = user->talking;
2685         if (last_talking == talking)
2686                 return;
2687
2688         user->talking = talking;
2689
2690         if (monitor) {
2691                 /* Check if talking state changed. Take care of -1 which means unmonitored */
2692                 int was_talking = (last_talking > 0);
2693                 int now_talking = (talking > 0);
2694                 if (was_talking != now_talking) {
2695                         send_talking_event(chan, conf, user, now_talking);
2696                 }
2697         }
2698 }
2699
2700 static int user_set_hangup_cb(void *obj, void *check_admin_arg, int flags)
2701 {
2702         struct ast_conf_user *user = obj;
2703         /* actual pointer contents of check_admin_arg is irrelevant */
2704
2705         if (!check_admin_arg || (check_admin_arg && !ast_test_flag64(&user->userflags, CONFFLAG_ADMIN))) {
2706                 user->adminflags |= ADMINFLAG_HANGUP;
2707         }
2708         return 0;
2709 }
2710
2711 static int user_set_kickme_cb(void *obj, void *check_admin_arg, int flags)
2712 {
2713         struct ast_conf_user *user = obj;
2714         /* actual pointer contents of check_admin_arg is irrelevant */
2715
2716         if (!check_admin_arg || (check_admin_arg && !ast_test_flag64(&user->userflags, CONFFLAG_ADMIN))) {
2717                 user->adminflags |= ADMINFLAG_KICKME;
2718         }
2719         return 0;
2720 }
2721
2722 static int user_set_unmuted_cb(void *obj, void *check_admin_arg, int flags)
2723 {
2724         struct ast_conf_user *user = obj;
2725         /* actual pointer contents of check_admin_arg is irrelevant */
2726
2727         if (!check_admin_arg || !ast_test_flag64(&user->userflags, CONFFLAG_ADMIN)) {
2728                 user->adminflags &= ~(ADMINFLAG_MUTED | ADMINFLAG_SELFMUTED | ADMINFLAG_T_REQUEST);
2729         }
2730         return 0;
2731 }
2732
2733 static int user_set_muted_cb(void *obj, void *check_admin_arg, int flags)
2734 {
2735         struct ast_conf_user *user = obj;
2736         /* actual pointer contents of check_admin_arg is irrelevant */
2737
2738         if (!check_admin_arg || !ast_test_flag64(&user->userflags, CONFFLAG_ADMIN)) {
2739                 user->adminflags |= ADMINFLAG_MUTED;
2740         }
2741         return 0;
2742 }
2743
2744 enum menu_modes {
2745         MENU_DISABLED = 0,
2746         MENU_NORMAL,
2747         MENU_ADMIN,
2748         MENU_ADMIN_EXTENDED,
2749 };
2750
2751 /*! \internal
2752  * \brief Processes menu options for the standard menu (accessible through the 's' option for app_meetme)
2753  *
2754  * \param menu_mode a pointer to the currently active menu_mode.
2755  * \param dtmf a pointer to the dtmf value currently being processed against the menu.
2756  * \param conf the active conference for which the user has called the menu from.
2757  * \param confflags flags used by conf for various options
2758  * \param chan ast_channel belonging to the user who called the menu
2759  * \param user which meetme conference user invoked the menu
2760  */
2761 static void meetme_menu_normal(enum menu_modes *menu_mode, int *dtmf, struct ast_conference *conf, struct ast_flags64 *confflags, struct ast_channel *chan, struct ast_conf_user *user)
2762 {
2763         switch (*dtmf) {
2764         case '1': /* Un/Mute */
2765                 *menu_mode = MENU_DISABLED;
2766
2767                 /* user can only toggle the self-muted state */
2768                 user->adminflags ^= ADMINFLAG_SELFMUTED;
2769
2770                 /* they can't override the admin mute state */
2771                 if (ast_test_flag64(confflags, CONFFLAG_MONITOR) || (user->adminflags & (ADMINFLAG_MUTED | ADMINFLAG_SELFMUTED))) {
2772                         if (!ast_streamfile(chan, "conf-muted", ast_channel_language(chan))) {
2773                                 ast_waitstream(chan, "");
2774                         }
2775                 } else {
2776                         if (!ast_streamfile(chan, "conf-unmuted", ast_channel_language(chan))) {
2777                                 ast_waitstream(chan, "");
2778                         }
2779                 }
2780                 break;
2781
2782         case '2':
2783                 *menu_mode = MENU_DISABLED;
2784                 if (user->adminflags & (ADMINFLAG_MUTED | ADMINFLAG_SELFMUTED)) {
2785                         user->adminflags |= ADMINFLAG_T_REQUEST;
2786                 }
2787
2788                 if (user->adminflags & ADMINFLAG_T_REQUEST) {
2789                         if (!ast_streamfile(chan, "beep", ast_channel_language(chan))) {
2790                                 ast_waitstream(chan, "");
2791                         }
2792                 }
2793                 break;
2794
2795         case '4':
2796                 tweak_listen_volume(user, VOL_DOWN);
2797                 break;
2798         case '5':
2799                 /* Extend RT conference */
2800                 if (rt_schedule) {
2801                         rt_extend_conf(conf->confno);
2802                 }
2803                 *menu_mode = MENU_DISABLED;
2804                 break;
2805
2806         case '6':
2807                 tweak_listen_volume(user, VOL_UP);
2808                 break;
2809
2810         case '7':
2811                 tweak_talk_volume(user, VOL_DOWN);
2812                 break;
2813
2814         case '8':
2815                 *menu_mode = MENU_DISABLED;
2816                 break;
2817
2818         case '9':
2819                 tweak_talk_volume(user, VOL_UP);
2820                 break;
2821
2822         default:
2823                 *menu_mode = MENU_DISABLED;
2824                 if (!ast_streamfile(chan, "conf-errormenu", ast_channel_language(chan))) {
2825                         ast_waitstream(chan, "");
2826                 }
2827                 break;
2828         }
2829 }
2830
2831 /*! \internal
2832  * \brief Processes menu options for the adminstrator menu (accessible through the 's' option for app_meetme)
2833  *
2834  * \param menu_mode a pointer to the currently active menu_mode.
2835  * \param dtmf a pointer to the dtmf value currently being processed against the menu.
2836  * \param conf the active conference for which the user has called the menu from.
2837  * \param confflags flags used by conf for various options
2838  * \param chan ast_channel belonging to the user who called the menu
2839  * \param user which meetme conference user invoked the menu
2840  */
2841 static void meetme_menu_admin(enum menu_modes *menu_mode, int *dtmf, struct ast_conference *conf, struct ast_flags64 *confflags, struct ast_channel *chan, struct ast_conf_user *user)
2842 {
2843         switch(*dtmf) {
2844         case '1': /* Un/Mute */
2845                 *menu_mode = MENU_DISABLED;
2846                 /* for admin, change both admin and use flags */
2847                 if (user->adminflags & (ADMINFLAG_MUTED | ADMINFLAG_SELFMUTED)) {
2848                         user->adminflags &= ~(ADMINFLAG_MUTED | ADMINFLAG_SELFMUTED);
2849                 } else {
2850                         user->adminflags |= (ADMINFLAG_MUTED | ADMINFLAG_SELFMUTED);
2851                 }
2852
2853                 if (ast_test_flag64(confflags, CONFFLAG_MONITOR) || (user->adminflags & (ADMINFLAG_MUTED | ADMINFLAG_SELFMUTED))) {
2854                         if (!ast_streamfile(chan, "conf-muted", ast_channel_language(chan))) {
2855                                 ast_waitstream(chan, "");
2856                         }
2857                 } else {
2858                         if (!ast_streamfile(chan, "conf-unmuted", ast_channel_language(chan))) {
2859                                 ast_waitstream(chan, "");
2860                         }
2861                 }
2862                 break;
2863
2864         case '2': /* Un/Lock the Conference */
2865                 *menu_mode = MENU_DISABLED;
2866                 if (conf->locked) {
2867                         conf->locked = 0;
2868                         if (!ast_streamfile(chan, "conf-unlockednow", ast_channel_language(chan))) {
2869                                 ast_waitstream(chan, "");
2870                         }
2871                 } else {
2872                         conf->locked = 1;
2873                         if (!ast_streamfile(chan, "conf-lockednow", ast_channel_language(chan))) {
2874                                 ast_waitstream(chan, "");
2875                         }
2876                 }
2877                 break;
2878
2879         case '3': /* Eject last user */
2880         {
2881                 struct ast_conf_user *usr = NULL;
2882                 int max_no = 0;
2883                 ao2_callback(conf->usercontainer, OBJ_NODATA, user_max_cmp, &max_no);
2884                 *menu_mode = MENU_DISABLED;
2885                 usr = ao2_find(conf->usercontainer, &max_no, 0);
2886                 if ((ast_channel_name(usr->chan) == ast_channel_name(chan)) || ast_test_flag64(&usr->userflags, CONFFLAG_ADMIN)) {
2887                         if (!ast_streamfile(chan, "conf-errormenu", ast_channel_language(chan))) {
2888                                 ast_waitstream(chan, "");
2889                         }
2890                 } else {
2891                         usr->adminflags |= ADMINFLAG_KICKME;
2892                 }
2893                 ao2_ref(usr, -1);
2894                 ast_stopstream(chan);
2895                 break;
2896         }
2897
2898         case '4':
2899                 tweak_listen_volume(user, VOL_DOWN);
2900                 break;
2901
2902         case '5':
2903                 /* Extend RT conference */
2904                 if (rt_schedule) {
2905                         if (!rt_extend_conf(conf->confno)) {
2906                                 if (!ast_streamfile(chan, "conf-extended", ast_channel_language(chan))) {
2907                                         ast_waitstream(chan, "");
2908                                 }
2909                         } else {
2910                                 if (!ast_streamfile(chan, "conf-nonextended", ast_channel_language(chan))) {
2911                                         ast_waitstream(chan, "");
2912                                 }
2913                         }
2914                         ast_stopstream(chan);
2915                 }
2916                 *menu_mode = MENU_DISABLED;
2917                 break;
2918
2919         case '6':
2920                 tweak_listen_volume(user, VOL_UP);
2921                 break;
2922
2923         case '7':
2924                 tweak_talk_volume(user, VOL_DOWN);
2925                 break;
2926
2927         case '8':
2928                 if (!ast_streamfile(chan, "conf-adminmenu-menu8", ast_channel_language(chan))) {
2929                         /* If the user provides DTMF while playing the sound, we want to drop right into the extended menu function with new DTMF once we get out of here. */
2930                         *dtmf = ast_waitstream(chan, AST_DIGIT_ANY);
2931                         ast_stopstream(chan);
2932                 }
2933                 *menu_mode = MENU_ADMIN_EXTENDED;
2934                 break;
2935
2936         case '9':
2937                 tweak_talk_volume(user, VOL_UP);
2938                 break;
2939         default:
2940                 menu_mode = MENU_DISABLED;
2941                 /* Play an error message! */
2942                 if (!ast_streamfile(chan, "conf-errormenu", ast_channel_language(chan))) {
2943                         ast_waitstream(chan, "");
2944                 }
2945                 break;
2946         }
2947
2948 }
2949
2950 /*! \internal
2951  * \brief Processes menu options for the extended administrator menu (accessible through option 8 on the administrator menu)
2952  *
2953  * \param menu_mode a pointer to the currently active menu_mode.
2954  * \param dtmf a pointer to the dtmf value currently being processed against the menu.
2955  * \param conf the active conference for which the user has called the menu from.
2956  * \param confflags flags used by conf for various options
2957  * \param chan ast_channel belonging to the user who called the menu
2958  * \param user which meetme conference user invoked the menu
2959  * \param recordingtmp character buffer which may hold the name of the conference recording file
2960  * \param dahdic dahdi configuration info used by the main conference loop
2961  */
2962
2963 static void meetme_menu_admin_extended(enum menu_modes *menu_mode, int *dtmf, struct ast_conference *conf, struct ast_flags64 *confflags, struct ast_channel *chan, struct ast_conf_user *user, char *recordingtmp, int recordingtmp_size, struct dahdi_confinfo *dahdic, struct ast_format_cap *cap_slin)
2964 {
2965         int keepplaying;
2966         int playednamerec;