flush period int->double
authorPritish Jetley <pjetley2@illinois.edu>
Wed, 16 Nov 2011 20:09:15 +0000 (14:09 -0600)
committerPritish Jetley <pjetley2@illinois.edu>
Wed, 16 Nov 2011 20:09:15 +0000 (14:09 -0600)
src/libs/ck-libs/MeshStreamer/MeshStreamer.ci
src/libs/ck-libs/MeshStreamer/MeshStreamer.h

index b1e527bb29c3091c2d961787bd64da391069f993..66e21a46be40c2b874e559065c91e55f88f680b8 100644 (file)
@@ -21,7 +21,7 @@ module MeshStreamer {
     entry MeshStreamer(int totalBufferCapacity, int numRows, 
                       int numColumns, int numPlanes, 
                       const CProxy_MeshStreamerClient<dtype> &clientProxy, 
-                       int yieldFlag = 0, int progressPeriodInMs = -1);   
+                       int yieldFlag = 0, double progressPeriodInMs = -1.0);   
     // entry void insertData(CmiUInt8, int); 
     entry void receiveAggregateData(MeshStreamerMessage<dtype> *msg);
     // entry void receivePersonalizedData(MeshStreamerMessage *msg);
index 0ea84af2bd9295be900cfb1cb62a6a6d423b07d5..c6798f0b108ed477aa3123dbd560601288b37c02 100644 (file)
@@ -103,7 +103,7 @@ private:
     CkCallback   userCallback_;
     int yieldFlag_;
 
-    int progressPeriodInMs_; 
+    double progressPeriodInMs_; 
     bool isPeriodicFlushEnabled_; 
     double timeOfLastSend_; 
 
@@ -131,7 +131,7 @@ public:
     MeshStreamer(int totalBufferCapacity, int numRows, 
                 int numColumns, int numPlanes, 
                 const CProxy_MeshStreamerClient<dtype> &clientProxy,
-                 int yieldFlag = 0, int progressPeriodInMs = -1);
+                 int yieldFlag = 0, double progressPeriodInMs = -1.0);
     ~MeshStreamer();
 
       // entry
@@ -171,7 +171,7 @@ template <class dtype>
 MeshStreamer<dtype>::MeshStreamer(int totalBufferCapacity, int numRows, 
                            int numColumns, int numPlanes, 
                            const CProxy_MeshStreamerClient<dtype> &clientProxy,
-                          int yieldFlag, int progressPeriodInMs): yieldFlag_(yieldFlag) {
+                          int yieldFlag, double progressPeriodInMs): yieldFlag_(yieldFlag) {
   // limit total number of messages in system to totalBufferCapacity
   //   but allocate a factor BUCKET_SIZE_FACTOR more space to take
   //   advantage of nonuniform filling of buckets