Changeset 17667 for trunk/Mars/mcore

Timestamp:

04/14/14 12:36:01 (11 years ago)

Author:

lyard

Message:

fixed uint32 bug for max available memory

File:

• trunk/Mars/mcore/zofits.h (modified) (5 diffs)

trunk/Mars/mcore/zofits.h

@@ -81 +81 @@
         /// static setter for the default number of threads to use. -1 means all available physical cores
         static uint32_t DefaultNumThreads(const uint32_t &_n=-2) { static uint32_t n=0; if (int32_t(_n)<-1) n=_n; return n; }
-        static uint32_t DefaultMaxMemory(const uint32_t &_n=0) { static uint32_t n=1000000; if (_n>0) n=_n; return n; }
+        static uint64_t DefaultMaxMemory(const uint64_t &_n=0) { static uint64_t n=1000000; if (_n>0) n=_n; return n; }
         static uint32_t DefaultMaxNumTiles(const uint32_t &_n=0) { static uint32_t n=1000; if (_n>0) n=_n; return n; }
         static uint32_t DefaultNumRowsPerTile(const uint32_t &_n=0) { static uint32_t n=100; if (_n>0) n=_n; return n; }
@@ -91 +91 @@
         zofits(uint32_t numTiles    = DefaultMaxNumTiles(),
                uint32_t rowPerTile  = DefaultNumRowsPerTile(),
-               uint32_t maxUsableMem= DefaultMaxMemory()) : ofits(),
+               uint64_t maxUsableMem= DefaultMaxMemory()) : ofits(),
             fMemPool(0, maxUsableMem*1000),
             fWriteToDiskQueue(std::bind(&zofits::WriteBufferToDisk, this, std::placeholders::_1), false)
@@ -106 +106 @@
                uint32_t numTiles    = DefaultMaxNumTiles(),
                uint32_t rowPerTile  = DefaultNumRowsPerTile(),
-               uint32_t maxUsableMem= DefaultMaxMemory()) : ofits(fname),
+               uint64_t maxUsableMem= DefaultMaxMemory()) : ofits(fname),
                    fMemPool(0, maxUsableMem*1000),
                    fWriteToDiskQueue(std::bind(&zofits::WriteBufferToDisk, this, std::placeholders::_1), false)
@@ -155 +155 @@
                 //start the compression queues
                 for (auto it=fCompressionQueues.begin(); it!= fCompressionQueues.end(); it++)
+                {
                     it->start();
-
+                }
                 //start the disk writer
                 fWriteToDiskQueue.start();
@@ -535 +536 @@
 
         /// Overload of the ofits method. Just calls the zofits specific one with default, uncompressed options for this column
-        bool AddColumn(uint32_t cnt, char typechar, const std::string& name, const std::string& unit,
-                       const std::string& comment="", bool addHeaderKeys=true)
+        bool AddColumn(uint32_t cnt,
+                       char typechar,
+                       const std::string& name,
+                       const std::string& unit,
+                       const std::string& comment="",
+                       bool addHeaderKeys=true)
         {
             return AddColumn(FITS::kFactRaw, cnt, typechar, name, unit, comment, addHeaderKeys);