forked from sin365/AxibugEmuOnline
Compare commits
No commits in common. "02e94317e4eb165ec02df2c4996ef01a3e5e58af" and "0783d7d90e492e993d5dc90d2d5a9bae7a55c10d" have entirely different histories.
02e94317e4
...
0783d7d90e
@ -17,8 +17,6 @@ namespace AxibugEmuOnline.Client.Network
|
||||
private NetMsg() { }
|
||||
|
||||
|
||||
public static object lockQueueObj = new object();
|
||||
|
||||
#region RegisterMsgEvent
|
||||
|
||||
public void RegNetMsgEvent(int cmd, Action<byte[]> callback)
|
||||
@ -63,21 +61,15 @@ namespace AxibugEmuOnline.Client.Network
|
||||
#region PostEvent
|
||||
public void EnqueueNesMsg(int cmd, int ERRCODE, byte[] arg)
|
||||
{
|
||||
lock (lockQueueObj)
|
||||
{
|
||||
queueNetMsg.Enqueue((cmd, ERRCODE, arg));
|
||||
}
|
||||
queueNetMsg.Enqueue((cmd, ERRCODE, arg));
|
||||
}
|
||||
|
||||
public void DequeueNesMsg()
|
||||
{
|
||||
lock (lockQueueObj)
|
||||
while (queueNetMsg.Count > 0)
|
||||
{
|
||||
while (queueNetMsg.Count > 0)
|
||||
{
|
||||
(int, int, byte[]) msgData = queueNetMsg.Dequeue();
|
||||
PostNetMsgEvent(msgData.Item1, msgData.Item2, msgData.Item3);
|
||||
}
|
||||
(int, int, byte[]) msgData = queueNetMsg.Dequeue();
|
||||
PostNetMsgEvent(msgData.Item1, msgData.Item2, msgData.Item3);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user