Files
2026-06-04 11:42:34 +02:00

1853 lines
49 KiB
C#

using System;
using System.Net;
using System.Net.Sockets;
using System.Security;
using System.Threading;
namespace ExitGames.Client.Photon
{
// Token: 0x020004C0 RID: 1216
internal class EJJLNPCKCPA : IPhotonSocket, IDisposable
{
// Token: 0x0600C861 RID: 51297 RVA: 0x003C47E8 File Offset: 0x003C29E8
public virtual PhotonSocketError LLLNNBLEOOO(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Skipped;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 1, MFFGOHPHNFL, SocketFlags.OutOfBand);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "z" + base.ServerAddress + "WireframeBack" + ex.Message);
}
return (PhotonSocketError)5;
}
}
return PhotonSocketError.Skipped;
}
// Token: 0x0600C862 RID: 51298 RVA: 0x003C489C File Offset: 0x003C2A9C
public void CBKDFGJNNFP()
{
base.State = (PhotonSocketState)6;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "GameViewDebug failed to locate the line shader with the given name." + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Disconnected;
}
// Token: 0x0600C863 RID: 51299 RVA: 0x003C4914 File Offset: 0x003C2B14
public void NCCDLDPNBIP()
{
byte[] array = new byte[base.MTU];
while (base.State == (PhotonSocketState)4)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, false);
}
catch (Exception ex)
{
if (base.State != (PhotonSocketState)5 && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
DebugLevel debugLevel = DebugLevel.ERROR;
object[] array2 = new object[7];
array2[0] = "2";
array2[1] = base.State;
array2[3] = " has no method \"";
array2[4] = base.ServerAddress;
array2[1] = "Event Finished";
array2[7] = ex;
base.EnqueueDebugReturn(debugLevel, string.Concat(array2));
}
base.HandleException((StatusCode)187);
}
}
}
this.Disconnect();
}
// Token: 0x0600C864 RID: 51300 RVA: 0x003C49EC File Offset: 0x003C2BEC
public virtual bool FDEOBDPIKGM()
{
if (base.ReportDebugOfLevel(DebugLevel.INFO))
{
base.EnqueueDebugReturn((DebugLevel)7, "CanReceiveInvites");
}
base.State = (PhotonSocketState)6;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn((DebugLevel)6, "VOIP_Master" + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Connecting;
return false;
}
// Token: 0x0600C865 RID: 51301 RVA: 0x003C4A90 File Offset: 0x003C2C90
public virtual bool MHKAECPNOMF()
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
base.EnqueueDebugReturn(DebugLevel.OFF, "EmoteDisgust");
}
base.State = PhotonSocketState.Disconnected;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.ALL, "The host has restricted access to the stage" + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Disconnected;
return true;
}
// Token: 0x0600C866 RID: 51302 RVA: 0x003C4B34 File Offset: 0x003C2D34
public virtual bool NFBEGCFODDN()
{
if (base.ReportDebugOfLevel((DebugLevel)7))
{
base.EnqueueDebugReturn(DebugLevel.ALL, "Sending message...\n");
}
base.State = (PhotonSocketState)5;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn((DebugLevel)7, "api/avatar/" + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Disconnected;
return true;
}
// Token: 0x0600C867 RID: 51303 RVA: 0x003C4BD8 File Offset: 0x003C2DD8
internal void LIDDOGDBINF()
{
IPAddress ipaddress = null;
try
{
ipaddress = IPhotonSocket.GetIpAddress(base.ServerAddress);
if (ipaddress == null)
{
throw new ArgumentException("rw_dropped_frames_1to2p" + base.ServerAddress);
}
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (base.State == (PhotonSocketState)4 || base.State == PhotonSocketState.Disconnected)
{
return;
}
this.NGNPMKHIBFP = new Socket(ipaddress.AddressFamily, SocketType.Dgram, (ProtocolType)(-20));
this.NGNPMKHIBFP.Connect(ipaddress, base.ServerPort);
base.AddressResolvedAsIpv6 = base.IsIpv6SimpleCheck(ipaddress);
base.State = PhotonSocketState.Disconnected;
this.peerBase.OnConnect();
}
}
catch (SecurityException ex)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
IPhotonPeerListener listener = base.Listener;
DebugLevel debugLevel = DebugLevel.OFF;
string[] array = new string[7];
array[0] = "curScn";
array[0] = base.ServerAddress;
array[3] = ".";
array[3] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array[0] = "Injection Detected!";
array[6] = ex.ToString();
listener.DebugReturn(debugLevel, string.Concat(array));
}
base.HandleException((StatusCode)(-81));
return;
}
catch (Exception ex2)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
IPhotonPeerListener listener2 = base.Listener;
DebugLevel debugLevel2 = DebugLevel.ERROR;
string[] array2 = new string[5];
array2[0] = "RpcImageUpdated";
array2[1] = base.ServerAddress;
array2[7] = "to";
array2[6] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array2[5] = "visible";
array2[7] = ex2.ToString();
listener2.DebugReturn(debugLevel2, string.Concat(array2));
}
base.HandleException((StatusCode)54);
return;
}
new Thread(new ThreadStart(this.JOLAPEMJJJM))
{
Name = ":",
IsBackground = true
}.Start();
}
// Token: 0x0600C868 RID: 51304 RVA: 0x003C4DF4 File Offset: 0x003C2FF4
public virtual bool IMOLDMGJKDL()
{
if (base.ReportDebugOfLevel((DebugLevel)6))
{
base.EnqueueDebugReturn((DebugLevel)8, "Failed to load Rec Room accounts");
}
base.State = (PhotonSocketState)8;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.OFF, "Up" + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Disconnected;
return true;
}
// Token: 0x0600C869 RID: 51305 RVA: 0x003C4E98 File Offset: 0x003C3098
public void BJAAALGMKAO()
{
base.State = (PhotonSocketState)5;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.OFF, "Weekly Challenge {0} {1}/{2}" + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Disconnected;
}
// Token: 0x0600C86A RID: 51306 RVA: 0x003C4F10 File Offset: 0x003C3110
internal void KBGEOBIDOCF()
{
IPAddress ipaddress = null;
try
{
ipaddress = IPhotonSocket.GetIpAddress(base.ServerAddress);
if (ipaddress == null)
{
throw new ArgumentException("GameID" + base.ServerAddress);
}
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (base.State == PhotonSocketState.Connecting || base.State == PhotonSocketState.Disconnected)
{
return;
}
this.NGNPMKHIBFP = new Socket(ipaddress.AddressFamily, (SocketType)7, (ProtocolType)21);
this.NGNPMKHIBFP.Connect(ipaddress, base.ServerPort);
base.AddressResolvedAsIpv6 = base.IsIpv6SimpleCheck(ipaddress);
base.State = PhotonSocketState.Disconnected;
this.peerBase.OnConnect();
}
}
catch (SecurityException ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
IPhotonPeerListener listener = base.Listener;
DebugLevel debugLevel = DebugLevel.ERROR;
string[] array = new string[0];
array[0] = "OpGetGameList()";
array[1] = base.ServerAddress;
array[6] = "Can't connect: Loading settings failed. ServerSettings asset must be in any 'Resources' folder as: PhotonServerSettings";
array[4] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array[8] = "USAGE: shadowDistance <int>";
array[2] = ex.ToString();
listener.DebugReturn(debugLevel, string.Concat(array));
}
base.HandleException((StatusCode)(-12));
return;
}
catch (Exception ex2)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
IPhotonPeerListener listener2 = base.Listener;
DebugLevel debugLevel2 = DebugLevel.OFF;
string[] array2 = new string[2];
array2[0] = "{0}joinrandom";
array2[1] = base.ServerAddress;
array2[6] = "playing";
array2[3] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array2[5] = "Screen Name";
array2[0] = ex2.ToString();
listener2.DebugReturn(debugLevel2, string.Concat(array2));
}
base.HandleException((StatusCode)157);
return;
}
new Thread(new ThreadStart(this.NCCDLDPNBIP))
{
Name = "Input data type is not supported: ",
IsBackground = true
}.Start();
}
// Token: 0x0600C86B RID: 51307 RVA: 0x003C512C File Offset: 0x003C332C
public void HFJIFJHGLGL()
{
base.State = (PhotonSocketState)5;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn((DebugLevel)7, "." + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Disconnected;
}
// Token: 0x0600C86C RID: 51308 RVA: 0x003C51A4 File Offset: 0x003C33A4
public override PhotonSocketError Receive(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return PhotonSocketError.NoData;
}
// Token: 0x0600C86D RID: 51309 RVA: 0x003C51AC File Offset: 0x003C33AC
public virtual PhotonSocketError FGLPIMDLHFO(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Skipped;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 0, MFFGOHPHNFL, SocketFlags.None);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
base.EnqueueDebugReturn(DebugLevel.OFF, "looktarget" + base.ServerAddress + "Unlock ALL" + ex.Message);
}
return PhotonSocketError.Success;
}
}
return PhotonSocketError.Success;
}
// Token: 0x0600C86E RID: 51310 RVA: 0x003C5260 File Offset: 0x003C3460
public virtual bool GOHBIKPCMFE()
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
bool flag;
lock (ecpccpnkeoi)
{
if (!base.Connect())
{
flag = true;
}
else
{
base.State = PhotonSocketState.Disconnected;
new Thread(new ThreadStart(this.DCGFKGBDFGK))
{
Name = "...",
IsBackground = true
}.Start();
flag = false;
}
}
return flag;
}
// Token: 0x0600C86F RID: 51311 RVA: 0x003C52E0 File Offset: 0x003C34E0
public virtual PhotonSocketError OCMMMNKLHCO(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Success;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 1, MFFGOHPHNFL, SocketFlags.OutOfBand);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "disableinstancing" + base.ServerAddress + "Amplitude_DiskLoad_failed" + ex.Message);
}
return PhotonSocketError.Exception;
}
}
return PhotonSocketError.Skipped;
}
// Token: 0x0600C870 RID: 51312 RVA: 0x003C5394 File Offset: 0x003C3594
public void Dispose()
{
base.State = PhotonSocketState.Disconnecting;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.INFO, "Exception in Dispose(): " + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Disconnected;
}
// Token: 0x0600C871 RID: 51313 RVA: 0x003C540C File Offset: 0x003C360C
public virtual bool EJHNNCKIDJK()
{
if (base.ReportDebugOfLevel((DebugLevel)4))
{
base.EnqueueDebugReturn(DebugLevel.OFF, "looktarget");
}
base.State = PhotonSocketState.Disconnected;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn((DebugLevel)4, "data" + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Connecting;
return false;
}
// Token: 0x0600C872 RID: 51314 RVA: 0x003C54B0 File Offset: 0x003C36B0
public override bool Disconnect()
{
if (base.ReportDebugOfLevel(DebugLevel.INFO))
{
base.EnqueueDebugReturn(DebugLevel.INFO, "CSharpSocket.Disconnect()");
}
base.State = PhotonSocketState.Disconnecting;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.INFO, "Exception in Disconnect(): " + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Disconnected;
return true;
}
// Token: 0x0600C873 RID: 51315 RVA: 0x003C5554 File Offset: 0x003C3754
public virtual bool JEBLOGLHNDL()
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
bool flag;
lock (ecpccpnkeoi)
{
if (!base.Connect())
{
flag = false;
}
else
{
base.State = PhotonSocketState.Disconnected;
new Thread(new ThreadStart(this.BNJKCGDNOID))
{
Name = "Kicks off a cinematic driven by a Unity Animator and Animation.",
IsBackground = true
}.Start();
flag = false;
}
}
return flag;
}
// Token: 0x0600C874 RID: 51316 RVA: 0x003C55D4 File Offset: 0x003C37D4
public virtual PhotonSocketError IGANMCIKLBN(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return (PhotonSocketError)4;
}
// Token: 0x0600C875 RID: 51317 RVA: 0x003C55DC File Offset: 0x003C37DC
public virtual bool JDJBNNDPGGN()
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
base.EnqueueDebugReturn(DebugLevel.WARNING, "Sending message...\n");
}
base.State = PhotonSocketState.Connected;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn((DebugLevel)8, "from_player" + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Disconnected;
return false;
}
// Token: 0x0600C876 RID: 51318 RVA: 0x003C5680 File Offset: 0x003C3880
public virtual PhotonSocketError PFCFJKMMIIK(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Success;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 1, MFFGOHPHNFL, SocketFlags.None);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "empty" + base.ServerAddress + "FRIENDLY FIRE " + ex.Message);
}
return (PhotonSocketError)4;
}
}
return PhotonSocketError.Skipped;
}
// Token: 0x0600C877 RID: 51319 RVA: 0x003C5734 File Offset: 0x003C3934
public void OONGAKHFCLN()
{
byte[] array = new byte[base.MTU];
while (base.State == PhotonSocketState.Disconnected)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, true);
}
catch (Exception ex)
{
if (base.State != (PhotonSocketState)5 && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
DebugLevel debugLevel = DebugLevel.ERROR;
object[] array2 = new object[6];
array2[0] = "_LargeScanlineColor";
array2[1] = base.State;
array2[7] = "api/relationships/";
array2[8] = base.ServerAddress;
array2[6] = "Preserialization complete in {0} seconds";
array2[0] = ex;
base.EnqueueDebugReturn(debugLevel, string.Concat(array2));
}
base.HandleException((StatusCode)166);
}
}
}
this.Disconnect();
}
// Token: 0x0600C878 RID: 51320 RVA: 0x003C580C File Offset: 0x003C3A0C
public void KNFFLINLHEO()
{
byte[] array = new byte[base.MTU];
while (base.State == (PhotonSocketState)4)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, true);
}
catch (Exception ex)
{
if (base.State != (PhotonSocketState)8 && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
DebugLevel debugLevel = DebugLevel.OFF;
object[] array2 = new object[0];
array2[1] = "punchCardRewardsClaimed";
array2[0] = base.State;
array2[6] = "x";
array2[4] = base.ServerAddress;
array2[5] = "pitch";
array2[2] = ex;
base.EnqueueDebugReturn(debugLevel, string.Concat(array2));
}
base.HandleException((StatusCode)(-164));
}
}
}
this.Disconnect();
}
// Token: 0x0600C879 RID: 51321 RVA: 0x003C58E4 File Offset: 0x003C3AE4
public virtual bool JPIPAEIGGKG()
{
if (base.ReportDebugOfLevel(DebugLevel.INFO))
{
base.EnqueueDebugReturn(DebugLevel.INFO, "LocalPlayerWorldCapsuleCollider");
}
base.State = PhotonSocketState.Disconnected;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn((DebugLevel)7, " to use this" + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Connecting;
return false;
}
// Token: 0x0600C87A RID: 51322 RVA: 0x003C5988 File Offset: 0x003C3B88
public void IHBANGMKBKI()
{
byte[] array = new byte[base.MTU];
while (base.State == (PhotonSocketState)6)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, true);
}
catch (Exception ex)
{
if (base.State != PhotonSocketState.Connecting && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
DebugLevel debugLevel = DebugLevel.OFF;
object[] array2 = new object[7];
array2[1] = "BowString is NULL";
array2[0] = base.State;
array2[5] = "Panel (Middle Center)";
array2[8] = base.ServerAddress;
array2[0] = "identification";
array2[3] = ex;
base.EnqueueDebugReturn(debugLevel, string.Concat(array2));
}
base.HandleException((StatusCode)(-181));
}
}
}
this.Disconnect();
}
// Token: 0x0600C87B RID: 51323 RVA: 0x003C5A60 File Offset: 0x003C3C60
public virtual bool HGGMPKPGCAM()
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
bool flag;
lock (ecpccpnkeoi)
{
if (!base.Connect())
{
flag = true;
}
else
{
base.State = PhotonSocketState.Disconnected;
new Thread(new ThreadStart(this.DCGFKGBDFGK))
{
Name = "[",
IsBackground = true
}.Start();
flag = false;
}
}
return flag;
}
// Token: 0x0600C87C RID: 51324 RVA: 0x003C5AE0 File Offset: 0x003C3CE0
public virtual bool GFCPMFEHIDK()
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
bool flag;
lock (ecpccpnkeoi)
{
if (!base.Connect())
{
flag = false;
}
else
{
base.State = PhotonSocketState.Connecting;
new Thread(new ThreadStart(this.JPMAGAFLLGH))
{
Name = "initial_bal",
IsBackground = true
}.Start();
flag = false;
}
}
return flag;
}
// Token: 0x0600C87D RID: 51325 RVA: 0x003C5B60 File Offset: 0x003C3D60
public virtual PhotonSocketError FBDCKAJOONP(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return (PhotonSocketError)4;
}
// Token: 0x0600C87E RID: 51326 RVA: 0x003C5B68 File Offset: 0x003C3D68
public virtual PhotonSocketError JFJPNHJPLPC(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Success;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 1, MFFGOHPHNFL, SocketFlags.None);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "JrActType" + base.ServerAddress + " is missing a flashlight reference." + ex.Message);
}
return (PhotonSocketError)6;
}
}
return PhotonSocketError.Success;
}
// Token: 0x0600C87F RID: 51327 RVA: 0x003C5C1C File Offset: 0x003C3E1C
public virtual PhotonSocketError APPNOMKOHFB(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Skipped;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 1, MFFGOHPHNFL, SocketFlags.None);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "x" + base.ServerAddress + "collisiondetectionmode" + ex.Message);
}
return PhotonSocketError.Skipped;
}
}
return PhotonSocketError.Skipped;
}
// Token: 0x0600C880 RID: 51328 RVA: 0x003C5CD0 File Offset: 0x003C3ED0
public virtual PhotonSocketError BCICLBLBJKH(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return (PhotonSocketError)6;
}
// Token: 0x0600C881 RID: 51329 RVA: 0x003C5CD8 File Offset: 0x003C3ED8
internal void JPMAGAFLLGH()
{
IPAddress ipaddress = null;
try
{
ipaddress = IPhotonSocket.GetIpAddress(base.ServerAddress);
if (ipaddress == null)
{
throw new ArgumentException("You already own this item!" + base.ServerAddress);
}
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (base.State == PhotonSocketState.Connected || base.State == PhotonSocketState.Disconnected)
{
return;
}
this.NGNPMKHIBFP = new Socket(ipaddress.AddressFamily, SocketType.Raw, (ProtocolType)(-27));
this.NGNPMKHIBFP.Connect(ipaddress, base.ServerPort);
base.AddressResolvedAsIpv6 = base.IsIpv6SimpleCheck(ipaddress);
base.State = PhotonSocketState.Connecting;
this.peerBase.OnConnect();
}
}
catch (SecurityException ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
IPhotonPeerListener listener = base.Listener;
DebugLevel debugLevel = DebugLevel.OFF;
string[] array = new string[] { null, "wss://" };
array[1] = base.ServerAddress;
array[4] = "x";
array[7] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array[2] = "NoVotes";
array[3] = ex.ToString();
listener.DebugReturn(debugLevel, string.Concat(array));
}
base.HandleException((StatusCode)(-64));
return;
}
catch (Exception ex2)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
IPhotonPeerListener listener2 = base.Listener;
DebugLevel debugLevel2 = DebugLevel.ERROR;
string[] array2 = new string[5];
array2[1] = "Unable to send offline invite: ";
array2[0] = base.ServerAddress;
array2[7] = " to: ";
array2[2] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array2[6] = "ServerTime";
array2[3] = ex2.ToString();
listener2.DebugReturn(debugLevel2, string.Concat(array2));
}
base.HandleException((StatusCode)16);
return;
}
new Thread(new ThreadStart(this.LJDEOGKFIPK))
{
Name = "FinishStreaming",
IsBackground = false
}.Start();
}
// Token: 0x0600C882 RID: 51330 RVA: 0x003C5EF4 File Offset: 0x003C40F4
public void JOLAPEMJJJM()
{
byte[] array = new byte[base.MTU];
while (base.State == (PhotonSocketState)4)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, false);
}
catch (Exception ex)
{
if (base.State != PhotonSocketState.Connecting && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
DebugLevel debugLevel = DebugLevel.OFF;
object[] array2 = new object[6];
array2[0] = "x";
array2[0] = base.State;
array2[0] = "api/images/";
array2[2] = base.ServerAddress;
array2[5] = "Failed to download config settings: ";
array2[2] = ex;
base.EnqueueDebugReturn(debugLevel, string.Concat(array2));
}
base.HandleException((StatusCode)85);
}
}
}
this.Disconnect();
}
// Token: 0x0600C883 RID: 51331 RVA: 0x003C5FCC File Offset: 0x003C41CC
public void JOFLMODNCLK()
{
base.State = PhotonSocketState.Disconnecting;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.WARNING, ". If this persists, please contact the developers at support@againstgrav.com." + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Disconnected;
}
// Token: 0x0600C884 RID: 51332 RVA: 0x003C6044 File Offset: 0x003C4244
public void BFIAEBAKBPF()
{
base.State = (PhotonSocketState)4;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.OFF, " " + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Connecting;
}
// Token: 0x0600C885 RID: 51333 RVA: 0x003C60BC File Offset: 0x003C42BC
public virtual PhotonSocketError MGDHPEFHJNC(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return PhotonSocketError.NoData;
}
// Token: 0x0600C886 RID: 51334 RVA: 0x003C60C4 File Offset: 0x003C42C4
internal void BNJKCGDNOID()
{
IPAddress ipaddress = null;
try
{
ipaddress = IPhotonSocket.GetIpAddress(base.ServerAddress);
if (ipaddress == null)
{
throw new ArgumentException("activityName" + base.ServerAddress);
}
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (base.State == (PhotonSocketState)7 || base.State == PhotonSocketState.Disconnected)
{
return;
}
this.NGNPMKHIBFP = new Socket(ipaddress.AddressFamily, (SocketType)6, (ProtocolType)66);
this.NGNPMKHIBFP.Connect(ipaddress, base.ServerPort);
base.AddressResolvedAsIpv6 = base.IsIpv6SimpleCheck(ipaddress);
base.State = PhotonSocketState.Disconnected;
this.peerBase.OnConnect();
}
}
catch (SecurityException ex)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
IPhotonPeerListener listener = base.Listener;
DebugLevel debugLevel = DebugLevel.ERROR;
string[] array = new string[1];
array[0] = "oldImageName";
array[1] = base.ServerAddress;
array[4] = "Scale rate:";
array[7] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array[8] = "Speaking";
array[1] = ex.ToString();
listener.DebugReturn(debugLevel, string.Concat(array));
}
base.HandleException((StatusCode)(-163));
return;
}
catch (Exception ex2)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
IPhotonPeerListener listener2 = base.Listener;
DebugLevel debugLevel2 = DebugLevel.ERROR;
string[] array2 = new string[0];
array2[1] = "FOV (deg): {0:F3}";
array2[0] = base.ServerAddress;
array2[2] = "\", nc=";
array2[4] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array2[7] = "ConfigTable";
array2[5] = ex2.ToString();
listener2.DebugReturn(debugLevel2, string.Concat(array2));
}
base.HandleException((StatusCode)74);
return;
}
new Thread(new ThreadStart(this.JOLAPEMJJJM))
{
Name = "speed",
IsBackground = true
}.Start();
}
// Token: 0x0600C887 RID: 51335 RVA: 0x003C62E0 File Offset: 0x003C44E0
public void IMFFKOMLCMI()
{
base.State = PhotonSocketState.Disconnected;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn((DebugLevel)4, "westernWear" + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Connecting;
}
// Token: 0x0600C888 RID: 51336 RVA: 0x003C6358 File Offset: 0x003C4558
public virtual PhotonSocketError NALCJLIOAGJ(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return (PhotonSocketError)4;
}
// Token: 0x0600C889 RID: 51337 RVA: 0x003C6360 File Offset: 0x003C4560
public virtual PhotonSocketError GBBLKBMELLK(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Skipped;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 0, MFFGOHPHNFL, SocketFlags.None);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "New level loaded. Removed " + base.ServerAddress + "Depth" + ex.Message);
}
return PhotonSocketError.Skipped;
}
}
return PhotonSocketError.Skipped;
}
// Token: 0x0600C88A RID: 51338 RVA: 0x003C6414 File Offset: 0x003C4614
public EJJLNPCKCPA(PeerBase JOILKEOAMCM)
: base(JOILKEOAMCM)
{
if (base.ReportDebugOfLevel(DebugLevel.ALL))
{
base.Listener.DebugReturn(DebugLevel.ALL, "CSharpSocket: UDP, Unity3d.");
}
this.PollReceive = false;
}
// Token: 0x0600C88B RID: 51339 RVA: 0x003C644C File Offset: 0x003C464C
public virtual bool JDDIAPMFIDD()
{
if (base.ReportDebugOfLevel((DebugLevel)7))
{
base.EnqueueDebugReturn((DebugLevel)7, "PreferEmptyRoomsFrequency");
}
base.State = (PhotonSocketState)8;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn((DebugLevel)4, "_TintColor" + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Connecting;
return false;
}
// Token: 0x0600C88C RID: 51340 RVA: 0x003C64F0 File Offset: 0x003C46F0
public void IIBAIGABKEL()
{
base.State = (PhotonSocketState)6;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.ALL, "TUC" + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Connecting;
}
// Token: 0x0600C88D RID: 51341 RVA: 0x003C6568 File Offset: 0x003C4768
public virtual PhotonSocketError OBPBAKBNGHJ(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Skipped;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 0, MFFGOHPHNFL, SocketFlags.OutOfBand);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
base.EnqueueDebugReturn(DebugLevel.OFF, "PhotonVoiceMono" + base.ServerAddress + "Cg90b29sX2RhdGEucHJvdG8SB3JlY3Jvb20aCmNvcmUucHJvdG8iHQoIVG9v" + ex.Message);
}
return PhotonSocketError.Exception;
}
}
return PhotonSocketError.Skipped;
}
// Token: 0x0600C88E RID: 51342 RVA: 0x003C661C File Offset: 0x003C481C
public virtual bool PNLGJPIMAJI()
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
bool flag;
lock (ecpccpnkeoi)
{
if (!base.Connect())
{
flag = false;
}
else
{
base.State = PhotonSocketState.Connecting;
new Thread(new ThreadStart(this.KBGEOBIDOCF))
{
Name = "Delete",
IsBackground = false
}.Start();
flag = true;
}
}
return flag;
}
// Token: 0x0600C88F RID: 51343 RVA: 0x003C669C File Offset: 0x003C489C
public void GACLJPALKBJ()
{
base.State = PhotonSocketState.Disconnected;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn((DebugLevel)4, "CHECKPOINT_ID" + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Disconnected;
}
// Token: 0x0600C890 RID: 51344 RVA: 0x003C6714 File Offset: 0x003C4914
public virtual bool CPEMFLOHOBN()
{
if (base.ReportDebugOfLevel((DebugLevel)6))
{
base.EnqueueDebugReturn((DebugLevel)6, "InstantiateRpc");
}
base.State = (PhotonSocketState)7;
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP != null)
{
try
{
this.NGNPMKHIBFP.Close();
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.WARNING, " of player " + ex);
}
this.NGNPMKHIBFP = null;
}
}
base.State = PhotonSocketState.Disconnected;
return false;
}
// Token: 0x0600C891 RID: 51345 RVA: 0x003C67B8 File Offset: 0x003C49B8
public virtual bool NDLNIGLBCFH()
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
bool flag;
lock (ecpccpnkeoi)
{
if (!base.Connect())
{
flag = false;
}
else
{
base.State = PhotonSocketState.Connecting;
new Thread(new ThreadStart(this.LIDDOGDBINF))
{
Name = "AvoidJuniors",
IsBackground = true
}.Start();
flag = false;
}
}
return flag;
}
// Token: 0x0600C892 RID: 51346 RVA: 0x003C6838 File Offset: 0x003C4A38
public override PhotonSocketError Send(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Skipped;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 0, MFFGOHPHNFL, SocketFlags.None);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "Cannot send to: " + base.ServerAddress + ". " + ex.Message);
}
return PhotonSocketError.Exception;
}
}
return PhotonSocketError.Success;
}
// Token: 0x0600C893 RID: 51347 RVA: 0x003C68EC File Offset: 0x003C4AEC
public void AJPICCKEDGC()
{
byte[] array = new byte[base.MTU];
while (base.State == (PhotonSocketState)4)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, true);
}
catch (Exception ex)
{
if (base.State != PhotonSocketState.Connecting && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
DebugLevel debugLevel = DebugLevel.OFF;
object[] array2 = new object[4];
array2[1] = "RpcDeleteSubExtrusions";
array2[0] = base.State;
array2[5] = "__b";
array2[8] = base.ServerAddress;
array2[8] = "api/challenge/";
array2[7] = ex;
base.EnqueueDebugReturn(debugLevel, string.Concat(array2));
}
base.HandleException((StatusCode)(-48));
}
}
}
this.Disconnect();
}
// Token: 0x0600C894 RID: 51348 RVA: 0x003C69C4 File Offset: 0x003C4BC4
internal void PHNCMHCKOLI()
{
IPAddress ipaddress = null;
try
{
ipaddress = IPhotonSocket.GetIpAddress(base.ServerAddress);
if (ipaddress == null)
{
throw new ArgumentException("Invalid IPAddress. Address: " + base.ServerAddress);
}
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (base.State == PhotonSocketState.Disconnecting || base.State == PhotonSocketState.Disconnected)
{
return;
}
this.NGNPMKHIBFP = new Socket(ipaddress.AddressFamily, SocketType.Dgram, ProtocolType.Udp);
this.NGNPMKHIBFP.Connect(ipaddress, base.ServerPort);
base.AddressResolvedAsIpv6 = base.IsIpv6SimpleCheck(ipaddress);
base.State = PhotonSocketState.Connected;
this.peerBase.OnConnect();
}
}
catch (SecurityException ex)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
base.Listener.DebugReturn(DebugLevel.ERROR, string.Concat(new string[]
{
"Connect() to '",
base.ServerAddress,
"' (",
(ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty,
") failed: ",
ex.ToString()
}));
}
base.HandleException(StatusCode.SecurityExceptionOnConnect);
return;
}
catch (Exception ex2)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
base.Listener.DebugReturn(DebugLevel.ERROR, string.Concat(new string[]
{
"Connect() to '",
base.ServerAddress,
"' (",
(ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty,
") failed: ",
ex2.ToString()
}));
}
base.HandleException(StatusCode.ExceptionOnConnect);
return;
}
new Thread(new ThreadStart(this.CKGHDKDCMFG))
{
Name = "photon receive thread",
IsBackground = true
}.Start();
}
// Token: 0x0600C895 RID: 51349 RVA: 0x003C6BE0 File Offset: 0x003C4DE0
public virtual PhotonSocketError CLMGPBDNFLK(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return PhotonSocketError.Skipped;
}
// Token: 0x0600C896 RID: 51350 RVA: 0x003C6BE8 File Offset: 0x003C4DE8
public virtual PhotonSocketError EDEBNOKPNPB(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return (PhotonSocketError)5;
}
// Token: 0x0600C897 RID: 51351 RVA: 0x003C6BF0 File Offset: 0x003C4DF0
public void AMOILOIDLHC()
{
base.State = PhotonSocketState.Disconnected;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.ERROR, ")" + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Connecting;
}
// Token: 0x0600C898 RID: 51352 RVA: 0x003C6C68 File Offset: 0x003C4E68
public virtual PhotonSocketError DNHHCEDJKFB(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return PhotonSocketError.Exception;
}
// Token: 0x0600C899 RID: 51353 RVA: 0x003C6C70 File Offset: 0x003C4E70
public virtual PhotonSocketError MDHHFEGDPHK(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Success;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 0, MFFGOHPHNFL, SocketFlags.OutOfBand);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
base.EnqueueDebugReturn(DebugLevel.OFF, "float" + base.ServerAddress + "No import friends dialog found" + ex.Message);
}
return PhotonSocketError.Success;
}
}
return PhotonSocketError.Success;
}
// Token: 0x0600C89A RID: 51354 RVA: 0x003C6D24 File Offset: 0x003C4F24
public void LJDEOGKFIPK()
{
byte[] array = new byte[base.MTU];
while (base.State == PhotonSocketState.Connecting)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, false);
}
catch (Exception ex)
{
if (base.State != (PhotonSocketState)5 && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
DebugLevel debugLevel = DebugLevel.OFF;
object[] array2 = new object[1];
array2[0] = "Skipping PhotonVoiceConnect for Junior profile";
array2[1] = base.State;
array2[6] = "Refund";
array2[7] = base.ServerAddress;
array2[3] = "BEHAVIOR";
array2[0] = ex;
base.EnqueueDebugReturn(debugLevel, string.Concat(array2));
}
base.HandleException((StatusCode)129);
}
}
}
this.Disconnect();
}
// Token: 0x0600C89B RID: 51355 RVA: 0x003C6DFC File Offset: 0x003C4FFC
public void ELBKPOKPHNI()
{
byte[] array = new byte[base.MTU];
while (base.State == PhotonSocketState.Disconnecting)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, true);
}
catch (Exception ex)
{
if (base.State != (PhotonSocketState)6 && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
DebugLevel debugLevel = DebugLevel.OFF;
object[] array2 = new object[6];
array2[0] = "Username";
array2[1] = base.State;
array2[0] = "TEAM";
array2[3] = base.ServerAddress;
array2[6] = "click";
array2[8] = ex;
base.EnqueueDebugReturn(debugLevel, string.Concat(array2));
}
base.HandleException((StatusCode)(-178));
}
}
}
this.Disconnect();
}
// Token: 0x0600C89C RID: 51356 RVA: 0x003C6ED4 File Offset: 0x003C50D4
public void GEOLMIFKFJP()
{
byte[] array = new byte[base.MTU];
while (base.State == PhotonSocketState.Connected)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, true);
}
catch (Exception ex)
{
if (base.State != PhotonSocketState.Connected && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
DebugLevel debugLevel = DebugLevel.ERROR;
object[] array2 = new object[8];
array2[1] = "OTID";
array2[1] = base.State;
array2[5] = "method";
array2[8] = base.ServerAddress;
array2[0] = "MD";
array2[7] = ex;
base.EnqueueDebugReturn(debugLevel, string.Concat(array2));
}
base.HandleException((StatusCode)33);
}
}
}
this.Disconnect();
}
// Token: 0x0600C89D RID: 51357 RVA: 0x003C6FAC File Offset: 0x003C51AC
public override bool Connect()
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
bool flag;
lock (ecpccpnkeoi)
{
if (!base.Connect())
{
flag = false;
}
else
{
base.State = PhotonSocketState.Connecting;
new Thread(new ThreadStart(this.PHNCMHCKOLI))
{
Name = "photon dns thread",
IsBackground = true
}.Start();
flag = true;
}
}
return flag;
}
// Token: 0x0600C89E RID: 51358 RVA: 0x003C702C File Offset: 0x003C522C
public void MMLHLFBFLKN()
{
base.State = (PhotonSocketState)8;
if (this.NGNPMKHIBFP != null)
{
try
{
if (this.NGNPMKHIBFP.Connected)
{
this.NGNPMKHIBFP.Close();
}
}
catch (Exception ex)
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "SystemInfo" + ex);
}
}
this.NGNPMKHIBFP = null;
base.State = PhotonSocketState.Disconnected;
}
// Token: 0x0600C89F RID: 51359 RVA: 0x003C70A4 File Offset: 0x003C52A4
public virtual PhotonSocketError JFHDEDPAAOF(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Success;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 1, MFFGOHPHNFL, SocketFlags.OutOfBand);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
base.EnqueueDebugReturn(DebugLevel.ERROR, "New Test" + base.ServerAddress + "websocket" + ex.Message);
}
return (PhotonSocketError)7;
}
}
return PhotonSocketError.Success;
}
// Token: 0x0600C8A0 RID: 51360 RVA: 0x003C7158 File Offset: 0x003C5358
public virtual PhotonSocketError KHKCNGHFGNE(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return (PhotonSocketError)6;
}
// Token: 0x0600C8A1 RID: 51361 RVA: 0x003C7160 File Offset: 0x003C5360
public void CKGHDKDCMFG()
{
byte[] array = new byte[base.MTU];
while (base.State == PhotonSocketState.Connected)
{
try
{
int num = this.NGNPMKHIBFP.Receive(array);
base.HandleReceivedDatagram(array, num, true);
}
catch (Exception ex)
{
if (base.State != PhotonSocketState.Disconnecting && base.State != PhotonSocketState.Disconnected)
{
if (base.ReportDebugOfLevel(DebugLevel.ERROR))
{
base.EnqueueDebugReturn(DebugLevel.ERROR, string.Concat(new object[] { "Receive issue. State: ", base.State, ". Server: '", base.ServerAddress, "' Exception: ", ex }));
}
base.HandleException(StatusCode.ExceptionOnReceive);
}
}
}
this.Disconnect();
}
// Token: 0x0600C8A2 RID: 51362 RVA: 0x003C7238 File Offset: 0x003C5438
internal void DCGFKGBDFGK()
{
IPAddress ipaddress = null;
try
{
ipaddress = IPhotonSocket.GetIpAddress(base.ServerAddress);
if (ipaddress == null)
{
throw new ArgumentException("ARM" + base.ServerAddress);
}
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (base.State == (PhotonSocketState)5 || base.State == PhotonSocketState.Disconnected)
{
return;
}
this.NGNPMKHIBFP = new Socket(ipaddress.AddressFamily, (SocketType)6, (ProtocolType)(-125));
this.NGNPMKHIBFP.Connect(ipaddress, base.ServerPort);
base.AddressResolvedAsIpv6 = base.IsIpv6SimpleCheck(ipaddress);
base.State = (PhotonSocketState)8;
this.peerBase.OnConnect();
}
}
catch (SecurityException ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
IPhotonPeerListener listener = base.Listener;
DebugLevel debugLevel = DebugLevel.OFF;
string[] array = new string[5];
array[0] = "DiscGolfParticles";
array[0] = base.ServerAddress;
array[0] = "TestBot-";
array[7] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array[0] = "success";
array[6] = ex.ToString();
listener.DebugReturn(debugLevel, string.Concat(array));
}
base.HandleException((StatusCode)(-15));
return;
}
catch (Exception ex2)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
IPhotonPeerListener listener2 = base.Listener;
DebugLevel debugLevel2 = DebugLevel.ERROR;
string[] array2 = new string[3];
array2[0] = "SupportLogger OnCreatedRoom(";
array2[1] = base.ServerAddress;
array2[5] = "RpcRequestImage";
array2[8] = ((ipaddress != null) ? ipaddress.AddressFamily.ToString() : string.Empty);
array2[7] = "accepted";
array2[8] = ex2.ToString();
listener2.DebugReturn(debugLevel2, string.Concat(array2));
}
base.HandleException((StatusCode)5);
return;
}
new Thread(new ThreadStart(this.LJDEOGKFIPK))
{
Name = "HoverUnlock ",
IsBackground = false
}.Start();
}
// Token: 0x0600C8A3 RID: 51363 RVA: 0x003C7454 File Offset: 0x003C5654
public virtual PhotonSocketError HJCBONENJAN(byte[] AOAILGGFDHJ, int MFFGOHPHNFL)
{
object ecpccpnkeoi = this.ECPCCPNKEOI;
lock (ecpccpnkeoi)
{
if (this.NGNPMKHIBFP == null || !this.NGNPMKHIBFP.Connected)
{
return PhotonSocketError.Success;
}
try
{
this.NGNPMKHIBFP.Send(AOAILGGFDHJ, 0, MFFGOHPHNFL, SocketFlags.OutOfBand);
}
catch (Exception ex)
{
if (base.ReportDebugOfLevel(DebugLevel.OFF))
{
base.EnqueueDebugReturn(DebugLevel.OFF, "Looking for crash dumps in " + base.ServerAddress + "OBJECTIVE" + ex.Message);
}
return (PhotonSocketError)8;
}
}
return PhotonSocketError.Success;
}
// Token: 0x0600C8A4 RID: 51364 RVA: 0x003C7508 File Offset: 0x003C5708
public virtual PhotonSocketError OBJMEMCKEOJ(out byte[] AOAILGGFDHJ)
{
AOAILGGFDHJ = null;
return (PhotonSocketError)5;
}
// Token: 0x04001CB4 RID: 7348
private Socket NGNPMKHIBFP;
// Token: 0x04001CB5 RID: 7349
private readonly object ECPCCPNKEOI = new object();
}
}