niko
503 lines
12 KiB
C#
503 lines
12 KiB
C#
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);
|
|
}
|
|
}
|
|
}
|