HostServerPushSelect.cpp

#include "Headers.h"
#include "HostServerPushSelect.h"

CHostServerPushSelect::CHostServerPushSelect(
    __uint32        id,
    CSimHandler*    sim,
    CAddress        address,
    CInfoPushSelect*    info,
    CData*          data
    ) : CHostServer(id, sim, address, info, data)
{
    // Global
    this->info = info;

    // Delegates
    this->delegateRecv = new Delegate4<CHostServerPushSelect, void, __uint32, CPacketIp*, CPacketUdp*, CPacket*>(this, &CHostServerPushSelect::Recv);
    this->delegateSendStream = new Delegate2<CHostServerPushSelect, void, CAddress, CPacketStream*>(this, &CHostServerPushSelect::SendStream);
    this->delegateSendMessage = new Delegate2<CHostServerPushSelect, void, CAddress, CStreamMessage*>(this, &CHostServerPushSelect::SendMessage);
    
    // Create stream servers for unicast channels
    this->streamServers = new CStreamServerPushSelect*[this->info->NumChannels()];

    for(__uint32 index = 0; index < this->info->NumChannels(); index++)
    {
        this->streamServers[index] = new CStreamServerPushSelect(
            this->sim,
            this->info,
            this->info->StreamSource(index),
            this->delegateSendStream,
            this->delegateSendMessage
            );
    }

    // Create layer connections
        // Layer UDP -> this
    (*this->layerUdp->EventRecv()) += this->delegateRecv;
}

CHostServerPushSelect::~CHostServerPushSelect()
{
    // Delete stream servers
    for(__uint32 index = 0; index < this->info->NumChannels(); index++)
        delete this->streamServers[index];
    delete[] this->streamServers;

    // Delegates
    delete this->delegateRecv;
    delete this->delegateSendStream;
    delete this->delegateSendMessage;
}

void CHostServerPushSelect::Start()
{
    // Start the unicast channel servers
    for(__uint32 index = 0; index < this->info->NumChannels(); index++)
        this->streamServers[index]->Start();
}

void CHostServerPushSelect::Stop()
{
// Start the unicast channel servers
    for(__uint32 index = 0; index < this->info->NumChannels(); index++)
        this->streamServers[index]->Stop();
}

void CHostServerPushSelect::Finalize()
{
    // Call base class finalizer
    CHostServer::Finalize();

    // Call stream servers finalizer
    for(__uint32 index = 0; index < this->info->NumChannels(); index++)
        this->streamServers[index]->Finalize();
}

void CHostServerPushSelect::Recv(__uint32 entry, CPacketIp* ip, CPacketUdp* udp, CPacket* packet)
{
    // Receive UDP packets : process only control messages for unicast servers

    if(NULL == packet) return;
    if(udp->Dst() != this->info->PortControl()) return;
    if(packet->Type() != PACKET_TYPE_MESSAGE) return;

    // Convert the packet to a message
    CStreamMessage* message = type_cast<CStreamMessage*>(packet);

    // Send the message to the upper layer : the server for the specified stream
    this->streamServers[message->Stream()]->Recv(ip->Src(), message);
}

void CHostServerPushSelect::SendStream(CAddress dst, CPacketStream* packet)
{
    // Send stream packet to the lower layer (TTL = 128)
    (*this->layerUdp->DelegateSend())(this->info->PortStream(), this->info->PortStream(), dst, 128, packet);
}

void CHostServerPushSelect::SendMessage(CAddress dst, CStreamMessage* message)
{
    // Send message packet to the lower layer (TTL = 128)
    (*this->layerUdp->DelegateSend())(this->info->PortControl(), this->info->PortControl(), dst, 128, message);
}