Package com.biglybt.core.devices.impl
Class TranscodePipe
java.lang.Object
com.biglybt.core.devices.impl.TranscodePipe
- Direct Known Subclasses:
TranscodePipeFileSource
,TranscodePipeStreamSource
,TranscodePipeStreamSource2
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate static class
protected static interface
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) LinkedList
<TranscodePipe.bufferCache> (package private) int
private final int
private final int
protected int
(package private) Average
protected boolean
private TranscodePipe.errorListener
protected int
protected boolean
(package private) AEThread2
(package private) ServerSocket
(package private) Average
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
TranscodePipe
(TranscodePipe.errorListener _error_listener) -
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
destroy()
long
protected int
getPort()
long
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
protected void
reportError
(Throwable error) protected RandomAccessFile
protected void
resume()
void
setMaxBytesPerSecond
(int max)
-
Field Details
-
BUFFER_SIZE
private final int BUFFER_SIZE- See Also:
-
BUFFER_CACHE_SIZE
private final int BUFFER_CACHE_SIZE- See Also:
-
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
-
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
-
-
Constructor Details
-
TranscodePipe
- Throws:
IOException
-
-
Method Details
-
getConnectionRate
public long getConnectionRate() -
getWriteSpeed
public long getWriteSpeed() -
handleSocket
-
handlePipe
-
reserveRAF
- Throws:
IOException
-
releaseRAF
-
handleRAF
-
pause
protected void pause() -
resume
protected void resume() -
setMaxBytesPerSecond
public void setMaxBytesPerSecond(int max) -
getPort
protected int getPort() -
destroy
protected boolean destroy() -
reportError
-