SGDemuxable: Add shared demuxer.

Author: libobjc

SGPlayer/Classes/Core/SGAsset/SGPaddingSegment.m

@@ -27,9 +27,19 @@ - (instancetype)initWithDuration:(CMTime)duration
     return self;
 }
 
-- (id<SGDemuxable>)newDemuxable
+- (NSString *)sharedDemuxerKey
+{
+    return nil;
+}
+
+- (id<SGDemuxable>)newDemuxer
 {
     return [[SGPaddingDemuxer alloc] initWithDuration:self->_duration];
 }
 
+- (id<SGDemuxable>)newDemuxerWithSharedDemuxer:(id<SGDemuxable>)demuxer
+{
+    return [self newDemuxer];
+}
+
 @end

SGPlayer/Classes/Core/SGAsset/SGSegment+Internal.h

@@ -14,6 +14,16 @@
 /**
  *
  */
-- (id<SGDemuxable>)newDemuxable;
+- (NSString *)sharedDemuxerKey;
+
+/**
+ *
+ */
+- (id<SGDemuxable>)newDemuxer;
+
+/**
+ *
+ */
+- (id<SGDemuxable>)newDemuxerWithSharedDemuxer:(id<SGDemuxable>)demuxer;
 
 @end

SGPlayer/Classes/Core/SGAsset/SGSegment.m

@@ -34,7 +34,19 @@ - (id)copyWithZone:(NSZone *)zone
     return obj;
 }
 
-- (id<SGDemuxable>)newDemuxable
+- (NSString *)sharedDemuxerKey
+{
+    NSAssert(NO, @"Subclass only.");
+    return nil;
+}
+
+- (id<SGDemuxable>)newDemuxer
+{
+    NSAssert(NO, @"Subclass only.");
+    return nil;
+}
+
+- (id<SGDemuxable>)newDemuxerWithSharedDemuxer:(id<SGDemuxable>)demuxer
 {
     NSAssert(NO, @"Subclass only.");
     return nil;

SGPlayer/Classes/Core/SGAsset/SGURLSegment.m

@@ -38,10 +38,22 @@ - (instancetype)initWithURL:(NSURL *)URL index:(NSInteger)index timeRange:(CMTim
     return self;
 }
 
-- (id<SGDemuxable>)newDemuxable
+- (NSString *)sharedDemuxerKey
 {
-    SGURLDemuxer *demuxable = [[SGURLDemuxer alloc] initWithURL:self->_URL];
-    SGExtractingDemuxer *obj = [[SGExtractingDemuxer alloc] initWithDemuxable:demuxable index:self->_index timeRange:self->_timeRange scale:self->_scale];
+    return self->_URL.isFileURL ? self->_URL.path : self->_URL.absoluteString;
+}
+
+- (id<SGDemuxable>)newDemuxer
+{
+    return [self newDemuxerWithSharedDemuxer:nil];
+}
+
+- (id<SGDemuxable>)newDemuxerWithSharedDemuxer:(id<SGDemuxable>)demuxer
+{
+    if (!demuxer) {
+        demuxer = [[SGURLDemuxer alloc] initWithURL:self->_URL];
+    }
+    SGExtractingDemuxer *obj = [[SGExtractingDemuxer alloc] initWithDemuxable:demuxer index:self->_index timeRange:self->_timeRange scale:self->_scale];
     return obj;
 }
 

SGPlayer/Classes/Core/SGDecoder/SGAudioDecoder.m

@@ -82,14 +82,20 @@ - (void)flush
     NSMutableArray<__kindof SGFrame *> *ret = [NSMutableArray array];
     SGCodecDescriptor *cd = packet.codecDescriptor;
     NSAssert(cd, @"Invalid codec descriptor.");
-    if (![cd isEqualCodecContextToDescriptor:self->_codecDescriptor]) {
+    BOOL isEqual = [cd isEqualToDescriptor:self->_codecDescriptor];
+    BOOL isEqualCodec = [cd isEqualCodecContextToDescriptor:self->_codecDescriptor];
+    if (!isEqual) {
         NSArray<SGFrame *> *objs = [self finish];
         for (SGFrame *obj in objs) {
             [ret addObject:obj];
         }
         self->_codecDescriptor = [cd copy];
-        [self destroy];
-        [self setup];
+        if (isEqualCodec) {
+            [self flush];
+        } else {
+            [self destroy];
+            [self setup];
+        }
     }
     [cd fillToDescriptor:self->_codecDescriptor];
     if (packet.flags & SGDataFlagPadding) {

SGPlayer/Classes/Core/SGDecoder/SGVideoDecoder.m

@@ -93,14 +93,20 @@ - (void)flush
     NSMutableArray *ret = [NSMutableArray array];
     SGCodecDescriptor *cd = packet.codecDescriptor;
     NSAssert(cd, @"Invalid Codec Descriptor.");
-    if (![cd isEqualCodecContextToDescriptor:self->_codecDescriptor]) {
+    BOOL isEqual = [cd isEqualToDescriptor:self->_codecDescriptor];
+    BOOL isEqualCodec = [cd isEqualCodecContextToDescriptor:self->_codecDescriptor];
+    if (!isEqual) {
         NSArray<SGFrame *> *objs = [self finish];
         for (SGFrame *obj in objs) {
             [ret addObject:obj];
         }
         self->_codecDescriptor = [cd copy];
-        [self destroy];
-        [self setup];
+        if (isEqualCodec) {
+            [self flush];
+        } else {
+            [self destroy];
+            [self setup];
+        }
     }
     if (self->_flags.sessionFinished) {
         return nil;

SGPlayer/Classes/Core/SGDemuxer/SGDemuxable.h

@@ -17,7 +17,7 @@
 /**
  *
  */
-@property (nonatomic, strong) SGDemuxerOptions *options;
+@property (nonatomic, copy) SGDemuxerOptions *options;
 
 /**
  *
@@ -39,6 +39,11 @@
  */
 @property (nonatomic, readonly) CMTime duration;
 
+/**
+ *
+ */
+- (id<SGDemuxable>)sharedDemuxer;
+
 /**
  *
  */

SGPlayer/Classes/Core/SGDemuxer/SGExtractingDemuxer.m

@@ -59,6 +59,11 @@ - (instancetype)initWithDemuxable:(id<SGDemuxable>)demuxable index:(NSInteger)in
 
 #pragma mark - Control
 
+- (id<SGDemuxable>)sharedDemuxer
+{
+    return [self->_demuxable sharedDemuxer];
+}
+
 - (NSError *)open
 {
     NSError *error = [self->_demuxable open];

SGPlayer/Classes/Core/SGDemuxer/SGMutilDemuxer.m

@@ -60,6 +60,11 @@ - (SGDemuxerOptions *)options
 
 #pragma mark - Control
 
+- (id<SGDemuxable>)sharedDemuxer
+{
+    return nil;
+}
+
 - (NSError *)open
 {
     for (id<SGDemuxable> obj in self->_demuxers) {

SGPlayer/Classes/Core/SGDemuxer/SGPaddingDemuxer.m

@@ -35,6 +35,11 @@ - (instancetype)initWithDuration:(CMTime)duration
 
 #pragma mark - Control
 
+- (id<SGDemuxable>)sharedDemuxer
+{
+    return nil;
+}
+
 - (NSError *)open
 {
     return nil;