Function clientReceive

engine/Poseidon/Network/NetTransportNet.cpp:989–1126

            SendMsg(const_cast<BYTE*>(pkt.data()), static_cast<int>(pkt.size()), msgID, NMFHighPriority);
        });

    SetNetTransportClientVoiceSenderId([c]() { return c; }, static_cast<uint32_t>(playerNo));

    LOG_INFO(Network, "VoN client initialized (player={})", playerNo);
    return true;
}

bool NetClient::IsVoicePlaying(int player)
{
    PumpVoiceSpeakers();
    auto found = _vonSpeakers.find(static_cast<uint32_t>(player));
    return found != _vonSpeakers.end() && found->second && found->second->active && found->second->level > 0.001f;
}

bool NetClient::IsVoiceRecording()
{
    auto* c = _vonSystem.client();
    return c && c->isTransmitting();
}

void NetClient::GetVoiceSpeakers(AutoArray<NetVoiceSpeakerInfo, Poseidon::Foundation::MemAllocSA>& speakers)
{
    PumpVoiceSpeakers();
    for (auto& [player, speaker] : _vonSpeakers)
    {
        if (!speaker)
        {
            continue;
        }
        NetVoiceSpeakerInfo info;
        info.player = static_cast<int>(player);
        const auto channel = _vonSpeakerChannels.find(player);
        info.channel = channel != _vonSpeakerChannels.end() ? static_cast<int>(channel->second)
                                                            : static_cast<int>(VoNChatChannel::Global);
        info.active = speaker->active && speaker->level > 0.001f;
        info.level = speaker->level;
        speakers.Add(info);
    }
}

void NetClient::PumpVoiceSpeakers()
{
    auto* c = _vonSystem.client();
    if (!c)
        return;

    DWORD now = GlobalTickCount();
    if (_lastVoicePumpTime != 0 && now - _lastVoicePumpTime < 15)
        return;
    _lastVoicePumpTime = now;

    for (auto& [ch, spk] : _vonSpeakers)
    {
        if (!spk)
            continue;

        const auto channel = _vonSpeakerChannels.find(ch);
        spk->setChannel(channel != _vonSpeakerChannels.end() ? channel->second : VoNChatChannel::Global);