diff options
Diffstat (limited to 'trunk/qpid/dotnet/client-010/client/transport/network/io/IoTransport.cs')
| -rw-r--r-- | trunk/qpid/dotnet/client-010/client/transport/network/io/IoTransport.cs | 141 |
1 files changed, 0 insertions, 141 deletions
diff --git a/trunk/qpid/dotnet/client-010/client/transport/network/io/IoTransport.cs b/trunk/qpid/dotnet/client-010/client/transport/network/io/IoTransport.cs deleted file mode 100644 index 483e5428b8..0000000000 --- a/trunk/qpid/dotnet/client-010/client/transport/network/io/IoTransport.cs +++ /dev/null @@ -1,141 +0,0 @@ -/* -* Licensed to the Apache Software Foundation (ASF) under one -* or more contributor license agreements. See the NOTICE file -* distributed with this work for additional information -* regarding copyright ownership. The ASF licenses this file -* to you under the Apache License, Version 2.0 (the -* "License"); you may not use this file except in compliance -* with the License. You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, -* software distributed under the License is distributed on an -* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -* KIND, either express or implied. See the License for the -* specific language governing permissions and limitations -* under the License. -*/ -using System; -using System.IO; -using System.Net.Sockets; -using org.apache.qpid.transport.util; - -namespace org.apache.qpid.transport.network.io -{ - /// <summary> - /// This class provides a socket based transport using sync io classes. - /// - /// The following params are configurable via JVM arguments - /// TCP_NO_DELAY - qpid.tcpNoDelay - /// SO_RCVBUF - qpid.readBufferSize - /// SO_SNDBUF - qpid.writeBufferSize - /// </summary> - public sealed class IoTransport : IIoTransport - { - // constants - private const int DEFAULT_READ_WRITE_BUFFER_SIZE = 64*1024; - private const int TIMEOUT = 60000; - private const int QUEUE_SIZE = 1000; - // props - private static readonly Logger log = Logger.Get(typeof (IoTransport)); - private Stream m_stream; - private IoSender m_sender; - private IReceiver<ReceivedPayload<MemoryStream>> m_receiver; - private TcpClient m_socket; - private Connection m_con; - - public static Connection Connect(String host, int port, ConnectionDelegate conndel) - { - IoTransport transport = new IoTransport(host, port, conndel); - return transport.Connection; - } - - public IoTransport(String host, int port, ConnectionDelegate conndel) - { - CreateSocket(host, port); - Sender = new IoSender(this, QUEUE_SIZE, TIMEOUT); - Receiver = new IoReceiver(Stream, Socket.ReceiveBufferSize * 2, TIMEOUT); - Assembler assembler = new Assembler(); - InputHandler inputHandler = new InputHandler(InputHandler.State.PROTO_HDR); - Connection = new Connection(assembler, new Disassembler(Sender, 64 * 1024 - 1), conndel); - // Input handler listen to Receiver events - Receiver.Received += inputHandler.On_ReceivedBuffer; - // Assembler listen to inputhandler events - inputHandler.ReceivedEvent += assembler.On_ReceivedEvent; - // Connection listen to asembler protocol event - Receiver.Closed += Connection.On_ReceivedClosed; - assembler.Closed += Connection.On_ReceivedClosed; - Receiver.Exception += Connection.On_ReceivedException; - inputHandler.ExceptionProcessing += Connection.On_ReceivedException; - assembler.ReceivedEvent += Connection.On_ReceivedEvent; - } - - public Connection Connection - { - get { return m_con; } - set { m_con = value; } - } - - public IReceiver<ReceivedPayload<MemoryStream>> Receiver - { - get { return m_receiver; } - set { m_receiver = value; } - } - - public IoSender Sender - { - get { return m_sender; } - set { m_sender = value; } - } - - - public Stream Stream - { - get { return m_stream; } - set { m_stream = value; } - } - - public TcpClient Socket - { - get { return m_socket; } - set { m_socket = value; } - } - - #region Private Support Functions - - private void CreateSocket(String host, int port) - { - try - { - TcpClient socket = new TcpClient(); - String noDelay = Environment.GetEnvironmentVariable("qpid.tcpNoDelay"); - String writeBufferSize = Environment.GetEnvironmentVariable("qpid.writeBufferSize"); - String readBufferSize = Environment.GetEnvironmentVariable("qpid.readBufferSize"); - socket.NoDelay = noDelay != null && bool.Parse(noDelay); - socket.ReceiveBufferSize = readBufferSize == null ? DEFAULT_READ_WRITE_BUFFER_SIZE : int.Parse(readBufferSize); - socket.SendBufferSize = writeBufferSize == null ? DEFAULT_READ_WRITE_BUFFER_SIZE : int.Parse(writeBufferSize); - - log.Debug("NoDelay : {0}", socket.NoDelay); - log.Debug("ReceiveBufferSize : {0}", socket.ReceiveBufferSize); - log.Debug("SendBufferSize : {0}", socket.SendBufferSize); - log.Debug("Openning connection with host : {0}; port: {1}", host, port); - - socket.Connect(host, port); - Socket = socket; - Stream = socket.GetStream(); - } - catch (SocketException e) - { - Console.WriteLine(e.StackTrace); - throw new TransportException("Error connecting to broker", e); - } - catch (IOException e) - { - throw new TransportException("Error connecting to broker", e); - } - } - - #endregion - } -}
\ No newline at end of file |