Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor Class Reference

Inheritance diagram for Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor:

Public Member Functions
	ClientProcessor (NetworkClientConnector connector)
IMessageEnvelope	ProcessMessage (IMessageEnvelope envelope)

Private Member Functions
IMessage	Ping (IMessageEnvelope envelope)
IMessage	RequestRollback (IMessageEnvelope envelope)
IMessage	RequestCommit (IMessageEnvelope envelope)
IMessage	RequestBegin (IMessageEnvelope envelope)
IMessage	RequestCreateTrigger (IMessageEnvelope envelope)
IMessage	RequestDisposeLargeObject (IMessageEnvelope envelope)
IMessage	RequestCreateLargeObject (IMessageEnvelope envelope)
IMessage	RequestDisposeResult (IMessageEnvelope envelope)
IMessage	RequestQueryResultPart (IMessageEnvelope envelope)
IMessage	RequestQueryExecute (IMessageEnvelope envelope)
IMessage	RequestAuthenticate (IMessageEnvelope envelope)
IMessage	RequestClose (IMessageEnvelope envelope)
IMessage	Request (IMessageEnvelope envelope)
IMessageEnvelope	CreateResponse (IDictionary< string, object > senderMetadata, IMessage response)
IMessage	RequestConnect (IMessageEnvelope envelope)

Private Attributes
readonly NetworkClientConnector	connector

Detailed Description

Definition at line 422 of file NetworkClientConnector.cs.

Constructor & Destructor Documentation

Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.ClientProcessor ( NetworkClientConnector  connector )

inline

Definition at line 425 of file NetworkClientConnector.cs.

                                                                     {
                this.connector = connector;
            }

Member Function Documentation

IMessageEnvelope Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.CreateResponse ( IDictionary< string, object >  senderMetadata, IMessage  response  )

inlineprivate

Definition at line 545 of file NetworkClientConnector.cs.

                                                                                                                   {
                return connector.CreateEnvelope(senderMetadata, response);
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.Ping ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 466 of file NetworkClientConnector.cs.

                                                             {
                return Request(envelope);
            }

IMessageEnvelope Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.ProcessMessage ( IMessageEnvelope  envelope )

inline

Implements Deveel.Data.Protocol.IMessageProcessor.

Definition at line 429 of file NetworkClientConnector.cs.

                                                                              {
                var message = envelope.Message;
                IMessage response = null;

                if (message is ConnectRequest)
                    response = RequestConnect(envelope);
                else if (message is AuthenticateRequest)
                    response = RequestAuthenticate(envelope);
                else if (message is QueryExecuteRequest)
                    response = RequestQueryExecute(envelope);
                else if (message is QueryResultPartRequest)
                    response = RequestQueryResultPart(envelope);
                else if (message is DisposeResultRequest)
                    response = RequestDisposeResult(envelope);
                else if (message is LargeObjectCreateRequest)
                    response = RequestCreateLargeObject(envelope);
                else if (message is LargeObjectDisposeRequest)
                    response = RequestDisposeLargeObject(envelope);
                else if (message is TriggerCreateRequest)
                    response = RequestCreateTrigger(envelope);
                else if (message is BeginRequest)
                    response = RequestBegin(envelope);
                else if (message is CommitRequest)
                    response = RequestCommit(envelope);
                else if (message is RollbackRequest)
                    response = RequestRollback(envelope);
                else if (message is PingRequest)
                    response = Ping(envelope);
                else if (message is CloseRequest)
                    response = RequestClose(envelope);
                
                if (response == null)
                    throw new NotSupportedException();

                return CreateResponse(envelope.Metadata, response);
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.Request ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 539 of file NetworkClientConnector.cs.

                                                                {
                connector.SendEnvelope(envelope);
                var response = connector.ReceiveResponse(connector.Timeout, envelope.Metadata);
                return connector.OnProcessServerResponse(response);
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestAuthenticate ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 506 of file NetworkClientConnector.cs.

                                                                            {
                try {
                    connector.AssertOpen();

                    var response = Request(envelope);
                    var responseMessage = (AuthenticateResponse) response;
                    if (!responseMessage.Authenticated)
                        throw new InvalidOperationException();

                    connector.OnAuthenticated(((AuthenticateRequest)envelope.Message).UserName, responseMessage.TimeStamp);
                    return response;
                } catch (Exception) {
                    
                    throw;
                }
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestBegin ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 478 of file NetworkClientConnector.cs.

                                                                     {
                throw new NotImplementedException();
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestClose ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 523 of file NetworkClientConnector.cs.

                                                                     {
                try {
                    var response = Request(envelope);
                    var responseMessage = (AcknowledgeResponse) response;
                    if (!responseMessage.State)
                        throw new InvalidOperationException();

                    connector.Close();

                    return response;
                } catch (Exception) {
                    
                    throw;
                }
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestCommit ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 474 of file NetworkClientConnector.cs.

                                                                      {
                throw new NotImplementedException();
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestConnect ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 549 of file NetworkClientConnector.cs.

                                                                       {
                try {
                    var request = (ConnectRequest) envelope.Message;
                    connector.Timeout = request.Timeout;
                    connector.OpenConnector(request.RemoteEndPoint);

                    var response = Request(envelope);
                    var responseMessage = (ConnectResponse) response;
                    if (!responseMessage.Opened) {
                        connector.Close();
                        throw new InvalidOperationException();
                    }

                    return response;
                } catch (Exception) {
                    //TODO: 
                    throw;
                }
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestCreateLargeObject ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 490 of file NetworkClientConnector.cs.

                                                                                 {
                throw new NotImplementedException();
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestCreateTrigger ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 482 of file NetworkClientConnector.cs.

                                                                             {
                throw new NotImplementedException();
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestDisposeLargeObject ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 486 of file NetworkClientConnector.cs.

                                                                                  {
                throw new NotImplementedException();
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestDisposeResult ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 494 of file NetworkClientConnector.cs.

                                                                             {
                throw new NotImplementedException();
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestQueryExecute ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 502 of file NetworkClientConnector.cs.

                                                                            {
                throw new NotImplementedException();
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestQueryResultPart ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 498 of file NetworkClientConnector.cs.

                                                                               {
                throw new NotImplementedException();
            }

IMessage Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.RequestRollback ( IMessageEnvelope  envelope )

inlineprivate

Definition at line 470 of file NetworkClientConnector.cs.

                                                                        {
                throw new NotImplementedException();
            }

Member Data Documentation

readonly NetworkClientConnector Deveel.Data.Protocol.NetworkClientConnector.ClientProcessor.connector

private

Definition at line 423 of file NetworkClientConnector.cs.

---

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

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Protocol/NetworkClientConnector.cs