F:/My Projects/LSEngine/Modules/LSSoundLib/Src/SoundComponents/LSSStreamingSoundSource.h

#ifndef __LSS_STREAMINGSOUNDSOURCE_H__
#define __LSS_STREAMINGSOUNDSOURCE_H__

#include "../LSSSoundLib.h"
#include "LSSStaticSoundSource.h"
#include "LSSStreamingSoundSourceStreamer.h"
#include "Vector/LSTLVectorPoD.h"


// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
// MACROS
// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
// The length, in microseconds of the buffers used for streaming.
#ifndef LSS_STREAMING_BUFFER_SIZE
#define LSS_STREAMING_BUFFER_SIZE                                                       ((1ULL * 1000000ULL) / 2ULL)
#endif  // #ifndef LSS_STREAMING_BUFFER_SIZE

namespace lss {

        class CStreamingSoundSource : public CStaticSoundSource {
        public :
                // == Various constructors.
                LSE_CALLCTOR                                                                            CStreamingSoundSource( LSUINT32 _ui32Id );
                virtual LSE_CALLCTOR                                                            ~CStreamingSoundSource();

                // == Functions.
                virtual LSS_SOUND_SOURCE LSE_CALL                                       GetType() const;

                virtual LSBOOL LSE_CALL                                                         Static() const;

                virtual LSVOID LSE_CALL                                                         SetBuffer( const CSoundBuffer * _psbBuffer );

                LSBOOL LSE_CALL                                                                         CreateStream( const IStreamingSoundSourceStreamer * _pssssSource,
                        CAllocator * _paAllocator );

                LSVOID LSE_CALL                                                                         Reset();

                virtual LSVOID LSE_CALL                                                         Tick( LSUINT64 _ui64TimeSinceLastUpdate );

                virtual LSBOOL LSE_CALL                                                         Play( LSUINT32 _ui32LoopCount );

                const IStreamingSoundSourceStreamer * LSE_CALL          GetStreamer() const;

                virtual LSBOOL LSE_CALL                                                         CanSoftReset() const;


        protected :
                // == Types.
                typedef struct LSS_STREAMING_BUFFER {
                        CSoundBuffer *                                                                  psbBuffer;

                        LSUINT64                                                                                ui64StartTime;

                        LSUINT64                                                                                ui64Length;

                        LSBOOL                                                                                  bUsed;
                } * LPLSS_STREAMING_BUFFER, * const LPCLSS_STREAMING_BUFFER;

                typedef CVectorPoD<LSS_STREAMING_BUFFER>                        LSS_STREAMING_BUFFER_LIST, * LPLSS_STREAMING_BUFFER_LIST, * const LPCLSS_STREAMING_BUFFER_LIST;


                // == Members.
                LSS_STREAMING_BUFFER_LIST                                                       m_sblBuffers;

                CAllocator *                                                                            m_paAllocator;

                // The source of audio data for our stream.
                const IStreamingSoundSourceStreamer *                           m_pssssSource;

                // The number of bytes in each buffer.
                LSUINT64                                                                                        m_ui64BufferSize;

                // How far into the sound have we queued?  In microseconds.
                LSUINT64                                                                                        m_ui64Queued;

                // Is the device activated?
                LSBOOL                                                                                          m_bHaveDevice;


                // == Functions.
                LSVOID LSE_CALL                                                                 SetSource( const IStreamingSoundSourceStreamer * _pssssSource );

                LSVOID LSE_CALL                                                                 CheckQueue();

                LSVOID LSE_CALL                                                                 CheckUnqueue();

                LSUINT32 LSE_CALL                                                               GetOldestBufferIndex() const;

                LSUINT32 LSE_CALL                                                               GetFreeBuffer() const;

                LSBOOL LSE_CALL                                                                 Buffer( LSUINT64 _ui64From, LSUINT64 _ui64Length );

                LSVOID LSE_CALL                                                                         UnBuffer( LSUINT32 _ui32Index );

                virtual LSBOOL LSE_CALL                                                 DeviceActivated();

                virtual LSVOID LSE_CALL                                                         DeviceWillClose();


        private :
                typedef CStaticSoundSource                                                      Parent;
        };

}       // namespace lss

#endif  // __LSS_STREAMINGSOUNDSOURCE_H__