using System;
using System.Collections.Generic;
using System.Threading;

namespace ExitGames.Client.Photon.Voice
{
	// Token: 0x02000577 RID: 1399
	public class OOJKABJBEIK<T> : GDDKAGGNCPO
	{
		// Token: 0x17000616 RID: 1558
		// (get) Token: 0x0600DCC9 RID: 56521 RVA: 0x0041D9F0 File Offset: 0x0041BBF0
		public bool FJMKPOGLEEJ
		{
			get
			{
				object aiagohhjkcf = this.AIAGOHHJKCF;
				bool flag;
				lock (aiagohhjkcf)
				{
					flag = this.AIAGOHHJKCF.Count < 49;
				}
				return flag;
			}
		}

		// Token: 0x0600DCCA RID: 56522 RVA: 0x0041DA38 File Offset: 0x0041BC38
		public override void Dispose()
		{
			if (!this.FFJBMBNBGJO)
			{
				this.OAJKIHIHIOP.Dispose();
				foreach (OOJKABJBEIK<T>.JIPMDGHLOMM jipmdghlomm in this.DCKCCNDMBLA)
				{
					jipmdghlomm.Dispose();
				}
				base.Dispose();
				this.FDKFAMPGHMA.Set();
			}
		}

		// Token: 0x0600DCCB RID: 56523 RVA: 0x0041DAC0 File Offset: 0x0041BCC0
		private void IKEAGIJLJJI()
		{
			try
			{
				for (;;)
				{
					this.FDKFAMPGHMA.WaitOne();
					if (this.FFJBMBNBGJO)
					{
						break;
					}
					for (;;)
					{
						T[] array = null;
						object aiagohhjkcf = this.AIAGOHHJKCF;
						lock (aiagohhjkcf)
						{
							if (this.AIAGOHHJKCF.Count > 0)
							{
								array = this.AIAGOHHJKCF.Dequeue();
							}
						}
						if (array == null)
						{
							break;
						}
						this.LEJFGDBOEHA(array);
						this.OAJKIHIHIOP.Release(array);
					}
				}
			}
			catch (Exception ex)
			{
				this.MIGHPCEJCFN.OKPJGBOCPIG.FKCFJOALLPB(base.MBADGNJPALF + ": Exception in encode thread: " + ex, new object[0]);
				throw ex;
			}
			finally
			{
				this.OAJKIHIHIOP.Dispose();
				this.FDKFAMPGHMA.Close();
				this.MIGHPCEJCFN.OKPJGBOCPIG.FAFGKCMJJKE(base.MBADGNJPALF + ": Exiting data encode thread", new object[0]);
			}
		}

		// Token: 0x0600DCCC RID: 56524 RVA: 0x0041DBE8 File Offset: 0x0041BDE8
		private void IEGECFKKJFK()
		{
			try
			{
				for (;;)
				{
					this.FDKFAMPGHMA.WaitOne();
					if (this.FFJBMBNBGJO)
					{
						break;
					}
					for (;;)
					{
						T[] array = null;
						object aiagohhjkcf = this.AIAGOHHJKCF;
						lock (aiagohhjkcf)
						{
							if (this.AIAGOHHJKCF.Count > 1)
							{
								array = this.AIAGOHHJKCF.Dequeue();
							}
						}
						if (array == null)
						{
							break;
						}
						this.LEJFGDBOEHA(array);
						this.OAJKIHIHIOP.Release(array);
					}
				}
			}
			catch (Exception ex)
			{
				this.MIGHPCEJCFN.OKPJGBOCPIG.FKCFJOALLPB(base.MBADGNJPALF + "TEAM WARZONE" + ex, new object[1]);
				throw ex;
			}
			finally
			{
				this.OAJKIHIHIOP.Dispose();
				this.FDKFAMPGHMA.Close();
				this.MIGHPCEJCFN.OKPJGBOCPIG.FAFGKCMJJKE(base.MBADGNJPALF + "F2", new object[1]);
			}
		}

		// Token: 0x0600DCCD RID: 56525 RVA: 0x0041DD10 File Offset: 0x0041BF10
		public void NEIJLFDGDFA(params OOJKABJBEIK<T>.JIPMDGHLOMM[] DCKCCNDMBLA)
		{
			foreach (OOJKABJBEIK<T>.JIPMDGHLOMM jipmdghlomm in DCKCCNDMBLA)
			{
				this.DCKCCNDMBLA.Insert(this.PPOIEDMLFOK++, jipmdghlomm);
			}
		}

