blob: b596ef5769ea6051c083b131dbe07a1f96cd185b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
using System;
using System.Collections;
using System.Net.Sockets;
using Hazel.Udp;
using UnityEngine;
namespace InnerNet
{
public class InnerDiscover : DestroyableSingleton<InnerDiscover>
{
public event Action<BroadcastPacket> OnPacketGet;
private UdpBroadcastListener listener;
private UdpBroadcaster sender;
public int Port = 47777;
public float Interval = 1f;
public void StartAsServer(string data)
{
bool flag = this.sender == null;
if (flag)
{
this.sender = new UdpBroadcaster(this.Port);
}
this.sender.SetData(data);
if (flag)
{
base.StartCoroutine(this.RunServer());
}
}
private IEnumerator RunServer()
{
while (this.sender != null)
{
this.sender.Broadcast();
for (float timer = 0f; timer < this.Interval; timer += Time.deltaTime)
{
yield return null;
}
}
yield break;
}
public void StopServer()
{
if (this.sender != null)
{
this.sender.Dispose();
this.sender = null;
}
}
public void StartAsClient()
{
if (this.listener == null)
{
try
{
this.listener = new UdpBroadcastListener(this.Port);
this.listener.StartListen();
base.StartCoroutine(this.RunClient());
}
catch (SocketException)
{
AmongUsClient.Instance.LastDisconnectReason = DisconnectReasons.Custom;
AmongUsClient.Instance.LastCustomDisconnect = "Couldn't start local network listener. You may need to restart Among Us.";
DestroyableSingleton<DisconnectPopup>.Instance.Show();
}
}
}
private IEnumerator RunClient()
{
while (this.listener != null)
{
if (!this.listener.Running)
{
this.listener.StartListen();
}
BroadcastPacket[] packets = this.listener.GetPackets();
for (int i = 0; i < packets.Length; i++)
{
Action<BroadcastPacket> onPacketGet = this.OnPacketGet;
if (onPacketGet != null)
{
onPacketGet(packets[i]);
}
}
yield return null;
}
yield break;
}
public void StopClient()
{
if (this.listener != null)
{
this.listener.Dispose();
this.listener = null;
}
}
public override void OnDestroy()
{
this.StopServer();
this.StopClient();
base.OnDestroy();
}
}
}
|
