xref: /aosp_15_r20/external/oboe/src/flowgraph/MultiToManyConverter.cpp (revision 05767d913155b055644481607e6fa1e35e2fe72c)
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 Wu MultiToManyConverter::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 Wu int32_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