		// Token: 0x0600DCCE RID: 56526 RVA: 0x0041DD54 File Offset: 0x0041BF54
		internal OOJKABJBEIK(HPIHEBBIDEI MIGHPCEJCFN, DHLLBCHHGML HPOHHDNDONL, byte HPCOKMAPCHB, HHACJANOPEN PBMJNABELNH, int FJHIEKCGNBB, int JEFHDMHEMAH)
			: base(MIGHPCEJCFN, HPOHHDNDONL, HPCOKMAPCHB, PBMJNABELNH, FJHIEKCGNBB)
		{
			this.GJDEKOFHJOE = JEFHDMHEMAH;
			this.LGPCFOFCOFH = new BMJKMEMIOPE<T>(this.GJDEKOFHJOE);
			this.OAJKIHIHIOP = new DNKIENDMPAC<T>(50, base.GDIECAFDIMC + " Data");
			this.OAJKIHIHIOP.GBKFKKGNLGF(this.GJDEKOFHJOE);
		}

		// Token: 0x0600DCCF RID: 56527 RVA: 0x0041DDD8 File Offset: 0x0041BFD8
		public int OJMCCLMAGJH()
		{
			return this.<DMIOCMBAJGO>k__BackingField;
		}

		// Token: 0x0600DCD0 RID: 56528 RVA: 0x0041DDE0 File Offset: 0x0041BFE0
		public void JMBPMHOBMNH()
		{
			this.DCKCCNDMBLA.Clear();
			this.PPOIEDMLFOK = 0;
		}

		// Token: 0x0600DCD1 RID: 56529 RVA: 0x0041DDF4 File Offset: 0x0041BFF4
		public virtual void IPOFBLDMIAG()
		{
			if (!this.FFJBMBNBGJO)
			{
				this.OAJKIHIHIOP.Dispose();
				foreach (OOJKABJBEIK<T>.JIPMDGHLOMM jipmdghlomm in this.DCKCCNDMBLA)
				{
					jipmdghlomm.Dispose();
				}
				base.Dispose();
				this.FDKFAMPGHMA.Set();
			}
		}

		// Token: 0x0600DCD2 RID: 56530 RVA: 0x0041DE7C File Offset: 0x0041C07C
		private void NOBEMKGAEPH(int NOBAPCOKFIL)
		{
			this.<DMIOCMBAJGO>k__BackingField = NOBAPCOKFIL;
		}

		// Token: 0x0600DCD3 RID: 56531 RVA: 0x0041DE88 File Offset: 0x0041C088
		private void DFHCCMEPILI()
		{
			try
			{
				for (;;)
				{
					this.FDKFAMPGHMA.WaitOne();
					if (this.FFJBMBNBGJO)
					{
						break;
					}
					for (;;)
					{
						T[] array = null;
						object aiagohhjkcf = this.AIAGOHHJKCF;
						lock (aiagohhjkcf)
						{
							if (this.AIAGOHHJKCF.Count > 0)
							{
								array = this.AIAGOHHJKCF.Dequeue();
							}
						}
						if (array == null)
						{
							break;
						}
						this.LEJFGDBOEHA(array);
						this.OAJKIHIHIOP.Release(array);
					}
				}
			}
			catch (Exception ex)
			{
				this.MIGHPCEJCFN.OKPJGBOCPIG.FKCFJOALLPB(base.MBADGNJPALF + "Bad CRC32 in GZIP trailer. (actual({0:X8})!=expected({1:X8}))" + ex, new object[0]);
				throw ex;
			}
			finally
			{
				this.OAJKIHIHIOP.Dispose();
				this.FDKFAMPGHMA.Close();
				this.MIGHPCEJCFN.OKPJGBOCPIG.FAFGKCMJJKE(base.MBADGNJPALF + "{0}v1/report", new object[0]);
			}
		}

		// Token: 0x0600DCD4 RID: 56532 RVA: 0x0041DFB0 File Offset: 0x0041C1B0
		public void GDDJBECGMLJ(params OOJKABJBEIK<T>.JIPMDGHLOMM[] DCKCCNDMBLA)
		{
			foreach (OOJKABJBEIK<T>.JIPMDGHLOMM jipmdghlomm in DCKCCNDMBLA)
			{
				this.DCKCCNDMBLA.Add(jipmdghlomm);
			}
		}

		// Token: 0x17000614 RID: 1556
		// (get) Token: 0x0600DCD5 RID: 56533 RVA: 0x0041DFE4 File Offset: 0x0041C1E4
		// (set) Token: 0x0600DCD7 RID: 56535 RVA: 0x0041DFF4 File Offset: 0x0041C1F4
		public int GJDEKOFHJOE { get; private set; }

		// Token: 0x0600DCD6 RID: 56534 RVA: 0x0041DFEC File Offset: 0x0041C1EC
		public int FKPNCPDBBFA()
		{
			return this.<DMIOCMBAJGO>k__BackingField;
		}

		// Token: 0x0600DCD8 RID: 56536 RVA: 0x0041E000 File Offset: 0x0041C200
		public void EKBEKAIMEED()
		{
			this.DCKCCNDMBLA.Clear();
			this.PPOIEDMLFOK = 0;
		}

