/usr/include/liveMedia/MPEG2TransportFileServerMediaSubsession.hh is in liblivemedia-dev 2018.02.18-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 | /**********
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 3 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.,
51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
**********/
// "liveMedia"
// Copyright (c) 1996-2018 Live Networks, Inc. All rights reserved.
// A 'ServerMediaSubsession' object that creates new, unicast, "RTPSink"s
// on demand, from a MPEG-2 Transport Stream file.
// C++ header
#ifndef _MPEG2_TRANSPORT_FILE_SERVER_MEDIA_SUBSESSION_HH
#define _MPEG2_TRANSPORT_FILE_SERVER_MEDIA_SUBSESSION_HH
#ifndef _FILE_SERVER_MEDIA_SUBSESSION_HH
#include "FileServerMediaSubsession.hh"
#endif
#ifndef _MPEG2_TRANSPORT_STREAM_FRAMER_HH
#include "MPEG2TransportStreamFramer.hh"
#endif
#ifndef _BYTE_STREAM_FILE_SOURCE_HH
#include "ByteStreamFileSource.hh"
#endif
#ifndef _MPEG2_TRANSPORT_STREAM_TRICK_MODE_FILTER_HH
#include "MPEG2TransportStreamTrickModeFilter.hh"
#endif
#ifndef _MPEG2_TRANSPORT_STREAM_FROM_ES_SOURCE_HH
#include "MPEG2TransportStreamFromESSource.hh"
#endif
class ClientTrickPlayState; // forward
class MPEG2TransportFileServerMediaSubsession: public FileServerMediaSubsession {
public:
static MPEG2TransportFileServerMediaSubsession*
createNew(UsageEnvironment& env,
char const* dataFileName, char const* indexFileName,
Boolean reuseFirstSource);
protected:
MPEG2TransportFileServerMediaSubsession(UsageEnvironment& env,
char const* fileName,
MPEG2TransportStreamIndexFile* indexFile,
Boolean reuseFirstSource);
// called only by createNew();
virtual ~MPEG2TransportFileServerMediaSubsession();
virtual ClientTrickPlayState* newClientTrickPlayState();
private: // redefined virtual functions
// Note that because - to implement 'trick play' operations - we're operating on
// more than just the input source, we reimplement some functions that are
// already implemented in "OnDemandServerMediaSubsession", rather than
// reimplementing "seekStreamSource()" and "setStreamSourceScale()":
virtual void startStream(unsigned clientSessionId, void* streamToken,
TaskFunc* rtcpRRHandler,
void* rtcpRRHandlerClientData,
unsigned short& rtpSeqNum,
unsigned& rtpTimestamp,
ServerRequestAlternativeByteHandler* serverRequestAlternativeByteHandler,
void* serverRequestAlternativeByteHandlerClientData);
virtual void pauseStream(unsigned clientSessionId, void* streamToken);
virtual void seekStream(unsigned clientSessionId, void* streamToken, double& seekNPT, double streamDuration, u_int64_t& numBytes);
virtual void setStreamScale(unsigned clientSessionId, void* streamToken, float scale);
virtual void deleteStream(unsigned clientSessionId, void*& streamToken);
// The virtual functions that are usually implemented by "ServerMediaSubsession"s:
virtual FramedSource* createNewStreamSource(unsigned clientSessionId,
unsigned& estBitrate);
virtual RTPSink* createNewRTPSink(Groupsock* rtpGroupsock,
unsigned char rtpPayloadTypeIfDynamic,
FramedSource* inputSource);
virtual void testScaleFactor(float& scale);
virtual float duration() const;
private:
ClientTrickPlayState* lookupClient(unsigned clientSessionId);
private:
MPEG2TransportStreamIndexFile* fIndexFile;
float fDuration;
HashTable* fClientSessionHashTable; // indexed by client session id
};
// This class encapsulates the 'trick play' state for each current client (for
// a given "MPEG2TransportFileServerMediaSubsession" - i.e., Transport Stream file).
// It is used only within the implementation of "MPEG2TransportFileServerMediaSubsession", but is included here,
// in case subclasses of "MPEG2TransportFileServerMediaSubsession" want to use it.
class ClientTrickPlayState {
public:
ClientTrickPlayState(MPEG2TransportStreamIndexFile* indexFile);
// Functions to bring "fNPT", "fTSRecordNum" and "fIxRecordNum" in sync:
unsigned long updateStateFromNPT(double npt, double seekDuration);
void updateStateOnScaleChange();
void updateStateOnPlayChange(Boolean reverseToPreviousVSH);
void handleStreamDeletion();
void setSource(MPEG2TransportStreamFramer* framer);
void setNextScale(float nextScale) { fNextScale = nextScale; }
Boolean areChangingScale() const { return fNextScale != fScale; }
protected:
void updateTSRecordNum();
void reseekOriginalTransportStreamSource();
protected:
MPEG2TransportStreamIndexFile* fIndexFile;
ByteStreamFileSource* fOriginalTransportStreamSource;
MPEG2TransportStreamTrickModeFilter* fTrickModeFilter;
MPEG2TransportStreamFromESSource* fTrickPlaySource;
MPEG2TransportStreamFramer* fFramer;
float fScale, fNextScale, fNPT;
unsigned long fTSRecordNum, fIxRecordNum;
};
#endif
|