Package org.infinispan.protostream.impl

Class SerializationContextImpl

java.lang.Object

org.infinispan.protostream.impl.SerializationContextImpl

All Implemented Interfaces:

ImmutableSerializationContext, SerializationContext

public final class SerializationContextImpl
extends Object
implements SerializationContext

Since:

1.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	SerializationContextImpl.Registration

Nested classes/interfaces inherited from interface org.infinispan.protostream.SerializationContext

SerializationContext.InstanceMarshallerProvider<T>, SerializationContext.MarshallerProvider

Field Summary

Fields

Modifier and Type	Field	Description
private final Configuration	configuration
private final StampedLock	descriptorLock	All descriptor related mutable internal state is protected by this RW lock.
(package private) static final Class<?>[]	EMPTY_CLASSES
private final Map<String,EnumValueDescriptor>	enumValueDescriptors
private final Map<String,FileDescriptor>	fileDescriptors
private final Map<String,GenericDescriptor>	genericDescriptors
private final List<SerializationContext.MarshallerProvider>	legacyMarshallerProviders
private static final Log	log
private final StampedLock	manifestLock	All marshaller related mutable internal state is protected by this RW lock.
private final Map<Class<?>,SerializationContextImpl.Registration>	marshallersByClass
private final Map<String,SerializationContextImpl.Registration>	marshallersByName
private final ProtostreamProtoParser	parser
private final Map<Integer,GenericDescriptor>	typeIds

Constructor Summary

Constructors

Constructor	Description
SerializationContextImpl(Configuration configuration)

Method Summary

Modifier and Type	Method	Description
boolean	canMarshall(Class<?> javaClass)	Checks if the given type (message or enum) can be marshalled.
boolean	canMarshall(Object object)	Checks if the given instance can be marshalled.
boolean	canMarshall(String fullTypeName)	Checks if the given type (message or enum) can be marshalled.
(package private) static Class<?>	classForName(String name)
Configuration	getConfiguration()	Get the (immutable) configuration object that was used when creating this context.
GenericDescriptor	getDescriptorByName(String fullTypeName)	Obtains the descriptor associated with a type name.
GenericDescriptor	getDescriptorByTypeId(Integer typeId)	Obtains the descriptor associated with a numeric type id.
EnumDescriptor	getEnumDescriptor(String fullTypeName)
Map<String,FileDescriptor>	getFileDescriptors()	Obtain the currently registered file descriptors.
Map<String,GenericDescriptor>	getGenericDescriptors()	Obtain the currently registered type descriptors.
<T> BaseMarshaller<T>	getMarshaller(Class<T> clazz)	Obtains the marshaller associated with a Java type.
<T> BaseMarshaller<T>	getMarshaller(String fullTypeName)	Obtains the marshaller associated with a Protobuf type name.
<T> BaseMarshaller<T>	getMarshaller(T object)	Obtains the marshaller associated with a given instance.
<T> BaseMarshallerDelegate<T>	getMarshallerDelegate(Class<T> javaClass)
<T> BaseMarshallerDelegate<T>	getMarshallerDelegate(String typeName)
<T> BaseMarshallerDelegate<T>	getMarshallerDelegate(T object)
private <T> BaseMarshaller<T>	getMarshallerFromLegacyProvider(Class<T> javaClass)
private <T> BaseMarshaller<T>	getMarshallerFromLegacyProvider(String fullTypeName)
Descriptor	getMessageDescriptor(String fullTypeName)
Integer	getTypeIdByName(String fullTypeName)	Deprecated.
String	getTypeNameById(Integer typeId)	Deprecated.
private <T> BaseMarshallerDelegate<T>	makeMarshallerDelegate(BaseMarshaller<T> marshaller)
void	registerMarshaller(BaseMarshaller<?> marshaller)	Register a type marshaller.
void	registerMarshallerProvider(SerializationContext.InstanceMarshallerProvider<?> marshallerProvider)
void	registerMarshallerProvider(SerializationContext.MarshallerProvider marshallerProvider)	Deprecated.
void	registerProtoFiles(FileDescriptorSource source)	Register some proto schema definition files from a FileDescriptorSource.
private void	unregisterFileDescriptorTypes(FileDescriptor fileDescriptor)
void	unregisterMarshaller(BaseMarshaller<?> marshaller)
void	unregisterMarshallerProvider(SerializationContext.InstanceMarshallerProvider<?> marshallerProvider)
void	unregisterMarshallerProvider(SerializationContext.MarshallerProvider marshallerProvider)	Deprecated.
void	unregisterProtoFile(String fileName)	Unregisters a file.
void	unregisterProtoFiles(Set<String> fileNames)	Unregisters a set of files.