		// Token: 0x0600DCD9 RID: 56537 RVA: 0x0041E014 File Offset: 0x0041C214
		private void MAAHAJJGBOM()
		{
			try
			{
				for (;;)
				{
					this.FDKFAMPGHMA.WaitOne();
					if (this.FFJBMBNBGJO)
					{
						break;
					}
					for (;;)
					{
						T[] array = null;
						object aiagohhjkcf = this.AIAGOHHJKCF;
						lock (aiagohhjkcf)
						{
							if (this.AIAGOHHJKCF.Count > 1)
							{
								array = this.AIAGOHHJKCF.Dequeue();
							}
						}
						if (array == null)
						{
							break;
						}
						this.LEJFGDBOEHA(array);
						this.OAJKIHIHIOP.Release(array);
					}
				}
			}
			catch (Exception ex)
			{
				this.MIGHPCEJCFN.OKPJGBOCPIG.FKCFJOALLPB(base.MBADGNJPALF + "/Resources" + ex, new object[0]);
				throw ex;
			}
			finally
			{
				this.OAJKIHIHIOP.Dispose();
				this.FDKFAMPGHMA.Close();
				this.MIGHPCEJCFN.OKPJGBOCPIG.FAFGKCMJJKE(base.MBADGNJPALF + "photon_pings", new object[0]);
			}
		}

		// Token: 0x0600DCDA RID: 56538 RVA: 0x0041E13C File Offset: 0x0041C33C
		public int LKCHBMGOCBO()
		{
			return this.<DMIOCMBAJGO>k__BackingField;
		}

		// Token: 0x0600DCDB RID: 56539 RVA: 0x0041E144 File Offset: 0x0041C344
		public void HHPJHAPDBNA(T[] OBKBOLEFCNO)
		{
			if (this.FFJBMBNBGJO)
			{
				return;
			}
			if (!this.NIOLLOBJHKK)
			{
				this.MIGHPCEJCFN.OKPJGBOCPIG.FAFGKCMJJKE(base.MBADGNJPALF + ": Starting data encode thread", new object[0]);
				Thread thread = new Thread(new ThreadStart(this.IKEAGIJLJJI));
				thread.Start();
				thread.Name = base.MBADGNJPALF + " data encode";
				this.NIOLLOBJHKK = true;
			}
			if (this.FJMKPOGLEEJ)
			{
				object aiagohhjkcf = this.AIAGOHHJKCF;
				lock (aiagohhjkcf)
				{
					this.AIAGOHHJKCF.Enqueue(OBKBOLEFCNO);
				}
				this.FDKFAMPGHMA.Set();
			}
			else
			{
				this.OAJKIHIHIOP.Release(OBKBOLEFCNO);
			}
		}

		// Token: 0x0600DCDC RID: 56540 RVA: 0x0041E224 File Offset: 0x0041C424
		public virtual void NDJCFIJCFEG()
		{
			if (!this.FFJBMBNBGJO)
			{
				this.OAJKIHIHIOP.Dispose();
				foreach (OOJKABJBEIK<T>.JIPMDGHLOMM jipmdghlomm in this.DCKCCNDMBLA)
				{
					jipmdghlomm.Dispose();
				}
				base.Dispose();
				this.FDKFAMPGHMA.Set();
			}
		}

		// Token: 0x0600DCDD RID: 56541 RVA: 0x0041E2AC File Offset: 0x0041C4AC
		public bool BCHIEOBJDOF()
		{
			object aiagohhjkcf = this.AIAGOHHJKCF;
			bool flag;
			lock (aiagohhjkcf)
			{
				flag = this.AIAGOHHJKCF.Count < -2;
			}
			return flag;
		}

		// Token: 0x0600DCDE RID: 56542 RVA: 0x0041E2F4 File Offset: 0x0041C4F4
		public int FKPIHMLCPFE()
		{
			return this.<DMIOCMBAJGO>k__BackingField;
		}

		// Token: 0x0600DCDF RID: 56543 RVA: 0x0041E2FC File Offset: 0x0041C4FC
		public void MFKNFDOCCDN()
		{
			this.DCKCCNDMBLA.Clear();
			this.PPOIEDMLFOK = 0;
		}

		// Token: 0x0600DCE0 RID: 56544 RVA: 0x0041E310 File Offset: 0x0041C510
		public void LEJFGDBOEHA(T[] OBKBOLEFCNO)
		{
			if (this.MIGHPCEJCFN.OKPJGBOCPIG.ONNNCKDJKAI(this.FJHIEKCGNBB) && base.ACHJBEJKAPA)
			{
				if (!(this.HPOHHDNDONL is HNAPNNHDFJL<T>))
				{
					throw new Exception(base.MBADGNJPALF + ": PushData(T[]) called on encoder of unsupported type " + ((this.HPOHHDNDONL != null) ? this.HPOHHDNDONL.GetType().ToString() : "null"));
				}
				foreach (T[] array in this.LGPCFOFCOFH.DNHCGCDCEGD(OBKBOLEFCNO))
				{
					T[] array2 = this.AJOOHMLBPHF(array);
					if (array2 != null)
					{
						base.OLLNFPCODLH(((HNAPNNHDFJL<T>)this.HPOHHDNDONL).BBCMHOFOOFC(array2));
					}
				}
			}
		}

