1. adding some support for int and uint8 vector types

2. adding rpcbasic_register_variable_rw (be careful with this)
author: Tim O'Shea <tim.oshea753@gmail.com> 2013-02-06 18:02:04 -0500
committer: Tom Rondeau <trondeau@vt.edu> 2013-02-13 12:53:19 -0500
commit: 13a1f7092714e696ba78edb1e59e0cbbdf122eba (patch)
tree: 37c183351c0fb4f04f3b697a5deb522632494770 /gnuradio-core/src/lib/runtime
parent: 02a6d1cf7966079a857ab198d633aea9401b6f17 (diff)
2 files changed, 93 insertions, 10 deletions
diff --git a/gnuradio-core/src/lib/runtime/rpcpmtconverters_ice.cc b/gnuradio-core/src/lib/runtime/rpcpmtconverters_ice.cc
index c5502c7362..5aa7bc7cbd 100644
--- a/gnuradio-core/src/lib/runtime/rpcpmtconverters_ice.cc
+++ b/gnuradio-core/src/lib/runtime/rpcpmtconverters_ice.cc
@@ -55,11 +55,21 @@ rpcpmtconverter::from_pmt(const pmt::pmt_t& knob, const Ice::Current& c)
     size_t size(pmt::length(knob));
     const float* start((const float*) pmt::c32vector_elements(knob,size));
     return new GNURadio::KnobVecF(std::vector<float>(start,start+size*2));
+  } 
+  else if (pmt::is_s32vector(knob)) {
+    size_t size(pmt::length(knob));
+    const int* start((const int*) pmt::s32vector_elements(knob,size));
+    return new GNURadio::KnobVecI(std::vector<int>(start,start+size));
   }
   else if(pmt::is_f32vector(knob)) {
     size_t size(pmt::length(knob));
     const float* start((const float*) pmt::f32vector_elements(knob,size));
     return new GNURadio::KnobVecF(std::vector<float>(start,start+size));
+  } 
+  else if (pmt::is_u8vector(knob)) {
+    size_t size(pmt::length(knob));
+    const uint8_t* start((const uint8_t*) pmt::u8vector_elements(knob,size));
+    return new GNURadio::KnobVecC(std::vector<Ice::Byte>(start,start+size));
   }
   else {
     std::cerr << "Error: Don't know how to handle Knob Type (from): " << std::endl; assert(0);}
@@ -98,13 +108,18 @@ rpcpmtconverter::to_pmt(const GNURadio::KnobPtr& knob, const Ice::Current& c)
   else if(id == "KnobL") {
     GNURadio::KnobLPtr k(GNURadio::KnobLPtr::dynamicCast(knob));
     return pmt::mp((long)k->value);
+  } else if(id == "KnobVecC") {
+    GNURadio::KnobVecCPtr k(GNURadio::KnobVecCPtr::dynamicCast(knob));
+    return pmt::init_u8vector(k->value.size(), &k->value[0]);
+  } else if(id == "KnobVecI") {
+    GNURadio::KnobVecIPtr k(GNURadio::KnobVecIPtr::dynamicCast(knob));
+    return pmt::init_s32vector(k->value.size(), &k->value[0]);
   }
   //else if(id == "KnobVecF") {
   //  GNURadio::KnobVecFPtr k(GNURadio::KnobVecFPtr::dynamicCast(knob));
   //  return pmt::mp(k->value);
   //TODO: FLOAT!!!
   //TODO: VECTORS!!!
-
   else {
     std::cerr << "Error: Don't know how to handle Knob Type: " << id << std::endl; assert(0);
   }
diff --git a/gnuradio-core/src/lib/runtime/rpcregisterhelpers.h b/gnuradio-core/src/lib/runtime/rpcregisterhelpers.h
index 411b660eaa..1be3769ac8 100644
--- a/gnuradio-core/src/lib/runtime/rpcregisterhelpers.h
+++ b/gnuradio-core/src/lib/runtime/rpcregisterhelpers.h
@@ -221,6 +221,28 @@ public:
 };
 
 template<typename T>
+class rpcbasic_inserter<T,std::vector< int > >
+  : public virtual rpcinserter_base<T,std::vector< int > >
+{
+public:
+  rpcbasic_inserter(T* source, std::vector<int > (T::*func)() const)
+    : rpcinserter_base<T,std::vector<int > >(source, func)
+  {;}
+
+  rpcbasic_inserter(T* source, std::vector<int > (T::*func)())
+    : rpcinserter_base<T,std::vector<int > >(source, func)
+  {;}
+
+  pmt::pmt_t retrieve()
+  {
+    std::vector< int >
+      vec((rpcinserter_base<T,std::vector<int > >::
+	   _source->*rpcinserter_base<T,std::vector< int > >::_func)()); 
+    return pmt::init_s32vector(vec.size(), &vec[0]);
+  }
+};
+
+template<typename T>
 class rpcbasic_inserter<T,std::vector< std::complex<float> > >
   : public virtual rpcinserter_base<T,std::vector< std::complex<float> > >
 {
@@ -263,6 +285,26 @@ public:
   }
 };
 
