Package com.gigaspaces.internal.transport

Class EntryPacket

java.lang.Object

com.gigaspaces.internal.serialization.AbstractExternalizable

com.gigaspaces.internal.transport.AbstractEntryPacket

com.gigaspaces.internal.transport.EntryPacket

All Implemented Interfaces:

RawEntry, ISwapExternalizable, IEntryPacket, ITransportPacket, IMVCCEntryPacket, Textualizable, SmartExternalizable, Externalizable, Serializable, Cloneable

Direct Known Subclasses:

ExternalEntryPacket, JoinedEntry, TemplatePacket

public class EntryPacket
extends AbstractEntryPacket
implements IMVCCEntryPacket

This class represents a packet of information transmitted between a J-Space client and its J-Space server (and vice versa).

The information transmitted is composed of 2 types: information on the entry's class, and information on the entry's data (the fields' values). Since the protocol between J-Space client and server are designed for minimum data passing, most of the fields in an EntryPacket are usually null (they are transmitted once for each entry class in a client's life-time).

All the fields in this class are public, in order to increase access and modification speed (no need to call a method).

Version:

1.0

Author:

Igor Goldenberg

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	_returnOnlyUIDs
protected String	_typeName

Fields inherited from class com.gigaspaces.internal.transport.AbstractEntryPacket

_entryType, _entryTypeCode, _typeDesc, _typeDescChecksum

Constructor Summary

Constructors

Modifier	Constructor	Description
	EntryPacket()	Default constructor required by Externalizable.
	EntryPacket(ITypeDesc typeDesc, EntryType entryType, Object[] fixedProperties, Map<String,Object> dynamicProperties, String uid, int version, long timeToLive, boolean isTransient)
protected	EntryPacket(ITypeDesc typeDesc, Object[] values)

Method Summary

Modifier and Type	Method	Description
void	applyMVCCEntryMetadata(MVCCEntryHolder eh)
IEntryPacket	clone()	Returns a shallow copy of this EntryPacket instance.
ICustomQuery	getCustomQuery()
Map<String,Object>	getDynamicProperties()
Object	getFieldValue(int index)
Object[]	getFieldValues()
String[]	getMultipleUIDs()
MVCCEntryPacketMetadata	getMVCCEntryMetadata()
TransportPacketType	getPacketType()
long	getTTL()
String	getTypeName()
String	getUID()
int	getVersion()
boolean	hasFixedPropertiesArray()	true if the entry packet has an array of fixed properties
boolean	isFifo()
boolean	isMVCCEntryMetadataApplied()	If packet is using not for recovery, metadata is not applied -> has default values
boolean	isNoWriteLease()
boolean	isReturnOnlyUids()
boolean	isTransient()
protected void	readExternal(ObjectInput in, PlatformLogicalVersion version)
void	readFromSwap(ObjectInput in)
void	setCustomQuery(ICustomQuery customQuery)
void	setDynamicProperties(Map<String,Object> dynamicProperties)
void	setFieldsValues(Object[] values)
void	setFieldValue(int index, Object value)
void	setMultipleUIDs(String[] multipleUIDs)
void	setReturnOnlyUIDs(boolean returnOnlyUIDs)
void	setTTL(long ttl)
void	setUID(String uid)
void	setVersion(int version)
protected void	writeExternal(ObjectOutput out, PlatformLogicalVersion version)
void	writeToSwap(ObjectOutput out)

Methods inherited from class com.gigaspaces.internal.transport.AbstractEntryPacket

equals, getCodebase, getEntryType, getExternalEntryImplClassName, getID, getIdImpl, getOperationID, getPreviousVersion, getPropertyValue, getRoutingFieldValue, getTypeDescChecksum, getTypeDescriptor, hashCode, hasPreviousVersion, isExternalizableEntryPacket, isSerializeTypeDesc, readExternalImpl, setOperationID, setPreviousVersion, setPropertyValue, setSerializeTypeDesc, setTypeDesc, supportsTypeDescChecksum, toObject, toObject, toObject, toObject, toString, toText, validateStorageType, writeExternalImpl

Methods inherited from class com.gigaspaces.internal.serialization.AbstractExternalizable

readExternal, writeExternal

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Methods inherited from interface com.gigaspaces.internal.transport.IEntryPacket

allNullFieldValues, getID, getPreviousVersion, hasPreviousVersion, isExternalizableEntryPacket, isHybrid, setPreviousVersion

Methods inherited from interface com.gigaspaces.internal.transport.ITransportPacket

getCodebase, getEntryType, getExternalEntryImplClassName, getOperationID, getPropertyValue, getRoutingFieldValue, getTypeDescChecksum, getTypeDescriptor, isSerializeTypeDesc, setOperationID, setPropertyValue, setSerializeTypeDesc, setTypeDesc, supportsTypeDescChecksum, toObject, toObject, toObject, toObject

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Field Details

