1*05767d91SRobert Wu /* 2*05767d91SRobert Wu * Copyright 2021 The Android Open Source Project 3*05767d91SRobert Wu * 4*05767d91SRobert Wu * Licensed under the Apache License, Version 2.0 (the "License"); 5*05767d91SRobert Wu * you may not use this file except in compliance with the License. 6*05767d91SRobert Wu * You may obtain a copy of the License at 7*05767d91SRobert Wu * 8*05767d91SRobert Wu * http://www.apache.org/licenses/LICENSE-2.0 9*05767d91SRobert Wu * 10*05767d91SRobert Wu * Unless required by applicable law or agreed to in writing, software 11*05767d91SRobert Wu * distributed under the License is distributed on an "AS IS" BASIS, 12*05767d91SRobert Wu * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13*05767d91SRobert Wu * See the License for the specific language governing permissions and 14*05767d91SRobert Wu * limitations under the License. 15*05767d91SRobert Wu */ 16*05767d91SRobert Wu 17*05767d91SRobert Wu #include <unistd.h> 18*05767d91SRobert Wu #include "FlowGraphNode.h" 19*05767d91SRobert Wu #include "MultiToManyConverter.h" 20*05767d91SRobert Wu 21*05767d91SRobert Wu using namespace FLOWGRAPH_OUTER_NAMESPACE::flowgraph; 22*05767d91SRobert Wu MultiToManyConverter(int32_t channelCount)23*05767d91SRobert WuMultiToManyConverter::MultiToManyConverter(int32_t channelCount) 24*05767d91SRobert Wu : outputs(channelCount) 25*05767d91SRobert Wu , input(*this, channelCount) { 26*05767d91SRobert Wu for (int i = 0; i < channelCount; i++) { 27*05767d91SRobert Wu outputs[i] = std::make_unique<FlowGraphPortFloatOutput>(*this, 1); 28*05767d91SRobert Wu } 29*05767d91SRobert Wu } 30*05767d91SRobert Wu 31*05767d91SRobert Wu MultiToManyConverter::~MultiToManyConverter() = default; 32*05767d91SRobert Wu onProcess(int32_t numFrames)33*05767d91SRobert Wuint32_t MultiToManyConverter::onProcess(int32_t numFrames) { 34*05767d91SRobert Wu int32_t channelCount = input.getSamplesPerFrame(); 35*05767d91SRobert Wu 36*05767d91SRobert Wu for (int ch = 0; ch < channelCount; ch++) { 37*05767d91SRobert Wu const float *inputBuffer = input.getBuffer() + ch; 38*05767d91SRobert Wu float *outputBuffer = outputs[ch]->getBuffer(); 39*05767d91SRobert Wu 40*05767d91SRobert Wu for (int i = 0; i < numFrames; i++) { 41*05767d91SRobert Wu *outputBuffer++ = *inputBuffer; 42*05767d91SRobert Wu inputBuffer += channelCount; 43*05767d91SRobert Wu } 44*05767d91SRobert Wu } 45*05767d91SRobert Wu 46*05767d91SRobert Wu return numFrames; 47*05767d91SRobert Wu } 48