+Data *W1Device::get_data() {
+ Data *ret_val;
+ vector<double> *vect;
+
+ ret_val = NULL;
+ vect = get_raw_data();
+ if (vect != NULL) {
+ ret_val = new Data(vect, get_unit());
+ cache(ret_val);
+ delete(vect);
+ log_debug("%s returning new data\n", id.c_str());
+ }
+ else {
+ // read old already saved data
+ log_debug("%s returning old saved data\n", id.c_str());
+ ret_val = reader->get_latest_data();
+ }
+ return ret_val;
+}
+
+void W1Device::cache(Data *new_data) {
+ Data *data;
+ int dec_precision;
+
+ data = new_data->clone();
+ pthread_mutex_lock(&plock);
+ memory_cache.push_back(data);
+ if (memory_cache.size() > 5) {
+ dec_precision = get_data_decimal_precision();
+ StoreDay::save(id, &memory_cache, dec_precision);
+ while(memory_cache.empty() == false) {
+ data = memory_cache.back();
+ memory_cache.pop_back();
+ delete(data);
+ }
+ }
+ pthread_mutex_unlock(&plock);
+}
+
+void W1Device::save_and_clean_cache() {
+ Data *data;
+ int dec_precision;
+
+ dec_precision = get_data_decimal_precision();
+ pthread_mutex_lock(&plock);
+ log_debug("memory cache size: %d\n", memory_cache.size());
+ StoreDay::save(id, &memory_cache, dec_precision);
+ while(memory_cache.empty() == false) {
+ data = memory_cache.back();
+ memory_cache.pop_back();
+ delete(data);
+ }
+ pthread_mutex_unlock(&plock);
+}