Live555源代碼解讀（4）下

[cpp] view plaincopy

1. static ServerMediaSession* createNewSMS(UsageEnvironment& env,char const* fileName, FILE* /*fid*/)   

2. {  

3.     // Use the file name extension to determine the type of "ServerMediaSession":  

4.     char const* extension = strrchr(fileName, '.');  

5.     if (extension == NULL)  

6.         return NULL;  

7.   

8.   

9.     ServerMediaSession* sms = NULL;  

10.     Boolean const reuseSource = False;  

11.     if (strcmp(extension, ".aac") == 0) {  

12.         // Assumed to be an AAC Audio (ADTS format) file:  

13.         NEW_SMS("AAC Audio");  

14.         sms->addSubsession(  

15.                 ADTSAudioFileServerMediaSubsession::createNew(env, fileName,  

16.                         reuseSource));  

17.     } else if (strcmp(extension, ".amr") == 0) {  

18.         // Assumed to be an AMR Audio file:  

19.         NEW_SMS("AMR Audio");  

20.         sms->addSubsession(  

21.                 AMRAudioFileServerMediaSubsession::createNew(env, fileName,  

22.                         reuseSource));  

23.     } else if (strcmp(extension, ".ac3") == 0) {  

24.         // Assumed to be an AC-3 Audio file:  

25.         NEW_SMS("AC-3 Audio");  

26.         sms->addSubsession(  

27.                 AC3AudioFileServerMediaSubsession::createNew(env, fileName,  

28.                         reuseSource));  

29.     } else if (strcmp(extension, ".m4e") == 0) {  

30.         // Assumed to be a MPEG-4 Video Elementary Stream file:  

31.         NEW_SMS("MPEG-4 Video");  

32.         sms->addSubsession(  

33.                 MPEG4VideoFileServerMediaSubsession::createNew(env, fileName,  

34.                         reuseSource));  

35.     } else if (strcmp(extension, ".264") == 0) {  

36.         // Assumed to be a H.264 Video Elementary Stream file:  

37.         NEW_SMS("H.264 Video");  

38.         OutPacketBuffer::maxSize = 100000; // allow for some possibly large H.264 frames  

39.         sms->addSubsession(  

40.                 H264VideoFileServerMediaSubsession::createNew(env, fileName,  

41.                         reuseSource));  

42.     } else if (strcmp(extension, ".mp3") == 0) {  

43.         // Assumed to be a MPEG-1 or 2 Audio file:  

44.         NEW_SMS("MPEG-1 or 2 Audio");  

45.         // To stream using 'ADUs' rather than raw MP3 frames, uncomment the following:  

46. //#define STREAM_USING_ADUS 1  

47.         // To also reorder ADUs before streaming, uncomment the following:  

48. //#define INTERLEAVE_ADUS 1  

49.         // (For more information about ADUs and interleaving,  

50.         //  see <http://www.live555.com/rtp-mp3/>)  

51.         Boolean useADUs = False;  

52.         Interleaving* interleaving = NULL;  

53. #ifdef STREAM_USING_ADUS  

54.         useADUs = True;  

55. #ifdef INTERLEAVE_ADUS  

56.         unsigned char interleaveCycle[] = {0,2,1,3}; // or choose your own...  

57.         unsigned const interleaveCycleSize  

58.         = (sizeof interleaveCycle)/(sizeof (unsigned char));  

59.         interleaving = new Interleaving(interleaveCycleSize, interleaveCycle);  

60. #endif  

61. #endif  

62.         sms->addSubsession(  

63.                 MP3AudioFileServerMediaSubsession::createNew(env, fileName,  

64.                         reuseSource, useADUs, interleaving));  

65.     } else if (strcmp(extension, ".mpg") == 0) {  

66.         // Assumed to be a MPEG-1 or 2 Program Stream (audio+video) file:  

67.         NEW_SMS("MPEG-1 or 2 Program Stream");  

68.         MPEG1or2FileServerDemux* demux = MPEG1or2FileServerDemux::createNew(env,  

69.                 fileName, reuseSource);  

70.         sms->addSubsession(demux->newVideoServerMediaSubsession());  

71.         sms->addSubsession(demux->newAudioServerMediaSubsession());  

72.     } else if (strcmp(extension, ".ts") == 0) {  

73.         // Assumed to be a MPEG Transport Stream file:  

74.         // Use an index file name that's the same as the TS file name, except with ".tsx":  

75.         unsigned indexFileNameLen = strlen(fileName) + 2; // allow for trailing "x\0"  

76.         char* indexFileName = new char[indexFileNameLen];  

77.         sprintf(indexFileName, "%sx", fileName);  

78.         NEW_SMS("MPEG Transport Stream");  

79.         sms->addSubsession(  

80.                 MPEG2TransportFileServerMediaSubsession::createNew(env,  

81.                         fileName, indexFileName, reuseSource));  

82.         delete[] indexFileName;  

83.     } else if (strcmp(extension, ".wav") == 0) {  

84.         // Assumed to be a WAV Audio file:  

85.         NEW_SMS("WAV Audio Stream");  

86.         // To convert 16-bit PCM data to 8-bit u-law, prior to streaming,  

87.         // change the following to True:  

88.         Boolean convertToULaw = False;  

89.         sms->addSubsession(  

90.                 WAVAudioFileServerMediaSubsession::createNew(env, fileName,  

91.                         reuseSource, convertToULaw));  

92.     } else if (strcmp(extension, ".dv") == 0) {  

93.         // Assumed to be a DV Video file  

94.         // First, make sure that the RTPSinks' buffers will be large enough to handle the huge size of DV frames (as big as 288000).  

95.         OutPacketBuffer::maxSize = 300000;  

96.   

97.   

98.         NEW_SMS("DV Video");  

99.         sms->addSubsession(  

100.                 DVVideoFileServerMediaSubsession::createNew(env, fileName,  

101.                         reuseSource));  

102.     } else if (strcmp(extension, ".mkv") == 0) {  

103.         // Assumed to be a Matroska file  

104.         NEW_SMS("Matroska video+audio+(optional)subtitles");  

105.   

106.   

107.         // Create a Matroska file server demultiplexor for the specified file.  (We enter the event loop to wait for this to complete.)  

108.         newMatroskaDemuxWatchVariable = 0;  

109.         MatroskaFileServerDemux::createNew(env, fileName,  

110.                 onMatroskaDemuxCreation, NULL);  

111.         env.taskScheduler().doEventLoop(&newMatroskaDemuxWatchVariable);  

112.   

113.   

114.         ServerMediaSubsession* smss;  

115.         while ((smss = demux->newServerMediaSubsession()) != NULL) {  

116.             sms->addSubsession(smss);  

117.         }  

118.     }  

119.   

120.   

121.     return sms;  

122. }  

能夠看到NEW_SMS("AMR Audio")會建立新的ServerMediaSession，以後立刻調用sms->addSubsession（）爲這個ServerMediaSession添加一個 ServerMediaSubSession 。看起來ServerMediaSession應該能夠添加多個ServerMediaSubSession，但這裏並無這樣作。若是能夠添加多個 ServerMediaSubsession 那麼ServerMediaSession與流名字所指定與文件是沒有關係的，也就是說它不會操做文件，而文件的操做是放在 ServerMediaSubsession中的。具體應改是在ServerMediaSubsession的sdpLines()函數中打開。