diff options
author | fcolin | 2007-02-01 12:03:55 +0000 |
---|---|---|
committer | fcolin | 2007-02-01 12:03:55 +0000 |
commit | 98ab5d0164040427f7c554febae125686284e2a7 (patch) | |
tree | a6ab9c20fbf1172553d364c91447149e4dc72ab0 /Ivy/IvyPPC/IvyUDPStream.cs | |
parent | 531dfa4389ba34a0d32eed0ba8c82839e437d992 (diff) | |
download | ivy-csharp-98ab5d0164040427f7c554febae125686284e2a7.zip ivy-csharp-98ab5d0164040427f7c554febae125686284e2a7.tar.gz ivy-csharp-98ab5d0164040427f7c554febae125686284e2a7.tar.bz2 ivy-csharp-98ab5d0164040427f7c554febae125686284e2a7.tar.xz |
modification structure svn
Diffstat (limited to 'Ivy/IvyPPC/IvyUDPStream.cs')
-rw-r--r-- | Ivy/IvyPPC/IvyUDPStream.cs | 66 |
1 files changed, 0 insertions, 66 deletions
diff --git a/Ivy/IvyPPC/IvyUDPStream.cs b/Ivy/IvyPPC/IvyUDPStream.cs deleted file mode 100644 index 0e3f517..0000000 --- a/Ivy/IvyPPC/IvyUDPStream.cs +++ /dev/null @@ -1,66 +0,0 @@ -using System;
-using System.Collections.Generic;
-using System.Text;
-using System.Net;
-using System.Net.Sockets;
-using System.IO;
-
-namespace IvyBus
-{
- abstract class IvyUDPStream
- {
- Socket socket;
- byte[] buffer;
-
- protected MemoryStream out_stream;
- protected MemoryStream in_stream;
-
- ushort protocol_version;
-
- public ushort ProtocolVersion
- {
- get { return protocol_version; }
- }
-
- public IvyUDPStream(Socket _socket, ushort protocol)
- {
- socket = _socket;
- buffer = new byte[4096];
- in_stream = new MemoryStream(buffer);
- out_stream = new MemoryStream();
- protocol_version = protocol;
- }
- internal void Close()
- {
- in_stream.Close();
- out_stream.Close();
- socket.Shutdown(SocketShutdown.Both);
- socket.Close();
- }
- internal void receiveMsg(out IPEndPoint remote, out ushort version, out ushort port, out string appId, out string appName)
- {
- int len;
- IPEndPoint remoteEP = new IPEndPoint(IPAddress.Any, 0);
- EndPoint tempRemoteEP = (EndPoint)remoteEP;
- remoteEP = null;
- len = socket.ReceiveFrom(buffer, ref tempRemoteEP);
- remote = (IPEndPoint)tempRemoteEP;
- in_stream.Position = 0;
- in_stream.SetLength(len);
- in_stream.Seek(0, SeekOrigin.Begin);
- //Call Deserialization
- Deserialize( out version, out port, out appId, out appName );
- }
- internal void sendMsg(IPEndPoint EPhost, ushort port, string appId, string appName)
- {
- // Call Serialisation
- Serialize(port, appId, appName);
-
- byte[] hellob = out_stream.GetBuffer();
- socket.SendTo(hellob, (int)out_stream.Length, 0, EPhost);
- }
- abstract internal void Serialize(ushort port, string appId, string appName);
- abstract internal void Deserialize(out ushort version, out ushort port, out string appId, out string appName);
-
- }
-}
|