+template<typename T> 
+class rpcbasic_inserter<T,std::vector< uint8_t> > 
+  : public virtual rpcinserter_base<T,std::vector< uint8_t > > {
+public:
+  rpcbasic_inserter(T* source, std::vector<uint8_t> (T::*func)() const) 
+    : rpcinserter_base<T,std::vector<uint8_t > >(source, func) 
+  {;}
+
+  rpcbasic_inserter(T* source, std::vector<uint8_t> (T::*func)()) 
+    : rpcinserter_base<T,std::vector<uint8_t> >(source, func) 
+  {;}
+
+  pmt::pmt_t retrieve() 
+  {
+    std::vector< uint8_t > vec((rpcinserter_base<T,std::vector<uint8_t> >::
+        _source->*rpcinserter_base<T,std::vector< uint8_t> >::_func)());
+    return pmt::init_u8vector(vec.size(), &vec[0]); 
+  }
+};
+
 template <typename T>
 struct rpc_register_base
 {
@@ -552,26 +594,22 @@ private:
 template<typename Tfrom>
 class rpcbasic_register_variable : public rpcbasic_base
 {
-private:
+protected:
   rpcbasic_register_get< rpcbasic_register_variable<Tfrom>, Tfrom > d_rpc_reg;
   Tfrom *d_variable;
   Tfrom get() { return *d_variable; }
-
 public:
   // empty constructor which should never be called but needs to exist for ues in varous STL data structures
+  void setptr(Tfrom* _variable){  rpcbasic_register_variable<Tfrom>::d_variable = _variable; }
   rpcbasic_register_variable() :
-    d_rpc_reg("FAIL", "FAIL", this, -1, &rpcbasic_register_variable::get,
+    d_rpc_reg("FAIL", "FAIL", this, &rpcbasic_register_variable::get,
 	      pmt::PMT_NIL, pmt::PMT_NIL, pmt::PMT_NIL, DISPNULL,
 	      "FAIL", "FAIL", RPC_PRIVLVL_MIN),
     d_variable(NULL)
   {
-    std::cerr << "ERROR: rpcbasic_register_variable called with no args. "
-	      << "If this happens, someone has tried to use rpcbasic_register_variable incorrectly.\n";
-    assert(0);
+    throw std::runtime_error("ERROR: rpcbasic_register_variable called with no args. If this happens, someone has tried to use rpcbasic_register_variable incorrectly.");
   };
 
-  void set(Tfrom* _variable) { d_variable = _variable; }
-
   rpcbasic_register_variable(const std::string& namebase,
 			     const char* functionbase,
 			     Tfrom *variable,
@@ -584,8 +622,38 @@ public:
 	      min, max, def, units_, desc_, minpriv_, display_),
     d_variable(variable)
   {
-    //std::cerr << "REGISTERING VAR: " << serial << " " << desc_ << std::endl;
+    //std::cerr << "REGISTERING VAR: " << " " << desc_ << std::endl;
   }
 };
 
+template<typename Tfrom> class rpcbasic_register_variable_rw : public rpcbasic_register_variable<Tfrom> {
+  private:
+    rpcbasic_register_set< rpcbasic_register_variable_rw<Tfrom>, Tfrom > d_rpc_regset;
+  public:
+    // empty constructor which should never be called but needs to exist for ues in varous STL data structures
+    rpcbasic_register_variable_rw()  :
+            d_rpc_regset("FAIL","FAIL",this,&rpcbasic_register_variable<Tfrom>::get,pmt::PMT_NIL,pmt::PMT_NIL,pmt::PMT_NIL,DISPNULL,"FAIL","FAIL",RPC_PRIVLVL_MIN)
+        {
+        throw std::runtime_error("ERROR: rpcbasic_register_variable_rw called with no args. if this happens someone used rpcbasic_register_variable_rw incorrectly.\n");
+        };
+    void set(Tfrom _variable){  *(rpcbasic_register_variable<Tfrom>::d_variable) = _variable; }
+    rpcbasic_register_variable_rw(
+        const std::string& namebase,
+        const char* functionbase,
+        Tfrom *variable,
+        const pmt::pmt_t &min, const pmt::pmt_t &max, const pmt::pmt_t &def,
+        const char* units_ = "",
+        const char* desc_ = "",
+        priv_lvl_t minpriv = RPC_PRIVLVL_MIN,
+        DisplayType display_=DISPNULL) :
+            rpcbasic_register_variable<Tfrom>(namebase,functionbase,variable,min,max,def,units_,desc_),
+            d_rpc_regset(namebase,functionbase,this,&rpcbasic_register_variable_rw::set,min,max,def,units_,desc_,minpriv,display_)
+         {
+        // no action
+        }
+};
+
+
+
+
 #endif
author	Tim O'Shea <tim.oshea753@gmail.com>	2013-02-06 18:02:04 -0500
committer	Tom Rondeau <trondeau@vt.edu>	2013-02-13 12:53:19 -0500
commit	13a1f7092714e696ba78edb1e59e0cbbdf122eba (patch)
tree	37c183351c0fb4f04f3b697a5deb522632494770 /gnuradio-core/src/lib/runtime
parent	02a6d1cf7966079a857ab198d633aea9401b6f17 (diff)