protected class TP.SimplifiedTransferQueueBundler extends TP.TransferQueueBundler
TP.TransferQueueBundler
but does not allocate
memory except for the buffer itself and does not use complex data structures.Modifier and Type | Field and Description |
---|---|
protected int |
curr |
protected static int |
MSG_BUF_SIZE |
protected Message[] |
msg_queue |
bundler_thread, queue, THREAD_NAME
output
Modifier | Constructor and Description |
---|---|
protected |
SimplifiedTransferQueueBundler(int capacity) |
Modifier and Type | Method and Description |
---|---|
protected void |
addMessage(Message msg,
long size) |
protected void |
sendBundledMessages()
Sends all messages in the map.
|
protected void |
sendSingleMessage(Message msg,
ByteArrayDataOutputStream output) |
getBufferSize, getThread, run, send, start, stop
numMessages, sendMessageList, sendSingleMessage
protected static final int MSG_BUF_SIZE
protected final Message[] msg_queue
protected int curr
protected SimplifiedTransferQueueBundler(int capacity)
protected void addMessage(Message msg, long size)
addMessage
in class TP.BaseBundler
protected void sendBundledMessages()
TP.BaseBundler
sendBundledMessages
in class TP.BaseBundler
protected void sendSingleMessage(Message msg, ByteArrayDataOutputStream output)
Copyright © 1998-2020 Red Hat. All Rights Reserved.