		// Token: 0x0600DCE1 RID: 56545 RVA: 0x0041E404 File Offset: 0x0041C604
		private void KMCJFPKLOLP(int NOBAPCOKFIL)
		{
			this.<DMIOCMBAJGO>k__BackingField = NOBAPCOKFIL;
		}

		// Token: 0x0600DCE2 RID: 56546 RVA: 0x0041E410 File Offset: 0x0041C610
		internal T[] AJOOHMLBPHF(T[] OBKBOLEFCNO)
		{
			foreach (OOJKABJBEIK<T>.JIPMDGHLOMM jipmdghlomm in this.DCKCCNDMBLA)
			{
				OBKBOLEFCNO = jipmdghlomm.BIGHBAOJNEO(OBKBOLEFCNO);
				if (OBKBOLEFCNO == null)
				{
					break;
				}
			}
			return OBKBOLEFCNO;
		}

		// Token: 0x0600DCE3 RID: 56547 RVA: 0x0041E47C File Offset: 0x0041C67C
		private void KMJKCJMKMGA(int NOBAPCOKFIL)
		{
			this.<DMIOCMBAJGO>k__BackingField = NOBAPCOKFIL;
		}

		// Token: 0x0600DCE4 RID: 56548 RVA: 0x0041E488 File Offset: 0x0041C688
		public int DPHJFPLINMH()
		{
			return this.<DMIOCMBAJGO>k__BackingField;
		}

		// Token: 0x0600DCE5 RID: 56549 RVA: 0x0041E490 File Offset: 0x0041C690
		public int LFBJPLDAPCD()
		{
			return this.<DMIOCMBAJGO>k__BackingField;
		}

		// Token: 0x0600DCE6 RID: 56550 RVA: 0x0041E498 File Offset: 0x0041C698
		public virtual void HNDIPAANELO()
		{
			if (!this.FFJBMBNBGJO)
			{
				this.OAJKIHIHIOP.Dispose();
				foreach (OOJKABJBEIK<T>.JIPMDGHLOMM jipmdghlomm in this.DCKCCNDMBLA)
				{
					jipmdghlomm.Dispose();
				}
				base.Dispose();
				this.FDKFAMPGHMA.Set();
			}
		}

		// Token: 0x0600DCE7 RID: 56551 RVA: 0x0041E520 File Offset: 0x0041C720
		public void BMPHJEHKHMK()
		{
			this.DCKCCNDMBLA.Clear();
			this.PPOIEDMLFOK = 1;
		}

		// Token: 0x17000615 RID: 1557
		// (get) Token: 0x0600DCE8 RID: 56552 RVA: 0x0041E534 File Offset: 0x0041C734
		public DNKIENDMPAC<T> KMBDNLIFGFH
		{
			get
			{
				return this.OAJKIHIHIOP;
			}
		}

		// Token: 0x0600DCE9 RID: 56553 RVA: 0x0041E53C File Offset: 0x0041C73C
		public void CENLDFLPOKB()
		{
			this.DCKCCNDMBLA.Clear();
			this.PPOIEDMLFOK = 1;
		}

		// Token: 0x0400203F RID: 8255
		private BMJKMEMIOPE<T> LGPCFOFCOFH;

		// Token: 0x04002041 RID: 8257
		private int PPOIEDMLFOK;

		// Token: 0x04002042 RID: 8258
		private List<OOJKABJBEIK<T>.JIPMDGHLOMM> DCKCCNDMBLA = new List<OOJKABJBEIK<T>.JIPMDGHLOMM>();

		// Token: 0x04002043 RID: 8259
		private bool NIOLLOBJHKK;

		// Token: 0x04002044 RID: 8260
		private Queue<T[]> AIAGOHHJKCF = new Queue<T[]>();

		// Token: 0x04002045 RID: 8261
		private AutoResetEvent FDKFAMPGHMA = new AutoResetEvent(false);

		// Token: 0x04002046 RID: 8262
		private DNKIENDMPAC<T> OAJKIHIHIOP;

		// Token: 0x02000578 RID: 1400
		public interface JIPMDGHLOMM : IDisposable
		{
			// Token: 0x0600DCEA RID: 56554
			T[] BIGHBAOJNEO(T[] OBKBOLEFCNO);
		}
	}
}