_typeName

protected String _typeName

_returnOnlyUIDs

protected boolean _returnOnlyUIDs

Constructor Details

EntryPacket

public EntryPacket()

Default constructor required by Externalizable.

EntryPacket

public EntryPacket(ITypeDesc typeDesc,
 EntryType entryType,
 Object[] fixedProperties,
 Map<String,Object> dynamicProperties,
 String uid,
 int version,
 long timeToLive,
 boolean isTransient)

EntryPacket

protected EntryPacket(ITypeDesc typeDesc,
 Object[] values)

Method Details

clone

public IEntryPacket clone()

Returns a shallow copy of this EntryPacket instance. And also only clone the values array.

Specified by:

clone in interface IEntryPacket

Overrides:

clone in class AbstractEntryPacket

Returns:

a shallow clone of this EntryPacket instance.

getPacketType

public TransportPacketType getPacketType()

Specified by:

getPacketType in interface ITransportPacket

getTypeName

public String getTypeName()

Specified by:

getTypeName in interface ITransportPacket

getUID

public String getUID()

Specified by:

getUID in interface ITransportPacket

setUID

public void setUID(String uid)

Specified by:

setUID in interface IEntryPacket

getMultipleUIDs

public String[] getMultipleUIDs()

Specified by:

getMultipleUIDs in interface ITransportPacket

setMultipleUIDs

public void setMultipleUIDs(String[] multipleUIDs)

Specified by:

setMultipleUIDs in interface ITransportPacket

isReturnOnlyUids

public boolean isReturnOnlyUids()

setReturnOnlyUIDs

public void setReturnOnlyUIDs(boolean returnOnlyUIDs)

getDynamicProperties

public Map<String,Object> getDynamicProperties()

Specified by:

getDynamicProperties in interface ITransportPacket

setDynamicProperties

public void setDynamicProperties(Map<String,Object> dynamicProperties)

Specified by:

setDynamicProperties in interface ITransportPacket

getFieldValues

public Object[] getFieldValues()

Specified by:

getFieldValues in interface ITransportPacket

setFieldsValues

public void setFieldsValues(Object[] values)

Specified by:

setFieldsValues in interface ITransportPacket

getFieldValue

public Object getFieldValue(int index)

Specified by:

getFieldValue in interface ITransportPacket

setFieldValue

public void setFieldValue(int index,
 Object value)

Specified by:

setFieldValue in interface ITransportPacket

isTransient

public boolean isTransient()

Specified by:

isTransient in interface ITransportPacket

isFifo

public boolean isFifo()

Specified by:

isFifo in interface ITransportPacket

getVersion

public int getVersion()

Specified by:

getVersion in interface ITransportPacket

setVersion

public void setVersion(int version)

Specified by:

setVersion in interface ITransportPacket

getTTL

public long getTTL()

Specified by:

getTTL in interface IEntryPacket

setTTL

public void setTTL(long ttl)

Specified by:

setTTL in interface IEntryPacket

isNoWriteLease

public boolean isNoWriteLease()

Specified by:

isNoWriteLease in interface ITransportPacket

getCustomQuery

public ICustomQuery getCustomQuery()

Specified by:

getCustomQuery in interface ITransportPacket

setCustomQuery

public void setCustomQuery(ICustomQuery customQuery)

Specified by:

setCustomQuery in interface IEntryPacket

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Overrides:

writeToSwap in class AbstractEntryPacket

Throws:

IOException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Overrides:

readFromSwap in class AbstractEntryPacket

Throws:

IOException

ClassNotFoundException

writeExternal

protected void writeExternal(ObjectOutput out,
 PlatformLogicalVersion version)
                      throws IOException

Overrides:

writeExternal in class AbstractEntryPacket

Throws:

IOException

readExternal

protected void readExternal(ObjectInput in,
 PlatformLogicalVersion version)
                     throws IOException,
ClassNotFoundException

Overrides:

readExternal in class AbstractEntryPacket

Throws:

IOException

ClassNotFoundException

hasFixedPropertiesArray

public boolean hasFixedPropertiesArray()

true if the entry packet has an array of fixed properties

Specified by:

hasFixedPropertiesArray in interface IEntryPacket

Overrides:

hasFixedPropertiesArray in class AbstractEntryPacket

applyMVCCEntryMetadata

public void applyMVCCEntryMetadata(MVCCEntryHolder eh)

Specified by:

applyMVCCEntryMetadata in interface IMVCCEntryPacket

isMVCCEntryMetadataApplied

public boolean isMVCCEntryMetadataApplied()

If packet is using not for recovery, metadata is not applied -> has default values

Specified by:

isMVCCEntryMetadataApplied in interface IMVCCEntryPacket

getMVCCEntryMetadata

public MVCCEntryPacketMetadata getMVCCEntryMetadata()

Specified by:

getMVCCEntryMetadata in interface IMVCCEntryPacket