update for memory api change

diff --git a/gst/multifile/gstmultifilesink.c b/gst/multifile/gstmultifilesink.c
index 56944402b6af5cd803129524c183d798d40e4eee..2ce4ad0584f011ff17fa8b4ca08385fa07fb5b47 100644 (file)
--- a/gst/multifile/gstmultifilesink.c
+++ b/gst/multifile/gstmultifilesink.c
@@ -692,8 +692,8 @@ buffer_list_copy_data (GstBuffer ** buf, guint idx, gpointer data)
   for (i = 0; i < num; ++i) {
     GstMemory *mem;
 
-    mem = gst_buffer_peek_memory (*buf, i, GST_MAP_READ);
-    gst_buffer_take_memory (dest, -1, gst_memory_ref (mem));
+    mem = gst_buffer_get_memory (*buf, i);
+    gst_buffer_take_memory (dest, -1, mem);
   }
 
   return TRUE;

diff --git a/gst/udp/gstmultiudpsink.c b/gst/udp/gstmultiudpsink.c
index a13b3601bbb7e127b3083eb2333cfec0735d3e33..9766a84cc033a0ec942efcc0dea307b8ee624ac9 100644 (file)
--- a/gst/udp/gstmultiudpsink.c
+++ b/gst/udp/gstmultiudpsink.c
@@ -458,7 +458,7 @@ gst_multiudpsink_render (GstBaseSink * bsink, GstBuffer * buffer)
 
   size = 0;
   for (i = 0; i < n_mem; i++) {
-    mem = gst_buffer_peek_memory (buffer, i, GST_MAP_READ);
+    mem = gst_buffer_get_memory (buffer, i);
     gst_memory_map (mem, &map[i], GST_MAP_READ);
 
     if (map[i].size > UDP_MAX_SIZE) {
@@ -510,8 +510,10 @@ gst_multiudpsink_render (GstBaseSink * bsink, GstBuffer * buffer)
   g_mutex_unlock (&sink->client_lock);
 
   /* unmap all memory again */
-  for (i = 0; i < n_mem; i++)
+  for (i = 0; i < n_mem; i++) {
     gst_memory_unmap (map[i].memory, &map[i]);
+    gst_memory_unref (map[i].memory);
+  }
 
   g_free (vec);
   g_free (map);