Class TranscodePipe

java.lang.Object

com.biglybt.core.devices.impl.TranscodePipe

Direct Known Subclasses:

TranscodePipeFileSource, TranscodePipeStreamSource, TranscodePipeStreamSource2

public abstract class TranscodePipe
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TranscodePipe.bufferCache
protected static interface	TranscodePipe.errorListener

Field Summary

Fields

Modifier and Type	Field	Description
(package private) LinkedList<TranscodePipe.bufferCache>	buffer_cache
(package private) int	buffer_cache_size
private final int	BUFFER_CACHE_SIZE
private final int	BUFFER_SIZE
protected int	bytes_available
(package private) Average	connection_speed
protected boolean	destroyed
private TranscodePipe.errorListener	error_listener
protected int	max_bytes_per_sec
protected boolean	paused
(package private) AEThread2	refiller
(package private) ServerSocket	server_socket
protected List<Socket>	sockets
(package private) Average	write_speed

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TranscodePipe(TranscodePipe.errorListener _error_listener)

Method Summary

Modifier and Type	Method	Description
protected boolean	destroy()
long	getConnectionRate()
protected int	getPort()
long	getWriteSpeed()
protected void	handlePipe(InputStream is, OutputStream os)
protected void	handleRAF(OutputStream os, long position, long length)
protected abstract void	handleSocket(Socket socket)
protected void	pause()
protected void	releaseRAF(RandomAccessFile raf)
protected void	reportError(Throwable error)
protected RandomAccessFile	reserveRAF()
protected void	resume()
void	setMaxBytesPerSecond(int max)

Methods inherited from class Object

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

Field Details

BUFFER_SIZE

private final int BUFFER_SIZE

See Also:

• Constant Field Values

BUFFER_CACHE_SIZE

private final int BUFFER_CACHE_SIZE

See Also:

• Constant Field Values

paused

protected volatile boolean paused

destroyed

protected volatile boolean destroyed

bytes_available

protected volatile int bytes_available

max_bytes_per_sec

protected volatile int max_bytes_per_sec

sockets

protected List<Socket> sockets

server_socket

ServerSocket server_socket

refiller

AEThread2 refiller

buffer_cache

LinkedList<TranscodePipe.bufferCache> buffer_cache

buffer_cache_size

int buffer_cache_size

connection_speed

Average connection_speed

write_speed

Average write_speed

error_listener

private TranscodePipe.errorListener error_listener

Constructor Details

TranscodePipe

protected TranscodePipe(TranscodePipe.errorListener _error_listener)
                 throws IOException

Throws:

IOException

Method Details

getConnectionRate

public long getConnectionRate()

getWriteSpeed

public long getWriteSpeed()

handleSocket

protected abstract void handleSocket(Socket socket)

handlePipe

protected void handlePipe(InputStream is,
 OutputStream os)

reserveRAF

protected RandomAccessFile reserveRAF()
                               throws IOException

Throws:

IOException

releaseRAF

protected void releaseRAF(RandomAccessFile raf)

handleRAF

protected void handleRAF(OutputStream os,
 long position,
 long length)

pause

protected void pause()

resume

protected void resume()

setMaxBytesPerSecond

public void setMaxBytesPerSecond(int max)

getPort

protected int getPort()

destroy

protected boolean destroy()

reportError

protected void reportError(Throwable error)