summaryrefslogtreecommitdiff
path: root/Ivy/IvyUDPStreamV3.cs
diff options
context:
space:
mode:
authorfcolin2008-08-22 16:44:01 +0000
committerfcolin2008-08-22 16:44:01 +0000
commit8d10e8bbd1e19adc7c70e1101dbb69c213c910dd (patch)
treef41034ab66b1b3174277b07c8aa45791dadbaae8 /Ivy/IvyUDPStreamV3.cs
parent7053d3d604920ab708076e107be4b55666c5af80 (diff)
downloadivy-csharp-8d10e8bbd1e19adc7c70e1101dbb69c213c910dd.zip
ivy-csharp-8d10e8bbd1e19adc7c70e1101dbb69c213c910dd.tar.gz
ivy-csharp-8d10e8bbd1e19adc7c70e1101dbb69c213c910dd.tar.bz2
ivy-csharp-8d10e8bbd1e19adc7c70e1101dbb69c213c910dd.tar.xz
optimisation for parsing same regular expression from multiple client
using fxCop for code beauty fix bug on concurrent connect
Diffstat (limited to 'Ivy/IvyUDPStreamV3.cs')
-rw-r--r--Ivy/IvyUDPStreamV3.cs29
1 files changed, 15 insertions, 14 deletions
diff --git a/Ivy/IvyUDPStreamV3.cs b/Ivy/IvyUDPStreamV3.cs
index 8f48f3b..a47ad3f 100644
--- a/Ivy/IvyUDPStreamV3.cs
+++ b/Ivy/IvyUDPStreamV3.cs
@@ -1,12 +1,13 @@
-using System;
-using System.Collections.Generic;
-using System.Text;
-using System.Net;
-using System.Net.Sockets;
-using System.IO;
namespace IvyBus
{
+ using System;
+ using System.Collections.Generic;
+ using System.Text;
+ using System.Net;
+ using System.Net.Sockets;
+ using System.IO;
+
class IvyUDPStreamV3 : IvyUDPStream
{
StreamReader input;
@@ -27,7 +28,7 @@ namespace IvyBus
* message Format:
protocol_version, TCP server port , appId, appName
*/
- private ushort DeserializeShort()
+ private int DeserializeInt()
{
int read;
ushort ret = 0;
@@ -63,15 +64,15 @@ namespace IvyBus
return str.ToString();
}
- internal override void Deserialize(out ushort version, out ushort port, out string appId, out string appName)
+ internal override void Deserialize(out int version, out int port, out string appId, out string appName)
{
version = 0;
port = 0;
- appId = "";
- appName = "";
+ appId = string.Empty;
+ appName = string.Empty;
try {
- version = DeserializeShort();
- port = DeserializeShort();
+ version = DeserializeInt();
+ port = DeserializeInt();
//Optionel in V3 protocol depend on client version
appId = DeserializeString(' ');
appName = DeserializeString('\n');
@@ -82,7 +83,7 @@ namespace IvyBus
}
input.DiscardBufferedData();
}
- private void Serialize(ushort arg, char sep)
+ private void Serialize(int arg, char sep)
{
output.Write(arg);
output.Write(sep);
@@ -92,7 +93,7 @@ namespace IvyBus
output.Write(arg);
output.Write(sep);
}
- internal override void Serialize(ushort port, string appId, string appName)
+ internal override void Serialize(int port, string appId, string appName)
{
Serialize(PROCOCOLVERSION, ' ');
Serialize(port,' ');