aboutsummaryrefslogtreecommitdiffstats
path: root/Dummy_Streaming.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'Dummy_Streaming.cpp')
-rw-r--r--Dummy_Streaming.cpp296
1 files changed, 296 insertions, 0 deletions
diff --git a/Dummy_Streaming.cpp b/Dummy_Streaming.cpp
new file mode 100644
index 0000000..493800d
--- /dev/null
+++ b/Dummy_Streaming.cpp
@@ -0,0 +1,296 @@
+/*
+ * The MIT License (MIT)
+ *
+ * Copyright (c) 2018 Matthias P. Braendli
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in
+ * all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+ * THE SOFTWARE.
+ */
+
+#include "SoapyDummy.hpp"
+#include <SoapySDR/Logger.hpp>
+#include <SoapySDR/Formats.hpp>
+#include <chrono>
+#include <thread>
+#include <algorithm>
+
+std::vector<std::string> SoapyDummy::getStreamFormats(const int direction, const size_t channel) const
+{
+ std::vector<std::string> formats;
+
+ formats.push_back(SOAPY_SDR_CS8);
+ formats.push_back(SOAPY_SDR_CS16);
+ formats.push_back(SOAPY_SDR_CF32);
+ formats.push_back(SOAPY_SDR_CF64);
+
+ return formats;
+}
+
+std::string SoapyDummy::getNativeStreamFormat(const int direction, const size_t channel, double &fullScale) const
+{
+ fullScale = 1.0;
+ return SOAPY_SDR_CF32;
+}
+
+SoapySDR::ArgInfoList SoapyDummy::getStreamArgsInfo(const int direction, const size_t channel) const
+{
+ SoapySDR::ArgInfoList streamArgs;
+
+ SoapySDR::ArgInfo buffersArg;
+ buffersArg.key="buffers";
+ buffersArg.value = std::to_string(1);
+ buffersArg.name = "Buffer Count";
+ buffersArg.description = "Number of buffers per read.";
+ buffersArg.units = "buffers";
+ buffersArg.type = SoapySDR::ArgInfo::INT;
+ streamArgs.push_back(buffersArg);
+
+ return streamArgs;
+}
+
+SoapySDR::Stream* SoapyDummy::setupStream(
+ const int direction,
+ const std::string &format,
+ const std::vector<size_t> &channels,
+ const SoapySDR::Kwargs &args )
+{
+ if ( channels.size() > 1 or( channels.size() > 0 and channels.at( 0 ) != 0 ) ) {
+ throw std::runtime_error( "setupStream invalid channel selection" );
+ }
+
+ if(direction==SOAPY_SDR_RX){
+
+ if ( format == SOAPY_SDR_CS8 )
+ {
+ SoapySDR_log( SOAPY_SDR_DEBUG, "Using format CS8." );
+ }else if ( format == SOAPY_SDR_CS16 )
+ {
+ SoapySDR_log( SOAPY_SDR_DEBUG, "Using format CS16." );
+ }else if ( format == SOAPY_SDR_CF32 )
+ {
+ SoapySDR_log( SOAPY_SDR_DEBUG, "Using format CF32." );
+ }else if(format==SOAPY_SDR_CF64){
+ SoapySDR_log( SOAPY_SDR_DEBUG, "Using format CF64." );
+ }else throw std::runtime_error( "setupStream invalid format " + format );
+
+ return RX_STREAM;
+ } else if(direction==SOAPY_SDR_TX){
+
+ if ( format == SOAPY_SDR_CS8 )
+ {
+ SoapySDR_log( SOAPY_SDR_DEBUG, "Using format CS8." );
+ }else if ( format == SOAPY_SDR_CS16 )
+ {
+ SoapySDR_log( SOAPY_SDR_DEBUG, "Using format CS16." );
+ }else if ( format == SOAPY_SDR_CF32 )
+ {
+ SoapySDR_log( SOAPY_SDR_DEBUG, "Using format CF32." );
+ }else if(format==SOAPY_SDR_CF64){
+ SoapySDR_log( SOAPY_SDR_DEBUG, "Using format CF64." );
+ }else throw std::runtime_error( "setupStream invalid format " + format );
+
+ return TX_STREAM;
+ }
+ else {
+ throw std::runtime_error("Invalid direction");
+ }
+}
+
+void SoapyDummy::closeStream( SoapySDR::Stream *stream )
+{
+ if (stream == RX_STREAM) {
+ } else if (stream == TX_STREAM) {
+ }
+}
+
+
+size_t SoapyDummy::getStreamMTU( SoapySDR::Stream *stream ) const
+{
+ if(stream == RX_STREAM){
+ return m_rxstream.mtu;
+ } else if(stream == TX_STREAM){
+ return m_txstream.mtu;
+ } else {
+ throw std::runtime_error("Invalid stream");
+ }
+}
+
+int SoapyDummy::activateStream(
+ SoapySDR::Stream *stream,
+ const int flags,
+ const long long timeNs,
+ const size_t numElems )
+{
+ if (stream == RX_STREAM) {
+ SoapySDR_logf(SOAPY_SDR_DEBUG, "Start RX");
+ }
+ else if (stream == TX_STREAM) {
+ SoapySDR_logf(SOAPY_SDR_DEBUG, "Start TX");
+ }
+
+ return 0;
+}
+
+
+int SoapyDummy::deactivateStream(
+ SoapySDR::Stream *stream,
+ const int flags,
+ const long long timeNs )
+{
+
+ if (stream == RX_STREAM) {
+ }
+ else if (stream == TX_STREAM) {
+ }
+ return 0;
+}
+
+
+int SoapyDummy::readStream(
+ SoapySDR::Stream *stream,
+ void * const *buffs,
+ const size_t numElems,
+ int &flags,
+ long long &timeNs,
+ const long timeoutUs )
+{
+ if (stream != RX_STREAM){
+ return SOAPY_SDR_NOT_SUPPORTED;
+ }
+
+ size_t returnedElems = std::min(numElems,this->getStreamMTU(stream));
+ return returnedElems;
+}
+
+int SoapyDummy::writeStream(
+ SoapySDR::Stream *stream,
+ const void * const *buffs,
+ const size_t numElems,
+ int &flags,
+ const long long timeNs,
+ const long timeoutUs )
+{
+ if (stream != TX_STREAM){
+ return SOAPY_SDR_NOT_SUPPORTED;
+ }
+
+ size_t returnedElems = std::min(numElems,this->getStreamMTU(stream));
+
+ return returnedElems;
+}
+
+
+int SoapyDummy::readStreamStatus(
+ SoapySDR::Stream *stream,
+ size_t &chanMask,
+ int &flags,
+ long long &timeNs,
+ const long timeoutUs
+ ){
+
+ if(stream != TX_STREAM){
+ return SOAPY_SDR_NOT_SUPPORTED;
+ }
+
+ return SOAPY_SDR_TIMEOUT;
+}
+
+int SoapyDummy::acquireReadBuffer(
+ SoapySDR::Stream *stream,
+ size_t &handle,
+ const void **buffs,
+ int &flags,
+ long long &timeNs,
+ const long timeoutUs)
+{
+ if (stream != RX_STREAM){
+ return SOAPY_SDR_NOT_SUPPORTED;
+ }
+
+ return this->getStreamMTU(stream);
+}
+
+void SoapyDummy::releaseReadBuffer(
+ SoapySDR::Stream *stream,
+ const size_t handle)
+{
+ if(stream != RX_STREAM){
+ throw std::runtime_error("Invalid stream");
+ }
+}
+
+int SoapyDummy::acquireWriteBuffer(
+ SoapySDR::Stream *stream,
+ size_t &handle,
+ void **buffs,
+ const long timeoutUs)
+{
+
+ if(stream != TX_STREAM){
+ return SOAPY_SDR_NOT_SUPPORTED;
+ }
+
+ return this->getStreamMTU(stream);
+}
+
+void SoapyDummy::releaseWriteBuffer(
+ SoapySDR::Stream *stream,
+ const size_t handle,
+ const size_t numElems,
+ int &flags,
+ const long long timeNs)
+{
+ if (stream == TX_STREAM) {
+ }
+ else {
+ throw std::runtime_error("Invalid stream");
+ }
+}
+
+size_t SoapyDummy::getNumDirectAccessBuffers(
+ SoapySDR::Stream *stream)
+{
+ if (stream == RX_STREAM) {
+ return m_rxstream.buf_num;
+ }
+ else if(stream == TX_STREAM){
+ return m_rxstream.buf_num;
+ }
+ else {
+ throw std::runtime_error("Invalid stream");
+ }
+}
+
+int SoapyDummy::getDirectAccessBufferAddrs(
+ SoapySDR::Stream *stream,
+ const size_t handle,
+ void **buffs)
+{
+
+ if (stream == RX_STREAM) {
+ buffs[0]=(void *)m_rxstream.buf;
+ }
+ else if (stream == TX_STREAM) {
+ buffs[0]=(void *)m_txstream.buf;
+ }
+ else {
+ throw std::runtime_error("Invalid stream");
+ }
+
+ return 0;
+}
generated by cgit v1.2.3 (git 2.39.1) at 2025-03-21 12:12:40 +0000