Загрузка Packet Loss Notification - Загрузка исходного кода Packet Loss Notification

Packet Loss Notification

Другие категории

1.0.0

Скачать

Уведомление о потере пакетов

Функции

Уведомление о каждом потерянном ненадежном пакете
Транспортно-агностический
Простой регистратор

Обзор

Проект предоставляет вспомогательный класс для обнаружения и уведомления о потере ненадежных пакетов. Это важная часть многих расширенных стратегий синхронизации. Например, его использует Eventual Consistency.

Для простоты сервер поддерживает только одного клиента.

Обзор

Детектор

Обнаружение работает путем добавления этого заголовка к каждому отправленному пакету:

ushort Идентификатор локальной последовательности
ushort Идентификатор последней удаленной последовательности
uint Битовая маска для 32 идентификаторов предыдущих удаленных последовательностей

Рабочий процесс такой:

Одноранговое соединение:
- Вызов AddPeer в помощнике
Отправка пакета Peer:
- Получить пустой BitBuffer
- Вызов AddHeaderForPeerId
- Запишите фактическую полезную нагрузку в BitBuffer
- Скопируйте содержимое BitBuffer в выделенную память.
- Очистить битбуфер
- Вызов EnqueueData
- - Если результат ИСТИНА
- - - Отправить пакет одноранговому узлу
- - Если результат ЛОЖЬ
- - - Отключите этот узел
Получен пакет от узла:
- Получить содержимое пакета в BitBuffer
- Вызовите ReadHeaderOfPeerId с ним
- - Если результат ИСТИНА
- - - Чтение фактической полезной нагрузки
Периодически:
- Вызов ExecuteLostPackets
При потере пакета:
- Получить данные в BitBuffer
- Вызов ClearHeader
- Чтение фактической полезной нагрузки
Одноранговое соединение отключено:
- Вызов RemovePeer

Если пакет считается потерянным, это означает, что он, скорее всего, был потерян. Если пакет считается « Прибывшим» , то он наверняка доставлен.

ILossHandler.OnPacketLost будет вызываться для каждого потерянного пакета И для каждого пакета, который был поставлен в очередь и все еще отслеживался, когда этот одноранговый узел был отключен.

Если присутствует символ LOSS_DETECTOR_DEBUG , то все потерянные последовательности пакетов будут выведены в регистратор.

Методы

void LossDetector ( ILossHandler handler, ushort maxPeerCount, ushort ackWindow ) — эта реализация ILossHandler будет вызываться для каждого потерянного пакета. MaxPeerCount — максимальное количество пиров, подключенных к этому узлу. AckWindow — максимальное количество локальных отслеживаемых пакетов на одноранговое устройство.
void AddPeer ( ushort peerId ) — очищает порядковый номер для этого PeerId.
void RemovePeer ( ushort peerId ) — ставит в очередь каждый отслеживаемый пакет для этого PeerId как потерянный.
void AddHeaderForPeerId ( ushort peerId, BitBuffer data ) — записывает информацию заголовка в BitBuffer для этого PeerId.
bool ReadHeaderOfPeerId ( ushort peerId, BitBuffer data ) — считывает заголовок из BitBuffer и определяет, подтвержден ли какой-либо отслеживаемый пакет ACK или NACK. В случае ACK детектор освободит выделенную память. Возвращает значение True, если значение SequenceId больше, чем значение LastSequenceId для этого PeerId.
bool EnqueueData ( ushort peerId, PacketData data ) — пытается поместить данные в очередь отслеживаемых пакетов для этого узла. Возвращает False, если очередь уже заполнена. Вероятно, вы слишком долго не получали пакеты от другого пира и вам следует его отключить.
void ExecuteLostPackets () — пересылает все буферизованные потерянные пакеты обработчику и освобождает выделенную им память.
void ClearHeader ( BitBuffer data ) — очищает заголовок из BitBuffer.

Если присутствует символ LOSS_DETECTOR_DEBUG , то эти методы также доступны:

void GetDebugString ( StringBuilder builder ) — записывает полное состояние буферов для каждого PeerId в StringBuilder.
void GetDebugString ( ushort peerId, StringBuilder builder ) — записывает состояние буферов для этого PeerId.