Methods inherited from class java.lang.Object

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

Field Details

EMPTY_CLASSES

static final Class<?>[] EMPTY_CLASSES

log

private static final Log log

descriptorLock

private final StampedLock descriptorLock

All descriptor related mutable internal state is protected by this RW lock.

configuration

private final Configuration configuration

parser

private final ProtostreamProtoParser parser

fileDescriptors

private final Map<String,FileDescriptor> fileDescriptors

typeIds

private final Map<Integer,GenericDescriptor> typeIds

genericDescriptors

private final Map<String,GenericDescriptor> genericDescriptors

enumValueDescriptors

private final Map<String,EnumValueDescriptor> enumValueDescriptors

manifestLock

private final StampedLock manifestLock

All marshaller related mutable internal state is protected by this RW lock.

marshallersByName

private final Map<String,SerializationContextImpl.Registration> marshallersByName

marshallersByClass

private final Map<Class<?>,SerializationContextImpl.Registration> marshallersByClass

legacyMarshallerProviders

private final List<SerializationContext.MarshallerProvider> legacyMarshallerProviders

Constructor Details

SerializationContextImpl

public SerializationContextImpl(Configuration configuration)

Method Details

getConfiguration

public Configuration getConfiguration()

Description copied from interface: ImmutableSerializationContext

Get the (immutable) configuration object that was used when creating this context.

Specified by:

getConfiguration in interface ImmutableSerializationContext

getFileDescriptors

public Map<String,FileDescriptor> getFileDescriptors()

Description copied from interface: ImmutableSerializationContext

Obtain the currently registered file descriptors.

Specified by:

getFileDescriptors in interface ImmutableSerializationContext

Returns:

an immutable copy of the internal map of descriptors

getGenericDescriptors

public Map<String,GenericDescriptor> getGenericDescriptors()

Description copied from interface: ImmutableSerializationContext

Obtain the currently registered type descriptors.

Specified by:

getGenericDescriptors in interface ImmutableSerializationContext

Returns:

an immutable copy of the internal map of descriptors

registerProtoFiles

public void registerProtoFiles(FileDescriptorSource source)
                        throws DescriptorParserException

Description copied from interface: SerializationContext

Register some proto schema definition files from a FileDescriptorSource.

Specified by:

registerProtoFiles in interface SerializationContext

Parameters:

source -

Throws:

DescriptorParserException

unregisterProtoFile

public void unregisterProtoFile(String fileName)

Description copied from interface: SerializationContext

Unregisters a file. All types defined in it are removed and also the types from all dependant files. The status of dependant files is set to 'unresolved'.

Specified by:

unregisterProtoFile in interface SerializationContext

unregisterProtoFiles

public void unregisterProtoFiles(Set<String> fileNames)

Description copied from interface: SerializationContext

Unregisters a set of files. All types defined in them are removed and also the types from all dependant files. The status of dependant files is set to 'unresolved'.

Specified by:

unregisterProtoFiles in interface SerializationContext

unregisterFileDescriptorTypes

@GuardedBy("descriptorLock")
private void unregisterFileDescriptorTypes(FileDescriptor fileDescriptor)

getMessageDescriptor

public Descriptor getMessageDescriptor(String fullTypeName)

Specified by:

getMessageDescriptor in interface ImmutableSerializationContext

getEnumDescriptor

public EnumDescriptor getEnumDescriptor(String fullTypeName)

Specified by:

getEnumDescriptor in interface ImmutableSerializationContext

registerMarshaller

public void registerMarshaller(BaseMarshaller<?> marshaller)

Description copied from interface: SerializationContext

Register a type marshaller.

Specified by:

registerMarshaller in interface SerializationContext

Parameters:

marshaller - the marshaller instance

classForName

static Class<?> classForName(String name)

makeMarshallerDelegate

private <T> BaseMarshallerDelegate<T> makeMarshallerDelegate(BaseMarshaller<T> marshaller)

unregisterMarshaller

public void unregisterMarshaller(BaseMarshaller<?> marshaller)

Specified by:

unregisterMarshaller in interface SerializationContext

registerMarshallerProvider

@Deprecated
public void registerMarshallerProvider(SerializationContext.MarshallerProvider marshallerProvider)

Deprecated.

Specified by:

registerMarshallerProvider in interface SerializationContext

unregisterMarshallerProvider

@Deprecated
public void unregisterMarshallerProvider(SerializationContext.MarshallerProvider marshallerProvider)

Deprecated.

Specified by:

unregisterMarshallerProvider in interface SerializationContext

registerMarshallerProvider

