StreamServerPushSelect.h

#pragma once

#include "StreamServer.h"

#include "Address.h"
#include "Timer.h"
#include "Shuffle.h"
#include "InfoPushSelect.h"

#include "PacketStream.h"
#include "StreamEncoderFrame.h"

#include "StreamMessage.h"
#include "StreamMessagePushSelectJoin.h"
#include "StreamMessagePushSelectLeave.h"
#include "StreamMessageBootPushSelectRequest.h"
#include "StreamMessageBootPushSelectResponse.h"
#include "StreamMessageBootPushSelectRegister.h"
#include "StreamMessageBootPushSelectDeregister.h"

class CStreamServerPushSelect : public CStreamServer
{
private:
    // Stream
    CStreamSource*                  source;
    set<CAddress>*                  receivers;
    CTimer<CStreamServerPushSelect>*    timer;
    CInfoPushSelect*                    info;

    // Delegates
    IDelegate2<void, CAddress, CPacketStream*>*
                                    delegateSendStream;
    IDelegate2<void, CAddress, CStreamMessage*>*
                                    delegateSendMessage;

    // Global
    __uint32                        layers;

    __byte                          gopLength;

    __time                          scheduleTime;
    __uint32                        scheduleFrame;
    __uint32                        scheduleRate;
    __uint32                        deltaFrame;

    // Encoder
    CStreamEncoderFrame*            encoder;

public:
    CStreamServerPushSelect(
        CSimHandler*                                    sim,
        CInfoPushSelect*                                    info,
        CStreamSource*                                  source,
        IDelegate2<void, CAddress, CPacketStream*>*     delegateSendStream,
        IDelegate2<void, CAddress, CStreamMessage*>*    delegateSendMessage
        );
    virtual ~CStreamServerPushSelect();

    // Control
    void            Start();
    void            Stop();

    // Receive
    void            Recv(CAddress src, CStreamMessage* message);

    // Finalizer
    virtual void    Finalize();

private:
    void            Timer(CTimerInfo* info);

    void            RecvMessageQuery(CAddress src, CStreamMessageBootPushSelectRequest* message);
    void            RecvMessageQueryStream(CAddress src, CStreamMessageBootPushSelectRequest* message);
    void            RecvMessageQueryLayer(CAddress src, CStreamMessageBootPushSelectRequest* message);

    void            RecvMessageRegister(CAddress src, CStreamMessageBootPushSelectRegister* message);
    void            RecvMessageDeregister(CAddress src, CStreamMessageBootPushSelectDeregister* message);

    void            RecvMessageJoin(CAddress src, CStreamMessagePushSelectJoin* message);
    void            RecvMessageLeave(CAddress src, CStreamMessagePushSelectLeave* message);
};