Inheritance diagram for Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor:

Public Member Functions
	ServerMessageProcessor (ServerConnector connector)

IMessageEnvelope	ProcessMessage (IMessageEnvelope envelope)

	ServerMessageProcessor (ServerConnector connector)

IMessageEnvelope	ProcessMessage (IMessageEnvelope envelope)

Private Member Functions
IMessageEnvelope	CreateErrorResponse (IMessageEnvelope sourceMessage, string message)

IMessageEnvelope	CreateErrorResponse (IMessageEnvelope sourceMessage, Exception error)

IMessageEnvelope	CreateErrorResponse (IDictionary< string, object > metadata, Exception error)

IMessageEnvelope	ProcessAuthenticate (IDictionary< string, object > metadata, AuthenticateRequest request)

IMessageEnvelope	ProcessConnect (IDictionary< string, object > metadata, ConnectRequest request)

IMessageEnvelope	ProcessClose (IDictionary< string, object > metadata)

IMessageEnvelope	ProcessQuery (IDictionary< string, object > metadata, QueryExecuteRequest request)

IMessageEnvelope	ProcessQueryPart (IDictionary< string, object > metadata, QueryResultPartRequest request)

IMessageEnvelope	ProcessDisposeResult (IDictionary< string, object > metadata, DisposeResultRequest request)

IMessageEnvelope	ProcessCreateLargeObject (IDictionary< string, object > metadata, LargeObjectCreateRequest request)

IMessageEnvelope	ProcessBegin (IDictionary< string, object > metadata)

IMessageEnvelope	ProcessCommit (IDictionary< string, object > metadata, CommitRequest request)

IMessageEnvelope	ProcessRollback (IDictionary< string, object > metadata, RollbackRequest request)

IMessageEnvelope	CreateErrorResponse (IMessageEnvelope sourceMessage, string message)

IMessageEnvelope	CreateErrorResponse (IMessageEnvelope sourceMessage, Exception error)

IMessageEnvelope	CreateErrorResponse (IDictionary< string, object > metadata, Exception error)

IMessageEnvelope	ProcessAuthenticate (IDictionary< string, object > metadata, AuthenticateRequest request)

IMessageEnvelope	ProcessConnect (IDictionary< string, object > metadata, ConnectRequest request)

IMessageEnvelope	ProcessClose (IDictionary< string, object > metadata)

IMessageEnvelope	ProcessQuery (IDictionary< string, object > metadata, QueryExecuteRequest request)

IMessageEnvelope	ProcessQueryPart (IDictionary< string, object > metadata, QueryResultPartRequest request)

IMessageEnvelope	ProcessDisposeResult (IDictionary< string, object > metadata, DisposeResultRequest request)

IMessageEnvelope	ProcessCreateLargeObject (IDictionary< string, object > metadata, LargeObjectCreateRequest request)

IMessageEnvelope	ProcessBegin (IDictionary< string, object > metadata)

IMessageEnvelope	ProcessCommit (IDictionary< string, object > metadata, CommitRequest request)

IMessageEnvelope	ProcessRollback (IDictionary< string, object > metadata, RollbackRequest request)

Private Attributes
readonly ServerConnector	connector

Detailed Description

Definition at line 535 of file ServerConnector.cs.

Constructor & Destructor Documentation

Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ServerMessageProcessor ( ServerConnector connector )

inline

Definition at line 538 of file ServerConnector.cs.

                                                                      {
                 this.connector = connector;
             }

Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ServerMessageProcessor ( ServerConnector connector )

inline

Definition at line 692 of file ServerConnector.old.cs.

                                                                      {
                 this.connector = connector;
             }

Member Function Documentation

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.CreateErrorResponse	(	IMessageEnvelope	sourceMessage,
		string	message
	)

inlineprivate

