sound4.impact.cl-pipe2.cpp

Go to the documentation of this file.

#include <unistd.h>
#include <iostream>
#include <strings.h>
#include <sys/types.h>
#include <filesystem>
 
#include "sound4.impact.cl.hpp"
 
using namespace sound4::impact;
 
 
std::string GetEnv(const std::string& name)
{
    char *data=getenv(name.c_str());
    if (!data) return {};
    return std::string(data);
}
 
 
// Reads from stdin, write to stdout
void ProcessLoop(CInstance &instance)
{
bool stopthread=false;
 
    #if defined(_WIN32) || defined(WIN32)
        // Windows: The stdin, stdout, and stderr streams always open in text mode by default
        _setmode(_fileno(stdin), _O_BINARY);
        _setmode(_fileno(stdout), _O_BINARY);
    #endif
    
    while (!stopthread)
    {
        // Read a chunk from stdin
        if (std::fread(instance.GetBufferIn(), sizeof(float), InputSampleSize, stdin) != InputSampleSize) {
            std::cerr << "ProcessLoop: input stopped"<< std::endl;
            stopthread=true;
            break;
        }
        if (stopthread) break;
        // Process it
        instance.ProcessAudio();
        // Write it to stdout
        if (fwrite(instance.GetBufferOut(), sizeof(float), OutputSampleSize, stdout) != OutputSampleSize) {
            std::cerr << "Failed to write audio output" << std::endl;
            stopthread=true;
        }
    }
}
 
void DoLog(LogSeverity severity,const std::string& msg)
{
    std::cerr << msg << std::endl;
}
 
int main(int argc, const char **argv)
{
    SetLogSeverity(verbose5);
    SetLoggerCallback(DoLog);
 
    CInstance instance;
    int listen_port = 8080;
 
    // Get credentials from environment
    auto LoginKey=GetEnv("S4LOGINKEY");
    if (LoginKey.empty()) {
        LoginKey=GetEnv("S4USERID");
    }
    auto RadioName=GetEnv("RADIO_NAME");
    auto KeyId=GetEnv("S4_AWS_ACCESS_KEY_ID");
    auto AccessKey=GetEnv("S4_AWS_SECRET_ACCESS_KEY");
 
    instance.SetParam("ADMIN_USER","admin");
    instance.SetParam("ADMIN_SECRET","admin");
 
    std::cout << "Creating" << std::endl;
    if (!instance.Create(LoginKey, RadioName, KeyId, AccessKey, std::filesystem::path())) {
        std::cerr << "Failed to create the processing instance" << std::endl;
        return 1;
    }
 
    std::cout << "Starting web server" << std::endl;
    if (!instance.StartWebServer(listen_port,0)) {
        std::cerr << "Failed to create the web server on port " << listen_port << std::endl;
        return 1;
    }
 
    ProcessLoop(instance);
 
    std::cout << "Stopping now" << std::endl;
    instance.Stop();
 
    std::cout << "End" << std::endl;
    return 0;
}