1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
/**********
This library is free software; you can redistribute it and/or modify it under
the terms of the GNU Lesser General Public License as published by the
Free Software Foundation; either version 2.1 of the License, or (at your
option) any later version. (See <http://www.gnu.org/copyleft/lesser.html>.)
This library is distributed in the hope that it will be useful, but WITHOUT
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for
more details.
You should have received a copy of the GNU Lesser General Public License
along with this library; if not, write to the Free Software Foundation, Inc.,
59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
**********/
// "liveMedia"
// Copyright (c) 1996-2006 Live Networks, Inc. All rights reserved.
// A 'ServerMediaSubsession' object that creates new, unicast, "RTPSink"s
// on demand, from a H263 video file.
// Implementation
// Author: Bernhard Feiten. // Based on MPEG4VideoFileServerMediaSubsession
#include "H263plusVideoFileServerMediaSubsession.hh"
#include "H263plusVideoRTPSink.hh"
#include "ByteStreamFileSource.hh"
#include "H263plusVideoStreamFramer.hh"
////////////////////////////////////////////////////////////////////////////////
H263plusVideoFileServerMediaSubsession*
H263plusVideoFileServerMediaSubsession::createNew(
UsageEnvironment& env,
char const* fileName,
Boolean reuseFirstSource) {
return new H263plusVideoFileServerMediaSubsession(env, fileName, reuseFirstSource);
}
////////////////////////////////////////////////////////////////////////////////
H263plusVideoFileServerMediaSubsession::H263plusVideoFileServerMediaSubsession(
UsageEnvironment& env,
char const* fileName,
Boolean reuseFirstSource)
: FileServerMediaSubsession(env, fileName, reuseFirstSource),
fDoneFlag(0)
{
}
////////////////////////////////////////////////////////////////////////////////
H263plusVideoFileServerMediaSubsession::~H263plusVideoFileServerMediaSubsession()
{
}
////////////////////////////////////////////////////////////////////////////////
#if 0
static void afterPlayingDummy(void* clientData) {
H263plusVideoFileServerMediaSubsession* subsess
= (H263plusVideoFileServerMediaSubsession*)clientData;
// Signal the event loop that we're done:
subsess->setDoneFlag();
}
#endif
static void checkForAuxSDPLine(void* clientData) {
H263plusVideoFileServerMediaSubsession* subsess
= (H263plusVideoFileServerMediaSubsession*)clientData;
subsess->checkForAuxSDPLine1();
}
void H263plusVideoFileServerMediaSubsession::checkForAuxSDPLine1() {
if (fDummyRTPSink->auxSDPLine() != NULL) {
// Signal the event loop that we're done:
setDoneFlag();
} else {
// try again after a brief delay:
int uSecsToDelay = 100000; // 100 ms
nextTask() = envir().taskScheduler().scheduleDelayedTask(uSecsToDelay,
(TaskFunc*)checkForAuxSDPLine, this);
}
}
char const* H263plusVideoFileServerMediaSubsession::getAuxSDPLine(
RTPSink* rtpSink,
FramedSource* inputSource)
{
// Note: For MPEG-4 video files, the 'config' information isn't known
// until we start reading the file. This means that "rtpSink"s
// "auxSDPLine()" will be NULL initially, and we need to start reading
// data from our file until this changes.
// Is this true also for H263 ?? >>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>
// asumption: no aux line needed for H263
// fDummyRTPSink = rtpSink;
// Start reading the file:
// fDummyRTPSink->startPlaying(*inputSource, afterPlayingDummy, this);
// Check whether the sink's 'auxSDPLine()' is ready:
// checkForAuxSDPLine(this);
// envir().taskScheduler().doEventLoop(&fDoneFlag);
// char const* auxSDPLine = fDummyRTPSink->auxSDPLine();
// return auxSDPLine;
return NULL;
}
////////////////////////////////////////////////////////////////////////////////
FramedSource* H263plusVideoFileServerMediaSubsession::createNewStreamSource(
unsigned /*clientSessionId*/,
unsigned& estBitrate)
{
estBitrate = 500; // kbps, estimate ??
// Create the video source:
ByteStreamFileSource* fileSource
= ByteStreamFileSource::createNew(envir(), fFileName);
if (fileSource == NULL) return NULL;
fFileSize = fileSource->fileSize();
// Create a framer for the Video Elementary Stream:
return H263plusVideoStreamFramer::createNew(envir(), fileSource);
}
///////////////////////////////////////////////////////////////////////////////
RTPSink* H263plusVideoFileServerMediaSubsession::createNewRTPSink(
Groupsock* rtpGroupsock,
unsigned char rtpPayloadTypeIfDynamic,
FramedSource* /*inputSource*/)
{
unsigned char payloadFormatCode;
if (false) // some more logic is needed if h263 is dynamic PT
payloadFormatCode = rtpPayloadTypeIfDynamic;
else
payloadFormatCode = 34;
return H263plusVideoRTPSink::createNew(envir(), rtpGroupsock, payloadFormatCode);
}
|
