Package org.apache.ignite.internal.processors.platform.services

Class PlatformAbstractService

java.lang.Object

org.apache.ignite.internal.processors.platform.services.PlatformAbstractService

All Implemented Interfaces:

Externalizable, Serializable, PlatformService, Service

Direct Known Subclasses:

PlatformDotNetServiceImpl

public abstract class PlatformAbstractService
extends Object
implements PlatformService, Externalizable

Base platform service implementation.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected Object	interceptors	Service call interceptors.
protected PlatformContext	platformCtx	Context.
protected long	ptr	Pointer to deployed service.
protected boolean	srvKeepBinary	Whether to keep objects binary on server if possible.
protected Object	svc	.Net binary service.

Constructor Summary

Constructors

Constructor	Description
PlatformAbstractService()	Default constructor for serialization.
PlatformAbstractService(Object svc, PlatformContext ctx, boolean srvKeepBinary, @Nullable Object interceptors)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancels this service.
void	execute()	Starts execution of this service.
void	init()	Pre-initializes service before execution.
Object	invokeMethod(String mthdName, boolean srvKeepBinary, boolean deserializeResult, @Nullable Object[] args, @Nullable Map<String,Object> callAttrs)	Invokes native service method.
long	pointer()	Gets native pointer.
void	readExternal(ObjectInput in)
void	setIgniteInstance(Ignite ignite)
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.services.Service

cancel, execute, init

Field Detail

svc

protected Object svc

.Net binary service.

interceptors

protected Object interceptors

Service call interceptors.

srvKeepBinary

protected boolean srvKeepBinary

Whether to keep objects binary on server if possible.

ptr

protected transient long ptr

Pointer to deployed service.

platformCtx

protected transient PlatformContext platformCtx

Context.

Constructor Detail

PlatformAbstractService

public PlatformAbstractService()

Default constructor for serialization.

PlatformAbstractService

public PlatformAbstractService(Object svc,
                               PlatformContext ctx,
                               boolean srvKeepBinary,
                               @Nullable
                               @Nullable Object interceptors)

Constructor.

Parameters:

svc - Service.

ctx - Context.

srvKeepBinary - Whether to keep objects binary on server if possible.

interceptors - Service call interceptors.

Method Detail

init

public void init()
          throws Exception

Pre-initializes service before execution. This method is guaranteed to be called before service deployment is complete (this guarantees that this method will be called before method Service.execute() is called).

Specified by:

init in interface Service

Throws:

Exception - If service initialization failed.

See Also:

ServiceContextResource

execute

public void execute()
             throws Exception

Starts execution of this service. This method is automatically invoked whenever an instance of the service is deployed on a grid node. Note that service is considered deployed even after it exits the execute method and can be cancelled (or undeployed) only by calling any of the cancel methods on IgniteServices API. Also note that service is not required to exit from execute method until Service.cancel() method was called.

Specified by:

execute in interface Service

Throws:

Exception - If service execution failed. Not that service will still remain deployed, until IgniteServices.cancel(String) method will be called.

See Also:

ServiceContextResource

cancel

public void cancel()

Cancels this service. Ignite will automatically call this method whenever any of the cancel methods on IgniteServices API are called.

Note that Ignite cannot guarantee that the service exits from Service.execute() method whenever cancel() method is called. It is up to the user to make sure that the service code properly reacts to cancellations.

Specified by:

cancel in interface Service

See Also:

ServiceContextResource

pointer

public long pointer()

Gets native pointer.

Specified by:

pointer in interface PlatformService

Returns:

Native pointer.

invokeMethod

public Object invokeMethod(String mthdName,
                           boolean srvKeepBinary,
                           boolean deserializeResult,
                           @Nullable
                           @Nullable Object[] args,
                           @Nullable
                           @Nullable Map<String,Object> callAttrs)
                    throws IgniteCheckedException

Invokes native service method.

Specified by:

invokeMethod in interface PlatformService

Parameters:

mthdName - Method name.

srvKeepBinary - Server keep binary flag.

deserializeResult - If true, call service in cross-platform compatible manner.

args - Arguments.

callAttrs - Service call context attributes.

Returns:

Resulting data.

Throws:

IgniteCheckedException - If failed.

setIgniteInstance

@IgniteInstanceResource
public void setIgniteInstance(Ignite ignite)

Parameters:

ignite - Ignite instance.

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException