Package com.biglybt.core.devices.impl
Class TranscodePipe
- java.lang.Object
-
- com.biglybt.core.devices.impl.TranscodePipe
-
- Direct Known Subclasses:
TranscodePipeFileSource
,TranscodePipeStreamSource
,TranscodePipeStreamSource2
public abstract class TranscodePipe extends java.lang.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) java.util.LinkedList<TranscodePipe.bufferCache>
buffer_cache
(package private) int
buffer_cache_size
private int
BUFFER_CACHE_SIZE
private 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) java.net.ServerSocket
server_socket
protected java.util.List<java.net.Socket>
sockets
(package private) Average
write_speed
-
Constructor Summary
Constructors Modifier Constructor Description protected
TranscodePipe(TranscodePipe.errorListener _error_listener)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected boolean
destroy()
long
getConnectionRate()
protected int
getPort()
long
getWriteSpeed()
protected void
handlePipe(java.io.InputStream is, java.io.OutputStream os)
protected void
handleRAF(java.io.OutputStream os, long position, long length)
protected abstract void
handleSocket(java.net.Socket socket)
protected void
pause()
protected void
releaseRAF(java.io.RandomAccessFile raf)
protected void
reportError(java.lang.Throwable error)
protected java.io.RandomAccessFile
reserveRAF()
protected void
resume()
void
setMaxBytesPerSecond(int max)
-
-
-
Field Detail
-
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 java.util.List<java.net.Socket> sockets
-
server_socket
java.net.ServerSocket server_socket
-
refiller
AEThread2 refiller
-
buffer_cache
java.util.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 Detail
-
TranscodePipe
protected TranscodePipe(TranscodePipe.errorListener _error_listener) throws java.io.IOException
- Throws:
java.io.IOException
-
-
Method Detail
-
getConnectionRate
public long getConnectionRate()
-
getWriteSpeed
public long getWriteSpeed()
-
handleSocket
protected abstract void handleSocket(java.net.Socket socket)
-
handlePipe
protected void handlePipe(java.io.InputStream is, java.io.OutputStream os)
-
reserveRAF
protected java.io.RandomAccessFile reserveRAF() throws java.io.IOException
- Throws:
java.io.IOException
-
releaseRAF
protected void releaseRAF(java.io.RandomAccessFile raf)
-
handleRAF
protected void handleRAF(java.io.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(java.lang.Throwable error)
-
-