davejansen/lidgren-network-gen3
1
0
Fork 0
mirror of https://github.com/lidgren/lidgren-network-gen3.git synced 2026-05-14 14:16:30 +09:00
Code Issues Releases Activity

SpeedSample added

Browse Source
This commit is contained in:
lidgren
2010-11-03 13:18:23 +00:00
parent 47579ba32f
commit e1d1913d15
21 changed files with 1679 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

184
Samples/LibraryTestSamples/SpeedSample/SpeedClient/Program.cs Normal file
View File

@@ -0,0 +1,184 @@
using System;
using System.Collections.Generic;
using System.Windows.Forms;
using SamplesCommon;
using Lidgren.Network;
using System.Threading;
namespace SpeedTestClient
{
static class Program
{
private static NetClient s_client;
private static Form1 s_form;
private static NetPeerSettingsWindow s_settingsWindow;
private static NetDeliveryMethod s_method;
private static int s_sequenceChannel;
private static long s_sentBytes;
private static float s_lastUpdatedTitle;
private const float s_titleUpdateInterval = 0.75f;
private static long[] s_nextSendNumber = new long[256];
private const float s_sendInterval = 0.1f;
[STAThread]
static void Main()
{
Application.EnableVisualStyles();
Application.SetCompatibleTextRenderingDefault(false);
s_form = new Form1();
NetPeerConfiguration config = new NetPeerConfiguration("speedtest");
s_client = new NetClient(config);
Application.Idle += new EventHandler(Application_Idle);
Application.Run(s_form);
}
private static void Output(string text)
{
NativeMethods.AppendText(s_form.richTextBox1, text);
}
private static void Application_Idle(object sender, EventArgs e)
{
while (NativeMethods.AppStillIdle)
{
NetIncomingMessage im;
while ((im = s_client.ReadMessage()) != null)
{
// handle incoming message
switch (im.MessageType)
{
case NetIncomingMessageType.DebugMessage:
case NetIncomingMessageType.ErrorMessage:
case NetIncomingMessageType.WarningMessage:
case NetIncomingMessageType.VerboseDebugMessage:
string text = im.ReadString();
Output(text);
break;
case NetIncomingMessageType.StatusChanged:
NetConnectionStatus status = (NetConnectionStatus)im.ReadByte();
string reason = im.ReadString();
Output(status.ToString() + ": " + reason);
s_form.Text = "Speed test client: " + status.ToString();
break;
case NetIncomingMessageType.Data:
//string chat = im.ReadString();
//Output(chat);
break;
default:
Output("Unhandled type: " + im.MessageType);
break;
}
}
float now = (float)NetTime.Now;
if (now > s_lastUpdatedTitle + s_titleUpdateInterval)
{
s_form.Text = "Speed test client: " + (s_client.ServerConnection != null ? s_client.ServerConnection.Status.ToString() : "(no connection)") + " " + NetUtility.ToHumanReadable(s_sentBytes) + " bytes sent";
s_lastUpdatedTitle = now;
}
if (s_client.ServerConnection != null && s_client.ServerConnection.Status == NetConnectionStatus.Connected)
{
//
// Saturate the line
//
int windowSize, freeWindowSlots;
s_client.ServerConnection.GetSendQueueInfo(s_method, s_sequenceChannel, out windowSize, out freeWindowSlots);
// queue up to double window size
if (windowSize == 0)
freeWindowSlots = 1;
int num = 0;
while(freeWindowSlots > -windowSize)
{
// send random data
int size = s_client.Configuration.MaximumTransmissionUnit - 30;
NetOutgoingMessage om = s_client.CreateMessage(size);
byte[] tmp = new byte[size];
NetRandom.Instance.NextBytes(tmp);
int slot = (int)s_method + s_sequenceChannel;
om.Write(s_nextSendNumber[slot]);
s_nextSendNumber[slot]++;
om.Write(tmp);
// queue message for sending
NetSendResult res = s_client.SendMessage(om, s_method, s_sequenceChannel);
if (s_method != NetDeliveryMethod.Unreliable && s_method != NetDeliveryMethod.UnreliableSequenced)
{
if (res != NetSendResult.Queued && res != NetSendResult.Sent)
throw new NetException("Got res " + res);
}
s_sentBytes += size;
freeWindowSlots--;
num++;
}
//Console.WriteLine("Queued " + num + " messages");
//
// Send every X millisecond
//
/*
if (now > s_lastSend + s_sendInterval)
{
// send random data
int size = s_client.Configuration.MaximumTransmissionUnit - 25;
NetOutgoingMessage om = s_client.CreateMessage(size);
byte[] tmp = new byte[size];
NetRandom.Instance.NextBytes(tmp);
int slot = (int)s_method + s_sequenceChannel;
om.Write(s_nextSendNumber[slot]);
s_nextSendNumber[slot]++;
om.Write(tmp);
// queue message for sending
NetSendResult res = s_client.SendMessage(om, s_method, s_sequenceChannel);
if (res != NetSendResult.Queued && res != NetSendResult.Sent)
throw new NetException("Got res " + res);
//Console.WriteLine("Res: " + res);
s_sentBytes += size;
s_lastSend = now;
}
*/
}
Thread.Sleep(0);
}
}
// called by the UI
internal static void Connect(string host, int port, string deliveryMethod, int sequenceChannel)
{
s_client.Start();
s_method = (NetDeliveryMethod)Enum.Parse(typeof(NetDeliveryMethod), deliveryMethod);
s_sequenceChannel = sequenceChannel;
s_client.Connect(host, port);
}
// called by the UI
public static void DisplaySettings()
{
if (s_settingsWindow != null && s_settingsWindow.Visible)
{
s_settingsWindow.Hide();
}
else
{
if (s_settingsWindow == null || s_settingsWindow.IsDisposed)
s_settingsWindow = new NetPeerSettingsWindow("Speed test client settings", s_client);
s_settingsWindow.Show();
}
}
}
}