diff options
| -rw-r--r-- | src/dabOutput/dabOutput.h | 2 | ||||
| -rw-r--r-- | src/dabOutput/dabOutputFifo.cpp | 58 |
2 files changed, 58 insertions, 2 deletions
diff --git a/src/dabOutput/dabOutput.h b/src/dabOutput/dabOutput.h index d68cd9c..9032297 100644 --- a/src/dabOutput/dabOutput.h +++ b/src/dabOutput/dabOutput.h @@ -154,6 +154,7 @@ class DabOutputFifo : public DabOutputFile DabOutputFifo() : DabOutputFile() {} ~DabOutputFifo() {} + int Open(const char* filename); int Write(void* buffer, int size); std::string get_info() const { @@ -405,4 +406,3 @@ class DabOutputZMQ : public DabOutput #endif #endif - diff --git a/src/dabOutput/dabOutputFifo.cpp b/src/dabOutput/dabOutputFifo.cpp index 6b1c016..1bc4d92 100644 --- a/src/dabOutput/dabOutputFifo.cpp +++ b/src/dabOutput/dabOutputFifo.cpp @@ -27,8 +27,65 @@ #include <cstring> #include <fcntl.h> #include <limits.h> +#include <sys/types.h> // mkfifo +#include <sys/stat.h> // mkfifo #include "dabOutput.h" +int DabOutputFifo::Open(const char* filename) +{ + char* token = strchr((char*)filename, '?'); + if (token != NULL) { + *(token++) = 0; + char* nextPair; + char* key; + char* value; + // Go through all the &stuff=foo pairs + // Only the key "type" is supported + do { + nextPair = strchr(token, '&'); + if (nextPair != NULL) { + *nextPair = 0; + } + key = token; + value = strchr(token, '='); + if (value != NULL) { + *(value++) = 0; + if (strcmp(key, "type") == 0) { + if (strcmp(value, "raw") == 0) { + this->type_ = ETI_FILE_TYPE_RAW; + break; + } else if (strcmp(value, "framed") == 0) { + this->type_ = ETI_FILE_TYPE_FRAMED; + break; + } else if (strcmp(value, "streamed") == 0) { + this->type_ = ETI_FILE_TYPE_STREAMED; + break; + } else { + etiLog.log(error, + "File type '%s' is not supported.\n", value); + return -1; + } + } + else { + etiLog.log(warn, "Parameter '%s' unknown\n", key); + } + } + } while (nextPair != NULL); + } + + this->file_ = mkfifo(filename, 0666); + if (this->file_ == -1) { + perror(filename); + return -2; + } + this->file_ = open(filename, O_WRONLY | O_CREAT | O_TRUNC | O_BINARY, 0666); + if (this->file_ == -1) { + perror(filename); + return -1; + } + return 0; +} + int DabOutputFifo::Write(void* buffer, int size) { @@ -71,4 +128,3 @@ FIFO_WRITE_ERROR: perror("Error while writting to file"); return -1; } - |