49 lines
1.3 KiB
C#
49 lines
1.3 KiB
C#
using System.Collections.Generic;
|
|
using System.Threading;
|
|
|
|
namespace LiteNetLib
|
|
{
|
|
internal abstract class BaseChannel
|
|
{
|
|
protected readonly NetPeer Peer;
|
|
protected readonly Queue<NetPacket> OutgoingQueue = new Queue<NetPacket>(NetConstants.DefaultWindowSize);
|
|
private int _isAddedToPeerChannelSendQueue;
|
|
|
|
public int PacketsInQueue => OutgoingQueue.Count;
|
|
|
|
protected BaseChannel(NetPeer peer)
|
|
{
|
|
Peer = peer;
|
|
}
|
|
|
|
public void AddToQueue(NetPacket packet)
|
|
{
|
|
lock (OutgoingQueue)
|
|
{
|
|
OutgoingQueue.Enqueue(packet);
|
|
}
|
|
AddToPeerChannelSendQueue();
|
|
}
|
|
|
|
protected void AddToPeerChannelSendQueue()
|
|
{
|
|
if (Interlocked.CompareExchange(ref _isAddedToPeerChannelSendQueue, 1, 0) == 0)
|
|
{
|
|
Peer.AddToReliableChannelSendQueue(this);
|
|
}
|
|
}
|
|
|
|
public bool SendAndCheckQueue()
|
|
{
|
|
bool hasPacketsToSend = SendNextPackets();
|
|
if (!hasPacketsToSend)
|
|
Interlocked.Exchange(ref _isAddedToPeerChannelSendQueue, 0);
|
|
|
|
return hasPacketsToSend;
|
|
}
|
|
|
|
protected abstract bool SendNextPackets();
|
|
public abstract bool ProcessPacket(NetPacket packet);
|
|
}
|
|
}
|