mirror/SDRPlusPlus
0
0
Fork 0
mirror of https://github.com/AlexandreRouma/SDRPlusPlus.git synced 2024-12-25 02:18:30 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #168 from mbiette/fix_typo

Browse Source 
Fix typo untyped_steam -> untyped_stream
This commit is contained in:
AlexandreRouma 2021-07-13 00:17:10 +02:00 committed by GitHub
commit ff38cefe11
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
core/src/dsp/block.h
View File

@ -87,19 +87,19 @@ namespace dsp {
ctrlMtx.unlock(); ctrlMtx.unlock();
} }
void registerInput(untyped_steam* inStream) { void registerInput(untyped_stream* inStream) {
inputs.push_back(inStream); inputs.push_back(inStream);
} }
void unregisterInput(untyped_steam* inStream) { void unregisterInput(untyped_stream* inStream) {
inputs.erase(std::remove(inputs.begin(), inputs.end(), inStream), inputs.end()); inputs.erase(std::remove(inputs.begin(), inputs.end(), inStream), inputs.end());
} }
void registerOutput(untyped_steam* outStream) { void registerOutput(untyped_stream* outStream) {
outputs.push_back(outStream); outputs.push_back(outStream);
} }
void unregisterOutput(untyped_steam* outStream) { void unregisterOutput(untyped_stream* outStream) {
outputs.erase(std::remove(outputs.begin(), outputs.end(), outStream), outputs.end()); outputs.erase(std::remove(outputs.begin(), outputs.end(), outStream), outputs.end());
} }
@ -133,8 +133,8 @@ namespace dsp {
std::mutex ctrlMtx; std::mutex ctrlMtx;
std::vector<untyped_steam*> inputs; std::vector<untyped_stream*> inputs;
std::vector<untyped_steam*> outputs; std::vector<untyped_stream*> outputs;
bool running = false; bool running = false;
bool tempStopped = false; bool tempStopped = false;

4
core/src/dsp/stream.h
View File

@ -7,7 +7,7 @@
#define STREAM_BUFFER_SIZE 1000000 #define STREAM_BUFFER_SIZE 1000000
namespace dsp { namespace dsp {
class untyped_steam { class untyped_stream {
public: public:
virtual bool swap(int size) { return false; } virtual bool swap(int size) { return false; }
virtual int read() { return -1; } virtual int read() { return -1; }
@ -19,7 +19,7 @@ namespace dsp {
}; };
template <class T> template <class T>
class stream : public untyped_steam { class stream : public untyped_stream {
public: public:
stream() { stream() {
writeBuf = (T*)volk_malloc(STREAM_BUFFER_SIZE * sizeof(T), volk_get_alignment()); writeBuf = (T*)volk_malloc(STREAM_BUFFER_SIZE * sizeof(T), volk_get_alignment());