ConvolverReader.h

Go to the documentation of this file.

/*******************************************************************************
* Copyright 2015-2016 Juan Francisco Crespo Galán
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
*   http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
******************************************************************************/
 
#pragma once
 
#include "IReader.h"
#include "ISound.h"
#include "Convolver.h"
#include "ImpulseResponse.h"
#include "util/FFTPlan.h"
#include "util/ThreadPool.h"
 
#include <memory>
#include <vector>
#include <future>
 
AUD_NAMESPACE_BEGIN
 
class AUD_API ConvolverReader : public IReader
{
private:
    int m_position;
 
    std::shared_ptr<IReader> m_reader;
 
    std::shared_ptr<ImpulseResponse> m_ir;
    
    int m_N;
 
    int m_M;
 
    int m_L;
 
    std::vector<std::unique_ptr<Convolver>> m_convolvers;
 
    sample_t* m_outBuffer;
 
    std::vector<sample_t*> m_vecInOut;
 
    int m_outBufferPos;
    
    int m_eOutBufLen;
 
    int m_outBufLen;
 
    bool m_eosReader;
 
    bool m_eosTail;
 
    int m_inChannels;
 
    int m_irChannels;
 
    int m_nChannelThreads;
 
    int m_lastLengthIn;
 
    std::shared_ptr<ThreadPool> m_threadPool;
 
    std::vector<std::future<int>> m_futures;
 
    // delete copy constructor and operator=
    ConvolverReader(const ConvolverReader&) = delete;
    ConvolverReader& operator=(const ConvolverReader&) = delete;
 
public:
    ConvolverReader(std::shared_ptr<IReader> reader, std::shared_ptr<ImpulseResponse> ir, std::shared_ptr<ThreadPool> threadPool, std::shared_ptr<FFTPlan> plan);
    virtual ~ConvolverReader();
 
    virtual bool isSeekable() const;
    virtual void seek(int position);
    virtual int getLength() const;
    virtual int getPosition() const;
    virtual Specs getSpecs() const;
    virtual void read(int& length, bool& eos, sample_t* buffer);
 
private:
    void divideByChannel(const sample_t* buffer, int len);
 
    void joinByChannel(int start, int len);
 
    void loadBuffer();
 
    int threadFunction(int id, bool input);
};
 
AUD_NAMESPACE_END