Package io.antmedia.streamsource

Class StreamFetcher.WorkerThread

java.lang.Object

java.lang.Thread

io.antmedia.streamsource.StreamFetcher.WorkerThread

All Implemented Interfaces:

Runnable

Enclosing class:

StreamFetcher

public class StreamFetcher.WorkerThread
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
(package private) long	bufferDuration
private AtomicBoolean	buffering
private long	bufferingFinishTimeMs
private ConcurrentSkipListSet<org.bytedeco.ffmpeg.avcodec.AVPacket>	bufferQueue
private long	firstPacketDtsInMs
private long	firstPacketReadyToSentTimeMs
(package private) long	firstPacketTime
(package private) org.bytedeco.ffmpeg.avformat.AVFormatContext	inputFormatContext
protected AtomicBoolean	isJobRunning
private long	lastPacketTimeMsInQueue
private long	lastSycnCheckTime
private static final int	PACKET_WRITER_PERIOD_IN_MS
(package private) long	packetWriterJobName
private static final long	STREAM_FETCH_RE_TRY_PERIOD_MS
private boolean	streamPublished
(package private) long	timeOffsetInMs

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
WorkerThread()

Method Summary

Modifier and Type	Method	Description
void	calculateBufferStatus()
void	checkAndFixSynch()
void	close(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)
void	closeInputFormatContext()
long	getBufferedDurationMs()
ConcurrentSkipListSet<org.bytedeco.ffmpeg.avcodec.AVPacket>	getBufferQueue()
int	getCodecType(int streamIndex)
long[]	getLastSentDTS()
org.bytedeco.ffmpeg.avutil.AVRational	getStreamTimebase(int streamIndex)
void	logBufferStatus()
void	packetRead(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)
Result	prepare(org.bytedeco.ffmpeg.avformat.AVFormatContext inputFormatContext)
Result	prepareInput(org.bytedeco.ffmpeg.avformat.AVFormatContext inputFormatContext)
boolean	prepareInputContext(Broadcast broadcast)
boolean	readMore(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)
int	readNextPacket(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)
void	run()
int	seekFrame()
void	setInputFormatContext(org.bytedeco.ffmpeg.avformat.AVFormatContext inputFormatContext)
void	unReferencePacket(org.bytedeco.ffmpeg.avcodec.AVPacket pkt)
private void	writeAllBufferedPackets()
void	writeBufferedPacket()
void	writePacket(org.bytedeco.ffmpeg.avformat.AVStream stream, 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

PACKET_WRITER_PERIOD_IN_MS

private static final int PACKET_WRITER_PERIOD_IN_MS

See Also:

• Constant Field Values

STREAM_FETCH_RE_TRY_PERIOD_MS

private static final long STREAM_FETCH_RE_TRY_PERIOD_MS

See Also:

• Constant Field Values

streamPublished

private volatile boolean streamPublished

isJobRunning

protected AtomicBoolean isJobRunning

inputFormatContext

org.bytedeco.ffmpeg.avformat.AVFormatContext inputFormatContext

buffering

private AtomicBoolean buffering

bufferQueue

private ConcurrentSkipListSet<org.bytedeco.ffmpeg.avcodec.AVPacket> bufferQueue

bufferingFinishTimeMs

private volatile long bufferingFinishTimeMs

firstPacketReadyToSentTimeMs

private volatile long firstPacketReadyToSentTimeMs

lastPacketTimeMsInQueue

private long lastPacketTimeMsInQueue

firstPacketTime

long firstPacketTime

bufferDuration

long bufferDuration

timeOffsetInMs

long timeOffsetInMs

packetWriterJobName

long packetWriterJobName

firstPacketDtsInMs

private long firstPacketDtsInMs

lastSycnCheckTime

private long lastSycnCheckTime

Constructor Details

WorkerThread

public WorkerThread()

Method Details

prepare

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

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)

seekFrame

public int seekFrame()

readNextPacket

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

unReferencePacket

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

prepareInputContext

public boolean prepareInputContext(Broadcast broadcast)
                            throws Exception

Throws:

Exception

packetRead

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

closeInputFormatContext

public void closeInputFormatContext()

close

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

writeAllBufferedPackets

private void writeAllBufferedPackets()

writePacket

public void writePacket(org.bytedeco.ffmpeg.avformat.AVStream stream,
 org.bytedeco.ffmpeg.avcodec.AVPacket pkt)

getLastSentDTS

public long[] getLastSentDTS()

getCodecType

public int getCodecType(int streamIndex)

getStreamTimebase

public org.bytedeco.ffmpeg.avutil.AVRational getStreamTimebase(int streamIndex)

checkAndFixSynch

public void checkAndFixSynch()

writeBufferedPacket

public void writeBufferedPacket()

calculateBufferStatus

public void calculateBufferStatus()

logBufferStatus

public void logBufferStatus()

getBufferedDurationMs

public long getBufferedDurationMs()

getBufferQueue

public ConcurrentSkipListSet<org.bytedeco.ffmpeg.avcodec.AVPacket> getBufferQueue()

setInputFormatContext

public void setInputFormatContext(org.bytedeco.ffmpeg.avformat.AVFormatContext inputFormatContext)