[asterisk-commits] trunk - r8070 in /trunk: ./ configs/
include/asterisk/ res/
asterisk-commits at lists.digium.com
asterisk-commits at lists.digium.com
Fri Jan 13 18:32:31 CST 2006
Author: mogorman
Date: Fri Jan 13 18:32:30 2006
New Revision: 8070
URL: http://svn.digium.com/view/asterisk?rev=8070&view=rev
Log:
added feature for pausing and unpausing the
monitor app from manager and in the call through
features.conf bug 5395 for the patch
Modified:
trunk/channel.c
trunk/configs/features.conf.sample
trunk/include/asterisk/monitor.h
trunk/res/res_monitor.c
Modified: trunk/channel.c
URL: http://svn.digium.com/view/asterisk/trunk/channel.c?rev=8070&r1=8069&r2=8070&view=diff
==============================================================================
--- trunk/channel.c (original)
+++ trunk/channel.c Fri Jan 13 18:32:30 2006
@@ -1899,8 +1899,10 @@
} else
chan->insmpl += f->samples;
#endif
- if (ast_writestream(chan->monitor->read_stream, f) < 0)
- ast_log(LOG_WARNING, "Failed to write data to channel monitor read stream\n");
+ if (chan->monitor->state == AST_MONITOR_RUNNING) {
+ if (ast_writestream(chan->monitor->read_stream, f) < 0)
+ ast_log(LOG_WARNING, "Failed to write data to channel monitor read stream\n");
+ }
}
if (chan->readtrans) {
f = ast_translate(chan->readtrans, f, 1);
@@ -2260,8 +2262,10 @@
} else
chan->outsmpl += f->samples;
#endif
- if (ast_writestream(chan->monitor->write_stream, f) < 0)
- ast_log(LOG_WARNING, "Failed to write data to channel monitor write stream\n");
+ if (chan->monitor->state == AST_MONITOR_RUNNING) {
+ if (ast_writestream(chan->monitor->write_stream, f) < 0)
+ ast_log(LOG_WARNING, "Failed to write data to channel monitor write stream\n");
+ }
}
res = chan->tech->write(chan, f);
Modified: trunk/configs/features.conf.sample
URL: http://svn.digium.com/view/asterisk/trunk/configs/features.conf.sample?rev=8070&r1=8069&r2=8070&view=diff
==============================================================================
--- trunk/configs/features.conf.sample (original)
+++ trunk/configs/features.conf.sample Fri Jan 13 18:32:30 2006
@@ -32,4 +32,5 @@
[applicationmap]
;testfeature => #9,callee,Playback,tt-monkeys ;Play tt-monkeys to
;callee if #9 was pressed
-
+;pauseMonitor => #1,caller,Pausemonitor ;Pause monitoring on channel
+;unpauseMonitor => #3,caller,UnPauseMonitor ;Unpause monitoring on channel
Modified: trunk/include/asterisk/monitor.h
URL: http://svn.digium.com/view/asterisk/trunk/include/asterisk/monitor.h?rev=8070&r1=8069&r2=8070&view=diff
==============================================================================
--- trunk/include/asterisk/monitor.h (original)
+++ trunk/include/asterisk/monitor.h Fri Jan 13 18:32:30 2006
@@ -27,6 +27,11 @@
struct ast_channel;
+enum AST_MONITORING_STATE {
+ AST_MONITOR_RUNNING,
+ AST_MONITOR_PAUSED
+};
+
/*! Responsible for channel monitoring data */
struct ast_channel_monitor {
struct ast_filestream *read_stream;
@@ -37,6 +42,7 @@
int filename_changed;
char *format;
int joinfiles;
+ enum AST_MONITORING_STATE state;
int (*stop)(struct ast_channel *chan, int need_lock);
};
@@ -53,4 +59,14 @@
void ast_monitor_setjoinfiles(struct ast_channel *chan, int turnon);
+/* Pause monitoring of a channel */
+int ast_monitor_pause(struct ast_channel *chan);
+
+/* Unpause monitoring of a channel */
+int ast_monitor_unpause(struct ast_channel *chan);
+
+int pause_monitor_exec(struct ast_channel *chan, void *data);
+
+int unpause_monitor_exec(struct ast_channel *chan, void *data);
+
#endif /* _ASTERISK_MONITOR_H */
Modified: trunk/res/res_monitor.c
URL: http://svn.digium.com/view/asterisk/trunk/res/res_monitor.c?rev=8070&r1=8069&r2=8070&view=diff
==============================================================================
--- trunk/res/res_monitor.c (original)
+++ trunk/res/res_monitor.c Fri Jan 13 18:32:30 2006
@@ -49,6 +49,23 @@
#include "asterisk/config.h"
AST_MUTEX_DEFINE_STATIC(monitorlock);
+
+#define LOCK_IF_NEEDED(lock, needed) \
+ do { \
+ if (needed) { \
+ if (ast_mutex_lock(lock)) { \
+ ast_log(LOG_WARNING, "Unable to lock channel\n"); \
+ return -1; \
+ } \
+ } \
+ } while(0)
+
+#define UNLOCK_IF_NEEDED(lock, needed) \
+ do { \
+ if (needed) { \
+ ast_mutex_unlock(lock); \
+ } \
+ } while(0) \
static unsigned long seq = 0;
@@ -89,6 +106,29 @@
"Changes monitoring filename of a channel. Has no effect if the channel is not monitored\n"
"The argument is the new filename base to use for monitoring this channel.\n";
+static char *pausemonitor_synopsis = "Pause monitoring of a channel";
+
+static char *pausemonitor_descrip = "PauseMonitor\n"
+ "Pauses monitoring of a channel until it is re-enabled by a call to UnpauseMonitor.\n";
+
+static char *unpausemonitor_synopsis = "Unpause monitoring of a channel";
+
+static char *unpausemonitor_descrip = "UnpauseMonitor\n"
+ "Unpauses monitoring of a channel on which monitoring had\n"
+ "previously been paused with PauseMonitor.\n";
+
+static int ast_monitor_set_state(struct ast_channel *chan, int state)
+{
+ LOCK_IF_NEEDED(&chan->lock, 1);
+ if (!chan->monitor) {
+ UNLOCK_IF_NEEDED(&chan->lock, 1);
+ return -1;
+ }
+ chan->monitor->state = state;
+ UNLOCK_IF_NEEDED(&chan->lock, 1);
+ return 0;
+}
+
/* Start monitoring a channel */
int ast_monitor_start( struct ast_channel *chan, const char *format_spec,
const char *fname_base, int need_lock)
@@ -96,12 +136,7 @@
int res = 0;
char tmp[256];
- if (need_lock) {
- if (ast_mutex_lock(&chan->lock)) {
- ast_log(LOG_WARNING, "Unable to lock channel\n");
- return -1;
- }
- }
+ LOCK_IF_NEEDED(&chan->lock, need_lock);
if (!(chan->monitor)) {
struct ast_channel_monitor *monitor;
@@ -117,8 +152,7 @@
monitor = malloc(sizeof(struct ast_channel_monitor));
if (!monitor) {
- if (need_lock)
- ast_mutex_unlock(&chan->lock);
+ UNLOCK_IF_NEEDED(&chan->lock, need_lock);
return -1;
}
memset(monitor, 0, sizeof(struct ast_channel_monitor));
@@ -196,6 +230,7 @@
return -1;
}
chan->monitor = monitor;
+ ast_monitor_set_state(chan, AST_MONITOR_RUNNING);
/* so we know this call has been monitored in case we need to bill for it or something */
pbx_builtin_setvar_helper(chan, "__MONITORED","true");
} else {
@@ -204,9 +239,8 @@
res = -1;
}
- if (need_lock) {
- ast_mutex_unlock(&chan->lock);
- }
+ UNLOCK_IF_NEEDED(&chan->lock, need_lock);
+
return res;
}
@@ -215,12 +249,7 @@
{
int delfiles = 0;
- if (need_lock) {
- if (ast_mutex_lock(&chan->lock)) {
- ast_log(LOG_WARNING, "Unable to lock channel\n");
- return -1;
- }
- }
+ LOCK_IF_NEEDED(&chan->lock, need_lock);
if (chan->monitor) {
char filename[ FILENAME_MAX ];
@@ -289,9 +318,32 @@
chan->monitor = NULL;
}
- if (need_lock)
- ast_mutex_unlock(&chan->lock);
+ UNLOCK_IF_NEEDED(&chan->lock, need_lock);
+
return 0;
+}
+
+
+/* Pause monitoring of a channel */
+int ast_monitor_pause(struct ast_channel *chan)
+{
+ return ast_monitor_set_state(chan, AST_MONITOR_PAUSED);
+}
+
+/* Unpause monitoring of a channel */
+int ast_monitor_unpause(struct ast_channel *chan)
+{
+ return ast_monitor_set_state(chan, AST_MONITOR_RUNNING);
+}
+
+int pause_monitor_exec(struct ast_channel *chan, void *data)
+{
+ return ast_monitor_pause(chan);
+}
+
+int unpause_monitor_exec(struct ast_channel *chan, void *data)
+{
+ return ast_monitor_unpause(chan);
}
/* Change monitoring filename of a channel */
@@ -302,13 +354,8 @@
ast_log(LOG_WARNING, "Cannot change monitor filename of channel %s to null", chan->name);
return -1;
}
-
- if (need_lock) {
- if (ast_mutex_lock(&chan->lock)) {
- ast_log(LOG_WARNING, "Unable to lock channel\n");
- return -1;
- }
- }
+
+ LOCK_IF_NEEDED(&chan->lock, need_lock);
if (chan->monitor) {
int directory = strchr(fname_base, '/') ? 1 : 0;
@@ -325,8 +372,7 @@
ast_log(LOG_WARNING, "Cannot change monitor filename of channel %s to %s, monitoring not started\n", chan->name, fname_base);
}
- if (need_lock)
- ast_mutex_unlock(&chan->lock);
+ UNLOCK_IF_NEEDED(&chan->lock, need_lock);
return 0;
}
@@ -546,14 +592,75 @@
chan->monitor->joinfiles = turnon;
}
+#define IS_NULL_STRING(string) ((!(string)) || (ast_strlen_zero((string))))
+
+enum MONITOR_PAUSING_ACTION
+{
+ MONITOR_ACTION_PAUSE,
+ MONITOR_ACTION_UNPAUSE
+};
+
+static int do_pause_or_unpause(struct mansession *s, struct message *m, int action)
+{
+ struct ast_channel *c = NULL;
+ char *name = astman_get_header(m, "Channel");
+
+ if (IS_NULL_STRING(name)) {
+ astman_send_error(s, m, "No channel specified");
+ return -1;
+ }
+
+ c = ast_get_channel_by_name_locked(name);
+ if (!c) {
+ astman_send_error(s, m, "No such channel");
+ return -1;
+ }
+
+ if (action == MONITOR_ACTION_PAUSE)
+ ast_monitor_pause(c);
+ else
+ ast_monitor_unpause(c);
+
+ ast_mutex_unlock(&c->lock);
+ astman_send_ack(s, m, "Paused monitoring of the channel");
+ return 0;
+}
+
+static char pause_monitor_action_help[] =
+ "Description: The 'PauseMonitor' action may be used to temporarily stop the\n"
+ " recording of a channel. The following parameters may\n"
+ " be used to control this:\n"
+ " Channel - Required. Used to specify the channel to record.\n";
+
+static int pause_monitor_action(struct mansession *s, struct message *m)
+{
+ return do_pause_or_unpause(s, m, MONITOR_ACTION_PAUSE);
+}
+
+static char unpause_monitor_action_help[] =
+ "Description: The 'UnpauseMonitor' action may be used to re-enable recording\n"
+ " of a channel after calling PauseMonitor. The following parameters may\n"
+ " be used to control this:\n"
+ " Channel - Required. Used to specify the channel to record.\n";
+
+static int unpause_monitor_action(struct mansession *s, struct message *m)
+{
+ return do_pause_or_unpause(s, m, MONITOR_ACTION_UNPAUSE);
+}
+
+
int load_module(void)
{
ast_register_application("Monitor", start_monitor_exec, monitor_synopsis, monitor_descrip);
ast_register_application("StopMonitor", stop_monitor_exec, stopmonitor_synopsis, stopmonitor_descrip);
ast_register_application("ChangeMonitor", change_monitor_exec, changemonitor_synopsis, changemonitor_descrip);
+ ast_register_application("PauseMonitor", pause_monitor_exec, pausemonitor_synopsis, pausemonitor_descrip);
+ ast_register_application("UnpauseMonitor", unpause_monitor_exec, unpausemonitor_synopsis, unpausemonitor_descrip);
ast_manager_register2("Monitor", EVENT_FLAG_CALL, start_monitor_action, monitor_synopsis, start_monitor_action_help);
ast_manager_register2("StopMonitor", EVENT_FLAG_CALL, stop_monitor_action, stopmonitor_synopsis, stop_monitor_action_help);
ast_manager_register2("ChangeMonitor", EVENT_FLAG_CALL, change_monitor_action, changemonitor_synopsis, change_monitor_action_help);
+ ast_manager_register2("PauseMonitor", EVENT_FLAG_CALL, pause_monitor_action, pausemonitor_synopsis, pause_monitor_action_help);
+ ast_manager_register2("UnpauseMonitor", EVENT_FLAG_CALL, unpause_monitor_action, unpausemonitor_synopsis, unpause_monitor_action_help);
return 0;
}
@@ -563,9 +670,14 @@
ast_unregister_application("Monitor");
ast_unregister_application("StopMonitor");
ast_unregister_application("ChangeMonitor");
+ ast_unregister_application("PauseMonitor");
+ ast_unregister_application("UnpauseMonitor");
ast_manager_unregister("Monitor");
ast_manager_unregister("StopMonitor");
ast_manager_unregister("ChangeMonitor");
+ ast_unregister_application("PauseMonitor");
+ ast_unregister_application("UnpauseMonitor");
+
return 0;
}
More information about the asterisk-commits
mailing list