public class DataChainSendOrderStructure
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private java.lang.Object |
m_additionalProtocolData
A multi purpose object that can be set to be anything
|
private byte[] |
m_channelCell
A byte array formatted for the channel that is used to send it.
|
private java.lang.Object |
m_internalSynchronization
Object used to synchronize processing and sending of the order.
|
private byte[] |
m_orderData |
private int |
m_processedBytes |
private boolean |
m_processingDone
Whether processing on this order has finished or not.
|
private java.io.IOException |
m_thrownException |
Constructor and Description |
---|
DataChainSendOrderStructure(byte[] a_orderData) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
getAdditionalProtocolData()
Returns the additional protocol data as an Object type.
|
byte[] |
getChannelCell()
Returns the channel cell buffer, that will be transmitted over the
channel.
|
byte[] |
getOrderData() |
int |
getProcessedBytes()
Returns the number of bytes of the order data, that have already
been processed.
|
java.lang.Object |
getSynchronizationObject()
Returns the internal synchronization object.
|
java.io.IOException |
getThrownException()
Returns the exception that occurred while processing this order.
|
boolean |
isProcessingDone()
Returns whether or not the processing was finished on this order
already.
|
void |
processingDone()
Declares the processing of this order as having finished and notifies
threads waiting on it.
|
void |
setAdditionalProtocolData(java.lang.Object a_protocolData)
Sets any object as additional protocol data.
|
void |
setChannelCell(byte[] a_channelCell)
Set the channel cell byte buffer, that will be transmitted over the
channel.
|
void |
setProcessedBytes(int a_processedBytes)
Set how many bytes of the order data have been processed already.
|
void |
setThrownException(java.io.IOException a_thrownException)
Sets the exception that occurred, when the processing of an order
ended in an error.
|
private byte[] m_orderData
private java.lang.Object m_additionalProtocolData
private int m_processedBytes
private java.io.IOException m_thrownException
private byte[] m_channelCell
This will be encrypted for the mix chain and send over the socket.
anon.client.SequentialChannelDataChain#createPacketPayload(DataChainSendOrderStructure)}
,
anon.client.SingleChannelDataChain#createPacketPayload(DataChainSendOrderStructure)}
private java.lang.Object m_internalSynchronization
private boolean m_processingDone
public DataChainSendOrderStructure(byte[] a_orderData)
public byte[] getOrderData()
public java.lang.Object getAdditionalProtocolData()
This needs to be cast to whatever type the protocol data is expected to be.
public void setAdditionalProtocolData(java.lang.Object a_protocolData)
a_protocolData
- protocol data as Objectpublic void processingDone()
anon.client.DataChainSendOrderStructure#m_internalSynchronization m_internalSynchronization}
,
anon.client.DataChainSendOrderStructure#isProcessingDone() isProcessingDone()}
,
anon.client.DataChainSendOrderStructure#getSynchronizationObject() getSynchronizationObject()}
public boolean isProcessingDone()
public java.lang.Object getSynchronizationObject()
public void setThrownException(java.io.IOException a_thrownException)
a_thrownException
- public java.io.IOException getThrownException()
public void setProcessedBytes(int a_processedBytes)
a_processedBytes
- public int getProcessedBytes()
public void setChannelCell(byte[] a_channelCell)
This is usually called by the data chain, when preparing the payload.
a_channelCell
- anon.client.DataChainSendOrderStructure#m_channelCell m_channelCell}
,
anon.client.AbstractDataChain#createPacketPayload(DataChainSendOrderStructure)}
public byte[] getChannelCell()
anon.client.DataChainSendOrderStructure#m_channelCell m_channelCell}
Copyright © 2023. All rights reserved.