Package | Description |
---|---|
anon.proxy |
This package implements a proxy for convienient use of the anonymous communication primitives provided by the ANON library.
|
anon.transport.connection | |
anon.transport.connection.util |
Modifier and Type | Field and Description |
---|---|
private ObjectQueue |
AnonProxy.OpenSocketRequester.m_socketQueue
A queue used for
SocketGuard objects, wrapping sockets the
client used to send requests over. |
Modifier and Type | Field and Description |
---|---|
private ObjectQueue |
SkypeConnection.SkypeReader.m_readBuffer
Der Empfangspuffer
|
Modifier and Type | Field and Description |
---|---|
private ObjectQueue |
QueuedChunkReader.m_readingQueue
Die BlockingQueue uas welcher chunks gelesen werden.
|
private ObjectQueue |
QueuedChunkWriter.m_writingQueue
Die BlockingQueue in welche Chunks eingefuegt werden.
|
Constructor and Description |
---|
QueuedChunkConnection(ObjectQueue a_loopbackQueue)
Erstellt einen neue
QueuedChunkConnection bei der Ein- und
Ausgabequeue durch die selbe BlockingQueue repraesentiert werden
und die Connection entsprechend mit sich selbst verbunden ist. |
QueuedChunkConnection(ObjectQueue a_readingQueue,
ObjectQueue a_writingQueue)
Erstell eine neue
QueuedChunkConnection , bei welcher Ein- und
Ausgabekanal durch entsprechende BlockingQueue repraesentiert
sind. |
QueuedChunkReader(ObjectQueue a_readingQueue)
Erstellt einen neuen
QueuedChunkReader auf Grundlage der
uebergebene Queue mit einen unendlichen Timeout. |
QueuedChunkReader(ObjectQueue a_readingQueue,
int a_timeout)
Erstellt einen neuen
QueuedChunkReader auf Grundlage der
uebergebene Queue und dem entsprechenden Timeout. |
QueuedChunkWriter(ObjectQueue a_writingQueue)
Erstellt einen neuen
QueuedChunkWriter auf Grundlage der
uebergebene Queue mit unendlichen Timeout. |
QueuedChunkWriter(ObjectQueue a_writingQueue,
int a_timeout)
Erstellt einen neuen
QueuedChunkWriter auf Grundlage der
uebergebene Queue und dem entsprechenden Timeout. |
Copyright © 2023. All rights reserved.