qtkitvideosrc: fix up refcounting

Should keep a strong reference to the device, but we don't need to manage
the reference count of elements of an NSMutableArray as it takes care of
that for us.

diff --git a/sys/applemedia/qtkitvideosrc.m b/sys/applemedia/qtkitvideosrc.m
index 1e9e40726ebff3e8e265edbd2a78acfb3c7ec4b9..b50acf32b2382b33bdc2f97d860c12db37ad9c1c 100644 (file)
--- a/sys/applemedia/qtkitvideosrc.m
+++ b/sys/applemedia/qtkitvideosrc.m
@@ -187,6 +187,7 @@ static GstPushSrcClass * parent_class;
     }
     device = [devices objectAtIndex:deviceIndex];
   }
+  [device retain];
 
   GST_INFO ("Opening '%s'", [[device localizedDisplayName] UTF8String]);
 
@@ -194,6 +195,8 @@ static GstPushSrcClass * parent_class;
     GST_ELEMENT_ERROR (element, RESOURCE, NOT_FOUND,
         ("Failed to open device '%s'",
             [[device localizedDisplayName] UTF8String]), (NULL));
+    [device release];
+    device = nil;
     return NO;
   }
 
@@ -213,6 +216,7 @@ static GstPushSrcClass * parent_class;
   [output release];
   output = nil;
 
+  [device release];
   device = nil;
 }
 
@@ -276,8 +280,6 @@ static GstPushSrcClass * parent_class;
   [session stopRunning];
   [output setDelegate:nil];
 
-  for (id frame in queue)
-    CVBufferRelease ((CVImageBufferRef) frame);
   [queueLock release];
   queueLock = nil;
   [queue release];
@@ -356,12 +358,9 @@ static GstPushSrcClass * parent_class;
     return;
   }
 
-  if ([queue count] == FRAME_QUEUE_SIZE) {
-    CVBufferRelease ((CVImageBufferRef) [queue lastObject]);
+  if ([queue count] == FRAME_QUEUE_SIZE)
     [queue removeLastObject];
-  }
 
-  CVBufferRetain (videoFrame);
   [queue insertObject:(id)videoFrame
               atIndex:0];
 
@@ -379,6 +378,7 @@ static GstPushSrcClass * parent_class;
   }
 
   frame = (CVPixelBufferRef) [queue lastObject];
+  CVBufferRetain (frame);
   [queue removeLastObject];
   [queueLock unlockWithCondition:
       ([queue count] == 0) ? NO_FRAMES : HAS_FRAME_OR_STOP_REQUEST];
@@ -657,4 +657,3 @@ gst_qtkit_video_src_create (GstPushSrc * pushsrc, GstBuffer ** buf)
 
   return ret;
 }
-