Package io.antmedia.streamsource

Class RTMPClusterStreamFetcher.RtmpFetcherThread

java.lang.Object

java.lang.Thread

io.antmedia.streamsource.RTMPClusterStreamFetcher.RtmpFetcherThread

All Implemented Interfaces:

Runnable

Enclosing class:

RTMPClusterStreamFetcher

public class RTMPClusterStreamFetcher.RtmpFetcherThread
extends Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private org.bytedeco.ffmpeg.avutil.AVRational	audioTimeBase
(package private) long	bufferDuration
(package private) long	firstPacketTime
(package private) org.bytedeco.ffmpeg.avformat.AVFormatContext	inputFormatContext
protected AtomicBoolean	isJobRunning
(package private) long	timeOffsetInMs
private org.bytedeco.ffmpeg.avutil.AVRational	videoTimeBase

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
RtmpFetcherThread()

Method Summary

Modifier and Type	Method	Description
void	close(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)
void	closeInputFormatContext()
Result	prepareInput(org.bytedeco.ffmpeg.avformat.AVFormatContext inputFormatContext)
boolean	prepareInputContext()
boolean	readMore(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)
int	readNextPacket(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)
void	run()
void	unReferencePacket(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

isJobRunning

protected AtomicBoolean isJobRunning

inputFormatContext

org.bytedeco.ffmpeg.avformat.AVFormatContext inputFormatContext

firstPacketTime

long firstPacketTime

bufferDuration

long bufferDuration

timeOffsetInMs

long timeOffsetInMs

videoTimeBase

private org.bytedeco.ffmpeg.avutil.AVRational videoTimeBase

audioTimeBase

private org.bytedeco.ffmpeg.avutil.AVRational audioTimeBase

Constructor Details

RtmpFetcherThread

public RtmpFetcherThread()

Method Details

prepareInput

public Result prepareInput(org.bytedeco.ffmpeg.avformat.AVFormatContext inputFormatContext)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

readMore

public boolean readMore(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)

readNextPacket

public int readNextPacket(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)

unReferencePacket

public void unReferencePacket(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)

prepareInputContext

public boolean prepareInputContext()
                            throws Exception

Throws:

Exception

closeInputFormatContext

public void closeInputFormatContext()

close

public void close(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)