| // $Id$ |
| // |
| // 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.Collections.Generic; |
| using Org.Apache.Etch.Bindings.Csharp.Util; |
| using NUnit.Framework; |
| |
| namespace Org.Apache.Etch.Bindings.Csharp.Transport |
| { |
| [TestFixture] |
| public class TestPacketizer |
| { |
| private static MyPacketHandler mph ; |
| private static Packetizer p ; |
| private static MyDataHandler dh; |
| |
| [TestFixtureSetUp] |
| public void First() |
| { |
| Console.WriteLine(); |
| Console.Write( "TestPacketizer" ); |
| } |
| |
| public void SetUp() |
| { |
| dh = new MyDataHandler(); |
| p = new Packetizer(dh,"tcp:",null); |
| mph = new MyPacketHandler( p); |
| |
| |
| } |
| |
| public class DummyWho : Who |
| { |
| public DummyWho() |
| { |
| // do nothing |
| } |
| } |
| private Who whoDummy = new DummyWho(); |
| |
| [Test] |
| public void SendPacket() |
| { |
| SetUp(); |
| FlexBuffer buf = new FlexBuffer( new byte[] { 0, 0, 0, 0, 0, 0, 0, 0 } ); |
| |
| byte[][] result = ( FlexBuffer.littleEndian )? new byte[][] { new byte[] { 239, 190, 173, 222, 0, 0, 0, 0 }, } : |
| new byte[][] { new byte[] { 222, 173, 190, 239, 0, 0, 0, 0 }, }; |
| |
| // p.Packet( whoDummy, buf ); |
| p.TransportPacket(whoDummy,buf); |
| Assert.AreEqual( dh.what, What.DATA ); |
| Assert.IsTrue( dh.Check( result ) ); |
| Assert.IsNull( dh.xsender ); |
| Assert.IsNull( dh.xbuf ); |
| } |
| |
| [Test] |
| public void SendPacket1() |
| { |
| SetUp(); |
| // Create Packet to send |
| FlexBuffer buf = new FlexBuffer( new byte[] { 0, 0, 0, 0, 0, 0, 0, 0, 1 } ); |
| |
| byte[][] result = ( FlexBuffer.littleEndian ) ? new byte[][] { new byte[] { 239, 190, 173, 222, 1, 0, 0, 0, 1 }, } : |
| new byte[][] { new byte[] { 222, 173, 190, 239, 0, 0, 0, 1, 1 }, }; |
| |
| // p.Packet( null, buf ); |
| p.TransportPacket(null,buf); |
| Assert.AreEqual( dh.what, What.DATA ); |
| Assert.IsTrue( dh.Check( result ) ); |
| Assert.IsNull( dh.xsender ); |
| Assert.IsNull( dh.xbuf ); |
| } |
| |
| [Test] |
| public void SendPacket2() |
| { |
| SetUp(); |
| // Create Packet to send |
| FlexBuffer buf = new FlexBuffer (new byte[] { 0, 0, 0, 0, 0, 0, 0, 0, 2, 3 }); |
| byte[][] result = ( FlexBuffer.littleEndian ) ? new byte[][] { new byte[] { 239, 190, 173, 222, 2, 0, 0, 0, 2, 3 }, } : |
| new byte[][] { new byte[] { 222, 173, 190, 239, 0, 0, 0, 2, 2, 3 }, }; |
| |
| p.TransportPacket(null, buf); |
| Assert.AreEqual( dh.what, What.DATA ); |
| Assert.IsTrue(dh.Check(result)); |
| Assert.IsNull(dh.xsender); |
| Assert.IsNull(dh.xbuf); |
| } |
| |
| //////////////////////////////////////////////////////////// |
| // these tests are for a single Packet in a single buffer // |
| //////////////////////////////////////////////////////////// |
| |
| [Test] |
| public void SendSingleSingleData0() |
| { |
| SetUp(); |
| // Create Data to send |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 0, 0, 0, 0 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0, 0, 0 } ); |
| |
| byte[][] result = new byte[][] { }; |
| |
| p.SessionData(null, buf); |
| Assert.IsTrue(mph.Check(result)); |
| |
| Assert.IsNull(mph.what); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| } |
| |
| [Test] |
| public void SendSingleSingleData1() |
| { |
| SetUp(); |
| // length = 1 |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 1, 0, 0, 0, 1 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0, 0, 1, 1 } ); |
| |
| byte[][] result = new byte[][] { new byte[] { 1 }, }; |
| |
| p.SessionData(null, buf); |
| Assert.IsTrue(mph.Check(result)); |
| |
| Assert.AreEqual(mph.what, What.PACKET); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| } |
| |
| [Test] |
| public void SendSingleSingleData2() |
| { |
| SetUp(); |
| // length = 2 |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 2, 0, 0, 0, 3, 4 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0, 0, 2, 3, 4 } ); |
| |
| byte[][] result = new byte[][] { new byte[] { 3, 4 }, }; |
| |
| p.SessionData(null, buf); |
| Assert.IsTrue(mph.Check(result)); |
| |
| Assert.AreEqual(mph.what, What.PACKET); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| } |
| |
| //////////////////////////////////////////////////////// |
| // these tests are for two Packets in a single buffer // |
| //////////////////////////////////////////////////////// |
| |
| [Test] |
| public void SendDoubleSingleData0() |
| { |
| SetUp(); |
| // length = 0 |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 0, 0, 0, 0, 239, 190, 173, 222, 0, 0, 0, 0 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0, 0, 0, 222, 173, 190, 239, 0, 0, 0, 0 } ); |
| |
| byte[][] result = new byte[][] {}; |
| |
| p.SessionData(null, buf); |
| |
| Assert.IsTrue(mph.Check(result)); |
| Assert.IsNull(mph.what); |
| Assert.IsNull(mph.xbuf); |
| Assert.IsNull(mph.xsender); |
| } |
| |
| [Test] |
| public void SendDoubleSingleData1() |
| { |
| SetUp(); |
| // length = 1 |
| FlexBuffer buf = ( FlexBuffer.littleEndian )? new FlexBuffer( new byte[] { 239, 190, 173, 222, 1, 0, 0, 0, 1, 239, 190, 173, 222, 1, 0, 0, 0, 2 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0, 0, 1, 1, 222, 173, 190, 239, 0, 0, 0, 1, 2 } ); |
| |
| byte[][] result = new byte[][] { new byte[] { 1 }, new byte[] { 2 } }; |
| |
| p.SessionData(null, buf); |
| |
| Assert.IsTrue(mph.Check(result)); |
| Assert.AreEqual(mph.what, What.PACKET); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| } |
| |
| [Test] |
| public void SendDoubleSingleData2() |
| { |
| SetUp(); |
| // length = 2 |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 2, 0, 0, 0, 3, 4, 239, 190, 173, 222, 2, 0, 0, 0, 5, 6 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0, 0, 2, 3, 4, 222, 173, 190, 239, 0, 0, 0, 2, 5, 6 } ); |
| |
| byte[][] result = new byte[][] { new byte[] { 3, 4 }, new byte[] { 5, 6 } } ; |
| |
| p.SessionData(null, buf); |
| |
| Assert.IsTrue(mph.Check(result)); |
| Assert.AreEqual(mph.what, What.PACKET); |
| Assert.IsNull(mph.xbuf); |
| Assert.IsNull(mph.xsender); |
| } |
| |
| ////////////////////////////////////////////////////////////////////// |
| // these tests are for two Packets in two buffers with header split // |
| ////////////////////////////////////////////////////////////////////// |
| |
| [Test] |
| public void SendDoubleSingle_HeaderSplit_Data0() |
| { |
| SetUp(); |
| // length = 0 |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 0, 0 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0 } ); |
| byte[][] result = new byte[][] { } ; |
| |
| p.SessionData(null, buf); |
| |
| Assert.IsTrue(mph.Check(result)); |
| Assert.IsNull(mph.what); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| |
| FlexBuffer buf2 = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 0, 0, 239, 190, 173, 222, 0, 0, 0, 0 } ) : |
| new FlexBuffer( new byte[] { 0, 0, 222, 173, 190, 239, 0, 0, 0, 0 } ); |
| byte[][] result2 = new byte[][] {}; |
| |
| p.SessionData(null, buf2); |
| |
| Assert.IsTrue(mph.Check(result2)); |
| Assert.IsNull(mph.what); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| } |
| |
| [Test] |
| public void SendDoubleSingle_HeaderSplit_Data1() |
| { |
| SetUp(); |
| // length = 1 |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 1, 0 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0 } ); |
| byte[][] result = new byte[][] { } ; |
| |
| p.SessionData(null, buf); |
| |
| Assert.IsTrue(mph.Check(result)); |
| Assert.IsNull(mph.what); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| |
| FlexBuffer buf2 = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 0, 0, 1, 239, 190, 173, 222, 1, 0, 0, 0, 2 } ) : |
| new FlexBuffer( new byte[] { 0, 1, 1, 222, 173, 190, 239, 0, 0, 0, 1, 2 } ); |
| byte[][] result2 = new byte[][] {new byte[] { 1 }, new byte[] { 2 }}; |
| |
| p.SessionData(null, buf2); |
| |
| Assert.IsTrue(mph.Check(result2)); |
| Assert.AreEqual(mph.what, What.PACKET); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| } |
| |
| [Test] |
| public void sendDoubleSingle_HeaderSplit_Data2() |
| { |
| SetUp(); |
| // length = 2 |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 2, 0 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0 } ); |
| byte[][] result = new byte[][] { } ; |
| |
| p.SessionData(null, buf); |
| |
| Assert.IsTrue(mph.Check(result)); |
| Assert.IsNull(mph.what); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| |
| FlexBuffer buf2 = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 0, 0, 3, 4, 239, 190, 173, 222, 2, 0, 0, 0, 5, 6 } ) : |
| new FlexBuffer( new byte[] { 0, 2, 3, 4, 222, 173, 190, 239, 0, 0, 0, 2, 5, 6 } ); |
| |
| byte[][] result2 = new byte[][] { new byte[] { 3, 4 }, new byte[] { 5, 6 } }; |
| |
| p.SessionData(null, buf2); |
| |
| Assert.IsTrue(mph.Check(result2)); |
| Assert.AreEqual(mph.what, What.PACKET); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| } |
| |
| //////////////////////////////////////////////////////////////////// |
| // these tests are for two Packets in two buffers with body split // |
| //////////////////////////////////////////////////////////////////// |
| |
| [Test] |
| public void SendDoubleSingle_BodySplit_Data2() |
| { |
| SetUp(); |
| // length = 2 |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 2, 0, 0, 0, 1 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0, 0, 2, 1 } ); |
| |
| byte[][] result = new byte[][] { } ; |
| |
| p.SessionData(null, buf); |
| |
| Assert.IsTrue(mph.Check(result)); |
| Assert.IsNull(mph.what); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| |
| FlexBuffer buf2 = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 2, 239, 190, 173, 222, 2, 0, 0, 0, 3, 4 } ) : |
| new FlexBuffer( new byte[] { 2, 222, 173, 190, 239, 0, 0, 0, 2, 3, 4 } ); |
| |
| byte[][] result2 = new byte[][] { new byte[] { 1, 2 }, new byte[] { 3, 4 } }; |
| |
| p.SessionData(null, buf2); |
| |
| Assert.IsTrue(mph.Check(result2)); |
| Assert.AreEqual(mph.what, What.PACKET); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| } |
| |
| [Test] |
| public void SendDoubleSingle_BodySplit_Data3() |
| { |
| SetUp(); |
| // length = 3 |
| FlexBuffer buf = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 239, 190, 173, 222, 3, 0, 0, 0, 5, 6 } ) : |
| new FlexBuffer( new byte[] { 222, 173, 190, 239, 0, 0, 0, 3, 5, 6 } ); |
| |
| byte[][] result = new byte[][] { } ; |
| |
| p.SessionData(null, buf); |
| |
| Assert.IsTrue(mph.Check(result)); |
| Assert.IsNull(mph.what); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| |
| FlexBuffer buf2 = ( FlexBuffer.littleEndian ) ? new FlexBuffer( new byte[] { 7, 239, 190, 173, 222, 3, 0, 0, 0, 8, 9, 10 } ) : |
| new FlexBuffer( new byte[] { 7, 222, 173, 190, 239, 0, 0, 0, 3, 8, 9, 10 } ); |
| |
| byte[][] result2 = new byte[][] { new byte[] { 5, 6, 7 }, new byte[] { 8, 9, 10 } }; |
| |
| p.SessionData(null, buf2); |
| |
| Assert.IsTrue(mph.Check(result2)); |
| Assert.AreEqual(mph.what, What.PACKET); |
| Assert.IsNull(mph.xsender); |
| Assert.IsNull(mph.xbuf); |
| } |
| |
| [Test] |
| public void Up() |
| { |
| SetUp(); |
| p.SessionNotify( SessionConsts.UP ); |
| |
| Assert.AreEqual(mph.what, What.UP); |
| Assert.IsNull(mph.xbuf); |
| Assert.IsNull(mph.xsender); |
| } |
| |
| [Test] |
| public void Down() |
| { |
| SetUp(); |
| p.SessionNotify( SessionConsts.DOWN ); |
| |
| Assert.AreEqual(mph.what, What.DOWN); |
| Assert.IsNull(mph.xbuf); |
| Assert.IsNull(mph.xsender); |
| } |
| |
| [Test] |
| public void LocalAddress() |
| { |
| SetUp(); |
| p.TransportQuery( Connection<SessionData>.LOCAL_ADDRESS ); |
| |
| Assert.AreEqual(dh.what, What.LOCALADDRESS); |
| Assert.IsNull(dh.xsender); |
| Assert.IsNull(dh.xbuf); |
| } |
| |
| [Test] |
| public void RemoteAddress() |
| { |
| SetUp(); |
| p.TransportQuery( Connection<SessionData>.REMOTE_ADDRESS ); |
| |
| Assert.AreEqual(dh.what, What.REMOTEADDRESS); |
| Assert.IsNull(dh.xsender); |
| Assert.IsNull(dh.xbuf); |
| } |
| |
| [Test] |
| public void Stop() |
| { |
| SetUp(); |
| p.TransportControl( TransportConsts.STOP, null ); |
| |
| Assert.AreEqual(dh.what, What.STOP); |
| Assert.IsNull(dh.xsender); |
| Assert.IsNull(dh.xbuf); |
| } |
| |
| public enum What { DATA, PACKET, UP, DOWN, RESET, LOCALADDRESS, REMOTEADDRESS, |
| STOP, STARTED, STOPPED, EXCEPTION }; |
| |
| |
| // This is like messagizer handling packets |
| public class MyPacketHandler : SessionPacket |
| { |
| public Enum what; |
| public Who xsender; |
| public FlexBuffer xbuf; |
| public Who xrecipient; |
| public TransportPacket _tp; |
| |
| public MyPacketHandler() |
| { |
| // nothing to do. |
| } |
| |
| public MyPacketHandler( TransportPacket tp ) |
| { |
| _tp = tp; |
| _tp.SetSession(this); |
| } |
| |
| private List<byte[]> list = new List<byte[]>(); |
| |
| // Auxiliary methods |
| |
| public void Clear() |
| { |
| list.Clear(); |
| } |
| |
| public bool Check( byte[][] result ) |
| { |
| bool flag = Check( list.Count == result.Length ); |
| if ( flag == false ) |
| return flag; |
| |
| for ( int i = 0; i < list.Count; i++ ) |
| { |
| flag = Check( list[i], result[i] ); |
| if ( flag == false ) |
| return flag; |
| } |
| return true; |
| } |
| |
| private bool Check( byte[] a, byte[] b ) |
| { |
| bool flag = Check( a.Length == b.Length ); |
| if ( flag == false ) |
| return flag; |
| |
| for ( int i = 0; i < a.Length; i++ ) |
| { |
| flag = Check( a[ i ] == b[ i ] ); |
| if ( flag == false ) |
| return flag; |
| } |
| return true; |
| } |
| |
| private bool Check( bool ok ) |
| { |
| return ok; |
| } |
| |
| public void tp_print() |
| { |
| foreach ( byte b in list[0] ) |
| Console.WriteLine(b); |
| } |
| |
| // PacketHandler methods |
| |
| /// <summary> |
| /// |
| /// </summary> |
| /// <param name="src"></param> |
| /// <param name="sender"></param> |
| /// <param name="buf"></param> |
| /// Exception: |
| /// |
| public void Packet( Who sender, FlexBuffer buf ) |
| { |
| what = What.PACKET; |
| xsender = sender; |
| list.Add(buf.GetAvailBytes()); |
| } |
| |
| // DataSource methods |
| |
| /// <summary> |
| /// |
| /// </summary> |
| /// <param name="recipient"></param> |
| /// <param name="buf"></param> |
| /// Exception: |
| /// |
| public void Data( Who recipient, FlexBuffer buf ) |
| { |
| |
| what = What.DATA; |
| this.xrecipient = recipient; |
| list.Add( buf.GetAvailBytes() ); |
| } |
| |
| |
| |
| #region Session Members |
| |
| public object SessionQuery( object query ) |
| { |
| throw new Exception( "unsupported query " + query ); |
| } |
| |
| public void SessionControl( object control, object value ) |
| { |
| throw new Exception( " unsupported control " + control ); |
| } |
| |
| public void SessionNotify( object eventObj ) |
| { |
| if ( eventObj.Equals( SessionConsts.UP ) ) |
| { |
| what = What.UP; |
| return; |
| } |
| if ( eventObj.Equals( SessionConsts.DOWN ) ) |
| { |
| what = What.DOWN; |
| return; |
| } |
| } |
| |
| #endregion |
| |
| |
| |
| #region SessionPacket Members |
| |
| public void SessionPacket(Who sender, FlexBuffer buf) |
| { |
| what = What.PACKET; |
| xsender = sender; |
| list.Add(buf.GetAvailBytes()); |
| } |
| |
| #endregion |
| |
| |
| } |
| |
| public class MyDataHandler : TransportData |
| { |
| public Enum what; |
| public Who xsender; |
| public FlexBuffer xbuf; |
| public Who xrecipient; |
| private List<byte[]> list = new List<byte[]>(); |
| |
| private SessionData session; |
| public MyDataHandler() |
| { |
| |
| } |
| |
| #region TransportData Members |
| |
| public void TransportData(Who recipient, FlexBuffer buf) |
| { |
| what = What.DATA; |
| this.xrecipient = recipient; |
| list.Add(buf.GetAvailBytes()); |
| } |
| |
| #endregion |
| |
| #region Transport<SessionData> Members |
| |
| public object TransportQuery(object query) |
| { |
| if (query.Equals(Connection<SessionData>.LOCAL_ADDRESS)) |
| { |
| what = What.LOCALADDRESS; |
| return null; |
| } |
| if (query.Equals(Connection<SessionData>.REMOTE_ADDRESS)) |
| { |
| what = What.REMOTEADDRESS; |
| return null; |
| } |
| throw new Exception(" unsupported query " + query); |
| } |
| |
| public void TransportControl(object control, object value) |
| { |
| if (control.Equals(TransportConsts.STOP)) |
| { |
| what = What.STOP; |
| return; |
| } |
| throw new Exception(" unsupported control " + control); |
| } |
| |
| public void TransportNotify(object eventObj) |
| { |
| |
| } |
| |
| public void SetSession(SessionData session) |
| { |
| this.session = session; |
| } |
| |
| public SessionData GetSession() |
| { |
| return session; |
| } |
| |
| #endregion |
| |
| // Auxiliary methods |
| |
| public void Clear() |
| { |
| list.Clear(); |
| } |
| |
| public bool Check(byte[][] result) |
| { |
| bool flag = Check(list.Count == result.Length); |
| if (flag == false) |
| return flag; |
| |
| for (int i = 0; i < list.Count; i++) |
| { |
| flag = Check(list[i], result[i]); |
| if (flag == false) |
| return flag; |
| } |
| return true; |
| } |
| |
| private bool Check(byte[] a, byte[] b) |
| { |
| bool flag = Check(a.Length == b.Length); |
| if (flag == false) |
| return flag; |
| |
| for (int i = 0; i < a.Length; i++) |
| { |
| flag = Check(a[i] == b[i]); |
| if (flag == false) |
| return flag; |
| } |
| return true; |
| } |
| |
| private bool Check(bool ok) |
| { |
| return ok; |
| } |
| } |
| |
| } |
| } |
