nthread as int

psrdada_cpp/effelsberg/edd/EDDPolnMerge.hpp

@@ -12,7 +12,7 @@ namespace edd {
 class EDDPolnMerge
 {
 public:
-    EDDPolnMerge(std::size_t nsamps_per_heap, std::size_t npol, std::size_t nthreads, DadaWriteClient& writer);
+    EDDPolnMerge(std::size_t nsamps_per_heap, std::size_t npol, std::int nthreads, DadaWriteClient& writer);
     ~EDDPolnMerge();
 
     /**
@@ -39,7 +39,7 @@ public:
 private:
     std::size_t _nsamps_per_heap;
     std::size_t _npol;
-    std::size_t _nthreads;	
+    int _nthreads;	
     DadaWriteClient& _writer;
 };
 

psrdada_cpp/effelsberg/edd/src/EDDPolnMerge.cpp

@@ -31,7 +31,7 @@ void merge2pol(char const *buf, char *out)
    }
   }
 
-    EDDPolnMerge::EDDPolnMerge(std::size_t nsamps_per_heap, std::size_t npol, std::size_t nthreads, DadaWriteClient& writer)
+    EDDPolnMerge::EDDPolnMerge(std::size_t nsamps_per_heap, std::size_t npol, int nthreads, DadaWriteClient& writer)
     : _nsamps_per_heap(nsamps_per_heap)
     , _npol(npol)
     ,_nthreads(nthreads)

psrdada_cpp/effelsberg/edd/src/EDDPolnMerge_cli.cpp

@@ -25,7 +25,7 @@ int main(int argc, char** argv)
     	key_t output_key;
     	std::size_t npol;
     	std::size_t nsamps_per_heap;
-        std::size_t nthreads;
+        int nthreads;
         /** Define and parse the program options
         */
         namespace po = boost::program_options;
@@ -52,7 +52,7 @@ int main(int argc, char** argv)
         ("npol,p", po::value<std::size_t>(&npol)->default_value(2),
             "Value of number of pol")
 
-        ("nthreads,n", po::value<std::size_t>(&nthreads)->default_value(2),
+        ("nthreads,n", po::value<int>(&nthreads)->default_value(2),
             "Value of number of threads")
 
         ("nsamps_per_heap,n", po::value<std::size_t>(&nsamps_per_heap)->default_value(4096),