[mod_av] fix leak (#211)

diff --git a/src/mod/applications/mod_av/avformat.c b/src/mod/applications/mod_av/avformat.c
index 74e3a8ea1ae45d36c7db9d9f67b7934d80944996..96684d3d28e571edde1c2ca00b309e34bf821f21 100644 (file)
--- a/src/mod/applications/mod_av/avformat.c
+++ b/src/mod/applications/mod_av/avformat.c
@@ -784,6 +784,7 @@ static void flush_video_pkt_queue(switch_queue_t *q)
 
        while (switch_queue_trypop(q, (void **)&pkt) == SWITCH_STATUS_SUCCESS) {
                av_packet_unref(pkt);
+               free(pkt);
        }
 }
 

diff --git a/src/mod/applications/mod_av/test/test_avformat.c b/src/mod/applications/mod_av/test/test_avformat.c
index 8520a558e6824ba0c667a7a7a4849fb25af67ac7..2304ca8c59b4d89e69ed676981cb3d333d6a718b 100644 (file)
--- a/src/mod/applications/mod_av/test/test_avformat.c
+++ b/src/mod/applications/mod_av/test/test_avformat.c
@@ -178,15 +178,18 @@ FST_CORE_BEGIN("conf")
                        status = switch_core_file_open(&fh, path, 1, 8000, flags, fst_pool);
                        fst_requires(status == SWITCH_STATUS_SUCCESS);
                        fst_requires(switch_test_flag(&fh, SWITCH_FILE_OPEN));
-                       frame.data = data;
+                       frame.packet = data;
+                       frame.data = data + 12;
+                       frame.buflen = SWITCH_RECOMMENDED_BUFFER_SIZE;
 
                        do {
-                               frame.datalen = SWITCH_RECOMMENDED_BUFFER_SIZE;
+                               frame.datalen = SWITCH_RECOMMENDED_BUFFER_SIZE - 12;
                                status = switch_core_file_read(&fh, data, &len);
                                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "status: %d len: %d\n", status, (int)len);
                                fst_check(frame.img == NULL);
-                               frame.datalen = SWITCH_RECOMMENDED_BUFFER_SIZE;
+                               frame.datalen = SWITCH_RECOMMENDED_BUFFER_SIZE - 12;
                                status = switch_core_file_read_video(&fh, &frame, 0);
+                               fst_check(frame.img == NULL);
                                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "status: %d len: %d %02x\n", status, frame.datalen, *(uint8_t *)frame.data);
                        } while (status == SWITCH_STATUS_MORE_DATA);