[mod_spandsp] add fax_trace_dir channel variable. When set, it will write spandsp...

diff --git a/src/mod/applications/mod_spandsp/mod_spandsp.h b/src/mod/applications/mod_spandsp/mod_spandsp.h
index 216895dd2993ba53ee34cde70f1673c0da6be732..01f79e254df00b6eb939901622719201524e00ff 100644 (file)
--- a/src/mod/applications/mod_spandsp/mod_spandsp.h
+++ b/src/mod/applications/mod_spandsp/mod_spandsp.h
@@ -110,6 +110,7 @@ typedef enum {
 struct mod_spandsp_log_data {
        switch_log_level_t verbose_log_level;
        switch_core_session_t *session;
+       FILE *trace_file;
 };
 typedef struct mod_spandsp_log_data mod_spandsp_log_data_t;
 

diff --git a/src/mod/applications/mod_spandsp/mod_spandsp_fax.c b/src/mod/applications/mod_spandsp/mod_spandsp_fax.c
index 14c2bb253bbf02a81a02d54f94503cd34eca8a31..4f5d825a36fc06f1e958b643537c1fee28ff69d7 100644 (file)
--- a/src/mod/applications/mod_spandsp/mod_spandsp_fax.c
+++ b/src/mod/applications/mod_spandsp/mod_spandsp_fax.c
@@ -107,6 +107,7 @@ struct pvt_s {
        int enable_grayscale_to_bilevel;
        int verbose;
        switch_log_level_t verbose_log_level;
+       FILE *trace_file;
        int caller;
 
        int tx_page_start;
@@ -299,6 +300,9 @@ void mod_spandsp_log_message(void *user_data, int level, const char *msg)
 
        if (!zstr(msg)) {
                switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), fs_log_level, "%s", msg);
+               if (log_data && log_data->trace_file) {
+                       fwrite(msg, strlen(msg) * sizeof(const char), 1, log_data->trace_file);
+               }
        }
 }
 
@@ -818,6 +822,7 @@ static switch_status_t spanfax_init(pvt_t *pvt, transport_mode_t trans_mode)
                        mod_spandsp_log_data_t *log_data = switch_core_session_alloc(pvt->session, sizeof(*log_data));
                        log_data->session = pvt->session;
                        log_data->verbose_log_level = pvt->verbose_log_level;
+                       log_data->trace_file = pvt->trace_file;
                        span_log_set_message_handler(fax_get_logging_state(fax), mod_spandsp_log_message, log_data);
                        span_log_set_message_handler(t30_get_logging_state(t30), mod_spandsp_log_message, log_data);
                }
@@ -877,6 +882,7 @@ static switch_status_t spanfax_init(pvt_t *pvt, transport_mode_t trans_mode)
                                mod_spandsp_log_data_t *log_data = switch_core_session_alloc(pvt->session, sizeof(*log_data));
                                log_data->session = pvt->session;
                                log_data->verbose_log_level = pvt->verbose_log_level;
+                               log_data->trace_file = pvt->trace_file;
                                span_log_set_message_handler(t38_terminal_get_logging_state(t38), mod_spandsp_log_message, log_data);
                                span_log_set_message_handler(t30_get_logging_state(t30), mod_spandsp_log_message, log_data);
                        }
@@ -939,6 +945,7 @@ static switch_status_t spanfax_init(pvt_t *pvt, transport_mode_t trans_mode)
                        mod_spandsp_log_data_t *log_data = switch_core_session_alloc(pvt->session, sizeof(*log_data));
                        log_data->session = pvt->session;
                        log_data->verbose_log_level = pvt->verbose_log_level;
+                       log_data->trace_file = pvt->trace_file;
                        span_log_set_message_handler(t38_gateway_get_logging_state(pvt->t38_gateway_state), mod_spandsp_log_message, log_data);
                        span_log_set_message_handler(t38_core_get_logging_state(pvt->t38_core), mod_spandsp_log_message, log_data);
                }
@@ -1083,6 +1090,12 @@ static switch_status_t spanfax_destroy(pvt_t *pvt)
        if (pvt->udptl_state) {
                udptl_release(pvt->udptl_state);
        }
+
+       if (pvt->trace_file) {
+               fclose(pvt->trace_file);
+               pvt->trace_file = NULL;
+       }
+
        return SWITCH_STATUS_SUCCESS;
 }
 
@@ -1403,6 +1416,12 @@ static pvt_t *pvt_init(switch_core_session_t *session, mod_spandsp_fax_applicati
                }
        }
 
+       if ((tmp = switch_channel_get_variable(channel, "fax_trace_dir"))) {
+               const char *trace_filename = switch_core_session_sprintf(session, "%s"SWITCH_PATH_SEPARATOR"fax-%s.log", tmp, switch_core_session_get_uuid(session));
+               switch_dir_make_recursive(tmp, SWITCH_DEFAULT_DIR_PERMS, switch_core_session_get_pool(session));
+               pvt->trace_file = fopen(trace_filename, "w");
+       }
+
        if ((tmp = switch_channel_get_variable(channel, "fax_force_caller"))) {
                if (switch_true(tmp)) {
                        pvt->caller = 1;