public void registerMarshallerProvider(SerializationContext.InstanceMarshallerProvider<?> marshallerProvider)

Specified by:

registerMarshallerProvider in interface SerializationContext

unregisterMarshallerProvider

public void unregisterMarshallerProvider(SerializationContext.InstanceMarshallerProvider<?> marshallerProvider)

Specified by:

unregisterMarshallerProvider in interface SerializationContext

canMarshall

public boolean canMarshall(Class<?> javaClass)

Description copied from interface: ImmutableSerializationContext

Checks if the given type (message or enum) can be marshalled. This checks that a marshaller was registered for it.

Specified by:

canMarshall in interface ImmutableSerializationContext

Parameters:

javaClass - the object or enum class to check

Returns:

true if a marshaller exists, false otherwise

canMarshall

public boolean canMarshall(String fullTypeName)

Description copied from interface: ImmutableSerializationContext

Checks if the given type (message or enum) can be marshalled. This checks that the Protobuf type was defined and a marshaller was registered for it.

Specified by:

canMarshall in interface ImmutableSerializationContext

Parameters:

fullTypeName - the fully qualified name of the Protobuf definition to check

Returns:

true if a marshaller exists, false otherwise

canMarshall

public boolean canMarshall(Object object)

Description copied from interface: ImmutableSerializationContext

Checks if the given instance can be marshalled.

Specified by:

canMarshall in interface ImmutableSerializationContext

Parameters:

object - the instance

Returns:

true if a marshaller exists, false otherwise

getMarshaller

public <T> BaseMarshaller<T> getMarshaller(T object)

Description copied from interface: ImmutableSerializationContext

Obtains the marshaller associated with a given instance.

Specified by:

getMarshaller in interface ImmutableSerializationContext

Parameters:

object - the instance

Returns:

the marshaller

getMarshaller

public <T> BaseMarshaller<T> getMarshaller(String fullTypeName)

Description copied from interface: ImmutableSerializationContext

Obtains the marshaller associated with a Protobuf type name.

Specified by:

getMarshaller in interface ImmutableSerializationContext

Parameters:

fullTypeName - the type name

Returns:

the marshaller

getMarshaller

public <T> BaseMarshaller<T> getMarshaller(Class<T> clazz)

Description copied from interface: ImmutableSerializationContext

Obtains the marshaller associated with a Java type.

Specified by:

getMarshaller in interface ImmutableSerializationContext

Parameters:

clazz - the class

Returns:

the marshaller

getMarshallerDelegate

public <T> BaseMarshallerDelegate<T> getMarshallerDelegate(String typeName)

getMarshallerDelegate

public <T> BaseMarshallerDelegate<T> getMarshallerDelegate(Class<T> javaClass)

getMarshallerDelegate

public <T> BaseMarshallerDelegate<T> getMarshallerDelegate(T object)

getMarshallerFromLegacyProvider

@GuardedBy("manifestLock")
private <T> BaseMarshaller<T> getMarshallerFromLegacyProvider(Class<T> javaClass)

getMarshallerFromLegacyProvider

@GuardedBy("manifestLock")
private <T> BaseMarshaller<T> getMarshallerFromLegacyProvider(String fullTypeName)

getTypeNameById

@Deprecated
public String getTypeNameById(Integer typeId)

Deprecated.

Description copied from interface: ImmutableSerializationContext

Obtains the Protobuf type name associated with a numeric type id.

Specified by:

getTypeNameById in interface ImmutableSerializationContext

Parameters:

typeId - the numeric type id

Returns:

the fully qualified type name

getTypeIdByName

@Deprecated
public Integer getTypeIdByName(String fullTypeName)

Deprecated.

Description copied from interface: ImmutableSerializationContext

Obtains the associated numeric type id for a Protobuf type name, if a numeric id was defined.

Specified by:

getTypeIdByName in interface ImmutableSerializationContext

Parameters:

fullTypeName - the fully qualified type name

Returns:

the type id or null if no type id is associated with the type

getDescriptorByName

public GenericDescriptor getDescriptorByName(String fullTypeName)

Description copied from interface: ImmutableSerializationContext

Obtains the descriptor associated with a type name.

Specified by:

getDescriptorByName in interface ImmutableSerializationContext

Parameters:

fullTypeName - the fully qualified type name

Returns:

the descriptor

getDescriptorByTypeId

public GenericDescriptor getDescriptorByTypeId(Integer typeId)

Description copied from interface: ImmutableSerializationContext

Obtains the descriptor associated with a numeric type id.

Specified by:

getDescriptorByTypeId in interface ImmutableSerializationContext

Parameters:

typeId - the numeric type id

Returns:

the descriptor