org.apache.tinkerpop.gremlin.server.op

Class AbstractOpProcessor

java.lang.Object

org.apache.tinkerpop.gremlin.server.op.AbstractOpProcessor

All Implemented Interfaces:

AutoCloseable, OpProcessor

Direct Known Subclasses:

AbstractEvalOpProcessor, TraversalOpProcessor

public abstract class AbstractOpProcessor
extends Object
implements OpProcessor

Author:

Stephen Mallette (http://stephen.genoprime.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	manageTransactions

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractOpProcessor(boolean manageTransactions)

Method Summary

Modifier and Type	Method and Description
protected static void	attemptCommit(RequestMessage msg, GraphManager graphManager, boolean strict)
protected static void	attemptRollback(RequestMessage msg, GraphManager graphManager, boolean strict)
protected void	handleIterator(Context context, Iterator itty) Provides a generic way of iterating a result set back to the client.
protected static Frame	makeFrame(ChannelHandlerContext ctx, RequestMessage msg, MessageSerializer serializer, boolean useBinary, List<Object> aggregate, ResponseStatusCode code)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.tinkerpop.gremlin.server.OpProcessor

getName, select

Methods inherited from interface java.lang.AutoCloseable

close

Field Detail

manageTransactions

protected final boolean manageTransactions

Constructor Detail

AbstractOpProcessor

protected AbstractOpProcessor(boolean manageTransactions)

Method Detail

handleIterator

protected void handleIterator(Context context,
                              Iterator itty)
                       throws TimeoutException,
                              InterruptedException

Provides a generic way of iterating a result set back to the client. Implementers should respect the Settings.serializedResponseTimeout configuration and break the serialization process if it begins to take too long to do so, throwing a TimeoutException in such cases.

Parameters:

context - The Gremlin Server Context object containing settings, request message, etc.

itty - The result to iterator

Throws:

TimeoutException - if the time taken to serialize the entire result set exceeds the allowable time.

InterruptedException

makeFrame

protected static Frame makeFrame(ChannelHandlerContext ctx,
                                 RequestMessage msg,
                                 MessageSerializer serializer,
                                 boolean useBinary,
                                 List<Object> aggregate,
                                 ResponseStatusCode code)
                          throws Exception

Throws:

Exception

attemptCommit

protected static void attemptCommit(RequestMessage msg,
                                    GraphManager graphManager,
                                    boolean strict)

attemptRollback

protected static void attemptRollback(RequestMessage msg,
                                      GraphManager graphManager,
                                      boolean strict)