Package io.antmedia.muxer

Class RecordMuxer

java.lang.Object

io.antmedia.muxer.Muxer

io.antmedia.muxer.RecordMuxer

Direct Known Subclasses:

Mp4Muxer, WebMMuxer

public abstract class RecordMuxer
extends Muxer

Nested Class Summary

Nested classes/interfaces inherited from class io.antmedia.muxer.Muxer

Muxer.VideoBuffer

Field Summary

Fields

Modifier and Type	Field	Description
protected File	fileTmp
protected String	previewPath
protected int	resolution
private static final int	S3_CONSTANT
private String	s3FolderPath
private long	startTime	Millisecond timestamp with record muxer initialization.
protected StorageClient	storageClient
protected int[]	SUPPORTED_CODECS
protected boolean	uploadMP4ToS3
private String	vodId

Fields inherited from class io.antmedia.muxer.Muxer

audioPkt, avRationalTimeBase, BITSTREAM_FILTER_H264_MP4TOANNEXB, BITSTREAM_FILTER_HEVC_MP4TOANNEXB, bsfAudioFilterContextList, bsfFilterContextList, bsfVideoNames, DATE_TIME_PATTERN, extension, file, firstAudioDts, firstKeyFrameReceived, firstVideoDts, format, headerWritten, initialResourceNameWithoutExtension, inputOutputStreamIndexMap, inputTimeBaseMap, isInitialized, isRunning, logger, loggerStatic, optionDictionary, options, outputFormatContext, registeredStreamIndexList, rotation, scope, SEGMENT_INDEX_LENGTH, streamId, subFolder, TEMP_EXTENSION, time2log, tmpPacket, vertx, videoExtradata, videoHeight, videoPkt, videoWidth

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RecordMuxer(StorageClient storageClient, io.vertx.core.Vertx vertx, String s3FolderPath)

Method Summary

Modifier and Type	Method	Description
private static boolean	doesFileExistInS3(StorageClient storageClient, String name)
protected void	finalizeRecordFile(File file)
File	getFinalFileName(boolean isS3Enabled)
org.bytedeco.ffmpeg.avformat.AVFormatContext	getOutputFormatContext()
String	getOutputURL()
static String	getS3Prefix(String s3FolderPath, String subFolder)
String	getVodId()
void	init(IScope scope, String name, int resolutionHeight, String subFolder, int bitrate)	Inits the file to write.
boolean	isCodecSupported(int codecId)
boolean	isUploadingToS3()
protected boolean	prepareAudioOutStream(org.bytedeco.ffmpeg.avformat.AVStream inStream, org.bytedeco.ffmpeg.avformat.AVStream outStream)
static void	saveToStorage(String prefix, File fileToUpload, String fileName, StorageClient storageClient)
static void	saveToStorage(String prefix, File fileToUpload, String fileName, StorageClient storageClient, boolean deleteLocalFile)
void	setFileTmp(File fileTmp)
void	setPreviewPath(String path)
void	setSubfolder(String subFolder)
void	setVodId(String vodId)
void	writeTrailer()	This function may be called by multiple encoders.

Methods inherited from class io.antmedia.muxer.Muxer

addAudioStream, addExtradataIfRequired, addStream, addStream, addVideoStream, avNewStream, checkToDropPacket, clearResource, contextChanged, contextWillChange, getAppAdaptor, getAppSettings, getAudioNotWrittenCount, getAverageBitrate, getBitStreamFilter, getBsfAudioNames, getCurrentVoDTimeStamp, getDurationInMs, getDurationInMs, getErrorDefinition, getExtendedName, getFile, getFileName, getFormat, getInputTimeBaseMap, getIsRunning, getLastPts, getOptionDictionary, getPacketBufferWithExtradata, getPreviewFile, getRecordFile, getRegisteredStreamIndexList, getResolution, getResourceFile, getSubFolder, getTmpPacket, getUserRecordFile, getVideoCodecId, getVideoHeight, getVideoNotWrittenCount, getVideoWidth, init, initAudioBitstreamFilter, initVideoBitstreamFilter, isAddDateTimeToSourceName, logPacketIssue, openIO, prepareIO, replaceDoubleSlashesWithSingleSlash, setAddDateTimeToSourceName, setAudioBitreamFilter, setBitstreamFilter, setCurrentVoDTimeStamp, setIsRunning, setOption, writeAudioBuffer, writeAudioFrame, writeDataFrame, writeHeader, writeMetaData, writePacket, writePacket, writePacket, writeVideoBuffer, writeVideoBuffer, writeVideoFrame

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

fileTmp

protected File fileTmp

storageClient

protected StorageClient storageClient

resolution

protected int resolution

uploadMP4ToS3

protected boolean uploadMP4ToS3

previewPath

protected String previewPath

S3_CONSTANT

private static final int S3_CONSTANT

See Also:

• Constant Field Values

s3FolderPath

private String s3FolderPath

startTime

private long startTime

Millisecond timestamp with record muxer initialization. It will be define when record muxer is called by anywhere

vodId

private String vodId

SUPPORTED_CODECS

protected int[] SUPPORTED_CODECS

Constructor Details

RecordMuxer

protected RecordMuxer(StorageClient storageClient,
 io.vertx.core.Vertx vertx,
 String s3FolderPath)

Method Details

isCodecSupported

public boolean isCodecSupported(int codecId)

Specified by:

isCodecSupported in class Muxer

init

public void init(IScope scope,
 String name,
 int resolutionHeight,
 String subFolder,
 int bitrate)

Inits the file to write. Multiple encoders can init the muxer. It is redundant to init multiple times.

Overrides:

init in class Muxer

getOutputFormatContext

public org.bytedeco.ffmpeg.avformat.AVFormatContext getOutputFormatContext()

Specified by:

getOutputFormatContext in class Muxer

prepareAudioOutStream

protected boolean prepareAudioOutStream(org.bytedeco.ffmpeg.avformat.AVStream inStream,
 org.bytedeco.ffmpeg.avformat.AVStream outStream)

getOutputURL

public String getOutputURL()

Overrides:

getOutputURL in class Muxer

setPreviewPath

public void setPreviewPath(String path)

setFileTmp

public void setFileTmp(File fileTmp)

writeTrailer

public void writeTrailer()

This function may be called by multiple encoders. Make sure that it is called once. See the sample implementations how it is being protected Implement this function with synchronized keyword as the subclass

Overrides:

writeTrailer in class Muxer

getS3Prefix

public static String getS3Prefix(String s3FolderPath,
 String subFolder)

getFinalFileName

public File getFinalFileName(boolean isS3Enabled)

doesFileExistInS3

private static boolean doesFileExistInS3(StorageClient storageClient,
 String name)

saveToStorage

public static void saveToStorage(String prefix,
 File fileToUpload,
 String fileName,
 StorageClient storageClient)

saveToStorage

public static void saveToStorage(String prefix,
 File fileToUpload,
 String fileName,
 StorageClient storageClient,
 boolean deleteLocalFile)

finalizeRecordFile

protected void finalizeRecordFile(File file)
                           throws IOException

Throws:

IOException

isUploadingToS3

public boolean isUploadingToS3()

getVodId

public String getVodId()

setVodId

public void setVodId(String vodId)

setSubfolder

public void setSubfolder(String subFolder)

Overrides:

setSubfolder in class Muxer