com.goldencode.p2j.net

Class Protocol.Writer

java.lang.Object

com.goldencode.p2j.net.Protocol.Writer

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

Protocol

private class Protocol.Writer
extends java.lang.Object
implements java.lang.Runnable

This helper class implements functionality of Writer thread.

Field Summary

Fields

Modifier and Type	Field and Description
private Protocol.ByteArrayOutputStream2	baos Pre-allocated helper buffers for object flattening
private static int	BUFFER_SIZE Default size of buffer for object flattening
private byte[]	data Holder for data to be written out
private java.io.ByteArrayOutputStream	res

Constructor Summary

Constructors

Modifier	Constructor and Description
private	Writer()

Method Summary

Modifier and Type	Method and Description
private byte[]	objToByteArray(Message obj) Serialize the given object into an in-memory array of bytes.
void	run() This method obtains messages from the Outbound Queue and writes them into output stream.
private void	setData(byte[] data) Set new value of the data field (by be used in lambdas)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BUFFER_SIZE

private static final int BUFFER_SIZE

Default size of buffer for object flattening

See Also:

Constant Field Values

baos

private Protocol.ByteArrayOutputStream2 baos

Pre-allocated helper buffers for object flattening

res

private java.io.ByteArrayOutputStream res

data

private byte[] data

Holder for data to be written out

Constructor Detail

Writer

private Writer()

Method Detail

setData

private void setData(byte[] data)

Set new value of the data field (by be used in lambdas)

Parameters:

data - new value of the field

run

public void run()

This method obtains messages from the Outbound Queue and writes them into output stream.

Specified by:

run in interface java.lang.Runnable

objToByteArray

private byte[] objToByteArray(Message obj)
                       throws java.io.IOException

Serialize the given object into an in-memory array of bytes.

Parameters:

obj - The graph of objects to be converted.

Returns:

The "flattened" version.

Throws:

java.io.IOException - on error