Package com.biglybt.pifimpl.local.peers
Class PeerForeignNetworkConnection.imq
java.lang.Object
com.biglybt.pifimpl.local.peers.PeerForeignNetworkConnection.imq
- All Implemented Interfaces:
IncomingMessageQueue
- Enclosing class:
- PeerForeignNetworkConnection
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.biglybt.core.networkmanager.IncomingMessageQueue
IncomingMessageQueue.MessageQueueListener
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Cancel queue event notification listener.void
destroy()
Destroy this queue.int[]
Get the progress of the current message that is being receivedvoid
notifyOfExternallyReceivedMessage
(Message message) Notifty the queue (and its listeners) of a message received externally on the queue's behalf.int[]
receiveFromTransport
(int max_bytes, boolean protocol_is_free) Receive (read) message(s) data from the underlying transport.void
Add a listener to be notified of queue events.void
Manually resume processing (reading) incoming messages.void
setDecoder
(MessageStreamDecoder new_stream_decoder) Set the message stream decoder that will be used to decode incoming messages.
-
Constructor Details
-
imq
protected imq()
-
-
Method Details
-
setDecoder
Description copied from interface:IncomingMessageQueue
Set the message stream decoder that will be used to decode incoming messages.- Specified by:
setDecoder
in interfaceIncomingMessageQueue
- Parameters:
new_stream_decoder
- to use
-
getDecoder
- Specified by:
getDecoder
in interfaceIncomingMessageQueue
-
getCurrentMessageProgress
public int[] getCurrentMessageProgress()Description copied from interface:IncomingMessageQueue
Get the progress of the current message that is being received- Specified by:
getCurrentMessageProgress
in interfaceIncomingMessageQueue
- Returns:
- [size, done] or null
-
receiveFromTransport
Description copied from interface:IncomingMessageQueue
Receive (read) message(s) data from the underlying transport.- Specified by:
receiveFromTransport
in interfaceIncomingMessageQueue
- Parameters:
max_bytes
- to read- Returns:
- number of bytes received as [data, protocol]
- Throws:
IOException
- on receive error
-
notifyOfExternallyReceivedMessage
Description copied from interface:IncomingMessageQueue
Notifty the queue (and its listeners) of a message received externally on the queue's behalf.- Specified by:
notifyOfExternallyReceivedMessage
in interfaceIncomingMessageQueue
- Parameters:
message
- received externally
-
resumeQueueProcessing
public void resumeQueueProcessing()Description copied from interface:IncomingMessageQueue
Manually resume processing (reading) incoming messages. NOTE: Allows us to resume docoding externally, in case it was auto-paused internally.- Specified by:
resumeQueueProcessing
in interfaceIncomingMessageQueue
-
registerQueueListener
Description copied from interface:IncomingMessageQueue
Add a listener to be notified of queue events.- Specified by:
registerQueueListener
in interfaceIncomingMessageQueue
-
cancelQueueListener
Description copied from interface:IncomingMessageQueue
Cancel queue event notification listener.- Specified by:
cancelQueueListener
in interfaceIncomingMessageQueue
-
destroy
public void destroy()Description copied from interface:IncomingMessageQueue
Destroy this queue.- Specified by:
destroy
in interfaceIncomingMessageQueue
-