|
|
@@ -76,7 +76,7 @@ namespace ET.Server
|
|
|
}
|
|
|
catch (Exception e)
|
|
|
{
|
|
|
- self.Fiber().Error(e);
|
|
|
+ Log.Error(e);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -134,7 +134,7 @@ namespace ET.Server
|
|
|
}
|
|
|
catch (Exception e)
|
|
|
{
|
|
|
- self.Fiber().Error(e);
|
|
|
+ Log.Error(e);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -147,7 +147,6 @@ namespace ET.Server
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
- Fiber fiber = self.Fiber();
|
|
|
// accept
|
|
|
byte flag = self.Cache[0];
|
|
|
switch (flag)
|
|
|
@@ -172,7 +171,7 @@ namespace ET.Server
|
|
|
self.ConnectIdNodes.TryGetValue(connectId, out routerNode);
|
|
|
if (routerNode == null)
|
|
|
{
|
|
|
- fiber.Info($"router create reconnect: {self.IPEndPoint} {realAddress} {connectId} {outerConn} {innerConn}");
|
|
|
+ Log.Info($"router create reconnect: {self.IPEndPoint} {realAddress} {connectId} {outerConn} {innerConn}");
|
|
|
routerNode = self.New(realAddress, connectId, outerConn, innerConn, self.CloneAddress());
|
|
|
// self.OuterNodes 这里不能add,因为还没验证完成,要在RouterAck中加入
|
|
|
}
|
|
|
@@ -180,7 +179,7 @@ namespace ET.Server
|
|
|
|
|
|
if (routerNode.ConnectId != connectId)
|
|
|
{
|
|
|
- fiber.Warning($"kcp router router reconnect connectId diff1: {routerNode.SyncIpEndPoint} {(IPEndPoint) self.IPEndPoint}");
|
|
|
+ Log.Warning($"kcp router router reconnect connectId diff1: {routerNode.SyncIpEndPoint} {(IPEndPoint) self.IPEndPoint}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
@@ -188,27 +187,27 @@ namespace ET.Server
|
|
|
// 这个路由连接不上,客户端会换个软路由,所以没关系
|
|
|
if (routerNode.InnerConn != innerConn)
|
|
|
{
|
|
|
- fiber.Warning($"kcp router router reconnect inner conn diff1: {routerNode.SyncIpEndPoint} {(IPEndPoint) self.IPEndPoint}");
|
|
|
+ Log.Warning($"kcp router router reconnect inner conn diff1: {routerNode.SyncIpEndPoint} {(IPEndPoint) self.IPEndPoint}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
if (routerNode.OuterConn != outerConn)
|
|
|
{
|
|
|
- fiber.Warning($"kcp router router reconnect outer conn diff1: {routerNode.SyncIpEndPoint} {(IPEndPoint) self.IPEndPoint}");
|
|
|
+ Log.Warning($"kcp router router reconnect outer conn diff1: {routerNode.SyncIpEndPoint} {(IPEndPoint) self.IPEndPoint}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
// 校验ip,连接过程中ip不能变化
|
|
|
if (!Equals(routerNode.SyncIpEndPoint, self.IPEndPoint))
|
|
|
{
|
|
|
- fiber.Warning($"kcp router syn ip is diff1: {routerNode.SyncIpEndPoint} {(IPEndPoint) self.IPEndPoint}");
|
|
|
+ Log.Warning($"kcp router syn ip is diff1: {routerNode.SyncIpEndPoint} {(IPEndPoint) self.IPEndPoint}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
// 校验内网地址
|
|
|
if (routerNode.InnerAddress != realAddress)
|
|
|
{
|
|
|
- fiber.Warning($"router sync error2: {routerNode.OuterConn} {routerNode.InnerAddress} {outerConn} {realAddress}");
|
|
|
+ Log.Warning($"router sync error2: {routerNode.OuterConn} {routerNode.InnerAddress} {outerConn} {realAddress}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
@@ -251,7 +250,7 @@ namespace ET.Server
|
|
|
{
|
|
|
outerConn = NetServices.Instance.CreateConnectChannelId();
|
|
|
routerNode = self.New(realAddress, connectId, outerConn, innerConn, self.CloneAddress());
|
|
|
- fiber.Info($"router create: {realAddress} {connectId} {outerConn} {innerConn} {routerNode.SyncIpEndPoint}");
|
|
|
+ Log.Info($"router create: {realAddress} {connectId} {outerConn} {innerConn} {routerNode.SyncIpEndPoint}");
|
|
|
self.OuterNodes.Add(routerNode.OuterConn, routerNode);
|
|
|
}
|
|
|
|
|
|
@@ -264,14 +263,14 @@ namespace ET.Server
|
|
|
// 校验ip,连接过程中ip不能变化
|
|
|
if (!Equals(routerNode.SyncIpEndPoint, self.IPEndPoint))
|
|
|
{
|
|
|
- fiber.Warning($"kcp router syn ip is diff1: {routerNode.SyncIpEndPoint} {self.IPEndPoint}");
|
|
|
+ Log.Warning($"kcp router syn ip is diff1: {routerNode.SyncIpEndPoint} {self.IPEndPoint}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
// 校验内网地址
|
|
|
if (routerNode.InnerAddress != realAddress)
|
|
|
{
|
|
|
- fiber.Warning($"router sync error2: {routerNode.OuterConn} {routerNode.InnerAddress} {outerConn} {realAddress}");
|
|
|
+ Log.Warning($"router sync error2: {routerNode.OuterConn} {routerNode.InnerAddress} {outerConn} {realAddress}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
@@ -300,7 +299,7 @@ namespace ET.Server
|
|
|
|
|
|
if (!self.OuterNodes.TryGetValue(outerConn, out RouterNode kcpRouter))
|
|
|
{
|
|
|
- fiber.Warning($"kcp router syn not found outer nodes: {outerConn} {innerConn}");
|
|
|
+ Log.Warning($"kcp router syn not found outer nodes: {outerConn} {innerConn}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
@@ -314,7 +313,7 @@ namespace ET.Server
|
|
|
IPEndPoint ipEndPoint = (IPEndPoint) self.IPEndPoint;
|
|
|
if (!Equals(kcpRouter.SyncIpEndPoint.Address, ipEndPoint.Address))
|
|
|
{
|
|
|
- fiber.Warning($"kcp router syn ip is diff3: {kcpRouter.SyncIpEndPoint.Address} {ipEndPoint.Address}");
|
|
|
+ Log.Warning($"kcp router syn ip is diff3: {kcpRouter.SyncIpEndPoint.Address} {ipEndPoint.Address}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
@@ -329,7 +328,7 @@ namespace ET.Server
|
|
|
self.Cache.WriteTo(5, innerConn);
|
|
|
byte[] addressBytes = ipEndPoint.ToString().ToByteArray();
|
|
|
Array.Copy(addressBytes, 0, self.Cache, 9, addressBytes.Length);
|
|
|
- fiber.Info($"kcp router syn: {outerConn} {innerConn} {kcpRouter.InnerIpEndPoint} {kcpRouter.OuterIpEndPoint}");
|
|
|
+ Log.Info($"kcp router syn: {outerConn} {innerConn} {kcpRouter.InnerIpEndPoint} {kcpRouter.OuterIpEndPoint}");
|
|
|
self.InnerSocket.SendTo(self.Cache, 0, 9 + addressBytes.Length, SocketFlags.None, kcpRouter.InnerIpEndPoint);
|
|
|
|
|
|
if (!kcpRouter.CheckOuterCount(timeNow))
|
|
|
@@ -352,19 +351,19 @@ namespace ET.Server
|
|
|
|
|
|
if (!self.OuterNodes.TryGetValue(outerConn, out RouterNode kcpRouter))
|
|
|
{
|
|
|
- fiber.Warning($"kcp router outer fin not found outer nodes: {outerConn} {innerConn}");
|
|
|
+ Log.Warning($"kcp router outer fin not found outer nodes: {outerConn} {innerConn}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
// 比对innerConn
|
|
|
if (kcpRouter.InnerConn != innerConn)
|
|
|
{
|
|
|
- fiber.Warning($"router node innerConn error: {innerConn} {outerConn} {kcpRouter.Status}");
|
|
|
+ Log.Warning($"router node innerConn error: {innerConn} {outerConn} {kcpRouter.Status}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
kcpRouter.LastRecvOuterTime = timeNow;
|
|
|
- fiber.Info($"kcp router outer fin: {outerConn} {innerConn} {kcpRouter.InnerIpEndPoint}");
|
|
|
+ Log.Info($"kcp router outer fin: {outerConn} {innerConn} {kcpRouter.InnerIpEndPoint}");
|
|
|
self.InnerSocket.SendTo(self.Cache, 0, messageLength, SocketFlags.None, kcpRouter.InnerIpEndPoint);
|
|
|
|
|
|
if (!kcpRouter.CheckOuterCount(timeNow))
|
|
|
@@ -388,20 +387,20 @@ namespace ET.Server
|
|
|
|
|
|
if (!self.OuterNodes.TryGetValue(outerConn, out RouterNode kcpRouter))
|
|
|
{
|
|
|
- fiber.Warning($"kcp router msg not found outer nodes: {outerConn} {innerConn}");
|
|
|
+ Log.Warning($"kcp router msg not found outer nodes: {outerConn} {innerConn}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
if (kcpRouter.Status != RouterStatus.Msg)
|
|
|
{
|
|
|
- fiber.Warning($"router node status error: {innerConn} {outerConn} {kcpRouter.Status}");
|
|
|
+ Log.Warning($"router node status error: {innerConn} {outerConn} {kcpRouter.Status}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
// 比对innerConn
|
|
|
if (kcpRouter.InnerConn != innerConn)
|
|
|
{
|
|
|
- fiber.Warning($"router node innerConn error: {innerConn} {outerConn} {kcpRouter.Status}");
|
|
|
+ Log.Warning($"router node innerConn error: {innerConn} {outerConn} {kcpRouter.Status}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
@@ -435,7 +434,6 @@ namespace ET.Server
|
|
|
|
|
|
// accept
|
|
|
byte flag = self.Cache[0];
|
|
|
- Fiber fiber = self.Fiber();
|
|
|
switch (flag)
|
|
|
{
|
|
|
case KcpProtocalType.RouterReconnectACK:
|
|
|
@@ -445,14 +443,14 @@ namespace ET.Server
|
|
|
uint connectId = BitConverter.ToUInt32(self.Cache, 9);
|
|
|
if (!self.ConnectIdNodes.TryGetValue(connectId, out RouterNode kcpRouterNode))
|
|
|
{
|
|
|
- fiber.Warning($"router node error: {innerConn} {connectId}");
|
|
|
+ Log.Warning($"router node error: {innerConn} {connectId}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
// 必须校验innerConn,防止伪造
|
|
|
if (innerConn != kcpRouterNode.InnerConn)
|
|
|
{
|
|
|
- fiber.Warning(
|
|
|
+ Log.Warning(
|
|
|
$"router node innerConn error: {innerConn} {kcpRouterNode.InnerConn} {outerConn} {kcpRouterNode.OuterConn} {kcpRouterNode.Status}");
|
|
|
break;
|
|
|
}
|
|
|
@@ -460,7 +458,7 @@ namespace ET.Server
|
|
|
// 必须校验outerConn,防止伪造
|
|
|
if (outerConn != kcpRouterNode.OuterConn)
|
|
|
{
|
|
|
- fiber.Warning(
|
|
|
+ Log.Warning(
|
|
|
$"router node outerConn error: {innerConn} {kcpRouterNode.InnerConn} {outerConn} {kcpRouterNode.OuterConn} {kcpRouterNode.Status}");
|
|
|
break;
|
|
|
}
|
|
|
@@ -480,7 +478,7 @@ namespace ET.Server
|
|
|
self.Cache.WriteTo(0, KcpProtocalType.RouterReconnectACK);
|
|
|
self.Cache.WriteTo(1, kcpRouterNode.InnerConn);
|
|
|
self.Cache.WriteTo(5, kcpRouterNode.OuterConn);
|
|
|
- fiber.Info($"kcp router RouterAck: {outerConn} {innerConn} {kcpRouterNode.SyncIpEndPoint}");
|
|
|
+ Log.Info($"kcp router RouterAck: {outerConn} {innerConn} {kcpRouterNode.SyncIpEndPoint}");
|
|
|
self.OuterSocket.SendTo(self.Cache, 0, 9, SocketFlags.None, kcpRouterNode.SyncIpEndPoint);
|
|
|
break;
|
|
|
}
|
|
|
@@ -492,7 +490,7 @@ namespace ET.Server
|
|
|
|
|
|
if (!self.OuterNodes.TryGetValue(outerConn, out RouterNode kcpRouterNode))
|
|
|
{
|
|
|
- fiber.Warning($"kcp router ack not found outer nodes: {outerConn} {innerConn}");
|
|
|
+ Log.Warning($"kcp router ack not found outer nodes: {outerConn} {innerConn}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
@@ -502,7 +500,7 @@ namespace ET.Server
|
|
|
|
|
|
kcpRouterNode.LastRecvInnerTime = timeNow;
|
|
|
// 转发出去
|
|
|
- fiber.Info($"kcp router ack: {outerConn} {innerConn} {kcpRouterNode.OuterIpEndPoint}");
|
|
|
+ Log.Info($"kcp router ack: {outerConn} {innerConn} {kcpRouterNode.OuterIpEndPoint}");
|
|
|
self.OuterSocket.SendTo(self.Cache, 0, messageLength, SocketFlags.None, kcpRouterNode.OuterIpEndPoint);
|
|
|
break;
|
|
|
}
|
|
|
@@ -519,14 +517,14 @@ namespace ET.Server
|
|
|
|
|
|
if (!self.OuterNodes.TryGetValue(outerConn, out RouterNode kcpRouterNode))
|
|
|
{
|
|
|
- fiber.Warning($"kcp router inner fin not found outer nodes: {outerConn} {innerConn}");
|
|
|
+ Log.Warning($"kcp router inner fin not found outer nodes: {outerConn} {innerConn}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
// 比对innerConn
|
|
|
if (kcpRouterNode.InnerConn != innerConn)
|
|
|
{
|
|
|
- fiber.Warning($"router node innerConn error: {innerConn} {outerConn} {kcpRouterNode.Status}");
|
|
|
+ Log.Warning($"router node innerConn error: {innerConn} {outerConn} {kcpRouterNode.Status}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
@@ -537,7 +535,7 @@ namespace ET.Server
|
|
|
}
|
|
|
|
|
|
kcpRouterNode.LastRecvInnerTime = timeNow;
|
|
|
- fiber.Info($"kcp router inner fin: {outerConn} {innerConn} {kcpRouterNode.OuterIpEndPoint}");
|
|
|
+ Log.Info($"kcp router inner fin: {outerConn} {innerConn} {kcpRouterNode.OuterIpEndPoint}");
|
|
|
self.OuterSocket.SendTo(self.Cache, 0, messageLength, SocketFlags.None, kcpRouterNode.OuterIpEndPoint);
|
|
|
|
|
|
break;
|
|
|
@@ -556,14 +554,14 @@ namespace ET.Server
|
|
|
|
|
|
if (!self.OuterNodes.TryGetValue(outerConn, out RouterNode kcpRouterNode))
|
|
|
{
|
|
|
- fiber.Warning($"kcp router inner msg not found outer nodes: {outerConn} {innerConn}");
|
|
|
+ Log.Warning($"kcp router inner msg not found outer nodes: {outerConn} {innerConn}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
// 比对innerConn
|
|
|
if (kcpRouterNode.InnerConn != innerConn)
|
|
|
{
|
|
|
- fiber.Warning($"router node innerConn error: {innerConn} {outerConn} {kcpRouterNode.Status}");
|
|
|
+ Log.Warning($"router node innerConn error: {innerConn} {outerConn} {kcpRouterNode.Status}");
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
@@ -603,7 +601,7 @@ namespace ET.Server
|
|
|
|
|
|
routerNode.Status = RouterStatus.Sync;
|
|
|
|
|
|
- self.Fiber().Info($"router new: outerConn: {outerConn} innerConn: {innerConn} {syncEndPoint}");
|
|
|
+ Log.Info($"router new: outerConn: {outerConn} innerConn: {innerConn} {syncEndPoint}");
|
|
|
|
|
|
return routerNode;
|
|
|
}
|
|
|
@@ -616,7 +614,7 @@ namespace ET.Server
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
- self.Fiber().Info($"router node remove: {routerNode.OuterConn} {routerNode.InnerConn} {error}");
|
|
|
+ Log.Info($"router node remove: {routerNode.OuterConn} {routerNode.InnerConn} {error}");
|
|
|
self.Remove(id);
|
|
|
}
|
|
|
|
|
|
@@ -639,7 +637,7 @@ namespace ET.Server
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- self.Fiber().Info($"router remove: {routerNode.Id} outerConn: {routerNode.OuterConn} innerConn: {routerNode.InnerConn}");
|
|
|
+ Log.Info($"router remove: {routerNode.Id} outerConn: {routerNode.OuterConn} innerConn: {routerNode.InnerConn}");
|
|
|
|
|
|
routerNode.Dispose();
|
|
|
}
|