109 lines
2.1 KiB
C#
109 lines
2.1 KiB
C#
using System;
|
|
using System.Runtime.Serialization;
|
|
using System.Runtime.Serialization.Formatters.Binary;
|
|
using System.Net.Sockets;
|
|
using System.IO;
|
|
|
|
//using Util;
|
|
|
|
namespace lib
|
|
{
|
|
|
|
|
|
|
|
public class Conn
|
|
{
|
|
public Socket Sock { get { return m_socket; } }
|
|
public Stream Stream { get { return m_streamNet; } }
|
|
public IFormatter Formatter { get { return m_formatter; } }
|
|
|
|
|
|
public Conn( Socket sock, IFormatter formatter )
|
|
{
|
|
m_socket = sock;
|
|
|
|
//sock.DontFragment = true;
|
|
sock.NoDelay = true;
|
|
|
|
m_streamNet = new NetworkStream( m_socket );
|
|
//m_streamBufIn = new BufferedStream( m_streamNet );
|
|
|
|
m_formatter = formatter;
|
|
//m_formatter = new VersionFormatter();
|
|
|
|
//mm_memStream = new MemoryStream( mm_buffer );
|
|
|
|
|
|
}
|
|
|
|
public object recieveObject()
|
|
{
|
|
return recieveObject( Stream );
|
|
}
|
|
|
|
public object recieveObject( Stream stream )
|
|
{
|
|
object obj = null;
|
|
lock( this )
|
|
{
|
|
try
|
|
{
|
|
obj = m_formatter.Deserialize( stream );
|
|
}
|
|
catch( System.Xml.XmlException e )
|
|
{
|
|
lib.Log.error( "Outer Exception {0}", e.ToString() );
|
|
//lib.Log.error( "Inner Exception {0}", e.InnerException.ToString() );
|
|
}
|
|
}
|
|
|
|
return obj;
|
|
}
|
|
|
|
public void send( object obj )
|
|
{
|
|
lock( this )
|
|
{
|
|
try
|
|
{
|
|
var ms = new MemoryStream( 1024 );
|
|
m_formatter.Serialize( ms, obj );
|
|
|
|
//var str = System.Text.Encoding.Default.GetString( mm_buffer, 0, (int)ms.Position );
|
|
//lib.Log.info( "Sent data {0} of length {1}", str, ms.Position );
|
|
lib.Log.info( "Sent {0}", obj );
|
|
|
|
byte[] byteSize = BitConverter.GetBytes( (uint)ms.Position );
|
|
m_streamNet.Write( byteSize, 0, 4 );
|
|
m_streamNet.Write( ms.GetBuffer(), 0, (int)ms.Position );
|
|
|
|
m_streamNet.Flush();
|
|
}
|
|
catch( Exception e )
|
|
{
|
|
lib.Log.warn( "Exception sending obj {0} of {1}", obj, e );
|
|
//m_streamNet.Close();
|
|
//m_socket.Close();
|
|
}
|
|
}
|
|
}
|
|
|
|
public virtual void recieve( object obj )
|
|
{
|
|
//Log.log.msg( "Recieved " + obj.ToString() );
|
|
}
|
|
|
|
private Socket m_socket;
|
|
|
|
private NetworkStream m_streamNet;
|
|
//private BufferedStream m_streamBufIn;
|
|
//private BufferedStream m_streamBufOut;
|
|
|
|
private IFormatter m_formatter;
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|