using System;
using Base;

namespace Model
{
	public class BenchmarkComponent: Component
	{
		private int k;

		private long time1 = TimeHelper.ClientNow();

		public async void TestAsync(NetOuterComponent networkComponent, string address, int j)
		{
			try
			{
				using (Session session = networkComponent.Create(address))
				{
					int i = 0;
					while (i < 10000000)
					{
						++i;
						await session.Call<C2R_Ping, R2C_Ping>(new C2R_Ping());

						++this.k;

						if (this.k % 100000 != 0)
						{
							continue;
						}

						long time2 = TimeHelper.ClientNow();
						long time = time2 - this.time1;
						this.time1 = time2;
						Log.Info($"{j} Benchmark k: {this.k} 每10W次耗时: {time} ms");
					}
				}
			}
			catch (RpcException e)
			{
				Log.Error(e.ToString());
			}
			catch (Exception e)
			{
				Log.Error(e.ToString());
			}
		}

		public override void Dispose()
		{
			if (this.Id == 0)
			{
				return;
			}

			base.Dispose();
		}
	}
}