HostClientPushSelect.cpp

#include "Headers.h"
#include "HostClientPushSelect.h"

CHostClientPushSelect::CHostClientPushSelect(
    __uint32        id,
    CSimHandler*    sim,
    CAddress        address,
    CInfoPushSelect*    info,
    CData*          data,
    __bitrate       bw
    ) : CHostClient(id, sim, address, info, data, bw)
{
    // Global
    this->info = info;

    // Delegates
    this->delegateRecv = new Delegate4<CHostClientPushSelect, void, __uint32, CPacketIp*, CPacketUdp*, CPacket*>(this, &CHostClientPushSelect::Recv);
    this->delegateSendStream = new Delegate2<CHostClientPushSelect, void, CAddress, CPacketStream*>(this, &CHostClientPushSelect::SendStream);
    this->delegateSendMessage = new Delegate2<CHostClientPushSelect, void, CAddress, CStreamMessage*>(this, &CHostClientPushSelect::SendMessage);
    this->delegateLink = new Delegate0<CHostClientPushSelect, CLink*>(this, &CHostClientPushSelect::Link);

    // Stream client push multi
    this->streamClient = new CStreamClientPushSelect(
        this->sim,
        this->info,
        this->address,
        this->delegateSendStream,
        this->delegateSendMessage,
        this->layerIgmp->DelegateJoin(),
        this->layerIgmp->DelegateLeave(),
        this->delegateLink,
        0,
        bw);

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

CHostClientPushSelect::~CHostClientPushSelect()
{
    // Client
    delete this->streamClient;

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

void CHostClientPushSelect::ChannelConnectMcast(CChannel* channel)
{
    // Start the client
    this->streamClient->Start(channel);

#ifdef MULTICAST
    // Multicast statistics
    this->info->MulticastJoin(this->id, channel->Id());
#endif
}

void CHostClientPushSelect::ChannelDisconnectMcast()
{
    // Stop the client
    this->streamClient->Stop();

#ifdef MULTICAST
    // Multicast statistics
    this->info->MulticastLeave(this->id, channel->Id());
#endif
}

void CHostClientPushSelect::ChannelConnectUcast(CChannel* channel)
{
    // Start the client
    this->streamClient->Start(channel);
}

void CHostClientPushSelect::ChannelDisconnectUcast()
{
    // Stop the client
    this->streamClient->Stop();
}

void CHostClientPushSelect::Recv(__uint32 entry, CPacketIp* ip, CPacketUdp* udp, CPacket* packet)
{
    // Process the received packets with the client
    this->streamClient->Recv(ip->Src(), ip->Dst(), udp->Src(), udp->Dst(), packet);
}


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

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

void CHostClientPushSelect::Finalize()
{
    // Call base class finalizer
    CHostClient::Finalize();

    // Call client finalizer
    this->streamClient->Finalize();
}