Deveel.Data.Protocol.TcpClientConnector Class Reference

Inheritance diagram for Deveel.Data.Protocol.TcpClientConnector:

Public Member Functions
override ConnectionEndPoint	MakeEndPoint (IDictionary< string, object > properties)
Public Member Functions inherited from Deveel.Data.Protocol.NetworkClientConnector
void	Dispose ()
virtual IMessageProcessor	CreateProcessor ()
virtual IMessageEnvelope	CreateEnvelope (IDictionary< string, object > metadata, IMessage message)
IStreamableObjectChannel	CreateObjectChannel (long objectId)
ITriggerChannel	CreateTriggerChannel (string triggerName, string objectName, TriggerEventType eventType)
void	SetEncrypton (EncryptionData encryptionData)
Public Member Functions inherited from Deveel.Data.Protocol.IConnector
ITriggerChannel	CreateTriggerChannel (string triggerName, string objectName, TriggerEventType eventType)

Public Attributes
const int	DefaultPort = 6669

Protected Member Functions
override NetworkStream	CreateNetworkStream (ConnectionEndPoint remoteEndPoint, FileAccess access)
Protected Member Functions inherited from Deveel.Data.Protocol.NetworkClientConnector
	NetworkClientConnector ()
virtual void	Dispose (bool disposing)
void	ChangeState (ConnectorState newState)
void	OpenConnector (ConnectionEndPoint remoteEndPoint)
void	Close ()
virtual void	OnAuthenticated (string username, long timeStamp)
virtual void	OnConnectorOpen ()
virtual IMessage	OnProcessServerResponse (IMessageEnvelope envelope)
virtual byte[]	SerializeEnvelope (IMessageEnvelope envelope)
void	SendEnvelope (IMessageEnvelope envelope)
virtual IMessageEnvelope	DeserializeEnvelope (byte[] bytes)
virtual bool	ShouldReceive (IDictionary< string, object > senderMetadata, IMessageEnvelope envelope)
virtual void	OnTriggerNotification (IMessageEnvelope envelope)

Properties
override ConnectionEndPoint	LocalEndPoint [get]
Properties inherited from Deveel.Data.Protocol.NetworkClientConnector
int	Timeout [get, set]
Stream	InputStream [get, set]
Stream	OutputStream [get, set]
ConnectorState	CurrentState [get, private set]
abstract ConnectionEndPoint	LocalEndPoint [get]
ConnectionEndPoint	RemoteEndPoint [get, private set]
Properties inherited from Deveel.Data.Protocol.IConnector
ConnectorState	CurrentState [get]
ConnectionEndPoint	LocalEndPoint [get]

Private Member Functions
EndPoint	ParseEndPoint (string s)

Detailed Description

Definition at line 24 of file TcpClientConnector.cs.

Member Function Documentation

override NetworkStream Deveel.Data.Protocol.TcpClientConnector.CreateNetworkStream ( ConnectionEndPoint  remoteEndPoint, FileAccess  access  )

inlineprotectedvirtual

Implements Deveel.Data.Protocol.NetworkClientConnector.

Definition at line 65 of file TcpClientConnector.cs.

                                                                                                                   {
            if (remoteEndPoint == null)
                throw new ArgumentNullException("remoteEndPoint");
            if (remoteEndPoint.Protocol != KnownConnectionProtocols.TcpIp)
                throw new ArgumentException();

            var endPoint = ParseEndPoint(remoteEndPoint.Address);

            var sockect = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
            sockect.SendTimeout = Timeout;
            sockect.ReceiveTimeout = Timeout;
            sockect.Connect(endPoint);

            return new NetworkStream(sockect, access, true);
        }

override ConnectionEndPoint Deveel.Data.Protocol.TcpClientConnector.MakeEndPoint ( IDictionary< string, object >  properties )

inlinevirtual

Implements Deveel.Data.Protocol.NetworkClientConnector.

Definition at line 31 of file TcpClientConnector.cs.

                                                                                                {
            object hostObj, portObj;
            if (!properties.TryGetValue("Host", out hostObj))
                throw new InvalidOperationException("Could not find the host address.");

            var host = (string) hostObj;
            var port = DefaultPort;

            if (properties.TryGetValue("Port", out portObj))
                port = (int) portObj;

            var address  = new StringBuilder(host);
            if (port > 0 && port != DefaultPort)
                address.AppendFormat(":{0}", port);

            return new ConnectionEndPoint(KnownConnectionProtocols.TcpIp, address.ToString());
        }

EndPoint Deveel.Data.Protocol.TcpClientConnector.ParseEndPoint ( string  s )

inlineprivate

Definition at line 49 of file TcpClientConnector.cs.

                                                 {
            string address = s;
            int port = DefaultPort;

            var sepIndex = address.IndexOf(':');
            if (sepIndex != -1) {
                string sPort = address.Substring(sepIndex + 1);
                if (!Int32.TryParse(sPort, out port))
                    throw new FormatException();

                address = address.Substring(0, sepIndex);
            }

            return new IPEndPoint(IPAddress.Parse(address), port);
        }

Member Data Documentation

const int Deveel.Data.Protocol.TcpClientConnector.DefaultPort = 6669

Definition at line 25 of file TcpClientConnector.cs.

Property Documentation

override ConnectionEndPoint Deveel.Data.Protocol.TcpClientConnector.LocalEndPoint

get

Definition at line 27 of file TcpClientConnector.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/TcpClientConnector.cs