Definition at line 542 of file ServerConnector.cs.

                                                                                                          {
                 return CreateErrorResponse(sourceMessage, new ProtocolException(message));
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.CreateErrorResponse	(	IMessageEnvelope	sourceMessage,
		Exception	error
	)

inlineprivate

Definition at line 546 of file ServerConnector.cs.

                                                                                                           {
                 IDictionary<string, object> metadata = null;
                 if (sourceMessage != null)
                     metadata = sourceMessage.Metadata;
 
                 return CreateErrorResponse(metadata, error);
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.CreateErrorResponse	(	IDictionary< string, object >	metadata,
		Exception	error
	)

inlineprivate

Definition at line 554 of file ServerConnector.cs.

                                                                                                                 {
                 var envelope = connector.CreateEnvelope(metadata, new AcknowledgeResponse(false));
                 envelope.SetError(error);
                 return envelope;
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.CreateErrorResponse	(	IMessageEnvelope	sourceMessage,
		string	message
	)

inlineprivate

Definition at line 696 of file ServerConnector.old.cs.

                                                                                                          {
                 return CreateErrorResponse(sourceMessage, new ProtocolException(message));
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.CreateErrorResponse	(	IMessageEnvelope	sourceMessage,
		Exception	error
	)

inlineprivate

Definition at line 700 of file ServerConnector.old.cs.

                                                                                                           {
                 IDictionary<string, object> metadata = null;
                 if (sourceMessage != null)
                     metadata = sourceMessage.Metadata;
 
                 return CreateErrorResponse(metadata, error);
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.CreateErrorResponse	(	IDictionary< string, object >	metadata,
		Exception	error
	)

inlineprivate

Definition at line 708 of file ServerConnector.old.cs.

                                                                                                                 {
                 var envelope = connector.CreateEnvelope(metadata, new AcknowledgeResponse(false));
                 envelope.SetError(error);
                 return envelope;
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessAuthenticate	(	IDictionary< string, object >	metadata,
		AuthenticateRequest	request
	)

inlineprivate

Definition at line 560 of file ServerConnector.cs.

                                                                                                                             {
                 try {
                     if (!connector.Authenticate(request.DefaultSchema, request.UserName, request.Password)) {
                         var response = connector.CreateEnvelope(metadata, new AuthenticateResponse(false, -1));
                         // TODO: make the specialized exception ...
                         response.SetError(new Exception("Unable to authenticate."));
                         return response;
                     }
 
                     connector.ChangeState(ConnectorState.Authenticated);
 
                     // TODO: Get the UNIX epoch here?
                     return connector.CreateEnvelope(metadata, new AuthenticateResponse(true, DateTime.UtcNow.Ticks));
                 } catch (Exception ex) {
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessAuthenticate	(	IDictionary< string, object >	metadata,
		AuthenticateRequest	request
	)

inlineprivate

Definition at line 714 of file ServerConnector.old.cs.

                                                                                                                             {
                 try {
                     if (!connector.Authenticate(request.DefaultSchema, request.UserName, request.Password)) {
                         var response = connector.CreateEnvelope(metadata, new AuthenticateResponse(false, -1));
                         // TODO: make the specialized exception ...
                         response.SetError(new Exception("Unable to authenticate."));
                         return response;
                     }
 
                     connector.ChangeState(ConnectorState.Authenticated);
 
                     // TODO: Get the UNIX epoch here?
                     return connector.CreateEnvelope(metadata, new AuthenticateResponse(true, DateTime.UtcNow.Ticks));
                 } catch (Exception ex) {
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessBegin ( IDictionary< string, object > metadata )

inlineprivate

Definition at line 709 of file ServerConnector.cs.

                                                                                         {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     var id = connector.BeginTransaction();
                     return connector.CreateEnvelope(metadata, new BeginResponse(id));
                 } catch (Exception ex) {
                     // TODO: Log the error ...
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessBegin ( IDictionary< string, object > metadata )

inlineprivate

Definition at line 871 of file ServerConnector.old.cs.

                                                                                         {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     var id = connector.BeginTransaction();
                     return connector.CreateEnvelope(metadata, new BeginResponse(id));
                 } catch (Exception ex) {
                     connector.Logger.Error(connector, "Error while beginning a transaction.");
                     connector.Logger.Error(connector, ex);
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessClose ( IDictionary< string, object > metadata )

inlineprivate

Definition at line 642 of file ServerConnector.cs.

                                                                                         {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     connector.CloseConnector();
                     return connector.CreateEnvelope(metadata, new AcknowledgeResponse(true));
                 } catch (Exception ex) {
                     // TODO: Log the error ...
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessClose ( IDictionary< string, object > metadata )

inlineprivate

Definition at line 798 of file ServerConnector.old.cs.

                                                                                         {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     connector.CloseConnector();
                     return connector.CreateEnvelope(metadata, new AcknowledgeResponse(true));
                 } catch (Exception ex) {
                     connector.Logger.Error(connector, "Error while closing a connection.");
                     connector.Logger.Error(connector, ex);
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessCommit	(	IDictionary< string, object >	metadata,
		CommitRequest	request
	)

inlineprivate

Definition at line 722 of file ServerConnector.cs.

                                                                                                                 {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     connector.CommitTransaction(request.TransactionId);
                     return connector.CreateEnvelope(metadata, new AcknowledgeResponse(true));
                 } catch (Exception ex) {
                     // TODO: Log the error ...
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessCommit	(	IDictionary< string, object >	metadata,
		CommitRequest	request
	)

inlineprivate

Definition at line 885 of file ServerConnector.old.cs.

                                                                                                                 {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     connector.CommitTransaction(request.TransactionId);
                     return connector.CreateEnvelope(metadata, new AcknowledgeResponse(true));
                 } catch (Exception ex) {
                     connector.Logger.Error(connector, "Error while committing the transaction.");
                     connector.Logger.Error(connector, ex);
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessConnect	(	IDictionary< string, object >	metadata,
		ConnectRequest	request
	)

inlineprivate

Definition at line 613 of file ServerConnector.cs.

                                                                                                                   {
                 Exception error = null;
                 ConnectResponse response;
 
                 try {
                     connector.OpenConnector(request.RemoteEndPoint, request.DatabaseName);
                     if (request.AutoCommit)
                         connector.SetAutoCommit(request.AutoCommit);
 
                     connector.SetIgnoreIdentifiersCase(request.IgnoreIdentifiersCase);
                     connector.SetParameterStyle(request.ParameterStyle);
 
                     var encryptionData = connector.GetEncryptionData();
 
                     var serverVersion = connector.Database.Version.ToString(2);
                     response = new ConnectResponse(true, serverVersion, encryptionData != null, encryptionData);
                 } catch (Exception ex) {
                     // TODO: Log the error ...
                     error = ex;
                     response = new ConnectResponse(false, null);
                 }
 
                 var envelope = connector.CreateEnvelope(metadata, response);
                 if (error != null)
                     envelope.SetError(error);
 
                 return connector.CreateEnvelope(metadata, response);
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessConnect	(	IDictionary< string, object >	metadata,
		ConnectRequest	request
	)

inlineprivate

Definition at line 767 of file ServerConnector.old.cs.

                                                                                                                   {
                 Exception error = null;
                 ConnectResponse response;
 
                 try {
                     connector.OpenConnector(request.RemoteEndPoint, request.DatabaseName);
                     if (request.AutoCommit)
                         connector.SetAutoCommit(request.AutoCommit);
 
                     connector.SetIgnoreIdentifiersCase(request.IgnoreIdentifiersCase);
                     connector.SetParameterStyle(request.ParameterStyle);
 
                     var encryptionData = connector.GetEncryptionData();
 
                     var serverVersion = connector.Database.Version.ToString(2);
                     response = new ConnectResponse(true, serverVersion, encryptionData != null, encryptionData);
                 } catch (Exception ex) {
                     connector.Logger.Error(connector, "Error while opening a connection.");
                     connector.Logger.Error(connector, ex);
 
                     error = ex;
                     response = new ConnectResponse(false, null);
                 }
 
                 var envelope = connector.CreateEnvelope(metadata, response);
                 if (error != null)
                     envelope.SetError(error);
 
                 return connector.CreateEnvelope(metadata, response);
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessCreateLargeObject	(	IDictionary< string, object >	metadata,
		LargeObjectCreateRequest	request
	)

inlineprivate

Definition at line 695 of file ServerConnector.cs.

                                                   {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     var objRef = connector.CreateLargeObject(request.ObjectLength);
                     return connector.CreateEnvelope(metadata, new LargeObjectCreateResponse(request.ObjectLength, objRef));
                 } catch (Exception ex) {
                     // TODO: Log the error ...
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessCreateLargeObject	(	IDictionary< string, object >	metadata,
		LargeObjectCreateRequest	request
	)

inlineprivate

Definition at line 855 of file ServerConnector.old.cs.

                                                   {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     var objRef = connector.CreateStreamableObject(request.ReferenceType, request.ObjectLength);
                     return connector.CreateEnvelope(metadata,
                         new LargeObjectCreateResponse(request.ReferenceType, request.ObjectLength, objRef));
                 } catch (Exception ex) {
                     connector.Logger.Error(connector, "Error while creating a large object.");
                     connector.Logger.Error(connector, ex);
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessDisposeResult	(	IDictionary< string, object >	metadata,
		DisposeResultRequest	request
	)

inlineprivate

Definition at line 682 of file ServerConnector.cs.

                                                                                                                               {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     connector.DisposeResult(request.ResultId);
                     return connector.CreateEnvelope(metadata, new AcknowledgeResponse(true));
                 } catch (Exception ex) {
                     // TODO: Log the error ...
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessDisposeResult	(	IDictionary< string, object >	metadata,
		DisposeResultRequest	request
	)

inlineprivate

Definition at line 841 of file ServerConnector.old.cs.

                                                                                                                               {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     connector.DisposeResult(request.ResultId);
                     return connector.CreateEnvelope(metadata, new AcknowledgeResponse(true));
                 } catch (Exception ex) {
                     connector.Logger.Error(connector, "Error occurred while disposing a query result.");
                     connector.Logger.Error(connector, ex);
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessMessage ( IMessageEnvelope envelope )

inline

Implements Deveel.Data.Protocol.IMessageProcessor.

Definition at line 578 of file ServerConnector.cs.

                                                                               {
                 var metadata = envelope.Metadata;
                 var message = connector.GetMessage(envelope);
                 if (message == null)
                     return CreateErrorResponse(metadata, new Exception("No message found in the envelope."));
 
                 if (message is ConnectRequest)
                     return ProcessConnect(metadata, (ConnectRequest)message);
 
                 if (message is AuthenticateRequest)
                     return ProcessAuthenticate(metadata, (AuthenticateRequest)message);
 
                 if (message is QueryExecuteRequest)
                     return ProcessQuery(metadata, (QueryExecuteRequest)message);
                 if (message is QueryResultPartRequest)
                     return ProcessQueryPart(metadata, (QueryResultPartRequest)message);
                 if (message is DisposeResultRequest)
                     return ProcessDisposeResult(metadata, (DisposeResultRequest)message);
 
                 if (message is LargeObjectCreateRequest)
                     return ProcessCreateLargeObject(metadata, (LargeObjectCreateRequest)message);
 
                 if (message is BeginRequest)
                     return ProcessBegin(metadata);
                 if (message is CommitRequest)
                     return ProcessCommit(metadata, (CommitRequest)message);
                 if (message is RollbackRequest)
                     return ProcessRollback(metadata, (RollbackRequest)message);
 
                 if (message is CloseRequest)
                     return ProcessClose(metadata);
 
                 return CreateErrorResponse(envelope, "Message not supported");
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessMessage ( IMessageEnvelope envelope )

inline

Implements Deveel.Data.Protocol.IMessageProcessor.

Definition at line 732 of file ServerConnector.old.cs.

                                                                               {
                 var metadata = envelope.Metadata;
                 var message = connector.GetMessage(envelope);
                 if (message == null)
                     return CreateErrorResponse(metadata, new Exception("No message found in the envelope."));
 
                 if (message is ConnectRequest)
                     return ProcessConnect(metadata, (ConnectRequest) message);
 
                 if (message is AuthenticateRequest)
                     return ProcessAuthenticate(metadata, (AuthenticateRequest) message);
 
                 if (message is QueryExecuteRequest)
                     return ProcessQuery(metadata, (QueryExecuteRequest) message);
                 if (message is QueryResultPartRequest)
                     return ProcessQueryPart(metadata, (QueryResultPartRequest) message);
                 if (message is DisposeResultRequest)
                     return ProcessDisposeResult(metadata, (DisposeResultRequest) message);
 
                 if (message is LargeObjectCreateRequest)
                     return ProcessCreateLargeObject(metadata, (LargeObjectCreateRequest) message);
 
                 if (message is BeginRequest)
                     return ProcessBegin(metadata);
                 if (message is CommitRequest)
                     return ProcessCommit(metadata, (CommitRequest)message);
                 if (message is RollbackRequest)
                     return ProcessRollback(metadata, (RollbackRequest)message);
 
                 if (message is CloseRequest)
                     return ProcessClose(metadata);
 
                 return CreateErrorResponse(envelope, "Message not supported");
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessQuery	(	IDictionary< string, object >	metadata,
		QueryExecuteRequest	request
	)

inlineprivate

Definition at line 655 of file ServerConnector.cs.

                                                                                                                      {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     // TODO: use the timeout ...
                     var queryResonse = connector.ExecuteQuery(request.CommitId, request.Query.Text, request.Query.Parameters);
                     return connector.CreateEnvelope(metadata, new QueryExecuteResponse(queryResonse));
                 } catch (Exception ex) {
                     // TODO: Log the error ...
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessQuery	(	IDictionary< string, object >	metadata,
		QueryExecuteRequest	request
	)

inlineprivate

Definition at line 812 of file ServerConnector.old.cs.

                                                                                                                      {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     // TODO: use the timeout ...
                     var queryResonse = connector.ExecuteQuery(request.Query.Text, request.Query.Parameters);
                     return connector.CreateEnvelope(metadata, new QueryExecuteResponse(queryResonse));
                 } catch (Exception ex) {
                     connector.Logger.Error(connector, "Error while processing a query request.");
                     connector.Logger.Error(connector, ex);
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessQueryPart	(	IDictionary< string, object >	metadata,
		QueryResultPartRequest	request
	)

inlineprivate

Definition at line 669 of file ServerConnector.cs.

                                                                                                                             {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     var part = connector.GetResultPart(request.ResultId, request.RowIndex, request.Count);
                     return connector.CreateEnvelope(metadata, new QueryResultPartResponse(request.ResultId, part));
                 } catch (Exception ex) {
                     // TODO: Log the error ...
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessQueryPart	(	IDictionary< string, object >	metadata,
		QueryResultPartRequest	request
	)

inlineprivate

Definition at line 827 of file ServerConnector.old.cs.

                                                                                                                             {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     var part = connector.GetResultPart(request.ResultId, request.RowIndex, request.Count);
                     return connector.CreateEnvelope(metadata, new QueryResultPartResponse(request.ResultId, part));
                 } catch (Exception ex) {
                     connector.Logger.Error(connector, "Error while requesting part of a query result.");
                     connector.Logger.Error(connector, ex);
                     throw;
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessRollback	(	IDictionary< string, object >	metadata,
		RollbackRequest	request
	)

inlineprivate

Definition at line 735 of file ServerConnector.cs.

                                                                                                                     {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     connector.RollbackTransaction(request.TransactionId);
                     return connector.CreateEnvelope(metadata, new AcknowledgeResponse(true));
                 } catch (Exception ex) {
                     // TODO: Log the error ...
                     return CreateErrorResponse(metadata, ex);
                 }
             }

IMessageEnvelope Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.ProcessRollback	(	IDictionary< string, object >	metadata,
		RollbackRequest	request
	)

inlineprivate

Definition at line 899 of file ServerConnector.old.cs.

                                                                                                                     {
                 try {
                     connector.AssertNotDisposed();
                     connector.AssertAuthenticated();
 
                     connector.RollbackTransaction(request.TransactionId);
                     return connector.CreateEnvelope(metadata, new AcknowledgeResponse(true));
                 } catch (Exception ex) {
                     connector.Logger.Error(connector, "Error while rolling-back the transaction.");
                     connector.Logger.Error(connector, ex);
                     return CreateErrorResponse(metadata, ex);
                 }               
             }

Member Data Documentation

readonly ServerConnector Deveel.Data.Protocol.ServerConnector.ServerMessageProcessor.connector

private

Definition at line 536 of file ServerConnector.cs.

The documentation for this class was generated from the following files:

/var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Protocol/ServerConnector.cs
/var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Protocol/ServerConnector.old.cs

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation